Start with signalR

MadWorldVPS/MadWorld.ShipSimulator.API/Hubs/CompanyHub.cs

@@ -0,0 +1,8 @@
+using Microsoft.AspNetCore.SignalR;
+
+namespace MadWorld.ShipSimulator.API.Hubs;
+
+public class CompanyHub : Hub
+{
+
+}

MadWorldVPS/MadWorld.ShipSimulator.API/Hubs/CompanyLiveUpdater.cs

@@ -0,0 +1,19 @@
+using MadWorld.ShipSimulator.Domain.Companies;
+using Microsoft.AspNetCore.SignalR;
+
+namespace MadWorld.ShipSimulator.API.Hubs;
+
+public class CompanyLiveUpdater : ICompanyLiveUpdater
+{
+    private readonly IHubContext<CompanyHub> _hubContext;
+
+    public CompanyLiveUpdater(IHubContext<CompanyHub> hubContext)
+    {
+        _hubContext = hubContext;
+    }
+
+    public async Task UpdateCompanyAsync(Company company)
+    {
+        await _hubContext.Clients.User(company.UserId.ToString()).SendAsync("CompanyUpdated", company);
+    }
+}

MadWorldVPS/MadWorld.ShipSimulator.API/Hubs/HubExtensions.cs

@@ -0,0 +1,12 @@
+using MadWorld.ShipSimulator.Domain.Companies;
+
+namespace MadWorld.ShipSimulator.API.Hubs;
+
+public static class HubExtensions
+{
+    public static void AddHubs(this WebApplicationBuilder builder)
+    {
+        builder.Services.AddSignalR();
+        builder.Services.AddScoped<ICompanyLiveUpdater, CompanyLiveUpdater>();
+    }
+}

MadWorldVPS/MadWorld.ShipSimulator.API/Program.cs

@@ -5,6 +5,7 @@
 using MadWorld.Shared.Infrastructure.Databases;
 using MadWorld.Shared.Infrastructure.Settings;
 using MadWorld.ShipSimulator.API.Endpoints;
+using MadWorld.ShipSimulator.API.Hubs;
 using MadWorld.ShipSimulator.Application.CommonLogic.Extensions;
 using MadWorld.ShipSimulator.Infrastructure.Database;
 using MadWorld.ShipSimulator.Infrastructure.Database.Extensions;
@@ -55,6 +56,7 @@ private static void Main(string[] args)
 
         builder.AddApplication();
         builder.AddDatabase();
+        builder.AddHubs();
 
         builder.Services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme).AddJwtBearer(options =>
         {
@@ -81,7 +83,7 @@ private static void Main(string[] args)
             });
 
         builder.Services.AddAuthorization();
-
+        
         builder.Services.AddHealthChecks();
 
         builder.Services.Configure<ForwardedHeadersOptions>(options =>
@@ -144,6 +146,7 @@ private static void Main(string[] args)
 
         apiBuilder.AddCompanyEndpoints();
         apiBuilder.AddDangerEndpoints();
+        apiBuilder.MapHub<CompanyHub>("/CompanyHub");
 
         app.MigrateDatabase<ShipSimulatorContext>();
 

MadWorldVPS/MadWorld.ShipSimulator.Domain/Companies/ICompanyLiveUpdater.cs

@@ -0,0 +1,6 @@
+namespace MadWorld.ShipSimulator.Domain.Companies;
+
+public interface ICompanyLiveUpdater
+{
+    Task UpdateCompanyAsync(Company company);
+}