refactor: 프로필 생성 완료 이벤트로 변경

Author: Dimo-2562

src/main/java/com/techfork/personalization/application/PersonalizationProfileService.java

@@ -1,11 +1,10 @@
 package com.techfork.personalization.application;
 
-import com.techfork.domain.recommendation.service.RecommendationService;
-import com.techfork.useraccount.domain.User;
+import com.techfork.personalization.application.event.PersonalizedProfileGeneratedEvent;
 import com.techfork.personalization.application.generation.PersonalizedProfileGenerator;
-import com.techfork.useraccount.application.query.lookup.UserLookupService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -16,8 +15,7 @@
 public class PersonalizationProfileService {
 
     private final PersonalizedProfileGenerator personalizedProfileGenerator;
-    private final UserLookupService userLookupService;
-    private final RecommendationService recommendationService;
+    private final ApplicationEventPublisher eventPublisher;
 
     @Async
     @Transactional
@@ -33,32 +31,13 @@ public void generatePersonalizationProfile(Long userId) {
     public void generatePersonalizationProfileSync(Long userId) {
         try {
             personalizedProfileGenerator.generate(userId);
+            eventPublisher.publishEvent(new PersonalizedProfileGeneratedEvent(userId));
 
             log.info("Personalization profile generated successfully for userId: {}", userId);
 
-            generateRecommendationsAfterProfile(userId);
-
         } catch (Exception e) {
             log.error("Failed to generate personalization profile for userId: {}", userId, e);
             throw e;
         }
     }
-
-    /**
-     * 개인화 프로필 생성 완료 후 추천 생성
-     * 온보딩 또는 관심사 변경 시 새 개인화 프로필 기반으로 추천을 갱신합니다.
-     */
-    private void generateRecommendationsAfterProfile(Long userId) {
-        try {
-            User user = userLookupService.getUserOrThrow(userId);
-
-            int recommendationCount = recommendationService.generateRecommendationsForUser(user);
-
-            log.info("Recommendations generated after personalization profile creation for userId: {} - {} recommendations created",
-                    userId, recommendationCount);
-
-        } catch (Exception e) {
-            log.error("Failed to generate recommendations after personalization profile creation for userId: {}", userId, e);
-        }
-    }
 }

src/main/java/com/techfork/personalization/application/event/PersonalizedProfileGeneratedEvent.java

@@ -0,0 +1,6 @@
+package com.techfork.personalization.application.event;
+
+public record PersonalizedProfileGeneratedEvent(
+        Long userId
+) {
+}

src/test/java/com/techfork/personalization/application/PersonalizationProfileServiceTest.java

@@ -1,19 +1,17 @@
 package com.techfork.personalization.application;
 
-import com.techfork.domain.recommendation.service.RecommendationService;
-import com.techfork.useraccount.domain.User;
-import com.techfork.useraccount.domain.enums.SocialType;
+import com.techfork.personalization.application.event.PersonalizedProfileGeneratedEvent;
 import com.techfork.personalization.application.generation.PersonalizedProfileGenerator;
-import com.techfork.useraccount.application.query.lookup.UserLookupService;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
 import org.mockito.InjectMocks;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
-import org.springframework.test.util.ReflectionTestUtils;
+import org.springframework.context.ApplicationEventPublisher;
 
-import static org.assertj.core.api.Assertions.assertThatCode;
+import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.mockito.BDDMockito.given;
 import static org.mockito.Mockito.verify;
@@ -26,32 +24,27 @@ class PersonalizationProfileServiceTest {
     private PersonalizedProfileGenerator personalizedProfileGenerator;
 
     @Mock
-    private UserLookupService userLookupService;
-
-    @Mock
-    private RecommendationService recommendationService;
+    private ApplicationEventPublisher eventPublisher;
 
     @InjectMocks
     private PersonalizationProfileService personalizationProfileService;
 
     @Test
-    @DisplayName("개인화 프로필 생성을 요청한 뒤 추천을 생성한다")
-    void generatePersonalizationProfileSync_GeneratesProfileAndRecommendations() {
+    @DisplayName("개인화 프로필 생성 성공 후 프로필 생성 이벤트를 발행한다")
+    void generatePersonalizationProfileSync_PublishesProfileGeneratedEventAfterProfileGeneration() {
         Long userId = 1L;
-        User user = createUser(userId);
-        given(userLookupService.getUserOrThrow(userId)).willReturn(user);
-        given(recommendationService.generateRecommendationsForUser(user)).willReturn(5);
 
         personalizationProfileService.generatePersonalizationProfileSync(userId);
 
+        ArgumentCaptor<PersonalizedProfileGeneratedEvent> eventCaptor = ArgumentCaptor.forClass(PersonalizedProfileGeneratedEvent.class);
         verify(personalizedProfileGenerator).generate(userId);
-        verify(userLookupService).getUserOrThrow(userId);
-        verify(recommendationService).generateRecommendationsForUser(user);
+        verify(eventPublisher).publishEvent(eventCaptor.capture());
+        assertThat(eventCaptor.getValue().userId()).isEqualTo(userId);
     }
 
     @Test
-    @DisplayName("개인화 프로필 생성이 실패하면 예외를 전파하고 추천을 시도하지 않는다")
-    void generatePersonalizationProfileSync_ProfileGenerationFailurePropagatesException() {
+    @DisplayName("개인화 프로필 생성이 실패하면 예외를 전파하고 이벤트를 발행하지 않는다")
+    void generatePersonalizationProfileSync_ProfileGenerationFailurePropagatesExceptionAndDoesNotPublishEvent() {
         Long userId = 2L;
         RuntimeException failure = new RuntimeException("profile generation failure");
         given(personalizedProfileGenerator.generate(userId)).willThrow(failure);
@@ -60,28 +53,6 @@ void generatePersonalizationProfileSync_ProfileGenerationFailurePropagatesExcept
                 .isSameAs(failure);
 
         verify(personalizedProfileGenerator).generate(userId);
-        verifyNoInteractions(userLookupService, recommendationService);
-    }
-
-    @Test
-    @DisplayName("추천 생성이 실패해도 개인화 프로필 저장은 유지된다")
-    void generatePersonalizationProfileSync_RecommendationFailureDoesNotBreakProfileSave() {
-        Long userId = 3L;
-        User user = createUser(userId);
-        given(userLookupService.getUserOrThrow(userId)).willReturn(user);
-        given(recommendationService.generateRecommendationsForUser(user))
-                .willThrow(new RuntimeException("recommendation failure"));
-
-        assertThatCode(() -> personalizationProfileService.generatePersonalizationProfileSync(userId))
-                .doesNotThrowAnyException();
-
-        verify(personalizedProfileGenerator).generate(userId);
-        verify(recommendationService).generateRecommendationsForUser(user);
-    }
-
-    private User createUser(Long userId) {
-        User user = User.createSocialUser(SocialType.KAKAO, "social-" + userId, "user" + userId + "@example.com", null);
-        ReflectionTestUtils.setField(user, "id", userId);
-        return user;
+        verifyNoInteractions(eventPublisher);
     }
 }