Skip to content

Repository Factory for Unit Of Work #149

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
noufionline wants to merge 11 commits into
base: develop
Choose a base branch
from
Open

Repository Factory for Unit Of Work #149

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
b8696c8
Create UnitOfWork
noufionline Sep 28, 2016
5df6661
Create UnitOfWork
noufionline Sep 28, 2016
3cccfd8
UnitOfWork with RepositoryFactory
noufionline Sep 28, 2016
3bcfd91
Generic Repository Factory
noufionline Sep 28, 2016
3bccd1b
Client Helper class to consume service
noufionline Sep 28, 2016
04bf544
Merge pull request #1 from noufionline/noufionline-patch-1
noufionline Sep 28, 2016
3ce0744
Update ServiceBase
noufionline Sep 28, 2016
0542362
Delete UnitOfWork
noufionline Sep 28, 2016
ad4f08d
Delete UnitOfWork
noufionline Sep 28, 2016
d6631c8
Added new overload for GetAll
noufionline Sep 29, 2016
a745ee4
Added optional token parameter to constructor
noufionline Sep 30, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
93 changes: 93 additions & 0 deletions Source/TrackableEntities.Client/ServiceBase
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,93 @@
using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Threading.Tasks;

namespace TrackableEntities.Client
{
public abstract class ServiceBase<T,TKey> where T:class
{
public string Request { get; set; }
public string BaseAddress { get; }


public HttpClient Client { get; }


protected ServiceBase(string baseAddress, string request,string token=null)
{
Request = request;
BaseAddress = baseAddress;
Client = new HttpClient() { BaseAddress = new Uri(baseAddress) };
if (token != null)
{
Client.SetBearerToken(token);
}
}

public async Task<IEnumerable<T>> GetAll()
{
var response = await Client.GetAsync(Request);

response.EnsureSuccessStatusCode();

return await response.Content.ReadAsAsync<IEnumerable<T>>();
}

public async Task<IEnumerable<T>> GetAll(string route,ExpandoObject parameters)
{
StringBuilder uri =new StringBuilder();
uri.Append($"{Request}").Append("/").Append(route);

if (parameters != null)
{
uri.Append("?");
foreach (KeyValuePair<string, object> parameter in parameters)
{
uri.Append($"{parameter.Key}={parameter.Value}").Append("&");
}
}
var response = await Client.GetAsync(uri.ToString().Substring(0,uri.ToString().Length-1));

response.EnsureSuccessStatusCode();

return await response.Content.ReadAsAsync<IEnumerable<T>>();
}

public async Task<T> Update(T entity)
{
var response = await Client.PutAsJsonAsync(Request, entity);

response.EnsureSuccessStatusCode();

return await response.Content.ReadAsAsync<T>();
}

public async Task<T> Create(T entity)
{
var response = await Client.PostAsJsonAsync(Request, entity);

response.EnsureSuccessStatusCode();

return await response.Content.ReadAsAsync<T>();
}

public async Task<T> Find(TKey id)
{
var response = await Client.GetAsync($"{Request}/{id}");

response.EnsureSuccessStatusCode();

return await response.Content.ReadAsAsync<T>();
}

public async Task<bool> VerifyDeleted(TKey id)
{
string request = Request + id;
var response = await Client.GetAsync(request);
if (response.IsSuccessStatusCode) return await Task.FromResult(false);
return await Task.FromResult(true);
}

}
}
7 changes: 5 additions & 2 deletions Source/TrackableEntities.Patterns.EF.6/UnitOfWork.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,20 +19,23 @@ public abstract class UnitOfWork : IUnitOfWork, IUnitOfWorkAsync, IDisposable
/// Constructs a new general unit of work.
/// </summary>
protected UnitOfWork() { }

/// <summary>
/// Constructs a new general unit of work.
/// </summary>
/// <param name="context">Entity Framework DbContext-derived class.</param>
protected UnitOfWork(DbContext context)
protected UnitOfWork(DbContext context,IRepositoryFactory repositoryFactory)
{
Context = context;
RepositoryFactory=repositoryFactory;
}

/// <summary>
/// Gets the DbContext for the unit of work.
/// </summary>
protected DbContext Context { get; set; }

protected IRepositoryFactory RepositoryFactory {get;set;}

/// <summary>
/// Disposes the DbContext.
Expand Down
4 changes: 4 additions & 0 deletions Source/TrackableEntities.Patterns/IRepositoryFactory
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
public interface IRepositoryFactory
{
T GetDataRepository<T>();
}