/** * @file Tests scripts/plugin-bootstrap.js — the SessionStart bootstrap that * makes a plugin install self-sufficient. Covers the fast path, the Node * version gate, stale-lock reclaim, legacy hook removal (the duplicate-hook * double-counting bug) and the CLI launcher's refusal to clobber a foreign * `agenthub`. Every path is exercised against injected temp directories — nothing * here touches the real $HOME. * @author Nguyễn Ngọc Trí Vĩ */ const { describe, it, beforeEach, after } = require("node:test"); const assert = require("node:assert/strict"); const fs = require("fs"); const os = require("os"); const path = require("path"); const TMP_HOME = fs.mkdtempSync(path.join(os.tmpdir(), "agenthub-bootstrap-")); process.env.CLAUDE_HOME = TMP_HOME; delete process.env.DASHBOARD_DATA_DIR; const boot = require("../../scripts/plugin-bootstrap"); const RT = path.join(TMP_HOME, "agenthub", "runtime"); function resetRuntime() { fs.rmSync(RT, { recursive: true, force: true }); fs.mkdirSync(RT, { recursive: true }); } after(() => { fs.rmSync(TMP_HOME, { recursive: true, force: true }); }); describe("serverIsLive", () => { const infoPath = path.join(TMP_HOME, ".agenthub.json"); beforeEach(() => fs.rmSync(infoPath, { force: true })); after(() => fs.rmSync(infoPath, { force: true })); it("is false with no discovery file at all", () => { // Regression: server-info's resolveAllDashboardPorts() falls back to // [DEFAULT_PORT] when nothing is live (a reasonable guess for the CLI), // which made the bootstrap wrongly believe a server was already running // and skip starting its own. assert.equal(boot.serverIsLive(), false); }); it("is false when every recorded pid is dead", () => { fs.writeFileSync( infoPath, JSON.stringify({ servers: [{ port: 4820, pid: 999999, startedAt: "x" }] }) ); assert.equal(boot.serverIsLive(), false); }); it("is true when a recorded pid is actually alive", () => { fs.writeFileSync( infoPath, JSON.stringify({ servers: [{ port: 4820, pid: process.pid, startedAt: "x" }] }) ); assert.equal(boot.serverIsLive(), true); assert.deepEqual(boot.liveServers(), [{ port: 4820, pid: process.pid, startedAt: "x" }]); }); it("ignores an entry started before this boot, even when its pid is alive (pid reuse)", () => { const beforeBoot = new Date(Date.now() - os.uptime() * 1000 - 3600_000).toISOString(); fs.writeFileSync( infoPath, JSON.stringify({ servers: [{ port: 4820, pid: process.pid, startedAt: beforeBoot }] }) ); assert.equal(boot.serverIsLive(), false); assert.deepEqual(boot.liveServers(), []); }); }); describe("runtime location", () => { it("lives under the shared data dir, not the plugin cache", () => { assert.equal(boot.runtimeDir(), RT); }); }); describe("node version gate", () => { it("refuses anything below 22.5 (node:sqlite is the only driver available)", () => { assert.equal(boot.nodeVersionOk("20.11.0"), false); assert.equal(boot.nodeVersionOk("22.4.1"), false); }); it("accepts 22.5 and newer", () => { assert.equal(boot.nodeVersionOk("22.5.0"), true); assert.equal(boot.nodeVersionOk("24.0.0"), true); }); }); describe("depsHash — only what npm installs", () => { function root(pkg, lock) { const dir = fs.mkdtempSync(path.join(os.tmpdir(), "agenthub-deps-")); fs.writeFileSync(path.join(dir, "package.json"), JSON.stringify(pkg)); fs.writeFileSync(path.join(dir, "package-lock.json"), JSON.stringify(lock)); return dir; } const pkg = (version, deps) => ({ name: "agenthub", version, dependencies: deps }); const lock = (version, deps) => ({ name: "agenthub", version, packages: { "": { name: "agenthub", version, dependencies: deps }, "node_modules/a": {} }, }); it("ignores a release's version bump", () => { // Every update reinstalled all runtime dependencies when only the version moved. const a = root(pkg("1.0.0", { a: "^1" }), lock("1.0.0", { a: "^1" })); const b = root(pkg("1.0.1", { a: "^1" }), lock("1.0.1", { a: "^1" })); assert.equal(boot.depsHash(a), boot.depsHash(b)); }); it("changes when a dependency does", () => { const a = root(pkg("1.0.0", { a: "^1" }), lock("1.0.0", { a: "^1" })); const b = root(pkg("1.0.0", { a: "^2" }), lock("1.0.0", { a: "^2" })); assert.notEqual(boot.depsHash(a), boot.depsHash(b)); }); }); describe("fast path", () => { beforeEach(resetRuntime); it("is false with no recorded state", () => { assert.equal(boot.fastPathOk(RT), false); }); it("is false when the recorded plugin version is stale", () => { fs.mkdirSync(path.join(RT, "node_modules"), { recursive: true }); boot.writeState({ pluginVersion: "0.0.0-old", depsHash: boot.depsHash() }, RT); assert.equal(boot.fastPathOk(RT), false); }); it("is false after a plugin update moved the install to a new cache dir", () => { const pkg = require("../../package.json"); fs.mkdirSync(path.join(RT, "node_modules"), { recursive: true }); boot.writeState( { pluginVersion: pkg.version, depsHash: boot.depsHash(), pluginRoot: "/old/plugin/cache/dir", }, RT ); assert.equal(boot.fastPathOk(RT), false); }); it("is false when node_modules is missing even if state matches", () => { const pkg = require("../../package.json"); boot.writeState({ pluginVersion: pkg.version, depsHash: boot.depsHash() }, RT); assert.equal(boot.fastPathOk(RT), false); }); it("is false while the skill-plugin check has never settled", () => { // A machine can be fully installed and still lack the plugins the // pipelines drive; the worker has to run once to find that out. const pkg = require("../../package.json"); fs.mkdirSync(path.join(RT, "node_modules"), { recursive: true }); boot.writeState( { pluginVersion: pkg.version, depsHash: boot.depsHash(), pluginRoot: path.resolve(__dirname, "..", ".."), }, RT ); assert.equal(boot.fastPathOk(RT), false); }); it("is false when the systemd unit still names a retired plugin root", () => { // The one failure a live server hides completely: everything is healthy // until the next reboot, and then the dashboard never comes back because // its unit points into a cache directory Claude Code has deleted. The fast // path has to reject it, or no SessionStart ever repairs it. // // Everything else here is deliberately HEALTHY — including a live server, // without which `fastPathOk` is false anyway and this test would pass // against the unfixed code. const ROOT = path.resolve(__dirname, "..", ".."); const pkg = require("../../package.json"); const infoPath = path.join(TMP_HOME, ".agenthub.json"); const prevHome = process.env.HOME; // HOME first: `unitPath()` resolves against it, and computing the path // before this line points every write in this test at the REAL // ~/.config/systemd/user/agenthub.service — which the cleanup below then // deletes. (Asked how I know.) process.env.HOME = TMP_HOME; const unit = require("../../scripts/systemd-service").unitPath("agenthub"); assert.ok( unit.startsWith(TMP_HOME + path.sep), `refusing to touch a unit outside the temp home: ${unit}` ); const writeUnit = (workingDir) => { fs.mkdirSync(path.dirname(unit), { recursive: true }); fs.writeFileSync( unit, "[Unit]\n# agenthub-managed-unit — regenerated on install, do not edit by hand\n" + `[Service]\nWorkingDirectory=${workingDir}\n`, "utf8" ); }; try { fs.mkdirSync(path.join(RT, "node_modules"), { recursive: true }); fs.writeFileSync( infoPath, JSON.stringify({ servers: [{ port: 4820, pid: process.pid, startedAt: "x" }] }) ); boot.writeState( { pluginVersion: pkg.version, depsHash: boot.depsHash(), pluginRoot: ROOT, }, RT ); // Control: a unit naming THIS root is the steady state — fast path taken. writeUnit(ROOT); assert.equal(boot.fastPathOk(RT), true, "a current unit must not block the fast path"); // The regression: same healthy install, unit left on a retired root. writeUnit("/plugins/cache/agenthub/deadbeef"); assert.equal(boot.fastPathOk(RT), false); } finally { fs.rmSync(infoPath, { force: true }); fs.rmSync(unit, { force: true }); if (prevHome === undefined) delete process.env.HOME; else process.env.HOME = prevHome; } }); }); describe("fast path after a Quit (issue #65)", () => { beforeEach(resetRuntime); it("starts nothing while the stopped flag is set, and starts again once it is gone", () => { const pkg = require("../../package.json"); const { markQuit, clearQuit } = require("../lib/quit"); const prevHome = process.env.HOME; process.env.HOME = TMP_HOME; // the real unit may name another root: stale try { fs.mkdirSync(path.join(RT, "node_modules"), { recursive: true }); boot.writeState( { pluginVersion: pkg.version, depsHash: boot.depsHash(), pluginRoot: path.resolve(__dirname, "..", ".."), }, RT ); // No server is live: without the flag the worker would start one. assert.equal(boot.fastPathOk(RT), false); markQuit(RT); assert.equal(boot.fastPathOk(RT), true); clearQuit(RT); assert.equal(boot.fastPathOk(RT), false); } finally { if (prevHome === undefined) delete process.env.HOME; else process.env.HOME = prevHome; } }); }); describe("bootstrap lock", () => { beforeEach(resetRuntime); it("is exclusive while held", () => { assert.equal(boot.acquireLock(RT), true); assert.equal(boot.acquireLock(RT), false, "a live lock must not be reclaimed"); boot.releaseLock(RT); assert.equal(fs.existsSync(boot.lockPath(RT)), false); }); it("reclaims a lock whose owner is dead", () => { fs.mkdirSync(boot.lockPath(RT), { recursive: true }); // PID 1 is alive but not ours; use an unused high pid instead. fs.writeFileSync(path.join(boot.lockPath(RT), "pid"), "999999", "utf8"); assert.equal(boot.lockIsStale(boot.lockPath(RT)), true); assert.equal(boot.acquireLock(RT), true); boot.releaseLock(RT); }); it("reclaims a lock older than the stale timeout even if its pid is alive", () => { fs.mkdirSync(boot.lockPath(RT), { recursive: true }); fs.writeFileSync(path.join(boot.lockPath(RT), "pid"), String(process.pid), "utf8"); const old = Date.now() - boot.LOCK_STALE_MS - 1000; fs.utimesSync(boot.lockPath(RT), old / 1000, old / 1000); assert.equal(boot.lockIsStale(boot.lockPath(RT)), true); assert.equal(boot.acquireLock(RT), true); boot.releaseLock(RT); }); it("treats a lock directory with no pid file as debris", () => { fs.mkdirSync(boot.lockPath(RT), { recursive: true }); assert.equal(boot.lockIsStale(boot.lockPath(RT)), true); }); }); describe("legacy hook cleanup", () => { const settings = path.join(TMP_HOME, "settings-legacy.json"); beforeEach(() => { fs.rmSync(settings, { force: true }); fs.rmSync(`${settings}.agenthub-bak`, { force: true }); }); it("reports a settings file that still carries checkout hooks", () => { // What fastPathOk consults on every SessionStart. The strip itself only // runs in the worker, so without this the one defect that DOUBLES every // event survives on an otherwise-healthy install forever. fs.writeFileSync(settings, JSON.stringify({ hooks: {} })); assert.equal(boot.hasLegacyHooks(settings), false); fs.writeFileSync( settings, JSON.stringify({ hooks: { PreToolUse: [ { matcher: "*", hooks: [{ type: "command", command: "node /other/tool.js" }] }, ], }, }) ); assert.equal(boot.hasLegacyHooks(settings), false, "an unrelated hook is not ours"); fs.writeFileSync( settings, JSON.stringify({ hooks: { PreToolUse: [ { matcher: "*", hooks: [ { type: "command", command: "node /repo/scripts/hook-handler.js PreToolUse" }, ], }, ], }, }) ); assert.equal(boot.hasLegacyHooks(settings), true); // Pure read: the caller is a hot path, and the file is the user's. assert.equal(fs.existsSync(`${settings}.agenthub-bak`), false); }); it("removes checkout-installed hook entries and backs the file up first", () => { fs.writeFileSync( settings, JSON.stringify({ hooks: { PreToolUse: [ { matcher: "*", hooks: [ { type: "command", command: "node /repo/scripts/hook-handler.js PreToolUse" }, ], }, { matcher: "*", hooks: [{ type: "command", command: "node /other/tool.js" }] }, ], SessionStart: [ { hooks: [ { type: "command", command: "node /repo/scripts/hook-handler.js SessionStart" }, ], }, ], }, }) ); const removed = boot.stripLegacyHooks(settings); assert.equal(removed, 2); const after = JSON.parse(fs.readFileSync(settings, "utf8")); assert.equal(after.hooks.PreToolUse.length, 1, "unrelated hooks must survive"); assert.match(JSON.stringify(after.hooks.PreToolUse), /other\/tool\.js/); assert.equal(after.hooks.SessionStart, undefined, "an emptied list is dropped"); assert.ok(fs.existsSync(`${settings}.agenthub-bak`), "must back up before writing"); }); it("never removes the plugin's own cache-resolved hook entries", () => { // Regression: `claude plugin install` materializes the plugin's inline // hooks into settings.json itself, with ${CLAUDE_PLUGIN_ROOT} resolved to // the cache path — confirmed against a real install. Those entries also // contain "hook-handler.js", so a naive substring check would strip them // right along with genuine checkout leftovers, killing the plugin's own // hooks on every session start. const cachePath = path.join( TMP_HOME, "plugins", "cache", "agenthub", "agenthub", "abc123", "scripts", "hook-handler.js" ); fs.writeFileSync( settings, JSON.stringify({ hooks: { PreToolUse: [ { matcher: "*", hooks: [{ type: "command", command: `node "${cachePath}" PreToolUse` }], }, { matcher: "*", hooks: [ { type: "command", command: "node /repo/scripts/hook-handler.js PreToolUse" }, ], }, ], }, }) ); const removed = boot.stripLegacyHooks(settings); assert.equal(removed, 1); const after = JSON.parse(fs.readFileSync(settings, "utf8")); assert.equal(after.hooks.PreToolUse.length, 1); assert.match(JSON.stringify(after.hooks.PreToolUse), /plugins.*cache/); }); it("leaves a file with no AgentHub hooks untouched and writes no backup", () => { fs.writeFileSync(settings, JSON.stringify({ hooks: { Stop: [{ hooks: [] }] } })); assert.equal(boot.stripLegacyHooks(settings), 0); assert.equal(fs.existsSync(`${settings}.agenthub-bak`), false); }); it("is a no-op when no settings file exists", () => { assert.equal(boot.stripLegacyHooks(path.join(TMP_HOME, "nope.json")), 0); }); }); describe("agenthub CLI launcher", () => { const bin = path.join(TMP_HOME, "bin"); const target = path.join(bin, process.platform === "win32" ? "agenthub.cmd" : "agenthub"); beforeEach(() => { fs.rmSync(bin, { recursive: true, force: true }); }); it("writes a launcher that points at the plugin's bin/agenthub.js", () => { assert.equal(boot.linkCli(bin), "written"); assert.match(fs.readFileSync(target, "utf8"), /bin[/\\]agenthub\.js/); }); it("is idempotent", () => { boot.linkCli(bin); assert.equal(boot.linkCli(bin), "exists"); }); it("never clobbers a agenthub it did not write (a linked checkout keeps winning)", () => { fs.mkdirSync(bin, { recursive: true }); fs.writeFileSync(target, '#!/bin/sh\nexec node /my/checkout/bin/agenthub.js "$@"\n'); assert.equal(boot.linkCli(bin), "foreign"); assert.match(fs.readFileSync(target, "utf8"), /my\/checkout/); }); it( "falls back to `node` on PATH when the pinned node binary is gone (brew upgrade)", { skip: process.platform === "win32" }, () => { const root = path.join(TMP_HOME, "fake-root"); fs.mkdirSync(path.join(root, "bin"), { recursive: true }); fs.writeFileSync( path.join(root, "bin", "agenthub.js"), "console.log('ran:' + process.argv.slice(2).join(','));\n" ); assert.equal(boot.linkCli(bin, root, "/nonexistent/Cellar/node/0.0.0/bin/node"), "written"); assert.match(fs.readFileSync(target, "utf8"), /\/nonexistent\/Cellar/); const out = require("child_process").execFileSync("sh", [target, "a", "b c"], { encoding: "utf8", env: { ...process.env, PATH: `${path.dirname(process.execPath)}:/usr/bin:/bin` }, }); assert.equal(out.trim(), "ran:a,b c"); } ); }); describe("plugin-open / plugin-bootstrap require cycle", () => { // bootstrap() lazily requires plugin-open for buildClient, and plugin-open // requires bootstrap at load. When plugin-open is the entry point (/agenthub-open) // that lazy require resolves to whatever sits on its module.exports at that // instant — so the assignment must come before the entry block that calls // bootstrap(), or /agenthub-open dies with "buildClient is not a function". const src = fs.readFileSync( path.join(__dirname, "..", "..", "scripts", "plugin-open.js"), "utf8" ); it("assigns module.exports before running the entry block", () => { const exportsAt = src.indexOf("module.exports ="); const entryAt = src.indexOf("require.main === module"); assert.ok(exportsAt !== -1 && entryAt !== -1); assert.ok(exportsAt < entryAt, "module.exports must be assigned before the entry block"); }); it("exposes buildClient to a bootstrap that requires it back", () => { assert.equal(typeof require("../../scripts/plugin-open").buildClient, "function"); }); }); describe("buildClient dependency install", () => { const { buildClient } = require("../../scripts/plugin-open"); // A fake plugin root holding just enough of a client/ to copy. function fakeRoot() { const root = fs.mkdtempSync(path.join(os.tmpdir(), "agenthub-root-")); fs.mkdirSync(path.join(root, "client")); fs.writeFileSync(path.join(root, "client", "package.json"), "{}"); return root; } // Records every invocation — npm's as its args, node's as `node