Function commitTerminalRunWithRuntimeFact

packages/runtime/src/terminal-run-commit.ts:82–111

(
  input: CommitTerminalRunWithRuntimeFactInput,
)

}

export async function commitTerminalRunWithRuntimeFact(
  input: CommitTerminalRunWithRuntimeFactInput,
): Promise<void> {
  if (isPartialRuntimeEvent(input.terminalEvent)) {
    throw new Error('terminal RuntimeEvent must be final before terminal run header');
  }
  const terminalStatus = terminalRunStatusFromRuntimeEvent(input.terminalEvent);
  if (!terminalStatus) {
    throw new Error('terminal RuntimeEvent must carry a terminal status');
  }
  if (terminalStatus !== input.status) {
    throw new Error(
      `terminal RuntimeEvent status ${input.terminalEvent.status} cannot commit ${input.status} run header`,
    );
  }
  if (
    input.terminalEvent.sessionId !== input.sessionId ||
    input.terminalEvent.runId !== input.runId ||
    input.terminalEvent.turnId !== input.turnId
  ) {
    throw new Error('terminal RuntimeEvent identity does not match run header commit');
  }
  await input.runtimeEventStore.ensureTerminalRuntimeEventDurable(
    input.sessionId,
    input.runId,
    input.terminalEvent,
  );

  await commitTerminalRunProjection(input);
}

async function commitTerminalRunProjection(
  input: CommitTerminalRunWithRuntimeFactInput,