Galosoft.IaaS.WorkflowCore 25.1.16.2-nj

DI

Galosoft.IaaS.WorkflowCore

      services.AddWorkflowCore();

Definition

    {
        public override ExecutionResult Run(IStepExecutionContext context)
        {
            //throw new Exception();
            Console.WriteLine($"Start");
            return ExecutionResult.Next();
        }
    }

    public class PlusStepBody : StepBody
    {
        public override ExecutionResult Run(IStepExecutionContext context)
        {
            //throw new Exception();
            var input = context.Workflow.Data as PlusInput;
            input.Output = input.P1 + input.P2;
            return ExecutionResult.Next();
        }
    }

    internal class TestWorkflow : IWorkflow<WorkflowParameter>
    {
        public string Id => "test";

        public int Version => 1;

        public void Build(IWorkflowBuilder<WorkflowParameter> builder)
        {
            builder.StartWith<PlusStepBody>()
                .Then<PrintStepBody>()
                .Then(i => Console.WriteLine("over"));
        }
    }

    internal class EventHandlerWorkflow : IWorkflow
    {
        public string Id => "event-handler";

        public int Version => 1;

        public void Build(IWorkflowBuilder<object> builder)
        {
            builder
                .StartWith(context => ExecutionResult.Next())
                .WaitFor(Id, data => "plus")
                .Output((step, data) =>
                {
                    var input = step.EventData as PlusInput;
                    var d = (PlusInput)data;
                    d = input;
                    Tracer.Trace($"{input.P1}+{input.P2}", "eventhandler=>plus");
                })
                .Then<PlusStepBody>();
        }
    }

QucikStart

 using (var scope = _scopeFactory.CreateScope())
            {
                var sp = scope.ServiceProvider;
                var host = sp.GetRequiredService<IWorkflowHost>();
                //await host.StartWorkflow("test", new PlusInput { P1 = 1, P2 = 2 });
                await host.StartWorkflow("event-handler", new PlusInput { P1 = 1, P2 = 2 });
                await host.PublishEvent("event-handler", "plus", new PlusInput { P1 = 2, P2 = 3 });
            }