Some IEnumerable/IAsyncEnumerable changes

Author: hhvrc

API/Controller/Admin/Configuration.cs

@@ -16,7 +16,7 @@ public sealed partial class AdminController
     /// <response code="200"></response>
     /// <response code="401">Unauthorized</response>
     [HttpGet("config")]
-    [ProducesResponseType<IAsyncEnumerable<ConfigurationItemDto>>(StatusCodes.Status200OK, MediaTypeNames.Application.Json)] // Ok
+    [ProducesResponseType<ConfigurationItemDto[]>(StatusCodes.Status200OK, MediaTypeNames.Application.Json)] // Ok
     public IAsyncEnumerable<ConfigurationItemDto> ConfigurationList([FromServices] IConfigurationService configurationService)
     {
         return configurationService

API/Controller/Admin/GetOnlineDevices.cs

@@ -17,7 +17,7 @@ public sealed partial class AdminController
     /// <response code="200">All online devices</response>
     /// <response code="401">Unauthorized</response>
     [HttpGet("monitoring/onlineDevices")]
-    [ProducesResponseType<LegacyDataResponse<IEnumerable<AdminOnlineDeviceResponse>>>(StatusCodes.Status200OK, MediaTypeNames.Application.Json)]
+    [ProducesResponseType<LegacyDataResponse<AdminOnlineDeviceResponse[]>>(StatusCodes.Status200OK, MediaTypeNames.Application.Json)]
     public async Task<IActionResult> GetOnlineDevices()
     {
         var devicesOnline = _redis.RedisCollection<DeviceOnline>(false);

API/Controller/Sessions/ListSessions.cs

@@ -1,15 +1,19 @@
-using Microsoft.AspNetCore.Mvc;
+using System.Net.Mime;
+using System.Runtime.CompilerServices;
+using Microsoft.AspNetCore.Mvc;
 using OpenShock.API.Models.Response;
 
 namespace OpenShock.API.Controller.Sessions;
 
 public sealed partial class SessionsController
 {
     [HttpGet]
-    public async Task<IEnumerable<LoginSessionResponse>> ListSessions()
+    [ProducesResponseType<LoginSessionResponse[]>(StatusCodes.Status200OK, MediaTypeNames.Application.Json)]
+    public async IAsyncEnumerable<LoginSessionResponse> ListSessions([EnumeratorCancellation] CancellationToken cancellationToken)
     {
-        var sessions = await _sessionService.ListSessionsByUserIdAsync(CurrentUser.Id);
-
-        return sessions.Select(LoginSessionResponse.MapFrom);
+        await foreach (var session in _sessionService.ListSessionsByUserIdAsync(CurrentUser.Id).WithCancellation(cancellationToken))
+        {
+            yield return LoginSessionResponse.MapFrom(session);
+        }
     }
 }

Common/Services/Session/ISessionService.cs

@@ -6,7 +6,7 @@ public interface ISessionService
 {
     public Task<CreateSessionResult> CreateSessionAsync(Guid userId, string userAgent, string ipAddress);
 
-    public Task<IReadOnlyList<LoginSession>> ListSessionsByUserIdAsync(Guid userId);
+    public IAsyncEnumerable<LoginSession> ListSessionsByUserIdAsync(Guid userId);
 
     public Task<LoginSession?> GetSessionByTokenAsync(string sessionToken);
 

Common/Services/Session/SessionService.cs

@@ -43,9 +43,9 @@ await _loginSessions.InsertAsync(new LoginSession
         return new CreateSessionResult(id, token);
     }
 
-    public async Task<IReadOnlyList<LoginSession>> ListSessionsByUserIdAsync(Guid userId)
+    public IAsyncEnumerable<LoginSession> ListSessionsByUserIdAsync(Guid userId)
     {
-        return await _loginSessions.Where(x => x.UserId == userId).ToArrayAsync();
+        return _loginSessions.Where(x => x.UserId == userId);
     }
 
     public async Task<LoginSession?> GetSessionByTokenAsync(string sessionToken)