Function setup

packages/angular/src/lib/threads.spec.ts:126–172

* Sets up a TestBed with the stubbed CopilotKit service and a configurable * fetch mock, and returns helpers for driving the runtime and flushing async * work. Follows the SIFERS pattern.

()

 * work. Follows the SIFERS pattern.
 */
function setup() {
  TestBed.resetTestingModule();
  stub = new CopilotKitStub();
  const originalFetch = globalThis.fetch;
  const fetchMock = vi.fn<typeof fetch>();
  globalThis.fetch = fetchMock as unknown as typeof fetch;

  TestBed.configureTestingModule({
    providers: [{ provide: CopilotKit, useValue: stub }],
  });

  const connect = (
    options: {
      list?: boolean;
      mutations?: boolean;
      wsUrl?: string;
    } = {},
  ): void => {
    stub.setThreadEndpoints({
      list: options.list ?? true,
      inspect: true,
      mutations: options.mutations ?? true,
      realtimeMetadata: false,
    });
    if (options.wsUrl) {
      stub.setIntelligence({ wsUrl: options.wsUrl });
    }
    stub.setRuntimeUrl("https://runtime.local");
    stub.setRuntimeConnectionStatus(
      CopilotKitCoreRuntimeConnectionStatus.Connected,
    );
  };

  // Drains the microtask/macrotask queue so the rxjs fetch pipeline (defer →
  // fromFetch → json() → reducer) and the signal bridges settle.
  const flush = async (): Promise<void> => {
    for (let i = 0; i < 5; i += 1) {
      await new Promise((resolve) => setTimeout(resolve, 0));
    }
  };

  const teardown = (): void => {
    globalThis.fetch = originalFetch;
  };

  return { stub, fetchMock, connect, flush, teardown };
}

describe("injectThreads", () => {
  let active: ReturnType<typeof setup> | undefined;