Function processCleanupStream

src/node/services/streamManager.test.ts:1031–1061

(params: {
    workspaceId: string;
    messageId: string;
    model: LanguageModel;
    streamInfoOverrides?: Record<string, unknown>;
  })

  }

  async function processCleanupStream(params: {
    workspaceId: string;
    messageId: string;
    model: LanguageModel;
    streamInfoOverrides?: Record<string, unknown>;
  }): Promise<void> {
    const streamManager = new StreamManager(historyService);
    streamManager.on("error", () => undefined);
    const historySequence = 1;

    await appendPartialAssistantForTests(params.workspaceId, params.messageId, historySequence);

    const streamInfo = createStreamInfoForTests({
      messageId: params.messageId,
      token: `${params.messageId}-token`,
      model: "openai:gpt-4.1-mini",
      metadataModel: "openai:gpt-4.1-mini",
      historySequence,
      request: { model: params.model, messages: [], providerOptions: undefined },
      runtime,
      ...params.streamInfoOverrides,
    });
    getWorkspaceStreamsForTests(streamManager).set(params.workspaceId, streamInfo);

    await getProcessStreamWithCleanupForTests(streamManager).call(
      streamManager,
      params.workspaceId,
      streamInfo,
      historySequence
    );
  }

  const cleanupLifecycleCases: Array<{
    name: string;