✨ [Feat] 가격 변동 알림 구현 (1/2)

Author: rlawngjs0313

build.gradle

@@ -42,7 +42,6 @@ dependencies {
     // MySQL
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 
-
     // Test
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
@@ -65,7 +64,7 @@ dependencies {
 
     // Firebase
     implementation 'com.google.firebase:firebase-admin:9.7.0'
-
+    
     // Spring Security
     implementation 'org.springframework.boot:spring-boot-starter-security'
 
@@ -74,6 +73,15 @@ dependencies {
 
     // Dotenv (환경변수)
     implementation 'me.paulschwarz:spring-dotenv:4.0.0'
+
+    // WebSocket
+    implementation 'org.springframework.boot:spring-boot-starter-websocket'
+    implementation 'org.webjars:stomp-websocket:2.3.3'
+    implementation 'org.webjars:webjars-locator-core'
+    implementation 'org.webjars:sockjs-client:1.0.2'
+
+    // Retry
+    implementation 'org.springframework.retry:spring-retry'
 }
 
 tasks.named('test') {

src/main/java/com/example/scoi/ScoiApplication.java

@@ -4,10 +4,12 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.retry.annotation.EnableRetry;
 
 @SpringBootApplication
 @EnableJpaAuditing
 @EnableFeignClients
+@EnableRetry
 public class ScoiApplication {
 
 	public static void main(String[] args) {

src/main/java/com/example/scoi/domain/member/entity/MemberFcm.java

@@ -31,4 +31,9 @@ public class MemberFcm {
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "member_id")
     private Member member;
+
+    // 업데이트
+    public void updateFcmToken(String fcmToken){
+        this.fcmToken = fcmToken;
+    }
 }

src/main/java/com/example/scoi/domain/websocket/WebsocketConnect.java

@@ -0,0 +1,27 @@
+package com.example.scoi.domain.websocket;
+
+import com.example.scoi.domain.websocket.handler.UpbitTickerHandler;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Service;
+import org.springframework.web.socket.client.WebSocketClient;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class WebsocketConnect {
+
+    private final WebSocketClient webSocketClient;
+    private final UpbitTickerHandler upbitTickerHandler;
+
+    private static final String PUBLIC_URL = "wss://api.upbit.com/websocket/v1";
+
+    // 실시간 가격 변동 체크
+    @EventListener(ApplicationReadyEvent.class)
+    public void connect(){
+        log.info("[ Websocket ]: 디페깅 알고리즘 구동 시작...");
+        webSocketClient.execute(upbitTickerHandler, PUBLIC_URL);
+    }
+}

src/main/java/com/example/scoi/domain/websocket/converter/WebSocketConverter.java

@@ -0,0 +1,48 @@
+package com.example.scoi.domain.websocket.converter;
+
+import com.example.scoi.domain.websocket.dto.UpbitReqDTO;
+import com.example.scoi.domain.websocket.dto.WebSocketReqDTO;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.PropertyNamingStrategies;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.socket.TextMessage;
+
+import java.util.List;
+import java.util.UUID;
+
+@RequiredArgsConstructor
+public class WebSocketConverter {
+
+    private static final ObjectMapper objectMapper = new ObjectMapper()
+            .setPropertyNamingStrategy(PropertyNamingStrategies.LOWER_CAMEL_CASE);
+
+    // 코인 가격 조회: 업비트
+    public static TextMessage toGetCoinPrice(
+            List<String> codes
+    ) throws JsonProcessingException {
+        List<Object> payload = List.of(toTicket(), toTicker(codes) ,toFormat());
+        return new TextMessage(objectMapper.writeValueAsString(payload));
+    }
+
+    private static WebSocketReqDTO.Ticket toTicket(){
+        return WebSocketReqDTO.Ticket.builder()
+                .ticket(UUID.randomUUID().toString())
+                .build();
+    }
+
+    private static WebSocketReqDTO.Format toFormat(){
+        return WebSocketReqDTO.Format.builder()
+                .format("SIMPLE_LIST")
+                .build();
+    }
+
+    private static UpbitReqDTO.Ticker toTicker(
+            List<String> codes
+    ){
+        return UpbitReqDTO.Ticker.builder()
+                .type("ticker")
+                .codes(codes)
+                .build();
+    }
+}

src/main/java/com/example/scoi/domain/websocket/dto/BithumbReqDTO.java

@@ -0,0 +1,4 @@
+package com.example.scoi.domain.websocket.dto;
+
+public class BithumbReqDTO {
+}

src/main/java/com/example/scoi/domain/websocket/dto/UpbitReqDTO.java

@@ -0,0 +1,15 @@
+package com.example.scoi.domain.websocket.dto;
+
+import lombok.Builder;
+
+import java.util.List;
+
+public class UpbitReqDTO {
+
+    // 가격 실시간 조회
+    @Builder
+    public record Ticker(
+            String type,
+            List<String> codes
+    ){}
+}

src/main/java/com/example/scoi/domain/websocket/dto/UpbitResDTO.java

@@ -0,0 +1,45 @@
+package com.example.scoi.domain.websocket.dto;
+
+import java.util.Date;
+
+public class UpbitResDTO {
+
+    // 현제 코인 가격
+    public record Ticker(
+            String ty,
+            String cd,
+            Double op,
+            Double hp,
+            Double lp,
+            Double tp,
+            Double pcp,
+            String c,
+            Double cp,
+            Double scp,
+            Double cr,
+            Double scr,
+            Double tv,
+            Double atv,
+            Double atv24h,
+            Double atp,
+            Double atp24h,
+            String tdt,
+            String ttm,
+            Long ttms,
+            String ab,
+            Double aav,
+            Double abv,
+            Double h52wp,
+            String h52wdt,
+            Double l52wp,
+            String l52wdt,
+            String ms,
+            Date dd,
+            Long tms,
+            String st,
+
+            // Deprecated
+            Boolean its,
+            String mw
+    ){}
+}

src/main/java/com/example/scoi/domain/websocket/dto/WebSocketReqDTO.java

@@ -0,0 +1,16 @@
+package com.example.scoi.domain.websocket.dto;
+
+import lombok.Builder;
+
+public class WebSocketReqDTO {
+
+    @Builder
+    public record Ticket(
+            String ticket
+    ){}
+
+    @Builder
+    public record Format(
+            String format
+    ){}
+}

src/main/java/com/example/scoi/domain/websocket/enums/RiseOrFall.java

@@ -0,0 +1,12 @@
+package com.example.scoi.domain.websocket.enums;
+
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public enum RiseOrFall {
+    RISE("올랐어요."),
+    FALL("떨어졌어요.")
+    ;
+
+    private final String message;
+}