Feature/#297 댓글 알림 조회 api, 읽음 상태 변경 api 및 is read 추가

backend/emm-sale/src/docs/asciidoc/index.adoc

@@ -370,6 +370,28 @@ include::{snippets}/find-all-request-notification/response-fields.adoc[]
 .HTTP response
 include::{snippets}/find-all-request-notification/http-response.adoc[]
 
+== Update Notification(댓글 & 행사 알림)
+
+=== `GET` : 댓글 & 행사 알림들 조회
+
+.HTTP request 설명
+include::{snippets}/get-update-notifications/request-parameters.adoc[]
+
+include::{snippets}/get-update-notifications/http-request.adoc[]
+
+.HTTP response
+include::{snippets}/get-update-notifications/http-response.adoc[]
+
+=== 'PUT' : 댓글 & 행사 알림 읽음 상태 변경
+
+.HTTP request 설명
+include::{snippets}/put-update-notifications-read/path-parameters.adoc[]
+
+include::{snippets}/put-update-notifications-read/http-request.adoc[]
+
+.HTTP response
+include::{snippets}/put-update-notifications-read/http-response.adoc[]
+
 == Block
 
 === `POST` : 사용자 차단 등록

backend/emm-sale/src/main/java/com/emmsale/member/exception/MemberExceptionType.java

@@ -43,7 +43,14 @@ public enum MemberExceptionType implements BaseExceptionType {
   OVER_LENGTH_DESCRIPTION(
       HttpStatus.BAD_REQUEST,
       "한줄 자기소개에 입력 가능한 글자 수를 초과했습니다."
-  );
+  ),
+
+  NOT_MATCHING_TOKEN_AND_LOGIN(
+      HttpStatus.UNAUTHORIZED,
+      "로그인 한 사용자와 토큰의 주인이 일치하지 않습니다."
+  )
+
+  ;
 
   private final HttpStatus httpStatus;
   private final String errorMessage;

backend/emm-sale/src/main/java/com/emmsale/notification/api/UpdateNotificationApi.java

@@ -0,0 +1,40 @@
+package com.emmsale.notification.api;
+
+import com.emmsale.member.domain.Member;
+import com.emmsale.notification.application.UpdateNotificationCommandService;
+import com.emmsale.notification.application.UpdateNotificationQueryService;
+import com.emmsale.notification.application.dto.UpdateNotificationResponse;
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+public class UpdateNotificationApi {
+
+  private final UpdateNotificationQueryService updateNotificationQueryService;
+  private final UpdateNotificationCommandService updateNotificationCommandService;
+
+  @GetMapping("/update-notifications")
+  public List<UpdateNotificationResponse> find(
+      final Member authMember,
+      @RequestParam("member-id") final Long loginMemberId
+  ) {
+    return updateNotificationQueryService.findAll(authMember, loginMemberId);
+  }
+
+  @PutMapping("/update-notifications/{update-notifications-id}/read")
+  @ResponseStatus(HttpStatus.NO_CONTENT)
+  public void read(
+      final Member authMember,
+      @PathVariable("update-notifications-id") final Long notificationId
+  ) {
+    updateNotificationCommandService.read(authMember, notificationId);
+  }
+}

backend/emm-sale/src/main/java/com/emmsale/notification/application/NotificationEventListener.java

@@ -0,0 +1,32 @@
+package com.emmsale.notification.application;
+
+import com.emmsale.comment.event.UpdateNotificationEvent;
+import com.emmsale.notification.domain.UpdateNotification;
+import com.emmsale.notification.domain.UpdateNotificationRepository;
+import com.emmsale.notification.domain.UpdateNotificationType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class NotificationEventListener {
+
+  private final UpdateNotificationRepository updateNotificationRepository;
+  private final FirebaseCloudMessageClient firebaseCloudMessageClient;
+
+  @EventListener
+  public void createUpdateNotification(final UpdateNotificationEvent updateNotificationEvent) {
+    final UpdateNotification updateNotification = new UpdateNotification(
+        updateNotificationEvent.getReceiverId(),
+        updateNotificationEvent.getRedirectId(),
+        UpdateNotificationType.from(updateNotificationEvent.getUpdateNotificationType()),
+        updateNotificationEvent.getCreatedAt()
+    );
+
+    final UpdateNotification savedNotification =
+        updateNotificationRepository.save(updateNotification);
+
+    firebaseCloudMessageClient.sendMessageTo(savedNotification);
+  }
+}

backend/emm-sale/src/main/java/com/emmsale/notification/application/UpdateNotificationCommandService.java

@@ -1,32 +1,37 @@
 package com.emmsale.notification.application;
 
+import static com.emmsale.member.exception.MemberExceptionType.NOT_MATCHING_TOKEN_AND_LOGIN;
+import static com.emmsale.notification.exception.NotificationExceptionType.NOT_FOUND_NOTIFICATION;
+
+import com.emmsale.member.domain.Member;
+import com.emmsale.member.exception.MemberException;
 import com.emmsale.notification.domain.UpdateNotification;
 import com.emmsale.notification.domain.UpdateNotificationRepository;
-import com.emmsale.comment.event.UpdateNotificationEvent;
-import com.emmsale.notification.domain.UpdateNotificationType;
+import com.emmsale.notification.exception.NotificationException;
 import lombok.RequiredArgsConstructor;
-import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
+@Transactional
 public class UpdateNotificationCommandService {
 
   private final UpdateNotificationRepository updateNotificationRepository;
-  private final FirebaseCloudMessageClient firebaseCloudMessageClient;
-
-  @EventListener
-  public void createUpdateNotification(final UpdateNotificationEvent updateNotificationEvent) {
-    final UpdateNotification updateNotification = new UpdateNotification(
-        updateNotificationEvent.getReceiverId(),
-        updateNotificationEvent.getRedirectId(),
-        UpdateNotificationType.from(updateNotificationEvent.getUpdateNotificationType()),
-        updateNotificationEvent.getCreatedAt()
-    );
 
+  public void read(final Member authMember, final Long notificationId) {
     final UpdateNotification savedNotification =
-        updateNotificationRepository.save(updateNotification);
+        updateNotificationRepository.findById(notificationId)
+            .orElseThrow(() -> new NotificationException(NOT_FOUND_NOTIFICATION));
+
+    validateSameMember(authMember, savedNotification.getReceiverId());
+
+    savedNotification.read();
+  }
 
-    firebaseCloudMessageClient.sendMessageTo(savedNotification);
+  private void validateSameMember(final Member authMember, final Long loginMemberId) {
+    if (authMember.isNotMe(loginMemberId)) {
+      throw new MemberException(NOT_MATCHING_TOKEN_AND_LOGIN);
+    }
   }
 }

backend/emm-sale/src/main/java/com/emmsale/notification/application/UpdateNotificationQueryService.java

@@ -0,0 +1,60 @@
+package com.emmsale.notification.application;
+
+import static com.emmsale.comment.exception.CommentExceptionType.NOT_FOUND_COMMENT;
+import static com.emmsale.member.exception.MemberExceptionType.NOT_MATCHING_TOKEN_AND_LOGIN;
+
+import com.emmsale.comment.domain.Comment;
+import com.emmsale.comment.domain.CommentRepository;
+import com.emmsale.comment.exception.CommentException;
+import com.emmsale.member.domain.Member;
+import com.emmsale.member.exception.MemberException;
+import com.emmsale.notification.application.dto.UpdateNotificationResponse;
+import com.emmsale.notification.domain.UpdateNotification;
+import com.emmsale.notification.domain.UpdateNotificationRepository;
+import java.util.Comparator;
+import java.util.List;
+import java.util.stream.Collectors;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class UpdateNotificationQueryService {
+
+  private final UpdateNotificationRepository updateNotificationRepository;
+  private final CommentRepository commentRepository;
+
+  public List<UpdateNotificationResponse> findAll(
+      final Member authMember,
+      final Long loginMemberId
+  ) {
+    validateSameMember(authMember, loginMemberId);
+
+    final List<UpdateNotification> notifications =
+        updateNotificationRepository.findAllByReceiverId(authMember.getId());
+
+    return notifications.stream()
+        .sorted(Comparator.comparing(UpdateNotification::getCreatedAt))
+        .map(this::convertToResponse)
+        .collect(Collectors.toList());
+  }
+
+  private void validateSameMember(final Member authMember, final Long loginMemberId) {
+    if (authMember.isNotMe(loginMemberId)) {
+      throw new MemberException(NOT_MATCHING_TOKEN_AND_LOGIN);
+    }
+  }
+
+  private UpdateNotificationResponse convertToResponse(final UpdateNotification notification) {
+    if (notification.isCommentNotification()) {
+      final Comment savedComment = commentRepository.findById(notification.getReceiverId())
+          .orElseThrow(() -> new CommentException(NOT_FOUND_COMMENT));
+
+      return UpdateNotificationResponse.convertCommentNotification(notification, savedComment);
+    }
+
+    return UpdateNotificationResponse.convertEventNotification(notification);
+  }
+}

backend/emm-sale/src/main/java/com/emmsale/notification/application/dto/UpdateNotificationResponse.java

@@ -0,0 +1,64 @@
+package com.emmsale.notification.application.dto;
+
+import com.emmsale.comment.domain.Comment;
+import com.emmsale.notification.domain.UpdateNotification;
+import com.emmsale.notification.domain.UpdateNotificationType;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public class UpdateNotificationResponse {
+
+  private final Long updateNotificationId;
+  private final Long receiverId;
+  private final Long redirectId;
+  @JsonFormat(pattern = "yyyy:MM:dd:HH:mm:ss")
+  private final LocalDateTime createdAt;
+  private final UpdateNotificationType type;
+  @JsonProperty(value = "isRead")
+  private final boolean isRead;
+  private final CommentTypeNotification commentTypeNotification;
+
+  @RequiredArgsConstructor
+  @Getter
+  public static class CommentTypeNotification {
+    private final String content;
+    private final String eventName;
+    private final String commenterImageUrl;
+  }
+
+  public static UpdateNotificationResponse convertCommentNotification(
+      final UpdateNotification notification,
+      final Comment comment
+  ) {
+    return new UpdateNotificationResponse(
+        notification.getId(), notification.getReceiverId(),
+        notification.getRedirectId(), notification.getCreatedAt(),
+        notification.getUpdateNotificationType(), notification.isRead(),
+        new CommentTypeNotification(
+            comment.getContent(),
+            comment.getEvent().getName(),
+            comment.getMember().getImageUrl()
+        )
+    );
+  }
+
+  public static UpdateNotificationResponse convertEventNotification(
+      final UpdateNotification notification
+  ) {
+    return new UpdateNotificationResponse(
+        notification.getId(), notification.getReceiverId(),
+        notification.getRedirectId(), notification.getCreatedAt(),
+        notification.getUpdateNotificationType(), notification.isRead(),
+        null
+    );
+  }
+
+  private boolean getIsRead() {
+    return isRead;
+  }
+}

backend/emm-sale/src/main/java/com/emmsale/notification/domain/UpdateNotification.java

@@ -30,6 +30,8 @@ public class UpdateNotification {
   @Column(name = "type", nullable = false)
   private UpdateNotificationType updateNotificationType;
   private LocalDateTime createdAt;
+  @Column(nullable = false)
+  private boolean isRead;
 
   public UpdateNotification(
       final Long receiverId,
@@ -41,5 +43,18 @@ public UpdateNotification(
     this.redirectId = redirectId;
     this.updateNotificationType = updateNotificationType;
     this.createdAt = createdAt;
+    this.isRead = false;
+  }
+
+  public boolean isCommentNotification() {
+    return updateNotificationType == UpdateNotificationType.COMMENT;
+  }
+
+  public boolean isEventNotification() {
+    return updateNotificationType == UpdateNotificationType.EVENT;
+  }
+
+  public void read() {
+    isRead = true;
   }
 }

backend/emm-sale/src/main/java/com/emmsale/notification/domain/UpdateNotificationRepository.java

@@ -1,7 +1,9 @@
 package com.emmsale.notification.domain;
 
+import java.util.List;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface UpdateNotificationRepository extends JpaRepository<UpdateNotification, Long> {
 
+  List<UpdateNotification> findAllByReceiverId(final Long receiverId);
 }

backend/emm-sale/src/main/resources/schema.sql

@@ -148,3 +148,7 @@ alter table event
     add column apply_start_date datetime(6) not null;
 alter table event
     add column apply_end_date datetime(6) not null;
+
+-- 2023-08-12 12:55
+alter table update_notification
+    add column is_read bit not null;