Function readDeployStream

packages/cli/src/deploy.ts:50–106

(
  response: Response,
  spinner: ReturnType<typeof p.spinner>,
)

  | { type: "error"; message: string }

async function readDeployStream(
  response: Response,
  spinner: ReturnType<typeof p.spinner>,
): Promise<Extract<DeployEvent, { type: "result" }>["result"]> {
  if (!response.body) {
    throw new Error("Deploy response did not include a stream")
  }

  const reader = response.body.getReader()
  const decoder = new TextDecoder()
  let buffer = ""
  let result: Extract<DeployEvent, { type: "result" }>["result"] | null = null

  const handleLine = (line: string) => {
    let event: DeployEvent
    try {
      event = JSON.parse(line) as DeployEvent
    } catch {
      throw new Error(`Invalid deploy stream response: ${line}`)
    }

    if (event.type === "status") {
      spinner.message(event.message)
      return
    }

    if (event.type === "error") {
      throw new Error(event.message)
    }

    result = event.result
  }

  while (true) {
    const { done, value } = await reader.read()
    buffer += decoder.decode(value ?? new Uint8Array(), { stream: !done })

    let newlineIndex = buffer.indexOf("\n")
    while (newlineIndex !== -1) {
      const line = buffer.slice(0, newlineIndex).trim()
      buffer = buffer.slice(newlineIndex + 1)
      if (line) handleLine(line)
      newlineIndex = buffer.indexOf("\n")
    }

    if (done) break
  }

  const tail = buffer.trim()
  if (tail) handleLine(tail)

  if (!result) {
    throw new Error("Deploy stream ended without a result")
  }

  return result
}