import { formatErrorMessage } from "../../dist/infra/errors.js";

import { rawDataToString } from "../../dist/infra/ws.js";

import { readStringValue } from "../../dist/shared/string-coerce.js";

import { connectMcpWithTimeout } from "./mcp-connect-timeout.ts";

export const ClaudeChannelNotificationSchema = z.object({

method: z.literal("notifications/claude/channel"),

const GATEWAY_RPC_TIMEOUT_MS = 60_000;

const GATEWAY_REQUEST_TIMEOUT_MS = 45_000;

const GATEWAY_CONNECT_RETRY_WINDOW_MS = 420_000;

const MCP_CONNECT_TIMEOUT_MS = readPositiveInt(

process.env.OPENCLAW_MCP_CHANNELS_CONNECT_TIMEOUT_MS,

60_000,

);

export function assert(condition: unknown, message: string): asserts condition {

if (!condition) {

throw new Error(message);

}

}

function readPositiveInt(raw: string | undefined, fallback: number) {

const parsed = Number.parseInt(raw ?? "", 10);

return Number.isInteger(parsed) && parsed > 0 ? parsed : fallback;

}

export function extractTextFromGatewayPayload(

payload: Record<string, unknown> | undefined,

): string | undefined {

};

const client = new Client({ name: "docker-mcp-channels", version: "1.0.0" });

await client.connect(transport);

await connectMcpWithTimeout(client, transport, MCP_CONNECT_TIMEOUT_MS);

return { client, transport, rawMessages };

}