HOT FIX! 리더보드 캐싱으로 시작된 핫픽스 + 이 참에 업데이트하는 관련 config 값들 (#43)

* modify: db config update, pool 좀 더 세밀하게 관리 * hotfix: run script api image 잘 사용하게 업데이트 * modify: app 실행과 index 업데이트, 그에 따른 dbms connection 관련 설정 업데이트 * modify: index 파일 모듈화, 고도화, 리펙토링, 린팅

Author: Nuung

run.sh

@@ -33,11 +33,12 @@ check_docker() {
 
 # 서비스 중지
 stop_services() {
- print_step "0. 현재 사용 중 이미지 stop, down"
+ print_step "0. 현재 사용 중인 서비스 중지"
  docker compose stop || true
  docker compose down || true
 }
 
+# Docker 리소스 정리
 cleanup_docker() {
  print_step "0.5. 사용하지 않는 Docker 리소스 정리"
 
@@ -53,37 +54,82 @@ cleanup_docker() {
  echo -e "${GREEN}Docker 정리 완료${NC}"
 }
 
-# 이미지 업데이트
+# 모든 이미지 업데이트 (API 포함)
 update_images() {
- print_step "1. 외부 이미지 업데이트 (fe, nginx)..."
- docker compose pull fe nginx
-}
-
-# API 빌드
-build_api() {
- print_step "2. 로컬 이미지 빌드 (api)..."
- docker compose build api
+ print_step "1. Docker Hub에서 최신 이미지 다운로드 중..."
+ 
+ # 모든 서비스의 이미지를 Docker Hub에서 최신 버전으로 pull
+ docker compose pull
+ 
+ echo -e "${GREEN}모든 이미지 업데이트 완료${NC}"
 }
 
 # 서비스 시작
 start_services() {
- print_step "3. 서비스 재시작..."
+ print_step "2. 서비스 시작 중..."
  docker compose up -d
+ 
+ echo -e "${GREEN}모든 서비스가 시작되었습니다${NC}"
+}
+
+# 서비스 상태 확인
+check_services() {
+ print_step "3. 서비스 상태 확인"
+ 
+ # 잠시 대기 (서비스 시작 시간 확보)
+ sleep 5
+ 
+ # 실행 중인 컨테이너 확인
+ echo -e "${YELLOW}실행 중인 컨테이너:${NC}"
+ docker compose ps
+ 
+ # 각 서비스 헬스체크
+ echo -e "\n${YELLOW}서비스 헬스체크:${NC}"
+ 
+ # API 서비스 확인
+ if curl -f http://localhost:8080/health &>/dev/null; then
+ echo -e "✅ API 서비스: ${GREEN}정상${NC}"
+ else
+ echo -e "❌ API 서비스: ${RED}응답 없음${NC}"
+ fi
+ 
+ # Frontend 서비스 확인 (포트 3000)
+ if curl -f http://localhost:3000 &>/dev/null; then
+ echo -e "✅ Frontend 서비스: ${GREEN}정상${NC}"
+ else
+ echo -e "❌ Frontend 서비스: ${RED}응답 없음${NC}"
+ fi
+ 
+ # Nginx 서비스 확인 (포트 80)
+ if curl -f http://localhost &>/dev/null; then
+ echo -e "✅ Nginx 서비스: ${GREEN}정상${NC}"
+ else
+ echo -e "❌ Nginx 서비스: ${RED}응답 없음${NC}"
+ fi
 }
 
 # 메인 실행 로직
 main() {
  set -e # 스크립트 실행 중 오류 발생 시 종료
 
+ print_step "Velog Dashboard V2 배포 스크립트 시작"
+ 
  check_docker
  stop_services
  cleanup_docker
  update_images
- build_api
  start_services
+ check_services
 
- print_step "모든 작업이 완료되었습니다! 로그 모니터링을 시작합니다."
- sleep 1
+ print_step "🎉 모든 작업이 완료되었습니다!"
+ echo -e "${GREEN}서비스 접속 정보:${NC}"
+ echo -e "• 메인 사이트: ${YELLOW}http://localhost${NC}"
+ echo -e "• API 서버: ${YELLOW}http://localhost:8080${NC}"
+ echo -e "• Frontend: ${YELLOW}http://localhost:3000${NC}"
+ echo -e "• API Health Check: ${YELLOW}http://localhost:8080/health${NC}"
+ 
+ echo -e "\n${YELLOW}로그 모니터링을 시작합니다... (Ctrl+C로 종료)${NC}"
+ sleep 2
  docker compose logs -f
 }
 

src/app.ts

@@ -11,15 +11,12 @@ import router from '@/routes';
 import { NotFoundError } from '@/exception';
 
 import { options } from '@/configs/swagger.config';
-import { initSentry, getSentryStatus } from '@/configs/sentry.config';
-import { initCache, getCacheStatus } from '@/configs/cache.config';
+import { getSentryStatus } from '@/configs/sentry.config';
+import { getCacheStatus } from '@/configs/cache.config';
 import { errorHandlingMiddleware } from '@/middlewares/errorHandling.middleware';
 
 dotenv.config();
 
-initSentry(); // Sentry 초기화
-initCache(); // Redis 캐시 초기화
-
 const app: Application = express();
 
 // 실제 클라이언트 IP를 알기 위한 trust proxy 설정
@@ -33,9 +30,10 @@ app.use(express.urlencoded({ extended: true, limit: '10mb' }));
 
 app.use(
  cors({
- origin: process.env.NODE_ENV === 'production'
- ? process.env.ALLOWED_ORIGINS?.split(',').map(origin => origin.trim())
- : '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,
@@ -52,8 +50,8 @@ app.get('/health', async (req: Request, res: Response) => {
  environment: process.env.NODE_ENV,
  services: {
  sentry: false,
- cache: false
- }
+ cache: false,
+ },
  };
 
  // Sentry 상태 확인
@@ -89,4 +87,4 @@ app.use((req: Request, res: Response, next: NextFunction) => {
 
 app.use(errorHandlingMiddleware);
 
-export default app;
+export default app;

src/configs/db.config.ts

@@ -16,7 +16,7 @@ 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 +27,65 @@ if (process.env.NODE_ENV === 'production') {
 
 const pool = new Pool(poolConfig);
 
-(async () => {
- const client = await pool.connect();
+/**
+ * 데이터베이스 연결을 초기화하고 TimescaleDB 확장을 보장
+ * 최대 3회 재시도하며, 실패 시 서버를 종료
+ *
+ * @throws 연결에 3회 실패하면 서버가 종료
+ * @returns {Promise<void>} 연결 및 확장 완료 시 resolve되는 프로미스
+ */
+export 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);
+ }
+ }
+}
+
+/**
+ * 데이터베이스 커넥션 풀을 안정적으로 직접 종료하는 함수
+ *
+ * @throws 데이터베이스 연결 종료에 실패할 경우 에러
+ * @returns {Promise<void>} 데이터베이스 연결이 종료되면 resolve되는 프로미스
+ */
+export async function closeDatabase(): Promise<void> {
  try {
- await client.query('CREATE EXTENSION IF NOT EXISTS timescaledb;');
- logger.info('TimescaleDB 확장 성공');
+ await pool.end();
+ logger.info('데이터베이스 연결이 정상적으로 종료되었습니다.');
  } catch (error) {
- logger.error('TimescaleDB 초기화 실패 : ', error);
- } finally {
- client.release();
+ logger.error('데이터베이스 연결 종료 중 오류 발생:', error);
+ throw error;
  }
-})();
+}
+
 export default pool;