[WIP] CQRS example (#161)

* added initial sln structure and nuget packages

* imported all message types from shared project

* added `ProductTotalsActor`

* upgrade to .NET 8

* keep Nuke on .NET 6

* added .NET 6 install back for github actions

* defining EF contexts

* added EF context

* fleshing out backend

* got executable up and running

* fixed populator script

* finished first pass of projector

* fixing live execution of data model

* fixed missing create event tags

Author: Aaronontheweb

.github/workflows/pr_validation.yml

@@ -38,10 +38,10 @@ jobs:
         run: chmod +x ./build.cmd
       - uses: actions/setup-dotnet@v1
         with:
-          dotnet-version: 5.0.*
+          dotnet-version: 6.0.*
       - uses: actions/setup-dotnet@v1
         with:
-          dotnet-version: 6.0.*
+          dotnet-version: 8.0.*
       - name: Cache .nuke/temp, ~/.nuget/packages
         uses: actions/cache@v2
         with:
@@ -64,10 +64,10 @@ jobs:
         run: chmod +x ./build.cmd
       - uses: actions/setup-dotnet@v1
         with:
-          dotnet-version: 5.0.*
+          dotnet-version: 6.0.*
       - uses: actions/setup-dotnet@v1
         with:
-          dotnet-version: 6.0.*
+          dotnet-version: 8.0.*
       - name: Cache .nuke/temp, ~/.nuget/packages
         uses: actions/cache@v2
         with:

infrastructure/mssql-init-container/src/Akka.SqlInitContainer/Dockerfile

@@ -1,6 +1,6 @@
-FROM mcr.microsoft.com/dotnet/runtime:6.0
+FROM mcr.microsoft.com/dotnet/runtime:8.0
 WORKDIR /app
 
-COPY ./bin/Release/net6.0/publish/ /app
+COPY ./bin/Release/net8.0/publish/ /app
 
 CMD ["dotnet", "Akka.SqlInitContainer.dll"]

src/Directory.Build.props

@@ -2,7 +2,7 @@
   <PropertyGroup>
    <Copyright>Copyright © 2015-2022 Petabridge, LLC</Copyright>
     <Authors>Petabridge</Authors>
-    <VersionPrefix>0.2.0</VersionPrefix>
+    <VersionPrefix>0.1.0</VersionPrefix>
     <PackageReleaseNotes>• Initial rewrite of repository</PackageReleaseNotes>
     <PackageIconUrl>
     </PackageIconUrl>
@@ -13,7 +13,7 @@
     <NoWarn>$(NoWarn);CS1591</NoWarn>
   </PropertyGroup>
   <PropertyGroup>
-    <NetRuntime>net6.0</NetRuntime>
+    <NetRuntime>net8.0</NetRuntime>
     <XunitVersion>2.4.2</XunitVersion>
     <TestSdkVersion>17.6.0</TestSdkVersion>
     <AkkaVersion>1.5.15</AkkaVersion>

src/clustering/sharding-sqlserver/SqlSharding.Host/Dockerfile

@@ -1,6 +1,6 @@
-FROM mcr.microsoft.com/dotnet/runtime:6.0
+FROM mcr.microsoft.com/dotnet/runtime:8.0
 WORKDIR /app
 
-COPY ./bin/Release/net6.0/publish/ /app
+COPY ./bin/Release/net8.0/publish/ /app
 
 CMD ["dotnet", "SqlSharding.Host.dll"]

src/clustering/sharding-sqlserver/SqlSharding.Shared/SqlSharding.Shared.csproj

@@ -9,7 +9,10 @@
     <ItemGroup>
         <PackageReference Include="Akka.Cluster.Sharding" Version="$(AkkaVersion)" />
         <PackageReference Include="Akka.Cluster.Hosting" Version="$(AkkaHostingVersion)" />
-        <PackageReference Include="Grpc.AspNetCore" Version="2.61.0" />
+        <PackageReference Include="Grpc.Tools" Version="2.62.0">
+            <PrivateAssets>all</PrivateAssets>
+            <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+        </PackageReference>
         <PackageReference Include="Bogus" Version="35.5.0" />
     </ItemGroup>
 

src/clustering/sharding-sqlserver/SqlSharding.Sql.Host/Dockerfile

@@ -1,6 +1,6 @@
-FROM mcr.microsoft.com/dotnet/runtime:6.0
+FROM mcr.microsoft.com/dotnet/runtime:8.0
 WORKDIR /app
 
-COPY ./bin/Release/net6.0/publish/ /app
+COPY ./bin/Release/net8.0/publish/ /app
 
 CMD ["dotnet", "SqlSharding.Host.dll"]

src/clustering/sharding-sqlserver/SqlSharding.WebApp/Dockerfile

@@ -1,6 +1,6 @@
-FROM mcr.microsoft.com/dotnet/aspnet:6.0
+FROM mcr.microsoft.com/dotnet/aspnet:8.0
 WORKDIR /app
 
-COPY ./bin/Release/net6.0/publish/ /app
+COPY ./bin/Release/net8.0/publish/ /app
 
 CMD ["dotnet", "SqlSharding.WebApp.dll"]

src/cqrs/cqrs-sqlserver/CqrsSqlServer.Backend/Actors/ExponentialBackoffTimeout.cs

@@ -0,0 +1,19 @@
+// -----------------------------------------------------------------------
+//  <copyright file="ExponentialBackoffTimeout.cs" company="Akka.NET Project">
+//      Copyright (C) 2013-2024 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+// -----------------------------------------------------------------------
+
+namespace CqrsSqlServer.Backend.Actors;
+
+/// <summary>
+/// Utility class for retries / exponential backoff
+/// </summary>
+public static class ExponentialBackoffTimeout
+{
+    public static TimeSpan BackoffTimeout(int attemptCount, TimeSpan initialTimeout)
+    {
+        // going to keep the values small for now
+        return initialTimeout + attemptCount * TimeSpan.FromSeconds(1);
+    }
+}

src/cqrs/cqrs-sqlserver/CqrsSqlServer.Backend/Actors/GenericChildPerEntityParent.cs

@@ -0,0 +1,43 @@
+// -----------------------------------------------------------------------
+//  <copyright file="GenericChildPerEntityParent.cs" company="Akka.NET Project">
+//      Copyright (C) 2013-2024 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+// -----------------------------------------------------------------------
+
+using Akka.Actor;
+using Akka.Cluster.Sharding;
+
+namespace CqrsSqlServer.Backend.Actors;
+
+/// <summary>
+/// A generic "child per entity" parent actor.
+/// </summary>
+/// <remarks>
+/// Intended for simplifying unit tests where we don't want to use Akka.Cluster.Sharding.
+/// </remarks>
+public sealed class GenericChildPerEntityParent : ReceiveActor
+{
+    public static Props Props(IMessageExtractor extractor, Func<string, Props> propsFactory)
+    {
+        return Akka.Actor.Props.Create(() => new GenericChildPerEntityParent(extractor, propsFactory));
+    }
+    
+    /*
+     * Re-use Akka.Cluster.Sharding's infrastructure here to keep things simple.
+     */
+    private readonly IMessageExtractor _extractor;
+    private Func<string, Props> _propsFactory;
+
+    public GenericChildPerEntityParent(IMessageExtractor extractor, Func<string, Props> propsFactory)
+    {
+        _extractor = extractor;
+        _propsFactory = propsFactory;
+        
+        ReceiveAny(o =>
+        {
+            var result = _extractor.EntityId(o);
+            if (result is null) return;
+            Context.Child(result).GetOrElse(() => Context.ActorOf(propsFactory(result), result)).Forward(_extractor.EntityMessage(o));
+        });
+    }
+}