실무 오케스트레이션 플레이북

import { defineHook, sleep } from 'workflow'

const opsApprovalHook = defineHook<{ approved: boolean }>()

export async function opsPlaybook(eventId: string) {
  'use workflow'

  const event = await loadEvent(eventId)
  const pattern = await classifyPattern(event)

  if (pattern === 'approval') {
    const approval = opsApprovalHook.create({ token: `ops:${event.id}` })
    await requestOpsApproval({ event, token: approval.token })
    return Promise.race([
      approval,
      sleep('4h').then(() => ({ approved: false })),
    ])
  }

  return executePlaybook(pattern, event)
}

async function loadEvent(eventId: string) {
  'use step'
  return loadOpsEvent(eventId)
}

async function classifyPattern(event: OpsEvent) {
  'use step'
  return classifyOpsPattern(event)
}

async function executePlaybook(pattern: OpsPattern, event: OpsEvent) {
  'use step'
  return runPlaybook(pattern, event)
}