import net from "node:net";

import path from "node:path";

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

import { MAX_TIMER_TIMEOUT_MS } from "../shared/number-coercion.js";

import { withTempDir } from "../test-helpers/temp-dir.js";

import { requestJsonlSocket } from "./jsonl-socket.js";

import { requestJsonlSocket, testApi } from "./jsonl-socket.js";

async function listenOnSocket(server: net.Server, socketPath: string): Promise<boolean> {

try {

}

describe.runIf(process.platform !== "win32")("requestJsonlSocket", () => {

it("caps oversized socket timeouts before arming the watchdog", () => {

expect(testApi.resolveJsonlSocketTimeoutMs(Number.MAX_SAFE_INTEGER)).toBe(MAX_TIMER_TIMEOUT_MS);

});

it("ignores malformed and non-accepted lines until one is accepted", async () => {

await withTempDir({ prefix: "openclaw-jsonl-socket-" }, async (dir) => {

const socketPath = path.join(dir, "socket.sock");

import net from "node:net";

import { clearTimeout as clearNodeTimeout, setTimeout as setNodeTimeout } from "node:timers";

import { resolveTimerTimeoutMs } from "../shared/number-coercion.js";

/**

* Sends one JSONL request line, half-closes the write side, and waits for an accepted response line.

*/

function resolveJsonlSocketTimeoutMs(timeoutMs: number): number {

return resolveTimerTimeoutMs(timeoutMs, 1);

}

export async function requestJsonlSocket<T>(params: {

socketPath: string;

requestLine: string;

timeoutMs: number;

accept: (msg: unknown) => T | null | undefined;

}): Promise<T | null> {

const { socketPath, requestLine, timeoutMs, accept } = params;

const { socketPath, requestLine, accept } = params;

const timeoutMs = resolveJsonlSocketTimeoutMs(params.timeoutMs);

return await new Promise((resolve) => {

const client = new net.Socket();

let settled = false;

});

});

}

export const testApi = { resolveJsonlSocketTimeoutMs };

export { testApi as __test__ };