Fixed errors with sending messages

2026-03-23 14:58:38 +01:00
parent aacba4f4dd
commit 8d649356b5
1 changed files with 21 additions and 1 deletions
@@ -3,12 +3,19 @@ using BeReadyBackend.Hubs;
 using BeReadyBackend.Models;
 using BeReadyBackend.Repositories;
 using BeReadyBackend.Services;
+using BeReadyBackend.Specifications.Groups;
 using FastEndpoints;
 using Microsoft.AspNetCore.SignalR;
+using Group = System.Text.RegularExpressions.Group;

 namespace BeReadyBackend.Endpoints.Messages;

-public class SendMessageEndpoint(UserService userService, AutoMapper.IMapper mapper, MessagesRepository messagesRepository, IHubContext<GroupHub> hubContext)
+public class SendMessageEndpoint(
+    UserService userService, 
+    GroupsRepository groupsRepository, 
+    AutoMapper.IMapper mapper, 
+    MessagesRepository messagesRepository, 
+    IHubContext<GroupHub> hubContext)
    : Endpoint<CreateMessageDto>
 {
    public override void Configure()
@@ -18,6 +25,19 @@ public class SendMessageEndpoint(UserService userService, AutoMapper.IMapper map

    public override async Task HandleAsync(CreateMessageDto req, CancellationToken ct)
    {
+        Models.Group? group = await groupsRepository.SingleOrDefaultAsync(new GetGroupByIdSpec(req.GroupId), ct);
+        if (group is null)
+        {
+            await Send.NotFoundAsync(ct);
+            return;
+        }
+
+        if (group.IsFinished)
+        {
+            await Send.StringAsync("Le groupe est fermé", 400, cancellation: ct);
+            return;
+        }
+        
        Message message = new();
        mapper.Map(req, message);
        message.UserId = userService.GetUserIdFromToken();