승인형 백오피스 자동화

import { defineHook, sleep } from 'workflow'

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

export async function refundWorkflow(refundId: string) {
  'use workflow'

  const proposal = await draftRefund(refundId)
  const approval = financeApprovalHook.create({ token: `refund:${proposal.id}` })
  await notifyFinanceApprover({ proposal, token: approval.token })

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

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

  return executeRefund({
    operatorId: result.operatorId,
    proposal,
  })
}

async function draftRefund(refundId: string) {
  'use step'
  return draftRefundProposal(refundId)
}

async function executeRefund(input: { operatorId: string; proposal: RefundProposal }) {
  'use step'
  return runRefundInSandbox(input)
}