Eventuous · alexeyzimarev · Nov 15, 2025 · Nov 14, 2025 · Nov 15, 2025 · Nov 15, 2025
diff --git a/.github/workflows/publish.yml b/.github/workflows/publish.yml
@@ -30,6 +30,19 @@ jobs:
         uses: actions/checkout@v5
         with:
           fetch-depth: 0
+      -
+        name: Setup .NET
+        uses: actions/setup-dotnet@v5
+        with:
+          dotnet-version: |
+            10.0
+      -
+        name: Login to Docker Hub
+        if: ${{ github.event.pull_request.head.repo.fork == false }}
+        uses: docker/login-action@v3
+        with:
+          username: ${{ secrets.DOCKER_USER }}
+          password: ${{ secrets.DOCKER_TOKEN }}
       -
         name: Run tests
         run: dotnet test --framework net10.0

diff --git a/Directory.Packages.props b/Directory.Packages.props
@@ -3,8 +3,8 @@
     <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
   </PropertyGroup>
   <PropertyGroup Label="Package versions for .NET 10" Condition="'$(TargetFramework)' == 'net10.0'">
-    <MicrosoftTestHostVer>10.0.0-rc.2.25502.107</MicrosoftTestHostVer>
-    <MicrosoftExtensionsVer>10.0.0-rc.2.25502.107</MicrosoftExtensionsVer>
+    <MicrosoftTestHostVer>10.0.0</MicrosoftTestHostVer>
+    <MicrosoftExtensionsVer>10.0.0</MicrosoftExtensionsVer>
   </PropertyGroup>
   <PropertyGroup Label="Package versions for .NET 9" Condition="'$(TargetFramework)' == 'net9.0'">
     <MicrosoftTestHostVer>9.0.10</MicrosoftTestHostVer>
@@ -38,11 +38,9 @@
     <PackageVersion Include="Microsoft.NET.Test.Sdk" Version="17.11.1" />
     <PackageVersion Include="Shouldly" Version="4.2.1" />
     <PackageVersion Include="System.Diagnostics.DiagnosticSource" Version="$(MicrosoftExtensionsVer)" />
+    <PackageVersion Include="System.Linq.AsyncEnumerable" Version="10.0.0" />
     <PackageVersion Include="System.Reactive" Version="6.0.1" />
-    <PackageVersion Include="System.Linq.Async" Version="6.0.3" />
     <PackageVersion Include="OpenTelemetry.Extensions.Hosting" Version="1.13.1" />
-    <PackageVersion Include="EventStore.Client.Grpc.PersistentSubscriptions" Version="23.3.9" />
-    <PackageVersion Include="EventStore.Client.Grpc.Streams" Version="23.3.9" />
     <PackageVersion Include="MongoDB.Driver" Version="3.4.0" />
     <PackageVersion Include="Google.Cloud.PubSub.V1" Version="3.19.0" />
     <PackageVersion Include="Confluent.Kafka" Version="2.6.1" />

diff --git a/samples/Directory.Build.props b/samples/Directory.Build.props
@@ -1,6 +1,6 @@
 <Project>
     <PropertyGroup>
-        <TargetFramework>net9.0</TargetFramework>
+        <TargetFramework>net10.0</TargetFramework>
         <Nullable>enable</Nullable>
         <ImplicitUsings>enable</ImplicitUsings>
         <LangVersion>preview</LangVersion>

diff --git a/samples/esdb/Bookings.Domain/Bookings/BookingState.cs b/samples/esdb/Bookings.Domain/Bookings/BookingState.cs
@@ -28,17 +28,17 @@ public BookingState() {
 
     static BookingState HandlePayment(BookingState state, V1.PaymentRecorded e)
         => state with {
-            Outstanding = new Money { Amount = e.Outstanding, Currency = e.Currency },
-            Payments = state.Payments.Add(new PaymentRecord(e.PaymentId, new Money(e.PaidAmount, e.Currency)))
+            Outstanding = new() { Amount = e.Outstanding, Currency = e.Currency },
+            Payments = state.Payments.Add(new(e.PaymentId, new(e.PaidAmount, e.Currency)))
         };
 
     static BookingState HandleBooked(BookingState state, V1.RoomBooked booked)
         => state with {
-            RoomId = new RoomId(booked.RoomId),
-            Period = new StayPeriod(booked.CheckInDate, booked.CheckOutDate),
+            RoomId = new(booked.RoomId),
+            Period = new(booked.CheckInDate, booked.CheckOutDate),
             GuestId = booked.GuestId,
-            Price = new Money { Amount       = booked.BookingPrice, Currency      = booked.Currency },
-            Outstanding = new Money { Amount = booked.OutstandingAmount, Currency = booked.Currency }
+            Price = new() { Amount       = booked.BookingPrice, Currency      = booked.Currency },
+            Outstanding = new() { Amount = booked.OutstandingAmount, Currency = booked.Currency }
         };
 }
 

diff --git a/samples/esdb/Bookings.Payments/Application/CommandService.cs b/samples/esdb/Bookings.Payments/Application/CommandService.cs
@@ -10,7 +10,7 @@ public CommandService(IEventStore store) : base(store) {
         On<PaymentCommands.RecordPayment>()
             .InState(ExpectedState.New)
             .GetId(cmd => new(cmd.PaymentId))
-            .Act((payment, cmd) => payment.ProcessPayment(cmd.BookingId, new Money(cmd.Amount, cmd.Currency), cmd.Method, cmd.Provider));
+            .Act((payment, cmd) => payment.ProcessPayment(cmd.BookingId, new(cmd.Amount, cmd.Currency), cmd.Method, cmd.Provider));
     }
 }
 

diff --git a/samples/esdb/Bookings.Payments/Bookings.Payments.csproj b/samples/esdb/Bookings.Payments/Bookings.Payments.csproj
@@ -24,7 +24,7 @@
     <ItemGroup>
         <ProjectReference Include="$(SrcRoot)\Extensions\src\Eventuous.Extensions.AspNetCore\Eventuous.Extensions.AspNetCore.csproj"/>
         <ProjectReference Include="$(SrcRoot)\Extensions\src\Eventuous.Extensions.DependencyInjection\Eventuous.Extensions.DependencyInjection.csproj"/>
-        <ProjectReference Include="..\..\..\src\KurrentDb\src\Eventuous.KurrentDB\Eventuous.KurrentDB.csproj" />
+        <ProjectReference Include="$(SrcRoot)\KurrentDB\src\Eventuous.KurrentDB\Eventuous.KurrentDB.csproj" />
         <ProjectReference Include="$(SrcRoot)\Mongo\src\Eventuous.Projections.MongoDB\Eventuous.Projections.MongoDB.csproj"/>
         <ProjectReference Include="$(SrcRoot)\Diagnostics\src\Eventuous.Diagnostics.OpenTelemetry\Eventuous.Diagnostics.OpenTelemetry.csproj"/>
         <ProjectReference Include="$(SrcRoot)\Gateway\src\Eventuous.Gateway\Eventuous.Gateway.csproj"/>

diff --git a/samples/esdb/Bookings.Payments/Integration/Payments.cs b/samples/esdb/Bookings.Payments/Integration/Payments.cs
@@ -11,16 +11,16 @@ namespace Bookings.Payments.Integration;
 public static class PaymentsGateway {
     static readonly StreamName Stream = new("PaymentsIntegration");
 
-    public static ValueTask<GatewayMessage<KurrentDbProduceOptions>[]> Transform(IMessageConsumeContext original) {
+    public static ValueTask<GatewayMessage<KurrentDBProduceOptions>[]> Transform(IMessageConsumeContext original) {
         var result = original.Message is PaymentEvents.PaymentRecorded evt
-            ? new GatewayMessage<KurrentDbProduceOptions>(
+            ? new GatewayMessage<KurrentDBProduceOptions>(
                 Stream,
                 new BookingPaymentRecorded(original.Stream.GetId(), evt.BookingId, evt.Amount, evt.Currency),
                 new(),
                 new()
             )
             : null;
-        GatewayMessage<KurrentDbProduceOptions>[] gatewayMessages = result != null ? [result] : [];
+        GatewayMessage<KurrentDBProduceOptions>[] gatewayMessages = result != null ? [result] : [];
         return ValueTask.FromResult(gatewayMessages);
     }
 }

diff --git a/samples/esdb/Bookings.Payments/Registrations.cs b/samples/esdb/Bookings.Payments/Registrations.cs
@@ -14,40 +14,42 @@
 namespace Bookings.Payments;
 
 public static class Registrations {
-    public static void AddServices(this IServiceCollection services, IConfiguration configuration) {
-        services.AddKurrentDBClient(configuration["EventStore:ConnectionString"]!);
-        services.AddEventStore<KurrentDBEventStore>();
-        services.AddCommandService<CommandService, PaymentState>();
-        services.AddSingleton(Mongo.ConfigureMongo(configuration));
-        services.AddCheckpointStore<MongoCheckpointStore>();
-        services.AddProducer<KurrentDbProducer>();
+    extension(IServiceCollection services) {
+        public void AddServices(IConfiguration configuration) {
+            services.AddKurrentDBClient(configuration["EventStore:ConnectionString"]!);
+            services.AddEventStore<KurrentDBEventStore>();
+            services.AddCommandService<CommandService, PaymentState>();
+            services.AddSingleton(Mongo.ConfigureMongo(configuration));
+            services.AddCheckpointStore<MongoCheckpointStore>();
+            services.AddProducer<KurrentDBProducer>();
 
-        services
-            .AddGateway<AllStreamSubscription, AllStreamSubscriptionOptions, KurrentDbProducer, KurrentDbProduceOptions>(
-                "IntegrationSubscription",
-                PaymentsGateway.Transform
-            );
-    }
+            services
+                .AddGateway<AllStreamSubscription, AllStreamSubscriptionOptions, KurrentDBProducer, KurrentDBProduceOptions>(
+                    "IntegrationSubscription",
+                    PaymentsGateway.Transform
+                );
+        }
 
-    public static void AddTelemetry(this IServiceCollection services) {
-        services.AddOpenTelemetry()
-            .WithMetrics(
-                builder => builder
-                    .AddAspNetCoreInstrumentation()
-                    .AddEventuous()
-                    .AddEventuousSubscriptions()
-                    .AddPrometheusExporter()
-            );
+        public void AddTelemetry() {
+            services.AddOpenTelemetry()
+                .WithMetrics(
+                    builder => builder
+                        .AddAspNetCoreInstrumentation()
+                        .AddEventuous()
+                        .AddEventuousSubscriptions()
+                        .AddPrometheusExporter()
+                );
 
-        services.AddOpenTelemetry()
-            .WithTracing(
-                builder => builder
-                    .AddAspNetCoreInstrumentation()
-                    .AddGrpcClientInstrumentation()
-                    .AddEventuousTracing()
-                    .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService("payments"))
-                    .SetSampler(new AlwaysOnSampler())
-                    .AddZipkinExporter()
-            );
+            services.AddOpenTelemetry()
+                .WithTracing(
+                    builder => builder
+                        .AddAspNetCoreInstrumentation()
+                        .AddGrpcClientInstrumentation()
+                        .AddEventuousTracing()
+                        .SetResourceBuilder(ResourceBuilder.CreateDefault().AddService("payments"))
+                        .SetSampler(new AlwaysOnSampler())
+                        .AddZipkinExporter()
+                );
+        }
     }
 }
diff --git a/samples/esdb/Bookings/Application/Queries/MyBookingsProjection.cs b/samples/esdb/Bookings/Application/Queries/MyBookingsProjection.cs
@@ -12,7 +12,7 @@ public MyBookingsProjection(IMongoDatabase database) : base(database) {
             .UpdateFromContext((ctx, update) =>
                 update.AddToSet(
                     x => x.Bookings,
-                    new MyBookings.Booking(ctx.Stream.GetId(),
+                    new(ctx.Stream.GetId(),
                         ctx.Message.CheckInDate,
                         ctx.Message.CheckOutDate,
                         ctx.Message.BookingPrice

diff --git a/samples/esdb/Bookings/Bookings.csproj b/samples/esdb/Bookings/Bookings.csproj
@@ -25,7 +25,7 @@
     </ItemGroup>
     <ItemGroup>
         <ProjectReference Include="$(SrcRoot)\Diagnostics\src\Eventuous.Diagnostics.Logging\Eventuous.Diagnostics.Logging.csproj"/>
-        <ProjectReference Include="..\..\..\src\KurrentDb\src\Eventuous.KurrentDB\Eventuous.KurrentDB.csproj" />
+        <ProjectReference Include="$(SrcRoot)\KurrentDB\src\Eventuous.KurrentDB\Eventuous.KurrentDB.csproj" />
         <ProjectReference Include="$(SrcRoot)\Experimental\src\Eventuous.Spyglass\Eventuous.Spyglass.csproj"/>
         <ProjectReference Include="$(SrcRoot)\Extensions\src\Eventuous.Extensions.DependencyInjection\Eventuous.Extensions.DependencyInjection.csproj"/>
         <ProjectReference Include="$(SrcRoot)\Mongo\src\Eventuous.Projections.MongoDB\Eventuous.Projections.MongoDB.csproj"/>

diff --git a/samples/esdb/Bookings/Infrastructure/Mongo.cs b/samples/esdb/Bookings/Infrastructure/Mongo.cs
@@ -11,7 +11,7 @@ public static IMongoDatabase ConfigureMongo(IConfiguration configuration) {
         var settings = MongoClientSettings.FromConnectionString(config!.ConnectionString);
 
         if (config is { User: not null, Password: not null }) {
-            settings.Credential = new MongoCredential(
+            settings.Credential = new(
                 null,
                 new MongoInternalIdentity("admin", config.User),
                 new PasswordEvidence(config.Password)

diff --git a/samples/esdb/Bookings/Registrations.cs b/samples/esdb/Bookings/Registrations.cs
@@ -32,7 +32,7 @@ public void AddEventuous(IConfiguration configuration) {
             services.AddCommandService<BookingsCommandService, BookingState>();
 
             services.AddSingleton<Services.IsRoomAvailable>((_,    _) => new(true));
-            services.AddSingleton<Services.ConvertCurrency>((from, currency) => new Money(from.Amount * 2, currency));
+            services.AddSingleton<Services.ConvertCurrency>((from, currency) => new(from.Amount * 2, currency));
 
             services.AddSingleton(Mongo.ConfigureMongo(configuration));
 

diff --git a/samples/postgres/Bookings.Payments/Integration/Payments.cs b/samples/postgres/Bookings.Payments/Integration/Payments.cs
@@ -16,7 +16,7 @@ public static ValueTask<GatewayMessage<RabbitMqProduceOptions>[]> Transform(IMes
             ? new GatewayMessage<RabbitMqProduceOptions>(
                 Stream,
                 new BookingPaymentRecorded(original.Stream.GetId(), evt.BookingId, evt.Amount, evt.Currency),
-                new Metadata(),
+                new(),
                 ProduceOptions
             )
             : null;

diff --git a/samples/postgres/Bookings.Payments/Registrations.cs b/samples/postgres/Bookings.Payments/Registrations.cs
@@ -13,7 +13,7 @@ namespace Bookings.Payments;
 public static class Registrations {
     public static void AddEventuous(this IServiceCollection services, IConfiguration configuration) {
         var connectionFactory = new ConnectionFactory {
-            Uri                    = new Uri(configuration["RabbitMq:ConnectionString"]!),
+            Uri                    = new(configuration["RabbitMq:ConnectionString"]!),
             DispatchConsumersAsync = true
         };
         services.AddSingleton(connectionFactory);

diff --git a/samples/postgres/Bookings/Application/Queries/MyBookingsProjection.cs b/samples/postgres/Bookings/Application/Queries/MyBookingsProjection.cs
@@ -12,7 +12,7 @@ public MyBookingsProjection(IMongoDatabase database) : base(database) {
             .UpdateFromContext((ctx, update) =>
                 update.AddToSet(
                     x => x.Bookings,
-                    new MyBookings.Booking(ctx.Stream.GetId(),
+                    new(ctx.Stream.GetId(),
                         ctx.Message.CheckInDate,
                         ctx.Message.CheckOutDate,
                         ctx.Message.BookingPrice

diff --git a/samples/postgres/Bookings/Registrations.cs b/samples/postgres/Bookings/Registrations.cs
@@ -37,7 +37,7 @@ public static void AddEventuous(this IServiceCollection services, IConfiguration
         services.AddSingleton<Services.IsRoomAvailable>((_, _) => new(true));
 
         services.AddSingleton<Services.ConvertCurrency>(
-            (from, currency) => new Money(from.Amount * 2, currency)
+            (from, currency) => new(from.Amount * 2, currency)
         );
 
         services.AddSingleton(Mongo.ConfigureMongo(configuration));

diff --git a/src/Core/gen/Eventuous.Shared.Generators/TypeMappingsGenerator.cs b/src/Core/gen/Eventuous.Shared.Generators/TypeMappingsGenerator.cs
@@ -172,12 +172,11 @@ static void Generate(SourceProductionContext context, string assemblyName, Immut
 
         foreach (var m in distinct) {
             // Prefer passing the explicit name when we have it, so runtime reflection is avoided
-            if (!string.IsNullOrEmpty(m.EventTypeName)) {
-                sb.AppendLine($"        mapper.AddType(typeof({m.FullyQualifiedType}), \"{EscapeString(m.EventTypeName)}\");");
-            }
-            else {
-                sb.AppendLine($"        mapper.AddType(typeof({m.FullyQualifiedType}));");
-            }
+            sb.AppendLine(
+                !string.IsNullOrEmpty(m.EventTypeName)
+                    ? $"        mapper.AddType(typeof({m.FullyQualifiedType}), \"{EscapeString(m.EventTypeName)}\");"
+                    : $"        mapper.AddType(typeof({m.FullyQualifiedType}));"
+            );
         }
 
         sb.AppendLine("    }");

diff --git a/src/Core/gen/Eventuous.Subscriptions.Generators/ConsumeContextConverterGenerator.cs b/src/Core/gen/Eventuous.Subscriptions.Generators/ConsumeContextConverterGenerator.cs
@@ -25,7 +25,7 @@ public void Initialize(IncrementalGeneratorInitializationContext context) {
 
     static bool IsPotentialUsage(SyntaxNode node, CancellationToken _) {
         return node switch {
-            GenericNameSyntax { TypeArgumentList.Arguments.Count: 1 } g => g.Identifier.Text == "IMessageConsumeContext" || g.Identifier.Text == "On",
+            GenericNameSyntax { TypeArgumentList.Arguments.Count: 1 } g => g.Identifier.Text is "IMessageConsumeContext" or "On",
             // handle qualified names like Eventuous.Subscriptions.Context.IMessageConsumeContext<T>
             QualifiedNameSyntax { Right: GenericNameSyntax { TypeArgumentList.Arguments.Count: 1 } g2 } => g2.Identifier.Text == "IMessageConsumeContext",
             // implicit: lambdas where parameter type is inferred to IMessageConsumeContext<T>

diff --git a/src/Core/src/Eventuous.Application/AggregateService/CommandHandlerBuilder.cs b/src/Core/src/Eventuous.Application/AggregateService/CommandHandlerBuilder.cs
@@ -205,7 +205,7 @@ IDefineAppendAmendment<TCommand> IDefineExecution<TCommand, TAggregate, TState>.
     }
 
     IDefineExecution<TCommand, TAggregate, TState> IDefineStore<TCommand, TAggregate, TState>.ResolveStore(Func<TCommand, IEventStore> resolveStore) {
-        Ensure.NotNull(resolveStore, nameof(resolveStore));
+        Ensure.NotNull(resolveStore);
         _reader = resolveStore;
         _writer = resolveStore;
 

diff --git a/src/Core/src/Eventuous.Application/FunctionalService/CommandHandlerBuilder.cs b/src/Core/src/Eventuous.Application/FunctionalService/CommandHandlerBuilder.cs
@@ -232,13 +232,13 @@ RegisteredHandler<TState> Build() {
         );
 
         Func<TCommand, IEventWriter> DefaultResolveWriter() {
-            ArgumentNullException.ThrowIfNull(writer, nameof(writer));
+            ArgumentNullException.ThrowIfNull(writer);
 
             return _ => writer;
         }
 
         Func<TCommand, IEventReader> DefaultResolveReader() {
-            ArgumentNullException.ThrowIfNull(reader, nameof(reader));
+            ArgumentNullException.ThrowIfNull(reader);
 
             return _ => reader;
         }