Ticket #112 : Implement Message Event - BPMN

Author: habarthierry-hue

src/CaseManagement.BPMN.AspNetCore/Apis/ProcessInstancesController.cs

@@ -83,6 +83,24 @@ public async Task<IActionResult> Start(string id, CancellationToken cancellation
             }
         }
 
+        [HttpPost("{id}/messages")]
+        public async Task<IActionResult> ConsumeMessage(string id, [FromBody] ConsumeMessageInstanceCommand consumeMessageInstanceCommand, CancellationToken token)
+        {
+            try
+            {
+                consumeMessageInstanceCommand.FlowNodeInstanceId = id;
+                await _mediator.Send(consumeMessageInstanceCommand, token);
+                return new OkResult();
+            }
+            catch (UnknownFlowInstanceException ex)
+            {
+                return this.ToError(new List<KeyValuePair<string, string>>
+                {
+                    new KeyValuePair<string, string>("bad_request", ex.Message)
+                }, HttpStatusCode.NotFound, Request);
+            }
+        }
+
         [HttpPost("{id}/statetransitions")]
         public async Task<IActionResult> MakeTransition(string id, [FromBody] MakeStateTransitionCommand stateTransitionCommand, CancellationToken token)
         {

src/CaseManagement.BPMN.Host/Bpmns/GetWeatherInformation.bpmn

@@ -5,7 +5,7 @@
       <outgoing>SequenceFlow_0h21x7r</outgoing>
     </startEvent>
     <sequenceFlow id="SequenceFlow_0h21x7r" sourceRef="StartEvent_1y45yut" targetRef="Task_1hcentk" />
-    <serviceTask id="Task_1hcentk" name="Check weather conditions" implementation="##csharpcallback" cmg:className="CaseManagement.BPMN.Host.Delegates.GetWeatherInformationDelegate">
+    <serviceTask id="Task_1hcentk" name="Check weather conditions" implementation="##csharpcallback" cmg:delegateId="GetWeatherInformationDelegate">
       <incoming>SequenceFlow_0h21x7r</incoming>
       <outgoing>Flow_0ofj7xp</outgoing>
     </serviceTask>

src/CaseManagement.BPMN.Host/Delegates/GetWeatherInformationDelegate.cs

@@ -9,7 +9,7 @@ namespace CaseManagement.BPMN.Host.Delegates
 {
     public class GetWeatherInformationDelegate : IDelegateHandler
     {
-        public Task<ICollection<MessageToken>> Execute(ICollection<MessageToken> incoming, CancellationToken cancellationToken)
+        public Task<ICollection<MessageToken>> Execute(ICollection<MessageToken> incoming, DelegateConfigurationAggregate delegateConfiguration, CancellationToken cancellationToken)
         {
             ICollection<MessageToken> result = new List<MessageToken>();
             var rnd = new Random();

src/CaseManagement.BPMN.Host/Delegates/SendEmailDelegate.cs

@@ -0,0 +1,66 @@
+using CaseManagement.BPMN.Domains;
+using CaseManagement.BPMN.Exceptions;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net;
+using System.Net.Mail;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace CaseManagement.BPMN.Host.Delegates
+{
+    public class SendEmailDelegate : IDelegateHandler
+    {
+        public Task<ICollection<MessageToken>> Execute(ICollection<MessageToken> incoming, DelegateConfigurationAggregate delegateConfiguration, CancellationToken cancellationToken)
+        {
+            var email = incoming.FirstOrDefault(i => i.Name == "email");
+            if (email == null)
+            {
+                throw new BPMNProcessorException("Email parameter is missing");
+            }
+
+
+            var parameter = SendDelegateParameter.Build(delegateConfiguration);
+            using (var smtpClient = new SmtpClient(parameter.SmtpHost)
+            {
+                Port = parameter.SmtpPort,
+                Credentials = new NetworkCredential(parameter.SmtpUserName, parameter.SmtpPassword),
+                EnableSsl = parameter.SmtpEnableSsl
+            })
+            {
+                var mailMessage = new MailMessage
+                {
+
+                };
+            }
+            
+            throw new NotImplementedException();
+        }
+
+        private class SendDelegateParameter
+        {
+            public string HttpBody { get; set; }
+            public string Subject { get; set; }
+            public string SmtpHost { get; set; }
+            public int SmtpPort { get; set; }
+            public string SmtpUserName { get; set; }
+            public string SmtpPassword { get; set; }
+            public bool SmtpEnableSsl { get; set; }
+
+            public static SendDelegateParameter Build(DelegateConfigurationAggregate delegateConfiguration)
+            {
+                return new SendDelegateParameter
+                {
+                    HttpBody = delegateConfiguration.GetValue("httpBody"),
+                    Subject = delegateConfiguration.GetValue("subject"),
+                    SmtpHost = delegateConfiguration.GetValue("smtpHost"),
+                    SmtpPort = delegateConfiguration.GetValueNumber("smtpPort"),
+                    SmtpUserName = delegateConfiguration.GetValue("smtpUserName"),
+                    SmtpPassword = delegateConfiguration.GetValue("smtpPassword"),
+                    SmtpEnableSsl = delegateConfiguration.GetValueBoolean("smtpEnableSsl")
+                };
+            }
+        }
+    }
+}

src/CaseManagement.BPMN.Host/Startup.cs

@@ -1,6 +1,6 @@
 // Copyright (c) SimpleIdServer. All rights reserved.
 // Licensed under the Apache License, Version 2.0. See LICENSE in the project root for license information.
-using CaseManagement.BPMN.AspNetCore.Apis;
+using CaseManagement.BPMN.Host.Delegates;
 using Microsoft.AspNetCore.Authentication.JwtBearer;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
@@ -11,6 +11,7 @@
 using Microsoft.IdentityModel.Tokens;
 using Newtonsoft.Json;
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
@@ -65,7 +66,10 @@ public void ConfigureServices(IServiceCollection services)
             {
                 opts.WSHumanTaskAPI = "http://localhost:60006";
                 opts.CallbackUrl = "http://localhost:60007/processinstances/{id}/complete/{eltId}";
-            }).AddProcessFiles(files);
+            }).AddProcessFiles(files).AddDelegateConfigurations(new ConcurrentBag<Domains.DelegateConfigurationAggregate>
+            {
+                Domains.DelegateConfigurationAggregate.Create("GetWeatherInformationDelegate", typeof(GetWeatherInformationDelegate).FullName)
+            });
             services.AddSwaggerGen();
             services.Configure<ForwardedHeadersOptions>(options =>
             {

src/CaseManagement.BPMN.Persistence.EF/BPMNDbContext.cs

@@ -1,4 +1,5 @@
 using CaseManagement.BPMN.Domains;
+using CaseManagement.BPMN.Domains.DelegateConfiguration;
 using Microsoft.EntityFrameworkCore;
 
 namespace CaseManagement.BPMN.Persistence.EF
@@ -9,6 +10,7 @@ public BPMNDbContext(DbContextOptions<BPMNDbContext> dbContextOptions) : base(db
 
         public DbSet<ProcessInstanceAggregate> ProcessInstances { get; set; }
         public DbSet<ProcessFileAggregate> ProcessFiles { get; set; }   
+        public DbSet<DelegateConfigurationAggregate> DelegateConfigurations { get; set; }
 
         protected override void OnModelCreating(ModelBuilder modelBuilder)
         {

src/CaseManagement.BPMN.Persistence.EF/Persistence/DelegateConfigurationRepository.cs

@@ -0,0 +1,22 @@
+using CaseManagement.BPMN.Domains;
+using Microsoft.EntityFrameworkCore;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace CaseManagement.BPMN.Persistence.EF.Persistence
+{
+    public class DelegateConfigurationRepository : IDelegateConfigurationRepository
+    {
+        private readonly BPMNDbContext _dbContext;
+
+        public DelegateConfigurationRepository(BPMNDbContext dbContext)
+        {
+            _dbContext = dbContext;
+        }
+
+        public Task<DelegateConfigurationAggregate> Get(string delegateId, CancellationToken cancellationToken)
+        {
+            return _dbContext.DelegateConfigurations.FirstOrDefaultAsync(d => d.AggregateId == delegateId, cancellationToken);
+        }
+    }
+}

src/CaseManagement.BPMN.Persistence.EF/ServiceCollectionExtensions.cs

@@ -14,6 +14,7 @@ public static IServiceCollection AddBPMNStoreEF(this IServiceCollection services
             services.AddTransient<IProcessInstanceQueryRepository, ProcessInstanceQueryRepository>();
             services.AddTransient<IProcessFileCommandRepository, ProcessFileCommandRepository>();
             services.AddTransient<IProcessFileQueryRepository, ProcessFileQueryRepository>();
+            services.AddTransient<IDelegateConfigurationRepository, DelegateConfigurationRepository>();
             services.AddDbContext<BPMNDbContext>(optionsAction, ServiceLifetime.Transient);
             return services;
         }

src/CaseManagement.BPMN.SqlServer.Host/Bpmns/GetWeatherInformation.bpmn

@@ -5,7 +5,7 @@
       <outgoing>SequenceFlow_0h21x7r</outgoing>
     </startEvent>
     <sequenceFlow id="SequenceFlow_0h21x7r" sourceRef="StartEvent_1y45yut" targetRef="Task_1hcentk" />
-    <serviceTask id="Task_1hcentk" name="Check weather conditions" implementation="##csharpcallback" cmg:className="CaseManagement.BPMN.SqlServer.Host.Delegates.GetWeatherInformationDelegate">
+    <serviceTask id="Task_1hcentk" name="Check weather conditions" implementation="##csharpcallback" cmg:delegateId="GetWeatherInformationDelegate">
       <incoming>SequenceFlow_0h21x7r</incoming>
       <outgoing>Flow_0ofj7xp</outgoing>
     </serviceTask>

src/CaseManagement.BPMN.SqlServer.Host/Delegates/GetWeatherInformationDelegate.cs

@@ -9,7 +9,7 @@ namespace CaseManagement.BPMN.SqlServer.Host.Delegates
 {
     public class GetWeatherInformationDelegate : IDelegateHandler
     {
-        public Task<ICollection<MessageToken>> Execute(ICollection<MessageToken> incoming, CancellationToken cancellationToken)
+        public Task<ICollection<MessageToken>> Execute(ICollection<MessageToken> incoming, DelegateConfigurationAggregate delegateConfiguration, CancellationToken cancellationToken)
         {
             ICollection<MessageToken> result = new List<MessageToken>();
             var rnd = new Random();