Merge pull request #20 from 9roomMoa/feat/#19

feat: 알림 읽음 처리 api

Author: EveryPine

src/main/java/com/groommoa/aether_back_notification/domain/notifications/controller/NotificationController.java

@@ -1,9 +1,6 @@
 package com.groommoa.aether_back_notification.domain.notifications.controller;
 
-import com.groommoa.aether_back_notification.domain.notifications.dto.CreateNotificationRequestDto;
-import com.groommoa.aether_back_notification.domain.notifications.dto.CreateNotificationResponseDto;
-import com.groommoa.aether_back_notification.domain.notifications.dto.NotificationPageResponseDto;
-import com.groommoa.aether_back_notification.domain.notifications.dto.NotificationResponseDto;
+import com.groommoa.aether_back_notification.domain.notifications.dto.*;
 import com.groommoa.aether_back_notification.domain.notifications.entity.Notification;
 import com.groommoa.aether_back_notification.domain.notifications.service.NotificationService;
 import com.groommoa.aether_back_notification.infrastructure.sse.service.SseService;
@@ -16,12 +13,16 @@
 import jakarta.validation.constraints.Min;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.bson.types.ObjectId;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.security.core.annotation.AuthenticationPrincipal;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
+import java.util.List;
+import java.util.Map;
+
 @Slf4j
 @RequestMapping("/notifications")
 @RequiredArgsConstructor
@@ -74,4 +75,19 @@ public SseEmitter subscribe(
 
         return sseService.subscribe(userId, lastEventId);
     }
+
+    @PatchMapping("/read")
+    public ResponseEntity<CommonResponse> markNotificationsAsRead(
+            @AuthenticationPrincipal Claims claims,
+            @Valid @RequestBody ReadNotificationsRequestDto request
+            ) {
+        String userId = claims.getSubject();
+        ReadNotificationResponseDto responseDto = notificationService.markNotificationsAsRead(userId, request);
+
+        CommonResponse response = new CommonResponse(
+                HttpStatus.OK, "알림 읽음 요청이 처리되었습니다.", DtoUtils.toMap(responseDto)
+        );
+
+        return ResponseEntity.ok(response);
+    }
 }

src/main/java/com/groommoa/aether_back_notification/domain/notifications/dto/ReadNotificationResponseDto.java

@@ -0,0 +1,16 @@
+package com.groommoa.aether_back_notification.domain.notifications.dto;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+import java.util.List;
+
+@RequiredArgsConstructor
+@Getter
+public class ReadNotificationResponseDto {
+
+    private final List<String> updatedIds;
+    private final List<String> alreadyReadIds;
+    private final List<String> notFoundIds;
+    private final List<String> accessDeniedIds;
+}

src/main/java/com/groommoa/aether_back_notification/domain/notifications/dto/ReadNotificationsRequestDto.java

@@ -0,0 +1,17 @@
+package com.groommoa.aether_back_notification.domain.notifications.dto;
+
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.Size;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+import java.util.List;
+
+@RequiredArgsConstructor
+@Getter
+public class ReadNotificationsRequestDto {
+
+    @NotEmpty(message="알림 ID 목록은 비어 있을 수 없습니다.")
+    @Size(max=100, message="한번에 최대 100개의 알림한 처리할 수 있습니다.")
+    private final List<String> notificationIds;
+}

src/main/java/com/groommoa/aether_back_notification/domain/notifications/entity/Notification.java

@@ -3,17 +3,20 @@
 import com.groommoa.aether_back_notification.domain.notifications.common.NoticeType;
 import lombok.Builder;
 import lombok.Getter;
+import lombok.Setter;
 import org.bson.types.ObjectId;
 import org.springframework.data.annotation.CreatedDate;
 import org.springframework.data.annotation.Id;
 import org.springframework.data.annotation.LastModifiedDate;
 import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.data.mongodb.core.mapping.Field;
 
 import java.time.Instant;
 
 @Document(collection = "notifications")
 @Builder
 @Getter
+@Setter
 public class Notification {
 
     @Id
@@ -33,6 +36,7 @@ public class Notification {
     private RelatedContent relatedContent;
 
     @Builder.Default
+    @Field("isRead")
     private boolean isRead = false;
 
     @CreatedDate

src/main/java/com/groommoa/aether_back_notification/domain/notifications/service/NotificationService.java

@@ -1,8 +1,6 @@
 package com.groommoa.aether_back_notification.domain.notifications.service;
 
-import com.groommoa.aether_back_notification.domain.notifications.dto.CreateNotificationRequestDto;
-import com.groommoa.aether_back_notification.domain.notifications.dto.NotificationPageResponseDto;
-import com.groommoa.aether_back_notification.domain.notifications.dto.NotificationResponseDto;
+import com.groommoa.aether_back_notification.domain.notifications.dto.*;
 import com.groommoa.aether_back_notification.domain.notifications.entity.Notification;
 import com.groommoa.aether_back_notification.domain.notifications.entity.RelatedContent;
 import com.groommoa.aether_back_notification.domain.notifications.repository.NotificationRepository;
@@ -16,8 +14,11 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Optional;
 
+@Slf4j
 @RequiredArgsConstructor
 @Service
 public class NotificationService {
@@ -76,4 +77,38 @@ public Notification createNotification(CreateNotificationRequestDto request) {
 
         return notificationRepository.save(notification);
     }
+
+    @Transactional
+    public ReadNotificationResponseDto markNotificationsAsRead(String userId, ReadNotificationsRequestDto request){
+        List<String> updatedIds = new ArrayList<>();
+        List<String> alreadyReadIds = new ArrayList<>();
+        List<String> notFoundIds = new ArrayList<>();
+        List<String> accessDeniedIds = new ArrayList<>();
+
+        List<String> notificationIds = request.getNotificationIds();
+        for (String id : notificationIds) {
+            Optional<Notification> optionalNotification = notificationRepository.findById(id);
+            if (optionalNotification.isEmpty()){
+                notFoundIds.add(id);
+                continue;
+            }
+            Notification notification = optionalNotification.get();
+
+            // 읽음 요청한 유저 id와 대상 알림의 수신자(receiver) id가 서로 일치하는지 검사
+            if (!notification.getReceiver().toHexString().equals(userId)) {
+                accessDeniedIds.add(id);
+                continue;
+            }
+
+            if (!notification.isRead()){
+                notification.setRead(true);
+                notificationRepository.save(notification);
+
+                updatedIds.add(id);
+            } else {
+                alreadyReadIds.add(id);
+            }
+        }
+        return new ReadNotificationResponseDto(updatedIds, alreadyReadIds, notFoundIds, accessDeniedIds);
+    }
 }