diff --git a/src/gateway/protocol/client-info.ts b/src/gateway/protocol/client-info.ts index 54720bcc5..3831cd0c8 100644 --- a/src/gateway/protocol/client-info.ts +++ b/src/gateway/protocol/client-info.ts @@ -5,6 +5,7 @@ export const GATEWAY_CLIENT_IDS = { CLI: "cli", GATEWAY_CLIENT: "gateway-client", MACOS_APP: "clawdbot-macos", + IOS_APP: "clawdbot-ios", NODE_HOST: "node-host", TEST: "test", FINGERPRINT: "fingerprint", diff --git a/src/gateway/server.ios-client-id.test.ts b/src/gateway/server.ios-client-id.test.ts new file mode 100644 index 000000000..6b8d71aee --- /dev/null +++ b/src/gateway/server.ios-client-id.test.ts @@ -0,0 +1,65 @@ +import { test } from "vitest"; +import WebSocket from "ws"; + +import { PROTOCOL_VERSION } from "./protocol/index.js"; +import { getFreePort, onceMessage, startGatewayServer } from "./test-helpers.server.js"; + +function connectReq( + ws: WebSocket, + params: { token?: string; password?: string } = {}, +): Promise<{ ok: boolean; error?: { message?: string } }> { + const id = `c-${Math.random().toString(16).slice(2)}`; + ws.send( + JSON.stringify({ + type: "req", + id, + method: "connect", + params: { + minProtocol: PROTOCOL_VERSION, + maxProtocol: PROTOCOL_VERSION, + client: { + id: "clawdbot-ios", + version: "dev", + platform: "ios", + mode: "node", + }, + auth: { + token: params.token, + password: params.password, + }, + role: "node", + scopes: [], + caps: ["canvas"], + commands: ["system.notify"], + permissions: {}, + }, + }), + ); + + return onceMessage( + ws, + (o) => (o as { type?: string }).type === "res" && (o as { id?: string }).id === id, + ); +} + +test("accepts clawdbot-ios as a valid gateway client id", async () => { + const port = await getFreePort(); + const server = await startGatewayServer(port); + const ws = new WebSocket(`ws://127.0.0.1:${port}`); + await new Promise((resolve) => ws.once("open", resolve)); + + const res = await connectReq(ws); + // We don't care if auth fails here; we only care that schema validation accepts the client id. + // A schema rejection would close the socket before sending a response. + if (!res.ok) { + // allow unauthorized error when gateway requires auth + // but reject schema validation errors + const message = String(res.error?.message ?? ""); + if (message.includes("invalid connect params")) { + throw new Error(message); + } + } + + ws.close(); + await server.close(); +});