Function captureStream

scripts/capture-run-stream.ts:64–110

(runId: string, filePath: string)

}

async function captureStream(runId: string, filePath: string) {
  await ensureOutputDir(filePath)
  const streamUrl = `${API_BASE_URL}/api/v1/workflows/runs/${runId}/stream`
  const response = await fetch(streamUrl, {
    headers: COMMON_HEADERS,
  })
  if (!response.ok || !response.body) {
    const text = await response.text().catch(() => '')
    throw new Error(
      `Failed to subscribe to stream ${streamUrl}: ${response.status} ${response.statusText} - ${text}`,
    )
  }

  const file = createWriteStream(filePath, { flags: 'w' })
  file.write(`# Workflow ${WORKFLOW_ID} run ${runId}\n`)
  file.write(`# Stream URL: ${streamUrl}\n`)
  file.write(`# Captured at: ${new Date().toISOString()}\n\n`)

  const reader = response.body.getReader()
  const decoder = new TextDecoder()
  let buffer = ''
  let finished = false

  while (!finished) {
    const { value, done } = await reader.read()
    if (done) {
      break
    }
    buffer += decoder.decode(value, { stream: true })
    let index: number
    while ((index = buffer.indexOf('\n\n')) >= 0) {
      const rawEvent = buffer.slice(0, index).replace(/\r/g, '')
      buffer = buffer.slice(index + 2)
      if (rawEvent.trim().length === 0) {
        continue
      }
      file.write(rawEvent + '\n\n')
      if (rawEvent.startsWith('event: complete')) {
        finished = true
        break
      }
    }
  }

  file.end()
  return filePath
}

async function main() {
  console.log(