Ticket #94 : Can edit a CMMN file

Author: habarthierry-hue

launch.cmd

@@ -1,7 +1,8 @@
 START cmd /k "cd src/CaseManagement.Identity && dotnet run"
 START cmd /k "cd src/CaseManagement.OAuth && dotnet run"
-START cmd /k "cd src/CaseManagement.HumanTask.Host && dotnet run"
+START cmd /k "cd src/CaseManagement.HumanTask.Host && dotnet run
 START cmd /k "cd src/CaseManagement.BPMN.Host && dotnet run"
+START cmd /k "cd src/CaseManagement.CMMN.Host && dotnet run"
 START cmd /k "cd src/CaseManagement.Website && npm run start"
 START cmd /k "cd src/CaseManagement.Tasklist.Website && npm run start"
 echo Applications are running ...

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

@@ -64,6 +64,26 @@ public async Task<IActionResult> Update(string id, [FromBody] UpdateCaseFileComm
             }
         }
 
+        [HttpPut("{id}/payload")]
+        [Authorize("update_casefile")]
+        public async Task<IActionResult> Update(string id, [FromBody] UpdateCaseFilePayloadCommand parameter, CancellationToken token)
+        {
+            try
+            {
+                parameter.Id = id;
+                await _mediator.Send(parameter, token);
+                return new OkResult();
+            }
+            catch (UnknownCaseFileException)
+            {
+                return new NotFoundResult();
+            }
+            catch (AggregateValidationException ex)
+            {
+                return this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request);
+            }
+        }
+
         [HttpGet("{id}/publish")]
         [Authorize("publish_casefile")]
         public async Task<IActionResult> Publish(string id, CancellationToken token)

src/CaseManagement.CMMN/CaseFile/Commands/Handlers/UpdateCaseFileCommandHandler.cs

@@ -28,7 +28,7 @@ public async Task<bool> Handle(UpdateCaseFileCommand command, CancellationToken
                 throw new UnknownCaseFileException(command.Id);
             }
 
-            caseFile.Update(command.Name, command.Description, command.Payload);
+            caseFile.Update(command.Name, command.Description);
             await _commitAggregateHelper.Commit(caseFile, CaseFileAggregate.GetStreamName(caseFile.AggregateId), token);
             return true;
         }

src/CaseManagement.CMMN/CaseFile/Commands/Handlers/UpdateCaseFilePayloadCommandHandler.cs

@@ -0,0 +1,35 @@
+using CaseManagement.CMMN.CaseFile.Exceptions;
+using CaseManagement.CMMN.Domains;
+using CaseManagement.Common;
+using CaseManagement.Common.EvtStore;
+using MediatR;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace CaseManagement.CMMN.CaseFile.Commands.Handlers
+{
+    public class UpdateCaseFilePayloadCommandHandler : IRequestHandler<UpdateCaseFilePayloadCommand, bool>
+    {
+        private readonly IEventStoreRepository _eventStoreRepository;
+        private readonly ICommitAggregateHelper _commitAggregateHelper;
+
+        public UpdateCaseFilePayloadCommandHandler(IEventStoreRepository eventStoreRepository, ICommitAggregateHelper commitAggregateHelper)
+        {
+            _eventStoreRepository = eventStoreRepository;
+            _commitAggregateHelper = commitAggregateHelper;
+        }
+
+        public async Task<bool> Handle(UpdateCaseFilePayloadCommand request, CancellationToken cancellationToken)
+        {
+            var caseFile = await _eventStoreRepository.GetLastAggregate<CaseFileAggregate>(request.Id, CaseFileAggregate.GetStreamName(request.Id));
+            if (caseFile == null || string.IsNullOrWhiteSpace(caseFile.AggregateId))
+            {
+                throw new UnknownCaseFileException(request.Id);
+            }
+
+            caseFile.UpdatePayload(request.Payload);
+            await _commitAggregateHelper.Commit(caseFile, CaseFileAggregate.GetStreamName(caseFile.AggregateId), cancellationToken);
+            return true;
+        }
+    }
+}

src/CaseManagement.CMMN/CaseFile/Commands/UpdateCaseFileCommand.cs

@@ -11,7 +11,5 @@ public class UpdateCaseFileCommand : IRequest<bool>
         public string Name { get; set; }
         [DataMember(Name = "description")]
         public string Description { get; set; }
-        [DataMember(Name = "payload")]
-        public string Payload { get; set; }
     }
 }

src/CaseManagement.CMMN/CaseFile/Commands/UpdateCaseFilePayloadCommand.cs

@@ -0,0 +1,10 @@
+using MediatR;
+
+namespace CaseManagement.CMMN.CaseFile.Commands
+{
+    public class UpdateCaseFilePayloadCommand : IRequest<bool>
+    {
+        public string Id { get; set; }
+        public string Payload { get; set; }
+    }
+}

src/CaseManagement.CMMN/CaseFile/EventHandlers/CaseFileHandler.cs

@@ -7,7 +7,10 @@
 
 namespace CaseManagement.CMMN.CaseFile.EventHandlers
 {
-    public class CaseFileHandler : IDomainEvtConsumerGeneric<CaseFileAddedEvent>, IDomainEvtConsumerGeneric<CaseFileUpdatedEvent>, IDomainEvtConsumerGeneric<CaseFilePublishedEvent>
+    public class CaseFileHandler : IDomainEvtConsumerGeneric<CaseFileAddedEvent>,
+        IDomainEvtConsumerGeneric<CaseFileUpdatedEvent>, 
+        IDomainEvtConsumerGeneric<CaseFilePublishedEvent>,
+        IDomainEvtConsumerGeneric<CaseFilePayloadUpdatedEvent>
     {
         private readonly ICaseFileCommandRepository _caseFileCommandRepository;
         private readonly ICaseFileQueryRepository _caseFileQueryRepository;
@@ -43,5 +46,13 @@ public async Task Handle(CaseFilePublishedEvent @event, CancellationToken cancel
             await _caseFileCommandRepository.Update(caseFile, cancellationToken);
             await _caseFileCommandRepository.SaveChanges(cancellationToken);
         }
+
+        public async Task Handle(CaseFilePayloadUpdatedEvent @event, CancellationToken token)
+        {
+            var caseFile = await _caseFileQueryRepository.Get(@event.AggregateId, token);
+            caseFile.Handle(@event);
+            await _caseFileCommandRepository.Update(caseFile, token);
+            await _caseFileCommandRepository.SaveChanges(token);
+        }
     }
 }

src/CaseManagement.CMMN/CaseFile/Queries/Handlers/SearchCaseFilesQueryHandler.cs

@@ -27,7 +27,8 @@ public async Task<SearchResult<CaseFileResult>> Handle(SearchCaseFileQuery reque
                 CaseFileId = request.CaseFileId,
                 Owner = request.Owner,
                 StartIndex = request.StartIndex,
-                TakeLatest = request.TakeLatest
+                TakeLatest = request.TakeLatest,
+                Text = request.Text
             }, cancellationToken);
             return new SearchResult<CaseFileResult>
             {

src/CaseManagement.CMMN/CaseFile/Queries/SearchCaseFileQuery.cs

@@ -10,5 +10,6 @@ public class SearchCaseFileQuery : BaseSearchParameter, IRequest<SearchResult<Ca
         public string Owner { get; set; }
         public string CaseFileId { get; set; }
         public bool TakeLatest { get; set; }
+        public string Text { get; set; }
     }
 }

src/CaseManagement.CMMN/Domains/CaseFile/CaseFileAggregate.cs

@@ -20,9 +20,16 @@ public class CaseFileAggregate : BaseAggregate
         public string Owner { get; set; }
         public CaseFileStatus Status { get; set; }
 
-        public void Update(string name, string description, string payload)
+        public void Update(string name, string description)
         {
-            var evt = new CaseFileUpdatedEvent(Guid.NewGuid().ToString(), AggregateId, Version, DateTime.UtcNow, name, description, payload);
+            var evt = new CaseFileUpdatedEvent(Guid.NewGuid().ToString(), AggregateId, Version, DateTime.UtcNow, name, description);
+            Handle(evt);
+            DomainEvents.Add(evt);
+        }
+
+        public void UpdatePayload(string payload)
+        {
+            var evt = new CaseFilePayloadUpdatedEvent(Guid.NewGuid().ToString(), AggregateId, Version, DateTime.UtcNow, payload);
             Handle(evt);
             DomainEvents.Add(evt);
         }
@@ -117,7 +124,14 @@ private void Handle(CaseFileUpdatedEvent caseFileUpdatedEvent)
                 });
             }
 
-            if (string.IsNullOrWhiteSpace(caseFileUpdatedEvent.Payload))
+            Name = caseFileUpdatedEvent.Name;
+            Description = caseFileUpdatedEvent.Description;
+            UpdateDateTime = caseFileUpdatedEvent.UpdateDatetime;
+        }
+
+        private void Handle(CaseFilePayloadUpdatedEvent caseFilePayloadUpdatedEvent)
+        {
+            if (string.IsNullOrWhiteSpace(caseFilePayloadUpdatedEvent.Payload))
             {
                 throw new AggregateValidationException(new List<KeyValuePair<string, string>>
                 {
@@ -127,7 +141,7 @@ private void Handle(CaseFileUpdatedEvent caseFileUpdatedEvent)
 
             try
             {
-                CMMNParser.ParseWSDL(caseFileUpdatedEvent.Payload);
+                CMMNParser.ParseWSDL(caseFilePayloadUpdatedEvent.Payload);
             }
             catch
             {
@@ -137,10 +151,8 @@ private void Handle(CaseFileUpdatedEvent caseFileUpdatedEvent)
                 });
             }
 
-            UpdateDateTime = caseFileUpdatedEvent.UpdateDatetime;
-            Name = caseFileUpdatedEvent.Name;
-            Description = caseFileUpdatedEvent.Description;
-            Payload = caseFileUpdatedEvent.Payload;
+            Payload = caseFilePayloadUpdatedEvent.Payload;
+            UpdateDateTime = caseFilePayloadUpdatedEvent.UpdateDatetime;
         }
 
         private void Handle(CaseFilePublishedEvent caseFilePublishedEvent)