MOSU-171 refactor: profile, 문의 답변 알림톡 기능 구현 및 cookie util 표준화

src/main/java/life/mosu/mosuserver/application/auth/provider/AuthTokenManager.java

@@ -2,8 +2,7 @@
 
 import life.mosu.mosuserver.application.auth.PrincipalDetails;
 import life.mosu.mosuserver.domain.user.UserJpaEntity;
-import life.mosu.mosuserver.global.exception.CustomRuntimeException;
-import life.mosu.mosuserver.global.exception.ErrorCode;
+import life.mosu.mosuserver.global.cookie.TokenCookies;
 import life.mosu.mosuserver.presentation.auth.dto.Token;
 import lombok.RequiredArgsConstructor;
 import org.springframework.security.core.Authentication;
@@ -24,16 +23,12 @@ public Token generateAuthToken(final UserJpaEntity user) {
                 accessTokenProvider.expireTime, refreshTokenProvider.expireTime);
     }
 
-    public Token reissueAccessToken(final String refreshTokenString) {
-        if (refreshTokenString == null) {
-            throw new CustomRuntimeException(ErrorCode.NOT_FOUND_REFRESH_TOKEN);
-        }
+    public Token reissueToken(final TokenCookies tokenCookies) {
 
         final Authentication authentication = refreshTokenProvider.getAuthentication(
-                refreshTokenString);
+                tokenCookies.refreshToken());
         final PrincipalDetails principalDetails = (PrincipalDetails) authentication.getPrincipal();
         final UserJpaEntity user = principalDetails.user();
-
         refreshTokenProvider.invalidateToken(user.getId());
 
         return generateAuthToken(user);

src/main/java/life/mosu/mosuserver/application/auth/provider/RefreshTokenProvider.java

@@ -12,15 +12,15 @@
 @Service
 public class RefreshTokenProvider extends JwtTokenProvider {
 
-    private final RefreshTokenRepository refreshTokenRepository;
     private static final String TOKEN_TYPE = "Refresh";
     private static final String HEADER = "Refresh-Token";
+    private final RefreshTokenRepository refreshTokenRepository;
 
     public RefreshTokenProvider(
-        @Value("${jwt.refresh-token.expire-time}") final Long expireTime,
-        @Value("${jwt.secret}") final String secretKey,
-        final UserJpaRepository userJpaRepository,
-        final RefreshTokenRepository refreshTokenRepository
+            @Value("${jwt.refresh-token.expire-time}") final Long expireTime,
+            @Value("${jwt.secret}") final String secretKey,
+            final UserJpaRepository userJpaRepository,
+            final RefreshTokenRepository refreshTokenRepository
     ) {
         super(expireTime, secretKey, TOKEN_TYPE, HEADER, userJpaRepository);
         this.refreshTokenRepository = refreshTokenRepository;
@@ -36,18 +36,18 @@ protected Claims validateAndParseToken(final String token) {
 
     public void invalidateToken(final Long id) {
         if (!refreshTokenRepository.existsByUserId(id)) {
-            throw new CustomRuntimeException(ErrorCode.NOT_EXIST_REFRESH_TOKEN);
+            throw new CustomRuntimeException(ErrorCode.NOT_FOUND_REFRESH_TOKEN);
         }
         refreshTokenRepository.deleteByUserId(id);
     }
 
     public void cacheToken(final Long userId, final String refreshToken) {
         refreshTokenRepository.save(
-            RefreshToken.of(
-                userId,
-                refreshToken,
-                expireTime
-            )
+                RefreshToken.of(
+                        userId,
+                        refreshToken,
+                        expireTime
+                )
         );
     }
 }

src/main/java/life/mosu/mosuserver/application/inquiry/InquiryAnswerService.java

@@ -6,9 +6,6 @@
 import life.mosu.mosuserver.domain.inquiryAnswer.InquiryAnswerJpaRepository;
 import life.mosu.mosuserver.global.exception.CustomRuntimeException;
 import life.mosu.mosuserver.global.exception.ErrorCode;
-import life.mosu.mosuserver.infra.notify.NotifyEventPublisher;
-import life.mosu.mosuserver.infra.notify.dto.NotificationEvent;
-import life.mosu.mosuserver.infra.notify.dto.NotificationStatus;
 import life.mosu.mosuserver.presentation.inquiry.dto.InquiryAnswerRequest;
 import life.mosu.mosuserver.presentation.inquiry.dto.InquiryAnswerUpdateRequest;
 import life.mosu.mosuserver.presentation.inquiry.dto.InquiryDetailResponse;
@@ -27,21 +24,29 @@ public class InquiryAnswerService {
     private final InquiryAnswerAttachmentService answerAttachmentService;
     private final InquiryAnswerJpaRepository inquiryAnswerJpaRepository;
     private final InquiryJpaRepository inquiryJpaRepository;
-    private final NotifyEventPublisher notifier;
+
+    private final InquiryAnswerTxService eventTxService;
 
     @Transactional
     public void createInquiryAnswer(Long postId, InquiryAnswerRequest request) {
         isAnswerAlreadyRegister(postId);
         InquiryJpaEntity inquiryEntity = getInquiry(postId);
         Long userId = inquiryEntity.getUserId();
 
-        InquiryAnswerJpaEntity answerEntity = inquiryAnswerJpaRepository.save(
-                request.toEntity(postId));
+        try {
+            InquiryAnswerJpaEntity answerEntity = inquiryAnswerJpaRepository.save(
+                    request.toEntity(postId));
 
-        answerAttachmentService.createAttachment(request.attachments(), answerEntity);
-        inquiryEntity.updateStatusToComplete();
+            answerAttachmentService.createAttachment(request.attachments(), answerEntity);
+            inquiryEntity.updateStatusToComplete();
+
+            eventTxService.publishSuccessEvent(userId, postId);
+
+        } catch (Exception ex) {
+            log.error("문의 답변 등록 실패: {}", ex.getMessage(), ex);
+            throw ex;
+        }
 
-        sendNotification(userId, postId);
 
     }
 
@@ -92,11 +97,5 @@ private void isAnswerAlreadyRegister(Long postId) {
         }
     }
 
-    private void sendNotification(Long userId, Long postId) {
-        NotificationEvent event = NotificationEvent.create(
-                NotificationStatus.INQUIRY_ANSWER_SUCCESS, userId, postId);
-        notifier.notify(event);
-    }
-
 
 }

src/main/java/life/mosu/mosuserver/application/inquiry/InquiryAnswerTxService.java

@@ -0,0 +1,26 @@
+package life.mosu.mosuserver.application.inquiry;
+
+import life.mosu.mosuserver.application.inquiry.tx.InquiryAnswerContext;
+import life.mosu.mosuserver.application.inquiry.tx.InquiryAnswerTxEventFactory;
+import life.mosu.mosuserver.global.tx.TxEvent;
+import life.mosu.mosuserver.global.tx.TxEventPublisher;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class InquiryAnswerTxService {
+
+    private final TxEventPublisher txEventPublisher;
+    private final InquiryAnswerTxEventFactory eventFactory;
+
+    @Transactional
+    public void publishSuccessEvent(Long userId, Long inquiryId) {
+        TxEvent<?> event = eventFactory.create(InquiryAnswerContext.ofSuccess(userId, inquiryId));
+        txEventPublisher.publish(event);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/inquiry/tx/InquiryAnswerContext.java

@@ -0,0 +1,13 @@
+package life.mosu.mosuserver.application.inquiry.tx;
+
+public record InquiryAnswerContext(
+        Long userId,
+        Long inquiryId,
+        Boolean isSuccess
+) {
+
+    public static final InquiryAnswerContext ofSuccess(Long userId, Long inquiryId) {
+        return new InquiryAnswerContext(userId, inquiryId, true);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/inquiry/tx/InquiryAnswerTxEvent.java

@@ -0,0 +1,11 @@
+package life.mosu.mosuserver.application.inquiry.tx;
+
+import life.mosu.mosuserver.global.tx.TxEvent;
+
+public class InquiryAnswerTxEvent extends TxEvent<InquiryAnswerContext> {
+
+    public InquiryAnswerTxEvent(boolean isSuccess, InquiryAnswerContext context) {
+        super(isSuccess, context);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/inquiry/tx/InquiryAnswerTxEventFactory.java

@@ -0,0 +1,15 @@
+package life.mosu.mosuserver.application.inquiry.tx;
+
+import life.mosu.mosuserver.global.tx.TxEvent;
+import life.mosu.mosuserver.global.tx.TxEventFactory;
+import org.springframework.stereotype.Component;
+
+@Component
+public class InquiryAnswerTxEventFactory implements TxEventFactory<InquiryAnswerContext> {
+
+    @Override
+    public TxEvent<?> create(InquiryAnswerContext context) {
+        return new InquiryAnswerTxEvent(context.isSuccess(), context);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/inquiry/tx/InquiryAnswerTxEventListener.java

@@ -0,0 +1,37 @@
+package life.mosu.mosuserver.application.inquiry.tx;
+
+import life.mosu.mosuserver.infra.notify.NotifyEventPublisher;
+import life.mosu.mosuserver.infra.notify.dto.NotificationEvent;
+import life.mosu.mosuserver.infra.notify.dto.NotificationStatus;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+@Transactional(propagation = Propagation.NOT_SUPPORTED)
+public class InquiryAnswerTxEventListener {
+
+    private final NotifyEventPublisher notifier;
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void afterCommitHandler(InquiryAnswerTxEvent event) {
+        InquiryAnswerContext ctx = event.getContext();
+        log.debug("[AFTER_COMMIT] 문의 답변 등록 후 알림톡 발송 시작: userId={}, inquiryId={}", ctx.userId(),
+                ctx.inquiryId());
+
+        sendNotification(ctx.userId(), ctx.inquiryId());
+    }
+
+    private void sendNotification(Long userId, Long inquiryId) {
+        NotificationEvent notificationEvent = NotificationEvent.create(
+                NotificationStatus.INQUIRY_ANSWER_SUCCESS, userId, inquiryId);
+        notifier.notify(notificationEvent);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/profile/ProfileEventTxService.java

@@ -0,0 +1,26 @@
+package life.mosu.mosuserver.application.profile;
+
+import life.mosu.mosuserver.application.profile.tx.ProfileContext;
+import life.mosu.mosuserver.application.profile.tx.ProfileTxEventFactory;
+import life.mosu.mosuserver.global.tx.TxEvent;
+import life.mosu.mosuserver.global.tx.TxEventPublisher;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class ProfileEventTxService {
+
+    private final TxEventPublisher txEventPublisher;
+    private final ProfileTxEventFactory eventFactory;
+
+    @Transactional
+    public void publishSuccessEvent(Long userId) {
+        TxEvent<?> event = eventFactory.create(ProfileContext.ofSuccess(userId));
+        txEventPublisher.publish(event);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/profile/ProfileService.java

@@ -7,24 +7,24 @@
 import life.mosu.mosuserver.domain.user.UserRole;
 import life.mosu.mosuserver.global.exception.CustomRuntimeException;
 import life.mosu.mosuserver.global.exception.ErrorCode;
-import life.mosu.mosuserver.infra.notify.NotifyEventPublisher;
-import life.mosu.mosuserver.infra.notify.dto.NotificationEvent;
-import life.mosu.mosuserver.infra.notify.dto.NotificationStatus;
 import life.mosu.mosuserver.presentation.profile.dto.EditProfileRequest;
 import life.mosu.mosuserver.presentation.profile.dto.ProfileDetailResponse;
 import life.mosu.mosuserver.presentation.profile.dto.SignUpProfileRequest;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class ProfileService {
 
     private final UserJpaRepository userRepository;
     private final ProfileJpaRepository profileJpaRepository;
-    private final NotifyEventPublisher notifier;
+
+    private final ProfileEventTxService eventTxService;
 
     @Transactional
     public void registerProfile(Long userId, SignUpProfileRequest request) {
@@ -33,13 +33,20 @@ public void registerProfile(Long userId, SignUpProfileRequest request) {
         );
         checkIfProfileExistsForUser(user);
 
-        ProfileJpaEntity profile = request.toEntity(userId);
-        profileJpaRepository.save(profile);
+        try {
+            ProfileJpaEntity profile = request.toEntity(userId);
+            profileJpaRepository.save(profile);
+
+            user.grantUserRole();
+            syncUserInfoFromProfile(user, request);
+
+            eventTxService.publishSuccessEvent(userId);
 
-        user.grantUserRole();
-        syncUserInfoFromProfile(user, request);
+        } catch (Exception ex) {
+            log.error("프로필 등록 실패: {}", ex.getMessage(), ex);
+            throw ex;
+        }
 
-        sendNotification();
     }
 
     @Transactional
@@ -71,10 +78,5 @@ private void syncUserInfoFromProfile(UserJpaEntity user, SignUpProfileRequest re
                     request.phoneNumber(), request.birth());
         }
     }
-
-    private void sendNotification() {
-        NotificationEvent event = NotificationEvent.create(NotificationStatus.SIGN_UP_SUCCESS);
-        notifier.notify(event);
-    }
 }
 

src/main/java/life/mosu/mosuserver/application/profile/tx/ProfileContext.java

@@ -0,0 +1,12 @@
+package life.mosu.mosuserver.application.profile.tx;
+
+public record ProfileContext(
+        Long userId,
+        Boolean isSuccess
+) {
+
+    public static ProfileContext ofSuccess(Long userId) {
+        return new ProfileContext(userId, true);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/profile/tx/ProfileTxEvent.java

@@ -0,0 +1,11 @@
+package life.mosu.mosuserver.application.profile.tx;
+
+import life.mosu.mosuserver.global.tx.TxEvent;
+
+public class ProfileTxEvent extends TxEvent<ProfileContext> {
+
+    public ProfileTxEvent(boolean isSuccess, ProfileContext context) {
+        super(isSuccess, context);
+    }
+
+}

src/main/java/life/mosu/mosuserver/application/profile/tx/ProfileTxEventFactory.java

@@ -0,0 +1,15 @@
+package life.mosu.mosuserver.application.profile.tx;
+
+import life.mosu.mosuserver.global.tx.TxEvent;
+import life.mosu.mosuserver.global.tx.TxEventFactory;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ProfileTxEventFactory implements TxEventFactory<ProfileContext> {
+
+    @Override
+    public TxEvent<?> create(ProfileContext context) {
+        return new ProfileTxEvent(context.isSuccess(), context);
+    }
+
+}