Add C# CombinedPatterns

Author: marcduiker

tutorials/workflow/csharp/CombinedPatterns/ShippingApp/Constants.cs

@@ -0,0 +1,5 @@
+public class Constants
+{
+    public const string DAPR_PUBSUB_COMPONENT = "shippingpubsub";
+    public const string DAPR_PUBSUB_TOPIC = "shipment-registration-events";
+}

tutorials/workflow/csharp/CombinedPatterns/ShippingApp/Program.cs

@@ -0,0 +1,42 @@
+using Dapr.Client;
+
+var builder = WebApplication.CreateBuilder(args);
+builder.Services.AddDaprClient();
+var app = builder.Build();
+app.UseCloudEvents();
+
+app.MapPost("/checkDestination", (
+    Order order) => {
+    Console.WriteLine($"checkDestination: Received input: {order}.");
+    var result = new ShippingDestinationResult(IsSuccess: true);
+    return Results.Ok(result);
+});
+
+app.MapPost("/registerShipment", async (
+    Order order,
+    DaprClient daprClient) => {
+    Console.WriteLine($"registerShipment: Received input: {order}.");
+    var status = new ShipmentRegistrationStatus(OrderId: order.Id, IsSucces: true);
+
+    if (order.Id == string.Empty)
+    {
+        Console.WriteLine($"Order Id is empty!");
+    }
+    else
+    {
+        await daprClient.PublishEventAsync(
+            Constants.DAPR_PUBSUB_COMPONENT,
+            Constants.DAPR_PUBSUB_TOPIC,
+            status);
+    }
+
+    return Results.Created();
+});
+
+app.Run();
+
+public record Order(string Id, OrderItem OrderItem, CustomerInfo CustomerInfo);
+public record OrderItem(string ProductId, string ProductName, int Quantity, decimal TotalPrice);
+public record CustomerInfo(string Id, string Country);
+public record ShipmentRegistrationStatus(string OrderId, bool IsSucces, string Message = "");
+public record ShippingDestinationResult(bool IsSuccess, string Message = "");

tutorials/workflow/csharp/CombinedPatterns/ShippingApp/Properties/launchSettings.json

@@ -0,0 +1,23 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:5261",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:7086;http://localhost:5261",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

tutorials/workflow/csharp/CombinedPatterns/ShippingApp/ShippingApp.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Dapr.AspNetCore" Version="1.15.2" />
+  </ItemGroup>
+
+</Project>

tutorials/workflow/csharp/CombinedPatterns/ShippingApp/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Warning",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

tutorials/workflow/csharp/CombinedPatterns/ShippingApp/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

tutorials/workflow/csharp/CombinedPatterns/WorkflowApp/Activities/CheckInventory.cs

@@ -0,0 +1,33 @@
+using Dapr.Client;
+using Dapr.Workflow;
+
+namespace WorkflowApp.Activities;
+
+public class CheckInventory : WorkflowActivity<OrderItem, ActivityResult>
+{
+    DaprClient _daprClient;
+
+    public CheckInventory(DaprClient daprClient)
+    {
+        _daprClient = daprClient;
+    }
+
+    public override async Task<ActivityResult> RunAsync(WorkflowActivityContext context, OrderItem orderItem)
+    {
+        Console.WriteLine($"{nameof(CheckInventory)}: Received input: {orderItem}.");
+
+        var productInventory = await _daprClient.GetStateAsync<ProductInventory>(
+                Constants.DAPR_INVENTORY_COMPONENT,
+                orderItem.ProductId);
+
+        if (productInventory == null)
+        {
+            return new ActivityResult(IsSuccess: false);
+        }
+
+        var isAvailable = productInventory.Quantity >= orderItem.Quantity;
+        return new ActivityResult(IsSuccess: isAvailable);
+    }
+}
+
+public record ActivityResult(bool IsSuccess, string Message = "");

tutorials/workflow/csharp/CombinedPatterns/WorkflowApp/Activities/CheckShippingDestination.cs

@@ -0,0 +1,30 @@
+using System.Net;
+using Dapr.Workflow;
+
+namespace WorkflowApp.Activities;
+
+public class CheckShippingDestination : WorkflowActivity<Order, ActivityResult>
+{
+    private readonly HttpClient _httpClient;
+
+    public CheckShippingDestination(HttpClient httpClient)
+    {
+        _httpClient = httpClient;
+    }
+
+    public override async Task<ActivityResult> RunAsync(WorkflowActivityContext context, Order order)
+    {
+        Console.WriteLine($"{nameof(CheckShippingDestination)}: Received input: {order}.");
+
+        var response = await _httpClient.PostAsJsonAsync("/checkDestination", order);
+        if (response.StatusCode != HttpStatusCode.OK)
+        {
+            throw new Exception($"Failed to register shipment. Reason: {response.ReasonPhrase}.");
+        }
+
+        var result = await response.Content.ReadFromJsonAsync<ShippingDestinationResult>();
+        return new ActivityResult(IsSuccess: result.IsSuccess);
+    }
+}
+
+public record ShippingDestinationResult(bool IsSuccess);

tutorials/workflow/csharp/CombinedPatterns/WorkflowApp/Activities/ProcessPayment.cs

@@ -0,0 +1,14 @@
+using Dapr.Workflow;
+
+namespace WorkflowApp.Activities;
+
+public class ProcessPayment : WorkflowActivity<Order, PaymentResult>
+{
+    public override Task<PaymentResult> RunAsync(WorkflowActivityContext context, Order order)
+    {
+        Console.WriteLine($"{nameof(ProcessPayment)}: Received input: {order}.");
+        return Task.FromResult(new PaymentResult(IsSuccess: true));
+    }
+}
+
+public record PaymentResult(bool IsSuccess);

tutorials/workflow/csharp/CombinedPatterns/WorkflowApp/Activities/RegisterShipment.cs

@@ -0,0 +1,28 @@
+using Dapr.Client;
+using Dapr.Workflow;
+
+namespace WorkflowApp.Activities;
+
+public class RegisterShipment : WorkflowActivity<Order, RegisterShipmentResult>
+{
+    private readonly DaprClient _daprClient;
+
+    public RegisterShipment(DaprClient daprClient)
+    {
+        _daprClient = daprClient;
+    }
+
+    public override async Task<RegisterShipmentResult> RunAsync(WorkflowActivityContext context, Order order)
+    {
+        Console.WriteLine($"{nameof(RegisterShipment)}: Received input: {order}.");
+
+        await _daprClient.PublishEventAsync(
+            Constants.DAPR_PUBSUB_COMPONENT,
+            Constants.DAPR_PUBSUB_TOPIC,
+            order);
+
+        return new RegisterShipmentResult(IsSucces: true);
+    }
+}
+
+public record RegisterShipmentResult(bool IsSucces);