ECER-5292: ICRA Eligibility submission endpoint and manager layer

Author: farzadnadiri

src/ECER.Clients.RegistryPortal/ECER.Clients.RegistryPortal.Server/ICRA/ICRAEligibilitiesEndpoints.cs

@@ -5,6 +5,7 @@
 using ECER.Utilities.Security;
 using MediatR;
 using Microsoft.AspNetCore.Http.HttpResults;
+using Microsoft.AspNetCore.Mvc;
 
 namespace ECER.Clients.RegistryPortal.Server.ICRA;
 
@@ -58,6 +59,36 @@ public void Register(IEndpointRouteBuilder endpointRouteBuilder)
         .WithOpenApi("Handles icra queries", string.Empty, "icra_get")
         .RequireAuthorization()
         .WithParameterValidation();
+
+    endpointRouteBuilder.MapPost("/api/icra", async Task<Results<Ok<SubmitICRAEligibilityResponse>, BadRequest<ProblemDetails>, NotFound>> (ICRAEligibilitySubmissionRequest request, HttpContext ctx, IMediator messageBus, IMapper mapper, CancellationToken ct) =>
+        {
+          var userId = ctx.User.GetUserContext()?.UserId;
+          bool IdIsNotGuid = !Guid.TryParse(request.Id, out _); if (IdIsNotGuid)
+          {
+            return TypedResults.BadRequest(new ProblemDetails() { Title = "ICRAEligibilityId is not valid" });
+          }
+
+          var cmd = new SubmitICRAEligibilityCommand(request.Id!, userId!);
+          var result = await messageBus.Send(cmd, ct);
+          if (!result.IsSuccess && result.Error == Managers.Registry.Contract.ICRA.SubmissionError.DraftIcraEligibilityNotFound)
+          {
+            return TypedResults.NotFound();
+          }
+          if (!result.IsSuccess && result.Error == Managers.Registry.Contract.ICRA.SubmissionError.DraftIcraEligibilityValidationFailed)
+          {
+            var problemDetails = new ProblemDetails
+            {
+              Status = StatusCodes.Status400BadRequest,
+              Title = "ICRA Eligibility submission failed",
+              Extensions = { ["errors"] = result.ValidationErrors }
+            };
+            return TypedResults.BadRequest(problemDetails);
+          }
+          return TypedResults.Ok(new SubmitICRAEligibilityResponse(mapper.Map<ICRAEligibility>(result.Eligibility)));
+        })
+        .WithOpenApi("Submit an ICRA Eligibility", string.Empty, "icra_post")
+        .RequireAuthorization()
+        .WithParameterValidation();
   }
 }
 
@@ -128,3 +159,6 @@ public enum ICRAStatus
   ReadyforReview,
   Submitted
 }
+
+public record ICRAEligibilitySubmissionRequest(string Id);
+public record SubmitICRAEligibilityResponse(ICRAEligibility Eligibility);

src/ECER.Managers.Registry.Contract/ICRA/Contract.cs

@@ -13,6 +13,22 @@ public record ICRAEligibilitiesQuery : IRequest<ICRAEligibilitiesQueryResults>
 }
 
 public record ICRAEligibilitiesQueryResults(IEnumerable<ICRAEligibility> Items);
+
+public record SubmitICRAEligibilityCommand(string icraEligibilityId, string userId) : IRequest<SubmitICRAEligibilityResult>;
+
+public record SubmitICRAEligibilityResult()
+{
+  public ICRAEligibility? Eligibility { get; set; }
+  public SubmissionError? Error { get; set; }
+  public IEnumerable<string>? ValidationErrors { get; set; }
+  public bool IsSuccess { get { return ValidationErrors == null || !ValidationErrors.Any(); } }
+}
+
+public enum SubmissionError
+{
+  DraftIcraEligibilityNotFound,
+  DraftIcraEligibilityValidationFailed
+}
 public record ICRAEligibility()
 {
   public string? Id { get; set; }

src/ECER.Managers.Registry/ICRAEligibilityHandlers.cs

@@ -5,6 +5,7 @@
 using ECER.Resources.Documents.Applications;
 using ECER.Resources.Documents.ICRA;
 using MediatR;
+using ECER.Engines.Validation.ICRA;
 
 
 namespace ECER.Managers.Registry;
@@ -14,9 +15,11 @@ namespace ECER.Managers.Registry;
 /// </summary>
 public class ICRAEligibilityHandlers(
      IICRARepository iCRARepository,
-     IMapper mapper)
+     IMapper mapper,
+     IICRAValidationEngine icraValidationEngine)
   : IRequestHandler<SaveICRAEligibilityCommand, Contract.ICRA.ICRAEligibility?>,
-    IRequestHandler<ICRAEligibilitiesQuery, ICRAEligibilitiesQueryResults>
+    IRequestHandler<ICRAEligibilitiesQuery, ICRAEligibilitiesQueryResults>,
+    IRequestHandler<SubmitICRAEligibilityCommand, SubmitICRAEligibilityResult>
 {
 
   public async Task<Contract.ICRA.ICRAEligibility?> Handle(SaveICRAEligibilityCommand request, CancellationToken cancellationToken)
@@ -27,7 +30,7 @@ public class ICRAEligibilityHandlers(
       var icraEligibilities = await iCRARepository.Query(new ICRAQuery
       {
         ByApplicantId = request.eligibility.ApplicantId,
-        ByStatus = [Resources.Documents.ICRA.ICRAStatus.Draft]
+        ByStatus = [Resources.Documents.ICRA.ICRAStatus.Draft] // IDE0028: already simplified
       }, cancellationToken);
 
       var existingDraftICRA = icraEligibilities.FirstOrDefault();
@@ -47,6 +50,37 @@ public class ICRAEligibilityHandlers(
     return mapper.Map<Contract.ICRA.ICRAEligibility>(freshIcraEligibilities.SingleOrDefault())!;
   }
 
+  public async Task<SubmitICRAEligibilityResult> Handle(SubmitICRAEligibilityCommand request, CancellationToken cancellationToken)
+  {
+    ArgumentNullException.ThrowIfNull(request);
+
+    var eligibilities = await iCRARepository.Query(new ICRAQuery
+    {
+      ById = request.icraEligibilityId,
+      ByApplicantId = request.userId,
+      ByStatus = [Resources.Documents.ICRA.ICRAStatus.Draft]
+    }, cancellationToken);
+
+    var draft = mapper.Map<IEnumerable<Contract.ICRA.ICRAEligibility>>(eligibilities)!.FirstOrDefault();
+    if (draft == null)
+    {
+      return new SubmitICRAEligibilityResult { Eligibility = null, Error = Contract.ICRA.SubmissionError.DraftIcraEligibilityNotFound, ValidationErrors = new List<string> { "draft icra eligibility does not exist" } };
+    }
+
+    var validation = await icraValidationEngine.Validate(draft!);
+    if (!validation.IsValid)
+    {
+      return new SubmitICRAEligibilityResult { Eligibility = null, Error = Contract.ICRA.SubmissionError.DraftIcraEligibilityValidationFailed, ValidationErrors = validation.ValidationErrors };
+    }
+
+    var repoModel = mapper.Map<Resources.Documents.ICRA.ICRAEligibility>(draft)!;
+    repoModel.Status = Resources.Documents.ICRA.ICRAStatus.Submitted;
+    var id = await iCRARepository.Save(repoModel, cancellationToken);
+
+    var fresh = await iCRARepository.Query(new ICRAQuery { ById = id }, cancellationToken);
+    return new SubmitICRAEligibilityResult { Eligibility = mapper.Map<Contract.ICRA.ICRAEligibility>(fresh.SingleOrDefault()) };
+  }
+
 
   public async Task<ICRAEligibilitiesQueryResults> Handle(ICRAEligibilitiesQuery request, CancellationToken cancellationToken)
   {