[LNK-71] domain/notification 코틀린 마이그레이션

build.gradle.kts

@@ -32,6 +32,10 @@ dependencies {
     implementation("org.jetbrains.kotlin:kotlin-stdlib")
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
 
+    // Kotlin Coroutines
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.8.0")
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor:1.8.0")
+
     // Spring
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("org.springframework.boot:spring-boot-starter-data-jpa")

src/main/java/leets/leenk/domain/notification/application/mapper/FeedFirstReactionDetailMapper.java

@@ -14,7 +14,7 @@ public FeedFirstReactionDetail toFeedFirstReactionDetail(User user) {
                 .userId(user.getId())
                 .name(user.getName())
                 .title(NotificationType.FEED_FIRST_REACTION.getTitle())
-                .body(NotificationType.FEED_FIRST_REACTION.getContent())
+                .body(NotificationType.FEED_FIRST_REACTION.formatContent(user.getName(), null, null))
                 .build();
     }
 }

src/main/java/leets/leenk/domain/notification/application/mapper/FeedReactionCountDetailMapper.java

@@ -12,7 +12,7 @@ public FeedReactionCountDetail toFeedReactionCountDetail(Long reactionCount) {
         return FeedReactionCountDetail.builder()
                 .reactionCount(reactionCount)
                 .title(NotificationType.FEED_REACTION_COUNT.getTitle())
-                .body(NotificationType.FEED_REACTION_COUNT.getFormattedContent(reactionCount))
+                .body(NotificationType.FEED_REACTION_COUNT.formatContent(null, null, reactionCount))
                 .build();
     }
 }

src/main/java/leets/leenk/domain/notification/application/usecase/NotificationUseCase.java

@@ -6,6 +6,7 @@
 import leets.leenk.domain.notification.domain.entity.Notification;
 import leets.leenk.domain.notification.domain.service.NotificationCountGetService;
 import leets.leenk.domain.notification.domain.service.NotificationGetService;
+import leets.leenk.domain.notification.domain.service.NotificationMarkReadService;
 import leets.leenk.domain.user.domain.entity.User;
 import leets.leenk.domain.user.domain.service.user.UserGetService;
 import lombok.RequiredArgsConstructor;
@@ -22,6 +23,7 @@ public class NotificationUseCase {
 
     private final UserGetService userGetService;
     private final NotificationGetService notificationGetService;
+    private final NotificationMarkReadService notificationMarkReadService;
 
     private final NotificationCountGetService notificationCountGetService;
     private final NotificationResponseMapper notificationResponseMapper;
@@ -39,4 +41,10 @@ public NotificationCountResponse getNotificationCount(long userId) {
         User user = userGetService.findById(userId);
         return notificationResponseMapper.toCountResponse(notificationCountGetService.getNotificationCount(user));
     }
+
+    @Transactional
+    public void markAsRead(Long userId, String notificationId) {
+        User user = userGetService.findById(userId);
+        notificationMarkReadService.markReadNotification(user, notificationId);
+    }
 }

src/main/java/leets/leenk/domain/notification/domain/entity/Notification.java

@@ -34,4 +34,8 @@ public void markRead() {
         this.isRead = true;
     }
 
+    public NotificationContent getContent() {
+        return this.content;
+    }
+
 }

src/main/java/leets/leenk/domain/notification/presentation/NotificationController.java

@@ -6,7 +6,6 @@
 import leets.leenk.domain.notification.application.dto.response.NotificationCountResponse;
 import leets.leenk.domain.notification.application.dto.response.NotificationListResponse;
 import leets.leenk.domain.notification.application.exception.NotificationErrorCode;
-import leets.leenk.domain.notification.application.usecase.FeedNotificationUsecase;
 import leets.leenk.domain.notification.application.usecase.NotificationUseCase;
 import leets.leenk.global.auth.application.annotation.CurrentUserId;
 import leets.leenk.global.common.exception.ApiErrorCodeExample;
@@ -23,7 +22,6 @@
 @RequiredArgsConstructor
 public class NotificationController {
 
-    private final FeedNotificationUsecase feedNotificationUsecase;
     private final NotificationUseCase notificationUseCase;
 
     @Operation(summary = "최근 알림 조회 API [무한스크롤] / 사용자의 최근 알림 목록을 페이지 단위로 조회합니다. pageNumber: 0부터 시작")
@@ -46,7 +44,7 @@ public CommonResponse<NotificationCountResponse> getNotificationCount(@Parameter
     @PatchMapping("/{notificationId}")
     public CommonResponse<Void> markAsRead(@Parameter(hidden = true) @CurrentUserId Long userId,
                                            @PathVariable String notificationId) {
-        feedNotificationUsecase.markNotificationAsRead(userId, notificationId);
+        notificationUseCase.markAsRead(userId, notificationId);
         return CommonResponse.success(NotificationResponseCode.NOTIFICATION_MARK_AS_READ_SUCCESS);
     }
 }

src/main/java/leets/leenk/domain/user/domain/entity/User.java

@@ -202,4 +202,16 @@ public void reRegisterFromApple(String name) {
     public boolean isAgree() {
         return this.termsAgreement && this.privacyAgreement;
     }
+
+    // TODO: 코틀린 자바 롬복 문제. 추후 마이그레이션 후 삭제
+    public Long getId() {
+        return id;
+    }
+
+    public Long requireId() {
+        if (id == null) {
+            throw new IllegalStateException("영속화되지 않은 User 엔티티입니다");
+        }
+        return id;
+    }
 }

src/main/java/leets/leenk/global/sqs/application/dto/SqsMessageEvent.java

@@ -13,4 +13,12 @@ public class SqsMessageEvent {
     private final String path;
     private final Long id;
 
+    public SqsMessageEvent(String title, String content, String fcmToken, String path, Long id) {
+        this.title = title;
+        this.content = content;
+        this.fcmToken = fcmToken;
+        this.path = path;
+        this.id = id;
+    }
+
 }

src/main/java/leets/leenk/global/sqs/application/handler/SqsEventHandler.java

@@ -1,8 +1,7 @@
 package leets.leenk.global.sqs.application.handler;
 
+import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
-import org.springframework.transaction.event.TransactionPhase;
-import org.springframework.transaction.event.TransactionalEventListener;
 
 import leets.leenk.global.sqs.application.mapper.AwsSqsManager;
 import leets.leenk.global.sqs.application.dto.SqsMessageEvent;
@@ -17,7 +16,7 @@ public class SqsEventHandler {
 
 	private final AwsSqsManager awsSqsManager;
 
-	@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+	@EventListener
 	public void handleEvent(SqsMessageEvent event) {
 		try {
 			SendMessageRequest request = awsSqsManager.createPushAlarmMessageRequest(event);