fix: api 요청 빈배열 반환 및 에러처리

packages/server/common/all-exceptions.filter.ts

@@ -0,0 +1,38 @@
+import {
+  ExceptionFilter,
+  Catch,
+  ArgumentsHost,
+  HttpException,
+  HttpStatus,
+} from '@nestjs/common';
+
+@Catch()
+export class AllExceptionsFilter implements ExceptionFilter {
+  catch(exception: unknown, host: ArgumentsHost) {
+    const ctx = host.switchToHttp();
+    const response = ctx.getResponse();
+    const request = ctx.getRequest();
+
+    // HTTP 예외 처리
+    const status =
+      exception instanceof HttpException
+        ? exception.getStatus()
+        : HttpStatus.INTERNAL_SERVER_ERROR;
+
+    const message =
+      exception instanceof HttpException
+        ? exception.getResponse()
+        : 'Internal server error';
+
+    // 일관된 에러 응답 형식
+    response.status(status).json({
+      statusCode: status,
+      message:
+        typeof message === 'string'
+          ? message
+          : (message as any)?.message || message,
+      timestamp: new Date().toISOString(),
+      path: request.url,
+    });
+  }
+}

packages/server/src/main.ts

@@ -7,6 +7,7 @@ import {
 } from '@nestjs/swagger';
 import { config } from 'dotenv';
 import { setupSshTunnel } from './configs/ssh-tunnel';
+import { AllExceptionsFilter } from 'common/all-exceptions.filter';
 
 config();
 
@@ -43,6 +44,7 @@ async function bootstrap() {
   SwaggerModule.setup('api', app, documentFactory);
 
   app.setGlobalPrefix('api');
+  app.useGlobalFilters(new AllExceptionsFilter());
 
   await app.listen(process.env.PORT ?? 3000);
 }

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

@@ -33,11 +33,15 @@ export class CoinListService implements OnModuleInit {
 			});
 	}
 	async getSimpleCoin(coins) {
+    console.log(coins);
 		let krwCoinInfo = this.coinDataUpdaterService.getKrwCoinInfo();
 		while (!krwCoinInfo) {
 			await new Promise((resolve) => setTimeout(resolve, 100));
 			krwCoinInfo = this.coinDataUpdaterService.getKrwCoinInfo();
 		}
+
+    if (!coins.length) return [];
+
 		return krwCoinInfo
 			.filter((coin) => coins.includes(coin.market))
 			.map((coin) => {
@@ -50,7 +54,7 @@ export class CoinListService implements OnModuleInit {
 				};
 			});
 	}
-  
+
 	getCoinNameList() {
 		return this.coinDataUpdaterService.getCoinCodeList();
 	}

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

@@ -12,6 +12,7 @@ export class UpbitController {
 
   @Sse('price-updates')
   priceUpdates(@Query('coins') coins: string[]): Observable<MessageEvent> {
+    coins = coins || [];
     const initData = this.sseService.initPriceStream(
       coins,
       this.coinListService.convertToMarketCoinDto,
@@ -26,6 +27,7 @@ export class UpbitController {
   }
   @Sse('orderbook')
   orderbookUpdates(@Query('coins') coins: string[]): Observable<MessageEvent> {
+    coins = coins || [];
     return this.sseService.getOrderbookUpdatesStream(
       coins,
       this.coinListService.convertToOrderbookDto,
@@ -55,6 +57,7 @@ export class UpbitController {
   }
   @Get('market/simplelist/krw')
   getSomeKRW(@Query('market') market: string[]) {
-    return this.coinListService.getSimpleCoin(market);
+    const marketList = market || [];
+    return this.coinListService.getSimpleCoin(marketList);
   }
 }