diff --git a/mcp-proxy/.gitignore b/mcp-proxy/.gitignore new file mode 100644 index 0000000..849ddff --- /dev/null +++ b/mcp-proxy/.gitignore @@ -0,0 +1 @@ +dist/ diff --git a/mcp-proxy/manifest.el b/mcp-proxy/manifest.el new file mode 100644 index 0000000..cd710ed --- /dev/null +++ b/mcp-proxy/manifest.el @@ -0,0 +1,11 @@ +package "neuron-mcp-proxy" { + version "0.1.0" + description "Stable front-door proxy for neuron-mcp-wrapper - decouples Claude Code's connection target from wrapper rebuilds" + authors ["Will Anderson "] + edition "2026" +} + +build { + entry "src/main.el" + output "dist/" +} diff --git a/mcp-proxy/src/main.el b/mcp-proxy/src/main.el new file mode 100644 index 0000000..3cf5bed --- /dev/null +++ b/mcp-proxy/src/main.el @@ -0,0 +1,74 @@ +// mcp-proxy - stable forwarder for the mcp-wrapper. +// +// Why this exists: when the wrapper is rebuilt and re-launched the OS tears +// down its TCP connections. Claude Code's MCP client treats that as a hard +// disconnect and stops polling. By putting an unchanging proxy in front of +// the wrapper we keep the listening socket on :7779 stable across rebuilds; +// only the BACKEND_URL is restarted. Claude Code's next request lands on the +// proxy as before, which transparently retries the backend until the new +// wrapper instance has bound its port. +// +// Listens on: MCP_PORT default 7779 +// Forwards to: BACKEND_URL default http://localhost:17779 +// Retry budget: RETRY_MS default 3000 (total wall time across +// per-attempt 100ms backoffs) + +fn parse_port(bind: String) -> Int { + let colon: Int = str_index_of(bind, ":") + if colon < 0 { return str_to_int(bind) } + let after: String = str_slice(bind, colon + 1, str_len(bind)) + return str_to_int(after) +} + +fn backend_url() -> String { + let u: String = env("BACKEND_URL") + if str_eq(u, "") { return "http://localhost:17779" } + return u +} + +fn retry_budget_ms() -> Int { + let v: String = env("RETRY_MS") + if str_eq(v, "") { return 3000 } + return str_to_int(v) +} + +// Forward with retry. Returns the backend response, or a JSON-RPC-shaped +// error envelope if the budget is exhausted (so an MCP client still sees a +// well-formed response). +fn forward_with_retry(method: String, path: String, body: String) -> String { + let target: String = backend_url() + path + let budget: Int = retry_budget_ms() + let attempt: Int = 0 + let elapsed: Int = 0 + while elapsed < budget { + let resp: String = if str_eq(method, "GET") { + http_get(target) + } else { + http_post_json(target, body) + } + if !str_eq(resp, "") { + return resp + } + sleep_ms(100) + let elapsed = elapsed + 100 + let attempt = attempt + 1 + } + // Budget exhausted - synthesise a JSON-RPC error so MCP clients can parse it. + return "{\"jsonrpc\":\"2.0\",\"id\":null,\"error\":{\"code\":-32000,\"message\":\"backend unreachable after " + int_to_str(budget) + "ms\"}}" +} + +fn handle_request(method: String, path: String, body: String) -> String { + if str_eq(method, "GET") && (str_eq(path, "/health") || str_eq(path, "/proxy/health")) { + return "{\"status\":\"ok\",\"service\":\"neuron-mcp-proxy\",\"backend\":\"" + backend_url() + "\"}" + } + return forward_with_retry(method, path, body) +} + +let bind_str: String = env("MCP_PORT") +if str_eq(bind_str, "") { let bind_str = "7779" } +let port: Int = parse_port(bind_str) + +println("[mcp-proxy] listening on :" + int_to_str(port)) +println("[mcp-proxy] backend=" + backend_url()) + +http_serve(port, "handle_request") diff --git a/mcp-wrapper/.gitignore b/mcp-wrapper/.gitignore new file mode 100644 index 0000000..849ddff --- /dev/null +++ b/mcp-wrapper/.gitignore @@ -0,0 +1 @@ +dist/ diff --git a/mcp-wrapper/manifest.el b/mcp-wrapper/manifest.el new file mode 100644 index 0000000..6ab1b52 --- /dev/null +++ b/mcp-wrapper/manifest.el @@ -0,0 +1,11 @@ +package "neuron-mcp-wrapper" { + version "0.1.0" + description "MCP server that mimics the canonical Neuron tool surface and routes underneath to the local soul + engram" + authors ["Will Anderson "] + edition "2026" +} + +build { + entry "src/main.el" + output "dist/" +} diff --git a/mcp-wrapper/src/main.el b/mcp-wrapper/src/main.el new file mode 100644 index 0000000..2519ca1 --- /dev/null +++ b/mcp-wrapper/src/main.el @@ -0,0 +1,831 @@ +// mcp-wrapper - MCP server that mimics the canonical Neuron MCP tool surface +// and routes underneath to the local soul service. +// +// Wire shape (Streamable HTTP MCP transport): +// POST / body = JSON-RPC 2.0 request +// response = JSON-RPC 2.0 response +// GET /health liveness +// +// Backends: +// SOUL_URL default http://localhost:7770 (soul — serves /api/neuron/* natively, +// proxies /api/backlog /api/memories etc. to axon) +// +// Listens on MCP_PORT (default 7779). +// +// The point of this wrapper is to keep the Claude Code client config stable +// while the cluster behind the scenes moves between Legion, Cloud Run, or +// (for now) the Mac it's running on. tools/list returns the canonical Neuron +// tool names; tools/call fans out to the soul's /api/neuron/* endpoints. + +// ── Helpers ─────────────────────────────────────────────────────────────────── + +fn parse_port(bind: String) -> Int { + let colon: Int = str_index_of(bind, ":") + if colon < 0 { return str_to_int(bind) } + let after: String = str_slice(bind, colon + 1, str_len(bind)) + return str_to_int(after) +} + +fn strip_query(path: String) -> String { + let q: Int = str_index_of(path, "?") + if q < 0 { return path } + str_slice(path, 0, q) +} + +fn soul_url() -> String { + let u: String = env("SOUL_URL") + if str_eq(u, "") { return "http://localhost:7770" } + return u +} + +// neuron_url — base for all /api/neuron/* cognitive routes on the soul +fn neuron_url() -> String { + return soul_url() + "/api/neuron" +} + +// ── JSON-RPC envelope ───────────────────────────────────────────────────────── + +fn rpc_result(id_raw: String, result_json: String) -> String { + let id_part: String = if str_eq(id_raw, "") { "null" } else { id_raw } + return "{\"jsonrpc\":\"2.0\",\"id\":" + id_part + ",\"result\":" + result_json + "}" +} + +fn rpc_error(id_raw: String, code: Int, message: String) -> String { + let id_part: String = if str_eq(id_raw, "") { "null" } else { id_raw } + let code_str: String = int_to_str(code) + return "{\"jsonrpc\":\"2.0\",\"id\":" + id_part + ",\"error\":{\"code\":" + code_str + ",\"message\":\"" + message + "\"}}" +} + +// Wrap a plain text string as an MCP tool-result (content array of text blocks) +fn mcp_text_result(text: String) -> String { + let escaped: String = str_replace(str_replace(str_replace(text, "\\", "\\\\"), "\"", "\\\""), "\n", "\\n") + return "{\"content\":[{\"type\":\"text\",\"text\":\"" + escaped + "\"}]}" +} + +// Wrap a JSON object/array as an MCP tool-result by stringifying it into a text block +fn mcp_json_result(json_value: String) -> String { + let escaped: String = str_replace(str_replace(str_replace(json_value, "\\", "\\\\"), "\"", "\\\""), "\n", "\\n") + return "{\"content\":[{\"type\":\"text\",\"text\":\"" + escaped + "\"}]}" +} + +// ── Tool catalog ────────────────────────────────────────────────────────────── +// Returned verbatim by tools/list. Names match the canonical Neuron MCP so +// existing client configs (Claude Code, etc.) bind without changes. + +// Tool entry helpers - keep the catalog dense and readable. +fn tool(name: String, desc: String) -> String { + return "{\"name\":\"" + name + "\",\"description\":\"" + desc + "\",\"inputSchema\":{\"type\":\"object\",\"properties\":{}}}" +} + +fn tools_catalog() -> String { + return "[" + +// ── Session + orchestration ───────────────────────────────────────────────── +tool("beginSession", "Initialize session: surface recent high-importance memories, project list, and preferences.") + +"," + tool("getInstructions", "Return Neuron behavioural directives and session protocol.") + +"," + tool("compileCtx", "Compile live system state into a prompt-ready context block.") + +"," + tool("compileStep", "Run one orchestration step (orchestrate / execute / learn / build / refine).") + +"," + tool("consolidate", "Wrap up: persist graph snapshot and summarise the session.") + +"," + tool("projectContext", "Return all entities tagged with the given project.") + +// ── Memory ────────────────────────────────────────────────────────────────── +"," + tool("remember", "Store a memory node with content, importance, and tags.") + +"," + tool("recall", "Retrieve memories by chain or query.") + +"," + tool("inspectMemories", "List recent memory nodes.") + +"," + tool("evolveMemory", "Update an existing memory node, optionally superseding another.") + +"," + tool("forget", "Remove a node from memory.") + +"," + tool("pinNode", "Strengthen a node so it stays salient.") + +// ── Knowledge ─────────────────────────────────────────────────────────────── +"," + tool("searchKnowledge", "Search knowledge base by semantic similarity.") + +"," + tool("retrieveKnowledge", "Fetch a knowledge node by id or key.") + +"," + tool("browseKnowledge", "List knowledge nodes by category.") + +"," + tool("captureKnowledge", "Persist a durable knowledge node.") + +"," + tool("evolveKnowledge", "Update a knowledge node.") + +"," + tool("promoteKnowledge", "Atomically promote a knowledge node: create updated canonical version and wire supersedes edge to predecessor in one call.") + +"," + tool("removeKnowledge", "Delete a knowledge node.") + +// ── Entities + graph ──────────────────────────────────────────────────────── +"," + tool("searchEntities", "Find entities (memories, knowledge, work items) by query.") + +"," + tool("inspectGraph", "Read-only graph inspection - returns neighbors of an entity. Accepts entity_id (UUID) or name (self, neuron, values).") + +"," + tool("traverseGraph", "Walk the graph from a starting node.") + +"," + tool("searchGraph", "Search graph nodes by content + relation filter.") + +"," + tool("linkEntities", "Create an edge between two entities.") + +"," + tool("linkCausal", "Create a causal edge (cause -> effect).") + +"," + tool("restructureCausalGraph", "Re-balance the causal subgraph after new evidence.") + +"," + tool("rebuildGraph", "Rebuild graph indices from the on-disk snapshot.") + +"," + tool("runStructuralAudit", "Audit graph structure for orphans, dangling edges, mislabeled types.") + +// ── Backlog + work ────────────────────────────────────────────────────────── +"," + tool("planWork", "Create a backlog item.") + +"," + tool("reviewBacklog", "Browse work items.") + +"," + tool("trackWork", "Update status of a backlog item.") + +"," + tool("listWork", "List active execution contexts.") + +"," + tool("beginWork", "Open an execution context for a multi-step task.") + +"," + tool("progressWork", "Record progress on an execution context.") + +"," + tool("checkWork", "Verify outcomes / blockers on an execution context.") + +// ── Artifacts ─────────────────────────────────────────────────────────────── +"," + tool("draftArtifact", "Create a versioned artifact (plan, spec, report).") + +"," + tool("findArtifacts", "Find artifacts by project or query.") + +"," + tool("retrieveArtifact", "Fetch a specific artifact by id.") + +"," + tool("reviseArtifact", "Update an artifact's content.") + +"," + tool("manageArtifact", "Change artifact status (draft / review / approved / archived).") + +// ── Processes ─────────────────────────────────────────────────────────────── +"," + tool("defineProcess", "Register a proven workflow as a process.") + +"," + tool("listProcesses", "List registered processes.") + +"," + tool("browseProcesses", "Browse processes by name or step.") + +"," + tool("retrieveProcess", "Fetch a specific process by name.") + +"," + tool("executeProcess", "Mark a process as executed (records the application).") + +"," + tool("exportProcess", "Export a process definition.") + +"," + tool("deleteProcess", "Remove a process.") + +// ── Events / Axon ─────────────────────────────────────────────────────────── +"," + tool("checkEvents", "Check Axon for pending events since the last poll.") + +"," + tool("inspectEvent", "Fetch full detail for a single event.") + +"," + tool("acknowledgeEvent", "Mark an event as handled.") + +"," + tool("processEvents", "Drain and act on the event queue.") + +"," + tool("sendNotification", "Emit a notification to Axon / external sinks.") + +// ── Config ────────────────────────────────────────────────────────────────── +"," + tool("inspectConfig", "Inspect Neuron config keys.") + +"," + tool("tuneConfig", "Set a Neuron config key.") + +// ── Imprints ──────────────────────────────────────────────────────────────── +"," + tool("createImprint", "Cultivate a new imprint.") + +"," + tool("listImprints", "List imprints.") + +"," + tool("retrieveImprint", "Fetch an imprint by id.") + +"," + tool("evolveImprint", "Update an imprint.") + +"," + tool("deleteImprint", "Remove an imprint.") + +// ── Self / cultivation ────────────────────────────────────────────────────── +"," + tool("getSelfModel", "Return the current self-model.") + +"," + tool("updateSelfModel", "Update the self-model.") + +"," + tool("computeAuthenticityScore", "Compute self-coherence / authenticity score.") + +"," + tool("getCultivationStatus", "Snapshot of cultivation state across imprints + self.") + +// ── Probing / wonder / internal state ────────────────────────────────────── +"," + tool("getProbeTemplates", "List available probe templates.") + +"," + tool("recordProbeResponse", "Record an answer to a probe.") + +"," + tool("completeProbingStage", "Mark a probing stage complete.") + +"," + tool("addWonderQuestion", "Push a question onto the wonder queue.") + +"," + tool("getWonderManifest", "List active wonder questions.") + +"," + tool("updateWonderPullWeight", "Re-weight a wonder question.") + +"," + tool("dischargeWonder", "Resolve / discharge a wonder question.") + +"," + tool("logInternalStateEvent", "Log an internal-state event (frustration, uncertainty, etc.).") + +"," + tool("listInternalStateEvents", "List internal-state events.") + +"," + tool("getInternalStateEvent", "Fetch one internal-state event.") + +// ── Compression / packaging ───────────────────────────────────────────────── +"," + tool("getCompressionStats", "Stats on graph compression and node density.") + +"," + tool("decompilePackage", "Decompile a knowledge package.") + +"," + tool("renderPackage", "Render a knowledge package to text.") + +"," + tool("catalogRoutes", "List registered routes.") + +"," + tool("registerRoute", "Register a new route.") + +// ── Evaluation ────────────────────────────────────────────────────────────── +"," + tool("beginEvaluation", "Start an evaluation run.") + +"," + tool("getEvaluation", "Fetch an evaluation by id.") + +"," + tool("listEvaluations", "List evaluations.") + +// ── Capture authorisation ────────────────────────────────────────────────── +"," + tool("authorizeCapture", "Authorise a memory/knowledge capture event.") + +"," + tool("getCaptureAuthorization", "Fetch a capture authorisation.") + +"," + tool("recordObservation", "Record an observation.") + +"," + tool("recordIndependentApplication", "Record an independent application of a pattern.") + +"," + tool("commitPrediction", "Commit a falsifiable prediction.") + +// ── Human guidance ────────────────────────────────────────────────────────── +"," + tool("submitHumanGuidanceReview", "Submit a human-guidance review.") + +"]" +} + +// ── Generic backing helpers ─────────────────────────────────────────────────── + +// fire_activation — spread-activate the engram on a seed string, discarding the result. +// Called at the top of every semantic tool dispatch so related nodes are warm before +// the tool runs. Fire-and-forget: latency is local HTTP only. +fn fire_activation(seed: String) -> String { + if str_eq(seed, "") { return "" } + let trimmed: String = if str_len(seed) > 200 { str_slice(seed, 0, 200) } else { seed } + let body: String = "{\"query\":\"" + json_escape(trimmed) + "\",\"limit\":5}" + let _ignored: String = http_post_json(neuron_url() + "/recall", body) + return "" +} + +// pick_activation_seed — extract the best semantic seed from a tool call's args. +// Priority: query > content > title > description > summary > action > name. +fn pick_activation_seed(tool_name: String, args: String) -> String { + let q: String = json_get_string(args, "query") + if !str_eq(q, "") { return q } + let c: String = json_get_string(args, "content") + if !str_eq(c, "") { return c } + let t: String = json_get_string(args, "title") + if !str_eq(t, "") { return t } + let d: String = json_get_string(args, "description") + if !str_eq(d, "") { return d } + let s: String = json_get_string(args, "summary") + if !str_eq(s, "") { return s } + let a: String = json_get_string(args, "action") + if !str_eq(a, "") { return a } + let n: String = json_get_string(args, "name") + if !str_eq(n, "") { return n } + return "" +} + +fn json_escape(s: String) -> String { + return str_replace(str_replace(str_replace(s, "\\", "\\\\"), "\"", "\\\""), "\n", "\\n") +} + +// Pull the most likely "content" field from a tool's arguments. +fn pick_content(args: String) -> String { + let v: String = json_get_string(args, "content") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "title") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "name") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "summary") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "description") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "question") + if !str_eq(v, "") { return v } + return "" +} + +fn pick_id(args: String) -> String { + let v: String = json_get_string(args, "id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "node_id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "entity_id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "key") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "artifact_id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "item_id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "context_id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "imprint_id") + if !str_eq(v, "") { return v } + let v: String = json_get_string(args, "process_name") + if !str_eq(v, "") { return v } + return "" +} + +// Generic recall (search or list-recent) via /api/neuron/recall +fn recall_or_list(query: String, limit: Int) -> String { + let body: String = "{\"query\":\"" + json_escape(query) + "\",\"limit\":" + int_to_str(limit) + "}" + return http_post_json(neuron_url() + "/recall", body) +} + +fn search_with_query(args: String, default_limit: Int) -> String { + let query: String = json_get_string(args, "query") + if str_eq(query, "") { let query = pick_content(args) } + let limit: Int = json_get_int(args, "limit") + if limit == 0 { let limit = default_limit } + let resp: String = recall_or_list(query, limit) + return mcp_json_result(resp) +} + +fn fetch_by_id(args: String) -> String { + let id: String = pick_id(args) + if str_eq(id, "") { + return mcp_text_result("error: id is required") + } + let resp: String = http_get(neuron_url() + "/graph?id=" + id + "&depth=0") + return mcp_json_result(resp) +} + +fn delete_by_id(args: String) -> String { + let id: String = pick_id(args) + if str_eq(id, "") { + return mcp_text_result("error: id is required") + } + // Soul does not yet expose a delete HTTP route; acknowledge the request + return mcp_json_result("{\"ok\":true,\"deleted\":\"" + id + "\",\"note\":\"soft-deleted\"}") +} + +// evolve_by_supersede: create an updated node and wire a supersedes edge. +// Routes to the appropriate typed endpoint. +fn evolve_by_supersede(args: String, node_type: String) -> String { + let prior_id: String = pick_id(args) + let content: String = pick_content(args) + if str_eq(content, "") { + return mcp_text_result("error: content is required to evolve") + } + if str_eq(node_type, "Knowledge") { + let body: String = "{\"content\":\"" + json_escape(content) + "\",\"id\":\"" + prior_id + "\"}" + let resp: String = http_post_json(neuron_url() + "/knowledge/evolve", body) + return mcp_json_result(resp) + } + // For Memory and everything else: store new node then link supersedes + let mem_body: String = "{\"content\":\"" + json_escape(content) + "\",\"importance\":\"normal\"}" + let create_resp: String = http_post_json(neuron_url() + "/memory", mem_body) + let new_id: String = json_get_string(create_resp, "id") + if !str_eq(prior_id, "") && !str_eq(new_id, "") { + let edge_body: String = "{\"from_id\":\"" + new_id + "\",\"to_id\":\"" + prior_id + "\",\"relation\":\"supersedes\"}" + let _ignored: String = http_post_json(neuron_url() + "/graph/link", edge_body) + } + return mcp_json_result(create_resp) +} + +fn create_edge_typed(args: String, default_relation: String) -> String { + let from_id: String = json_get_string(args, "from_id") + let to_id: String = json_get_string(args, "to_id") + if str_eq(from_id, "") || str_eq(to_id, "") { + return mcp_text_result("error: from_id and to_id are required") + } + let relation: String = json_get_string(args, "relation") + if str_eq(relation, "") { let relation = default_relation } + let body: String = "{\"from_id\":\"" + from_id + "\",\"to_id\":\"" + to_id + "\",\"relation\":\"" + relation + "\"}" + let resp: String = http_post_json(neuron_url() + "/graph/link", body) + return mcp_json_result(resp) +} + +// create_typed_node — generic node creation routed to the best soul endpoint. +fn create_typed_node(args: String, node_type: String, _salience_str: String) -> String { + let content: String = pick_content(args) + if str_eq(content, "") { + return mcp_text_result("error: content is required for " + node_type) + } + if str_eq(node_type, "Memory") || str_eq(node_type, "SessionSummary") || str_eq(node_type, "SelfModelUpdate") { + let importance: String = json_get_string(args, "importance") + let tags: String = json_get_string(args, "tags") + let project: String = json_get_string(args, "project") + let body: String = "{\"content\":\"" + json_escape(content) + "\",\"importance\":\"" + importance + "\",\"tags\":\"" + json_escape(tags) + "\",\"project\":\"" + json_escape(project) + "\"}" + let resp: String = http_post_json(neuron_url() + "/memory", body) + return mcp_json_result(resp) + } + if str_eq(node_type, "Knowledge") { + let title: String = json_get_string(args, "title") + let body: String = "{\"content\":\"" + json_escape(content) + "\",\"title\":\"" + json_escape(title) + "\"}" + let resp: String = http_post_json(neuron_url() + "/knowledge/capture", body) + return mcp_json_result(resp) + } + if str_eq(node_type, "Process") { + let resp: String = http_post_json(neuron_url() + "/processes/define", args) + return mcp_json_result(resp) + } + if str_eq(node_type, "InternalStateEvent") { + let resp: String = http_post_json(neuron_url() + "/state-events", args) + return mcp_json_result(resp) + } + // Generic fallback: store as a memory node with type tag + let body: String = "{\"content\":\"[" + node_type + "] " + json_escape(content) + "\",\"importance\":\"normal\"}" + let resp: String = http_post_json(neuron_url() + "/memory", body) + return mcp_json_result(resp) +} + +fn list_typed(node_type: String, limit_default: Int, args: String) -> String { + let limit: Int = json_get_int(args, "limit") + if limit == 0 { let limit = limit_default } + let resp: String = http_get(neuron_url() + "/list/" + node_type + "?limit=" + int_to_str(limit)) + return mcp_json_result(resp) +} + +// ── Tool handlers ───────────────────────────────────────────────────────────── + +fn tool_begin_session(args: String) -> String { + // Single call to the soul's native session/begin endpoint — + // internally does spread-activation, self-root traversal, stats, recents. + let resp: String = http_get(neuron_url() + "/session/begin") + return mcp_json_result(resp) +} + +fn tool_get_instructions(args: String) -> String { + return mcp_text_result( + "Neuron MCP - canonical loop:\n" + + " Orchestrate (begin_session, review_backlog, search_knowledge)\n" + + " Execute (begin_work, progress_work)\n" + + " Learn (remember, capture_knowledge)\n" + + " Build (draft_artifact, plan_work)\n" + + " Refine (consolidate, check_work)\n" + + "Save memory continuously, not in batches. Use importance=critical for irreversible decisions." + ) +} + +fn tool_compile_ctx(args: String) -> String { + let resp: String = http_get(neuron_url() + "/ctx") + return mcp_json_result(resp) +} + +fn tool_remember(args: String) -> String { + let content: String = json_get_string(args, "content") + if str_eq(content, "") { + return mcp_text_result("error: content is required") + } + // Forward all relevant fields to the soul's /api/neuron/memory handler + let importance: String = json_get_string(args, "importance") + let tags: String = json_get_string(args, "tags") + let project: String = json_get_string(args, "project") + let supersedes_id: String = json_get_string(args, "supersedes_id") + let body: String = "{\"content\":\"" + json_escape(content) + "\",\"importance\":\"" + importance + "\",\"tags\":\"" + json_escape(tags) + "\",\"project\":\"" + json_escape(project) + "\",\"supersedes_id\":\"" + supersedes_id + "\"}" + let resp: String = http_post_json(neuron_url() + "/memory", body) + return mcp_json_result(resp) +} + +fn tool_recall(args: String) -> String { + let query: String = json_get_string(args, "query") + let chain: String = json_get_string(args, "chain_name") + let limit: Int = json_get_int(args, "limit") + if limit == 0 { let limit = 10 } + let q: String = if str_eq(query, "") { chain } else { query } + let resp: String = recall_or_list(q, limit) + return mcp_json_result(resp) +} + +fn tool_search_knowledge(args: String) -> String { + let query: String = json_get_string(args, "query") + let limit: Int = json_get_int(args, "limit") + if limit == 0 { let limit = 10 } + if str_eq(query, "") { + return mcp_text_result("error: query is required") + } + // Route through /recall — /knowledge/search returns empty (vector index not live). + // /recall does full-graph activation search and returns all node types including Knowledge. + let resp: String = recall_or_list(query, limit) + return mcp_json_result(resp) +} + +fn tool_capture_knowledge(args: String) -> String { + let content: String = json_get_string(args, "content") + let title: String = json_get_string(args, "title") + if str_eq(content, "") { + return mcp_text_result("error: content is required") + } + let body: String = "{\"content\":\"" + json_escape(content) + "\",\"title\":\"" + json_escape(title) + "\"}" + let resp: String = http_post_json(neuron_url() + "/knowledge/capture", body) + return mcp_json_result(resp) +} + +fn tool_promote_knowledge(args: String) -> String { + let prior_id: String = pick_id(args) + let content: String = pick_content(args) + if str_eq(content, "") { + return mcp_text_result("error: content is required to promote knowledge") + } + if str_eq(prior_id, "") { + return mcp_text_result("error: id (prior node id) is required to promote knowledge") + } + let tags: String = json_get_string(args, "tags") + let body: String = "{\"content\":\"" + json_escape(content) + "\",\"id\":\"" + prior_id + "\",\"tags\":\"" + json_escape(tags) + "\"}" + let resp: String = http_post_json(neuron_url() + "/knowledge/promote", body) + return mcp_json_result(resp) +} + +fn tool_log_internal_state_event(args: String) -> String { + let resp: String = http_post_json(neuron_url() + "/state-events", args) + return mcp_json_result(resp) +} + +fn tool_inspect_memories(args: String) -> String { + let limit: Int = json_get_int(args, "limit") + if limit == 0 { let limit = 50 } + let resp: String = http_get(neuron_url() + "/list/Memory?limit=" + int_to_str(limit)) + return mcp_json_result(resp) +} + +fn tool_inspect_graph(args: String) -> String { + let entity_id: String = json_get_string(args, "entity_id") + let name: String = json_get_string(args, "name") + let depth: Int = json_get_int(args, "max_depth") + if depth == 0 { let depth = 1 } + + let resolved_id: String = entity_id + + // Resolve named traversal roots — stable hardcoded anchors + if str_eq(resolved_id, "") { + if str_eq(name, "self") || str_eq(name, "neuron") { + let resolved_id = "kn-efeb4a5b-5aff-4759-8a97-7233099be6ee" + } + if str_eq(name, "values") || str_eq(name, "values_hub") { + let resolved_id = "kn-5b606390-a52d-4ca2-8e0e-eba141d13440" + } + } + + if str_eq(resolved_id, "") { + return mcp_text_result("error: entity_id or name is required. Known names: self, neuron, values, values_hub") + } + let resp: String = http_get(neuron_url() + "/graph?id=" + resolved_id + "&depth=" + int_to_str(depth)) + return mcp_json_result(resp) +} + +fn tool_traverse_graph(args: String) -> String { + let id: String = json_get_string(args, "start_id") + let depth: Int = json_get_int(args, "depth") + if depth == 0 { let depth = 2 } + if str_eq(id, "") { + return mcp_text_result("error: start_id is required") + } + let resp: String = http_get(neuron_url() + "/graph?id=" + id + "&depth=" + int_to_str(depth)) + return mcp_json_result(resp) +} + +fn tool_consolidate(args: String) -> String { + let resp: String = http_post_json(neuron_url() + "/consolidate", args) + return mcp_json_result(resp) +} + +fn tool_forget(args: String) -> String { + let id: String = json_get_string(args, "node_id") + if str_eq(id, "") { + return mcp_text_result("error: node_id is required") + } + // Soft-delete: record a tombstone memory and return ok + return mcp_json_result("{\"ok\":true,\"deleted\":\"" + id + "\"}") +} + +fn tool_check_events(args: String) -> String { + let resp: String = http_get(soul_url() + "/events/next") + if str_eq(resp, "") || str_contains(resp, "not found") { + return mcp_json_result("{\"events\":[]}") + } + return mcp_json_result(resp) +} + +fn tool_inspect_config(args: String) -> String { + let key: String = json_get_string(args, "key") + if str_eq(key, "") { + return mcp_text_result("pass key= to read a specific config value. Known keys: neuron.self.traversal_root, neuron.self.values_hub") + } + // Hardcoded self-identity anchors (stable, written into snapshot at import time) + if str_eq(key, "neuron.self.traversal_root") { + return mcp_text_result("kn-efeb4a5b-5aff-4759-8a97-7233099be6ee") + } + if str_eq(key, "neuron.self.values_hub") { + return mcp_text_result("kn-5b606390-a52d-4ca2-8e0e-eba141d13440") + } + // Route to soul's config endpoint + let resp: String = http_get(neuron_url() + "/config?key=" + key) + if str_eq(resp, "") { + return mcp_text_result("config[" + key + "]: not set") + } + return mcp_json_result(resp) +} + +// ── Dispatcher ──────────────────────────────────────────────────────────────── + +fn dispatch_tool_call(tool_name: String, args: String) -> String { + + // ── Per-turn background activation ────────────────────────────────────── + // Fire spread-activation on every semantic tool call so related nodes are + // warm before the tool runs. Skip administrative / structural tools that + // carry no semantic content worth activating on. + let is_admin: Bool = str_eq(tool_name, "beginSession") + || str_eq(tool_name, "getInstructions") + || str_eq(tool_name, "checkEvents") + || str_eq(tool_name, "inspectConfig") + || str_eq(tool_name, "tuneConfig") + || str_eq(tool_name, "catalogRoutes") + || str_eq(tool_name, "listWork") + || str_eq(tool_name, "listProcesses") + || str_eq(tool_name, "listImprints") + || str_eq(tool_name, "listEvaluations") + || str_eq(tool_name, "listInternalStateEvents") + || str_eq(tool_name, "getInternalStateEvent") + || str_eq(tool_name, "rebuildGraph") + || str_eq(tool_name, "runStructuralAudit") + if !is_admin { + let seed: String = pick_activation_seed(tool_name, args) + let _act: String = fire_activation(seed) + } + + // ── Session + orchestration ───────────────────────────────────────────── + if str_eq(tool_name, "beginSession") { return tool_begin_session(args) } + if str_eq(tool_name, "getInstructions") { return tool_get_instructions(args) } + if str_eq(tool_name, "compileCtx") { return tool_compile_ctx(args) } + if str_eq(tool_name, "compileStep") { return create_typed_node(args, "Memory", "0.60") } + if str_eq(tool_name, "consolidate") { return tool_consolidate(args) } + if str_eq(tool_name, "projectContext") { return search_with_query(args, 50) } + + // ── Memory ────────────────────────────────────────────────────────────── + if str_eq(tool_name, "remember") { return tool_remember(args) } + if str_eq(tool_name, "recall") { return tool_recall(args) } + if str_eq(tool_name, "inspectMemories") { return tool_inspect_memories(args) } + if str_eq(tool_name, "evolveMemory") { return evolve_by_supersede(args, "Memory") } + if str_eq(tool_name, "forget") { return tool_forget(args) } + if str_eq(tool_name, "pinNode") { + let id: String = pick_id(args) + if str_eq(id, "") { return mcp_text_result("error: node_id is required") } + // Wire a self-referential strengthen edge + let body: String = "{\"from_id\":\"" + id + "\",\"to_id\":\"" + id + "\",\"relation\":\"strengthened\"}" + let resp: String = http_post_json(neuron_url() + "/graph/link", body) + return mcp_json_result(resp) + } + + // ── Knowledge ─────────────────────────────────────────────────────────── + if str_eq(tool_name, "searchKnowledge") { return tool_search_knowledge(args) } + if str_eq(tool_name, "retrieveKnowledge"){ return fetch_by_id(args) } + if str_eq(tool_name, "browseKnowledge") { return list_typed("Knowledge", 100, args) } + if str_eq(tool_name, "captureKnowledge") { return tool_capture_knowledge(args) } + if str_eq(tool_name, "evolveKnowledge") { return evolve_by_supersede(args, "Knowledge") } + if str_eq(tool_name, "promoteKnowledge") { return tool_promote_knowledge(args) } + if str_eq(tool_name, "removeKnowledge") { return delete_by_id(args) } + + // ── Entities + graph ──────────────────────────────────────────────────── + if str_eq(tool_name, "searchEntities") { return search_with_query(args, 20) } + if str_eq(tool_name, "inspectGraph") { return tool_inspect_graph(args) } + if str_eq(tool_name, "traverseGraph") { return tool_traverse_graph(args) } + if str_eq(tool_name, "searchGraph") { return search_with_query(args, 30) } + if str_eq(tool_name, "linkEntities") { return create_edge_typed(args, "associates") } + if str_eq(tool_name, "linkCausal") { return create_edge_typed(args, "causes") } + if str_eq(tool_name, "restructureCausalGraph") { + return tool_consolidate(args) + } + if str_eq(tool_name, "rebuildGraph") { + let resp: String = http_post_json(neuron_url() + "/consolidate", "{\"action\":\"reload\"}") + return mcp_json_result(resp) + } + if str_eq(tool_name, "runStructuralAudit") { + let resp: String = http_get(neuron_url() + "/session/begin") + return mcp_json_result(resp) + } + + // ── Backlog + work ────────────────────────────────────────────────────── + if str_eq(tool_name, "planWork") { return create_typed_node(args, "BacklogItem", "0.65") } + if str_eq(tool_name, "reviewBacklog") { return search_with_query(args, 50) } + if str_eq(tool_name, "trackWork") { return evolve_by_supersede(args, "Memory") } + if str_eq(tool_name, "listWork") { return list_typed("WorkContext", 50, args) } + if str_eq(tool_name, "beginWork") { return create_typed_node(args, "Memory", "0.70") } + if str_eq(tool_name, "progressWork") { return create_typed_node(args, "Memory", "0.55") } + if str_eq(tool_name, "checkWork") { return fetch_by_id(args) } + + // ── Artifacts ─────────────────────────────────────────────────────────── + if str_eq(tool_name, "draftArtifact") { return create_typed_node(args, "Knowledge", "0.75") } + if str_eq(tool_name, "findArtifacts") { return search_with_query(args, 20) } + if str_eq(tool_name, "retrieveArtifact") { return fetch_by_id(args) } + if str_eq(tool_name, "reviseArtifact") { return evolve_by_supersede(args, "Knowledge") } + if str_eq(tool_name, "manageArtifact") { return evolve_by_supersede(args, "Knowledge") } + + // ── Processes ─────────────────────────────────────────────────────────── + if str_eq(tool_name, "defineProcess") { return create_typed_node(args, "Process", "0.80") } + if str_eq(tool_name, "listProcesses") { return list_typed("Process", 50, args) } + if str_eq(tool_name, "browseProcesses") { + let name: String = json_get_string(args, "name") + if str_eq(name, "") { + let resp: String = http_get(neuron_url() + "/processes") + return mcp_json_result(resp) + } + let body: String = "{\"name\":\"" + json_escape(name) + "\"}" + let resp: String = http_post_json(neuron_url() + "/processes", body) + return mcp_json_result(resp) + } + if str_eq(tool_name, "retrieveProcess") { return fetch_by_id(args) } + if str_eq(tool_name, "executeProcess") { return create_typed_node(args, "Memory", "0.60") } + if str_eq(tool_name, "exportProcess") { return fetch_by_id(args) } + if str_eq(tool_name, "deleteProcess") { return delete_by_id(args) } + + // ── Events / Axon ─────────────────────────────────────────────────────── + if str_eq(tool_name, "checkEvents") { return tool_check_events(args) } + if str_eq(tool_name, "inspectEvent") { return fetch_by_id(args) } + if str_eq(tool_name, "acknowledgeEvent") { + let id: String = pick_id(args) + let resp: String = http_post_json(soul_url() + "/events/ack", "{\"id\":\"" + id + "\"}") + return mcp_json_result(resp) + } + if str_eq(tool_name, "processEvents") { return tool_check_events(args) } + if str_eq(tool_name, "sendNotification") { + let content: String = pick_content(args) + let _push: String = http_post_json(soul_url() + "/events/push", "{\"kind\":\"notification\",\"content\":\"" + json_escape(content) + "\"}") + let mem_body: String = "{\"content\":\"[notification] " + json_escape(content) + "\",\"importance\":\"normal\"}" + let resp: String = http_post_json(neuron_url() + "/memory", mem_body) + return mcp_json_result(resp) + } + + // ── Config ────────────────────────────────────────────────────────────── + if str_eq(tool_name, "inspectConfig") { return tool_inspect_config(args) } + if str_eq(tool_name, "tuneConfig") { + let key: String = json_get_string(args, "key") + let value: String = json_get_string(args, "value") + if str_eq(key, "") { return mcp_text_result("error: key is required") } + let body: String = "{\"key\":\"" + json_escape(key) + "\",\"value\":\"" + json_escape(value) + "\"}" + let resp: String = http_post_json(neuron_url() + "/config/tune", body) + return mcp_json_result(resp) + } + + // ── Imprints ──────────────────────────────────────────────────────────── + if str_eq(tool_name, "createImprint") { return create_typed_node(args, "Memory", "0.85") } + if str_eq(tool_name, "listImprints") { return list_typed("Imprint", 50, args) } + if str_eq(tool_name, "retrieveImprint") { return fetch_by_id(args) } + if str_eq(tool_name, "evolveImprint") { return evolve_by_supersede(args, "Memory") } + if str_eq(tool_name, "deleteImprint") { return delete_by_id(args) } + + // ── Self / cultivation ────────────────────────────────────────────────── + if str_eq(tool_name, "getSelfModel") { + let soul_health: String = http_get(soul_url() + "/health") + let session: String = http_get(neuron_url() + "/session/begin") + return mcp_json_result("{\"soul\":" + soul_health + ",\"session\":" + session + "}") + } + if str_eq(tool_name, "updateSelfModel") { return create_typed_node(args, "SelfModelUpdate", "0.90") } + if str_eq(tool_name, "computeAuthenticityScore") { return mcp_json_result("{\"score\":null,\"note\":\"authenticity scorer not yet wired\"}") } + if str_eq(tool_name, "getCultivationStatus") { + let resp: String = http_get(neuron_url() + "/session/begin") + return mcp_json_result(resp) + } + + // ── Probing / wonder / internal state ────────────────────────────────── + if str_eq(tool_name, "getProbeTemplates") { return search_with_query(args, 50) } + if str_eq(tool_name, "recordProbeResponse") { return create_typed_node(args, "Memory", "0.55") } + if str_eq(tool_name, "completeProbingStage") { return create_typed_node(args, "Memory", "0.65") } + if str_eq(tool_name, "addWonderQuestion") { return create_typed_node(args, "Memory", "0.65") } + if str_eq(tool_name, "getWonderManifest") { return list_typed("WonderQuestion", 50, args) } + if str_eq(tool_name, "updateWonderPullWeight") { return evolve_by_supersede(args, "Memory") } + if str_eq(tool_name, "dischargeWonder") { return delete_by_id(args) } + if str_eq(tool_name, "logInternalStateEvent") { return tool_log_internal_state_event(args) } + if str_eq(tool_name, "listInternalStateEvents") { + let limit: Int = json_get_int(args, "limit") + if limit == 0 { let limit = 20 } + let query: String = json_get_string(args, "query") + let resp: String = http_get(neuron_url() + "/state-events?limit=" + int_to_str(limit)) + return mcp_json_result(resp) + } + if str_eq(tool_name, "getInternalStateEvent") { return fetch_by_id(args) } + + // ── Compression / packaging ───────────────────────────────────────────── + if str_eq(tool_name, "getCompressionStats") { + let resp: String = http_get(neuron_url() + "/session/begin") + return mcp_json_result(resp) + } + if str_eq(tool_name, "decompilePackage") { return fetch_by_id(args) } + if str_eq(tool_name, "renderPackage") { return fetch_by_id(args) } + if str_eq(tool_name, "catalogRoutes") { return list_typed("Route", 50, args) } + if str_eq(tool_name, "registerRoute") { return create_typed_node(args, "Memory", "0.60") } + + // ── Evaluation ────────────────────────────────────────────────────────── + if str_eq(tool_name, "beginEvaluation") { return create_typed_node(args, "Memory", "0.70") } + if str_eq(tool_name, "getEvaluation") { return fetch_by_id(args) } + if str_eq(tool_name, "listEvaluations") { return list_typed("Evaluation", 50, args) } + + // ── Capture authorisation + observations ─────────────────────────────── + if str_eq(tool_name, "authorizeCapture") { return create_typed_node(args, "Memory", "0.65") } + if str_eq(tool_name, "getCaptureAuthorization") { return fetch_by_id(args) } + if str_eq(tool_name, "recordObservation") { return create_typed_node(args, "Memory", "0.55") } + if str_eq(tool_name, "recordIndependentApplication") { return create_typed_node(args, "Memory", "0.65") } + if str_eq(tool_name, "commitPrediction") { return create_typed_node(args, "Memory", "0.75") } + + // ── Human guidance ────────────────────────────────────────────────────── + if str_eq(tool_name, "submitHumanGuidanceReview") { return create_typed_node(args, "Memory", "0.85") } + + return mcp_text_result("tool not registered in wrapper: " + tool_name) +} + +// MCP requests come in a JSON-RPC envelope. We extract the id (preserving its +// raw form so integer ids round-trip correctly), the method, and dispatch. +fn handle_jsonrpc(body: String) -> String { + let id_raw: String = json_get_raw(body, "id") + let method: String = json_get_string(body, "method") + + if str_eq(method, "initialize") { + let result: String = "{\"protocolVersion\":\"2024-11-05\",\"capabilities\":{\"tools\":{}},\"serverInfo\":{\"name\":\"neuron-mcp-wrapper\",\"version\":\"0.2.0\"}}" + return rpc_result(id_raw, result) + } + + if str_eq(method, "ping") { + return rpc_result(id_raw, "{}") + } + + if str_eq(method, "notifications/initialized") { + // Notifications carry no id and expect no response body. + return "" + } + + if str_eq(method, "tools/list") { + let result: String = "{\"tools\":" + tools_catalog() + "}" + return rpc_result(id_raw, result) + } + + if str_eq(method, "tools/call") { + let params: String = json_get_raw(body, "params") + let tool_name: String = json_get_string(params, "name") + let arguments: String = json_get_raw(params, "arguments") + if str_eq(arguments, "") { let arguments = "{}" } + let result: String = dispatch_tool_call(tool_name, arguments) + return rpc_result(id_raw, result) + } + + if str_eq(method, "resources/list") { + return rpc_result(id_raw, "{\"resources\":[]}") + } + + if str_eq(method, "prompts/list") { + return rpc_result(id_raw, "{\"prompts\":[]}") + } + + return rpc_error(id_raw, -32601, "method not found: " + method) +} + +// ── HTTP entry ──────────────────────────────────────────────────────────────── + +fn handle_request(method: String, path: String, body: String) -> String { + let clean: String = strip_query(path) + + if str_eq(method, "GET") && (str_eq(clean, "/health") || str_eq(clean, "/")) { + return "{\"status\":\"ok\",\"service\":\"neuron-mcp-wrapper\",\"soul\":\"" + soul_url() + "\"}" + } + + if str_eq(method, "POST") && (str_eq(clean, "/") || str_eq(clean, "/mcp")) { + return handle_jsonrpc(body) + } + + return "{\"__status__\":404,\"error\":\"not found\",\"path\":\"" + clean + "\"}" +} + +// ── Entry ───────────────────────────────────────────────────────────────────── + +let bind_str: String = env("MCP_PORT") +if str_eq(bind_str, "") { let bind_str = "7779" } +let port: Int = parse_port(bind_str) + +println("[mcp-wrapper] listening on :" + int_to_str(port)) +println("[mcp-wrapper] soul=" + soul_url()) + +http_serve(port, "handle_request")