Function streamAndGetStartStreamArgs

src/node/services/aiService.test.ts:3051–3072

(
    harness: ModelParameterOverridesHarness,
    workspaceId: string,
    modelString = ANTHROPIC_MODEL
  )

  }

  async function streamAndGetStartStreamArgs(
    harness: ModelParameterOverridesHarness,
    workspaceId: string,
    modelString = ANTHROPIC_MODEL
  ): Promise<unknown[]> {
    const result = await harness.service.streamMessage({
      messages: [createMuxMessage("user-message", "user", "hello")],
      workspaceId,
      modelString,
      thinkingLevel: "off",
    });

    expect(result.success).toBe(true);
    expect(harness.startStreamCalls).toHaveLength(1);

    const startStreamCall = harness.startStreamCalls[0];
    if (!startStreamCall) {
      throw new Error("Expected streamManager.startStream call arguments");
    }

    return startStreamCall;
  }

  afterEach(() => {
    mock.restore();