Restructured query repositries to move ef logic from handlers

This commit is contained in:
2019-04-27 00:02:55 -04:00
parent 7be4075222
commit 1a95acac01
18 changed files with 169 additions and 59 deletions

View File

@@ -6,8 +6,6 @@
<ItemGroup>
<Folder Include="Interfaces\" />
<Folder Include="Handlers\QueryHandlers\" />
<Folder Include="Queries\" />
</ItemGroup>
<ItemGroup>

View File

@@ -1,8 +1,6 @@
using BrightGlimmer.Domain;
using MediatR;
using System;
using System.Collections.Generic;
using System.Text;
namespace BrightGlimmer.Service.Commands
{

View File

@@ -2,9 +2,6 @@
using BrightGlimmer.Domain;
using BrightGlimmer.Service.Commands;
using MediatR;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

View File

@@ -1,30 +0,0 @@
using BrightGlimmer.Data.Interfaces;
using BrightGlimmer.Domain;
using BrightGlimmer.Services.Queries;
using MediatR;
using Microsoft.EntityFrameworkCore; /* TODO */
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace BrightGlimmer.Services.Handlers.QueryHandlers
{
public class GetAllStudentsQueryHandler : IRequestHandler<GetAllStudentsQuery, IEnumerable<Student>>
{
private readonly IQueryRepository<Student> repository;
public GetAllStudentsQueryHandler(IQueryRepository<Student> repository)
{
this.repository = repository;
}
public async Task<IEnumerable<Student>> Handle(GetAllStudentsQuery request, CancellationToken cancellationToken)
{
return await repository.Get()
.Include(x => x.Phones)
.Include(x => x.Address)
.Include(x => x.AssignedCourses)
.ToListAsync();
}
}
}

View File

@@ -0,0 +1,24 @@
using BrightGlimmer.Data.Interfaces;
using BrightGlimmer.Domain;
using BrightGlimmer.Service.Queries;
using MediatR;
using System.Threading;
using System.Threading.Tasks;
namespace BrightGlimmer.Service.Handlers.QueryHandlers
{
public class GetStudentQueryHandler : IRequestHandler<GetStudentQuery, Student>
{
private readonly IQueryRepository<Student> repository;
public GetStudentQueryHandler(IQueryRepository<Student> repository)
{
this.repository = repository;
}
public async Task<Student> Handle(GetStudentQuery request, CancellationToken cancellationToken)
{
return await repository.GetAsync(request.Id);
}
}
}

View File

@@ -0,0 +1,26 @@
using BrightGlimmer.Data.Interfaces;
using BrightGlimmer.Domain;
using BrightGlimmer.Service.Queries;
using MediatR;
using Microsoft.EntityFrameworkCore;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace BrightGlimmer.Service.Handlers.QueryHandlers
{
public class GetStudentsQueryHandler : IRequestHandler<GetStudentsQuery, IEnumerable<Student>>
{
private readonly IQueryRepository<Student> repository;
public GetStudentsQueryHandler(IQueryRepository<Student> repository)
{
this.repository = repository;
}
public async Task<IEnumerable<Student>> Handle(GetStudentsQuery request, CancellationToken cancellationToken)
{
return await repository.Get().ToListAsync();
}
}
}

View File

@@ -1,10 +0,0 @@
using BrightGlimmer.Domain;
using MediatR;
using System.Collections.Generic;
namespace BrightGlimmer.Services.Queries
{
public class GetAllStudentsQuery : IRequest<IEnumerable<Student>>
{
}
}

View File

@@ -0,0 +1,16 @@
using BrightGlimmer.Domain;
using MediatR;
using System;
namespace BrightGlimmer.Service.Queries
{
public class GetStudentQuery : IRequest<Student>
{
public Guid Id { get; set; }
public GetStudentQuery(Guid id)
{
Id = id;
}
}
}

View File

@@ -0,0 +1,10 @@
using BrightGlimmer.Domain;
using MediatR;
using System.Collections.Generic;
namespace BrightGlimmer.Service.Queries
{
public class GetStudentsQuery : IRequest<IEnumerable<Student>>
{
}
}