Shared memory and context tools for agentic work.
Code Rooms
"use strict";
const assert = require("node:assert/strict");
const fs = require("node:fs");
const os = require("node:os");
const path = require("node:path");
const { spawnSync } = require("node:child_process");
const test = require("node:test");
const { agentRuntimeCacheTarget } = require("../lib/agent-runtime-cache");
const CLI = path.resolve(__dirname, "../bin/m1nd.js");
const POSIX_SHEBANG_ONLY = {
skip: process.platform === "win32" && "POSIX shebang fixture cannot be spawned by Windows CreateProcess",
};
test("startup failure keeps the primary error when teardown also fails", POSIX_SHEBANG_ONLY, () => {
const fixture = fs.mkdtempSync(path.join(os.tmpdir(), "m1nd-agent-startup-diagnostic-"));
try {
const repo = path.join(fixture, "repo-alpha");
const binary = path.join(fixture, "failing-m1nd-mcp.js");
const cache = path.join(fixture, "cache");
fs.mkdirSync(repo, { recursive: true });
fs.writeFileSync(path.join(repo, "signal.js"), "export const startup_signal = 1;\n");
fs.writeFileSync(
binary,
`#!${process.execPath}\n` +
`"use strict";\n` +
`if (process.argv.includes("--version")) { console.log("m1nd-mcp 1.6.3"); process.exit(0); }\n` +
`let answered = false;\n` +
`process.stdin.on("data", () => {\n` +
` if (answered) return;\n` +
` answered = true;\n` +
` process.stderr.write("fixture-primary-stderr\\n");\n` +
` process.stdout.write("{not-json}\\n");\n` +
`});\n` +
`process.stdin.on("end", () => {\n` +
` process.stderr.write("fixture-cleanup-stderr\\n");\n` +
` process.exit(1);\n` +
`});\n`,
{ mode: 0o700 }
);
const env = {
HOME: path.join(fixture, "home"),
TMPDIR: path.join(fixture, "tmp"),
TMP: path.join(fixture, "tmp"),
TEMP: path.join(fixture, "tmp"),
PATH: process.env.PATH || "/usr/bin:/bin",
XDG_CACHE_HOME: cache,
M1ND_AGENT_CACHE_DIR: cache,
M1ND_REGISTRY_DIR: path.join(fixture, "registry"),
NPM_CONFIG_OFFLINE: "true",
NPM_CONFIG_UPDATE_NOTIFIER: "false",
for (const key of ["HOME", "TMPDIR", "XDG_CACHE_HOME", "M1ND_REGISTRY_DIR"]) {
fs.mkdirSync(env[key], { recursive: true });
}
const target = agentRuntimeCacheTarget(repo, env);
const run = spawnSync(
process.execPath,
[CLI, "agent", "first-minute", "--repo", repo, "--binary", binary, "--query", "startup_signal", "--no-attach", "--json"],
{ encoding: "utf8", timeout: 15_000, env }
assert.equal(run.signal, null, run.stderr);
assert.equal(run.status, 1, "the failed runtime was reported as success");
assert.match(run.stderr, /invalid MCP JSON response/, "the primary protocol failure was lost");
assert.match(run.stderr, /child teardown was not clean: exit=1 signal=none/, "cleanup failure was lost");
assert.match(run.stderr, /fixture-primary-stderr/, "native stderr before the protocol failure was lost");
assert.match(run.stderr, /fixture-cleanup-stderr/, "native stderr during cleanup was lost");
assert.equal(
fs.existsSync(path.join(target.runtimeDir, ".agent-cache-owner-v1")),
false,
"a child that has exited cannot strand its automatic cache lease"
} finally {
fs.rmSync(fixture, { recursive: true, force: true });
});
test("unconfirmed child close retains owner lease and blocks another CLI", POSIX_SHEBANG_ONLY, () => {
const fixture = fs.mkdtempSync(path.join(os.tmpdir(), "m1nd-agent-unconfirmed-close-"));
const repo = path.join(fixture, "repo");
const preload = path.join(fixture, "unconfirmed-close.cjs");
fs.mkdirSync(repo);
fs.writeFileSync(path.join(repo, "signal.js"), "export const signal = 1;\n");
fs.writeFileSync(binary,
`#!${process.execPath}\nprocess.stdin.once("data", () => process.stdout.write("{not-json}\\n")); process.stdin.on("end", () => process.exit(0));\n`,
{ mode: 0o700 });
fs.writeFileSync(preload,
`const { McpRuntimeClient } = require(${JSON.stringify(path.resolve(__dirname, "../lib/mcp-runtime-client.js"))});\n` +
`McpRuntimeClient.prototype.closeAndWait = async function () { this.proc.stdin.end(); throw new Error("child streams did not close after EOF, SIGTERM, and SIGKILL"); };\n`);
HOME: path.join(fixture, "home"), TMPDIR: path.join(fixture, "tmp"),
PATH: process.env.PATH || "/usr/bin:/bin", XDG_CACHE_HOME: cache,
M1ND_AGENT_CACHE_DIR: cache, M1ND_REGISTRY_DIR: path.join(fixture, "registry"),
NODE_OPTIONS: `--require=${preload}`,
for (const key of ["HOME", "TMPDIR", "XDG_CACHE_HOME", "M1ND_REGISTRY_DIR"]) fs.mkdirSync(env[key], { recursive: true });
const args = [CLI, "agent", "first-minute", "--repo", repo, "--binary", binary,
"--query", "signal", "--no-attach", "--json"];
const first = spawnSync(process.execPath, args, { encoding: "utf8", timeout: 15_000, env });
assert.equal(first.status, 1, first.stderr);
assert.match(first.stderr, /child streams did not close/);
assert.equal(fs.existsSync(path.join(target.runtimeDir, ".agent-cache-owner-v1")), true,
"without confirmed child termination the owner proof must remain");
const second = spawnSync(process.execPath, args,
{ encoding: "utf8", timeout: 15_000, env: { ...env, NODE_OPTIONS: "", M1ND_AGENT_CACHE_OWNER_WAIT_MS: "1000" } });
assert.equal(second.status, 1, second.stderr);
assert.match(second.stderr, /agent runtime cache is busy/);
test(
"asynchronous EACCES spawn failure reports the cause and releases its cache lease",
{ skip: process.platform === "win32" },
() => {
const fixture = fs.mkdtempSync(path.join(os.tmpdir(), "m1nd-agent-spawn-eacces-"));
const binary = path.join(fixture, "not-executable-m1nd-mcp");
fs.writeFileSync(binary, "not executable\n", { mode: 0o600 });
assert.equal(run.status, 1, `spawn failure exited ${run.status}: ${run.stderr}\n${run.stdout}`);
assert.match(run.stderr, /m1nd-mcp spawn failed: EACCES/, run.stderr);
"a failed spawn left a cache lease behind"
"synchronous ENOEXEC spawn failure reports the cause and releases its cache lease",
const fixture = fs.mkdtempSync(path.join(os.tmpdir(), "m1nd-agent-spawn-enoexec-"));
const binary = path.join(fixture, "invalid-m1nd-mcp");
const preload = path.join(fixture, "throw-enoexec.cjs");
fs.writeFileSync(binary, "not an executable format\n", { mode: 0o700 });
fs.writeFileSync(preload, [
`const childProcess = require("node:child_process");`,
`const originalSpawn = childProcess.spawn;`,
`childProcess.spawn = function(file) {`,
` if (file === ${JSON.stringify(binary)}) {`,
` const error = new Error("fixture-ENOEXEC");`,
` error.code = "ENOEXEC";`,
` throw error;`,
` }`,
` return originalSpawn.apply(this, arguments);`,
`};`,
].join("\n"));
assert.match(run.stderr, /m1nd-mcp spawn failed: ENOEXEC/, run.stderr);
test("stdin EPIPE rejects startup and releases its confirmed cache lease", POSIX_SHEBANG_ONLY, () => {
const fixture = fs.mkdtempSync(path.join(os.tmpdir(), "m1nd-agent-stdin-epipe-"));
const binary = path.join(fixture, "idle-m1nd-mcp.js");
const preload = path.join(fixture, "broken-pipe.cjs");
`if (process.argv.includes("--version")) { console.log("m1nd-mcp 1.6.4"); process.exit(0); }\n` +
`process.stdin.resume();\n`, { mode: 0o700 });
`const { McpRuntimeClient } = require(${JSON.stringify(path.resolve(__dirname, "../lib/mcp-runtime-client.js"))});`,
`const realStart = McpRuntimeClient.prototype.start;`,
`McpRuntimeClient.prototype.start = function () {`,
` const pendingStart = realStart.call(this);`,
` this.proc.prependOnceListener("spawn", () => {`,
` const stdin = this.proc.stdin;`,
` stdin.write = () => {`,
` process.nextTick(() => stdin.emit("error", Object.assign(new Error("fixture-EPIPE"), { code: "EPIPE" })));`,
` return false;`,
` };`,
` });`,
` return pendingStart;`,
const run = spawnSync(process.execPath,
[CLI, "agent", "first-minute", "--repo", repo, "--binary", binary, "--query", "signal", "--no-attach", "--json"],
{ encoding: "utf8", timeout: 15_000, env });
assert.equal(run.status, 1, run.stderr);
assert.doesNotMatch(run.stderr, /Unhandled 'error' event/, run.stderr);
assert.match(run.stderr, /fixture-EPIPE/, run.stderr);
assert.equal(fs.existsSync(path.join(target.runtimeDir, ".agent-cache-owner-v1")), false,
"a failed startup with a closed child must not strand its cache lease");
test("reused-cache refresh refusal is an honest failing envelope before trust", POSIX_SHEBANG_ONLY, () => {
const fixture = fs.mkdtempSync(path.join(os.tmpdir(), "m1nd-agent-refresh-refusal-"));
const binary = path.join(fixture, "refusing-m1nd-mcp.js");
`const readline = require("node:readline");\n` +
`const rl = readline.createInterface({ input: process.stdin });\n` +
`rl.on("line", (line) => {\n` +
` const req = JSON.parse(line);\n` +
` let result = {};\n` +
` if (req.method === "tools/list") result = { tools: [{ name: "ingest" }, { name: "trust_selftest" }, { name: "session_handshake" }] };\n` +
` if (req.method === "tools/call") {\n` +
` const payload = { ok: false, action: "graph.ingest.refresh_declared_root", refused: "refresh_would_shrink_graph", reason: "fixture refusal" };\n` +
` result = { isError: false, content: [{ type: "text", text: JSON.stringify(payload) }] };\n` +
` }\n` +
` process.stdout.write(JSON.stringify({ jsonrpc: "2.0", id: req.id, result }) + "\\n");\n` +
fs.mkdirSync(target.runtimeDir, { recursive: true });
path.join(target.runtimeDir, "agent-cache-identity.json"),
`${JSON.stringify(target.identity, null, 2)}\n`,
{ mode: 0o600 }
fs.writeFileSync(path.join(target.runtimeDir, "graph_snapshot.json"), "{}\n");
assert.equal(run.status, 1, `refusal exited ${run.status}: ${run.stderr}\n${run.stdout}`);
const envelope = JSON.parse(run.stdout);
assert.equal(envelope.ok, false);
assert.equal(envelope.status, "refresh_refused");
assert.equal(envelope.trust.verdict, "not_evaluated");
assert.equal(envelope.trust.freshness, "refresh_refused");
assert.deepEqual(envelope.freshness, {
isError: false,
ok: false,
action: "graph.ingest.refresh_declared_root",
refused: "refresh_would_shrink_graph",
reason: "fixture refusal",
assert.deepEqual(envelope.calls.map((call) => call.tool), ["tools/list", "ingest"]);
