Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333#!/usr/bin/env node// memory/cli.mjs// Local-first memory CLI for Claude/Codex session continuity.
import { buildEnvProfile, commitEvent, createCheckpoint, createSession, flushRemote, inspectStore, listSessionCheckpoints, listSessions, rememberSession, searchEvents, setDeviceId,} from "./index.mjs";
function parseArgs(argv) { const out = { _: [] }; for (let i = 0; i < argv.length; i += 1) { const token = argv[i]; if (!token.startsWith("--")) { out._.push(token); continue; }
const key = token.slice(2); const next = argv[i + 1]; if (next && !next.startsWith("--")) { out[key] = next; i += 1; } else { out[key] = true; } } return out;}
async function readStdinIfAny() { if (process.stdin.isTTY) return ""; return new Promise((resolve, reject) => { let data = ""; process.stdin.setEncoding("utf8"); process.stdin.on("data", (chunk) => { data += chunk; }); process.stdin.on("end", () => resolve(data)); process.stdin.on("error", reject); });}
function toInt(value, fallback) { const parsed = Number(value); if (Number.isFinite(parsed)) return parsed; return fallback;}
function printUsage() { console.log(`agent-memory CLI
Commands: create [--session <id>] [--title <title>] [--provider <name>] [--project <name>] event [--session <id>] [--provider <name>] [--model <name>] [--role <role>] [--text <text>] [--source <source>] [--project <name>] [--ticket <id>] checkpoint --session <id> [--reason <reason>] [--summary <text>] [--max-events <n>] checkpoints --session <id> list [--limit <n>] [--project <name>] [--json] search <query> [--limit <n>] [--since <iso|YYYY-MM-DD>] [--session <id>] [--project <name>] [--provider <name>] [--role <role>] [--regex] [--json] remember --from <session-id> [--checkpoint <id>] [--session <new-id>] [--title <title>] [--project <name>] [--provider <name>] set-device --id <device-id> doctor [--json] profile [--include-key] [--exports] [--project <name>] [--provider <name>] [--ticket <id>] [--session <id>] [--device <id>] flush-remote`);}
async function commandCreate(args) { const session = await createSession({ sessionId: args.session || process.env.AGENT_SESSION_ID, title: args.title, provider: args.provider || process.env.AGENT_MEMORY_PROVIDER, project: args.project || process.env.AGENT_MEMORY_PROJECT, }); console.log(JSON.stringify(session, null, 2));}
async function commandEvent(args) { const stdinRaw = await readStdinIfAny(); let stdinPayload = {};
if (stdinRaw.trim()) { try { stdinPayload = JSON.parse(stdinRaw); } catch { stdinPayload = { text: stdinRaw.trim() }; } }
const payload = { ...stdinPayload, sessionId: args.session || stdinPayload.sessionId || stdinPayload.session_id || process.env.AGENT_SESSION_ID, provider: args.provider || stdinPayload.provider || process.env.AGENT_MEMORY_PROVIDER, model: args.model || stdinPayload.model, role: args.role || stdinPayload.role || "user", source: args.source || stdinPayload.source || "manual", project: args.project || stdinPayload.project || process.env.AGENT_MEMORY_PROJECT, text: args.text || stdinPayload.text || stdinPayload.content || stdinPayload.message, content: stdinPayload.content, context: stdinPayload.context, tool_calls: stdinPayload.tool_calls, metadata: { ...(stdinPayload.metadata || {}), ...(args.ticket ? { ticket: args.ticket } : {}), }, title: args.title || stdinPayload.title, };
const result = await commitEvent(payload); console.log(JSON.stringify(result, null, 2));}
async function commandCheckpoint(args) { const sessionId = args.session || process.env.AGENT_SESSION_ID; if (!sessionId) { throw new Error("--session is required (or set AGENT_SESSION_ID)"); }
const stdinRaw = await readStdinIfAny(); const summary = args.summary || stdinRaw.trim() || undefined;
const checkpoint = await createCheckpoint({ sessionId, reason: args.reason || "manual", summary, maxEvents: toInt(args["max-events"], 40), });
console.log(JSON.stringify(checkpoint, null, 2));}
async function commandCheckpoints(args) { const sessionId = args.session || process.env.AGENT_SESSION_ID; if (!sessionId) { throw new Error("--session is required (or set AGENT_SESSION_ID)"); }
const checkpoints = await listSessionCheckpoints(sessionId); console.log(JSON.stringify(checkpoints, null, 2));}
async function commandList(args) { const sessions = await listSessions({ limit: toInt(args.limit, 30), project: args.project || process.env.AGENT_MEMORY_PROJECT, });
if (args.json) { console.log(JSON.stringify(sessions, null, 2)); return; }
if (sessions.length === 0) { console.log("No sessions found."); return; }
for (const session of sessions) { const remembered = session.remembered_from?.session_id ? ` remembered_from=${session.remembered_from.session_id}` : ""; console.log( `${session.session_id} project=${session.project} updated=${session.updated_at} seq=${session.last_seq} title="${session.title}"${remembered}` ); }}
async function commandSearch(args) { const query = args._.slice(1).join(" ").trim() || (typeof args.query === "string" ? args.query : ""); if (!query) { throw new Error('search requires a query, e.g. search "menu band rejection"'); }
const result = await searchEvents({ query, limit: toInt(args.limit, 20), since: args.since, session: args.session, project: args.project || process.env.AGENT_MEMORY_PROJECT, provider: args.provider, role: args.role, regex: Boolean(args.regex), });
// --json is what the fleet fan-out consumes over ssh (memory-mcp.mjs). if (args.json) { console.log(JSON.stringify(result)); return; }
if (result.hits.length === 0) { console.log(`No matches for "${query}" on ${result.device_id}.`); return; }
console.log(`${result.total} match${result.total === 1 ? "" : "es"} for "${query}" on ${result.device_id}:\n`); for (const hit of result.hits) { console.log(`${hit.when} ${hit.role} ${hit.session_id}#${hit.seq}`); console.log(` ${hit.snippet}\n`); }}
async function commandRemember(args) { if (!args.from) { throw new Error("--from is required"); }
const result = await rememberSession({ fromSessionId: args.from, checkpointId: args.checkpoint, sessionId: args.session || process.env.AGENT_SESSION_ID, title: args.title, project: args.project || process.env.AGENT_MEMORY_PROJECT, provider: args.provider || process.env.AGENT_MEMORY_PROVIDER, });
console.log(JSON.stringify(result, null, 2));}
async function commandFlushRemote() { const result = await flushRemote(); console.log(JSON.stringify(result, null, 2));}
async function commandSetDevice(args) { if (!args.id) { throw new Error("--id is required"); }
const normalized = await setDeviceId(args.id); console.log(`AGENT_DEVICE_ID set to ${normalized}`);}
async function commandDoctor(args) { const info = await inspectStore(); if (args.json) { console.log(JSON.stringify(info, null, 2)); return; }
console.log(`home: ${info.home}`); console.log(`device: ${info.device_id}`); console.log(`key source: ${info.key_source}`); console.log(`key fingerprint: ${info.key_fingerprint}`); console.log(`sessions: ${info.sessions_count}`); console.log(`event streams: ${info.event_streams_count}`); console.log(`checkpoints: ${info.checkpoint_streams_count}`); console.log(`remote enabled: ${info.remote_enabled}`); if (info.remote_enabled) { console.log(`remote endpoint: ${info.remote_endpoint}`); }}
function formatProfileLine(line, useExports) { return useExports ? `export ${line}` : line;}
async function commandProfile(args) { const includeKey = Boolean(args["include-key"]); const useExports = Boolean(args.exports);
const profile = await buildEnvProfile({ includeKey, deviceId: args.device, project: args.project, provider: args.provider, ticket: args.ticket, sessionId: args.session, });
console.log(`# Agent memory profile (${profile.home})`); for (const line of profile.lines) { console.log(formatProfileLine(line, useExports)); }}
async function main() { const args = parseArgs(process.argv.slice(2)); const command = args._[0] || "help";
if (command === "help" || command === "--help" || command === "-h") { printUsage(); return; }
const handlers = { create: commandCreate, event: commandEvent, checkpoint: commandCheckpoint, checkpoints: commandCheckpoints, list: commandList, search: commandSearch, remember: commandRemember, "set-device": commandSetDevice, doctor: commandDoctor, profile: commandProfile, "flush-remote": commandFlushRemote, };
const handler = handlers[command]; if (!handler) { printUsage(); process.exitCode = 1; return; }
await handler(args);}
main().catch((error) => { console.error(`agent-memory: ${error.message}`); process.exit(1);});