more (azure) signal Rsetup

Author: NielsPilgaard

src/web/Client/Extensions/WebAssemblyHostBuilderExtensions.cs

@@ -11,7 +11,8 @@ public static IServiceCollection AddRefitClient<TClient>(
         RefitSettings? settings = null)
         where TClient : class
     {
-        services.AddRefitClient<TClient>(settings).ConfigureHttpClient(client =>
+        services.AddRefitClient<TClient>(settings)
+            .ConfigureHttpClient(client =>
             {
                 client.BaseAddress = baseAddress;
                 // This prevents the api from redirecting to Account/Login on 401

src/web/Client/Features/Chat/ChatClientHub.razor

@@ -0,0 +1,43 @@
+@page "/"
+@using Microsoft.AspNetCore.SignalR.Client
+@inject NavigationManager Navigation
+@implements IAsyncDisposable
+
+@code {
+    private HubConnection? _hubConnection;
+
+    protected override async Task OnInitializedAsync()
+    {
+        _hubConnection = new HubConnectionBuilder()
+            .WithUrl(Navigation.ToAbsoluteUri("/chathub"))
+            .WithAutomaticReconnect()
+            .Build();
+            
+        _hubConnection.On<string, string>("ReceiveMessage", (user, message) =>
+        {
+            var encodedMsg = $"{user}: {message}";
+            //messages.Add(encodedMsg);
+            StateHasChanged();
+        });
+
+        await _hubConnection.StartAsync();
+    }
+
+    private async Task Send()
+    {
+        if (_hubConnection is not null)
+        {
+            await _hubConnection.SendAsync("SendMessage");
+        }
+    }
+
+    public bool IsConnected => _hubConnection?.State == HubConnectionState.Connected;
+
+    public async ValueTask DisposeAsync()
+    {
+        if (_hubConnection is not null)
+        {
+            await _hubConnection.DisposeAsync();
+        }
+    }
+}

src/web/Server/Jordnaer.Server.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk.Web">
+<Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
     <TargetFramework>net7.0</TargetFramework>
@@ -9,8 +9,10 @@
 
   <ItemGroup>
     <PackageReference Include="Azure.Storage.Blobs" Version="12.17.0" />
+
     <PackageReference Include="MassTransit.AspNetCore" Version="7.3.1" />
     <PackageReference Include="MassTransit.Azure.ServiceBus.Core" Version="8.0.16" />
+
     <PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.21.0" />
 
     <PackageReference Include="Microsoft.AspNetCore.Authentication.Facebook" Version="7.0.9" />
@@ -52,6 +54,8 @@
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
+
+    <PackageReference Include="Microsoft.Azure.SignalR" Version="1.21.3" />
   </ItemGroup>
 
   <ItemGroup>

src/web/Server/Program.cs

@@ -63,7 +63,8 @@
 
     builder.AddMassTransit();
 
-    builder.Services.AddSignalR();
+    builder.Services.AddSignalR().AddAzureSignalR(options =>
+        options.ServerStickyMode = ServerStickyMode.Required);
     if (!builder.Environment.IsDevelopment())
     {
         builder.Services.AddResponseCompression(options =>
@@ -126,6 +127,8 @@
 
     app.MapHealthChecks("/health").AllowAnonymous().RequireHealthCheckRateLimit();
 
+    app.MapHub<ChatHub>("/chathub");
+
     app.MapFallbackToFile("index.html");
 
     app.Run();

src/web/Server/Properties/launchSettings.json

@@ -8,7 +8,8 @@
       "applicationUrl": "https://localhost:7116;http://localhost:5235",
         "environmentVariables": {
             "ASPNETCORE_ENVIRONMENT": "Development",
-            "ConnectionStrings_JordnaerDbContext": "Server=localhost,1433;Database=jordnaer;User ID=sa;Password=6efe173b-3e33-4d6c-8f50-3e5f7cadd54c;Persist Security Info=False;TrustServerCertificate=true;"
+            "ConnectionStrings_JordnaerDbContext": "Server=localhost,1433;Database=jordnaer;User ID=sa;Password=6efe173b-3e33-4d6c-8f50-3e5f7cadd54c;Persist Security Info=False;TrustServerCertificate=true;",
+            "ASPNETCORE_HOSTINGSTARTUPASSEMBLIES": "Microsoft.Azure.SignalR"
         }
     }
   }

src/web/Server/Properties/serviceDependencies.json

@@ -12,6 +12,11 @@
       "type": "mssql",
       "connectionId": "ConnectionStrings:JordnaerDbContext",
       "dynamicId": null
+    },
+    "signalr1": {
+        "type": "signalr",
+        "connectionId": "ConnectionStrings:AzureSignalR",
+        "dynamicId": null
     }
   }
 }

src/web/Server/Properties/serviceDependencies.local.json

@@ -21,6 +21,14 @@
       "type": "mssql.container",
       "connectionId": "ConnectionStrings:JordnaerDbContext",
       "dynamicId": null
+    },
+    "signalr1": {
+        "serviceConnectorResourceId": "/subscriptions/[parameters('subscriptionId')]/resourceGroups/[parameters('resourceGroupName')]/providers/Microsoft.ServiceLinker/locations/swedencentral/connectors/AzureSignalRConnectionString_4B4C9F2617",
+        "secretStore": null,
+        "resourceId": "/subscriptions/[parameters('subscriptionId')]/resourceGroups/[parameters('resourceGroupName')]/providers/Microsoft.SignalRService/SignalR/jordnaer",
+        "type": "signalr.azure",
+        "connectionId": "ConnectionStrings:AzureSignalR",
+        "dynamicId": null
     }
   }
 }

src/web/Server/appsettings.json

@@ -15,5 +15,10 @@
   },
   "DataForsyningen": {
     "BaseUrl": "https://api.dataforsyningen.dk"
+  },
+  "Azure": {
+    "SignalR": {
+      "Enabled": "true"
+    }
   }
 }