feat: Claude Code Monitor — lanes, pipelines and a merged workspace

Internal SmartGift build of a Claude Code monitoring dashboard. Lanes: a durable unit of parallel agent work, one per working directory, tracked across session restarts. Managed lanes are git worktrees the dashboard provisions and can reset or remove behind a three-check destroy guard and a counted preflight; adopted lanes are directories you already own and are never destroyable. Pipelines: a lane moves through pipeline stages. A stage the agent declares with evidence renders green; a stage inferred from the tool-event stream renders dashed amber and never counts as done. Detection is forward-only within a 30-minute window, and never writes the declared stage. Workspace: one page at /run with a lane grid, the selected lane's pipeline, and a full Claude console behind a disclosure.
2026-07-29 17:07:45 +07:00
commit 9413462bca
781 changed files with 220593 additions and 0 deletions
@@ -0,0 +1,50 @@
+/**
+ * @file remote-tools.ts
+ * @description MCP tools for Remote Data Sources — list configured SSH sources
+ * and trigger on-demand syncs so agents can operate remotes without the UI/CLI.
+ * @author Nguyễn Ngọc Trí Vĩ <vinnt@smartgift.vn>
+ */
+
+import { z } from "zod";
+import { createToolRegistrar } from "../../core/tool-registry.js";
+import { assertMutationsEnabled } from "../../policy/tool-guards.js";
+import type { ToolContext } from "../../types/tool-context.js";
+
+/**
+ * Registers remote-source tools against `/api/remote-sources/*`.
+ * List is read-only; sync tools require the mutations policy gate.
+ */
+export function registerRemoteTools(context: ToolContext): void {
+  const { api, logger, server, config } = context;
+  const register = createToolRegistrar(server, logger);
+
+  register(
+    "dashboard_list_remote_sources",
+    "List configured Remote Data Sources (SSH machines) with status and last sync.",
+    {},
+    async () => api.get("/api/remote-sources")
+  );
+
+  register(
+    "dashboard_sync_remote_source",
+    "Trigger an immediate SSH pull+import for one Remote Data Source by id.",
+    {
+      source_id: z.string().min(1).describe("Remote source id (src_…)"),
+    },
+    async (args) => {
+      assertMutationsEnabled(config);
+      const id = encodeURIComponent(args.source_id as string);
+      return api.post(`/api/remote-sources/${id}/sync`);
+    }
+  );
+
+  register(
+    "dashboard_sync_all_remote_sources",
+    "Trigger an immediate SSH pull+import for every enabled Remote Data Source.",
+    {},
+    async () => {
+      assertMutationsEnabled(config);
+      return api.post("/api/remote-sources/sync-all");
+    }
+  );
+}