Adds user Alias. Make StoredDataUrls optionals.

src/Web/Features/Messages/Data/MessagingDbContext.cs

@@ -1,4 +1,5 @@
-using Microsoft.EntityFrameworkCore;
+using Hutopy.Web.Features.Messages.Handlers.Models;
+using Microsoft.EntityFrameworkCore;
 
 namespace Hutopy.Web.Features.Messages.Data;
 
@@ -9,7 +10,7 @@ public class MessagingDbContext(
     protected override void OnModelCreating(ModelBuilder modelBuilder)
     {
         modelBuilder.HasDefaultSchema("Messaging");
-        
+
         modelBuilder
             .Entity<Message>()
             .Property(c => c.CreatedAt)
@@ -17,5 +18,41 @@ public class MessagingDbContext(
             .HasDefaultValueSql("CURRENT_TIMESTAMP");
     }
 
-    public DbSet<Message> Messages { get; set; } 
+    public DbSet<Message> Messages { get; set; }
+
+    public async Task<List<MessageDto>> GetMessagesAsync(
+        Guid subjectId,
+        Guid? parentId,
+        Guid? lastId,
+        int pageSize,
+        CancellationToken ct = default)
+    {
+        var query = Messages
+            .Where(c => c.SubjectId == subjectId)
+            .Where(c => c.ParentId == parentId);
+
+        if (lastId.HasValue)
+        {
+            var lastMessage = await Messages
+                .Where(c => c.Id == lastId.Value)
+                .Select(c => new { c.CreatedAt, c.Id })
+                .FirstOrDefaultAsync(cancellationToken: ct);
+
+            if (lastMessage != null)
+            {
+                query = query
+                    .Where(c => c.CreatedAt < lastMessage.CreatedAt
+                                || (c.CreatedAt == lastMessage.CreatedAt && c.Id < lastMessage.Id));
+            }
+        }
+
+        var messages = await query
+            .OrderByDescending(c => c.CreatedAt)
+            .ThenByDescending(c => c.Id)
+            .Take(pageSize)
+            .Select(message => message.ToDto())
+            .ToListAsync(cancellationToken: ct);
+
+        return messages;
+    }
 }