feature: 추후 Ops 를 위한 헬스 체크 세팅, app.ts 리뉴얼

Author: Nuung

src/app.ts

@@ -1,44 +1,94 @@
 import 'reflect-metadata';
-import express, { Application } from 'express';
+import express, { Application, Request, Response, NextFunction } from 'express';
 import dotenv from 'dotenv';
 import cors from 'cors';
 import cookieParser from 'cookie-parser';
-import router from './routes';
 import swaggerUi from 'swagger-ui-express';
 import swaggerJSDoc from 'swagger-jsdoc';
+
+import logger from '@/configs/logger.config';
+import router from '@/routes';
+import { NotFoundError } from '@/exception';
+
 import { options } from '@/configs/swagger.config';
-import { errorHandlingMiddleware } from './middlewares/errorHandling.middleware';
-import { NotFoundError } from './exception';
 import { initSentry } from '@/configs/sentry.config';
+import { initCache } from '@/configs/cache.config';
+import { errorHandlingMiddleware } from '@/middlewares/errorHandling.middleware';
 
 dotenv.config();
 
-// Sentry 초기화
-initSentry();
+initSentry();  // Sentry 초기화
+initCache();  // Redis 캐시 초기화
 
 const app: Application = express();
+
 // 실제 클라이언트 IP를 알기 위한 trust proxy 설정
-app.set('trust proxy', true);
+app.set('trust proxy', process.env.NODE_ENV === 'production');
+
 const swaggerSpec = swaggerJSDoc(options);
 
 app.use(cookieParser());
-app.use(express.json());
-app.use(express.urlencoded({ extended: true }));
+app.use(express.json({ limit: '10mb' })); // 파일 업로드 대비
+app.use(express.urlencoded({ extended: true, limit: '10mb' }));
+
 app.use(
   cors({
-    origin: process.env.NODE_ENV === 'production' ? process.env.ALLOWED_ORIGINS?.split(',') : 'http://localhost:3000',
+    origin: process.env.NODE_ENV === 'production'
+      ? process.env.ALLOWED_ORIGINS?.split(',').map(origin => origin.trim())
+      : 'http://localhost:3000',
     methods: ['GET', 'POST'],
     allowedHeaders: ['Content-Type', 'Authorization', 'Cookie', 'access_token', 'refresh_token'],
     credentials: true,
   }),
 );
 
-app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerSpec));
+// 헬스체크 엔드포인트
+app.get('/health', async (req: Request, res: Response) => {
+  // 기본 정보
+  const healthData = {
+    status: 'OK',
+    timestamp: new Date().toISOString(),
+    uptime: process.uptime(),
+    environment: process.env.NODE_ENV,
+    services: {
+      sentry: false,
+      cache: false
+    }
+  };
+
+  // Sentry 상태 확인
+  try {
+    const { getSentryStatus } = await import('./configs/sentry.config.ts');
+    healthData.services.sentry = getSentryStatus();
+  } catch (error) {
+    healthData.services.sentry = false;
+    logger.error('Failed to health check for sentry:', error);
+  }
+
+  // Cache 상태 확인
+  try {
+    const { getCacheStatus } = await import('./configs/cache.config.ts');
+    healthData.services.cache = await getCacheStatus();
+  } catch (error) {
+    healthData.services.cache = false;
+    logger.error('Failed to health check for cache:', error);
+  }
+
+  res.status(200).json(healthData);
+});
+
+// Swagger는 개발 환경에서만
+if (process.env.NODE_ENV !== 'production') {
+  app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerSpec));
+}
+
 app.use('/api', router);
-app.use((req) => {
-  throw new NotFoundError(`${req.url} not found`);
+
+// 404 에러 핸들링 수정 (throw 대신 next 사용)
+app.use((req: Request, res: Response, next: NextFunction) => {
+  next(new NotFoundError(`${req.url} not found`));
 });
 
 app.use(errorHandlingMiddleware);
 
-export default app;
+export default app;

src/configs/cache.config.ts

@@ -15,15 +15,19 @@ const cacheConfig: CacheConfig = {
 
 // 싱글톤 캐시 인스턴스 (const로 변경하고 null 초기화)
 const cacheInstance: ICache = new RedisCache(cacheConfig);
-
 export const cache = cacheInstance;
 
+// 캐시 상태 추적 변수
+let cacheInitialized = false;
+
 // 초기화 함수
 export const initCache = async (): Promise<void> => {
   try {
     await cache.connect();
+    cacheInitialized = true;
     logger.info('Cache system initialized successfully');
   } catch (error) {
+    cacheInitialized = false;
     logger.error('Failed to initialize cache system:', error);
     // 캐시 연결 실패해도 애플리케이션은 계속 실행
     logger.warn('Application will continue without cache');
@@ -34,8 +38,26 @@ export const initCache = async (): Promise<void> => {
 export const closeCache = async (): Promise<void> => {
   try {
     await cache.disconnect();
+    cacheInitialized = false;
     logger.info('Cache system closed successfully');
   } catch (error) {
     logger.error('Failed to close cache system:', error);
   }
 };
+
+// 캐시 상태 확인 함수
+export const getCacheStatus = async (): Promise<boolean> => {
+  if (!cacheInitialized) {
+    return false;
+  }
+
+  try {
+    // Redis ping 명령어로 연결 상태 확인
+    await cache.set('health-check', 'ok', 1); // 1초 TTL로 테스트 키 설정
+    await cache.get('health-check'); // 읽기 테스트
+    return true;
+  } catch (error) {
+    logger.warn('Cache health check failed:', error);
+    return false;
+  }
+};

src/configs/db.config.ts

@@ -1,6 +1,7 @@
 import dotenv from 'dotenv';
 import pg from 'pg';
-import logger from './logger.config';
+import logger from '@/configs/logger.config';
+
 // eslint-disable-next-line @typescript-eslint/naming-convention
 const { Pool } = pg;
 

src/configs/sentry.config.ts

@@ -3,22 +3,42 @@ import dotenv from 'dotenv';
 
 dotenv.config();
 
+// Sentry 초기화 상태 추적
+let sentryInitialized = false;
+
 export const initSentry = () => {
-  Sentry.init({
-    dsn: process.env.SENTRY_DSN,
-    release: process.env.NODE_ENV,
-
-    // Define how likely traces are sampled. Adjust this value in production, or use tracesSampler for greater control.
-    tracesSampleRate: 0.1,
-
-    // Setting this option to true will print useful information to the console while you're setting up Sentry.
-    debug: false,
-    enabled: true,
-
-    // Capture 100% of the transactions for performance monitoring
-    integrations: [
-      Sentry.httpIntegration(),
-      Sentry.expressIntegration(),
-    ],
-  });
+  try {
+    if (!process.env.SENTRY_DSN) {
+      sentryInitialized = false;
+      return;
+    }
+
+    Sentry.init({
+      dsn: process.env.SENTRY_DSN,
+      release: process.env.NODE_ENV,
+
+      // Define how likely traces are sampled. Adjust this value in production, or use tracesSampler for greater control.
+      tracesSampleRate: 0.1,
+
+      // Setting this option to true will print useful information to the console while you're setting up Sentry.
+      debug: false,
+      enabled: true,
+
+      // Capture 100% of the transactions for performance monitoring
+      integrations: [
+        Sentry.httpIntegration(),
+        Sentry.expressIntegration(),
+      ],
+    });
+
+    sentryInitialized = true;
+  } catch (error) {
+    sentryInitialized = false;
+    throw error;
+  }
+};
+
+// Sentry 상태 확인 함수
+export const getSentryStatus = (): boolean => {
+  return sentryInitialized;
 };

src/index.ts

@@ -1,8 +1,43 @@
-import app from './app';
-import logger from './configs/logger.config';
+import app from '@/app';
+import logger from '@/configs/logger.config';
 
-const port = process.env.PORT || 3000;
+const port = parseInt(process.env.PORT || '8080', 10);
 
-app.listen(port, () => {
-  logger.info(`Server is running on http://localhost:${port}`);
+const server = app.listen(port, () => {
+  logger.info(`Server running on port ${port}`);
+  logger.info(`Environment: ${process.env.NODE_ENV}`);
+  if (process.env.NODE_ENV !== 'production') {
+    logger.info(`API Docs: http://localhost:${port}/api-docs`);
+  }
+  logger.info(`Health Check: http://localhost:${port}/health`);
+});
+
+// 기본적인 graceful shutdown 추가
+const gracefulShutdown = (signal: string) => {
+  logger.info(`${signal} received, shutting down gracefully`);
+
+  server.close(() => {
+    logger.info('HTTP server closed');
+    process.exit(0);
+  });
+
+  // 강제 종료 타이머 (10초)
+  setTimeout(() => {
+    logger.error('Could not close connections in time, forcefully shutting down');
+    process.exit(1);
+  }, 10000);
+};
+
+process.on('SIGTERM', () => gracefulShutdown('SIGTERM'));
+process.on('SIGINT', () => gracefulShutdown('SIGINT'));
+
+// 예상치 못한 에러 처리
+process.on('uncaughtException', (error) => {
+  logger.error('Uncaught Exception:', error);
+  process.exit(1);
+});
+
+process.on('unhandledRejection', (reason, promise) => {
+  logger.error('Unhandled Rejection at:', promise, 'reason:', reason);
+  process.exit(1);
 });