feat: 이벤트 알림 로직 구현

build.gradle

@@ -46,6 +46,7 @@ dependencies {
     // notification
     implementation 'com.github.maricn:logback-slack-appender:1.4.0'
     implementation 'net.logstash.logback:logstash-logback-encoder:8.0'
+    implementation 'com.slack.api:slack-api-client:1.44.2'
 
     // querydsl
     implementation 'com.querydsl:querydsl-jpa:5.0.0:jakarta'

src/main/java/gg/agit/konect/domain/user/event/UserRegisterEvent.java

@@ -0,0 +1,9 @@
+package gg.agit.konect.domain.user.event;
+
+public record UserRegisterEvent(
+    String email
+) {
+    public static UserRegisterEvent from(String email) {
+        return new UserRegisterEvent(email);
+    }
+}

src/main/java/gg/agit/konect/domain/user/event/UserWithdrawEvent.java

@@ -0,0 +1,9 @@
+package gg.agit.konect.domain.user.event;
+
+public record UserWithdrawEvent(
+    String email
+) {
+    public static UserWithdrawEvent from(String email) {
+        return new UserWithdrawEvent(email);
+    }
+}

src/main/java/gg/agit/konect/domain/user/service/UserService.java

@@ -4,6 +4,7 @@
 
 import java.util.List;
 
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
@@ -21,6 +22,8 @@
 import gg.agit.konect.domain.user.dto.UserInfoResponse;
 import gg.agit.konect.domain.user.dto.UserUpdateRequest;
 import gg.agit.konect.domain.user.enums.Provider;
+import gg.agit.konect.domain.user.event.UserRegisterEvent;
+import gg.agit.konect.domain.user.event.UserWithdrawEvent;
 import gg.agit.konect.domain.user.model.UnRegisteredUser;
 import gg.agit.konect.domain.user.model.User;
 import gg.agit.konect.domain.user.repository.UnRegisteredUserRepository;
@@ -43,6 +46,7 @@ public class UserService {
     private final ChatMessageRepository chatMessageRepository;
     private final ChatRoomRepository chatRoomRepository;
     private final StudyTimeQueryService studyTimeQueryService;
+    private final ApplicationEventPublisher applicationEventPublisher;
 
     @Transactional
     public Integer signup(String email, Provider provider, SignupRequest request) {
@@ -74,6 +78,7 @@ public Integer signup(String email, Provider provider, SignupRequest request) {
 
         unRegisteredUserRepository.delete(tempUser);
 
+        applicationEventPublisher.publishEvent(UserRegisterEvent.from(savedUser.getEmail()));
         return savedUser.getId();
     }
 
@@ -149,5 +154,7 @@ public void deleteUser(Integer userId) {
         clubApplyRepository.deleteByUserId(userId);
         clubMemberRepository.deleteByUserId(userId);
         userRepository.delete(user);
+
+        applicationEventPublisher.publishEvent(UserWithdrawEvent.from(user.getEmail()));
     }
 }

src/main/java/gg/agit/konect/infrastructure/slack/client/SlackClient.java

@@ -0,0 +1,41 @@
+package gg.agit.konect.infrastructure.slack.client;
+
+import static org.springframework.http.MediaType.APPLICATION_JSON;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class SlackClient {
+
+    private final RestTemplate restTemplate;
+
+    public void sendMessage(String message, String url) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(APPLICATION_JSON);
+
+            Map<String, Object> payload = new HashMap<>();
+            payload.put("text", message);
+
+            HttpEntity<Map<String, Object>> request = new HttpEntity<>(payload, headers);
+            restTemplate.postForEntity(
+                url,
+                request,
+                String.class
+            );
+        } catch (Exception e) {
+            log.error("Slack 메시지 전송 중 오류 발생", e);
+        }
+    }
+}

src/main/java/gg/agit/konect/infrastructure/slack/config/SlackProperties.java

@@ -0,0 +1,15 @@
+package gg.agit.konect.infrastructure.slack.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@ConfigurationProperties(prefix = "slack")
+public record SlackProperties(
+    Webhooks webhooks
+) {
+    public record Webhooks(
+        String error,
+        String event
+    ) {
+
+    }
+}

src/main/java/gg/agit/konect/infrastructure/slack/enums/SlackMessageTemplate.java

@@ -0,0 +1,27 @@
+package gg.agit.konect.infrastructure.slack.enums;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public enum SlackMessageTemplate {
+
+    USER_REGISTER(
+        """
+        `%s님이 가입하셨습니다.`
+        """
+    ),
+    USER_WITHDRAWAL(
+        """
+        `%s님이 탈퇴하셨습니다.`
+        """
+    ),
+    ;
+
+    private final String template;
+
+    public String format(Object... args) {
+        return String.format(template, args);
+    }
+}

src/main/java/gg/agit/konect/infrastructure/slack/listener/UserSlackListener.java

@@ -0,0 +1,31 @@
+package gg.agit.konect.infrastructure.slack.listener;
+
+import static org.springframework.transaction.event.TransactionPhase.AFTER_COMMIT;
+
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+import gg.agit.konect.domain.user.event.UserRegisterEvent;
+import gg.agit.konect.domain.user.event.UserWithdrawEvent;
+import gg.agit.konect.infrastructure.slack.service.SlackNotificationService;
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+public class UserSlackListener {
+
+    private final SlackNotificationService slackNotificationService;
+
+    @Async
+    @TransactionalEventListener(phase = AFTER_COMMIT)
+    public void handleUserWithdraw(UserWithdrawEvent event) {
+        slackNotificationService.notifyUserWithdraw(event.email());
+    }
+
+    @Async
+    @TransactionalEventListener(phase = AFTER_COMMIT)
+    public void handleUserRegister(UserRegisterEvent event) {
+        slackNotificationService.notifyUserRegister(event.email());
+    }
+}

src/main/java/gg/agit/konect/infrastructure/slack/service/SlackNotificationService.java

@@ -0,0 +1,28 @@
+package gg.agit.konect.infrastructure.slack.service;
+
+import static gg.agit.konect.infrastructure.slack.enums.SlackMessageTemplate.USER_REGISTER;
+import static gg.agit.konect.infrastructure.slack.enums.SlackMessageTemplate.USER_WITHDRAWAL;
+
+import org.springframework.stereotype.Service;
+
+import gg.agit.konect.infrastructure.slack.client.SlackClient;
+import gg.agit.konect.infrastructure.slack.config.SlackProperties;
+import lombok.RequiredArgsConstructor;
+
+@Service
+@RequiredArgsConstructor
+public class SlackNotificationService {
+
+    private final SlackProperties slackProperties;
+    private final SlackClient slackClient;
+
+    public void notifyUserWithdraw(String email) {
+        String message = USER_WITHDRAWAL.format(email);
+        slackClient.sendMessage(message, slackProperties.webhooks().event());
+    }
+
+    public void notifyUserRegister(String email) {
+        String message = USER_REGISTER.format(email);
+        slackClient.sendMessage(message, slackProperties.webhooks().event());
+    }
+}