import { existsSync } from "node:fs"; import { SwarmServerClient, healthSupportsDirectHarnessSpawn, resolveSwarmServerSocketPath } from "./swarmServerClient.ts";
/**
- Operator-facing observability for
swarm-server, the Rust control-plane - daemon shipped with
swarm-mcp. swarm-server is what gives Clanky-spawned - coding workers terminal visibility / takeover / replay in
swarm-uiand swarm-ios. When it is down or missing direct-spawn capabilities, Clanky- fails fast unless the operator explicitly enables headless direct-child
- fallback.
- This module is the cheap "is it up?" surface for the bot startup log and
- the dashboard widget. The richer client capabilities (spawn / close /
- state) live in
swarmServerClient.ts. */
export type SwarmServerStatus = { available: boolean; directSpawnSupported: boolean; socketPath: string; /** Operator-facing hint when the daemon is unreachable. */ hint?: string; };
/**
- Synchronous existence check. Cheap; useful when the caller only needs to
- know "is the socket file there at all?" — e.g. boot-time logging that
- shouldn't block on a network round-trip. */ export function swarmServerSocketExists(dbPath?: string | null): boolean { return existsSync(resolveSwarmServerSocketPath(dbPath || "")); }
/**
- Asynchronous probe via the daemon's
/healthendpoint. Returns available: trueonly when swarm-server actually responds withok: true,- not just when the socket file exists. Resolves quickly (<= 1.5s default
- client timeout) — safe for boot-time use. */ export async function getSwarmServerStatus(dbPath?: string | null): Promise { const client = new SwarmServerClient({ dbPath }); const socketPath = client.socketPath;
if (!swarmServerSocketExists(dbPath)) {
return {
available: false,
directSpawnSupported: false,
socketPath,
hint:
"swarm-server is not running. Code workers require swarm-server PTY launch unless direct-child fallback is enabled. " +
"Open swarm-ui (auto-starts the daemon) or run swarm-server directly to enable terminal visibility."
};
}
try {
const health = await client.getHealth();
if (health?.ok === true && Number(health.v) === 1) {
const directSpawnSupported = healthSupportsDirectHarnessSpawn(health);
if (directSpawnSupported) {
return { available: true, directSpawnSupported: true, socketPath };
}
return {
available: true,
directSpawnSupported: false,
socketPath,
hint:
"swarm-server is running, but it does not advertise direct PTY spawn capabilities. " +
"Restart/rebuild the current swarm-ui/swarm-server so /health includes pty.spawn.args, pty.spawn.env, and pty.spawn.initial_input."
};
}
return {
available: false,
directSpawnSupported: false,
socketPath,
hint:
Socket ${socketPath} exists but the daemon did not respond with a healthy /health. +
"Stale socket from a crashed swarm-server? Try restarting it."
};
} catch {
return {
available: false,
directSpawnSupported: false,
socketPath,
hint:
Socket ${socketPath} exists but the daemon did not respond with a healthy /health. +
"Stale socket from a crashed or incompatible swarm-server? Try restarting it."
};
}
}
/**
- Format a single human-readable status line. Used at bot startup.
*/
export function formatSwarmServerStatusLine(status: SwarmServerStatus): string {
if (status.available) {
if (status.directSpawnSupported) {
return "swarm-server: running ✓ — code workers will be visible/interactive in swarm-ui/swarm-ios";
}
return
swarm-server: running but not PTY-spawn capable ✗ — ${status.hint || "restart/rebuild swarm-ui or swarm-server"}; } returnswarm-server: not running ✗ — ${status.hint || "code workers require swarm-server PTY launch"}; }