Merge pull request #114 from J-Tech-Japan/92-read-model-updater-basic

improving document and read model updator

.vscode/settings.json

@@ -1,3 +1,6 @@
 {
-    "azureFunctions.projectSubpath": "src\\Sekiban.Testing"
+    "azureFunctions.projectSubpath": "src\\Sekiban.Testing",
+    "cSpell.words": [
+        "Stöckl"
+    ]
 }

Tutorials/1.GetStarted/BookBorrowing.Domain.Test/BookBorrowing.Domain.Test.csproj

@@ -10,10 +10,10 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.6.0" />
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.7.2" />
         <PackageReference Include="Sekiban.Testing" Version="0.14.4" />
-        <PackageReference Include="xunit" Version="2.5.0" />
-        <PackageReference Include="xunit.runner.visualstudio" Version="2.5.0">
+        <PackageReference Include="xunit" Version="2.5.1" />
+        <PackageReference Include="xunit.runner.visualstudio" Version="2.5.1">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>

Tutorials/1.GetStarted/BookBorrowing.Domain/BookBorrowing.Domain.csproj

@@ -7,7 +7,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="Sekiban.Core" Version="0.14.4" />
+        <PackageReference Include="Sekiban.Core" Version="0.14.5" />
     </ItemGroup>
 
 

Tutorials/1.GetStarted/BookBorrowing.Web.Cosmos/BookBorrowing.Web.Cosmos.csproj

@@ -10,8 +10,8 @@
 
     <ItemGroup>
         <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.11" />
-        <PackageReference Include="Sekiban.Infrastructure.Cosmos" Version="0.14.4" />
-        <PackageReference Include="Sekiban.Web" Version="0.14.4" />
+        <PackageReference Include="Sekiban.Infrastructure.Cosmos" Version="0.14.5" />
+        <PackageReference Include="Sekiban.Web" Version="0.14.5" />
         <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
     </ItemGroup>
 

Tutorials/1.GetStarted/BookBorrowing.Web.Dynamo/BookBorrowing.Web.Dynamo.csproj

@@ -9,8 +9,8 @@
 
     <ItemGroup>
         <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.11" />
-        <PackageReference Include="Sekiban.Infrastructure.Dynamo" Version="0.14.4" />
-        <PackageReference Include="Sekiban.Web" Version="0.14.4" />
+        <PackageReference Include="Sekiban.Infrastructure.Dynamo" Version="0.14.5" />
+        <PackageReference Include="Sekiban.Web" Version="0.14.5" />
         <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
     </ItemGroup>
 

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Cosmos.Web/Program.cs

@@ -1,8 +1,17 @@
+using Sekiban.Core.Dependency;
+using Sekiban.Infrastructure.Cosmos;
+using Sekiban.Web.Dependency;
+using SekibanEventSourcingBasics.Cosmos.Web;
+using SekibanEventSourcingBasics.Domain;
 var builder = WebApplication.CreateBuilder(args);
 
-// Add services to the container.
+// Sekiban Core Setting
+builder.Services.AddSekibanCoreWithDependency(new DomainDependency(), configuration: builder.Configuration);
+// Sekiban Cosmos Setting
+builder.Services.AddSekibanCosmosDB();
+// Sekiban Web Setting
+builder.Services.AddSekibanWeb(new SekibanWebDependency());
 
-builder.Services.AddControllers();
 // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
 builder.Services.AddEndpointsApiExplorer();
 builder.Services.AddSwaggerGen();

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Cosmos.Web/SekibanEventSourcingBasics.Cosmos.Web.csproj

@@ -8,7 +8,13 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.11" />
+    <PackageReference Include="Sekiban.Infrastructure.Cosmos" Version="0.14.5" />
+    <PackageReference Include="Sekiban.Web" Version="0.14.5" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\SekibanEventSourcingBasics.Domain\SekibanEventSourcingBasics.Domain.csproj" />
+  </ItemGroup>
+
 </Project>

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Cosmos.Web/SekibanWebDependency.cs

@@ -0,0 +1,13 @@
+using Sekiban.Web.Authorizations;
+using Sekiban.Web.Common;
+using Sekiban.Web.Dependency;
+using SekibanEventSourcingBasics.Domain;
+namespace SekibanEventSourcingBasics.Cosmos.Web;
+
+public class SekibanWebDependency : DomainDependency, IWebDependencyDefinition
+{
+    public bool ShouldMakeSimpleAggregateListQueries => true;
+    public bool ShouldMakeSimpleSingleProjectionListQueries => true;
+    public AuthorizeDefinitionCollection AuthorizationDefinitions => new();
+    public SekibanControllerOptions Options => new();
+}

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Cosmos.Web/appsettings.Development.json

@@ -4,5 +4,17 @@
       "Default": "Information",
       "Microsoft.AspNetCore": "Warning"
     }
+  },
+  "Sekiban": {
+    "Default": {
+      "AggregateEventCosmosDbContainer": "events",
+      "AggregateEventCosmosDbContainerDissolvable": "dissolvableevents",
+      "BlobConnectionString": "[Set your blob connection string here. (not necessary for just running the sample)]",
+      "CosmosDbEndPointUrl": "[Set your CosmosDb endpoint url here.]",
+      "CosmosDbAuthorizationKey": "[Set your CosmosDb authorization key here.]",
+      "CosmosDbDatabase": "SekibanBasics",
+      "CosmosDbContainer": "items",
+      "CosmosDbContainerDissolvable": "dissolvableitems"
+    }
   }
 }

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/UserPointCommands.cs → Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/Commands/ChangeUserPointName.cs

@@ -1,32 +1,9 @@
-using System;
-using System.Collections.Generic;
-using System.ComponentModel.DataAnnotations;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using Sekiban.Core.Aggregate;
 using Sekiban.Core.Command;
 using Sekiban.Core.Events;
-
-namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints;
-
-
-public record CreateUserPoint(
-    [property: Required]string Name, 
-    [property:Required, EmailAddress]string Email,
-    [property:Range(0,10000)] int Point) : ICommand<UserPoint>
-{
-    // Assign new Aggregate Id by NewGuid()
-    public Guid GetAggregateId() => Guid.NewGuid();
-
-    public class Handler : ICommandHandler<UserPoint, CreateUserPoint>
-    {
-        public IEnumerable<IEventPayloadApplicableTo<UserPoint>> HandleCommand(Func<AggregateState<UserPoint>> getAggregateState, CreateUserPoint command)
-        {
-            yield return new UserPointCreated(command.Name, command.Email, command.Point);
-        }
-    }
-}
+using SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Events;
+using System.ComponentModel.DataAnnotations;
+namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Commands;
 
 public record ChangeUserPointName(
     [property: Required] Guid UserPointId,

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/Commands/CreateUserPoint.cs

@@ -0,0 +1,24 @@
+using Sekiban.Core.Aggregate;
+using Sekiban.Core.Command;
+using Sekiban.Core.Events;
+using SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Events;
+using System.ComponentModel.DataAnnotations;
+namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Commands;
+
+
+public record CreateUserPoint(
+    [property: Required]string Name, 
+    [property:Required, EmailAddress]string Email,
+    [property:Range(0,10000)] int Point) : ICommand<UserPoint>
+{
+    // Assign new Aggregate Id by NewGuid()
+    public Guid GetAggregateId() => Guid.NewGuid();
+
+    public class Handler : ICommandHandler<UserPoint, CreateUserPoint>
+    {
+        public IEnumerable<IEventPayloadApplicableTo<UserPoint>> HandleCommand(Func<AggregateState<UserPoint>> getAggregateState, CreateUserPoint command)
+        {
+            yield return new UserPointCreated(command.Name, command.Email, command.Point);
+        }
+    }
+}

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/Events/UserPointCreated.cs

@@ -0,0 +1,8 @@
+using Sekiban.Core.Events;
+namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Events;
+
+public record UserPointCreated(string Name, string Email, int Point) : IEventPayload<UserPoint, UserPointCreated>
+{
+    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointCreated> ev) =>
+        new(ev.Payload.Name, ev.Payload.Email, ev.Payload.Point);
+}

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/Events/UserPointNameChanged.cs

@@ -0,0 +1,8 @@
+using Sekiban.Core.Events;
+namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Events;
+
+public record UserPointNameChanged(string ChangedName) : IEventPayload<UserPoint, UserPointNameChanged>
+{
+    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointNameChanged> ev) =>
+        aggregatePayload with { Name = ev.Payload.ChangedName };
+}

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/Events/UserPointReceived.cs

@@ -0,0 +1,8 @@
+using Sekiban.Core.Events;
+namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Events;
+
+public record UserPointReceived(int Point, string Note) : IEventPayload<UserPoint, UserPointReceived>
+{
+    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointReceived> ev) =>
+        aggregatePayload with { Point = aggregatePayload.Point + ev.Payload.Point };
+}

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/Events/UserPointUsed.cs

@@ -0,0 +1,8 @@
+using Sekiban.Core.Events;
+namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Events;
+
+public record UserPointUsed(int Point, string Note) : IEventPayload<UserPoint, UserPointUsed>
+{
+    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointUsed> ev) =>
+        aggregatePayload with { Point = aggregatePayload.Point - ev.Payload.Point };
+}

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/Aggregates/UserPoints/UserPoint.cs

@@ -4,35 +4,10 @@
 using System.Text;
 using System.Threading.Tasks;
 using Sekiban.Core.Aggregate;
-using Sekiban.Core.Events;
 
 namespace SekibanEventSourcingBasics.Domain.Aggregates.UserPoints;
 
 public record UserPoint(string Name, string Email, int Point) : IAggregatePayload<UserPoint>
 {
     public static UserPoint CreateInitialPayload(UserPoint? _) => new UserPoint(string.Empty,string.Empty,0);
-}
-
-public record UserPointCreated(string Name, string Email, int Point) : IEventPayload<UserPoint, UserPointCreated>
-{
-    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointCreated> ev) =>
-        new(ev.Payload.Name, ev.Payload.Email, ev.Payload.Point);
-}
-
-public record UserPointNameChanged(string ChangedName) : IEventPayload<UserPoint, UserPointNameChanged>
-{
-    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointNameChanged> ev) =>
-        aggregatePayload with { Name = ev.Payload.ChangedName };
-}
-
-public record UserPointReceived(int Point, string Note) : IEventPayload<UserPoint, UserPointReceived>
-{
-    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointReceived> ev) =>
-        aggregatePayload with { Point = aggregatePayload.Point + ev.Payload.Point };
-}
-
-public record UserPointUsed(int Point, string Note) : IEventPayload<UserPoint, UserPointUsed>
-{
-    public static UserPoint OnEvent(UserPoint aggregatePayload, Event<UserPointUsed> ev) =>
-        aggregatePayload with { Point = aggregatePayload.Point - ev.Payload.Point };
 }

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Domain/DomainDependency.cs

@@ -6,18 +6,18 @@
 using System.Threading.Tasks;
 using Sekiban.Core.Dependency;
 using SekibanEventSourcingBasics.Domain.Aggregates.UserPoints;
+using SekibanEventSourcingBasics.Domain.Aggregates.UserPoints.Commands;
 
 namespace SekibanEventSourcingBasics.Domain;
 
-internal class DomainDependency : DomainDependencyDefinitionBase
+public class DomainDependency : DomainDependencyDefinitionBase
 {
-    public override Assembly GetExecutingAssembly()
-    {
-        return Assembly.GetExecutingAssembly();
-    }
+    public override Assembly GetExecutingAssembly() => Assembly.GetExecutingAssembly();
 
     public override void Define()
     {
-        AddAggregate<UserPoint>();
+        AddAggregate<UserPoint>()
+            .AddCommandHandler<CreateUserPoint, CreateUserPoint.Handler>()
+            .AddCommandHandler<ChangeUserPointName, ChangeUserPointName.Handler>();
     }
 }

Tutorials/2.SekibanEventSourcingBasics/SekibanEventSourcingBasics.Testing/GlobalUsings.cs

@@ -0,0 +1 @@
+global using Xunit;