import { describe, expect, it, vi } from "vitest";

import { createClickClackClient } from "./http-client.js";

function streamedErrorResponse(body: string, limit: number) {

const encoded = new TextEncoder().encode(body);

let readCount = 0;

const cancel = vi.fn(async () => undefined);

const releaseLock = vi.fn();

const text = vi.fn(async () => {

throw new Error("raw response.text() should not be used");

});

const response = {

ok: false,

status: 502,

text,

body: {

getReader: () => ({

read: async () => {

if (readCount > 0) {

return { done: true, value: undefined };

}

readCount += 1;

return { done: false, value: encoded };

},

cancel,

releaseLock,

}),

},

} as unknown as Response;

return {

response,

cancel,

releaseLock,

text,

expectedDetail: body.slice(0, limit),

};

}

describe("ClickClack HTTP client", () => {

it("bounds error response bodies without using raw response.text()", async () => {

const streamed = streamedErrorResponse("x".repeat(9000), 8 * 1024);

const fetchMock = vi.fn(async () => streamed.response);

const client = createClickClackClient({

baseUrl: "https://clickclack.example",

token: "test-token",

fetch: fetchMock,

});

await expect(client.me()).rejects.toThrow(`ClickClack 502: ${streamed.expectedDetail}`);

expect(streamed.text).not.toHaveBeenCalled();

expect(streamed.cancel).toHaveBeenCalledTimes(1);

expect(streamed.releaseLock).toHaveBeenCalledTimes(1);

});

});

* Thin ClickClack REST/websocket client used by gateway, resolver, and outbound

* delivery code.

*/

import { readResponseTextLimited } from "openclaw/plugin-sdk/provider-http";

import { WebSocket } from "ws";

import type {

ClickClackChannel,

fetch?: typeof fetch;

};

const CLICKCLACK_ERROR_BODY_LIMIT_BYTES = 8 * 1024;

/**

* Creates a typed client for the ClickClack API using bearer-token auth.

*/

}

const response = await fetcher(`${baseUrl}${path}`, { ...init, headers: requestHeaders });

if (!response.ok) {

throw new Error(`ClickClack ${response.status}: ${await response.text()}`);

const detail = await readResponseTextLimited(response, CLICKCLACK_ERROR_BODY_LIMIT_BYTES);

throw new Error(`ClickClack ${response.status}: ${detail}`);

}

return (await response.json()) as T;

}