Function writeTerminal

apps/sim/lib/execution/event-buffer.ts:940–981

(
    event: ExecutionEvent,
    status: TerminalExecutionStreamStatus
  )

  }

  const writeTerminal = (
    event: ExecutionEvent,
    status: TerminalExecutionStreamStatus
  ): Promise<ExecutionEventEntry> => {
    if (closed) return Promise.resolve({ eventId: 0, executionId, event })
    const p = writeQueue.then(async () => {
      if (flushTimer) {
        clearTimeout(flushTimer)
        flushTimer = null
      }
      if (nextEventId === 0 || nextEventId > maxReservedId) {
        await reserveIds(1)
      }
      const eventId = nextEventId++
      const compactEvent = await compactEventForBuffer(event, {
        ...context,
        executionId,
        requireDurablePayloads: true,
      })
      const entry: ExecutionEventEntry = { eventId, executionId, event: compactEvent }
      pending.push(entry)
      const ok = await flushPending(false, status)
      if (!ok) {
        pending = pending.filter((pendingEntry) => pendingEntry !== entry)
        throw new Error(`Failed to flush terminal execution event for ${executionId}`)
      }
      closed = true
      return entry
    })
    writeQueue = p.then(
      () => {
        writeFailure = null
      },
      (error) => {
        writeFailure = toError(error)
      }
    )
    inflightWrites.add(p)
    const remove = () => inflightWrites.delete(p)
    p.then(remove, remove)
    return p
  }

  const close = async () => {
    closed = true