openclaw/extensions/qa-lab/src/lab-server-capture.test.ts

import { createServer } from "node:http";
import { afterEach, describe, expect, it } from "vitest";
import { mapCaptureEventForQa, probeTcpReachability } from "./lab-server-capture.js";

const cleanups: Array<() => Promise<void>> = [];

afterEach(async () => {
  while (cleanups.length > 0) {
    await cleanups.pop()?.();
  }
});

describe("qa-lab server capture helpers", () => {
  it("maps capture rows into QA-friendly fields", () => {
    expect(
      mapCaptureEventForQa({
        flowId: "flow-1",
        dataText: '{"hello":"world"}',
        metaJson: JSON.stringify({
          provider: "openai",
          api: "responses",
          model: "gpt-5.5",
          captureOrigin: "shared-fetch",
        }),
      }),
    ).toEqual(
      expect.objectContaining({
        flowId: "flow-1",
        payloadPreview: '{"hello":"world"}',
        provider: "openai",
        api: "responses",
        model: "gpt-5.5",
        captureOrigin: "shared-fetch",
      }),
    );
  });

  it("probes tcp reachability for reachable and unreachable targets", async () => {
    const server = createServer((_req, res) => {
      res.writeHead(200);
      res.end("ok");
    });
    await new Promise<void>((resolve, reject) => {
      server.once("error", reject);
      server.listen(0, "127.0.0.1", () => resolve());
    });
    cleanups.push(
      async () =>
        await new Promise<void>((resolve, reject) =>
          server.close((error) => (error ? reject(error) : resolve())),
        ),
    );

    const address = server.address();
    if (!address || typeof address === "string") {
      throw new Error("expected tcp probe address");
    }

    await expect(probeTcpReachability(`http://127.0.0.1:${address.port}`)).resolves.toEqual(
      expect.objectContaining({
        ok: true,
      }),
    );
    await expect(probeTcpReachability("http://127.0.0.1:9", 50)).resolves.toEqual(
      expect.objectContaining({
        ok: false,
      }),
    );
  });
});