Merge pull request #67 from classic-daramg/feature/notification

Feature/notification

Author: k3vin7

src/main/java/com/daramg/server/comment/application/CommentService.java

@@ -8,10 +8,13 @@
 import com.daramg.server.common.application.EntityUtils;
 import com.daramg.server.common.exception.BusinessException;
 import com.daramg.server.post.domain.Post;
+import com.daramg.server.notification.domain.NotificationType;
+import com.daramg.server.notification.event.NotificationEvent;
 import com.daramg.server.post.dto.CommentCreateDto;
 import com.daramg.server.post.dto.CommentReplyCreateDto;
 import com.daramg.server.user.domain.User;
 import lombok.RequiredArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -23,6 +26,7 @@ public class CommentService {
     private final EntityUtils entityUtils;
     private final CommentRepository commentRepository;
     private final CommentLikeRepository commentLikeRepository;
+    private final ApplicationEventPublisher eventPublisher;
 
     public void createComment(Long postId, CommentCreateDto request, User user){
         Post post = entityUtils.getEntity(postId, Post.class);
@@ -39,6 +43,11 @@ public void createComment(Long postId, CommentCreateDto request, User user){
 
         commentRepository.save(comment);
         post.incrementCommentCount();
+        if (!post.getUser().getId().equals(user.getId())) {
+            eventPublisher.publishEvent(new NotificationEvent(
+                    post.getUser(), user, post, NotificationType.COMMENT
+            ));
+        }
     }
 
     public void createReply(Long commentId, CommentReplyCreateDto request, User user){
@@ -60,6 +69,11 @@ public void createReply(Long commentId, CommentReplyCreateDto request, User user
 
         commentRepository.save(reply);
         post.incrementCommentCount();
+        if (!parentComment.getUser().getId().equals(user.getId())) {
+            eventPublisher.publishEvent(new NotificationEvent(
+                    parentComment.getUser(), user, post, NotificationType.REPLY
+            ));
+        }
     }
 
     public CommentLikeResponseDto toggleCommentLike(Long commentId, User user){
@@ -79,6 +93,11 @@ public CommentLikeResponseDto toggleCommentLike(Long commentId, User user){
 
         commentLikeRepository.save(CommentLike.of(comment, user));
         comment.incrementLikeCount();
+        if (!comment.getUser().getId().equals(user.getId())) {
+            eventPublisher.publishEvent(new NotificationEvent(
+                    comment.getUser(), user, comment.getPost(), NotificationType.COMMENT_LIKE
+            ));
+        }
         return new CommentLikeResponseDto(true, comment.getLikeCount());
     }
 

src/main/java/com/daramg/server/notification/application/NotificationQueryService.java

@@ -0,0 +1,42 @@
+package com.daramg.server.notification.application;
+
+import com.daramg.server.common.dto.PageRequestDto;
+import com.daramg.server.common.dto.PageResponseDto;
+import com.daramg.server.common.util.PagingUtils;
+import com.daramg.server.notification.domain.Notification;
+import com.daramg.server.notification.dto.NotificationResponseDto;
+import com.daramg.server.notification.repository.NotificationQueryRepository;
+import com.daramg.server.notification.repository.NotificationRepository;
+import com.daramg.server.user.domain.User;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Service
+@Transactional(readOnly = true)
+@RequiredArgsConstructor
+public class NotificationQueryService {
+
+    private final NotificationRepository notificationRepository;
+    private final NotificationQueryRepository notificationQueryRepository;
+    private final PagingUtils pagingUtils;
+
+    public PageResponseDto<NotificationResponseDto> getNotifications(User user, PageRequestDto request) {
+        List<Notification> notifications = notificationQueryRepository
+                .getNotificationsWithPaging(user.getId(), request);
+
+        return pagingUtils.createPageResponse(
+                notifications,
+                request.getValidatedSize(),
+                NotificationResponseDto::from,
+                Notification::getCreatedAt,
+                Notification::getId
+        );
+    }
+
+    public long getUnreadCount(User user) {
+        return notificationRepository.countByReceiverIdAndIsReadFalse(user.getId());
+    }
+}

src/main/java/com/daramg/server/notification/application/NotificationService.java

@@ -0,0 +1,41 @@
+package com.daramg.server.notification.application;
+
+import com.daramg.server.common.application.EntityUtils;
+import com.daramg.server.common.exception.BusinessException;
+import com.daramg.server.notification.domain.Notification;
+import com.daramg.server.notification.repository.NotificationRepository;
+import com.daramg.server.user.domain.User;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional
+@RequiredArgsConstructor
+public class NotificationService {
+
+    private final NotificationRepository notificationRepository;
+    private final EntityUtils entityUtils;
+
+    public void markAsRead(Long notificationId, User user) {
+        Notification notification = entityUtils.getEntity(notificationId, Notification.class);
+        validateReceiver(notification, user);
+        notification.markAsRead();
+    }
+
+    public void markAllAsRead(User user) {
+        notificationRepository.markAllAsReadByReceiverId(user.getId());
+    }
+
+    public void delete(Long notificationId, User user) {
+        Notification notification = entityUtils.getEntity(notificationId, Notification.class);
+        validateReceiver(notification, user);
+        notificationRepository.delete(notification);
+    }
+
+    private void validateReceiver(Notification notification, User user) {
+        if (!notification.getReceiver().getId().equals(user.getId())) {
+            throw new BusinessException("본인의 알림만 처리할 수 있습니다.");
+        }
+    }
+}

src/main/java/com/daramg/server/notification/domain/Notification.java

@@ -0,0 +1,54 @@
+package com.daramg.server.notification.domain;
+
+import com.daramg.server.common.domain.BaseEntity;
+import com.daramg.server.post.domain.Post;
+import com.daramg.server.user.domain.User;
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.springframework.lang.NonNull;
+
+@Entity
+@Getter
+@Table(name = "notifications")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Notification extends BaseEntity<Notification> {
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "receiver_id", nullable = false)
+    private User receiver;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "sender_id", nullable = false)
+    private User sender;
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "post_id", nullable = false)
+    private Post post;
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "type", nullable = false, length = 20)
+    private NotificationType type;
+
+    @Column(name = "is_read", nullable = false)
+    private boolean isRead = false;
+
+    private Notification(User receiver, User sender, Post post, NotificationType type) {
+        this.receiver = receiver;
+        this.sender = sender;
+        this.post = post;
+        this.type = type;
+    }
+
+    public static Notification of(@NonNull User receiver,
+                                   @NonNull User sender,
+                                   @NonNull Post post,
+                                   @NonNull NotificationType type) {
+        return new Notification(receiver, sender, post, type);
+    }
+
+    public void markAsRead() {
+        this.isRead = true;
+    }
+}

src/main/java/com/daramg/server/notification/domain/NotificationType.java

@@ -0,0 +1,8 @@
+package com.daramg.server.notification.domain;
+
+public enum NotificationType {
+    POST_LIKE,
+    COMMENT_LIKE,
+    COMMENT,
+    REPLY
+}

src/main/java/com/daramg/server/notification/dto/NotificationResponseDto.java

@@ -0,0 +1,30 @@
+package com.daramg.server.notification.dto;
+
+import com.daramg.server.notification.domain.Notification;
+import com.daramg.server.notification.domain.NotificationType;
+
+import java.time.LocalDateTime;
+
+public record NotificationResponseDto(
+        Long id,
+        String senderNickname,
+        String senderProfileImage,
+        Long postId,
+        String postTitle,
+        NotificationType type,
+        boolean isRead,
+        LocalDateTime createdAt
+) {
+    public static NotificationResponseDto from(Notification notification) {
+        return new NotificationResponseDto(
+                notification.getId(),
+                notification.getSender().getNickname(),
+                notification.getSender().getProfileImage(),
+                notification.getPost().getId(),
+                notification.getPost().getTitle(),
+                notification.getType(),
+                notification.isRead(),
+                notification.getCreatedAt()
+        );
+    }
+}

src/main/java/com/daramg/server/notification/event/NotificationEvent.java

@@ -0,0 +1,13 @@
+package com.daramg.server.notification.event;
+
+import com.daramg.server.notification.domain.NotificationType;
+import com.daramg.server.post.domain.Post;
+import com.daramg.server.user.domain.User;
+
+public record NotificationEvent(
+        User receiver,
+        User sender,
+        Post post,
+        NotificationType type
+) {
+}

src/main/java/com/daramg/server/notification/event/NotificationEventListener.java

@@ -0,0 +1,32 @@
+package com.daramg.server.notification.event;
+
+import com.daramg.server.notification.domain.Notification;
+import com.daramg.server.notification.repository.NotificationRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+import static org.springframework.transaction.event.TransactionPhase.BEFORE_COMMIT;
+
+@Component
+@RequiredArgsConstructor
+public class NotificationEventListener {
+
+    private final NotificationRepository notificationRepository;
+
+    @TransactionalEventListener(phase = BEFORE_COMMIT)
+    public void handleNotificationEvent(NotificationEvent event) {
+        if (event.receiver().getId().equals(event.sender().getId())) {
+            return;
+        }
+
+        Notification notification = Notification.of(
+                event.receiver(),
+                event.sender(),
+                event.post(),
+                event.type()
+        );
+
+        notificationRepository.save(notification);
+    }
+}

src/main/java/com/daramg/server/notification/presentation/NotificationController.java

@@ -0,0 +1,33 @@
+package com.daramg.server.notification.presentation;
+
+import com.daramg.server.notification.application.NotificationService;
+import com.daramg.server.user.domain.User;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/notifications")
+public class NotificationController {
+
+    private final NotificationService notificationService;
+
+    @PatchMapping("/{notificationId}/read")
+    @ResponseStatus(HttpStatus.OK)
+    public void markAsRead(@PathVariable Long notificationId, User user) {
+        notificationService.markAsRead(notificationId, user);
+    }
+
+    @PatchMapping("/read-all")
+    @ResponseStatus(HttpStatus.OK)
+    public void markAllAsRead(User user) {
+        notificationService.markAllAsRead(user);
+    }
+
+    @DeleteMapping("/{notificationId}")
+    @ResponseStatus(HttpStatus.NO_CONTENT)
+    public void delete(@PathVariable Long notificationId, User user) {
+        notificationService.delete(notificationId, user);
+    }
+}

src/main/java/com/daramg/server/notification/presentation/NotificationQueryController.java

@@ -0,0 +1,33 @@
+package com.daramg.server.notification.presentation;
+
+import com.daramg.server.common.dto.PageRequestDto;
+import com.daramg.server.common.dto.PageResponseDto;
+import com.daramg.server.notification.application.NotificationQueryService;
+import com.daramg.server.notification.dto.NotificationResponseDto;
+import com.daramg.server.user.domain.User;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/notifications")
+public class NotificationQueryController {
+
+    private final NotificationQueryService notificationQueryService;
+
+    @GetMapping
+    public PageResponseDto<NotificationResponseDto> getNotifications(
+            User user,
+            @ModelAttribute PageRequestDto request
+    ) {
+        return notificationQueryService.getNotifications(user, request);
+    }
+
+    @GetMapping("/unread-count")
+    public long getUnreadCount(User user) {
+        return notificationQueryService.getUnreadCount(user);
+    }
+}