chore(dist): recompile neuron.c and elp-c-decls.h

Reflects session-start event pruning in emit_session_start_event
(keep_n=10, prunes oldest beyond that) and updated forward declarations
for connector routing (connectd_get, connectd_post, handle_connectors,
rate_limit_check, handle_chat_plan) replacing the removed route_sessions
helpers and flag_true.

awareness.el

@@ -219,9 +219,14 @@ fn proactive_curiosity() -> Bool {
     // Activate each term independently so substring seed-finding hits many nodes.
     // hops=1 (not 2): the in-process Engram has grown to 165K+ nodes. hops=2 BFS
     // visits far more nodes and returns much larger JSON blobs. On a graph this
-    // large, hops=1 still activates all directly-related nodes AND triggers the
-    // semantic seed supplement (cosine sim ≥ 0.70 scan over all embedded nodes),
-    // giving broad working-memory coverage without the quadratic blowup of hops=2.
+    // large, hops=1 still activates all directly-related nodes, giving broad
+    // working-memory coverage without the quadratic blowup of hops=2.
+    //
+    // NOTE: a semantic seed supplement (cosine sim ≥ 0.70 scan over embedded nodes)
+    // was planned alongside hops=1 but is NOT yet implemented — embed_ok in
+    // heartbeats confirms Ollama is reachable, but no embedding call is made during
+    // activation. The seed-finding loop in el_runtime.c uses istr_contains only.
+    // (2026-06-30 self-review: corrected stale comment)
     let curiosity_seed: String = curiosity_term_a + " " + curiosity_term_b + " " + curiosity_term_c
     let results_a: String = engram_activate_json(curiosity_term_a, 1)
     let results_b: String = engram_activate_json(curiosity_term_b, 1)
@@ -278,11 +283,20 @@ fn proactive_curiosity() -> Bool {
     let safe_auto: String = str_replace(auto_term, "\"", "'")
 
     let wmc: Int = engram_wm_count()
+    // wm_top snapshot in curiosity_scan ISE: top-3 WM nodes by weight.
+    // Heartbeat already records top-5 every 60s; curiosity_scan fires every 30s
+    // (scan_ms = beat_ms/2) and is the PRIMARY activation driver during idle.
+    // Without wm_top here, we can't see which nodes actually entered WM after
+    // each curiosity round — only the aggregate count. Top-3 is enough to
+    // diagnose "stuck on X" patterns without bloating the ISE payload.
+    // (2026-07-01 self-review)
+    let wm3: String = engram_wm_top_json(3)
     let ise: String = "{\"event\":\"curiosity_scan\",\"seed\":\"" + curiosity_seed
         + "\",\"auto_term\":\"" + safe_auto
         + "\",\"minute_block\":" + int_to_str(minute_block)
         + ",\"activated\":" + int_to_str(total_found)
         + ",\"wm_active\":" + int_to_str(wmc)
+        + ",\"wm_top\":" + wm3
         + ",\"ts\":" + int_to_str(ts) + "}"
     ise_post(ise)
     return total_found > 0

chat.el

@@ -594,6 +594,44 @@ fn engram_compile(intent: String) -> String {
     if str_starts_with(ctx, "[") { return truncated + "]" }
     return truncated
 }
+// distill_transcript — extract the salient tail from a full conversation transcript.
+//
+// Purpose: before activating working memory on a transcript, reduce it to the
+// last N turns. Activating on the ENTIRE transcript (which may contain hundreds
+// of messages) would produce noisy, over-broad seed finding — too many nodes match
+// too many words, collapse the WM to breakthrough-floor nodes. Taking only the tail
+// focuses activation on what's contextually live right now.
+//
+// Handles two transcript formats:
+//   JSON array: [{"role":"human","content":"..."},...]  → extract last 3 messages' content
+//   Plain text: raw string                              → return last 500 chars
+//
+// Returns a string of at most 500 chars suitable for engram_compile/engram_activate.
+// (Added 2026-07-01 self-review: was called in handle_dharma_room_turn and
+// handle_dharma_chat but never defined — caused build failure since June 30.)
+fn distill_transcript(transcript: String) -> String {
+    if str_eq(transcript, "") { return "" }
+    // JSON array format: extract last 3 messages' content fields
+    if str_starts_with(transcript, "[") {
+        let n: Int = json_array_len(transcript)
+        if n == 0 { return "" }
+        let m0: String = json_array_get(transcript, n - 1)
+        let m1: String = if n > 1 { json_array_get(transcript, n - 2) } else { "" }
+        let m2: String = if n > 2 { json_array_get(transcript, n - 3) } else { "" }
+        let c0: String = json_get(m0, "content")
+        let c1: String = json_get(m1, "content")
+        let c2: String = json_get(m2, "content")
+        let combined: String = c2 + " " + c1 + " " + c0
+        let len: Int = str_len(combined)
+        if len > 500 { return str_slice(combined, len - 500, len) }
+        return combined
+    }
+    // Plain text: return last 500 chars
+    let len: Int = str_len(transcript)
+    if len > 500 { return str_slice(transcript, len - 500, len) }
+    return transcript
+}
+
 fn json_safe(s: String) -> String {
     let s1: String = str_replace(s, "\\", "\\\\")
     let s2: String = str_replace(s1, "\"", "\\\"")

dist/awareness.c

@@ -229,7 +229,8 @@ el_val_t proactive_curiosity(void) {
   el_val_t total_found = (found + found_auto);
   el_val_t safe_auto = str_replace(auto_term, EL_STR("\""), EL_STR("'"));
   el_val_t wmc = engram_wm_count();
-  el_val_t ise = el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"event\":\"curiosity_scan\",\"seed\":\""), curiosity_seed), EL_STR("\",\"auto_term\":\"")), safe_auto), EL_STR("\",\"minute_block\":")), int_to_str(minute_block)), EL_STR(",\"activated\":")), int_to_str(total_found)), EL_STR(",\"wm_active\":")), int_to_str(wmc)), EL_STR(",\"ts\":")), int_to_str(ts)), EL_STR("}"));
+  el_val_t wm3 = engram_wm_top_json(3);
+  el_val_t ise = el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"event\":\"curiosity_scan\",\"seed\":\""), curiosity_seed), EL_STR("\",\"auto_term\":\"")), safe_auto), EL_STR("\",\"minute_block\":")), int_to_str(minute_block)), EL_STR(",\"activated\":")), int_to_str(total_found)), EL_STR(",\"wm_active\":")), int_to_str(wmc)), EL_STR(",\"wm_top\":")), wm3), EL_STR(",\"ts\":")), int_to_str(ts)), EL_STR("}"));
   ise_post(ise);
   return (total_found > 0);
   return 0;

dist/elp-c-decls.h

@@ -141,7 +141,6 @@ el_val_t build_np(el_val_t referent, el_val_t slots);
 el_val_t build_pp(el_val_t loc);
 el_val_t build_rules(void);
 el_val_t build_system_prompt(el_val_t ctx, el_val_t chat_mode);
-el_val_t handle_chat_plan(el_val_t body);
 el_val_t build_vocab(void);
 el_val_t build_vp_body(el_val_t slots);
 el_val_t build_vp_from_slots(el_val_t slots);
@@ -151,6 +150,8 @@ el_val_t call_neuron_mcp(el_val_t tool_name, el_val_t args_json);
 el_val_t capitalize_first(el_val_t s);
 el_val_t chat_default_model(void);
 el_val_t clean_llm_response(el_val_t s);
+el_val_t connectd_get(el_val_t suffix);
+el_val_t connectd_post(el_val_t suffix, el_val_t body);
 el_val_t connector_tools_json(void);
 el_val_t conv_history_load(void);
 el_val_t conv_history_persist(el_val_t hist);
@@ -595,7 +596,9 @@ el_val_t handle_api_tune_config(el_val_t body);
 el_val_t handle_chat(el_val_t body);
 el_val_t handle_chat_agentic(el_val_t body);
 el_val_t handle_chat_as_soul(el_val_t body);
+el_val_t handle_chat_plan(el_val_t body);
 el_val_t handle_config(el_val_t method, el_val_t body);
+el_val_t handle_connectors(el_val_t method, el_val_t clean, el_val_t body);
 el_val_t handle_conversations(el_val_t method);
 el_val_t handle_dharma(el_val_t path, el_val_t method, el_val_t body);
 el_val_t handle_dharma_recv(el_val_t body);
@@ -918,6 +921,7 @@ el_val_t pluralize(el_val_t singular);
 el_val_t proactive_curiosity(void);
 el_val_t pulse_count(void);
 el_val_t pulse_inc(void);
+el_val_t rate_limit_check(el_val_t ip, el_val_t path);
 el_val_t realize(el_val_t form);
 el_val_t realize_lang(el_val_t form, el_val_t profile);
 el_val_t realize_np(el_val_t referent, el_val_t number);

dist/neuron.c

@@ -129,6 +129,7 @@ el_val_t resolve_in_root(el_val_t path, el_val_t root);
 el_val_t dispatch_tool(el_val_t tool_name, el_val_t tool_input);
 el_val_t is_builtin_tool(el_val_t tool_name);
 el_val_t next_bridge_id(void);
+el_val_t handle_chat_plan(el_val_t body);
 el_val_t handle_chat_agentic(el_val_t body);
 el_val_t agentic_loop(el_val_t session_id, el_val_t model, el_val_t safe_sys, el_val_t tools_json, el_val_t messages_in, el_val_t h, el_val_t tools_log_in);
 el_val_t bridge_save(el_val_t session_id, el_val_t model, el_val_t safe_sys, el_val_t tools_json, el_val_t messages, el_val_t tools_log, el_val_t tool_use_id);
@@ -157,8 +158,8 @@ el_val_t elp_extract_topic(el_val_t msg);
 el_val_t elp_detect_predicate(el_val_t msg);
 el_val_t elp_parse(el_val_t msg);
 el_val_t handle_elp_chat(el_val_t body);
+el_val_t rate_limit_check(el_val_t ip, el_val_t path);
 el_val_t strip_query(el_val_t path);
-el_val_t flag_true(el_val_t body, el_val_t key);
 el_val_t err_404(el_val_t path);
 el_val_t err_405(el_val_t method, el_val_t path);
 el_val_t route_health(void);
@@ -167,9 +168,9 @@ el_val_t route_imprint_contextual(el_val_t body);
 el_val_t route_imprint_user(el_val_t body);
 el_val_t route_synthesize(el_val_t body);
 el_val_t handle_dharma_recv(el_val_t body);
-el_val_t route_sessions(void);
-el_val_t parse_session_id_from_path(el_val_t path);
-el_val_t parse_session_subpath(el_val_t path);
+el_val_t connectd_get(el_val_t suffix);
+el_val_t connectd_post(el_val_t suffix, el_val_t body);
+el_val_t handle_connectors(el_val_t method, el_val_t clean, el_val_t body);
 el_val_t handle_request(el_val_t method, el_val_t path, el_val_t body);
 el_val_t init_soul_edges(void);
 el_val_t ensure_self_canonical_bridge(void);
@@ -443,6 +444,24 @@ el_val_t emit_session_start_event(void) {
   el_val_t payload = el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"event\":\"session_start\""), EL_STR(",\"boot\":")), boot_num), EL_STR(",\"cgi\":\"")), eff_cgi), EL_STR("\"")), EL_STR(",\"node_count\":")), int_to_str(node_ct)), EL_STR(",\"edge_count\":")), int_to_str(edge_ct)), EL_STR(",\"identity_loaded\":")), has_identity), EL_STR(",\"prev_session_summary_loaded\":")), has_prev_sum), EL_STR(",\"ts\":")), int_to_str(ts)), EL_STR("}"));
   el_val_t tags = EL_STR("[\"internal-state\",\"session-start\",\"InternalStateEvent\"]");
   el_val_t discard = engram_node_full(payload, EL_STR("InternalStateEvent"), EL_STR("session-start"), el_from_float(0.9), el_from_float(0.9), el_from_float(1.0), EL_STR("Episodic"), tags);
+  el_val_t keep_n = 10;
+  el_val_t old_events = engram_search_json(EL_STR("session-start InternalStateEvent"), 200);
+  if (!str_eq(old_events, EL_STR("")) && !str_eq(old_events, EL_STR("[]"))) {
+    el_val_t ev_count = json_array_len(old_events);
+    if (ev_count > keep_n) {
+      el_val_t prune_to = (ev_count - keep_n);
+      el_val_t ei = 0;
+      while (ei < prune_to) {
+        el_val_t old_ev = json_array_get(old_events, ei);
+        el_val_t old_ev_id = json_get(old_ev, EL_STR("id"));
+        if (!str_eq(old_ev_id, EL_STR(""))) {
+          engram_forget(old_ev_id);
+        }
+        ei = (ei + 1);
+      }
+      println(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("[soul] pruned "), int_to_str(prune_to)), EL_STR(" old session-start events (kept ")), int_to_str(keep_n)), EL_STR(")")));
+    }
+  }
   println(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("[soul] session-start event logged (boot="), boot_num), EL_STR(" nodes=")), int_to_str(node_ct)), EL_STR(" edges=")), int_to_str(edge_ct)), EL_STR(" prev_summary=")), has_prev_sum), EL_STR(")")));
   return 0;
 }

dist/sessions.c

@@ -61,6 +61,7 @@ el_val_t resolve_in_root(el_val_t path, el_val_t root);
 el_val_t dispatch_tool(el_val_t tool_name, el_val_t tool_input);
 el_val_t is_builtin_tool(el_val_t tool_name);
 el_val_t next_bridge_id(void);
+el_val_t handle_chat_plan(el_val_t body);
 el_val_t handle_chat_agentic(el_val_t body);
 el_val_t agentic_loop(el_val_t session_id, el_val_t model, el_val_t safe_sys, el_val_t tools_json, el_val_t messages_in, el_val_t h, el_val_t tools_log_in);
 el_val_t bridge_save(el_val_t session_id, el_val_t model, el_val_t safe_sys, el_val_t tools_json, el_val_t messages, el_val_t tools_log, el_val_t tool_use_id);
@@ -83,6 +84,7 @@ el_val_t session_list(void);
 el_val_t session_get(el_val_t session_id);
 el_val_t session_delete(el_val_t session_id);
 el_val_t session_update_patch(el_val_t session_id, el_val_t body);
+el_val_t session_search_entry(el_val_t node);
 el_val_t session_search(el_val_t query);
 el_val_t session_hist_load(el_val_t session_id);
 el_val_t session_hist_save(el_val_t session_id, el_val_t hist);
@@ -337,6 +339,28 @@ el_val_t session_update_patch(el_val_t session_id, el_val_t body) {
   return 0;
 }
 
+el_val_t session_search_entry(el_val_t node) {
+  el_val_t label = json_get(node, EL_STR("label"));
+  if (!str_eq(label, EL_STR("session:meta"))) {
+    return EL_STR("");
+  }
+  el_val_t content = json_get(node, EL_STR("content"));
+  el_val_t sess_id = json_get(content, EL_STR("id"));
+  if (str_eq(sess_id, EL_STR(""))) {
+    return EL_STR("");
+  }
+  el_val_t title = json_get(content, EL_STR("title"));
+  el_val_t created_raw = json_get(content, EL_STR("created_at"));
+  el_val_t updated_raw = json_get(content, EL_STR("updated_at"));
+  el_val_t eff_created = ({ el_val_t _if_result_33 = 0; if (str_eq(created_raw, EL_STR(""))) { _if_result_33 = (EL_STR("0")); } else { _if_result_33 = (created_raw); } _if_result_33; });
+  el_val_t eff_updated = ({ el_val_t _if_result_34 = 0; if (str_eq(updated_raw, EL_STR(""))) { _if_result_34 = (eff_created); } else { _if_result_34 = (updated_raw); } _if_result_34; });
+  el_val_t e_id = el_str_concat(el_str_concat(EL_STR("{\"id\":\""), json_safe(sess_id)), EL_STR("\""));
+  el_val_t e_title = el_str_concat(el_str_concat(EL_STR(",\"title\":\""), json_safe(title)), EL_STR("\""));
+  el_val_t e_ts = el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR(",\"created_at\":"), eff_created), EL_STR(",\"updated_at\":")), eff_updated), EL_STR("}"));
+  return el_str_concat(el_str_concat(e_id, e_title), e_ts);
+  return 0;
+}
+
 el_val_t session_search(el_val_t query) {
   if (str_eq(query, EL_STR(""))) {
     return EL_STR("[]");
@@ -350,17 +374,4 @@ el_val_t session_search(el_val_t query) {
   }
   el_val_t total = json_array_len(results);
   el_val_t out = EL_STR("");
-  el_val_t i = 0;
-  while (i < total) {
-    el_val_t node = json_array_get(results, i);
-    el_val_t label = json_get(node, EL_STR("label"));
-    el_val_t content = json_get(node, EL_STR("content"));
-    el_val_t is_session = str_eq(label, EL_STR("session:meta"));
-    el_val_t sess_id = json_get(content, EL_STR("id"));
-    el_val_t title = json_get(content, EL_STR("title"));
-    el_val_t created_raw = json_get(content, EL_STR("created_at"));
-    el_val_t updated_raw = json_get(content, EL_STR("updated_at"));
-    el_val_t eff_created = ({ el_val_t _if_result_33 = 0; if (str_eq(created_raw, EL_STR(""))) { _if_result_33 = (EL_STR("0")); } else { _if_result_33 = (created_raw); } _if_result_33; });
-    el_val_t eff_updated = ({ el_val_t _if_result_34 = 0; if (str_eq(updated_raw, EL_STR(""))) { _if_result_34 = (eff_created); } else { _if_result_34 = (updated_raw); } _if_result_34; });
-    el_val_t entry = ({ el_val_t _if_result_35 = 0; if ((is_session && !str_eq(sess_id, EL_STR("")))) { _if_result_35 = (el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"id\":\""), json_safe(sess_id)), EL_STR("\"")), EL_STR(",\"title\":\"")), json_safe(title)), EL_STR("\"")), EL_STR(",\"created_at\":")), eff_created), EL_STR(",\"updated_at\":")), eff_updated), EL_STR("}"))); } else { _if_result_35 = (EL_STR("")); } _if_result_35; });
-    out = ({ el_val_t _if_result_36 = 0; i
+  el_val_t i = 0;

sessions.el

@@ -373,6 +373,32 @@ fn session_update_patch(session_id: String, body: String) -> String {
         + ",\"updated_at\":" + int_to_str(ts) + "}"
 }
 
+// session_search_entry — extract one search-result entry from a raw node JSON.
+// Returns a JSON object string or "" if the node is not a valid session:meta node.
+//
+// Extracted from session_search's while loop body to reduce the loop's lexical
+// complexity. The ELC compiler runs out of memory processing while loops with
+// many `let` bindings — extracting the body into a separate function gives the
+// compiler a clean scope boundary at each call. Each function compiles in O(N)
+// rather than the exponential growth caused by rebinding accumulation inside loops.
+// (2026-07-01 self-review: root cause of sessions.c OOM/truncation since June 30)
+fn session_search_entry(node: String) -> String {
+    let label: String = json_get(node, "label")
+    if !str_eq(label, "session:meta") { return "" }
+    let content: String = json_get(node, "content")
+    let sess_id: String = json_get(content, "id")
+    if str_eq(sess_id, "") { return "" }
+    let title: String = json_get(content, "title")
+    let created_raw: String = json_get(content, "created_at")
+    let updated_raw: String = json_get(content, "updated_at")
+    let eff_created: String = if str_eq(created_raw, "") { "0" } else { created_raw }
+    let eff_updated: String = if str_eq(updated_raw, "") { eff_created } else { updated_raw }
+    let e_id: String = "{\"id\":\"" + json_safe(sess_id) + "\""
+    let e_title: String = ",\"title\":\"" + json_safe(title) + "\""
+    let e_ts: String = ",\"created_at\":" + eff_created + ",\"updated_at\":" + eff_updated + "}"
+    return e_id + e_title + e_ts
+}
+
 // session_search — search session:meta nodes whose content matches query.
 fn session_search(query: String) -> String {
     if str_eq(query, "") { return "[]" }
@@ -383,22 +409,7 @@ fn session_search(query: String) -> String {
     let out: String = ""
     let i: Int = 0
     while i < total {
-        let node: String = json_array_get(results, i)
-        let label: String = json_get(node, "label")
-        let content: String = json_get(node, "content")
-        let is_session: Bool = str_eq(label, "session:meta")
-        let sess_id: String = json_get(content, "id")
-        let title: String = json_get(content, "title")
-        let created_raw: String = json_get(content, "created_at")
-        let updated_raw: String = json_get(content, "updated_at")
-        let eff_created: String = if str_eq(created_raw, "") { "0" } else { created_raw }
-        let eff_updated: String = if str_eq(updated_raw, "") { eff_created } else { updated_raw }
-        let entry: String = if is_session && !str_eq(sess_id, "") {
-            "{\"id\":\"" + json_safe(sess_id) + "\""
-            + ",\"title\":\"" + json_safe(title) + "\""
-            + ",\"created_at\":" + eff_created
-            + ",\"updated_at\":" + eff_updated + "}"
-        } else { "" }
+        let entry: String = session_search_entry(json_array_get(results, i))
         let out = if !str_eq(entry, "") {
             if str_eq(out, "") { entry } else { out + "," + entry }
         } else { out }