modify: db config update, pool 좀 더 세밀하게 관리

Author: Nuung

src/configs/db.config.ts

@@ -16,7 +16,8 @@ const poolConfig: pg.PoolConfig = {
   port: Number(process.env.POSTGRES_PORT),
   max: 10, // 최대 연결 수
   idleTimeoutMillis: 30000, // 연결 유휴 시간 (30초)
-  connectionTimeoutMillis: 5000, // 연결 시간 초과 (5초)
+  connectionTimeoutMillis: 10000, // 연결 시간 초과 (10초)
+
 };
 
 if (process.env.NODE_ENV === 'production') {
@@ -27,15 +28,49 @@ if (process.env.NODE_ENV === 'production') {
 
 const pool = new Pool(poolConfig);
 
-(async () => {
-  const client = await pool.connect();
-  try {
-    await client.query('CREATE EXTENSION IF NOT EXISTS timescaledb;');
-    logger.info('TimescaleDB 확장 성공');
-  } catch (error) {
-    logger.error('TimescaleDB 초기화 실패 : ', error);
-  } finally {
-    client.release();
+async function initializeDatabase(): Promise<void> {
+  const maxRetries = 3;
+  let delay = 800;
+
+  for (let attempt = 1; attempt <= maxRetries; attempt++) {
+    try {
+      logger.info(`데이터베이스 연결 시도 ${attempt}/${maxRetries}`);
+
+      const client = await pool.connect();
+
+      try {
+        // 연결 테스트
+        await client.query('SELECT 1');
+        logger.info('데이터베이스 연결 성공');
+
+        // TimescaleDB 확장 (필수)
+        await client.query('CREATE EXTENSION IF NOT EXISTS timescaledb;');
+        logger.info('TimescaleDB 확장 성공');
+
+        return; // 성공
+
+      } finally {
+        client.release();
+      }
+
+    } catch (error) {
+      logger.error(`데이터베이스 연결 실패 (시도 ${attempt}/${maxRetries}):`, error);
+
+      if (attempt === maxRetries) {
+        logger.error('데이터베이스 연결에 완전히 실패했습니다. 서버를 종료합니다.');
+        process.exit(1); // 연결 실패시 서버 종료
+      }
+
+      logger.info(`${delay}ms 후 재시도...`);
+      await new Promise(resolve => setTimeout(resolve, delay));
+      delay = Math.floor(delay * 1.5);
+    }
   }
-})();
-export default pool;
+}
+
+initializeDatabase().catch(error => {
+  logger.error('데이터베이스 초기화 중 예상치 못한 오류:', error);
+  process.exit(1); // 치명적 오류시 서버 종료
+});
+
+export default pool;