Function commitTerminalRunProjection

packages/runtime/src/terminal-run-commit.ts:113–150

(
  input: CommitTerminalRunWithRuntimeFactInput,
)

}

async function commitTerminalRunProjection(
  input: CommitTerminalRunWithRuntimeFactInput,
): Promise<void> {
  const failureClass = input.status === 'failed' ? (input.failureClass ?? 'unknown') : undefined;
  const abortSource = input.status === 'cancelled' ? input.abortSource : undefined;
  await input.runStore.updateRun(
    input.sessionId,
    input.runId,
    {
      status: input.status,
      updatedAt: input.ts,
      completedAt: input.ts,
      ...(failureClass ? { failureClass } : {}),
      ...(input.failureMessage ? { failureMessage: input.failureMessage } : {}),
      ...(input.traceWriteError ? { traceWriteError: input.traceWriteError } : {}),
      ...(abortSource ? { abortSource } : {}),
    },
    { durable: true },
  );

  if (hasTerminalAgentRunEvent(input.existingEvents ?? [])) return;
  const data = terminalRunEventData(input.status, failureClass, input.runEventData);
  await input.runStore.appendEvent(
    input.sessionId,
    input.runId,
    {
      type: terminalAgentRunEventType(input.status),
      id: input.newId(),
      runId: input.runId,
      sessionId: input.sessionId,
      turnId: input.turnId,
      ts: input.ts,
      ...(input.runEventMessage ? { message: input.runEventMessage } : {}),
      ...(Object.keys(data).length > 0 ? { data } : {}),
    },
    { durable: true },
  );
}

export interface CommitOrCreateTerminalRunFactInput
  extends Omit<CommitTerminalRunWithRuntimeFactInput, 'status' | 'terminalEvent'> {