Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ee585a8370 | ||
|
|
1f078bf0c8 |
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "claudemesh-cli",
|
||||
"version": "0.5.6",
|
||||
"version": "0.5.7",
|
||||
"description": "Claude Code MCP client for claudemesh — peer mesh messaging between Claude sessions.",
|
||||
"keywords": [
|
||||
"claude-code",
|
||||
|
||||
@@ -445,11 +445,14 @@ Your message mode is "${messageMode}".
|
||||
if (!existsSync(filePath)) return text(`share_file: file not found: ${filePath}`, true);
|
||||
const client = allClients()[0];
|
||||
if (!client) return text("share_file: not connected", true);
|
||||
try {
|
||||
const fileId = await client.uploadFile(filePath, client.meshId, client.meshSlug, {
|
||||
name: fileName, tags, persistent: true,
|
||||
});
|
||||
if (!fileId) return text("share_file: upload failed", true);
|
||||
return text(`Shared: ${fileName ?? filePath} (${fileId})`);
|
||||
} catch (e) {
|
||||
return text(`share_file: upload failed — ${e instanceof Error ? e.message : String(e)}`, true);
|
||||
}
|
||||
}
|
||||
|
||||
case "get_file": {
|
||||
@@ -856,7 +859,21 @@ Your message mode is "${messageMode}".
|
||||
});
|
||||
}
|
||||
|
||||
// Event loop keepalive: Node.js stdout to a pipe is buffered. Without
|
||||
// periodic event loop activity, stdout.write() from WS callbacks may not
|
||||
// flush until the next I/O event. This 1s interval keeps the event loop
|
||||
// ticking so channel notifications flush promptly — same pattern that made
|
||||
// claude-intercom's push delivery reliable (its 1s HTTP poll had this
|
||||
// effect as a side effect). The interval does nothing except prevent the
|
||||
// event loop from settling.
|
||||
const keepalive = setInterval(() => {
|
||||
// Intentionally empty — the interval itself keeps the event loop active.
|
||||
// Do NOT call .unref() — that would defeat the purpose.
|
||||
}, 1_000);
|
||||
void keepalive; // suppress unused warning
|
||||
|
||||
const shutdown = (): void => {
|
||||
clearInterval(keepalive);
|
||||
stopAll();
|
||||
process.exit(0);
|
||||
};
|
||||
|
||||
@@ -526,8 +526,11 @@ export class BrokerClient {
|
||||
body: data,
|
||||
signal: AbortSignal.timeout(30_000),
|
||||
});
|
||||
const body = await res.json() as { ok?: boolean; fileId?: string };
|
||||
return body.fileId ?? null;
|
||||
const body = await res.json() as { ok?: boolean; fileId?: string; error?: string };
|
||||
if (!res.ok || !body.fileId) {
|
||||
throw new Error(body.error ?? `HTTP ${res.status}`);
|
||||
}
|
||||
return body.fileId;
|
||||
}
|
||||
|
||||
// --- Vectors ---
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
"private": true,
|
||||
"type": "module",
|
||||
"scripts": {
|
||||
"build": "next build",
|
||||
"build": "next build --no-turbopack",
|
||||
"clean": "git clean -xdf .cache .next .turbo node_modules",
|
||||
"dev": "next dev",
|
||||
"format": "prettier --check . --ignore-path ../../.gitignore",
|
||||
|
||||
Reference in New Issue
Block a user