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

build.gradle.kts

@@ -31,6 +31,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")

gradle.properties

@@ -0,0 +1,5 @@
+org.gradle.jvmargs=-Xmx2048m -XX:MaxMetaspaceSize=512m
+org.gradle.parallel=true
+org.gradle.caching=true
+kotlin.daemon.jvmargs=-Xmx2048m
+org.gradle.java.home=/Users/jj/Library/Java/JavaVirtualMachines/corretto-21.0.6/Contents/Home

src/main/java/leets/leenk/domain/feed/application/usecase/FeedUsecase.java

@@ -22,6 +22,8 @@
 import leets.leenk.domain.media.domain.service.MediaGetService;
 import leets.leenk.domain.media.domain.service.MediaSaveService;
 import leets.leenk.domain.notification.application.usecase.FeedNotificationUsecase;
+import leets.leenk.domain.feed.domain.event.FeedDomainEvent;
+import org.springframework.context.ApplicationEventPublisher;
 import leets.leenk.domain.user.domain.entity.User;
 import leets.leenk.domain.user.domain.entity.UserBlock;
 import leets.leenk.domain.user.domain.service.NotionDatabaseService;
@@ -71,6 +73,7 @@ public class FeedUsecase {
     private final CommentDeleteService commentDeleteService;
 
     private final FeedNotificationUsecase feedNotificationUsecase;
+    private final ApplicationEventPublisher eventPublisher;
 
     private final FeedMapper feedMapper;
     private final MediaMapper mediaMapper;
@@ -197,8 +200,18 @@ public void uploadFeed(long userId, FeedUploadRequest request) {
         List<LinkedUser> linkedUsers = getLinkedUsers(author, request.userIds(), feed);
         linkedUserSaveService.saveAll(linkedUsers);
 
-        feedNotificationUsecase.saveNewFeedNotification(feed);
-        feedNotificationUsecase.saveTagNotification(feed, linkedUsers, author);
+        // TODO: 코틀린 마이그레이션 후 코틀린화하기
+        eventPublisher.publishEvent(
+                FeedDomainEvent.created(
+                        feed.getId(),
+                        author.getId(),
+                        author.getName(),
+                        linkedUsers.stream()
+                                .map(LinkedUser::getUser)
+                                .map(User::getId)
+                                .toList()
+                )
+        );
     }
 
     private List<LinkedUser> getLinkedUsers(User author, List<Long> userIds, Feed feed) {
@@ -230,14 +243,20 @@ public void reactToFeed(long userId, long feedId, ReactionRequest request) {
                         )
                 );
 
-        long previousReactionCount = reaction.getReactionCount();
+        Long previousReactionCount = reaction.getReactionCount();
 
-        // Feed를 가져올 때 Fetch Join으로 작성자를 함께 가져와 락이 함께 걸리므로 별도의 락 필요 없음.
         feedUpdateService.updateTotalReaction(feed, reaction, feed.getUser(), request.reactionCount());
-        feedNotificationUsecase.saveFirstReactionNotification(reaction);
 
-        long updatedReactionCount = previousReactionCount + request.reactionCount();
-        notifyIfReachedReactionMilestone(previousReactionCount, updatedReactionCount, feed);
+        eventPublisher.publishEvent(
+                FeedDomainEvent.Companion.reacted(
+                    feed.getId(),
+                    feed.getUser().getId(),
+                    user.getId(),
+                    user.getName(),
+                    previousReactionCount,
+                    feed.getTotalReactionCount()
+            )
+        );
     }
 
     @Transactional

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

@@ -175,4 +175,9 @@ public void reRegister(OauthUserInfoResponse userInfo) {
     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/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, // 피드 공감
+}