diff --git a/src/WorkflowEngine.Core/IWorkflow.cs b/src/WorkflowEngine.Core/IWorkflow.cs index b9f3762..1fd1736 100644 --- 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 where TInput : class + { + + } } diff --git a/src/WorkflowEngine.Core/IWorkflowExecutor.cs b/src/WorkflowEngine.Core/IWorkflowExecutor.cs index 05ee87c..204a645 100644 --- 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 other) other.PrincipalId = PrincipalId; return other; } + + } public interface IWorkflowExecutor { diff --git a/src/WorkflowEngine.Core/Workflow.cs b/src/WorkflowEngine.Core/Workflow.cs index 2b4fda8..98c8553 100644 --- 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 : Workflow, IWorkflowInputs + where TInput : class + { + + } } diff --git a/src/WorkflowEngine.Hangfire/WorkflowStarterBackgroundJob.cs b/src/WorkflowEngine.Hangfire/WorkflowStarterBackgroundJob.cs index b793cfe..735b93a 100644 --- 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>)((executor) => executor.TriggerAsync(new TriggerContext { + PrincipalId = "1b714972-8d0a-4feb-b166-08d93c6ae328", Workflow = workflow, Trigger = new Trigger {