Workflow 장기 실행

import { defineHook, sleep } from 'workflow'

const approvalHook = defineHook<{ approved: boolean; operatorId: string }>()

export async function customerEscalation(ticketId: string) {
  'use workflow'

  const summary = await summarizeTicket(ticketId)
  const approval = approvalHook.create({ token: `ticket:${ticketId}` })
  await sendApprovalRequest({ ticketId, summary, token: approval.token })

  const result = await Promise.race([
    approval,
    sleep('24h').then(() => ({ approved: false, operatorId: 'timeout' })),
  ])

  if (!result.approved) {
    return { status: 'rejected' }
  }

  return executeEscalation(summary)
}

async function summarizeTicket(ticketId: string) {
  'use step'
  return loadAndSummarizeTicket(ticketId)
}

async function executeEscalation(summary: TicketSummary) {
  'use step'
  return dispatchEscalation(summary)
}