Change and Delete messages

src/Web/Features/Contents/Handlers/GetContentsByCreator.cs

@@ -28,46 +28,6 @@ public class GetContentsByCreatorHandler(
         GetContentsByCreatorRequest req,
         CancellationToken ct)
     {
-//         var queryBuilder = new StringBuilder();
-//         queryBuilder.AppendLine($"""
-//                                  SELECT content."Id", 
-//                                         content."CreatedBy", 
-//                                         creator."Name" as CreatedByName, 
-//                                         i."Logo" as CreatedByPortraitUrl, 
-//                                         c."Menu" as ColorMenu, 
-//                                         c."Accent" as ColorAccent, 
-//                                         content."CreatedAt", 
-//                                         content."DeletedBy",
-//                                         content."DeletedAt",
-//                                         content."Title",
-//                                         content."Description", 
-//                                         content."Urls",
-//                                  FROM "Content"."Contents" AS content
-//                                  INNER JOIN "Content"."Creators" AS creator ON content."CreatedBy" = creator."Id"
-//                                  LEFT JOIN "Content"."Images" AS i ON creator."Id" = i."CreatorId"
-//                                  LEFT JOIN "Content"."Colors" AS c ON creator."Id" = c."CreatorId"
-//                                  WHERE content."CreatedBy" = '{req.CreatorId}' 
-//                                     AND content."DeletedBy" IS NULL
-//                                  """);
-//
-//         if (req.LastId.HasValue)
-//         {
-//             queryBuilder.AppendLine($"""AND content."Id" > '{req.LastId.Value}'""");
-//         }
-//
-//         queryBuilder.AppendLine($"""
-//                              ORDER BY content."CreatedAt" DESC
-//                              LIMIT {req.PageSize}
-//                              """);
-//
-//         var query = queryBuilder.ToString();
-//         
-//         var results = await context
-//             .Database
-//             .SqlQueryRaw<ContentModel>(query)
-//             .ToListAsync(cancellationToken: ct);
-
-
         var query = context.Contents
             .Where(c => c.CreatedBy == req.CreatorId && c.DeletedAt == null)
             .OrderByDescending(c => c.CreatedAt);

src/Web/Features/Messages/Handlers/ChangeMessage.cs

@@ -0,0 +1,64 @@
+using Hutopy.Web.Common;
+using Hutopy.Web.Features.Messages.Data;
+
+namespace Hutopy.Web.Features.Messages.Handlers;
+
+public sealed class ChangeMessageRequest
+{
+    public Guid? Id { get; set; }
+    public required Guid SubjectId { get; set; }
+    public required string Message { get; set; }
+}
+
+internal sealed class ChangeMessageRequestValidator
+    : Validator<ChangeMessageRequest>
+{
+    public ChangeMessageRequestValidator()
+    {
+        RuleFor(r => r.SubjectId)
+            .NotNull().WithMessage("You must specify a SubjectId")
+            .NotEmpty().WithMessage("You must specify a non-empty SubjectId");
+
+        RuleFor(r => r.Message)
+            .NotNull().WithMessage("You must specify a Message")
+            .NotEmpty().WithMessage("You must specify a non-empty Message");
+    }
+}
+
+public class ChangeMessage(
+    MessagingDbContext context)
+    : Endpoint<ChangeMessageRequest>
+{
+    public override void Configure()
+    {
+        Post("/api/messages/update");
+        Options(o => o.WithTags("Messages"));
+    }
+
+    public override async Task HandleAsync(
+        ChangeMessageRequest req,
+        CancellationToken ct)
+    {
+        var message = await context.Messages.FirstOrDefaultAsync(x => x.Id == req.Id, ct);
+        
+        if (message is null)
+        {
+            await SendNotFoundAsync(ct);
+            return;
+        }
+        
+        var userId = HttpContext.User.GetUserId();
+        if (message.CreatedBy != userId)
+        {
+            await SendForbiddenAsync(ct);
+            return;
+        }
+
+        message.SubjectId = req.SubjectId;
+        message.Value = req.Message;
+
+        context.Update(message);
+        
+        await context.SaveChangesAsync(ct);
+    }
+}

src/Web/Features/Messages/Handlers/DeleteMessage.cs

@@ -0,0 +1,52 @@
+using Hutopy.Web.Common;
+using Hutopy.Web.Features.Messages.Data;
+
+namespace Hutopy.Web.Features.Messages.Handlers;
+
+public record DeleteMessageRequest(Guid MessageId);
+
+internal sealed class DeleteMessageRequestValidator
+    : Validator<DeleteMessageRequest>
+{
+    public DeleteMessageRequestValidator()
+    {
+        RuleFor(r => r.MessageId)
+            .NotNull().WithMessage("You must specify a MessageId")
+            .NotEmpty().WithMessage("You must specify a non-empty MessageId");
+    }
+}
+
+public class DeleteMessage(
+    MessagingDbContext context)
+    : Endpoint<DeleteMessageRequest>
+{
+    public override void Configure()
+    {
+        Delete("/api/messages/{MessageId}");
+        Options(o => o.WithTags("Messages"));
+    }
+
+    public override async Task HandleAsync(
+        DeleteMessageRequest req,
+        CancellationToken ct)
+    {
+        var message = await context.Messages.FirstOrDefaultAsync(x => x.Id == req.MessageId, ct);
+
+        if (message is null)
+        {
+            await SendNotFoundAsync(ct);
+            return;
+        }
+        
+        var userId = HttpContext.User.GetUserId();
+        if (message.CreatedBy != userId)
+        {
+            await SendForbiddenAsync(ct);
+            return;
+        }
+        
+        context.Messages.Remove(message);
+
+        await context.SaveChangesAsync(ct);
+    }
+}