Feature/dispatcher

Arbiter.slnx

@@ -38,6 +38,7 @@
     <Project Path="test/Arbiter.CommandQuery.MongoDB.Tests/Arbiter.CommandQuery.MongoDB.Tests.csproj" Id="a664a030-159e-403f-8063-5a36616687b7" />
     <Project Path="test/Arbiter.CommandQuery.Tests/Arbiter.CommandQuery.Tests.csproj" Id="ea445280-2bc1-4030-b0c2-e454ce5c4aa6" />
     <Project Path="test/Arbiter.Communication.Tests/Arbiter.Communication.Tests.csproj" Id="9da5eada-3069-46ed-900a-c319b7858690" />
+    <Project Path="test/Arbiter.Dispatcher.Client.Tests/Arbiter.Dispatcher.Client.Tests.csproj" Id="a27a225b-7be5-4fa8-9023-690f07312a86" />
     <Project Path="test/Arbiter.Mediation.Tests/Arbiter.Mediation.Tests.csproj" />
     <Project Path="test/Arbiter.Services.Tests/Arbiter.Services.Tests.csproj" Id="f3d73b4c-09de-4369-b45a-eba1aac348ed" />
   </Folder>
@@ -46,6 +47,8 @@
   <Project Path="src/Arbiter.CommandQuery.MongoDB/Arbiter.CommandQuery.MongoDB.csproj" />
   <Project Path="src/Arbiter.CommandQuery.Mvc/Arbiter.CommandQuery.Mvc.csproj" Id="2b53d754-a9d9-498e-91d1-f2f3810b8c42" />
   <Project Path="src/Arbiter.CommandQuery/Arbiter.CommandQuery.csproj" />
+  <Project Path="src/Arbiter.Dispatcher.Client/Arbiter.Dispatcher.Client.csproj" Id="a8dc1ebc-37b2-44d4-ac36-ceeb04de395b" />
+  <Project Path="src/Arbiter.Dispatcher.Server/Arbiter.Dispatcher.Server.csproj" Id="06f452bc-2f7b-43ce-b2d2-b97204f08b69" />
   <Project Path="src/Arbiter.Mediation.OpenTelemetry/Arbiter.Mediation.OpenTelemetry.csproj" Id="b28ea0e4-e239-4846-a3d5-d184da2d39b1" />
   <Project Path="src/Arbiter.Mediation/Arbiter.Mediation.csproj" />
   <Project Path="src/Arbiter.Services/Arbiter.Services.csproj" Id="d25d1a52-81b3-4a16-9a77-415950b0cac3" />

Directory.Packages.props

@@ -13,7 +13,7 @@
     <PackageVersion Include="Azure.Communication.Email" Version="1.1.0" />
     <PackageVersion Include="Azure.Communication.Sms" Version="1.0.2" />
     <PackageVersion Include="BenchmarkDotNet" Version="0.15.8" />
-    <PackageVersion Include="Blazilla" Version="2.1.0" />
+    <PackageVersion Include="Blazilla" Version="2.2.0" />
     <PackageVersion Include="Bogus" Version="35.6.5" />
     <PackageVersion Include="CsvHelper" Version="33.1.0" />
     <PackageVersion Include="dbup-sqlserver" Version="6.0.16" />
@@ -24,29 +24,28 @@
     <PackageVersion Include="LoreSoft.Blazor.Controls" Version="13.4.2" />
     <PackageVersion Include="MailKit" Version="4.14.1" />
     <PackageVersion Include="MediatR" Version="[12.5.0]" />
-    <PackageVersion Include="Meziantou.Analyzer" Version="2.0.276" />
+    <PackageVersion Include="MessagePack" Version="3.1.4" />
+    <PackageVersion Include="Meziantou.Analyzer" Version="2.0.278" />
     <PackageVersion Include="Microsoft.AspNetCore.Components.WebAssembly" Version="10.0.2" />
     <PackageVersion Include="Microsoft.AspNetCore.Components.WebAssembly.Authentication" Version="10.0.2" />
     <PackageVersion Include="Microsoft.AspNetCore.Components.WebAssembly.Server" Version="10.0.2" />
     <PackageVersion Include="Microsoft.AspNetCore.OpenApi" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Bcl.Memory" Version="10.0.2" />
-    <PackageVersion Include="Microsoft.EntityFrameworkCore" Version="10.0.1" />
+    <PackageVersion Include="Microsoft.EntityFrameworkCore" Version="10.0.2" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.SqlServer" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Caching.Abstractions" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Caching.Hybrid" Version="10.2.0" />
     <PackageVersion Include="Microsoft.Extensions.Configuration.Binder" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.DependencyInjection" Version="10.0.2" />
-    <PackageVersion Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="10.0.1" />
+    <PackageVersion Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Diagnostics.HealthChecks" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Diagnostics.HealthChecks.EntityFrameworkCore" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Hosting" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Http" Version="10.0.2" />
-    <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="10.0.1" />
-    <PackageVersion Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="10.0.1" />
+    <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="10.0.2" />
+    <PackageVersion Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="10.0.2" />
     <PackageVersion Include="Microsoft.Extensions.ServiceDiscovery" Version="10.2.0" />
     <PackageVersion Include="Microsoft.Identity.Web" Version="4.3.0" />
-    <PackageVersion Include="Microsoft.Testing.Extensions.CodeCoverage" Version="18.3.2" />
-    <PackageVersion Include="Microsoft.Testing.Extensions.TrxReport" Version="2.0.2" />
     <PackageVersion Include="MinVer" Version="7.0.0" />
     <PackageVersion Include="MongoDB.Abstracts" Version="7.1.0" />
     <PackageVersion Include="Newtonsoft.Json" Version="13.0.4" />
@@ -59,18 +58,18 @@
     <PackageVersion Include="OpenTelemetry.Instrumentation.SqlClient" Version="1.11.0-beta.2" />
     <PackageVersion Include="Riok.Mapperly" Version="4.3.1" />
     <PackageVersion Include="Rocks" Version="10.0.0" />
-    <PackageVersion Include="Scalar.AspNetCore" Version="2.12.5" />
+    <PackageVersion Include="Scalar.AspNetCore" Version="2.12.7" />
     <PackageVersion Include="SendGrid.Extensions.DependencyInjection" Version="1.0.1" />
     <PackageVersion Include="Serilog.AspNetCore" Version="10.0.0" />
     <PackageVersion Include="starkbank-ecdsa" Version="1.3.3" />
-    <PackageVersion Include="System.IO.Hashing" Version="10.0.1" />
+    <PackageVersion Include="System.IO.Hashing" Version="10.0.2" />
     <PackageVersion Include="System.Linq.Dynamic.Core" Version="1.7.1" />
-    <PackageVersion Include="System.Text.Json" Version="10.0.0" />
+    <PackageVersion Include="System.Text.Json" Version="10.0.2" />
     <PackageVersion Include="SystemTextJsonPatch" Version="4.2.0" />
     <PackageVersion Include="TestHost.Abstracts" Version="2.0.0" />
     <PackageVersion Include="Testcontainers.MongoDb" Version="4.10.0" />
     <PackageVersion Include="Testcontainers.MsSql" Version="4.10.0" />
-    <PackageVersion Include="TUnit" Version="1.11.16" />
+    <PackageVersion Include="TUnit" Version="1.11.28" />
     <PackageVersion Include="Twilio" Version="7.14.1" />
     <PackageVersion Include="Verify.TUnit" Version="31.9.4" />
     <PackageVersion Include="YamlDotNet" Version="16.3.0" />

samples/EntityFramework/src/Tracker.Client/Components/Abstracts/StorePageBase.cs

@@ -1,5 +1,5 @@
 using Arbiter.CommandQuery.Definitions;
-using Arbiter.CommandQuery.State;
+using Arbiter.Dispatcher.State;
 
 using LoreSoft.Blazor.Controls;
 

samples/EntityFramework/src/Tracker.Client/Components/EntitySelect.razor

@@ -1,6 +1,5 @@
 @using System.Linq.Expressions
 @using Arbiter.CommandQuery.Definitions
-@using Arbiter.CommandQuery.Dispatcher
 @using Arbiter.CommandQuery.Queries
 
 @typeparam TModel where TModel : class, IHaveIdentifier<int>, ISupportSearch

samples/EntityFramework/src/Tracker.Client/Services/DataService.cs

@@ -1,6 +1,7 @@
 using System.Security.Claims;
 
-using Arbiter.CommandQuery.Dispatcher;
+using Arbiter.Dispatcher;
+using Arbiter.Dispatcher.Client;
 
 using Microsoft.AspNetCore.Components.Authorization;
 

samples/EntityFramework/src/Tracker.Client/Services/ServiceRegistration.cs

@@ -1,6 +1,7 @@
 using System.Text.Json;
 
-using Arbiter.CommandQuery;
+using Arbiter.Dispatcher;
+using Arbiter.Dispatcher.Client;
 
 using LoreSoft.Blazor.Controls;
 
@@ -39,6 +40,7 @@ public static void Register(IServiceCollection services, ISet<string> tags)
                     client.BaseAddress = new Uri(hostEnvironment.Value.BaseAddress);
                 })
                 .AddHttpMessageHandler<ProgressBarHandler>();
+
         }
 
         if (tags.Contains("Server"))

samples/EntityFramework/src/Tracker.Client/Tracker.Client.csproj

@@ -18,6 +18,7 @@
   </ItemGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\Arbiter.Dispatcher.Client\Arbiter.Dispatcher.Client.csproj" />
     <ProjectReference Include="..\Tracker.Shared\Tracker.Shared.csproj" />
   </ItemGroup>
 

samples/EntityFramework/src/Tracker.Shared/Domain/Priority/Models/PriorityCreateModel.cs

@@ -1,9 +1,9 @@
-using System;
-using System.Collections.Generic;
+using MessagePack;
 
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class PriorityCreateModel
     : EntityCreateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Priority/Models/PriorityReadModel.cs

@@ -3,9 +3,12 @@
 
 using Arbiter.CommandQuery.Definitions;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class PriorityReadModel
     : EntityReadModel, ISupportSearch
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Priority/Models/PriorityUpdateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class PriorityUpdateModel
     : EntityUpdateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Status/Models/StatusCreateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class StatusCreateModel
     : EntityCreateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Status/Models/StatusReadModel.cs

@@ -3,9 +3,12 @@
 
 using Arbiter.CommandQuery.Definitions;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class StatusReadModel
     : EntityReadModel, ISupportSearch
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Status/Models/StatusUpdateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class StatusUpdateModel
     : EntityUpdateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Task/Models/TaskCreateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class TaskCreateModel
     : EntityCreateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Task/Models/TaskReadModel.cs

@@ -2,9 +2,12 @@
 
 using Arbiter.CommandQuery.Definitions;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class TaskReadModel
     : EntityReadModel, ISupportSearch
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Task/Models/TaskUpdateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class TaskUpdateModel
     : EntityUpdateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Tenant/Models/TenantCreateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class TenantCreateModel
     : EntityCreateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Tenant/Models/TenantReadModel.cs

@@ -3,9 +3,12 @@
 
 using Arbiter.CommandQuery.Definitions;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class TenantReadModel
     : EntityReadModel, ISupportSearch
 {

samples/EntityFramework/src/Tracker.Shared/Domain/Tenant/Models/TenantUpdateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class TenantUpdateModel
     : EntityUpdateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/User/Models/UserCreateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class UserCreateModel
     : EntityCreateModel
 {

samples/EntityFramework/src/Tracker.Shared/Domain/User/Models/UserReadModel.cs

@@ -4,9 +4,12 @@
 
 using Arbiter.CommandQuery.Definitions;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class UserReadModel
     : EntityReadModel, ISupportSearch
 {

samples/EntityFramework/src/Tracker.Shared/Domain/User/Models/UserUpdateModel.cs

@@ -1,9 +1,12 @@
 using System;
 using System.Collections.Generic;
 
+using MessagePack;
+
 namespace Tracker.Domain.Models;
 
 [Equatable]
+[MessagePackObject(true)]
 public partial class UserUpdateModel
     : EntityUpdateModel
 {

samples/EntityFramework/src/Tracker.Web/Program.cs

@@ -1,4 +1,5 @@
 using Arbiter.CommandQuery.Endpoints;
+using Arbiter.Dispatcher.Server;
 using Arbiter.Mediation.OpenTelemetry;
 
 using Microsoft.AspNetCore.Authentication.Cookies;
@@ -101,7 +102,8 @@ private static void ConfigureServices(WebApplicationBuilder builder)
             .AddTrackerWeb();
 
         services
-            .AddEndpointRoutes();
+            .AddEndpointRoutes()
+            .AddDispatcherService();
 
         services
             .ConfigureHttpJsonOptions(options => options.SerializerOptions.AddDomainOptions());
@@ -159,5 +161,7 @@ private static void ConfigureMiddleware(WebApplication app)
 
         app.MapEndpointRoutes();
 
+        app.MapDispatcherService().RequireAuthorization();
+
     }
 }

samples/EntityFramework/src/Tracker.Web/Tracker.Web.csproj

@@ -10,6 +10,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\..\..\..\src\Arbiter.CommandQuery.Endpoints\Arbiter.CommandQuery.Endpoints.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Arbiter.Dispatcher.Server\Arbiter.Dispatcher.Server.csproj" />
     <ProjectReference Include="..\..\..\..\src\Arbiter.Mediation.OpenTelemetry\Arbiter.Mediation.OpenTelemetry.csproj" />
     <ProjectReference Include="..\Tracker.Client\Tracker.Client.csproj" />
     <ProjectReference Include="..\Tracker.Core\Tracker.Core.csproj" />