Ticket 25 : Display a case plan instance

Author: Thierry Habart

src/CaseManagement.CMMN.AspNetCore/Apis/CasePlanInstancesController.cs

@@ -800,6 +800,7 @@ private static FindWorkflowInstanceParameter ExtractFindParameter(IEnumerable<Ke
             FindOrders findOrder;
             string casePlanId;
             string owner;
+            bool takeLatest;
             var parameter = new FindWorkflowInstanceParameter();
             if (query.TryGet("start_index", out startIndex))
             {
@@ -831,6 +832,11 @@ private static FindWorkflowInstanceParameter ExtractFindParameter(IEnumerable<Ke
                 parameter.CaseOwner = owner;
             }
 
+            if (query.TryGet("take_latest", out takeLatest))
+            {
+                parameter.TakeLatest = takeLatest;
+            }
+
             return parameter;
         }
     }

src/CaseManagement.CMMN/Domains/CasePlanInstance/CasePlanInstanceAggregate.cs

@@ -715,7 +715,7 @@ private void Handle(CaseInstanceCreatedEvent evt)
         private CaseElementInstance Handle(CaseElementCreatedEvent evt)
         {
             var existingPlanItem = WorkflowElementInstances.Where(p => p.CasePlanElementId == evt.CasePlanElementId).OrderByDescending(p => p.Version).FirstOrDefault();
-            var elt = new CaseElementInstance(evt.CasePlanElementId, evt.CreateDateTime, evt.CasePlanElementId, evt.CasePlanElementType, existingPlanItem == null ? 0 : existingPlanItem.Version + 1, evt.ParentId)
+            var elt = new CaseElementInstance(evt.CasePlanElementInstanceId, evt.CreateDateTime, evt.CasePlanElementId, evt.CasePlanElementType, existingPlanItem == null ? 0 : existingPlanItem.Version + 1, evt.ParentId)
             {
                 CasePlanElementName = evt.CasePlanElementName
             };

src/CaseManagement.CMMN/Domains/CasePlanInstance/Events/CaseElementCreatedEvent.cs

@@ -24,4 +24,4 @@ public CaseElementCreatedEvent(string id, string aggregateId, int version, strin
         public DateTime CreateDateTime { get; set; }
         public string ParentId { get; set; }
     }
-}
+}

src/CaseManagement.CMMN/Parser/CMMNParser.cs

@@ -126,6 +126,11 @@ private static SEntry BuildSEntry(tSentry sEntry)
 
         private static PlanItemDefinition BuildPlanItem(string id, string name, tPlanItemDefinition planItemDef)
         {
+            if (string.IsNullOrWhiteSpace(name))
+            {
+                name = planItemDef.name;
+            }
+
             if (planItemDef is tProcessTask)
             {
                 return PlanItemDefinition.New(id, name, BuildProcessTask((tProcessTask)planItemDef));

src/CaseManagement.CMMN/Persistence/InMemory/InMemoryCaseInstanceQueryRepository.cs

@@ -18,7 +18,7 @@ public class InMemoryCaseInstanceQueryRepository : ICasePlanInstanceQueryReposit
             { "state", "State" },
             { "create_datetime", "CreateDateTime" }
         };
-        private ConcurrentBag<Domains.CasePlanInstanceAggregate> _instances;
+        private ConcurrentBag<CasePlanInstanceAggregate> _instances;
 
         public InMemoryCaseInstanceQueryRepository(ConcurrentBag<CasePlanInstanceAggregate> instances)
         {
@@ -28,6 +28,12 @@ public InMemoryCaseInstanceQueryRepository(ConcurrentBag<CasePlanInstanceAggrega
         public Task<FindResponse<CasePlanInstanceAggregate>> Find(FindWorkflowInstanceParameter parameter)
         {
             IQueryable<Domains.CasePlanInstanceAggregate> result = _instances.AsQueryable();
+            if (parameter.TakeLatest)
+            {
+                result = result.OrderByDescending(r => r.Version);
+                result = result.GroupBy(r => r.CasePlanId).Select(r => r.First());
+            }
+
             if (!string.IsNullOrWhiteSpace(parameter.CasePlanId))
             {
                 result = result.Where(r => r.CasePlanId == parameter.CasePlanId);

src/CaseManagement.CMMN/Persistence/Parameters/FindWorkflowInstanceParameter.cs

@@ -12,5 +12,6 @@ public FindWorkflowInstanceParameter() : base()
         public string CasePlanId { get; set; }
         public string CaseOwner { get; set; }
         public ICollection<string> Roles { get; set; }
+        public bool TakeLatest { get; set; }
     }
 }

src/CaseManagement.Gateway.Website.AspNetCore/Apis/CasePlanInstancesController.cs

@@ -1,4 +1,6 @@
 using CaseManagement.Gateway.Website.AspNetCore.Extensions;
+using CaseManagement.Gateway.Website.CasePlanInstance.CommandHandlers;
+using CaseManagement.Gateway.Website.CasePlanInstance.Commands;
 using CaseManagement.Gateway.Website.CasePlanInstance.Queries;
 using CaseManagement.Gateway.Website.CasePlanInstance.QueryHandlers;
 using Microsoft.AspNetCore.Authorization;
@@ -14,13 +16,15 @@ public class CasePlanInstancesController : Controller
         private readonly ISearchCasePlanInstanceQueryHandler _searchCasePlanInstanceQueryHandler;
         private readonly IGetCasePlanInstanceQueryHandler _getCasePlanInstanceQueryHandler;
         private readonly IGetAssignedCasePlanInstanceQueryHandler _getAssignedCasePlanInstanceQueryHandler;
+        private readonly IEnableCasePlanElementInstanceCommandHandler _enableCasePlanElementInstanceCommandHandler;
 
-        public CasePlanInstancesController(ISearchAssignedCasePlanInstanceQueryHandler searchAssignedCasePlanInstanceQueryHandler, ISearchCasePlanInstanceQueryHandler searchCasePlanInstanceQueryHandler, IGetCasePlanInstanceQueryHandler getCasePlanInstanceQueryHandler, IGetAssignedCasePlanInstanceQueryHandler getAssignedCasePlanInstanceQueryHandler)
+        public CasePlanInstancesController(ISearchAssignedCasePlanInstanceQueryHandler searchAssignedCasePlanInstanceQueryHandler, ISearchCasePlanInstanceQueryHandler searchCasePlanInstanceQueryHandler, IGetCasePlanInstanceQueryHandler getCasePlanInstanceQueryHandler, IGetAssignedCasePlanInstanceQueryHandler getAssignedCasePlanInstanceQueryHandler, IEnableCasePlanElementInstanceCommandHandler enableCasePlanElementInstanceCommandHandler)
         {
             _searchAssignedCasePlanInstanceQueryHandler = searchAssignedCasePlanInstanceQueryHandler;
             _searchCasePlanInstanceQueryHandler = searchCasePlanInstanceQueryHandler;
             _getCasePlanInstanceQueryHandler = getCasePlanInstanceQueryHandler;
             _getAssignedCasePlanInstanceQueryHandler = getAssignedCasePlanInstanceQueryHandler;
+            _enableCasePlanElementInstanceCommandHandler = enableCasePlanElementInstanceCommandHandler;
         }
 
         [HttpGet("search")]
@@ -56,5 +60,13 @@ public async Task<IActionResult> GetMe(string id)
             var result = await _getAssignedCasePlanInstanceQueryHandler.Handle(new GetAssignedCasePlanInstanceQuery { CasePlanInstanceId = id, IdentityToken = this.GetIdentityToken() });
             return new OkObjectResult(CasePlansController.ToDto(result));
         }
+
+        [HttpGet("{id}/enable/{eltId}")]
+        [Authorize("enable_caseplaninstance")]
+        public async Task<IActionResult> Enable(string id, string eltId)
+        {
+            await _enableCasePlanElementInstanceCommandHandler.Handle(new EnableCasePlanElementInstanceCommand { CasePlanElementInstanceId = eltId, CasePlanInstanceId = id });
+            return new OkResult();
+        }
     }
 }

src/CaseManagement.Gateway.Website.Host/Startup.cs

@@ -70,8 +70,9 @@ public void ConfigureServices(IServiceCollection services)
                 policy.AddPolicy("terminate_caseplaninstance", p => p.RequireRole("businessanalyst"));
                 policy.AddPolicy("search_caseplaninstance", p => p.RequireRole("businessanalyst"));
                 policy.AddPolicy("get_caseplaninstance", p => p.RequireRole("businessanalyst"));
+                policy.AddPolicy("enable_caseplaninstance", p => p.RequireRole("businessanalyst"));
                 policy.AddPolicy("me_search_caseplaninstance", p => p.RequireRole("caseworker"));
-                policy.AddPolicy("me_get_caseplaninstance", p => p.RequireRole("businessanalyst"));
+                policy.AddPolicy("me_get_caseplaninstance", p => p.RequireRole("caseworker"));
             });
             services.AddCors(options => options.AddPolicy("AllowAll", p => p.AllowAnyOrigin()
                 .AllowAnyMethod()

src/CaseManagement.Gateway.Website/CasePlanInstance/CommandHandlers/EnableCasePlanElementInstanceCommandHandler.cs

@@ -0,0 +1,21 @@
+using CaseManagement.Gateway.Website.CasePlanInstance.Commands;
+using CaseManagement.Gateway.Website.CasePlanInstance.Services;
+using System.Threading.Tasks;
+
+namespace CaseManagement.Gateway.Website.CasePlanInstance.CommandHandlers
+{
+    public class EnableCasePlanElementInstanceCommandHandler : IEnableCasePlanElementInstanceCommandHandler
+    {
+        private readonly ICasePlanInstanceService _casePlanInstanceService;
+
+        public EnableCasePlanElementInstanceCommandHandler(ICasePlanInstanceService casePlanInstanceService)
+        {
+            _casePlanInstanceService = casePlanInstanceService;
+        }
+
+        public Task Handle(EnableCasePlanElementInstanceCommand command)
+        {
+            return _casePlanInstanceService.Enable(command.CasePlanInstanceId, command.CasePlanElementInstanceId);
+        }
+    }
+}

src/CaseManagement.Gateway.Website/CasePlanInstance/CommandHandlers/IEnableCasePlanElementInstanceCommandHandler.cs

@@ -0,0 +1,10 @@
+using CaseManagement.Gateway.Website.CasePlanInstance.Commands;
+using System.Threading.Tasks;
+
+namespace CaseManagement.Gateway.Website.CasePlanInstance.CommandHandlers
+{
+    public interface IEnableCasePlanElementInstanceCommandHandler
+    {
+        Task Handle(EnableCasePlanElementInstanceCommand command);
+    }
+}