Project User Cqrs implementation.

backend/src/ThreeTee.Api/Controllers/ProjectUserController.cs

@@ -1,7 +1,10 @@
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.CodeAnalysis;
+using ThreeTee.Application.Cqrs.ProjectUsers.Commands.CreateProjectUser;
+using ThreeTee.Application.Cqrs.ProjectUsers.Commands.DeleteProjectUser;
+using ThreeTee.Application.Cqrs.ProjectUsers.Commands.UpdateProjectUser;
 using ThreeTee.Application.Cqrs.ProjectUsers.Queries;
-using ThreeTee.Application.Interfaces;
 using ThreeTee.Application.Models.ProjectUser;
 
 // For more information on enabling Web API for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860
@@ -13,12 +16,6 @@ namespace ThreeTee.Api.Controllers
  [Authorize]
  public class ProjectUserController : ApiControllerBase
  {
- private readonly IProjectUserService _projectUserService;
-
- public ProjectUserController(IProjectUserService projectUserService)
- {
- _projectUserService = projectUserService;
- }
  // GET: api/<ClientController>
  [HttpGet]
  [Produces(typeof(List<ProjectUserResponse>))]
@@ -28,37 +25,39 @@ public async Task<IResult> Get([FromQuery] GetProjectUsersWithPaginationQuery qu
  return TypedResults.Ok(items);
  }
 
- [HttpGet("{id}")]
+ //GET PROJECT USER LIST api/<ClientController>
+ [HttpPost("{UserId}")]
  [Produces(typeof(List<ProjectUserResponse>))]
- public async Task<IResult> Get(Guid id)
+ public async Task<IResult> Get(GetProjectUsersWithUserIdPaginationQuery query)
  {
- var items = await _projectUserService.GetByProjectId(id);
+ var items = await Mediator.Send(query);
  return TypedResults.Ok(items);
  }
 
  // POST api/<ClientController>
  [HttpPost]
- public async Task<IResult> Post([FromBody] ProjectUserUpsertRequest value)
+ public async Task<IResult> Post([FromBody] CreateProjectUserCommand query)
  {
-
- var ret = await _projectUserService.InsertAsync(value);
- if (ret == null) return TypedResults.BadRequest();
- return TypedResults.Created(ret.ProjectId.ToString());
+ var items = await Mediator.Send(query);
+ if (items != Guid.Empty)
+ { return TypedResults.Created(items.ToString()); }
+ return TypedResults.BadRequest();
  }
+
  // PUT api/<ClientController>
  [HttpPut]
- public async Task<IResult> Put(ProjectUserUpsertRequest request)
+ public async Task<IResult> Put(UpdateProjectUserCommand query)
  {
- var item = await _projectUserService.UpdateAsync(request);
+ var item = await Mediator.Send(query);
  return TypedResults.Ok(item);
  }
 
- [HttpDelete("{id}")]
- public async Task<IResult> Delete(Guid id)
+ // DELETE api/<ClientController>
+ [HttpDelete("{UserId}")]
+ public async Task<IResult> Delete(DeleteProjectUserCommand query)
  {
- await _projectUserService.DeleteAsync(id);
+ var item = await Mediator.Send(query);
  return TypedResults.NoContent();
  }
-
  }
 }

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Commands/CreateProjectUser/CreateProjectUserCommand.cs

@@ -1,3 +1,4 @@
+using Mapster;
 using MediatR;
 using ThreeTee.Core.Entities;
 
@@ -20,11 +21,12 @@ public CreateProjectUserCommandHandler(IEntitiesContext context)
 
  public async Task<Guid> Handle(CreateProjectUserCommand request, CancellationToken cancellationToken)
  {
- var entity = new ProjectUser
- {
- ProjectId = request.ProjectId,
- UserId = request.UserId,
- };
+ var entity = request.Adapt<ProjectUser>();
+ //var entitys = new ProjectUser
+ //{
+ // ProjectId = request.ProjectId,
+ // UserId = entity.UserId,
+ //};
 
  // entity.AddDomainEvent(new ProjectUserCreatedEvent(entity));
 

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Commands/DeleteProjectUser/DeleteProjectUserCommand.cs

@@ -0,0 +1,31 @@
+using MediatR;
+
+namespace ThreeTee.Application.Cqrs.ProjectUsers.Commands.DeleteProjectUser;
+
+public record DeleteProjectUserCommand : IRequest<bool>
+{
+ public Guid UserId { get; set; }
+ public Guid ProjectId { get; set; }
+}
+
+public class DeleteProjectUserCommandHandler : IRequestHandler<DeleteProjectUserCommand, bool>
+{
+ private readonly IEntitiesContext _context;
+ public DeleteProjectUserCommandHandler(IEntitiesContext context)
+ {
+ _context = context;
+ }
+ public async Task<bool> Handle(DeleteProjectUserCommand request, CancellationToken cancellationToken)
+ {
+ var projectUser = _context.ProjectUsers.Where(e => e.UserId == request.UserId)
+ .FirstOrDefault(e => e.ProjectId == request.ProjectId);
+
+ if (projectUser is null)
+ return false;
+
+ _context.ProjectUsers.Remove(projectUser);
+ await _context.SaveChangesAsync(cancellationToken);
+ return true;
+ }
+}
+

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Commands/DeleteProjectUser/DeleteProjectUserCommandValidator.cs

@@ -0,0 +1,15 @@
+using FluentValidation;
+
+namespace ThreeTee.Application.Cqrs.ProjectUsers.Commands.DeleteProjectUser;
+
+public class DeleteProjectUserCommandValidator:AbstractValidator<DeleteProjectUserCommand>
+{
+ public DeleteProjectUserCommandValidator()
+ {
+ RuleFor(e=>e.UserId)
+ .NotEmpty();
+ RuleFor(e => e.ProjectId)
+ .NotEmpty();
+ }
+}
+

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Commands/UpdateProjectUser/UpdateProjectUserCommand.cs

@@ -0,0 +1,40 @@
+using FluentValidation;
+using Mapster;
+using MediatR;
+using ThreeTee.Core.Entities;
+
+namespace ThreeTee.Application.Cqrs.ProjectUsers.Commands.UpdateProjectUser;
+
+public record UpdateProjectUserCommand : IRequest<ProjectUser>
+{
+ public Guid UserId { get; set; }
+ public Guid ProjectId { get; set; }
+ public Guid OldProjectId { get; set; }
+}
+
+public class UpdateProjectUserCommandHandler : IRequestHandler<UpdateProjectUserCommand, ProjectUser>
+{
+ private readonly IEntitiesContext _context;
+ public UpdateProjectUserCommandHandler(IEntitiesContext context)
+ {
+ _context = context;
+ }
+ public async Task<ProjectUser> Handle(UpdateProjectUserCommand request, CancellationToken cancellationToken)
+ {
+ //Check user for project present. If not create new one.
+
+ var projectUser = _context.ProjectUsers.Where(e => e.UserId == request.UserId)
+ .FirstOrDefault(e => e.ProjectId == request.ProjectId);
+ if (projectUser == null)
+ {
+ var entity = request.Adapt<ProjectUser>();
+
+ _context.ProjectUsers.Add(entity);
+ await _context.SaveChangesAsync(cancellationToken);
+
+ return entity;
+ }
+ return projectUser;
+ }
+}
+

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Commands/UpdateProjectUser/UpdateProjectUserCommandValidator.cs

@@ -0,0 +1,19 @@
+using FluentValidation;
+
+namespace ThreeTee.Application.Cqrs.ProjectUsers.Commands.UpdateProjectUser;
+
+public class UpdateProjectUserCommandValidator:AbstractValidator<UpdateProjectUserCommand>
+{
+ public UpdateProjectUserCommandValidator()
+ {
+ RuleFor(v => v.UserId)
+ .NotEmpty();
+ RuleFor(v => v.ProjectId)
+ .NotEmpty();
+ RuleFor(v => v.OldProjectId)
+ .NotEmpty();
+ RuleFor(e => e.ProjectId)
+ .NotEqual(v => v.OldProjectId);
+ }
+}
+

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Queries/GetProjectUsersWithPagination.cs

@@ -13,12 +13,12 @@ public record GetProjectUsersWithPaginationQuery : IRequest<PaginatedList<Projec
  public int PageSize { get; init; } = 10;
 }
 
-public class GetTodoItemsWithPaginationQueryHandler : IRequestHandler<GetProjectUsersWithPaginationQuery, PaginatedList<ProjectUserResponse>>
+public class GetProjectUsersWithPaginationQueryHandler : IRequestHandler<GetProjectUsersWithPaginationQuery, PaginatedList<ProjectUserResponse>>
 {
  private readonly IEntitiesContext _context;
  private readonly IMapper _mapper;
 
- public GetTodoItemsWithPaginationQueryHandler(IEntitiesContext context, IMapper mapper)
+ public GetProjectUsersWithPaginationQueryHandler(IEntitiesContext context, IMapper mapper)
  {
  _context = context;
  _mapper = mapper;

backend/src/ThreeTee.Application/Cqrs/ProjectUsers/Queries/GetProjectUsersWithUserIdPagination.cs

@@ -0,0 +1,36 @@
+using Mapster;
+using MapsterMapper;
+using MediatR;
+using ThreeTee.Application.Mappings;
+using ThreeTee.Application.Models;
+using ThreeTee.Application.Models.ProjectUser;
+
+namespace ThreeTee.Application.Cqrs.ProjectUsers.Queries;
+
+public record GetProjectUsersWithUserIdPaginationQuery : IRequest<PaginatedList<ProjectUserResponse>>
+{
+ public int PageNumber { get; init; } = 1;
+ public int PageSize { get; init; } = 10;
+ public Guid UserId { get; set; }
+}
+
+public class GetProjectUsersWithUserIdPaginationQueryHandler : IRequestHandler<GetProjectUsersWithUserIdPaginationQuery, PaginatedList<ProjectUserResponse>>
+{
+ private readonly IEntitiesContext _context;
+ private readonly IMapper _mapper;
+
+ public GetProjectUsersWithUserIdPaginationQueryHandler(IEntitiesContext context, IMapper mapper)
+ {
+ _context = context;
+ _mapper = mapper;
+ }
+
+ public async Task<PaginatedList<ProjectUserResponse>> Handle(GetProjectUsersWithUserIdPaginationQuery request, CancellationToken cancellationToken)
+ {
+ return await _context.ProjectUsers
+ .Where(e=>e.UserId==request.UserId)
+ // .OrderBy(pu=>pu.LastTouchedBy)
+ .ProjectToType<ProjectUserResponse>()
+ .PaginatedListAsync(request.PageNumber, request.PageSize);
+ }
+}