[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()))
                 .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(reactionCount))
                 .build();
     }
 }

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

@@ -140,10 +140,4 @@ public void saveTagNotification(Feed feed, List<LinkedUser> linkedUsers, User au
                 }
             });
     }
-
-    @Transactional
-    public void markNotificationAsRead(Long userId, String notificationId) {
-        User user = userGetService.findById(userId);
-        notificationMarkReadService.markReadNotification(user, notificationId);
-    }
 }

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 markNotificationAsRead(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

@@ -46,7 +46,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.markNotificationAsRead(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,9 @@ public void reRegisterFromApple(String name) {
     public boolean isAgree() {
         return this.termsAgreement && this.privacyAgreement;
     }
+
+    // TODO: 코틀린 자바 롬복 문제. 추후 마이그레이션 후 삭제
+    public Long getId() {
+        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/kotlin/leets/leenk/domain/feed/application/usecase/FeedUsecase.kt

@@ -22,6 +22,7 @@ import leets.leenk.domain.feed.application.mapper.ReactionMapper
 import leets.leenk.domain.feed.domain.entity.Comment
 import leets.leenk.domain.feed.domain.entity.Feed
 import leets.leenk.domain.feed.domain.entity.LinkedUser
+import leets.leenk.domain.feed.domain.event.FeedDomainEvent
 import leets.leenk.domain.feed.domain.service.CommentDeleteService
 import leets.leenk.domain.feed.domain.service.CommentGetService
 import leets.leenk.domain.feed.domain.service.CommentSaveService
@@ -44,6 +45,7 @@ import leets.leenk.domain.user.domain.service.NotionDatabaseService
 import leets.leenk.domain.user.domain.service.SlackWebhookService
 import leets.leenk.domain.user.domain.service.blockuser.UserBlockService
 import leets.leenk.domain.user.domain.service.user.UserGetService
+import org.springframework.context.ApplicationEventPublisher
 import org.springframework.data.domain.PageRequest
 import org.springframework.stereotype.Service
 import org.springframework.transaction.annotation.Transactional
@@ -75,6 +77,7 @@ class FeedUsecase(
     private val feedUserMapper: FeedUserMapper,
     private val reactionMapper: ReactionMapper,
     private val commentMapper: CommentMapper,
+    private val eventPublisher: ApplicationEventPublisher,
 ) {
     @Transactional(readOnly = true)
     fun getFeeds(
@@ -211,8 +214,17 @@ class FeedUsecase(
         val linkedUsers = getLinkedUsers(author, request.userIds, feed)
         linkedUserSaveService.saveAll(linkedUsers)
 
-        feedNotificationUsecase.saveNewFeedNotification(feed)
-        feedNotificationUsecase.saveTagNotification(feed, linkedUsers, author)
+        // 태그된 사용자 ID 목록 (작성자 제외)
+        val taggedUserIds = request.userIds.filter { it != author.id }
+
+        eventPublisher.publishEvent(
+            FeedDomainEvent.created(
+                feedId = feed.id!!,
+                authorId = author.id!!,
+                authorName = author.name,
+                taggedUserIds = taggedUserIds,
+            ),
+        )
     }
 
     private fun getLinkedUsers(
@@ -258,7 +270,20 @@ class FeedUsecase(
 
         // Feed를 가져올 때 Fetch Join으로 작성자를 함께 가져와 락이 함께 걸리므로 별도의 락 필요 없음.
         feedUpdateService.updateTotalReaction(feed, reaction, feed.user, request.reactionCount)
-        feedNotificationUsecase.saveFirstReactionNotification(reaction)
+
+        // 업데이트된 총 공감 수 계산
+        val totalReactionCount = feed.totalReactionCount + request.reactionCount
+
+        eventPublisher.publishEvent(
+            FeedDomainEvent.reacted(
+                feedId = feed.id!!,
+                feedAuthorId = feed.user.id!!,
+                reactorId = user.id!!,
+                reactorName = user.name,
+                previousReactionCount = previousReactionCount,
+                totalReactionCount = totalReactionCount,
+            ),
+        )
 
         val updatedReactionCount = previousReactionCount + request.reactionCount
         notifyIfReachedReactionMilestone(previousReactionCount, updatedReactionCount, feed)

src/main/kotlin/leets/leenk/domain/feed/domain/event/FeedDomainEvent.kt

@@ -0,0 +1,68 @@
+package leets.leenk.domain.feed.domain.event
+
+/**
+ * Feed 도메인의 단일 이벤트
+ * eventType으로 이벤트 종류 구분, data로 필요한 정보 전달
+ */
+data class FeedDomainEvent(
+    val eventType: FeedEventType,
+    val data: Map<String, Any>,
+) {
+    companion object {
+        /**
+         * 피드 생성 이벤트
+         */
+        @JvmStatic
+        fun created(
+            feedId: Long,
+            authorId: Long,
+            authorName: String,
+            taggedUserIds: List<Long> = emptyList(),
+        ) = FeedDomainEvent(
+            eventType = FeedEventType.CREATED,
+            data =
+                mapOf(
+                    "feedId" to feedId,
+                    "authorId" to authorId,
+                    "authorName" to authorName,
+                    "taggedUserIds" to taggedUserIds,
+                ),
+        )
+
+        /**
+         * 피드 공감 이벤트
+         */
+        @JvmStatic
+        fun reacted(
+            feedId: Long,
+            feedAuthorId: Long,
+            reactorId: Long,
+            reactorName: String,
+            previousReactionCount: Long,
+            totalReactionCount: Long,
+        ) = FeedDomainEvent(
+            eventType = FeedEventType.REACTED,
+            data =
+                mapOf(
+                    "feedId" to feedId,
+                    "feedAuthorId" to feedAuthorId,
+                    "reactorId" to reactorId,
+                    "reactorName" to reactorName,
+                    "previousReactionCount" to previousReactionCount,
+                    "totalReactionCount" to totalReactionCount,
+                ),
+        )
+    }
+
+    // 타입 안전한 접근자
+    val feedId: Long get() = data["feedId"] as Long
+    val authorId: Long get() = data["authorId"] as Long
+    val authorName: String get() = data["authorName"] as String
+    val taggedUserIds: List<Long>
+        get() = (data["taggedUserIds"] as? List<*>)?.filterIsInstance<Long>() ?: emptyList()
+    val feedAuthorId: Long get() = data["feedAuthorId"] as Long
+    val reactorId: Long get() = data["reactorId"] as Long
+    val reactorName: String get() = data["reactorName"] as String
+    val previousReactionCount: Long get() = data["previousReactionCount"] as Long
+    val totalReactionCount: Long get() = data["totalReactionCount"] as Long
+}

src/main/kotlin/leets/leenk/domain/feed/domain/event/FeedEventType.kt

@@ -0,0 +1,9 @@
+package leets.leenk.domain.feed.domain.event
+
+/**
+ * Feed 도메인 이벤트 타입
+ */
+enum class FeedEventType {
+    CREATED, // 피드 생성
+    REACTED, // 피드 공감
+}