Ticket #106 & #105 : Pass tokens in CaseManagement tool + add simple form builder

Author: habarthierry-hue

create-neventstore-table.txt

@@ -0,0 +1,35 @@
+IF EXISTS(SELECT * FROM sysobjects WHERE name='Commits' AND xtype = 'U') RETURN;
+CREATE TABLE [dbo].[Commits]
+(
+       [BucketId] [varchar](200) NOT NULL,
+       [StreamId] [char](200) NOT NULL,
+       [StreamIdOriginal] [nvarchar](1000) NOT NULL,
+       [StreamRevision] [int] NOT NULL CHECK ([StreamRevision] > 0),
+       [Items] [int] NOT NULL CHECK ([Items] > 0),
+       [CommitId] [uniqueidentifier] NOT NULL CHECK ([CommitId] != 0x0),
+       [CommitSequence] [int] NOT NULL CHECK ([CommitSequence] > 0),
+       [CheckpointNumber] [bigint] IDENTITY NOT NULL,
+       [Headers] [varbinary](MAX) NULL CHECK ([Headers] IS NULL OR DATALENGTH([Headers]) > 0),
+       [Payload] [varbinary](MAX) NOT NULL CHECK (DATALENGTH([Payload]) > 0),
+       CONSTRAINT [PK_Commits] PRIMARY KEY CLUSTERED ([CheckpointNumber])
+);
+
+--datetime2 is supported starting from MSSQL 2008. For MSSQL 2005 datetime has to be used
+IF EXISTS(SELECT * FROM sys.types WHERE NAME = 'datetime2')
+	ALTER TABLE [dbo].[Commits] ADD [CommitStamp] [datetime2] NOT NULL
+ELSE
+	ALTER TABLE [dbo].[Commits] ADD [CommitStamp] [datetime] NOT NULL
+
+CREATE UNIQUE NONCLUSTERED INDEX [IX_Commits_CommitSequence] ON Commits (BucketId, StreamId, CommitSequence);
+CREATE UNIQUE NONCLUSTERED INDEX [IX_Commits_CommitId] ON [dbo].[Commits] ([BucketId], [StreamId], [CommitId]);
+CREATE UNIQUE NONCLUSTERED INDEX [IX_Commits_Revisions] ON [dbo].[Commits] ([BucketId], [StreamId], [StreamRevision], [Items]);
+CREATE INDEX [IX_Commits_Stamp] ON Commits ([CommitStamp]);
+
+CREATE TABLE [dbo].[Snapshots]
+(
+       [BucketId] [varchar](40) NOT NULL,
+       [StreamId] [char](40) NOT NULL,
+       [StreamRevision] [int] NOT NULL CHECK ([StreamRevision] > 0),
+       [Payload] [varbinary](MAX) NOT NULL CHECK (DATALENGTH([Payload]) > 0),
+       CONSTRAINT [PK_Snapshots] PRIMARY KEY CLUSTERED ([BucketId], [StreamId], [StreamRevision])
+);

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.Host.Delegates.GetWeatherInformationDelegate">
+    <serviceTask id="Task_1hcentk" name="Check weather conditions" implementation="##csharpcallback" cmg:className="CaseManagement.BPMN.SqlServer.Host.Delegates.GetWeatherInformationDelegate">
       <incoming>SequenceFlow_0h21x7r</incoming>
       <outgoing>Flow_0ofj7xp</outgoing>
     </serviceTask>

src/CaseManagement.BPMN.SqlServer.Host/CaseManagement.BPMN.SqlServer.Host.csproj

@@ -47,4 +47,7 @@
       <LastGenOutput>SqlStatements.Designer.cs</LastGenOutput>
     </EmbeddedResource>
   </ItemGroup>
+  <ItemGroup>
+    <Folder Include="Migrations\" />
+  </ItemGroup>
 </Project>

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

@@ -0,0 +1,26 @@
+using CaseManagement.BPMN.Common;
+using Newtonsoft.Json.Linq;
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace CaseManagement.BPMN.SqlServer.Host.Delegates
+{
+    public class GetWeatherInformationDelegate : IDelegateHandler
+    {
+        public Task<ICollection<MessageToken>> Execute(ICollection<MessageToken> incoming, CancellationToken cancellationToken)
+        {
+            ICollection<MessageToken> result = new List<MessageToken>();
+            var rnd = new Random();
+            var degree = rnd.Next(0, 40);
+
+            result.Add(MessageToken.NewMessage("weatherInformation", new JObject
+            {
+                { "city", "Bruxelles" },
+                { "degree", degree }
+            }.ToString()));
+            return Task.FromResult(result);
+        }
+    }
+}

…grations/20201218131021_Init.Designer.cs …grations/20210201134341_Init.Designer.cssrc/CaseManagement.BPMN.SqlServer.Host/Migrations/20201218131021_Init.Designer.cs renamed to src/CaseManagement.BPMN.SqlServer.Host/Migrations/20210201134341_Init.Designer.cs src/CaseManagement.BPMN.SqlServer.Host/Migrations/20201218131021_Init.Designer.cs renamed to src/CaseManagement.BPMN.SqlServer.Host/Migrations/20210201134341_Init.Designer.cs

@@ -83,8 +83,7 @@ public void ConfigureServices(IServiceCollection services)
             var factory = new NetStandardConnectionFactory(SqlClientFactory.Instance, _configuration.GetConnectionString("db"));
             var wireup = Wireup.Init()
                 .UsingSqlPersistence(factory)
-                .WithDialect(new SqlDialect())
-                .InitializeStorageEngine()
+                .WithDialect(new MsSqlDialect())
                 .UsingBinarySerialization()
                 .Build();
             services.AddSingleton<IStoreEvents>(wireup);

…r.Host/Migrations/20201218131021_Init.cs …r.Host/Migrations/20210201134341_Init.cssrc/CaseManagement.BPMN.SqlServer.Host/Migrations/20201218131021_Init.cs renamed to src/CaseManagement.BPMN.SqlServer.Host/Migrations/20210201134341_Init.cs src/CaseManagement.BPMN.SqlServer.Host/Migrations/20201218131021_Init.cs renamed to src/CaseManagement.BPMN.SqlServer.Host/Migrations/20210201134341_Init.cs

@@ -15,7 +15,6 @@ namespace CaseManagement.BPMN.ProcessInstance.Commands.Handlers
     public class MakeStateTransitionCommandHandler : IRequestHandler<MakeStateTransitionCommand, bool>
     {
         private readonly IEventStoreRepository _eventStoreRepository;
-        private readonly IProcessInstanceQueryRepository _processInstanceQueryRepository;
         private readonly ILogger<MakeStateTransitionCommandHandler> _logger;
         private readonly IMessageBroker _messageBroker;
 
@@ -44,7 +43,7 @@ public async Task<bool> Handle(MakeStateTransitionCommand request, CancellationT
                 throw new UnknownFlowNodeElementInstanceException(string.Format(Global.UnknownProcessElementInstance, request.FlowNodeElementInstanceId));
             }
 
-            await _messageBroker.QueueStateTransition(request.FlowNodeInstanceId, request.FlowNodeElementInstanceId, request.State, request.Content, cancellationToken);
+            await _messageBroker.QueueStateTransition(request.FlowNodeInstanceId, request.FlowNodeElementInstanceId, request.State, request.Parameters, cancellationToken);
             return true;
         }
     }

src/CaseManagement.BPMN.SqlServer.Host/SqlDialect.cs

@@ -8,6 +8,6 @@ public class MakeStateTransitionCommand : IRequest<bool>
         public string State { get; set; }
         public string FlowNodeInstanceId { get; set; }
         public string FlowNodeElementInstanceId { get; set; }
-        public JObject Content { get; set; }
+        public JObject Parameters { get; set; }
     }
 }