Made ReadUserSessionLogs stream logs with IAsyncEnumerable and added cancelationtoken

Author: Henrik Zetterström

src/Templates/Boilerplate/Bit.Boilerplate/src/Client/Boilerplate.Client.Core/Components/Pages/Management/UsersPage.razor.cs

@@ -191,10 +191,12 @@ private void SearchSessions()
     /// </summary>
     private async Task ReadUserSessionLogs(Guid userSessionId)
     {
-        var logs = await hubConnection.InvokeAsync<DiagnosticLogDto[]>("GetUserSessionLogs", userSessionId);
-
         DiagnosticLogger.Store.Clear();
-        foreach (var log in logs)
+
+        await foreach (var log in hubConnection.StreamAsync<DiagnosticLogDto>(
+            "GetUserSessionLogs",
+            userSessionId,
+            cancellationToken: CurrentCancellationToken))
         {
             DiagnosticLogger.Store.Enqueue(log);
         }

src/Templates/Boilerplate/Bit.Boilerplate/src/Server/Boilerplate.Server.Api/SignalR/AppHub.cs

@@ -1,4 +1,5 @@
 //+:cnd:noEmit
+using System.Runtime.CompilerServices;
 using Boilerplate.Server.Api.Controllers.Identity;
 using Boilerplate.Server.Api.Models.Identity;
 using Boilerplate.Shared.Dtos.Diagnostic;
@@ -66,17 +67,30 @@ public Task ChangeAuthenticationState(string? accessToken)
     /// <inheritdoc cref="SignalRMethods.UPLOAD_DIAGNOSTIC_LOGGER_STORE"/>
     /// </summary>
     [Authorize(Policy = AppFeatures.System.ManageLogs)]
-    public async Task<DiagnosticLogDto[]> GetUserSessionLogs(Guid userSessionId, [FromServices] AppDbContext dbContext)
+    public async IAsyncEnumerable<DiagnosticLogDto> GetUserSessionLogs(
+        Guid userSessionId,
+        [EnumeratorCancellation] CancellationToken cancellationToken,
+        [FromServices] AppDbContext dbContext)
     {
         var userSessionSignalRConnectionId = await dbContext.UserSessions
             .Where(us => us.Id == userSessionId)
             .Select(us => us.SignalRConnectionId)
-            .FirstOrDefaultAsync(Context.ConnectionAborted);
+            .FirstOrDefaultAsync(cancellationToken);
 
         if (string.IsNullOrEmpty(userSessionSignalRConnectionId))
-            return [];
+            yield break;
 
-        return await Clients.Client(userSessionSignalRConnectionId).InvokeAsync<DiagnosticLogDto[]>(SignalRMethods.UPLOAD_DIAGNOSTIC_LOGGER_STORE, Context.ConnectionAborted);
+        var logs = await Clients.Client(userSessionSignalRConnectionId)
+            .InvokeAsync<DiagnosticLogDto[]>(SignalRMethods.UPLOAD_DIAGNOSTIC_LOGGER_STORE, cancellationToken);
+
+        if (logs is null || logs.Length is 0)
+            yield break;
+
+        foreach (var log in logs)
+        {
+            cancellationToken.ThrowIfCancellationRequested();
+            yield return log;
+        }
     }
 
     private async Task ChangeAuthenticationStateImplementation(ClaimsPrincipal? user)