feat: 관리자 로그인 및 서포터 토큰 발급 이벤트를 발행하도록 알림 시스템을 이벤트 기반으로 리팩토링 (#405)

Author: fivedragon5

src/main/java/org/ject/support/domain/admin/service/AdminAuthService.java

@@ -9,8 +9,9 @@
 import org.ject.support.domain.admin.exception.AdminException;
 import org.ject.support.domain.member.MemberStatus;
 import org.ject.support.domain.member.entity.Member;
-import org.ject.support.external.discord.DiscordComponent;
 import org.ject.support.external.infrastructure.DiscordRateLimiter;
+import org.ject.support.external.notification.event.AdminLoginNotificationEvent;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.security.core.Authentication;
 import org.springframework.stereotype.Service;
@@ -24,10 +25,10 @@
 @Transactional(readOnly = true)
 public class AdminAuthService {
 
+    private final ApplicationEventPublisher applicationEventPublisher;
     private final RedisTemplate<String, String> redisTemplate;
     private final AdminMemberComponent adminMemberComponent;
     private final DiscordRateLimiter discordRateLimiter;
-    private final DiscordComponent discordComponent;
     private final JwtTokenProvider jwtTokenProvider;
 
     private static final String ADMIN_LOGIN_AUTH_CODE_KEY_PREFIX = "admin-login:";
@@ -46,9 +47,9 @@ public String sendAdminAuthCode(String email) {
 
         if (discordRateLimiter.tryConsume(1)) {
             redisTemplate.opsForValue().set(key, authCode, Duration.ofSeconds(ADMIN_LOGIN_AUTH_CODE_EXPIRATION));
-            discordComponent.sendAdminLoginMessage(member.getEmail(), authCode)
-                    .doOnError(e -> log.error("Discord 전송 실패: {}", member.getEmail(), e))
-                    .subscribe();
+
+            applicationEventPublisher
+                    .publishEvent(new AdminLoginNotificationEvent(email, authCode));
         } else {
             throw new AdminException(AdminErrorCode.TOO_MANY_REQUESTS);
         }

src/main/java/org/ject/support/domain/auth/service/AuthSupporterTokenService.java

@@ -11,7 +11,8 @@
 import org.ject.support.domain.member.Role;
 import org.ject.support.domain.member.entity.Member;
 import org.ject.support.domain.member.repository.MemberRepository;
-import org.ject.support.external.discord.DiscordComponent;
+import org.ject.support.external.notification.event.SupporterTokenIssuedEvent;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -28,10 +29,10 @@ public class AuthSupporterTokenService {
 
     private final long TOKEN_EXPIRATION_MILLIS = 24 * 60 * 60 * 1000; // 1일
 
+    private final ApplicationEventPublisher applicationEventPublisher;
     private final JwtTokenProvider jwtTokenProvider;
     private final MemberRepository memberRepository;
     private final PasswordEncoder passwordEncoder;
-    private final DiscordComponent discordComponent;
 
     public void issueReadOnlyToken(String email, String pin) {
         Member member = memberRepository.findByEmailAndRole(email, Role.ADMIN)
@@ -50,10 +51,7 @@ public void issueReadOnlyToken(String email, String pin) {
 
         String token = jwtTokenProvider.createToken(claims, TOKEN_EXPIRATION_MILLIS);
 
-        discordComponent.sendSupporterTokenIssueMessage(email, token)
-                .doOnError(e -> {
-                    log.error("지원자 토큰 전송 실패: {}", email, e);
-                })
-                .subscribe();
+        applicationEventPublisher
+                .publishEvent(new SupporterTokenIssuedEvent(email, token));
     }
 }

src/main/java/org/ject/support/external/discord/DiscordComponent.java

@@ -0,0 +1,49 @@
+package org.ject.support.external.notification.client;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.ject.support.external.notification.payload.DiscordWebhookPayload;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Mono;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class DiscordClient {
+
+    private final WebClient webClient;
+
+    public Mono<Void> send(
+            String webhookUrl,
+            DiscordWebhookPayload payload
+    ) {
+        if (!StringUtils.hasText(webhookUrl)) {
+            log.warn("Discord webhook URL이 비어있어 메시지를 전송하지 않습니다.");
+            return Mono.empty();
+        }
+
+        return webClient.post()
+                .uri(webhookUrl)
+                .bodyValue(payload)
+                .retrieve()
+                .toBodilessEntity()
+                .doOnSuccess(this::logSuccess)
+                .doOnError(this::logError)
+                .then();
+    }
+
+    private void logSuccess(ResponseEntity<Void> response) {
+        log.info("Discord message sent successfully (status={})", response.getStatusCode());
+    }
+
+    private void logError(Throwable e) {
+        log.error(
+                "Discord message send failed: {} - {}",
+                e.getClass().getSimpleName(),
+                e.getMessage()
+        );
+    }
+}

src/main/java/org/ject/support/external/discord/DiscordWebhookPayload.java

@@ -0,0 +1,6 @@
+package org.ject.support.external.notification.event;
+
+public record AdminLoginNotificationEvent(
+        String email,
+        String code
+) {}

src/main/java/org/ject/support/external/notification/DiscordNotificationMessageFactory.java

@@ -0,0 +1,6 @@
+package org.ject.support.external.notification.event;
+
+public record SupporterTokenIssuedEvent(
+        String email,
+        String accessToken
+) {}

src/main/java/org/ject/support/external/notification/NotificationMessageFactory.java

@@ -0,0 +1,20 @@
+package org.ject.support.external.notification.executor;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+import java.time.Duration;
+
+@Component
+@Slf4j
+public class NotificationExecutorService {
+
+    public void execute(Mono<Void> mono) {
+        mono
+            .retry(3)
+            .timeout(Duration.ofSeconds(3))
+            .doOnError(e -> log.error("Notification failed", e))
+            .subscribe();
+    }
+}