Function commitOrCreateTerminalRunFact

packages/runtime/src/terminal-run-commit.ts:173–249

(
  input: CommitOrCreateTerminalRunFactInput,
)

}

export async function commitOrCreateTerminalRunFact(
  input: CommitOrCreateTerminalRunFactInput,
): Promise<CommitOrCreateTerminalRunFactResult> {
  const createdTerminalEvent = !input.terminalEvent;
  const effectiveAbortSource =
    input.fallbackStatus === 'cancelled' ? (input.abortSource ?? 'user_stop') : input.abortSource;
  const terminalEvent =
    input.terminalEvent ??
    buildSyntheticTerminalRuntimeEvent({
      id: input.newId(),
      invocationId: input.fallbackInvocationId,
      run: {
        sessionId: input.sessionId,
        runId: input.runId,
        turnId: input.turnId,
      },
      status: input.fallbackStatus,
      ts: input.ts,
      ...(input.fallbackFailureClass ? { failureClass: input.fallbackFailureClass } : {}),
      ...(effectiveAbortSource ? { abortSource: effectiveAbortSource } : {}),
      ...((input.fallbackFailureMessage ?? input.failureMessage)
        ? { message: input.fallbackFailureMessage ?? input.failureMessage }
        : {}),
    });
  const status = terminalRunStatusFromRuntimeEvent(terminalEvent);
  if (!status) {
    throw new Error('terminal RuntimeEvent must carry a terminal status');
  }
  if (isPartialRuntimeEvent(terminalEvent)) {
    throw new Error('terminal RuntimeEvent must be final before terminal run header');
  }
  if (
    terminalEvent.sessionId !== input.sessionId ||
    terminalEvent.runId !== input.runId ||
    terminalEvent.turnId !== input.turnId
  ) {
    throw new Error('terminal RuntimeEvent identity does not match run header commit');
  }
  const failureClass =
    status === 'failed'
      ? (runtimeEventFailureClass(terminalEvent) ?? input.failureClass ?? 'unknown')
      : undefined;
  await input.runtimeEventStore.ensureTerminalRuntimeEventDurable(
    input.sessionId,
    input.runId,
    terminalEvent,
  );
  // Between the terminal durability barrier and the header commit: the one
  // point where "the terminal fact is durable" is true and nothing else has
  // been projected yet. Callers that must order a crash boundary against
  // the barrier itself hang it here (#2313 corruption recovery, where the
  // claimed event's own write never ran).
  await input.afterTerminalDurable?.();
  let headerCommitted = false;
  let headerCommitError: unknown;
  try {
    await commitTerminalRunProjection({
      ...input,