알림 기능 구현 (이벤트 발행 및 구독, 알림 조회, 알림 삭제, 알림 업데이트)

backend/baton/src/docs/asciidoc/NotificationDeleteApi.adoc

@@ -0,0 +1,29 @@
+ifndef::snippets[]
+:snippets: ../../../build/generated-snippets
+endif::[]
+:doctype: book
+:icons: font
+:source-highlighter: highlight.js
+:toc: left
+:toclevels: 3
+:sectlinks:
+:operation-http-request-title: Example Request
+:operation-http-response-title: Example Response
+
+==== *알림 삭제 API*
+
+===== *Http Request*
+
+include::{snippets}/../../build/generated-snippets/notification-delete-api-test/delete-notification-by-notification-id/http-request.adoc[]
+
+===== *Http Request Headers*
+
+include::{snippets}/../../build/generated-snippets/notification-delete-api-test/delete-notification-by-notification-id/request-headers.adoc[]
+
+===== *Http Request Path Parameters*
+
+include::{snippets}/../../build/generated-snippets/notification-delete-api-test/delete-notification-by-notification-id/path-parameters.adoc[]
+
+===== *Http Response*
+
+include::{snippets}/../../build/generated-snippets/notification-delete-api-test/delete-notification-by-notification-id/http-response.adoc[]

backend/baton/src/docs/asciidoc/NotificationLoginReadApi.adoc

@@ -0,0 +1,29 @@
+ifndef::snippets[]
+:snippets: ../../../build/generated-snippets
+endif::[]
+:doctype: book
+:icons: font
+:source-highlighter: highlight.js
+:toc: left
+:toclevels: 3
+:sectlinks:
+:operation-http-request-title: Example Request
+:operation-http-response-title: Example Response
+
+==== *로그인된 사용자 알림 목록 조회 API*
+
+===== *Http Request*
+
+include::{snippets}/../../build/generated-snippets/notification-read-with-logined-member-api-test/read-notifications-by-member-id/http-request.adoc[]
+
+===== *Http Request Headers*
+
+include::{snippets}/../../build/generated-snippets/notification-read-with-logined-member-api-test/read-notifications-by-member-id/request-headers.adoc[]
+
+===== *Http Response*
+
+include::{snippets}/../../build/generated-snippets/notification-read-with-logined-member-api-test/read-notifications-by-member-id/http-response.adoc[]
+
+===== *Http Response Fields*
+
+include::{snippets}/../../build/generated-snippets/notification-read-with-logined-member-api-test/read-notifications-by-member-id/response-fields.adoc[]

backend/baton/src/docs/asciidoc/NotificationUpdateApi.adoc

@@ -0,0 +1,29 @@
+ifndef::snippets[]
+:snippets: ../../../build/generated-snippets
+endif::[]
+:doctype: book
+:icons: font
+:source-highlighter: highlight.js
+:toc: left
+:toclevels: 3
+:sectlinks:
+:operation-http-request-title: Example Request
+:operation-http-response-title: Example Response
+
+==== *알림 읽음 여부 업데이트 API*
+
+===== *Http Request*
+
+include::{snippets}/../../build/generated-snippets/notification-update-api-test/update-notification-is-read-true-by-member/http-request.adoc[]
+
+===== *Http Request Headers*
+
+include::{snippets}/../../build/generated-snippets/notification-update-api-test/update-notification-is-read-true-by-member/request-headers.adoc[]
+
+===== *Http Request Path Parameters*
+
+include::{snippets}/../../build/generated-snippets/notification-update-api-test/update-notification-is-read-true-by-member/path-parameters.adoc[]
+
+===== *Http Response*
+
+include::{snippets}/../../build/generated-snippets/notification-update-api-test/update-notification-is-read-true-by-member/http-response.adoc[]

backend/baton/src/docs/asciidoc/index.adoc

@@ -63,3 +63,17 @@ include::RunnerPostUpdateApplicantCancelationApi.adoc[]
 === *러너 게시글 삭제*
 
 include::RunnerPostDeleteApi.adoc[]
+
+== *[ 알림 ]*
+
+=== *알림 조회*
+
+include::NotificationLoginReadApi.adoc[]
+
+=== *알림 수정*
+
+include::NotificationUpdateApi.adoc[]
+
+=== *알림 삭제*
+
+include::NotificationDeleteApi.adoc[]

backend/baton/src/main/java/touch/baton/domain/common/TruncatedBaseEntity.java

@@ -0,0 +1,22 @@
+package touch.baton.domain.common;
+
+import java.time.LocalDateTime;
+import java.time.temporal.ChronoUnit;
+
+public abstract class TruncatedBaseEntity extends BaseEntity {
+
+    @Override
+    public LocalDateTime getCreatedAt() {
+        return super.getCreatedAt().truncatedTo(ChronoUnit.MINUTES);
+    }
+
+    @Override
+    public LocalDateTime getDeletedAt() {
+        return super.getDeletedAt().truncatedTo(ChronoUnit.MINUTES);
+    }
+
+    @Override
+    public LocalDateTime getUpdatedAt() {
+        return super.getUpdatedAt().truncatedTo(ChronoUnit.MINUTES);
+    }
+}

backend/baton/src/main/java/touch/baton/domain/notification/command/Notification.java

@@ -0,0 +1,146 @@
+package touch.baton.domain.notification.command;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Embedded;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.ForeignKey;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.SQLDelete;
+import org.hibernate.annotations.Where;
+import touch.baton.domain.common.TruncatedBaseEntity;
+import touch.baton.domain.member.command.Member;
+import touch.baton.domain.notification.command.vo.IsRead;
+import touch.baton.domain.notification.command.vo.NotificationMessage;
+import touch.baton.domain.notification.command.vo.NotificationReferencedId;
+import touch.baton.domain.notification.command.vo.NotificationTitle;
+import touch.baton.domain.notification.command.vo.NotificationType;
+import touch.baton.domain.notification.exception.NotificationDomainException;
+
+import java.util.Objects;
+
+import static jakarta.persistence.EnumType.STRING;
+import static jakarta.persistence.FetchType.LAZY;
+import static jakarta.persistence.GenerationType.IDENTITY;
+import static lombok.AccessLevel.PROTECTED;
+
+@Getter
+@NoArgsConstructor(access = PROTECTED)
+@Where(clause = "deleted_at IS NULL")
+@SQLDelete(sql = "UPDATE notification SET deleted_at = now() WHERE id = ?")
+@Entity
+public class Notification extends TruncatedBaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = IDENTITY)
+    private Long id;
+
+    @Embedded
+    private NotificationTitle notificationTitle;
+
+    @Embedded
+    private NotificationMessage notificationMessage;
+
+    @Enumerated(STRING)
+    @Column(nullable = false)
+    private NotificationType notificationType;
+
+    @Embedded
+    private NotificationReferencedId notificationReferencedId;
+
+    @Embedded
+    private IsRead isRead;
+
+    @ManyToOne(fetch = LAZY)
+    @JoinColumn(name = "member_id",
+            nullable = false,
+            foreignKey = @ForeignKey(name = "fk_notification_to_member"))
+    private Member member;
+
+    @Builder
+    private Notification(final NotificationTitle notificationTitle,
+                         final NotificationMessage notificationMessage,
+                         final NotificationType notificationType,
+                         final NotificationReferencedId notificationReferencedId,
+                         final IsRead isRead,
+                         final Member member
+    ) {
+        this(null, notificationTitle, notificationMessage, notificationType, notificationReferencedId, isRead, member);
+    }
+
+    private Notification(final Long id,
+                         final NotificationTitle notificationTitle,
+                         final NotificationMessage notificationMessage,
+                         final NotificationType notificationType,
+                         final NotificationReferencedId notificationReferencedId,
+                         final IsRead isRead,
+                         final Member member
+    ) {
+        validateNotNull(notificationTitle, notificationMessage, notificationType, notificationReferencedId, isRead, member);
+        this.id = id;
+        this.notificationTitle = notificationTitle;
+        this.notificationMessage = notificationMessage;
+        this.notificationType = notificationType;
+        this.notificationReferencedId = notificationReferencedId;
+        this.isRead = isRead;
+        this.member = member;
+    }
+
+    private void validateNotNull(final NotificationTitle notificationTitle,
+                                 final NotificationMessage notificationMessage,
+                                 final NotificationType notificationType,
+                                 final NotificationReferencedId notificationReferencedId,
+                                 final IsRead isRead,
+                                 final Member member
+    ) {
+        if (notificationTitle == null) {
+            throw new NotificationDomainException("NotificationTitle 의 notificationTitle 은 null 일 수 없습니다.");
+        }
+        if (notificationMessage == null) {
+            throw new NotificationDomainException("NotificationMessage 의 notificationMessage 는 null 일 수 없습니다.");
+        }
+        if (notificationType == null) {
+            throw new NotificationDomainException("NotificationType 의 notificationType 는 null 일 수 없습니다.");
+        }
+        if (notificationReferencedId == null) {
+            throw new NotificationDomainException("NotificationReferencedId 의 notificationReferencedId 은 null 일 수 없습니다.");
+        }
+        if (isRead == null) {
+            throw new NotificationDomainException("IsRead 의 isRead 는 null 일 수 없습니다.");
+        }
+        if (member == null) {
+            throw new NotificationDomainException("Member 의 member 는 null 일 수 없습니다.");
+        }
+    }
+
+    public void markAsRead(final Member currentMember) {
+        if (!this.member.equals(currentMember)) {
+            throw new NotificationDomainException("Notification 의 주인(사용자)가 아니므로 알림의 읽은 여부를 수정할 수 없습니다.");
+        }
+
+        this.isRead = IsRead.asRead();
+    }
+
+    public boolean isNotOwner(final Member currentMember) {
+        return !this.member.equals(currentMember);
+    }
+
+    @Override
+    public boolean equals(final Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        final Notification notification = (Notification) o;
+        return Objects.equals(id, notification.id);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id);
+    }
+}

backend/baton/src/main/java/touch/baton/domain/notification/command/controller/NotificationCommandController.java

@@ -0,0 +1,38 @@
+package touch.baton.domain.notification.command.controller;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PatchMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import touch.baton.domain.notification.command.service.NotificationCommandService;
+import touch.baton.domain.member.command.Member;
+import touch.baton.domain.oauth.query.controller.resolver.AuthMemberPrincipal;
+
+@RequiredArgsConstructor
+@RequestMapping("/api/v1/notifications")
+@RestController
+public class NotificationCommandController {
+
+    private final NotificationCommandService notificationCommandService;
+
+    @PatchMapping("/{notificationId}")
+    public ResponseEntity<Void> updateNotificationIsReadTrueByNotificationId(@AuthMemberPrincipal final Member member,
+                                                                             @PathVariable final Long notificationId
+    ) {
+        notificationCommandService.updateNotificationIsReadTrueByMember(member, notificationId);
+
+        return ResponseEntity.noContent().build();
+    }
+
+    @DeleteMapping("/{notificationId}")
+    public ResponseEntity<Void> deleteNotificationByNotificationId(@AuthMemberPrincipal final Member member,
+                                                                   @PathVariable final Long notificationId
+    ) {
+        notificationCommandService.deleteNotificationByMember(member, notificationId);
+
+        return ResponseEntity.noContent().build();
+    }
+}

backend/baton/src/main/java/touch/baton/domain/notification/command/event/NotificationEventListener.java

@@ -0,0 +1,82 @@
+package touch.baton.domain.notification.command.event;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionalEventListener;
+import touch.baton.domain.member.command.Member;
+import touch.baton.domain.notification.command.Notification;
+import touch.baton.domain.notification.command.repository.NotificationCommandRepository;
+import touch.baton.domain.notification.command.vo.IsRead;
+import touch.baton.domain.notification.command.vo.NotificationMessage;
+import touch.baton.domain.notification.command.vo.NotificationReferencedId;
+import touch.baton.domain.notification.command.vo.NotificationTitle;
+import touch.baton.domain.notification.command.vo.NotificationType;
+import touch.baton.domain.notification.exception.NotificationBusinessException;
+import touch.baton.domain.runnerpost.command.RunnerPost;
+import touch.baton.domain.runnerpost.command.event.RunnerPostApplySupporterEvent;
+import touch.baton.domain.runnerpost.command.event.RunnerPostAssignSupporterEvent;
+import touch.baton.domain.runnerpost.command.event.RunnerPostReviewStatusDoneEvent;
+import touch.baton.domain.runnerpost.query.repository.RunnerPostQueryRepository;
+
+import static org.springframework.transaction.annotation.Propagation.REQUIRES_NEW;
+import static org.springframework.transaction.event.TransactionPhase.AFTER_COMMIT;
+
+@RequiredArgsConstructor
+@Component
+public class NotificationEventListener {
+
+    private final NotificationCommandRepository notificationCommandRepository;
+    private final RunnerPostQueryRepository runnerPostQueryRepository;
+
+    @TransactionalEventListener(phase = AFTER_COMMIT)
+    @Transactional(propagation = REQUIRES_NEW)
+    public void subscribeRunnerPostApplySupporterEvent(final RunnerPostApplySupporterEvent event) {
+        final RunnerPost foundRunnerPost = getRunnerPostWithRunnerOrThrowException(event.runnerPostId());
+
+        notificationCommandRepository.save(
+                createNotification("서포터의 제안이 왔습니다.", foundRunnerPost, foundRunnerPost.getRunner().getMember())
+        );
+    }
+
+    private RunnerPost getRunnerPostWithRunnerOrThrowException(final Long runnerPostId) {
+        return runnerPostQueryRepository.joinMemberByRunnerPostId(runnerPostId)
+                .orElseThrow(() -> new NotificationBusinessException("러너 게시글 식별자값으로 러너 게시글과 러너(작성자)를 조회하던 도중에 오류가 발생하였습니다."));
+    }
+
+    private Notification createNotification(final String notificationTitle, final RunnerPost runnerPost, final Member targetMember) {
+        return Notification.builder()
+                .notificationTitle(new NotificationTitle(notificationTitle))
+                .notificationMessage(new NotificationMessage(String.format("관련 게시글 - %s", runnerPost.getTitle().getValue())))
+                .notificationType(NotificationType.RUNNER_POST)
+                .notificationReferencedId(new NotificationReferencedId(runnerPost.getId()))
+                .isRead(IsRead.asUnRead())
+                .member(targetMember)
+                .build();
+    }
+
+    @TransactionalEventListener(phase = AFTER_COMMIT)
+    @Transactional(propagation = REQUIRES_NEW)
+    public void subscribeRunnerPostReviewStatusDoneEvent(final RunnerPostReviewStatusDoneEvent event) {
+        final RunnerPost foundRunnerPost = getRunnerPostWithRunnerOrThrowException(event.runnerPostId());
+
+        notificationCommandRepository.save(
+                createNotification("코드 리뷰 상태가 완료로 변경되었습니다.", foundRunnerPost, foundRunnerPost.getRunner().getMember())
+        );
+    }
+
+    @TransactionalEventListener(phase = AFTER_COMMIT)
+    @Transactional(propagation = REQUIRES_NEW)
+    public void subscribeRunnerPostAssignSupporterEvent(final RunnerPostAssignSupporterEvent event) {
+        final RunnerPost foundRunnerPost = getRunnerPostWithSupporterOrThrowException(event.runnerPostId());
+
+        notificationCommandRepository.save(
+                createNotification("코드 리뷰 매칭이 완료되었습니다.", foundRunnerPost, foundRunnerPost.getSupporter().getMember())
+        );
+    }
+
+    private RunnerPost getRunnerPostWithSupporterOrThrowException(final Long runnerPostId) {
+        return runnerPostQueryRepository.joinSupporterByRunnerPostId(runnerPostId)
+                .orElseThrow(() -> new NotificationBusinessException("러너 게시글 식별자값으로 러너 게시글과 서포터(지원자)를 조회하던 도중에 오류가 발생하였습니다."));
+    }
+}