[Feature/#243] 디스코드 알림 연동

linkmind/build.gradle

@@ -79,6 +79,15 @@ dependencies {
 
 	implementation 'io.sentry:sentry-spring-boot-starter:5.7.0'
 
+	// openfeign
+	implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
+
+}
+
+dependencyManagement {
+	imports {
+		mavenBom("org.springframework.cloud:spring-cloud-dependencies:2023.0.3")
+	}
 }
 //sourceSets {
 //	main {

linkmind/src/main/java/com/app/toaster/ToasterApplication.java

@@ -3,13 +3,15 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cglib.core.Local;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 
 import javax.annotation.PostConstruct;
 import java.time.LocalTime;
 import java.util.TimeZone;
 
 @SpringBootApplication
+@EnableFeignClients
 @EnableJpaAuditing
 public class ToasterApplication {
 

linkmind/src/main/java/com/app/toaster/exception/Error.java

@@ -70,6 +70,7 @@ public enum Error {
 	CREATE_PUBLIC_KEY_EXCEPTION(HttpStatus.INTERNAL_SERVER_ERROR, "publickey 생성 과정 중 문제가 발생했습니다."),
 	FAIL_TO_SEND_PUSH_ALARM(HttpStatus.INTERNAL_SERVER_ERROR, "다수기기 푸시메시지 전송 실패"),
 	FAIL_TO_SEND_SQS(HttpStatus.INTERNAL_SERVER_ERROR, "sqs 전송 실패"),
+	INVALID_DISCORD_MESSAGE(HttpStatus.INTERNAL_SERVER_ERROR, "디스코드 알림 전송 실패"),
 
 	CREATE_TOAST_PROCCESS_EXCEPTION(HttpStatus.INTERNAL_SERVER_ERROR, "토스트 저장 중 문제가 발생했습니다. 카테고리 또는 s3 관련 문제로 예상됩니다.")
 	;

linkmind/src/main/java/com/app/toaster/external/client/discord/DiscordClient.java

@@ -0,0 +1,13 @@
+package com.app.toaster.external.client.discord;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(name = "${discord.name}", url = "${discord.webhook-url}")
+public interface DiscordClient {
+	@PostMapping(produces = MediaType.APPLICATION_JSON_VALUE)
+	void sendMessage(@RequestBody DiscordMessage discordMessage);
+}

linkmind/src/main/java/com/app/toaster/external/client/discord/DiscordMessage.java

@@ -0,0 +1,29 @@
+package com.app.toaster.external.client.discord;
+
+import java.util.List;
+
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Builder
+@AllArgsConstructor(access = AccessLevel.PROTECTED)
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Getter
+public class DiscordMessage {
+
+    private String content;
+    private List<Embed> embeds;
+
+    @Builder
+    @AllArgsConstructor(access = AccessLevel.PROTECTED)
+    @NoArgsConstructor(access = AccessLevel.PROTECTED)
+    @Getter
+    public static class Embed {
+
+        private String title;
+        private String description;
+    }
+}

linkmind/src/main/java/com/app/toaster/external/client/discord/DiscordMessageProvider.java

@@ -0,0 +1,54 @@
+package com.app.toaster.external.client.discord;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+import org.springframework.context.ApplicationContextException;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.WebRequest;
+
+import com.app.toaster.exception.Error;
+import com.app.toaster.exception.model.CustomException;
+import com.app.toaster.infrastructure.UserRepository;
+
+import feign.FeignException;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+@Component
+public class DiscordMessageProvider {
+    private final DiscordClient discordClient;
+    private final UserRepository userRepository;
+
+    public void sendSignUpNotification() {
+        sendMessageToDiscord(createSingUpMessage());
+    }
+
+    private void sendMessageToDiscord(DiscordMessage discordMessage) {
+        try {
+            discordClient.sendMessage(discordMessage);
+        } catch (FeignException e) {
+            throw new CustomException(Error.INVALID_DISCORD_MESSAGE, Error.INVALID_APPLE_IDENTITY_TOKEN.getMessage());
+        }
+    }
+
+    private DiscordMessage createSingUpMessage() {
+        return DiscordMessage.builder()
+            .content("# 😍 회원가입 이벤트가 발생했습니다.")
+            .embeds(
+                List.of(
+                    DiscordMessage.Embed.builder()
+                        .title("ℹ️ 회원가입 정보")
+                        .description(
+                            "### 🕖 발생 시간\n"
+                                + LocalDateTime.now()
+                                + "\n"
+                                + "### 📜 유저 가입 정보\n"
+                                + "토스터의 " + userRepository.count() + "번째 유저가 생성되었습니다!! ❤️"
+                                + "\n")
+                        .build()
+                )
+            )
+            .build();
+    }
+}

linkmind/src/main/java/com/app/toaster/service/auth/AuthService.java

@@ -1,11 +1,13 @@
 package com.app.toaster.service.auth;
 
 import java.io.IOException;
+import java.time.LocalDateTime;
 
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.client.RestTemplate;
+import org.springframework.web.context.request.WebRequest;
 
 import com.app.toaster.common.dto.ApiResponse;
 import com.app.toaster.config.jwt.JwtService;
@@ -21,6 +23,8 @@
 import com.app.toaster.exception.model.CustomException;
 import com.app.toaster.exception.model.NotFoundException;
 import com.app.toaster.exception.model.UnprocessableEntityException;
+import com.app.toaster.external.client.discord.DiscordMessage;
+import com.app.toaster.external.client.discord.DiscordMessageProvider;
 import com.app.toaster.external.client.slack.SlackApi;
 import com.app.toaster.infrastructure.CategoryRepository;
 import com.app.toaster.infrastructure.TimerRepository;
@@ -48,6 +52,7 @@ public class AuthService {
 	private final PopupManagerRepository popupManagerRepository;
 
 	private final SlackApi slackApi;
+	private final DiscordMessageProvider discordMessageProvider;
 
 
 	private final Long TOKEN_EXPIRATION_TIME_ACCESS =  7*24*60 * 60 * 1000L; //7일
@@ -76,7 +81,8 @@ public SignInResponseDto signIn(String socialAccessToken, SignInRequestDto reque
 				.socialType(socialType).build();
 			newUser.updateFcmIsAllowed(true); //신규 유저면 true박고
 			userRepository.save(newUser);
-			slackApi.sendSuccess(Success.LOGIN_SUCCESS);
+			// slackApi.sendSuccess(Success.LOGIN_SUCCESS);
+			discordMessageProvider.sendSignUpNotification();
 		}
 
 		User user = userRepository.findBySocialIdAndSocialType(socialId, socialType)
@@ -167,4 +173,5 @@ public TokenHealthDto checkHealthOfToken(String refreshToken){
 		return TokenHealthDto.of(jwtService.verifyToken(refreshToken));
 	}
 
+
 }