fixing live execution of data model

Author: Aaronontheweb

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

@@ -8,7 +8,7 @@
 using Akka.Event;
 using Akka.Persistence;
 using Akka.Persistence.Query;
-using Akka.Persistence.Query.Sql;
+using Akka.Persistence.Sql.Query;
 using Akka.Streams;
 using Akka.Streams.Dsl;
 using CqrsSqlServer.DataModel;
@@ -51,9 +51,11 @@ public sealed class ProductProjectorActor : ReceivePersistentActor
     public ProductProjectorActor(IServiceProvider serviceProvider)
     {
         _serviceProvider = serviceProvider;
+        CurrentState = new MaterializedViewState(Offset.NoOffset());
         PersistenceId = "product-projector";
 
         Recovers();
+        Commands();
     }
 
     private void Recovers()

src/cqrs/cqrs-sqlserver/CqrsSqlServer.Backend/CqrsSqlServer.Backend.csproj

@@ -13,7 +13,7 @@
     </ItemGroup>
 
     <ItemGroup>
-        <PackageReference Include="Akka.Persistence.SqlServer.Hosting" Version="1.5.15"/>
+        <PackageReference Include="Akka.Persistence.Sql.Hosting" Version="1.5.13" />
         <PackageReference Include="Petabridge.Cmd.Cluster" Version="$(PbmVersion)"/>
         <PackageReference Include="Petabridge.Cmd.Cluster.Sharding" Version="$(PbmVersion)"/>
         <PackageReference Include="Petabridge.Cmd.Host" Version="$(PbmVersion)"/>

src/cqrs/cqrs-sqlserver/CqrsSqlServer.Backend/Program.cs

@@ -1,17 +1,18 @@
 using Akka.Actor;
 using Akka.Hosting;
-using Akka.Persistence.SqlServer.Hosting;
+using Akka.Persistence.Sql.Config;
 using CqrsSqlServer.Backend.Actors;
 using CqrsSqlServer.DataModel;
 using CqrsSqlServer.Shared;
+using CqrsSqlServer.Shared.Events;
 using CqrsSqlServer.Shared.Serialization;
 using CqrsSqlServer.Shared.Sharding;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
-using Petabridge.Cmd.Cluster;
-using Petabridge.Cmd.Cluster.Sharding;
+using Akka.Persistence.Sql.Hosting;
+using LinqToDB;
 using Petabridge.Cmd.Host;
 
 var environment = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") ?? "Development";
@@ -40,24 +41,38 @@
         {
             builder
                 .AddAppSerialization()
-                .WithSqlServerPersistence(connectionString)
+                .WithSqlPersistence(connectionString: connectionString,
+                    providerName: ProviderName.SqlServer2019,
+                    databaseMapping: DatabaseMapping.SqlServer,
+                    tagStorageMode: TagMode.TagTable,
+                    journalBuilder: journalBuilder =>
+                    {
+                        journalBuilder.AddWriteEventAdapter<MessageTagger>("product-tagger",
+                            new[] { typeof(IProductEvent) });
+                    })
                 .WithActors((system, registry, resolver) =>
                 {
+                    // in a real world scenario, this actor would be an Akka.Cluster.Sharding ShardRegion
                     var parentActor =
                         system.ActorOf(
                             Props.Create(() => new GenericChildPerEntityParent(new ProductMessageRouter(),
                                 ProductTotalsActor.GetProps)), "productTotals");
-                    
+
                     registry.Register<ProductMarker>(parentActor);
                 })
-                .AddPetabridgeCmd(cmd =>
+                .WithActors((system, registry, resolver) =>
                 {
-
+                    // in a real-world scenario, this projector would be a cluster singleton or would run in its own process
+                    var projectionsActor = system.ActorOf(resolver.Props<ProductProjectorActor>(), "projections");
                 })
+                .AddPetabridgeCmd(cmd => { })
                 .AddStartup((system, registry) =>
                 {
-                    new FakeDataGenerator().Generate(system, registry, 100);
-                });;
+                    var seedDb = hostContext.Configuration.GetValue<bool>("SeedDb");
+                    if (seedDb)
+                        new FakeDataGenerator().Generate(system, registry, 100);
+                });
+            ;
         });
     });
 

src/cqrs/cqrs-sqlserver/CqrsSqlServer.Backend/appsettings.json

@@ -5,5 +5,6 @@
             "System": "Information",
             "Microsoft": "Information"
         }
-    }
+    },
+    "SeedDb": false
 }

src/cqrs/cqrs-sqlserver/CqrsSqlServer.DataModel/CqrsSqlServer.DataModel.csproj

@@ -22,4 +22,8 @@
         </Content>
     </ItemGroup>
 
+    <ItemGroup>
+      <Folder Include="Migrations\" />
+    </ItemGroup>
+
 </Project>

src/cqrs/cqrs-sqlserver/CqrsSqlServer.DataModel/Migrations/20240325192428_InitialCreat.Designer.cs src/cqrs/cqrs-sqlserver/CqrsSqlServer.DataModel/Migrations/20240326010601_InitialCreate.Designer.cs

@@ -6,7 +6,7 @@
 namespace CqrsSqlServer.DataModel.Migrations
 {
     /// <inheritdoc />
-    public partial class InitialCreat : Migration
+    public partial class InitialCreate : Migration
     {
         /// <inheritdoc />
         protected override void Up(MigrationBuilder migrationBuilder)
@@ -18,7 +18,7 @@ protected override void Up(MigrationBuilder migrationBuilder)
                     ProductId = table.Column<string>(type: "nvarchar(128)", maxLength: 128, nullable: false),
                     ProductName = table.Column<string>(type: "nvarchar(256)", maxLength: 256, nullable: false),
                     Price = table.Column<decimal>(type: "decimal(18,2)", nullable: false),
-                    RemainingInventory = table.Column<int>(type: "int", nullable: false),
+                    AllInventory = table.Column<int>(type: "int", nullable: false),
                     SoldUnits = table.Column<int>(type: "int", nullable: false),
                     TotalRevenue = table.Column<decimal>(type: "decimal(18,2)", nullable: false),
                     Created = table.Column<DateTime>(type: "datetime2", nullable: false),

src/cqrs/cqrs-sqlserver/CqrsSqlServer.DataModel/Migrations/20240325192428_InitialCreat.cs src/cqrs/cqrs-sqlserver/CqrsSqlServer.DataModel/Migrations/20240326010601_InitialCreate.cs

@@ -28,6 +28,9 @@ protected override void BuildModel(ModelBuilder modelBuilder)
                         .HasMaxLength(128)
                         .HasColumnType("nvarchar(128)");
 
+                    b.Property<int>("AllInventory")
+                        .HasColumnType("int");
+
                     b.Property<DateTime>("Created")
                         .HasColumnType("datetime2");
 
@@ -42,9 +45,6 @@ protected override void BuildModel(ModelBuilder modelBuilder)
                         .HasMaxLength(256)
                         .HasColumnType("nvarchar(256)");
 
-                    b.Property<int>("AllInventory")
-                        .HasColumnType("int");
-
                     b.Property<int>("SoldUnits")
                         .HasColumnType("int");