Function snapshotInvocationRequest

packages/runtime/src/runtime-runner.ts:521–569

(
  request: InvocationRequest,
  known?: { continuation: InvocationRequest['continuation'] },
)

}

function snapshotInvocationRequest(
  request: InvocationRequest,
  known?: { continuation: InvocationRequest['continuation'] },
): InvocationRequest {
  const continuation = known ? known.continuation : request.continuation;
  const snapshot: InvocationRequest = {
    sessionId: request.sessionId,
    ...(request.invocationId !== undefined ? { invocationId: request.invocationId } : {}),
    ...(request.runId !== undefined ? { runId: request.runId } : {}),
    turnId: request.turnId,
    text: request.text,
    source: request.source,
    ...(request.orchestration !== undefined
      ? { orchestration: cloneAndFreezeSnapshotValue(request.orchestration) }
      : {}),
    ...(request.toolMode !== undefined ? { toolMode: request.toolMode } : {}),
    ...(request.maxSteps !== undefined ? { maxSteps: request.maxSteps } : {}),
    ...(request.attachments !== undefined
      ? { attachments: cloneAndFreezeSnapshotValue(request.attachments) }
      : {}),
    ...(request.quotes !== undefined
      ? { quotes: cloneAndFreezeSnapshotValue(request.quotes) }
      : {}),
    ...(request.inlineReferences !== undefined
      ? { inlineReferences: cloneAndFreezeSnapshotValue(request.inlineReferences) }
      : {}),
    ...(request.context !== undefined
      ? { context: cloneAndFreezeSnapshotValue(request.context) }
      : {}),
    ...(request.runtimeContext !== undefined
      ? { runtimeContext: cloneAndFreezeSnapshotValue(request.runtimeContext) }
      : {}),
    ...(continuation !== undefined
      ? { continuation: cloneAndFreezeSnapshotValue(continuation) }
      : {}),
    ...(request.initialRuntimeEvent !== undefined
      ? { initialRuntimeEvent: cloneAndFreezeSnapshotValue(request.initialRuntimeEvent) }
      : {}),
    ...(request.branch !== undefined ? { branch: request.branch } : {}),
    ...(request.lineage !== undefined
      ? { lineage: cloneAndFreezeSnapshotValue(request.lineage) }
      : {}),
    ...(request.pullSteering !== undefined ? { pullSteering: request.pullSteering } : {}),
    ...(request.ackSteering !== undefined ? { ackSteering: request.ackSteering } : {}),
    ...(request.nackSteering !== undefined ? { nackSteering: request.nackSteering } : {}),
    ...(request.abortSignal !== undefined ? { abortSignal: request.abortSignal } : {}),
  };
  return Object.freeze(snapshot);
}

function cloneAndFreezeSnapshotValue<T>(value: T): T {
  if (Array.isArray(value)) {