StewKI/AIPS
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

implement two queries

Browse Source
This commit is contained in:
Andrija Stevanovic
2026-02-12 00:39:05 +01:00
parent a1e80cb748
commit ae5a2be7e4
9 changed files with 119 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dotnet/AipsCore/Application/Abstract/Query/IQueryHandler.cs
View File

@@ -3,5 +3,5 @@
public interface IQueryHandler<in TQuery, TResult>
where TQuery : IQuery<TResult>
{
Task<TResult> HandleAsync(TQuery query, CancellationToken cancellationToken = default);
Task<TResult> Handle(TQuery query, CancellationToken cancellationToken = default);
}

5
dotnet/AipsCore/Application/Models/User/Query/GetUser/GetUserQuery.cs Normal file
View File

@@ -0,0 +1,5 @@
using AipsCore.Application.Abstract.Query;
namespace AipsCore.Application.Models.User.Query.GetUser;
public record GetUserQuery(string UserId) : IQuery<Infrastructure.Persistence.User.User>;

32
dotnet/AipsCore/Application/Models/User/Query/GetUser/GetUserQueryHandler.cs Normal file
View File

@@ -0,0 +1,32 @@
using AipsCore.Application.Abstract.Query;
using AipsCore.Domain.Common.Validation;
using AipsCore.Domain.Models.User.Validation;
using AipsCore.Domain.Models.User.ValueObjects;
using AipsCore.Infrastructure.Persistence.Db;
using Microsoft.EntityFrameworkCore;
namespace AipsCore.Application.Models.User.Query.GetUser;
public class GetUserQueryHandler : IQueryHandler<GetUserQuery, Infrastructure.Persistence.User.User>
{
private readonly AipsDbContext _context;
public GetUserQueryHandler(AipsDbContext context)
{
_context = context;
}
public async Task<Infrastructure.Persistence.User.User> Handle(GetUserQuery query, CancellationToken cancellationToken = default)
{
var result = await _context.Users
.Where(u => u.Id.ToString() == query.UserId)
.FirstOrDefaultAsync(cancellationToken);
if (result is null)
{
throw new ValidationException(UserErrors.NotFound(new UserId(query.UserId)));
}
return result;
}
}

5
dotnet/AipsCore/Application/Models/Whiteboard/Query/GetRecentWhiteboards/GetRecentWhiteboardsQuery.cs Normal file
View File

@@ -0,0 +1,5 @@
using AipsCore.Application.Abstract.Query;
namespace AipsCore.Application.Models.Whiteboard.Query.GetRecentWhiteboards;
public record GetRecentWhiteboardsQuery(string UserId): IQuery<ICollection<Infrastructure.Persistence.Whiteboard.Whiteboard>>;

35
dotnet/AipsCore/Application/Models/Whiteboard/Query/GetRecentWhiteboards/GetRecentWhiteboardsQueryHandler.cs Normal file
View File

@@ -0,0 +1,35 @@
using AipsCore.Application.Abstract.Query;
using AipsCore.Infrastructure.Persistence.Db;
using Microsoft.EntityFrameworkCore;
namespace AipsCore.Application.Models.Whiteboard.Query.GetRecentWhiteboards;
public class GetRecentWhiteboardsQueryHandler : IQueryHandler<GetRecentWhiteboardsQuery, ICollection<Infrastructure.Persistence.Whiteboard.Whiteboard>>
{
private readonly AipsDbContext _context;
public GetRecentWhiteboardsQueryHandler(AipsDbContext context)
{
_context = context;
}
public async Task<ICollection<Infrastructure.Persistence.Whiteboard.Whiteboard>> Handle(GetRecentWhiteboardsQuery query, CancellationToken cancellationToken = default)
{
return await GetQuery(query.UserId).ToListAsync(cancellationToken);
}
private IQueryable<Infrastructure.Persistence.Whiteboard.Whiteboard> GetQuery(string userId)
{
Guid userIdGuid = Guid.Parse(userId);
return _context.WhiteboardMemberships
.Include(m => m.Whiteboard)
.Where(m => (
m.UserId == userIdGuid &&
m.IsBanned == false &&
m.Whiteboard != null
))
.OrderByDescending(m => m.LastInteractedAt)
.Select(m => m.Whiteboard!);
}
}