Ticket 27 : Add or edit the roles

Author: Thierry Habart

src/CaseManagement.CMMN.AspNet/Apis/RolesController.cs

@@ -0,0 +1,100 @@
+using CaseManagement.CMMN.AspNet.Extensions;
+using CaseManagement.CMMN.Infrastructures;
+using CaseManagement.CMMN.Roles;
+using CaseManagement.CMMN.Roles.Commands;
+using CaseManagement.CMMN.Roles.Exceptions;
+using System.Net;
+using System.Net.Http;
+using System.Threading.Tasks;
+using System.Web.Http;
+
+namespace CaseManagement.CMMN.AspNet.Apis
+{
+    [RoutePrefix(CMMNConstants.RouteNames.Roles)]
+    public class RolesController : ApiController
+    {
+        private readonly IRoleService _roleService;
+
+        public RolesController(IRoleService roleService)
+        {
+            _roleService = roleService;
+        }
+
+        [HttpGet]
+        [Route("{id:string}")]
+        public async Task<IHttpActionResult> Get(string id)
+        {
+            try
+            {
+                var result = await _roleService.Get(id);
+                return Ok(result);
+            }
+            catch (UnknownRoleException)
+            {
+                return NotFound();
+            }
+        }
+
+        [HttpGet]
+        [Route("search")]
+        public async Task<IHttpActionResult> Search()
+        {
+            var query = this.Request.GetQueryNameValuePairs();
+            var result = await _roleService.Search(query);
+            return Ok(result);
+        }
+
+        [HttpPost]
+        public async Task<IHttpActionResult> Add([FromBody] AddRoleCommand command)
+        {
+            try
+            {
+                var result = await _roleService.Add(command);
+                return Content(HttpStatusCode.Created, result);
+            }
+            catch (AggregateValidationException ex)
+            {
+                return Content(HttpStatusCode.BadRequest, this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request));
+            }
+        }
+
+        [HttpDelete]
+        [Route("{id:string}")]
+        public async Task<IHttpActionResult> Delete(string id)
+        {
+            try
+            {
+                await _roleService.Delete(new DeleteRoleCommand { Role = id });
+                return Ok();
+            }
+            catch (UnknownRoleException)
+            {
+                return NotFound();
+            }
+            catch (AggregateValidationException ex)
+            {
+                return Content(HttpStatusCode.BadRequest, this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request));
+            }
+        }
+
+        [HttpPut]
+        [Route("{id:string}")]
+        public async Task<IHttpActionResult> Update(string id, [FromBody] UpdateRoleCommand updateRoleCommand)
+        {
+            try
+            {
+                updateRoleCommand.Role = id;
+                await _roleService.Update(updateRoleCommand);
+                return Ok();
+            }
+            catch (UnknownRoleException)
+            {
+                return NotFound();
+            }
+            catch (AggregateValidationException ex)
+            {
+                return Content(HttpStatusCode.BadRequest, this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request));
+            }
+        }
+    }
+}

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

@@ -0,0 +1,106 @@
+using CaseManagement.CMMN.AspNetCore.Extensions;
+using CaseManagement.CMMN.Infrastructures;
+using CaseManagement.CMMN.Roles;
+using CaseManagement.CMMN.Roles.Commands;
+using CaseManagement.CMMN.Roles.Exceptions;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using System.Net;
+using System.Threading.Tasks;
+
+namespace CaseManagement.CMMN.AspNetCore.Apis
+{
+    [Route(CMMNConstants.RouteNames.Roles)]
+    public class RolesController : Controller
+    {
+        private readonly IRoleService _roleService;
+
+        public RolesController(IRoleService roleService)
+        {
+            _roleService = roleService;
+        }
+
+        [HttpGet("{id}")]
+        [Authorize("get_role")]
+        public async Task<IActionResult> Get(string id)
+        {
+            try
+            {
+                var result = await _roleService.Get(id);
+                return new OkObjectResult(result);
+            }
+            catch(UnknownRoleException)
+            {
+                return new NotFoundResult();
+            }
+        }
+
+        [HttpGet("search")]
+        [Authorize("search_role")]
+        public async Task<IActionResult> Search()
+        {
+            var query = HttpContext.Request.Query.ToEnumerable();
+            var result = await _roleService.Search(query);
+            return new OkObjectResult(result);
+        }
+
+        [HttpPost]
+        [Authorize("add_role")]
+        public async Task<IActionResult> Add([FromBody] AddRoleCommand command)
+        {
+            try
+            {
+                var result = await _roleService.Add(command);
+                return new ContentResult
+                {
+                    StatusCode = (int)HttpStatusCode.Created,
+                    Content = result.ToString(),
+                    ContentType = "application/json"
+                };
+            }
+            catch (AggregateValidationException ex) 
+            {                
+                return this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request);
+            }
+        }
+
+        [HttpDelete("{id}")]
+        [Authorize("delete_role")]
+        public async Task<IActionResult> Delete(string id)
+        {
+            try
+            {
+                await _roleService.Delete(new DeleteRoleCommand { Role = id });
+                return new OkResult();
+            }
+            catch(UnknownRoleException)
+            {
+                return new NotFoundResult();
+            }
+            catch(AggregateValidationException ex)
+            {
+                return this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request);
+            }
+        }
+
+        [HttpPut("{id}")]
+        [Authorize("update_role")]
+        public async Task<IActionResult> Update(string id, [FromBody] UpdateRoleCommand updateRoleCommand)
+        {
+            try
+            {
+                updateRoleCommand.Role = id;
+                await _roleService.Update(updateRoleCommand);
+                return new OkResult();
+            }
+            catch (UnknownRoleException)
+            {
+                return new NotFoundResult();
+            }
+            catch (AggregateValidationException ex)
+            {
+                return this.ToError(ex.Errors, HttpStatusCode.BadRequest, Request);
+            }
+        }
+    }
+}

src/CaseManagement.CMMN.Host/Startup.cs

@@ -200,6 +200,12 @@ public void ConfigureServices(IServiceCollection services)
                 policy.AddPolicy("get_performance", p => p.RequireClaim("scope", "get_performance"));
                 // Statistic
                 policy.AddPolicy("get_statistic", p => p.RequireClaim("scope", "get_statistic"));
+                // Role
+                policy.AddPolicy("get_role", p => p.RequireClaim("scope", "get_role"));
+                policy.AddPolicy("search_role", p => p.RequireClaim("scope", "search_role"));
+                policy.AddPolicy("add_role", p => p.RequireClaim("scope", "add_role"));
+                policy.AddPolicy("delete_role", p => p.RequireClaim("scope", "delete_role"));
+                policy.AddPolicy("update_role", p => p.RequireClaim("scope", "update_role"));
             });
             services.AddCors(options => options.AddPolicy("AllowAll", p => p.AllowAnyOrigin()
                 .AllowAnyMethod()

src/CaseManagement.CMMN/CMMNConstants.cs

@@ -30,6 +30,7 @@ public static class RouteNames
             public const string Statistics = "statistics";
             public const string Performances = "performances";
             public const string Forms = "forms";
+            public const string Roles = "roles";
         }
 
         public static class ProcessImplementationTypes

src/CaseManagement.CMMN/CasePlan/EventHandlers/CasePlanEventHandler.cs

@@ -2,8 +2,10 @@
 using CaseManagement.CMMN.Domains.Events;
 using CaseManagement.CMMN.Infrastructures;
 using CaseManagement.CMMN.Infrastructures.Bus;
+using CaseManagement.CMMN.Infrastructures.Lock;
 using CaseManagement.CMMN.Parser;
 using CaseManagement.CMMN.Persistence;
+using System.Diagnostics;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -14,18 +16,26 @@ public class CasePlanEventHandler : IMessageBrokerConsumerGeneric<CaseFilePublis
         private readonly ICaseFileQueryRepository _caseFileQueryRepository;
         private readonly ICasePlanCommandRepository _casePlanCommandRepository;
         private readonly ICommitAggregateHelper _commitAggregateHelper;
+        private readonly IDistributedLock _distributedLock;
 
-        public CasePlanEventHandler(ICaseFileQueryRepository caseFileQueryRepository, ICasePlanCommandRepository casePlanCommandRepository, ICommitAggregateHelper commitAggregateHelper)
+        public CasePlanEventHandler(ICaseFileQueryRepository caseFileQueryRepository, ICasePlanCommandRepository casePlanCommandRepository, ICommitAggregateHelper commitAggregateHelper, IDistributedLock distributedLock)
         {
             _caseFileQueryRepository = caseFileQueryRepository;
             _casePlanCommandRepository = casePlanCommandRepository;
             _commitAggregateHelper = commitAggregateHelper;
+            _distributedLock = distributedLock;
         }
 
         public string QueueName => CMMNConstants.QueueNames.CaseFiles;
 
         public async Task Handle(CaseFilePublishedEvent @event, CancellationToken cancellationToken)
         {
+            var lockId = $"case-file-published-{@event.Id}";
+            if (!await _distributedLock.AcquireLock(lockId))
+            {
+                return;
+            }
+
             var caseFile = await _caseFileQueryRepository.FindById(@event.AggregateId);
             var tDefinitions = CMMNParser.ParseWSDL(caseFile.Payload);
             foreach (var casePlan in CMMNParser.ExtractCasePlans(tDefinitions, caseFile))
@@ -35,6 +45,7 @@ public async Task Handle(CaseFilePublishedEvent @event, CancellationToken cancel
             }
 
             await _casePlanCommandRepository.SaveChanges();
+            await _distributedLock.ReleaseLock(lockId);
         }
     }
-}
+}

src/CaseManagement.CMMN/CasePlanInstance/CasePlanInstanceService.cs

@@ -400,34 +400,11 @@ private static JObject ToDto(CaseInstanceExecutionContext context)
 
         private static FindWorkflowInstanceParameter ExtractFindParameter(IEnumerable<KeyValuePair<string, string>> query)
         {
-            int startIndex;
-            int count;
-            string orderBy;
-            FindOrders findOrder;
             string casePlanId;
             string owner;
             bool takeLatest;
             var parameter = new FindWorkflowInstanceParameter();
-            if (query.TryGet("start_index", out startIndex))
-            {
-                parameter.StartIndex = startIndex;
-            }
-
-            if (query.TryGet("count", out count))
-            {
-                parameter.Count = count;
-            }
-
-            if (query.TryGet("order_by", out orderBy))
-            {
-                parameter.OrderBy = orderBy;
-            }
-
-            if (query.TryGet("order", out findOrder))
-            {
-                parameter.Order = findOrder;
-            }
-
+            parameter.ExtractFindParameter(query);
             if (query.TryGet("case_plan_id", out casePlanId))
             {
                 parameter.CasePlanId = casePlanId;

src/CaseManagement.CMMN/CasePlanInstance/CommandHandlers/ActivateCommandHandler.cs

@@ -3,7 +3,6 @@
 using CaseManagement.CMMN.CaseWorkerTask;
 using CaseManagement.CMMN.CaseWorkerTask.Commands;
 using CaseManagement.CMMN.Domains;
-using CaseManagement.CMMN.Infrastructures;
 using CaseManagement.CMMN.Infrastructures.Bus;
 using CaseManagement.CMMN.Infrastructures.EvtStore;
 using CaseManagement.Workflow.Infrastructure.Bus;

src/CaseManagement.CMMN/Domains/Role/Events/RoleDeletedEvent.cs

@@ -0,0 +1,11 @@
+using CaseManagement.CMMN.Infrastructures;
+
+namespace CaseManagement.CMMN.Domains.Role.Events
+{
+    public class RoleDeletedEvent : DomainEvent
+    {
+        public RoleDeletedEvent(string id, string aggregateId, int version) : base(id, aggregateId, version)
+        {
+        }
+    }
+}

src/CaseManagement.CMMN/Domains/Role/Events/RoleUpdatedEvent.cs

@@ -0,0 +1,18 @@
+using CaseManagement.CMMN.Infrastructures;
+using System;
+using System.Collections.Generic;
+
+namespace CaseManagement.CMMN.Domains.Role.Events
+{
+    public class RoleUpdatedEvent : DomainEvent
+    {
+        public RoleUpdatedEvent(string id, string aggregateId, int version, ICollection<string> users, DateTime updateDateTime) : base(id, aggregateId, version)
+        {
+            Users = users;
+            UpdateDateTime = updateDateTime;
+        }
+
+        public ICollection<string> Users { get; set; }
+        public DateTime UpdateDateTime { get; set; }
+    }
+}