feat: 코인 정보 upbit api로 받아오기

Co-authored-by: 이승관 <[email protected]>

dockerfile-client

@@ -7,5 +7,8 @@ RUN yarn build
 
 FROM nginx:alpine
 COPY --from=build /app/dist /usr/share/nginx/html
+
+COPY nginx.conf /etc/nginx/conf.d/default.conf
+
 EXPOSE 80
 CMD ["nginx", "-g", "daemon off;"]

nginx.conf

@@ -0,0 +1,27 @@
+#nginx.conf
+server {
+    listen 80;
+    server_name localhost;
+
+    # 정적 파일 서빙 설정
+    location / {
+        root /usr/share/nginx/html;
+        try_files $uri /index.html;  # SPA(싱글 페이지 애플리케이션) 라우팅
+    }
+
+    # SSE 요청을 처리하는 프록시 설정 예시
+    location /sse {
+        proxy_pass http://backend_server:3000; # SSE 요청을 백엔드 서버로 프록시
+        proxy_set_header Host $host;
+        proxy_set_header X-Real-IP $remote_addr;
+        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+        proxy_set_header X-Forwarded-Proto $scheme;
+
+        # SSE 스트리밍을 위해 버퍼링 비활성화
+        proxy_buffering off;
+
+        # SSE 연결을 오랫동안 유지할 수 있도록 타임아웃 설정
+        proxy_read_timeout 3600s;
+        proxy_send_timeout 3600s;
+    }
+}

package.json

@@ -15,6 +15,9 @@
     "typescript": "5.4.3"
   },
   "dependencies": {
-    "@floating-ui/dom": "^1.6.12"
+    "@floating-ui/dom": "^1.6.12",
+    "@nestjs/platform-socket.io": "^10.4.7",
+    "@nestjs/websockets": "^10.4.7",
+    "ws": "^8.18.0"
   }
 }

packages/server/package.json

@@ -20,10 +20,13 @@
     "test:e2e": "jest --config ./test/jest-e2e.json"
   },
   "dependencies": {
+    "@nestjs/axios": "^3.1.2",
     "@nestjs/common": "^10.0.0",
     "@nestjs/core": "^10.0.0",
     "@nestjs/platform-express": "^10.0.0",
+    "@nestjs/platform-socket.io": "^10.4.7",
     "@nestjs/typeorm": "9.0.0",
+    "@nestjs/websockets": "^10.4.7",
     "axios": "^1.7.7",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.1",
@@ -48,6 +51,7 @@
     "@types/jest": "^29.5.2",
     "@types/js-yaml": "^4",
     "@types/node": "^20.3.1",
+    "@types/socket.io": "^3.0.2",
     "@types/supertest": "^6.0.0",
     "@types/ws": "^8.5.13",
     "@typescript-eslint/eslint-plugin": "^8.0.0",

packages/server/src/upbit/coin-list.service.ts

@@ -0,0 +1,15 @@
+import { Injectable } from '@nestjs/common';
+import { HttpService } from '@nestjs/axios';
+import { firstValueFrom } from 'rxjs';
+
+@Injectable()
+export class CoinListService {
+  constructor(private readonly httpService: HttpService) {}
+
+  async getCoinList() {
+    const response = await firstValueFrom(
+      this.httpService.get('https://api.upbit.com/v1/market/all?is_details=true')
+    );
+    return response.data;
+  }
+}

packages/server/src/upbit/types/market.ts

@@ -0,0 +1,17 @@
+export type Market = 'KRW' | 'BTC' | 'USDT';
+
+type MarketEvent = {
+	CONCENTRATION_OF_SMALL_ACCOUNTS: boolean;
+	DEPOSIT_AMOUNT_SOARING: boolean;
+	GLOBAL_PRICE_DIFFERENCES: boolean;
+	PRICE_FLUCTUATIONS: boolean;
+	TRADING_VOLUME_SOARING: boolean;
+};
+
+export type MarketData = {
+	market: string;
+	korean_name: string;
+	english_name: string;
+	market_warning?: string;
+	market_event: { warning: boolean; caution: MarketEvent };
+};

packages/server/src/upbit/types/ticker.ts

@@ -0,0 +1,40 @@
+ type CoinTicker = {
+	type: string;
+	code: string;
+	opening_price: number;
+	high_price: number;
+	low_price: number;
+	trade_price: number;
+	prev_closing_price: number;
+	acc_trade_price: number;
+	change: 'RISE' | 'FALL' | 'EVEN';
+	change_price: number;
+	signed_change_price: number;
+	change_rate: number;
+	signed_change_rate: number;
+	ask_bid: 'ASK' | 'BID';
+	trade_volume: number;
+	acc_trade_volume: number;
+	trade_date: string;
+	trade_time: string;
+	trade_timestamp: number;
+	acc_ask_volume: number;
+	acc_bid_volume: number;
+	highest_52_week_price: number;
+	highest_52_week_date: string;
+	lowest_52_week_price: number;
+	lowest_52_week_date: string;
+	market_state: 'ACTIVE' | 'SUSPENDED' | 'DELISTED';
+	is_trading_suspended: boolean;
+	delisting_date: string | null;
+	market_warning: 'NONE' | 'CAUTION';
+	timestamp: number;
+	acc_trade_price_24h: number;
+	acc_trade_volume_24h: number;
+	stream_type: 'REALTIME' | 'SNAPSHOT';
+};
+
+export type SocketDataType = {
+	[key: string]: CoinTicker;  // 또는
+	// [market: string]: CoinTicker;
+ }

packages/server/src/upbit/upbit.controller.ts

@@ -1,15 +1,20 @@
 import { Controller, Sse } from '@nestjs/common';
 import { UpbitService } from './upbit.service';
-import { Observable } from 'rxjs';
-import { map } from 'rxjs/operators';
+import { Observable, Subject } from 'rxjs';
+import { map, takeUntil } from 'rxjs/operators';
 
 @Controller('upbit')
 export class UpbitController {
+
+  private destroy$ = new Subject<void>();
+
   constructor(private readonly upbitService: UpbitService) {}
 
   @Sse('price-updates')
   priceUpdates(): Observable<MessageEvent> {
-    return this.upbitService.getPriceUpdatesStream().pipe(
+    return this.upbitService.getPriceUpdatesStream()
+    .pipe(
+      takeUntil(this.destroy$),
       map((data) => {
         // MessageEvent 타입에 맞게 필요한 속성 추가
         return new MessageEvent('price-update', {

packages/server/src/upbit/upbit.module.ts

@@ -1,9 +1,12 @@
 import { Module } from '@nestjs/common';
 import { UpbitService } from './upbit.service';
 import { UpbitController } from './upbit.controller';
+import { CoinListService } from './coin-list.service'
+import { HttpModule } from '@nestjs/axios';
 
 @Module({
-  providers: [UpbitService],
+  imports: [HttpModule],
+  providers: [UpbitService, CoinListService],
   controllers: [UpbitController]
 })
 export class UpbitModule {}

packages/server/src/upbit/upbit.service.ts

@@ -1,31 +1,35 @@
 import { Injectable, OnModuleInit } from '@nestjs/common';
 import { Subject } from 'rxjs';
 import * as WebSocket from 'ws';
+import { CoinListService } from './coin-list.service';
 
 @Injectable()
 export class UpbitService implements OnModuleInit {
 	private ws: WebSocket;
-  private priceUpdates$: Subject<any> = new Subject(); // SSE로 전달할 스트림 생성
+	private priceUpdates$: Subject<any> = new Subject(); // SSE로 전달할 스트림 생성
+
+	constructor(private readonly coinListService: CoinListService) {};
 
 	onModuleInit() {
 		this.connectWebSocket();
 	}
 
-	private connectWebSocket() {
+	private async connectWebSocket() {
+		const coin_list = await this.coinListService.getCoinList()
 		this.ws = new WebSocket('wss://api.upbit.com/websocket/v1');
 
 		this.ws.on('open', () => {
 			console.log('WebSocket 연결 성공');
 			// 구독할 마켓 설정
 			const subscribeMessage = JSON.stringify([
 				{ ticket: 'test' },
-				{ type: 'ticker', codes: ['KRW-BTC', 'KRW-ETH'] }, // 원하는 코인 추가
+				{ type: 'ticker', codes: coin_list.map(coin=>coin.market) }, // 원하는 코인 추가
 			]);
 			this.ws.send(subscribeMessage);
 		});
 
 		this.ws.on('message', (data) => {
-      //TODO: upbitTicker 타입으로 변경
+      //TODO: upbitTickerDto 타입으로 변경
 			const message = JSON.parse(data.toString());
       this.priceUpdates$.next(message); // SSE로 전달하기 위해 데이터 방출
 		});