diff --git a/CHANGELOG.md b/CHANGELOG.md index e3cc4a8e8..b00bfe9df 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,6 +4,7 @@ - macOS: add node bridge heartbeat pings to detect half-open sockets and reconnect cleanly. (#572) — thanks @ngutman - Node bridge: harden keepalive + heartbeat handling (TCP keepalive, better disconnects, and keepalive config tests). (#577) — thanks @steipete +- Control UI: improve mobile responsiveness. (#558) — thanks @carlulsoe - CLI: add `sandbox list` and `sandbox recreate` commands for managing Docker sandbox containers after image/config updates. (#563) — thanks @pasogott - Providers: add Microsoft Teams provider with polling, attachments, and CLI send support. (#404) — thanks @onutc - Commands: accept /models as an alias for /model. diff --git a/src/auto-reply/reply.triggers.test.ts b/src/auto-reply/reply.triggers.test.ts index c4c67945a..c12b1e543 100644 --- a/src/auto-reply/reply.triggers.test.ts +++ b/src/auto-reply/reply.triggers.test.ts @@ -56,7 +56,11 @@ async function withTempHome(fn: (home: string) => Promise): Promise { const previousUserProfile = process.env.USERPROFILE; const previousHomeDrive = process.env.HOMEDRIVE; const previousHomePath = process.env.HOMEPATH; + const previousStateDir = process.env.CLAWDBOT_STATE_DIR; + const previousClawdisStateDir = process.env.CLAWDIS_STATE_DIR; process.env.HOME = base; + process.env.CLAWDBOT_STATE_DIR = join(base, ".clawdbot"); + process.env.CLAWDIS_STATE_DIR = join(base, ".clawdbot"); if (process.platform === "win32") { process.env.USERPROFILE = base; const driveMatch = base.match(/^([A-Za-z]:)(.*)$/); @@ -74,6 +78,8 @@ async function withTempHome(fn: (home: string) => Promise): Promise { process.env.USERPROFILE = previousUserProfile; process.env.HOMEDRIVE = previousHomeDrive; process.env.HOMEPATH = previousHomePath; + process.env.CLAWDBOT_STATE_DIR = previousStateDir; + process.env.CLAWDIS_STATE_DIR = previousClawdisStateDir; await fs.rm(base, { recursive: true, force: true }); } } diff --git a/src/infra/bridge/server.test.ts b/src/infra/bridge/server.test.ts index c60de4ca5..fe320d8f1 100644 --- a/src/infra/bridge/server.test.ts +++ b/src/infra/bridge/server.test.ts @@ -46,6 +46,14 @@ function sendLine(socket: net.Socket, obj: unknown) { socket.write(`${JSON.stringify(obj)}\n`); } +async function waitForSocketConnect(socket: net.Socket) { + if (!socket.connecting) return; + await new Promise((resolve, reject) => { + socket.once("connect", resolve); + socket.once("error", reject); + }); +} + describe("node bridge server", () => { let baseDir = ""; @@ -156,6 +164,7 @@ describe("node bridge server", () => { }); const socket = net.connect({ host: "127.0.0.1", port: server.port }); + await waitForSocketConnect(socket); const readLine = createLineReader(socket); sendLine(socket, { type: "pair-request", nodeId: "n2", platform: "ios" }); @@ -189,6 +198,7 @@ describe("node bridge server", () => { socket.destroy(); const socket2 = net.connect({ host: "127.0.0.1", port: server.port }); + await waitForSocketConnect(socket2); const readLine2 = createLineReader(socket2); sendLine(socket2, { type: "hello", nodeId: "n2", token }); const line3 = JSON.parse(await readLine2()) as { type: string }; @@ -239,6 +249,7 @@ describe("node bridge server", () => { }); const socket = net.connect({ host: "127.0.0.1", port: server.port }); + await waitForSocketConnect(socket); const readLine = createLineReader(socket); sendLine(socket, { type: "pair-request", @@ -248,7 +259,7 @@ describe("node bridge server", () => { // Approve the pending request from the gateway side. let reqId: string | undefined; - for (let i = 0; i < 40; i += 1) { + for (let i = 0; i < 120; i += 1) { const list = await listNodePairing(baseDir); const req = list.pending.find((p) => p.nodeId === "n3-rpc"); if (req) {