diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/revalidation-utils.ts | 99 | ||||
| -rw-r--r-- | lib/vendors/service.ts | 31 |
2 files changed, 112 insertions, 18 deletions
diff --git a/lib/revalidation-utils.ts b/lib/revalidation-utils.ts new file mode 100644 index 00000000..14c5bf01 --- /dev/null +++ b/lib/revalidation-utils.ts @@ -0,0 +1,99 @@ +/** + * Request Context가 없는 환경(cronjob, background worker 등)에서 + * 캐시를 무효화하기 위한 유틸리티 + * + * 사용 예시: + * ```ts + * // Cronjob에서 사용 + * await revalidateViaCronJob({ tags: ['vendors', 'users'] }); + * + * // 또는 개별 태그 + * await revalidateTagViaCronJob('vendors'); + * ``` + */ + +/** + * API를 통한 캐시 무효화 (cronjob 등에서 사용) + */ +export async function revalidateViaCronJob(options: { + tags?: string[]; +}): Promise<{ success: boolean; error?: string }> { + try { + const baseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'http://localhost:3000'; + + const response = await fetch(`${baseUrl}/api/revalidate/approval`, { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + }, + body: JSON.stringify({ + tags: options.tags, + secret: process.env.REVALIDATION_SECRET, + }), + }); + + if (!response.ok) { + const error = await response.text(); + console.error('[Revalidation] API call failed:', error); + return { + success: false, + error: `Revalidation API failed: ${response.statusText}`, + }; + } + + const result = await response.json(); + console.log('[Revalidation] Cache invalidated:', options.tags); + + return { success: true }; + } catch (error) { + console.error('[Revalidation] Failed to revalidate cache:', error); + // 캐시 무효화 실패는 치명적이지 않으므로 경고만 출력 + return { + success: false, + error: error instanceof Error ? error.message : 'Unknown error', + }; + } +} + +/** + * 단일 태그 무효화 (cronjob에서 사용) + */ +export async function revalidateTagViaCronJob(tag: string) { + return revalidateViaCronJob({ tags: [tag] }); +} + +/** + * 벤더 관련 캐시 무효화 + */ +export async function revalidateVendorCaches() { + return revalidateViaCronJob({ + tags: ['vendors', 'vendor-status-counts'], + }); +} + +/** + * 유저 관련 캐시 무효화 + */ +export async function revalidateUserCaches() { + return revalidateViaCronJob({ + tags: ['users', 'roles', 'user-roles'], + }); +} + +/** + * 승인 프로세스에서 사용하는 모든 캐시 무효화 + */ +export async function revalidateApprovalRelatedCaches() { + return revalidateViaCronJob({ + tags: [ + 'vendors', + 'vendor-status-counts', + 'users', + 'roles', + 'user-roles', + 'approval-logs', + 'pending-actions', + ], + }); +} + diff --git a/lib/vendors/service.ts b/lib/vendors/service.ts index 76193eb9..6454bc7b 100644 --- a/lib/vendors/service.ts +++ b/lib/vendors/service.ts @@ -1772,10 +1772,8 @@ export async function approveVendors(input: ApproveVendorsInput & { userId: numb ? "[eVCP] 업체 승인 완료 - 계정 활성화" : "[eVCP] Vendor Approved - Account Activated"; - const headersList = await headers(); - const host = headersList.get('host') || 'localhost:3000'; - const protocol = headersList.get('x-forwarded-proto') || 'http'; - const baseUrl = `${protocol}://${host}`; + // ✅ Request Context가 없을 수 있으므로 환경변수 사용 + const baseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'http://localhost:3000'; const loginUrl = `${baseUrl}/${userLang}/login`; const passwordSetupUrl = `${baseUrl}/${userLang}/auth/reset-password?token=${resetToken}`; // 패스워드 설정 URL @@ -1804,12 +1802,9 @@ export async function approveVendors(input: ApproveVendorsInput & { userId: numb return updated; }); - // 캐시 무효화 - revalidateTag("vendors"); - revalidateTag("vendor-status-counts"); - revalidateTag("users"); // 유저 캐시도 무효화 - revalidateTag("roles"); // 역할 캐시도 무효화 - revalidateTag("user-roles"); // 유저 역할 캐시도 무효화 + // ✅ 캐시 무효화 (cronjob에서도 작동하도록 API 사용) + const { revalidateApprovalRelatedCaches } = await import('@/lib/revalidation-utils'); + await revalidateApprovalRelatedCaches(); return { data: result, error: null }; } catch (err) { @@ -1933,10 +1928,8 @@ export async function rejectVendors(input: ApproveVendorsInput & { userId: numbe ? "[eVCP] 업체 등록 거절 안내" : "[eVCP] Vendor Registration Rejected"; - const headersList = await headers(); - const host = headersList.get('host') || 'localhost:3000'; - const protocol = headersList.get('x-forwarded-proto') || 'http'; - const baseUrl = `${protocol}://${host}`; + // ✅ Request Context가 없을 수 있으므로 환경변수 사용 + const baseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'http://localhost:3000'; const loginUrl = `${baseUrl}/${userLang}/login`; await sendEmail({ @@ -1962,10 +1955,12 @@ export async function rejectVendors(input: ApproveVendorsInput & { userId: numbe return updated; }); - // 캐시 무효화 - revalidateTag("vendors"); - revalidateTag("vendor-status-counts"); - revalidateTag("users"); // 유저 캐시도 무효화 + // ✅ 캐시 무효화 (cronjob에서도 작동하도록 API 사용) + const { revalidateVendorCaches, revalidateUserCaches } = await import('@/lib/revalidation-utils'); + await Promise.all([ + revalidateVendorCaches(), + revalidateUserCaches(), + ]); return { data: result, error: null }; } catch (err) { |