Simplified source generation using attribute

Cleipnir.Flows.Tests.AspNet/TestFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Tests.AspNet;
 
+[GenerateFlows]
 public class TestFlow : Flow<string, string>
 {
     public override Task<string> Run(string param)

Cleipnir.Flows.Tests/Flows/FlowsWithStateTests.cs

@@ -93,6 +93,7 @@ public async Task FuncFlowWithStateCanBeFetchedAfterExecution()
     }
 }
 
+[GenerateFlows]
 public class ActionWithStateFlow : Flow<string>, IExposeState<ActionWithStateFlow.WorkflowState>
 {
     public required WorkflowState State { get; init; }
@@ -109,6 +110,7 @@ public class WorkflowState : FlowState
     }
 }
 
+[GenerateFlows]
 public class FuncWithStateFlow : Flow<string, string>, IExposeState<FuncWithStateFlow.WorkflowState>
 {
     public required WorkflowState State { get; init; }
@@ -125,6 +127,7 @@ public class WorkflowState : FlowState
     }
 }
 
+[GenerateFlows]
 public class ParamlessWithStateFlow : Flow, IExposeState<ParamlessWithStateFlow.WorkflowState>
 {
     public required WorkflowState State { get; init; }

Cleipnir.Flows.Tests/Flows/OptionsTests.cs

@@ -77,6 +77,7 @@ public async Task FlowNameCanBeSpecifiedFromTheOutside()
     }
 }
 
+[GenerateFlows]
 public class OptionsTestWithOverriddenOptionsFlow : Flow
 {
     public override async Task Run()
@@ -85,6 +86,7 @@ public override async Task Run()
     }
 }
 
+[GenerateFlows]
 public class OptionsTestWithDefaultProvidedOptionsFlow : Flow
 {
     public override async Task Run()
@@ -93,6 +95,7 @@ public override async Task Run()
     }
 }
 
+[GenerateFlows]
 public class SimpleFlow : Flow
 {
     public override Task Run() => Task.CompletedTask;

Cleipnir.Flows/GenerateFlowsAttribute.cs

@@ -0,0 +1,4 @@
+namespace Cleipnir.Flows;
+
+[System.AttributeUsage(System.AttributeTargets.Class)]
+public class GenerateFlowsAttribute : System.Attribute;

Samples/Cleipnir.Flows.Sample.AspNet/Flows/OrderFlow.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Flows;
 
+[GenerateFlows]
 public class OrderFlow : Flow<Order>
 {
     private readonly IPaymentProviderClient _paymentProviderClient;

Samples/Cleipnir.Flows.Sample.Presentation.AspNet/Flows/MessageDriven/MessageDrivenOrderFlow.cs

@@ -1,9 +1,8 @@
 using Cleipnir.Flows.Sample.MicrosoftOpen.Flows.MessageDriven.Other;
-using Cleipnir.ResilientFunctions.Helpers;
-using Cleipnir.ResilientFunctions.Reactive.Extensions;
 
 namespace Cleipnir.Flows.Sample.MicrosoftOpen.Flows.MessageDriven;
 
+[GenerateFlows]
 public class MessageDrivenOrderFlow(Bus bus) : Flow<Order>
 {
     public override async Task Run(Order order)

Samples/Cleipnir.Flows.Sample.Presentation.AspNet/Flows/MessageDriven/Solution/MessageDrivenOrderFlow.cs

@@ -3,6 +3,7 @@
 
 namespace Cleipnir.Flows.Sample.MicrosoftOpen.Flows.MessageDriven.Solution;
 
+[GenerateFlows]
 public class MessageDrivenOrderFlow(Bus bus) : Flow<Order>
 {
     public override async Task Run(Order order)

Samples/Cleipnir.Flows.Sample.Presentation.AspNet/Flows/Rpc/OrderFlow.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.MicrosoftOpen.Flows.Rpc;
 
+[GenerateFlows]
 public class OrderFlow(
     IPaymentProviderClient paymentProviderClient,
     IEmailClient emailClient,

Samples/Cleipnir.Flows.Sample.Presentation.AspNet/Flows/Rpc/Solution/OrderFlow.cs

@@ -3,6 +3,7 @@
 
 namespace Cleipnir.Flows.Sample.MicrosoftOpen.Flows.Rpc.Solution;
 
+[GenerateFlows]
 public class OrderFlow(
     IPaymentProviderClient paymentProviderClient,
     IEmailClient emailClient,

Samples/Cleipnir.Flows.Sample.Presentation/A_OrderFlowRpc/OrderFlow.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.A_OrderFlowRpc;
 
+[GenerateFlows]
 public class OrderFlow : Flow<Order>
 {
     private readonly IPaymentProviderClient _paymentProviderClient;

Samples/Cleipnir.Flows.Sample.Presentation/A_OrderFlowRpc/Solution/OrderFlow.cs

@@ -3,6 +3,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.A_OrderFlowRpc.Solution;
 
+[GenerateFlows]
 public class OrderFlow : Flow<Order>
 {
     private readonly IPaymentProviderClient _paymentProviderClient;

Samples/Cleipnir.Flows.Sample.Presentation/B_OrderFlow_Messaging/OrderFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.B_OrderFlow_Messaging;
 
+[GenerateFlows]
 public class OrderFlow : Flow<Order>
 {
     /*

Samples/Cleipnir.Flows.Sample.Presentation/B_OrderFlow_Messaging/Solution/OrderFlow.cs

@@ -5,6 +5,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.B_OrderFlow_Messaging.Solution;
 
+[GenerateFlows]
 public class OrderFlow(MessageBroker messageBroker) : Flow<Order>
 {
     private ILogger Logger { get; } = Log.Logger.ForContext<OrderFlow>();

Samples/Cleipnir.Flows.Sample.Presentation/C_NewsletterSender/Distributed/NewsletterChildFlow.cs

@@ -5,6 +5,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.C_NewsletterSender.Distributed;
 
+[GenerateFlows]
 public class NewsletterChildFlow(NewsletterParentFlows parentFlows, int child) : Flow<NewsletterChildWork>
 {
     public override async Task Run(NewsletterChildWork work)

Samples/Cleipnir.Flows.Sample.Presentation/C_NewsletterSender/Distributed/NewsletterParentFlow.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.C_NewsletterSender.Distributed;
 
+[GenerateFlows]
 public class NewsletterParentFlow(NewsletterChildFlows childFlows) : Flow<MailAndRecipients>
 {
     public override async Task Run(MailAndRecipients param)

Samples/Cleipnir.Flows.Sample.Presentation/C_NewsletterSender/NewsletterFlow.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.C_NewsletterSender;
 
+[GenerateFlows]
 public class NewsletterFlow : Flow<MailAndRecipients>
 {
     /*

Samples/Cleipnir.Flows.Sample.Presentation/C_NewsletterSender/Solution/NewsletterFlow.cs

@@ -5,6 +5,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.C_NewsletterSender.Solution;
 
+[GenerateFlows]
 public class NewsletterFlow : Flow<MailAndRecipients>, IExposeState<NewsletterFlow.NewsletterState>
 {
     public required NewsletterState State { get; init; }

Samples/Cleipnir.Flows.Sample.Presentation/D_LoanApplication/LoanApplicationFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.D_LoanApplication;
 
+[GenerateFlows]
 public class LoanApplicationFlow : Flow<LoanApplication>
 {
     public override async Task Run(LoanApplication loanApplication)

Samples/Cleipnir.Flows.Sample.Presentation/D_LoanApplication/Solution/LoanApplicationFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.D_LoanApplication.Solution;
 
+[GenerateFlows]
 public class LoanApplicationFlow : Flow<LoanApplication>
 {
     public override async Task Run(LoanApplication loanApplication)

Samples/Cleipnir.Flows.Sample.Presentation/E_CustomerSignup/SignupFlow.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.E_CustomerSignup;
 
+[GenerateFlows]
 public class SignupFlow : Flow<string>
 {
     public override async Task Run(string customerEmail)

Samples/Cleipnir.Flows.Sample.Presentation/E_CustomerSignup/Solution/SignupFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.E_CustomerSignup.Solution;
 
+[GenerateFlows]
 public class SignupFlow : Flow<string>
 {
     public override async Task Run(string customerEmail)

Samples/Cleipnir.Flows.Sample.Presentation/F_SmsVerificationFlow/SmsFlow.cs

@@ -3,6 +3,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.F_SmsVerificationFlow;
 
+[GenerateFlows]
 public class SmsFlow : Flow<string>, IExposeState<SmsFlow.SmsState>
 {
     public required SmsState State { get; init; }

Samples/Cleipnir.Flows.Sample.Presentation/G_SupportTicket/Solution/SupportTicketFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.G_SupportTicket.Solution;
 
+[GenerateFlows]
 public class SupportTicketFlow : Flow<SupportTicketRequest>
 {
     public override async Task Run(SupportTicketRequest request)

Samples/Cleipnir.Flows.Sample.Presentation/G_SupportTicket/SupportTicketFlow.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.G_SupportTicket;
 
+[GenerateFlows]
 public class SupportTicketFlow : Flow<SupportTicketRequest>
 {
     public override async Task Run(SupportTicketRequest request)

Samples/Cleipnir.Flows.Sample.Presentation/H_BankTransfer/Example.cs

@@ -0,0 +1,29 @@
+using Cleipnir.ResilientFunctions.PostgreSQL;
+
+namespace Cleipnir.Flows.Sample.Presentation.H_BankTransfer;
+
+public static class Example
+{
+    public static async Task Perform()
+    {
+        var serviceCollection = new ServiceCollection();
+        serviceCollection.AddTransient<TransferFlow>();
+
+        var connStr = "Server=localhost;Database=presentation;User Id=postgres;Password=Pa55word!; Include Error Detail=true;";
+        await DatabaseHelper.CreateDatabaseIfNotExists(connStr);
+        var store = new PostgreSqlFunctionStore(connStr);
+        await store.Initialize();
+
+        var flowsContainer = new FlowsContainer(
+            store,
+            serviceCollection.BuildServiceProvider(),
+            Options.Default
+        );
+
+        var transferFlows = new TransferFlows(flowsContainer);
+        var transactionId = Guid.NewGuid();
+        await transferFlows.Run(
+            transactionId.ToString(), new Transfer(transactionId, "FROM_ACC123", "TO_ACC456", Amount: 100)
+        );
+    }
+}

Samples/Cleipnir.Flows.Sample.Presentation/H_BankTransfer/Solution/Example.cs

@@ -0,0 +1,29 @@
+using Cleipnir.ResilientFunctions.PostgreSQL;
+
+namespace Cleipnir.Flows.Sample.Presentation.H_BankTransfer.Solution;
+
+public static class Example
+{
+    public static async Task Perform()
+    {
+        var serviceCollection = new ServiceCollection();
+        serviceCollection.AddTransient<TransferFlow>();
+
+        var connStr = "Server=localhost;Database=presentation;User Id=postgres;Password=Pa55word!; Include Error Detail=true;";
+        await DatabaseHelper.CreateDatabaseIfNotExists(connStr);
+        var store = new PostgreSqlFunctionStore(connStr);
+        await store.Initialize();
+
+        var flowsContainer = new FlowsContainer(
+            store,
+            serviceCollection.BuildServiceProvider(),
+            Options.Default
+        );
+
+        var transferFlows = new TransferFlows(flowsContainer);
+        var transactionId = Guid.NewGuid();
+        await transferFlows.Run(
+            transactionId.ToString(), new Transfer(transactionId, "FROM_ACC123", "TO_ACC456", Amount: 100)
+        );
+    }
+}

Samples/Cleipnir.Flows.Sample.Presentation/H_BankTransfer/Solution/TransferFlow.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.H_BankTransfer.Solution;
 
+[GenerateFlows]
 public sealed class TransferFlow : Flow<Transfer>
 {
     public TransferFlow(IBankCentralClient bankCentralClient) => BankCentralClient = bankCentralClient;

Samples/Cleipnir.Flows.Sample.Presentation/H_BankTransfer/TransferFlow.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.H_BankTransfer;
 
+[GenerateFlows]
 public sealed class TransferFlow : Flow<Transfer>
 {
     public TransferFlow(IBankCentralClient bankCentralClient) => BankCentralClient = bankCentralClient;

Samples/Cleipnir.Flows.Sample.Presentation/OutBoxPattern/OutboxFlow.cs

@@ -2,6 +2,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.OutBoxPattern;
 
+[GenerateFlows]
 public class OutboxFlow(IBus bus) : Flow<Order>
 {
     public override async Task Run(Order order)

Samples/Cleipnir.Flows.Sample.Presentation/Program.cs

@@ -11,7 +11,8 @@ private static async Task Main(string[] args)
             .Enrich.FromLogContext()
             .CreateLogger();
 
-        await C_NewsletterSender.Distributed.Example.Perform();
+        //await C_NewsletterSender.Distributed.Example.Perform();
+        await H_BankTransfer.Example.Perform();
 
         Console.ReadLine();
     }

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/A_OrderFlowRpc/OrderFlow0.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.A_OrderFlowRpc;
 
+[GenerateFlows]
 public class OrderFlow0 : Flow<Order>
 {
     private readonly IPaymentProviderClient _paymentProviderClient;

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/A_OrderFlowRpc/OrderFlow1.cs

@@ -1,5 +1,6 @@
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.A_OrderFlowRpc;
 
+[GenerateFlows]
 public class OrderFlow1 : Flow<Order>
 {
     private readonly IPaymentProviderClient _paymentProviderClient;

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/A_OrderFlowRpc/OrderFlow2.cs

@@ -1,9 +1,8 @@
 using Cleipnir.ResilientFunctions.Domain;
-using Serilog;
-using ILogger = Serilog.ILogger;
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.A_OrderFlowRpc;
 
+[GenerateFlows]
 public class OrderFlow2 : Flow<Order>
 {
     private readonly IPaymentProviderClient _paymentProviderClient;

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/B_OrderFlowMessaging/OrderFlow.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.B_OrderFlowMessaging;
 
+[GenerateFlows]
 public class OrderFlow(Bus bus) : Flow<Order>
 {
     public override async Task Run(Order order)

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/C_NewsletterSender/NewsletterFlow0.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.C_NewsletterSender;
 
+[GenerateFlows]
 public class NewsletterFlow0 : Flow<MailAndRecipients>
 {
     public override async Task Run(MailAndRecipients mailAndRecipients)

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/C_NewsletterSender/NewsletterFlow1.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.C_NewsletterSender;
 
+[GenerateFlows]
 public class NewsletterFlow1 : Flow<MailAndRecipients>
 {
     public override async Task Run(MailAndRecipients mailAndRecipients)

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/C_NewsletterSender/NewsletterFlow_Parallelized.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.C_NewsletterSender;
 
+[GenerateFlows]
 public class NewsletterFlow_Parallelized : Flow<MailAndRecipients>
 {
     public override async Task Run(MailAndRecipients mailAndRecipients)

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/C_NewsletterSender/NewsletterFlow_SpaceOptimized.cs

@@ -4,6 +4,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.C_NewsletterSender;
 
+[GenerateFlows]
 public class NewsletterFlow_SpaceOptimized : Flow<MailAndRecipients>
 {
     public override async Task Run(MailAndRecipients mailAndRecipients)

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/D_LoanApplication/LoanApplicationFlow0.cs

@@ -3,6 +3,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.D_LoanApplication;
 
+[GenerateFlows]
 public class LoanApplicationFlow0 : Flow<LoanApplication>
 {
     public override async Task Run(LoanApplication loanApplication)

Samples/Cleipnir.Flows.Sample.Presentation/Solutions/D_LoanApplication/LoanApplicationFlow1.cs

@@ -3,6 +3,7 @@
 
 namespace Cleipnir.Flows.Sample.Presentation.Solutions.D_LoanApplication;
 
+[GenerateFlows]
 public class LoanApplicationFlow1 : Flow<LoanApplication>
 {
     public override async Task Run(LoanApplication loanApplication)