~20250428 작업사항

3 files changed, 197 insertions, 6 deletions

diff --git a/app/api/cron/forms/route.ts b/app/api/cron/forms/route.ts
index f58c146b..abe6753a 100644
--- a/app/api/cron/forms/route.ts
+++ b/app/api/cron/forms/route.ts
@@ -1,20 +1,65 @@
-// src/app/api/cron/tag-form-mappings/route.ts
+// app/api/cron/forms/route.ts
 import { syncTagFormMappings } from '@/lib/sedp/sync-form';
 import { NextRequest } from 'next/server';
+import { revalidateTag } from 'next/cache';
+
+// TypeScript에서 global 객체를 확장하기 위한 type 선언
+declare global {
+  var pendingTasks: Set<Promise<any>>;
+}
+
+// 글로벌 태스크 집합 초기화 (서버가 시작될 때만 한 번 실행됨)
+if (!global.pendingTasks) {
+  global.pendingTasks = new Set<Promise<any>>();
+}
+
+// 이 함수는 비동기 작업을 더 안전하게 처리하기 위한 도우미 함수입니다
+function runBackgroundTask<T>(task: Promise<T>, taskName: string): Promise<T> {
+  // 작업을 추적 세트에 추가
+  global.pendingTasks.add(task);
+  
+  // finally 블록을 사용하여 작업이 완료될 때 세트에서 제거
+  task
+    .then(result => {
+      console.log(`Background task '${taskName}' completed successfully`);
+      return result;
+    })
+    .catch(error => {
+      console.error(`Background task '${taskName}' failed:`, error);
+    })
+    .finally(() => {
+      global.pendingTasks.delete(task);
+    });
+    
+  return task;
+}
 
 export async function GET(request: NextRequest) {
   try {
     console.log('태그 폼 매핑 동기화 API 호출됨:', new Date().toISOString());
     
-    // syncTagFormMappings 함수 호출
-    const result = await syncTagFormMappings();
+    // 비동기 작업을 생성하고 전역 객체에 저장
+    const syncTask = syncTagFormMappings()
+      .then(result => {
+        // 작업이 완료되면 캐시 무효화
+        revalidateTag('form-lists');
+        return result;
+      });
+    
+    // 백그라운드에서 작업이 계속 실행되도록 보장
+    runBackgroundTask(syncTask, 'form-sync');
     
-    // 성공 시 결과와 함께 200 OK 반환
-    return Response.json({ success: true, result }, { status: 200 });
+    // 먼저 상태를 반환하고, 그 동안 백그라운드에서 작업 계속
+    return new Response(
+      JSON.stringify({ 
+        success: true, 
+        message: 'Form sync started in background. This may take a while.' 
+      }), 
+      { status: 202, headers: { 'Content-Type': 'application/json' } }
+    );
   } catch (error: any) {
     console.error('태그 폼 매핑 동기화 API 에러:', error);
     
-    // 에러 시에는 message를 담아 500 반환
     const message = error.message || 'Something went wrong';
     return Response.json({ success: false, error: message }, { status: 500 });
   }
diff --git a/app/api/cron/forms/start/route.ts b/app/api/cron/forms/start/route.ts
new file mode 100644
index 00000000..a99c4677
--- /dev/null
+++ b/app/api/cron/forms/start/route.ts
@@ -0,0 +1,100 @@
+// app/api/cron/forms/start/route.ts
+import { NextRequest } from 'next/server';
+import { v4 as uuidv4 } from 'uuid';
+import { revalidateTag } from 'next/cache';
+
+// 동기화 작업의 상태를 저장할 Map
+// 실제 프로덕션에서는 Redis 또는 DB에 저장하는 것이 좋습니다
+const syncJobs = new Map<string, {
+  status: 'queued' | 'processing' | 'completed' | 'failed';
+  startTime: Date;
+  endTime?: Date;
+  result?: any;
+  error?: string;
+  progress?: number;
+}>();
+
+export async function POST(request: NextRequest) {
+  try {
+    // 고유 ID 생성
+    const syncId = uuidv4();
+    
+    // 작업 상태 초기화
+    syncJobs.set(syncId, {
+      status: 'queued',
+      startTime: new Date(),
+    });
+    
+    // 비동기 작업 시작 (백그라운드에서 실행)
+    processSyncJob(syncId).catch(error => {
+      console.error('Background sync job failed:', error);
+      syncJobs.set(syncId, {
+        ...syncJobs.get(syncId)!,
+        status: 'failed',
+        endTime: new Date(),
+        error: error.message || 'Unknown error occurred'
+      });
+    });
+    
+    // 즉시 응답 반환 (작업 ID 포함)
+    return Response.json({
+      success: true,
+      message: 'Form sync job started',
+      syncId
+    }, { status: 200 });
+    
+  } catch (error: any) {
+    console.error('Failed to start sync job:', error);
+    return Response.json({
+      success: false,
+      error: error.message || 'Failed to start sync job'
+    }, { status: 500 });
+  }
+}
+
+// 백그라운드에서 실행되는 동기화 작업
+async function processSyncJob(syncId: string) {
+  try {
+    // 상태 업데이트: 처리 중
+    syncJobs.set(syncId, {
+      ...syncJobs.get(syncId)!,
+      status: 'processing',
+      progress: 0,
+    });
+    
+    // 여기서 실제 동기화 로직 가져오기
+    const { syncTagFormMappings } = await import('@/lib/sedp/sync-form');
+    
+    // 실제 동기화 작업 실행
+    const result = await syncTagFormMappings();
+    
+    // 명시적으로 캐시 무효화 (동적 import 대신 상단에서 import)
+    revalidateTag('form-lists');
+    
+    // 상태 업데이트: 완료
+    syncJobs.set(syncId, {
+      ...syncJobs.get(syncId)!,
+      status: 'completed',
+      endTime: new Date(),
+      result,
+      progress: 100,
+    });
+    
+    return result;
+  } catch (error: any) {
+    // 에러 발생 시 상태 업데이트
+    syncJobs.set(syncId, {
+      ...syncJobs.get(syncId)!,
+      status: 'failed',
+      endTime: new Date(),
+      error: error.message || 'Unknown error occurred',
+    });
+    
+    throw error; // 에러 다시 던지기
+  }
+}
+
+// 서버 메모리에 저장된 작업 상태 접근 함수 (다른 API에서 사용)
+export function getSyncJobStatus(id: string) {
+  return syncJobs.get(id);
+}
\ No newline at end of file
diff --git a/app/api/cron/forms/status/route.ts b/app/api/cron/forms/status/route.ts
new file mode 100644
index 00000000..c0e27b2e
--- /dev/null
+++ b/app/api/cron/forms/status/route.ts
@@ -0,0 +1,46 @@
+// app/api/cron/forms/status/route.ts
+import { NextRequest } from 'next/server';
+import { getSyncJobStatus } from '../start/route';
+
+export async function GET(request: NextRequest) {
+  try {
+    // URL에서 작업 ID 가져오기
+    const searchParams = request.nextUrl.searchParams;
+    const syncId = searchParams.get('id');
+    
+    if (!syncId) {
+      return Response.json({
+        success: false,
+        error: 'Missing sync ID parameter'
+      }, { status: 400 });
+    }
+    
+    // 작업 상태 조회
+    const jobStatus = getSyncJobStatus(syncId);
+    
+    if (!jobStatus) {
+      return Response.json({
+        success: false,
+        error: 'Sync job not found'
+      }, { status: 404 });
+    }
+    
+    // 작업 상태 반환
+    return Response.json({
+      success: true,
+      status: jobStatus.status,
+      startTime: jobStatus.startTime,
+      endTime: jobStatus.endTime,
+      progress: jobStatus.progress,
+      result: jobStatus.result,
+      error: jobStatus.error
+    }, { status: 200 });
+    
+  } catch (error: any) {
+    console.error('Error retrieving sync status:', error);
+    return Response.json({
+      success: false,
+      error: error.message || 'Failed to retrieve sync status'
+    }, { status: 500 });
+  }
+}
\ No newline at end of file