mirror of
https://github.com/rohitg00/agentmemory.git
synced 2026-09-14 20:16:33 +08:00
Rohit Ghumare
6761a99ba1
#1047: JSON.parse("null") returns null without throwing, so every hook's parse guard passed it through and the first data.xxx access threw a TypeError. Bare main() turned that into an unhandled rejection -> exit 1 -> host reported 'hook failed' on every affected tool call. All 13 hook entrypoints now guard non-object payloads before dereferencing and wrap main() in .catch() to fail closed (silent exit 0). #1057: mem::context and api::context filtered candidate sessions by project only, leaking cross-agent observations/summaries under AGENTMEMORY_AGENT_SCOPE=isolated. Now applies the same agent-scope filter as mem::search (#817); api::context, api::session::start, and event::session::started forward agentId. Also: bump 0.9.28 across manifests/deploy/export-import set; refresh stale README/AGENTS stats (files/LOC/functions/KV; AGENTS tests 950+ -> 1,428+) and regenerate the website meta snapshot to 0.9.28; CHANGELOG 0.9.28 section; remove the rate-limited star-history chart from README and all 11 translations.
86 lines
2.3 KiB
JavaScript
Executable File
86 lines
2.3 KiB
JavaScript
Executable File
#!/usr/bin/env node
|
|
import { execSync } from "node:child_process";
|
|
import { basename } from "node:path";
|
|
//#region src/hooks/_project.ts
|
|
function resolveProject(cwd) {
|
|
const explicit = process.env["AGENTMEMORY_PROJECT_NAME"];
|
|
if (explicit && explicit.trim()) return explicit.trim();
|
|
const dir = cwd && cwd.trim() ? cwd : process.cwd();
|
|
try {
|
|
const top = execSync("git rev-parse --show-toplevel", {
|
|
cwd: dir,
|
|
stdio: [
|
|
"ignore",
|
|
"pipe",
|
|
"ignore"
|
|
],
|
|
timeout: 500
|
|
}).toString().trim();
|
|
if (top) return basename(top);
|
|
} catch {}
|
|
return basename(dir);
|
|
}
|
|
//#endregion
|
|
//#region src/hooks/session-start.ts
|
|
function isSdkChildContext(payload) {
|
|
if (process.env["AGENTMEMORY_SDK_CHILD"] === "1") return true;
|
|
if (!payload || typeof payload !== "object") return false;
|
|
return payload.entrypoint === "sdk-ts";
|
|
}
|
|
const INJECT_CONTEXT = process.env["AGENTMEMORY_INJECT_CONTEXT"] === "true";
|
|
const REST_URL = process.env["AGENTMEMORY_URL"] || "http://localhost:3111";
|
|
const SECRET = process.env["AGENTMEMORY_SECRET"] || "";
|
|
const INJECT_TIMEOUT_MS = 1500;
|
|
const REGISTER_TIMEOUT_MS = 800;
|
|
function authHeaders() {
|
|
const h = { "Content-Type": "application/json" };
|
|
if (SECRET) h["Authorization"] = `Bearer ${SECRET}`;
|
|
return h;
|
|
}
|
|
async function main() {
|
|
let input = "";
|
|
for await (const chunk of process.stdin) input += chunk;
|
|
let data;
|
|
try {
|
|
data = JSON.parse(input);
|
|
} catch {
|
|
return;
|
|
}
|
|
if (!data || typeof data !== "object") return;
|
|
if (isSdkChildContext(data)) return;
|
|
const sessionId = data.session_id || data.sessionId || `ses_${Date.now().toString(36)}`;
|
|
const cwd = data.cwd || process.cwd();
|
|
const project = resolveProject(data.cwd);
|
|
const url = `${REST_URL}/agentmemory/session/start`;
|
|
const init = {
|
|
method: "POST",
|
|
headers: authHeaders(),
|
|
body: JSON.stringify({
|
|
sessionId,
|
|
project,
|
|
cwd
|
|
})
|
|
};
|
|
if (!INJECT_CONTEXT) {
|
|
fetch(url, {
|
|
...init,
|
|
signal: AbortSignal.timeout(REGISTER_TIMEOUT_MS)
|
|
}).catch(() => {});
|
|
return;
|
|
}
|
|
try {
|
|
const res = await fetch(url, {
|
|
...init,
|
|
signal: AbortSignal.timeout(INJECT_TIMEOUT_MS)
|
|
});
|
|
if (res.ok) {
|
|
const result = await res.json();
|
|
if (result.context) process.stdout.write(result.context);
|
|
}
|
|
} catch {}
|
|
}
|
|
main().catch(() => process.exit(0));
|
|
//#endregion
|
|
export {};
|
|
|
|
//# sourceMappingURL=session-start.mjs.map
|