diff options
Diffstat (limited to 'app/api/nonsap-sync')
| -rw-r--r-- | app/api/nonsap-sync/config/route.ts | 22 | ||||
| -rw-r--r-- | app/api/nonsap-sync/cron/route.ts | 41 | ||||
| -rw-r--r-- | app/api/nonsap-sync/health/route.ts | 63 | ||||
| -rw-r--r-- | app/api/nonsap-sync/status/route.ts | 22 | ||||
| -rw-r--r-- | app/api/nonsap-sync/trigger/route.ts | 25 |
5 files changed, 173 insertions, 0 deletions
diff --git a/app/api/nonsap-sync/config/route.ts b/app/api/nonsap-sync/config/route.ts new file mode 100644 index 00000000..7441088b --- /dev/null +++ b/app/api/nonsap-sync/config/route.ts @@ -0,0 +1,22 @@ +import { NextResponse } from 'next/server'; +import { getSyncConfigInfo } from '@/lib/nonsap-sync/sync-config'; + +export async function GET() { + try { + const config = getSyncConfigInfo(); + + return NextResponse.json({ + success: true, + data: config, + timestamp: new Date().toISOString() + }); + } catch (error) { + console.error('Failed to get sync config:', error); + + return NextResponse.json({ + success: false, + error: 'Failed to get sync config', + timestamp: new Date().toISOString() + }, { status: 500 }); + } +}
\ No newline at end of file diff --git a/app/api/nonsap-sync/cron/route.ts b/app/api/nonsap-sync/cron/route.ts new file mode 100644 index 00000000..80944280 --- /dev/null +++ b/app/api/nonsap-sync/cron/route.ts @@ -0,0 +1,41 @@ +import { NextRequest, NextResponse } from 'next/server'; + +export async function GET(request: NextRequest) { + try { + // 인증 확인 (선택적) + const authToken = process.env.CRON_AUTH_TOKEN; + if (authToken) { + const providedToken = new URL(request.url).searchParams.get('token'); + if (providedToken !== authToken) { + return NextResponse.json({ error: 'Unauthorized' }, { status: 401 }); + } + } + + // 동적 import로 cron 스케줄러 호출 + const { triggerEnhancedSync } = await import('../../../../lib/nonsap-sync/enhanced-sync-service'); + + // 백그라운드에서 동기화 실행 + triggerEnhancedSync().catch(error => { + console.error('Cron sync failed:', error); + }); + + return NextResponse.json({ + success: true, + message: 'NONSAP sync triggered via cron endpoint', + timestamp: new Date().toISOString() + }); + } catch (error) { + console.error('Cron endpoint error:', error); + + return NextResponse.json({ + success: false, + error: 'Failed to trigger sync', + timestamp: new Date().toISOString() + }, { status: 500 }); + } +} + +export async function POST() { + // POST 요청도 동일하게 처리 + return GET(); +}
\ No newline at end of file diff --git a/app/api/nonsap-sync/health/route.ts b/app/api/nonsap-sync/health/route.ts new file mode 100644 index 00000000..6bfa4ffb --- /dev/null +++ b/app/api/nonsap-sync/health/route.ts @@ -0,0 +1,63 @@ +import { NextResponse } from 'next/server'; + +export async function GET() { + try { + // Oracle DB 연결 테스트 + let oracleStatus = 'unknown'; + let oracleError = null; + + try { + const { oracleKnex } = await import('@/lib/oracle-db/db'); + const result = await oracleKnex.raw('SELECT 1 FROM DUAL'); + oracleStatus = result ? 'connected' : 'disconnected'; + } catch (error) { + oracleStatus = 'disconnected'; + oracleError = error instanceof Error ? error.message : String(error); + } + + // PostgreSQL 연결 테스트 + let postgresStatus = 'unknown'; + let postgresError = null; + + try { + const db = await import('@/db/db'); + await db.default.execute('SELECT 1'); + postgresStatus = 'connected'; + } catch (error) { + postgresStatus = 'disconnected'; + postgresError = error instanceof Error ? error.message : String(error); + } + + // 전체 상태 판단 + const overallStatus = oracleStatus === 'connected' && postgresStatus === 'connected' + ? 'healthy' + : 'unhealthy'; + + return NextResponse.json({ + status: overallStatus, + timestamp: new Date().toISOString(), + databases: { + oracle: { + status: oracleStatus, + error: oracleError + }, + postgres: { + status: postgresStatus, + error: postgresError + } + }, + environment: { + nodeEnv: process.env.NODE_ENV, + runtime: process.env.NEXT_RUNTIME || 'nodejs' + } + }); + } catch (error) { + console.error('Health check error:', error); + + return NextResponse.json({ + status: 'error', + timestamp: new Date().toISOString(), + error: error instanceof Error ? error.message : String(error) + }, { status: 500 }); + } +}
\ No newline at end of file diff --git a/app/api/nonsap-sync/status/route.ts b/app/api/nonsap-sync/status/route.ts new file mode 100644 index 00000000..0a847904 --- /dev/null +++ b/app/api/nonsap-sync/status/route.ts @@ -0,0 +1,22 @@ +import { NextResponse } from 'next/server'; +import { getSyncProgressEnhanced } from '../../../../lib/nonsap-sync/enhanced-sync-service'; + +export async function GET() { + try { + const progress = await getSyncProgressEnhanced(); + + return NextResponse.json({ + success: true, + data: progress, + timestamp: new Date().toISOString() + }); + } catch (error) { + console.error('Error getting sync progress:', error); + + return NextResponse.json({ + success: false, + error: 'Failed to get sync progress', + timestamp: new Date().toISOString() + }, { status: 500 }); + } +}
\ No newline at end of file diff --git a/app/api/nonsap-sync/trigger/route.ts b/app/api/nonsap-sync/trigger/route.ts new file mode 100644 index 00000000..fbad7c4a --- /dev/null +++ b/app/api/nonsap-sync/trigger/route.ts @@ -0,0 +1,25 @@ +import { NextResponse } from 'next/server'; +import { triggerEnhancedSync } from '../../../../lib/nonsap-sync/enhanced-sync-service'; + +export async function POST() { + try { + // 수동 동기화 트리거 (백그라운드에서 실행) + triggerEnhancedSync().catch(error => { + console.error('Manual sync failed:', error); + }); + + return NextResponse.json({ + success: true, + message: 'Manual sync triggered successfully', + timestamp: new Date().toISOString() + }); + } catch (error) { + console.error('Error triggering manual sync:', error); + + return NextResponse.json({ + success: false, + error: 'Failed to trigger manual sync', + timestamp: new Date().toISOString() + }, { status: 500 }); + } +}
\ No newline at end of file |
