Function createStreamInfoForTests

src/node/services/streamManager.test.ts:185–226

(
  overrides: Record<string, unknown> = {}
)

}

function createStreamInfoForTests(
  overrides: Record<string, unknown> = {}
): Record<string, unknown> {
  const now = Date.now();
  const model = overrides.model ?? TEST_STREAM_MODEL_ID;
  return {
    state: "streaming",
    streamResult: createStreamResultForTests(
      (async function* emptyStream() {
        await Promise.resolve();
        yield* [];
      })()
    ),
    abortController: new AbortController(),
    messageId: "test-message",
    token: "test-token",
    startTime: now,
    lastPartTimestamp: now,
    toolCompletionTimestamps: new Map<string, number>(),
    pendingWorkflowRunAttachments: new Map<string, unknown>(),
    model,
    metadataModel: overrides.metadataModel ?? model,
    historySequence: 1,
    request: { model: createTestLanguageModel(), messages: [], providerOptions: undefined },
    toolModelUsages: [],
    parts: [],
    lastPartialWriteTime: 0,
    partialWriteTimer: undefined,
    partialWritePromise: undefined,
    processingPromise: Promise.resolve(),
    softInterrupt: { pending: false as const },
    runtimeTempDir: "",
    runtime: LOCAL_TEST_RUNTIME,
    cumulativeUsage: { inputTokens: 0, outputTokens: 0, totalTokens: 0 },
    cumulativeProviderMetadata: undefined,
    didRetryPreviousResponseIdAtStep: false,
    receivedTerminalEvent: false,
    currentStepStartIndex: 0,
    stepTracker: {},
    ...overrides,
  };
}

describe("StreamManager - workflow run attachments", () => {
  test("persists attached workflow run metadata to partial immediately", async () => {