Merge pull request #26 from bsandmann/dev

Dev

Blocktrust.CredentialWorkflow.Core/Commands/WorkflowOutcome/GetWorkflowOutcomeById/GetWorkflowOutcomeByIdHandler.cs

@@ -1,6 +1,5 @@
 namespace Blocktrust.CredentialWorkflow.Core.Commands.WorkflowOutcome.GetWorkflowOutcomeById;
 
-using Blocktrust.CredentialWorkflow.Core.Domain.ProcessFlow.Actions;
 using Domain.Workflow;
 using FluentResults;
 using MediatR;

Blocktrust.CredentialWorkflow.Core/Commands/WorkflowOutcome/GetWorkflowOutcomeIdsByState/GetWorkflowOutcomeIdsByStateHandler.cs

@@ -1,33 +1,32 @@
-namespace Blocktrust.CredentialWorkflow.Core.Commands.WorkflowOutcome.GetWorkflowOutcomeIdsByState
+namespace Blocktrust.CredentialWorkflow.Core.Commands.WorkflowOutcome.GetWorkflowOutcomeIdsByState;
+
+using FluentResults;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+
+public class GetWorkflowOutcomeIdsByStateHandler
+    : IRequestHandler<GetWorkflowOutcomeIdsByStateRequest, Result<List<GetWorkflowOutcomeIdsByStateResponse>>>
 {
-    using FluentResults;
-    using MediatR;
-    using Microsoft.EntityFrameworkCore;
+    private readonly DataContext _context;
 
-    public class GetWorkflowOutcomeIdsByStateHandler
-        : IRequestHandler<GetWorkflowOutcomeIdsByStateRequest, Result<List<GetWorkflowOutcomeIdsByStateResponse>>>
+    public GetWorkflowOutcomeIdsByStateHandler(DataContext context)
     {
-        private readonly DataContext _context;
-
-        public GetWorkflowOutcomeIdsByStateHandler(DataContext context)
-        {
-            _context = context;
-        }
+        _context = context;
+    }
 
-        public async Task<Result<List<GetWorkflowOutcomeIdsByStateResponse>>> Handle(
-            GetWorkflowOutcomeIdsByStateRequest request,
-            CancellationToken cancellationToken)
-        {
-            var outcomes = await _context.WorkflowOutcomeEntities
-                .Where(o => request.WorkflowOutcomeStates.Contains(o.WorkflowOutcomeState))
-                .Select(o => new GetWorkflowOutcomeIdsByStateResponse
-                {
-                    OutcomeId = o.WorkflowOutcomeEntityId,
-                    WorkflowOutcomeState = o.WorkflowOutcomeState
-                })
-                .ToListAsync(cancellationToken);
+    public async Task<Result<List<GetWorkflowOutcomeIdsByStateResponse>>> Handle(
+        GetWorkflowOutcomeIdsByStateRequest request,
+        CancellationToken cancellationToken)
+    {
+        var outcomes = await _context.WorkflowOutcomeEntities
+            .Where(o => request.WorkflowOutcomeStates.Contains(o.WorkflowOutcomeState))
+            .Select(o => new GetWorkflowOutcomeIdsByStateResponse
+            {
+                OutcomeId = o.WorkflowOutcomeEntityId,
+                WorkflowOutcomeState = o.WorkflowOutcomeState
+            })
+            .ToListAsync(cancellationToken);
 
-            return Result.Ok(outcomes);
-        }
+        return Result.Ok(outcomes);
     }
 }

Blocktrust.CredentialWorkflow.Core/Commands/WorkflowOutcome/UpdateWorkflowOutcomeState/UpdateWorkflowOutcomeStateHandler.cs

@@ -1,36 +1,35 @@
-namespace Blocktrust.CredentialWorkflow.Core.Commands.WorkflowOutcome.UpdateWorkflowOutcomeState
+namespace Blocktrust.CredentialWorkflow.Core.Commands.WorkflowOutcome.UpdateWorkflowOutcomeState;
+
+using FluentResults;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+
+public class UpdateWorkflowOutcomeStateHandler : IRequestHandler<UpdateWorkflowOutcomeStateRequest, Result>
 {
-    using FluentResults;
-    using MediatR;
-    using Microsoft.EntityFrameworkCore;
+    private readonly DataContext _context;
 
-    public class UpdateWorkflowOutcomeStateHandler : IRequestHandler<UpdateWorkflowOutcomeStateRequest, Result>
+    public UpdateWorkflowOutcomeStateHandler(DataContext context)
     {
-        private readonly DataContext _context;
+        _context = context;
+    }
 
-        public UpdateWorkflowOutcomeStateHandler(DataContext context)
-        {
-            _context = context;
-        }
+    public async Task<Result> Handle(UpdateWorkflowOutcomeStateRequest request, CancellationToken cancellationToken)
+    {
+        // Retrieve the outcome from the database
+        var outcomeEntity = await _context.WorkflowOutcomeEntities
+            .FirstOrDefaultAsync(o => o.WorkflowOutcomeEntityId == request.WorkflowOutcomeId, cancellationToken);
 
-        public async Task<Result> Handle(UpdateWorkflowOutcomeStateRequest request, CancellationToken cancellationToken)
+        if (outcomeEntity is null)
         {
-            // Retrieve the outcome from the database
-            var outcomeEntity = await _context.WorkflowOutcomeEntities
-                .FirstOrDefaultAsync(o => o.WorkflowOutcomeEntityId == request.WorkflowOutcomeId, cancellationToken);
-
-            if (outcomeEntity is null)
-            {
-                return Result.Fail("The specified outcome does not exist in the database.");
-            }
+            return Result.Fail("The specified outcome does not exist in the database.");
+        }
 
-            // Update the state
-            outcomeEntity.WorkflowOutcomeState = request.NewState;
+        // Update the state
+        outcomeEntity.WorkflowOutcomeState = request.NewState;
 
-            // Save changes to the database
-            await _context.SaveChangesAsync(cancellationToken);
+        // Save changes to the database
+        await _context.SaveChangesAsync(cancellationToken);
 
-            return Result.Ok();
-        }
+        return Result.Ok();
     }
 }

Blocktrust.CredentialWorkflow.Core/Domain/Enums/EWorkflowState.cs

@@ -5,4 +5,6 @@ public enum EWorkflowState
     Inactive,
     ActiveWithExternalTrigger,
     ActiveWithRecurrentTrigger,
+    ActiveWithFormTrigger
+
 }