Merge pull request #172 from TRIP-Side-Project/feature/#155-notificat…

…ion-api 알림 관련 API 변경
TRIP-Side-Project · Dec 28, 2023 · 5b53823 · 5b53823
2 parents 1941621 + 8d34805
commit 5b53823
Show file tree

Hide file tree

Showing 7 changed files with 48 additions and 1,123 deletions.
diff --git a/src/main/java/com/api/trip/domain/notification/controller/NotificationController.java b/src/main/java/com/api/trip/domain/notification/controller/NotificationController.java
@@ -2,9 +2,11 @@
 
 import com.api.trip.common.exception.CustomException;
 import com.api.trip.common.exception.ErrorCode;
+import com.api.trip.common.sse.emitter.SseEmitterMap;
 import com.api.trip.domain.member.repository.MemberRepository;
+import com.api.trip.domain.notification.controller.dto.DeleteNotificationRequest;
 import com.api.trip.domain.notification.controller.dto.GetMyNotificationsResponse;
-import com.api.trip.common.sse.emitter.SseEmitterMap;
+import com.api.trip.domain.notification.controller.dto.ReadNotificationRequest;
 import com.api.trip.domain.notification.service.NotificationService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.MediaType;
@@ -37,29 +39,23 @@ public ResponseEntity<SseEmitter> connect() {
         return ResponseEntity.ok(sseEmitter);
     }
 
-    @GetMapping("/send-to-all")
-    public void sendToAll(@RequestParam String message) {
-        String email = SecurityContextHolder.getContext().getAuthentication().getName();
-        sseEmitterMap.sendToAll("send-to-all", email + ": " + message);
-    }
-
     @GetMapping("/me")
     public ResponseEntity<GetMyNotificationsResponse> getMyNotifications() {
         String email = SecurityContextHolder.getContext().getAuthentication().getName();
         return ResponseEntity.ok(notificationService.getMyNotifications(email));
     }
 
-    @PatchMapping("/{notificationId}")
-    public ResponseEntity<Void> readNotification(@PathVariable Long notificationId) {
+    @PatchMapping
+    public ResponseEntity<Void> readNotification(@RequestBody ReadNotificationRequest request) {
         String email = SecurityContextHolder.getContext().getAuthentication().getName();
-        notificationService.readNotification(notificationId, email);
+        notificationService.readNotification(request, email);
         return ResponseEntity.ok().build();
     }
 
-    @DeleteMapping("/{notificationId}")
-    public ResponseEntity<Void> deleteNotification(@PathVariable Long notificationId) {
+    @DeleteMapping
+    public ResponseEntity<Void> deleteNotification(@RequestBody DeleteNotificationRequest request) {
         String email = SecurityContextHolder.getContext().getAuthentication().getName();
-        notificationService.deleteNotification(notificationId, email);
+        notificationService.deleteNotification(request, email);
         return ResponseEntity.ok().build();
     }
 

diff --git a/src/main/java/com/api/trip/domain/notification/controller/dto/DeleteNotificationRequest.java b/src/main/java/com/api/trip/domain/notification/controller/dto/DeleteNotificationRequest.java
@@ -0,0 +1,11 @@
+package com.api.trip.domain.notification.controller.dto;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+
+@Getter
+public class DeleteNotificationRequest {
+
+    @NotNull(message = "itemId를 입력해 주세요.")
+    private Long itemId;
+}
diff --git a/src/main/java/com/api/trip/domain/notification/controller/dto/ReadNotificationRequest.java b/src/main/java/com/api/trip/domain/notification/controller/dto/ReadNotificationRequest.java
@@ -0,0 +1,11 @@
+package com.api.trip.domain.notification.controller.dto;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Getter;
+
+@Getter
+public class ReadNotificationRequest {
+
+    @NotNull(message = "itemId를 입력해 주세요.")
+    private Long itemId;
+}
diff --git a/src/main/java/com/api/trip/domain/notification/repository/NotificationRepository.java b/src/main/java/com/api/trip/domain/notification/repository/NotificationRepository.java
@@ -5,8 +5,11 @@
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;
+import java.util.Optional;
 
 public interface NotificationRepository extends JpaRepository<Notification, Long>, NotificationRepositoryCustom {
 
     List<Notification> findAllByMember(Member member);
+
+    Optional<Notification> findByMemberIdAndItemId(Long memberId, Long itemId);
 }
diff --git a/src/main/java/com/api/trip/domain/notification/service/NotificationService.java b/src/main/java/com/api/trip/domain/notification/service/NotificationService.java
@@ -7,7 +7,9 @@
 import com.api.trip.domain.itemtag.model.ItemTag;
 import com.api.trip.domain.member.model.Member;
 import com.api.trip.domain.member.repository.MemberRepository;
+import com.api.trip.domain.notification.controller.dto.DeleteNotificationRequest;
 import com.api.trip.domain.notification.controller.dto.GetMyNotificationsResponse;
+import com.api.trip.domain.notification.controller.dto.ReadNotificationRequest;
 import com.api.trip.domain.notification.domain.Notification;
 import com.api.trip.domain.notification.repository.NotificationRepository;
 import lombok.RequiredArgsConstructor;
@@ -25,17 +27,17 @@ public class NotificationService {
     private final NotificationRepository notificationRepository;
     private final InterestTagService interestTagService;
 
-    public void createNotification(Item item, List<String> tagNames){
-
+    public void createNotification(Item item, List<String> tagNames) {
         List<Member> receivers = interestTagService.getMemberByTags(tagNames);
 
-        receivers.stream().forEach(member -> {
-            notificationRepository.save(Notification.builder()
-                    .item(item)
-                    .member(member).build());
+        receivers.forEach(member -> {
+            notificationRepository.save(
+                    Notification.builder()
+                            .item(item)
+                            .member(member)
+                            .build()
+            );
         });
-
-
     }
 
     @Transactional(readOnly = true)
@@ -54,31 +56,23 @@ public GetMyNotificationsResponse getMyNotifications(String email) {
         return GetMyNotificationsResponse.of(notifications, itemTags);
     }
 
-    public void readNotification(Long notificationId, String email) {
+    public void readNotification(ReadNotificationRequest request, String email) {
         Member member = memberRepository.findByEmail(email)
                 .orElseThrow(() -> new CustomException(ErrorCode.UNAUTHORIZED));
 
-        Notification notification = notificationRepository.findById(notificationId)
+        Notification notification = notificationRepository.findByMemberIdAndItemId(member.getId(), request.getItemId())
                 .orElseThrow(() -> new CustomException(ErrorCode.NOTIFICATION_NOT_FOUND));
 
-        if (notification.getMember() == member) {
-            throw new CustomException(ErrorCode.FORBIDDEN);
-        }
-
         notification.read();
     }
 
-    public void deleteNotification(Long notificationId, String email) {
+    public void deleteNotification(DeleteNotificationRequest request, String email) {
         Member member = memberRepository.findByEmail(email)
                 .orElseThrow(() -> new CustomException(ErrorCode.UNAUTHORIZED));
 
-        Notification notification = notificationRepository.findById(notificationId)
+        Notification notification = notificationRepository.findByMemberIdAndItemId(member.getId(), request.getItemId())
                 .orElseThrow(() -> new CustomException(ErrorCode.NOTIFICATION_NOT_FOUND));
 
-        if (notification.getMember() == member) {
-            throw new CustomException(ErrorCode.FORBIDDEN);
-        }
-
         notificationRepository.delete(notification);
     }
 

diff --git a/src/main/resources/static/index.html b/src/main/resources/static/index.html