feat: Added typed workflow support

delegateas · Jun 20, 2024 · c9a6411 · c9a6411
1 parent 04ccdc1
commit c9a6411
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 2 deletions.
diff --git a/src/WorkflowEngine.Core/IWorkflow.cs b/src/WorkflowEngine.Core/IWorkflow.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 
 namespace WorkflowEngine.Core
 {
@@ -14,5 +14,9 @@ public interface IWorkflow // Documentet
 
     }
 
+    public interface IWorkflowInputs<TInput> where TInput : class
+    {
+
+    }
 
 }
diff --git a/src/WorkflowEngine.Core/IWorkflowExecutor.cs b/src/WorkflowEngine.Core/IWorkflowExecutor.cs
@@ -1,4 +1,5 @@
 using System;
+using System.Security.Claims;
 using System.Threading.Tasks;
 
 namespace WorkflowEngine.Core
@@ -16,6 +17,8 @@ public T CopyTo<T>(T other)
             other.PrincipalId = PrincipalId;
             return other;
         }
+
+
     }
     public interface IWorkflowExecutor
     {

diff --git a/src/WorkflowEngine.Core/Workflow.cs b/src/WorkflowEngine.Core/Workflow.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Linq;
 
 namespace WorkflowEngine.Core
@@ -24,6 +24,11 @@ public string ToString(string format, IFormatProvider formatProvider)
             return string.Empty;
         }
     }
+    public class Workflow<TInput> : Workflow, IWorkflowInputs<TInput>
+   where TInput : class
+    {
+
+    }
 
 
 }
diff --git a/src/WorkflowEngine.Hangfire/WorkflowStarterBackgroundJob.cs b/src/WorkflowEngine.Hangfire/WorkflowStarterBackgroundJob.cs
@@ -44,6 +44,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                             jobs.AddOrUpdate(workflow.Id.ToString() + trigger.Key,
                                 (System.Linq.Expressions.Expression<System.Action<IHangfireWorkflowExecutor>>)((executor) => executor.TriggerAsync(new TriggerContext
                                 {
+                                    PrincipalId = "1b714972-8d0a-4feb-b166-08d93c6ae328",
                                     Workflow = workflow,
                                     Trigger = new Trigger
                                     {