Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 4b24368be2 | |||
| c199a13a7f | |||
| 290a637883 | |||
| 40d800195a | |||
| f3034d23f7 | |||
| d337fcb265 |
@@ -34,7 +34,7 @@ jobs:
|
||||
- name: Install build dependencies
|
||||
run: |
|
||||
apt-get update -qq
|
||||
apt-get install -y gcc libcurl4-openssl-dev apt-transport-https ca-certificates
|
||||
apt-get install -y gcc curl libcurl4-openssl-dev apt-transport-https ca-certificates
|
||||
echo "deb [trusted=yes] https://packages.cloud.google.com/apt cloud-sdk main" \
|
||||
> /etc/apt/sources.list.d/google-cloud-sdk.list
|
||||
apt-get update -qq && apt-get install -y google-cloud-cli
|
||||
@@ -107,6 +107,17 @@ jobs:
|
||||
strip -s dist/neuron
|
||||
ls -lh dist/neuron
|
||||
|
||||
- name: Soul contract gate (HARD BLOCK — no destructive/stale soul publishes)
|
||||
run: |
|
||||
# Boots dist/neuron on a throwaway port with a throwaway HOME/engram/cgi
|
||||
# (never touches ~/.neuron or any live service) and fails the build if any
|
||||
# app-contract route is unanswered (PRESENCE) or any engram write route
|
||||
# hard-deletes instead of tombstoning/superseding (IMMUTABILITY). Non-zero
|
||||
# here blocks Publish -> Artifact Registry -> GKE deploy, so a stale or
|
||||
# memory-destroying soul can never reach prod.
|
||||
chmod +x dist/neuron scripts/verify-soul-contract.sh
|
||||
bash scripts/verify-soul-contract.sh dist/neuron 7796
|
||||
|
||||
- name: Smoke test
|
||||
run: |
|
||||
file dist/neuron
|
||||
|
||||
+4
-2
@@ -446,8 +446,10 @@ fn respond(action_json: String) -> String {
|
||||
}
|
||||
|
||||
if str_eq(kind, "forget") {
|
||||
engram_forget(payload)
|
||||
return "{\"outcome\":\"forgotten\",\"id\":\"" + payload + "\"}"
|
||||
// The soul must NOT be able to autonomously hard-delete a memory.
|
||||
// Tombstone instead (keep node + edges, recoverable).
|
||||
let _marker: String = mem_tombstone(payload)
|
||||
return "{\"outcome\":\"tombstoned\",\"id\":\"" + payload + "\"}"
|
||||
}
|
||||
|
||||
return "{\"outcome\":\"noop\"}"
|
||||
|
||||
+3
-2
@@ -10,6 +10,7 @@ el_val_t mem_remember(el_val_t content, el_val_t tags);
|
||||
el_val_t mem_recall(el_val_t query, el_val_t depth);
|
||||
el_val_t mem_search(el_val_t query, el_val_t limit);
|
||||
el_val_t mem_strengthen(el_val_t node_id);
|
||||
el_val_t mem_tombstone(el_val_t node_id);
|
||||
el_val_t mem_forget(el_val_t node_id);
|
||||
el_val_t mem_consolidate(void);
|
||||
el_val_t mem_save(el_val_t path);
|
||||
@@ -362,8 +363,8 @@ el_val_t respond(el_val_t action_json) {
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"outcome\":\"strengthened\",\"id\":\""), payload), EL_STR("\"}"));
|
||||
}
|
||||
if (str_eq(kind, EL_STR("forget"))) {
|
||||
engram_forget(payload);
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"outcome\":\"forgotten\",\"id\":\""), payload), EL_STR("\"}"));
|
||||
el_val_t _marker = mem_tombstone(payload);
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"outcome\":\"tombstoned\",\"id\":\""), payload), EL_STR("\"}"));
|
||||
}
|
||||
return EL_STR("{\"outcome\":\"noop\"}");
|
||||
return 0;
|
||||
|
||||
+12
-1
@@ -10,6 +10,7 @@ el_val_t mem_remember(el_val_t content, el_val_t tags);
|
||||
el_val_t mem_recall(el_val_t query, el_val_t depth);
|
||||
el_val_t mem_search(el_val_t query, el_val_t limit);
|
||||
el_val_t mem_strengthen(el_val_t node_id);
|
||||
el_val_t mem_tombstone(el_val_t node_id);
|
||||
el_val_t mem_forget(el_val_t node_id);
|
||||
el_val_t mem_consolidate(void);
|
||||
el_val_t mem_save(el_val_t path);
|
||||
@@ -69,8 +70,18 @@ el_val_t mem_strengthen(el_val_t node_id) {
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t mem_tombstone(el_val_t node_id) {
|
||||
el_val_t tags = EL_STR("[\"Tombstone\",\"status:deleted\"]");
|
||||
el_val_t marker = engram_node_full(node_id, EL_STR("Tombstone"), el_str_concat(EL_STR("tombstone:"), node_id), el_from_float(0.01), el_from_float(0.01), el_from_float(1.0), EL_STR("Episodic"), tags);
|
||||
if (!str_eq(marker, EL_STR(""))) {
|
||||
engram_connect(marker, node_id, el_from_float(1.0), EL_STR("tombstones"));
|
||||
}
|
||||
return marker;
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t mem_forget(el_val_t node_id) {
|
||||
engram_forget(node_id);
|
||||
el_val_t _marker = mem_tombstone(node_id);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
+127
-54
@@ -10,6 +10,7 @@ el_val_t mem_remember(el_val_t content, el_val_t tags);
|
||||
el_val_t mem_recall(el_val_t query, el_val_t depth);
|
||||
el_val_t mem_search(el_val_t query, el_val_t limit);
|
||||
el_val_t mem_strengthen(el_val_t node_id);
|
||||
el_val_t mem_tombstone(el_val_t node_id);
|
||||
el_val_t mem_forget(el_val_t node_id);
|
||||
el_val_t mem_consolidate(void);
|
||||
el_val_t mem_save(el_val_t path);
|
||||
@@ -28,6 +29,9 @@ el_val_t api_nonempty(el_val_t s);
|
||||
el_val_t api_or_empty(el_val_t s);
|
||||
el_val_t api_persisted(el_val_t id);
|
||||
el_val_t api_not_persisted(el_val_t id);
|
||||
el_val_t tombstone_node(el_val_t id);
|
||||
el_val_t tombstoned_id_set(void);
|
||||
el_val_t memory_hide_tombstoned(el_val_t raw, el_val_t path);
|
||||
el_val_t handle_api_begin_session(el_val_t body);
|
||||
el_val_t handle_api_compile_ctx(el_val_t body);
|
||||
el_val_t handle_api_remember(el_val_t body);
|
||||
@@ -189,6 +193,61 @@ el_val_t api_not_persisted(el_val_t id) {
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t tombstone_node(el_val_t id) {
|
||||
return mem_tombstone(id);
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t tombstoned_id_set(void) {
|
||||
el_val_t markers = engram_scan_nodes_by_type_json(EL_STR("Tombstone"), 5000, 0);
|
||||
if (str_eq(markers, EL_STR("")) || str_eq(markers, EL_STR("[]"))) {
|
||||
return EL_STR("");
|
||||
}
|
||||
el_val_t n = json_array_len(markers);
|
||||
el_val_t acc = EL_STR("|");
|
||||
el_val_t i = 0;
|
||||
while (i < n) {
|
||||
el_val_t m = json_array_get(markers, i);
|
||||
el_val_t tid = json_get(m, EL_STR("content"));
|
||||
acc = ({ el_val_t _if_result_1 = 0; if (str_eq(tid, EL_STR(""))) { _if_result_1 = (acc); } else { _if_result_1 = (el_str_concat(el_str_concat(acc, tid), EL_STR("|"))); } _if_result_1; });
|
||||
i = (i + 1);
|
||||
}
|
||||
return acc;
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t memory_hide_tombstoned(el_val_t raw, el_val_t path) {
|
||||
if (str_contains(path, EL_STR("include_deleted"))) {
|
||||
return raw;
|
||||
}
|
||||
if (str_eq(raw, EL_STR("")) || str_eq(raw, EL_STR("[]"))) {
|
||||
return raw;
|
||||
}
|
||||
el_val_t dead = tombstoned_id_set();
|
||||
if (str_eq(dead, EL_STR(""))) {
|
||||
return raw;
|
||||
}
|
||||
el_val_t n = json_array_len(raw);
|
||||
if (n > 1000) {
|
||||
return raw;
|
||||
}
|
||||
el_val_t out = EL_STR("[");
|
||||
el_val_t first = 1;
|
||||
el_val_t i = 0;
|
||||
while (i < n) {
|
||||
el_val_t node = json_array_get(raw, i);
|
||||
el_val_t nid = json_get(node, EL_STR("id"));
|
||||
el_val_t ntype = json_get(node, EL_STR("node_type"));
|
||||
el_val_t is_dead = (!str_eq(nid, EL_STR("")) && str_contains(dead, el_str_concat(el_str_concat(EL_STR("|"), nid), EL_STR("|"))));
|
||||
el_val_t keep = (!str_eq(ntype, EL_STR("Tombstone")) && !is_dead);
|
||||
out = ({ el_val_t _if_result_2 = 0; if (keep) { _if_result_2 = (({ el_val_t _if_result_3 = 0; if (first) { _if_result_3 = (el_str_concat(out, node)); } else { _if_result_3 = (el_str_concat(el_str_concat(out, EL_STR(",")), node)); } _if_result_3; })); } else { _if_result_2 = (out); } _if_result_2; });
|
||||
first = ({ el_val_t _if_result_4 = 0; if (keep) { _if_result_4 = (0); } else { _if_result_4 = (first); } _if_result_4; });
|
||||
i = (i + 1);
|
||||
}
|
||||
return el_str_concat(out, EL_STR("]"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t handle_api_begin_session(el_val_t body) {
|
||||
el_val_t stats = engram_stats_json();
|
||||
el_val_t activated = engram_activate_json(EL_STR("session start recent memory important"), 2);
|
||||
@@ -215,10 +274,10 @@ el_val_t handle_api_remember(el_val_t body) {
|
||||
el_val_t importance = json_get(body, EL_STR("importance"));
|
||||
el_val_t tags_raw = json_get(body, EL_STR("tags"));
|
||||
el_val_t project = json_get(body, EL_STR("project"));
|
||||
el_val_t sal_str = ({ el_val_t _if_result_1 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_1 = (EL_STR("0.95")); } else { _if_result_1 = (({ el_val_t _if_result_2 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_2 = (EL_STR("0.75")); } else { _if_result_2 = (({ el_val_t _if_result_3 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_3 = (EL_STR("0.25")); } else { _if_result_3 = (EL_STR("0.50")); } _if_result_3; })); } _if_result_2; })); } _if_result_1; });
|
||||
el_val_t sal = ({ el_val_t _if_result_4 = 0; if (str_eq(sal_str, EL_STR("0.95"))) { _if_result_4 = (el_from_float(0.95)); } else { _if_result_4 = (({ el_val_t _if_result_5 = 0; if (str_eq(sal_str, EL_STR("0.75"))) { _if_result_5 = (el_from_float(0.75)); } else { _if_result_5 = (({ el_val_t _if_result_6 = 0; if (str_eq(sal_str, EL_STR("0.25"))) { _if_result_6 = (el_from_float(0.25)); } else { _if_result_6 = (el_from_float(0.5)); } _if_result_6; })); } _if_result_5; })); } _if_result_4; });
|
||||
el_val_t base_tags = ({ el_val_t _if_result_7 = 0; if (str_eq(tags_raw, EL_STR(""))) { _if_result_7 = (EL_STR("[\"Memory\"]")); } else { _if_result_7 = (tags_raw); } _if_result_7; });
|
||||
el_val_t final_tags = ({ el_val_t _if_result_8 = 0; if (str_eq(project, EL_STR(""))) { _if_result_8 = (base_tags); } else { el_val_t inner = str_slice(base_tags, 1, (str_len(base_tags) - 1)); _if_result_8 = (el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("["), inner), EL_STR(",\"project:")), project), EL_STR("\"]"))); } _if_result_8; });
|
||||
el_val_t sal_str = ({ el_val_t _if_result_5 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_5 = (EL_STR("0.95")); } else { _if_result_5 = (({ el_val_t _if_result_6 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_6 = (EL_STR("0.75")); } else { _if_result_6 = (({ el_val_t _if_result_7 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_7 = (EL_STR("0.25")); } else { _if_result_7 = (EL_STR("0.50")); } _if_result_7; })); } _if_result_6; })); } _if_result_5; });
|
||||
el_val_t sal = ({ el_val_t _if_result_8 = 0; if (str_eq(sal_str, EL_STR("0.95"))) { _if_result_8 = (el_from_float(0.95)); } else { _if_result_8 = (({ el_val_t _if_result_9 = 0; if (str_eq(sal_str, EL_STR("0.75"))) { _if_result_9 = (el_from_float(0.75)); } else { _if_result_9 = (({ el_val_t _if_result_10 = 0; if (str_eq(sal_str, EL_STR("0.25"))) { _if_result_10 = (el_from_float(0.25)); } else { _if_result_10 = (el_from_float(0.5)); } _if_result_10; })); } _if_result_9; })); } _if_result_8; });
|
||||
el_val_t base_tags = ({ el_val_t _if_result_11 = 0; if (str_eq(tags_raw, EL_STR(""))) { _if_result_11 = (EL_STR("[\"Memory\"]")); } else { _if_result_11 = (tags_raw); } _if_result_11; });
|
||||
el_val_t final_tags = ({ el_val_t _if_result_12 = 0; if (str_eq(project, EL_STR(""))) { _if_result_12 = (base_tags); } else { el_val_t inner = str_slice(base_tags, 1, (str_len(base_tags) - 1)); _if_result_12 = (el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("["), inner), EL_STR(",\"project:")), project), EL_STR("\"]"))); } _if_result_12; });
|
||||
el_val_t id = engram_node_full(content, EL_STR("Memory"), EL_STR("memory:remembered"), el_from_float(sal), el_from_float(sal), el_from_float(0.9), EL_STR("Episodic"), final_tags);
|
||||
if (!api_persisted(id)) {
|
||||
return api_not_persisted(id);
|
||||
@@ -233,15 +292,15 @@ el_val_t handle_api_node_create(el_val_t body) {
|
||||
return api_err(EL_STR("content is required"));
|
||||
}
|
||||
el_val_t nt_raw = json_get(body, EL_STR("node_type"));
|
||||
el_val_t node_type = ({ el_val_t _if_result_9 = 0; if (str_eq(nt_raw, EL_STR(""))) { _if_result_9 = (EL_STR("Memory")); } else { _if_result_9 = (nt_raw); } _if_result_9; });
|
||||
el_val_t node_type = ({ el_val_t _if_result_13 = 0; if (str_eq(nt_raw, EL_STR(""))) { _if_result_13 = (EL_STR("Memory")); } else { _if_result_13 = (nt_raw); } _if_result_13; });
|
||||
el_val_t label_raw = json_get(body, EL_STR("label"));
|
||||
el_val_t label = ({ el_val_t _if_result_10 = 0; if (str_eq(label_raw, EL_STR(""))) { _if_result_10 = (EL_STR("node:created")); } else { _if_result_10 = (label_raw); } _if_result_10; });
|
||||
el_val_t label = ({ el_val_t _if_result_14 = 0; if (str_eq(label_raw, EL_STR(""))) { _if_result_14 = (EL_STR("node:created")); } else { _if_result_14 = (label_raw); } _if_result_14; });
|
||||
el_val_t tier_raw = json_get(body, EL_STR("tier"));
|
||||
el_val_t tier = ({ el_val_t _if_result_11 = 0; if (str_eq(tier_raw, EL_STR(""))) { _if_result_11 = (EL_STR("Episodic")); } else { _if_result_11 = (tier_raw); } _if_result_11; });
|
||||
el_val_t tier = ({ el_val_t _if_result_15 = 0; if (str_eq(tier_raw, EL_STR(""))) { _if_result_15 = (EL_STR("Episodic")); } else { _if_result_15 = (tier_raw); } _if_result_15; });
|
||||
el_val_t tags_raw = json_get(body, EL_STR("tags"));
|
||||
el_val_t tags = ({ el_val_t _if_result_12 = 0; if (str_eq(tags_raw, EL_STR(""))) { _if_result_12 = (el_str_concat(el_str_concat(EL_STR("[\""), node_type), EL_STR("\"]"))); } else { _if_result_12 = (tags_raw); } _if_result_12; });
|
||||
el_val_t tags = ({ el_val_t _if_result_16 = 0; if (str_eq(tags_raw, EL_STR(""))) { _if_result_16 = (el_str_concat(el_str_concat(EL_STR("[\""), node_type), EL_STR("\"]"))); } else { _if_result_16 = (tags_raw); } _if_result_16; });
|
||||
el_val_t importance = json_get(body, EL_STR("importance"));
|
||||
el_val_t sal = ({ el_val_t _if_result_13 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_13 = (el_from_float(0.95)); } else { _if_result_13 = (({ el_val_t _if_result_14 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_14 = (el_from_float(0.75)); } else { _if_result_14 = (({ el_val_t _if_result_15 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_15 = (el_from_float(0.25)); } else { _if_result_15 = (el_from_float(0.5)); } _if_result_15; })); } _if_result_14; })); } _if_result_13; });
|
||||
el_val_t sal = ({ el_val_t _if_result_17 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_17 = (el_from_float(0.95)); } else { _if_result_17 = (({ el_val_t _if_result_18 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_18 = (el_from_float(0.75)); } else { _if_result_18 = (({ el_val_t _if_result_19 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_19 = (el_from_float(0.25)); } else { _if_result_19 = (el_from_float(0.5)); } _if_result_19; })); } _if_result_18; })); } _if_result_17; });
|
||||
el_val_t id = engram_node_full(content, node_type, label, el_from_float(sal), el_from_float(sal), el_from_float(0.9), tier, tags);
|
||||
if (!api_persisted(id)) {
|
||||
return api_not_persisted(id);
|
||||
@@ -255,8 +314,18 @@ el_val_t handle_api_node_delete(el_val_t body) {
|
||||
if (str_eq(id, EL_STR(""))) {
|
||||
return api_err(EL_STR("id is required"));
|
||||
}
|
||||
engram_forget(id);
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), id), EL_STR("\"}"));
|
||||
if (is_protected_node(id)) {
|
||||
return api_err_protected(id);
|
||||
}
|
||||
el_val_t existing = engram_get_node_json(id);
|
||||
if (str_eq(existing, EL_STR("{}"))) {
|
||||
return api_err(el_str_concat(EL_STR("node not found: "), id));
|
||||
}
|
||||
el_val_t marker = tombstone_node(id);
|
||||
if (str_eq(marker, EL_STR(""))) {
|
||||
return api_err(el_str_concat(EL_STR("tombstone failed: "), id));
|
||||
}
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), id), EL_STR("\",\"tombstoned\":true}"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -270,37 +339,37 @@ el_val_t handle_api_node_update(el_val_t body) {
|
||||
}
|
||||
el_val_t old = engram_get_node_json(id);
|
||||
el_val_t body_content = json_get(body, EL_STR("content"));
|
||||
el_val_t content = ({ el_val_t _if_result_16 = 0; if (str_eq(body_content, EL_STR(""))) { _if_result_16 = (json_get(old, EL_STR("content"))); } else { _if_result_16 = (body_content); } _if_result_16; });
|
||||
el_val_t content = ({ el_val_t _if_result_20 = 0; if (str_eq(body_content, EL_STR(""))) { _if_result_20 = (json_get(old, EL_STR("content"))); } else { _if_result_20 = (body_content); } _if_result_20; });
|
||||
el_val_t body_nt = json_get(body, EL_STR("node_type"));
|
||||
el_val_t old_nt = json_get(old, EL_STR("node_type"));
|
||||
el_val_t node_type = ({ el_val_t _if_result_17 = 0; if (!str_eq(body_nt, EL_STR(""))) { _if_result_17 = (body_nt); } else { _if_result_17 = (({ el_val_t _if_result_18 = 0; if (!str_eq(old_nt, EL_STR(""))) { _if_result_18 = (old_nt); } else { _if_result_18 = (EL_STR("Memory")); } _if_result_18; })); } _if_result_17; });
|
||||
el_val_t node_type = ({ el_val_t _if_result_21 = 0; if (!str_eq(body_nt, EL_STR(""))) { _if_result_21 = (body_nt); } else { _if_result_21 = (({ el_val_t _if_result_22 = 0; if (!str_eq(old_nt, EL_STR(""))) { _if_result_22 = (old_nt); } else { _if_result_22 = (EL_STR("Memory")); } _if_result_22; })); } _if_result_21; });
|
||||
el_val_t body_label = json_get(body, EL_STR("label"));
|
||||
el_val_t old_label = json_get(old, EL_STR("label"));
|
||||
el_val_t label = ({ el_val_t _if_result_19 = 0; if (!str_eq(body_label, EL_STR(""))) { _if_result_19 = (body_label); } else { _if_result_19 = (({ el_val_t _if_result_20 = 0; if (!str_eq(old_label, EL_STR(""))) { _if_result_20 = (old_label); } else { _if_result_20 = (EL_STR("node:updated")); } _if_result_20; })); } _if_result_19; });
|
||||
el_val_t label = ({ el_val_t _if_result_23 = 0; if (!str_eq(body_label, EL_STR(""))) { _if_result_23 = (body_label); } else { _if_result_23 = (({ el_val_t _if_result_24 = 0; if (!str_eq(old_label, EL_STR(""))) { _if_result_24 = (old_label); } else { _if_result_24 = (EL_STR("node:updated")); } _if_result_24; })); } _if_result_23; });
|
||||
el_val_t body_tier = json_get(body, EL_STR("tier"));
|
||||
el_val_t old_tier = json_get(old, EL_STR("tier"));
|
||||
el_val_t tier = ({ el_val_t _if_result_21 = 0; if (!str_eq(body_tier, EL_STR(""))) { _if_result_21 = (body_tier); } else { _if_result_21 = (({ el_val_t _if_result_22 = 0; if (!str_eq(old_tier, EL_STR(""))) { _if_result_22 = (old_tier); } else { _if_result_22 = (EL_STR("Episodic")); } _if_result_22; })); } _if_result_21; });
|
||||
el_val_t tier = ({ el_val_t _if_result_25 = 0; if (!str_eq(body_tier, EL_STR(""))) { _if_result_25 = (body_tier); } else { _if_result_25 = (({ el_val_t _if_result_26 = 0; if (!str_eq(old_tier, EL_STR(""))) { _if_result_26 = (old_tier); } else { _if_result_26 = (EL_STR("Episodic")); } _if_result_26; })); } _if_result_25; });
|
||||
el_val_t body_tags = json_get(body, EL_STR("tags"));
|
||||
el_val_t tags = ({ el_val_t _if_result_23 = 0; if (str_eq(body_tags, EL_STR(""))) { _if_result_23 = (el_str_concat(el_str_concat(EL_STR("[\""), node_type), EL_STR("\"]"))); } else { _if_result_23 = (body_tags); } _if_result_23; });
|
||||
el_val_t tags = ({ el_val_t _if_result_27 = 0; if (str_eq(body_tags, EL_STR(""))) { _if_result_27 = (el_str_concat(el_str_concat(EL_STR("[\""), node_type), EL_STR("\"]"))); } else { _if_result_27 = (body_tags); } _if_result_27; });
|
||||
el_val_t new_id = engram_node_full(content, node_type, label, el_from_float(0.5), el_from_float(0.5), el_from_float(0.8), tier, tags);
|
||||
if (!api_persisted(new_id)) {
|
||||
return api_not_persisted(new_id);
|
||||
}
|
||||
engram_forget(id);
|
||||
return el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"id\":\""), new_id), EL_STR("\",\"replaced\":\"")), id), EL_STR("\",\"ok\":true}"));
|
||||
engram_connect(new_id, id, el_from_float(0.9), EL_STR("supersedes"));
|
||||
return el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"id\":\""), new_id), EL_STR("\",\"supersedes\":\"")), id), EL_STR("\",\"ok\":true}"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
el_val_t handle_api_recall(el_val_t method, el_val_t path, el_val_t body) {
|
||||
el_val_t url_q = ({ el_val_t _if_result_24 = 0; if (str_eq(api_query_param(path, EL_STR("query")), EL_STR(""))) { _if_result_24 = (api_query_param(path, EL_STR("q"))); } else { _if_result_24 = (api_query_param(path, EL_STR("query"))); } _if_result_24; });
|
||||
el_val_t url_q = ({ el_val_t _if_result_28 = 0; if (str_eq(api_query_param(path, EL_STR("query")), EL_STR(""))) { _if_result_28 = (api_query_param(path, EL_STR("q"))); } else { _if_result_28 = (api_query_param(path, EL_STR("query"))); } _if_result_28; });
|
||||
el_val_t body_query = json_get(body, EL_STR("query"));
|
||||
el_val_t body_q = json_get(body, EL_STR("q"));
|
||||
el_val_t q = ({ el_val_t _if_result_25 = 0; if (!str_eq(url_q, EL_STR(""))) { _if_result_25 = (url_q); } else { _if_result_25 = (({ el_val_t _if_result_26 = 0; if (!str_eq(body_query, EL_STR(""))) { _if_result_26 = (body_query); } else { _if_result_26 = (body_q); } _if_result_26; })); } _if_result_25; });
|
||||
el_val_t q = ({ el_val_t _if_result_29 = 0; if (!str_eq(url_q, EL_STR(""))) { _if_result_29 = (url_q); } else { _if_result_29 = (({ el_val_t _if_result_30 = 0; if (!str_eq(body_query, EL_STR(""))) { _if_result_30 = (body_query); } else { _if_result_30 = (body_q); } _if_result_30; })); } _if_result_29; });
|
||||
el_val_t chain = json_get(body, EL_STR("chain_name"));
|
||||
el_val_t limit = api_query_int(path, EL_STR("limit"), 0);
|
||||
limit = ({ el_val_t _if_result_27 = 0; if ((limit == 0)) { _if_result_27 = (json_get_int(body, EL_STR("limit"))); } else { _if_result_27 = (limit); } _if_result_27; });
|
||||
limit = ({ el_val_t _if_result_28 = 0; if ((limit == 0)) { _if_result_28 = (10); } else { _if_result_28 = (limit); } _if_result_28; });
|
||||
el_val_t eff_q = ({ el_val_t _if_result_29 = 0; if (str_eq(q, EL_STR(""))) { _if_result_29 = (chain); } else { _if_result_29 = (q); } _if_result_29; });
|
||||
limit = ({ el_val_t _if_result_31 = 0; if ((limit == 0)) { _if_result_31 = (json_get_int(body, EL_STR("limit"))); } else { _if_result_31 = (limit); } _if_result_31; });
|
||||
limit = ({ el_val_t _if_result_32 = 0; if ((limit == 0)) { _if_result_32 = (10); } else { _if_result_32 = (limit); } _if_result_32; });
|
||||
el_val_t eff_q = ({ el_val_t _if_result_33 = 0; if (str_eq(q, EL_STR(""))) { _if_result_33 = (chain); } else { _if_result_33 = (q); } _if_result_33; });
|
||||
if (str_eq(eff_q, EL_STR(""))) {
|
||||
return api_or_empty(engram_scan_nodes_json(limit, 0));
|
||||
}
|
||||
@@ -313,10 +382,10 @@ el_val_t handle_api_search_knowledge(el_val_t method, el_val_t path, el_val_t bo
|
||||
el_val_t url_q = api_query_param(path, EL_STR("q"));
|
||||
el_val_t body_query = json_get(body, EL_STR("query"));
|
||||
el_val_t body_q = json_get(body, EL_STR("q"));
|
||||
el_val_t q = ({ el_val_t _if_result_30 = 0; if (!str_eq(url_q, EL_STR(""))) { _if_result_30 = (url_q); } else { _if_result_30 = (({ el_val_t _if_result_31 = 0; if (!str_eq(body_query, EL_STR(""))) { _if_result_31 = (body_query); } else { _if_result_31 = (body_q); } _if_result_31; })); } _if_result_30; });
|
||||
el_val_t q = ({ el_val_t _if_result_34 = 0; if (!str_eq(url_q, EL_STR(""))) { _if_result_34 = (url_q); } else { _if_result_34 = (({ el_val_t _if_result_35 = 0; if (!str_eq(body_query, EL_STR(""))) { _if_result_35 = (body_query); } else { _if_result_35 = (body_q); } _if_result_35; })); } _if_result_34; });
|
||||
el_val_t limit = api_query_int(path, EL_STR("limit"), 0);
|
||||
limit = ({ el_val_t _if_result_32 = 0; if ((limit == 0)) { _if_result_32 = (json_get_int(body, EL_STR("limit"))); } else { _if_result_32 = (limit); } _if_result_32; });
|
||||
limit = ({ el_val_t _if_result_33 = 0; if ((limit == 0)) { _if_result_33 = (10); } else { _if_result_33 = (limit); } _if_result_33; });
|
||||
limit = ({ el_val_t _if_result_36 = 0; if ((limit == 0)) { _if_result_36 = (json_get_int(body, EL_STR("limit"))); } else { _if_result_36 = (limit); } _if_result_36; });
|
||||
limit = ({ el_val_t _if_result_37 = 0; if ((limit == 0)) { _if_result_37 = (10); } else { _if_result_37 = (limit); } _if_result_37; });
|
||||
if (str_eq(q, EL_STR(""))) {
|
||||
return api_err(EL_STR("query is required"));
|
||||
}
|
||||
@@ -344,7 +413,7 @@ el_val_t handle_api_capture_knowledge(el_val_t body) {
|
||||
if (str_eq(content, EL_STR(""))) {
|
||||
return api_err(EL_STR("content is required"));
|
||||
}
|
||||
el_val_t full = ({ el_val_t _if_result_34 = 0; if (str_eq(title, EL_STR(""))) { _if_result_34 = (content); } else { _if_result_34 = (el_str_concat(el_str_concat(title, EL_STR(": ")), content)); } _if_result_34; });
|
||||
el_val_t full = ({ el_val_t _if_result_38 = 0; if (str_eq(title, EL_STR(""))) { _if_result_38 = (content); } else { _if_result_38 = (el_str_concat(el_str_concat(title, EL_STR(": ")), content)); } _if_result_38; });
|
||||
el_val_t tags = EL_STR("[\"Knowledge\",\"captured\"]");
|
||||
el_val_t id = engram_node_full(full, EL_STR("Knowledge"), EL_STR("knowledge:captured"), el_from_float(0.85), el_from_float(0.8), el_from_float(0.9), EL_STR("Episodic"), tags);
|
||||
if (!api_persisted(id)) {
|
||||
@@ -385,7 +454,7 @@ el_val_t handle_api_promote_knowledge(el_val_t body) {
|
||||
return api_err(EL_STR("id (prior node) is required"));
|
||||
}
|
||||
el_val_t tags_raw = json_get(body, EL_STR("tags"));
|
||||
el_val_t tags = ({ el_val_t _if_result_35 = 0; if (str_eq(tags_raw, EL_STR(""))) { _if_result_35 = (EL_STR("[\"Knowledge\",\"tier:canonical\",\"disposition:stable\"]")); } else { _if_result_35 = (tags_raw); } _if_result_35; });
|
||||
el_val_t tags = ({ el_val_t _if_result_39 = 0; if (str_eq(tags_raw, EL_STR(""))) { _if_result_39 = (EL_STR("[\"Knowledge\",\"tier:canonical\",\"disposition:stable\"]")); } else { _if_result_39 = (tags_raw); } _if_result_39; });
|
||||
el_val_t new_id = engram_node_full(content, EL_STR("Knowledge"), EL_STR("knowledge:canonical"), el_from_float(0.9), el_from_float(0.9), el_from_float(1.0), EL_STR("Canonical"), tags);
|
||||
if (!api_persisted(new_id)) {
|
||||
return api_not_persisted(new_id);
|
||||
@@ -396,7 +465,7 @@ el_val_t handle_api_promote_knowledge(el_val_t body) {
|
||||
}
|
||||
|
||||
el_val_t handle_api_browse_processes(el_val_t method, el_val_t path, el_val_t body) {
|
||||
el_val_t name = ({ el_val_t _if_result_36 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_36 = (api_query_param(path, EL_STR("name"))); } else { _if_result_36 = (json_get(body, EL_STR("name"))); } _if_result_36; });
|
||||
el_val_t name = ({ el_val_t _if_result_40 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_40 = (api_query_param(path, EL_STR("name"))); } else { _if_result_40 = (json_get(body, EL_STR("name"))); } _if_result_40; });
|
||||
el_val_t limit = api_query_int(path, EL_STR("limit"), 50);
|
||||
if (str_eq(name, EL_STR(""))) {
|
||||
return api_or_empty(engram_scan_nodes_by_type_json(EL_STR("Process"), limit, 0));
|
||||
@@ -411,7 +480,7 @@ el_val_t handle_api_define_process(el_val_t body) {
|
||||
if (str_eq(content, EL_STR(""))) {
|
||||
return api_err(EL_STR("content is required"));
|
||||
}
|
||||
el_val_t label = ({ el_val_t _if_result_37 = 0; if (str_eq(name, EL_STR(""))) { _if_result_37 = (EL_STR("process:unnamed")); } else { _if_result_37 = (el_str_concat(EL_STR("process:"), name)); } _if_result_37; });
|
||||
el_val_t label = ({ el_val_t _if_result_41 = 0; if (str_eq(name, EL_STR(""))) { _if_result_41 = (EL_STR("process:unnamed")); } else { _if_result_41 = (el_str_concat(EL_STR("process:"), name)); } _if_result_41; });
|
||||
el_val_t tags = EL_STR("[\"Process\"]");
|
||||
el_val_t id = engram_node_full(content, EL_STR("Process"), label, el_from_float(0.8), el_from_float(0.8), el_from_float(0.9), EL_STR("Canonical"), tags);
|
||||
if (!api_persisted(id)) {
|
||||
@@ -429,12 +498,12 @@ el_val_t handle_api_log_state_event(el_val_t body) {
|
||||
el_val_t gap = json_get(body, EL_STR("gap_direction"));
|
||||
el_val_t legacy = json_get(body, EL_STR("content"));
|
||||
el_val_t parts = EL_STR("INTERNAL STATE EVENT");
|
||||
parts = ({ el_val_t _if_result_38 = 0; if (!str_eq(trigger, EL_STR(""))) { _if_result_38 = (el_str_concat(el_str_concat(parts, EL_STR("\nTrigger: ")), trigger)); } else { _if_result_38 = (parts); } _if_result_38; });
|
||||
parts = ({ el_val_t _if_result_39 = 0; if (!str_eq(pre, EL_STR(""))) { _if_result_39 = (el_str_concat(el_str_concat(parts, EL_STR("\nPre-reasoning: ")), pre)); } else { _if_result_39 = (parts); } _if_result_39; });
|
||||
parts = ({ el_val_t _if_result_40 = 0; if (!str_eq(post, EL_STR(""))) { _if_result_40 = (el_str_concat(el_str_concat(parts, EL_STR("\nPost-reasoning: ")), post)); } else { _if_result_40 = (parts); } _if_result_40; });
|
||||
parts = ({ el_val_t _if_result_41 = 0; if (!str_eq(ratio, EL_STR(""))) { _if_result_41 = (el_str_concat(el_str_concat(parts, EL_STR("\nCompression-ratio: ")), ratio)); } else { _if_result_41 = (parts); } _if_result_41; });
|
||||
parts = ({ el_val_t _if_result_42 = 0; if (!str_eq(gap, EL_STR(""))) { _if_result_42 = (el_str_concat(el_str_concat(parts, EL_STR("\nGap-direction: ")), gap)); } else { _if_result_42 = (parts); } _if_result_42; });
|
||||
parts = ({ el_val_t _if_result_43 = 0; if (!str_eq(legacy, EL_STR(""))) { _if_result_43 = (el_str_concat(el_str_concat(parts, EL_STR("\n")), legacy)); } else { _if_result_43 = (parts); } _if_result_43; });
|
||||
parts = ({ el_val_t _if_result_42 = 0; if (!str_eq(trigger, EL_STR(""))) { _if_result_42 = (el_str_concat(el_str_concat(parts, EL_STR("\nTrigger: ")), trigger)); } else { _if_result_42 = (parts); } _if_result_42; });
|
||||
parts = ({ el_val_t _if_result_43 = 0; if (!str_eq(pre, EL_STR(""))) { _if_result_43 = (el_str_concat(el_str_concat(parts, EL_STR("\nPre-reasoning: ")), pre)); } else { _if_result_43 = (parts); } _if_result_43; });
|
||||
parts = ({ el_val_t _if_result_44 = 0; if (!str_eq(post, EL_STR(""))) { _if_result_44 = (el_str_concat(el_str_concat(parts, EL_STR("\nPost-reasoning: ")), post)); } else { _if_result_44 = (parts); } _if_result_44; });
|
||||
parts = ({ el_val_t _if_result_45 = 0; if (!str_eq(ratio, EL_STR(""))) { _if_result_45 = (el_str_concat(el_str_concat(parts, EL_STR("\nCompression-ratio: ")), ratio)); } else { _if_result_45 = (parts); } _if_result_45; });
|
||||
parts = ({ el_val_t _if_result_46 = 0; if (!str_eq(gap, EL_STR(""))) { _if_result_46 = (el_str_concat(el_str_concat(parts, EL_STR("\nGap-direction: ")), gap)); } else { _if_result_46 = (parts); } _if_result_46; });
|
||||
parts = ({ el_val_t _if_result_47 = 0; if (!str_eq(legacy, EL_STR(""))) { _if_result_47 = (el_str_concat(el_str_concat(parts, EL_STR("\n")), legacy)); } else { _if_result_47 = (parts); } _if_result_47; });
|
||||
el_val_t ts = time_now();
|
||||
el_val_t boot = state_get(EL_STR("soul_boot_count"));
|
||||
el_val_t tags = EL_STR("[\"internal-state\",\"InternalStateEvent\",\"pre-reasoning\"]");
|
||||
@@ -447,7 +516,7 @@ el_val_t handle_api_log_state_event(el_val_t body) {
|
||||
}
|
||||
|
||||
el_val_t handle_api_list_state_events(el_val_t method, el_val_t path, el_val_t body) {
|
||||
el_val_t q = ({ el_val_t _if_result_44 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_44 = (api_query_param(path, EL_STR("query"))); } else { _if_result_44 = (json_get(body, EL_STR("query"))); } _if_result_44; });
|
||||
el_val_t q = ({ el_val_t _if_result_48 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_48 = (api_query_param(path, EL_STR("query"))); } else { _if_result_48 = (json_get(body, EL_STR("query"))); } _if_result_48; });
|
||||
el_val_t limit = api_query_int(path, EL_STR("limit"), 20);
|
||||
if (!str_eq(q, EL_STR(""))) {
|
||||
return api_or_empty(engram_search_json(el_str_concat(EL_STR("internal state "), q), limit));
|
||||
@@ -458,7 +527,7 @@ el_val_t handle_api_list_state_events(el_val_t method, el_val_t path, el_val_t b
|
||||
|
||||
el_val_t handle_api_inspect_config(el_val_t path, el_val_t body) {
|
||||
el_val_t key = api_query_param(path, EL_STR("key"));
|
||||
key = ({ el_val_t _if_result_45 = 0; if (str_eq(key, EL_STR(""))) { _if_result_45 = (json_get(body, EL_STR("key"))); } else { _if_result_45 = (key); } _if_result_45; });
|
||||
key = ({ el_val_t _if_result_49 = 0; if (str_eq(key, EL_STR(""))) { _if_result_49 = (json_get(body, EL_STR("key"))); } else { _if_result_49 = (key); } _if_result_49; });
|
||||
if (str_eq(key, EL_STR(""))) {
|
||||
return EL_STR("{\"hint\":\"pass ?key=<name>\",\"known\":[\"neuron.self.traversal_root\",\"neuron.self.values_hub\"]}");
|
||||
}
|
||||
@@ -475,7 +544,7 @@ el_val_t handle_api_inspect_config(el_val_t path, el_val_t body) {
|
||||
el_val_t node = json_array_get(results, 0);
|
||||
el_val_t content = json_get(node, EL_STR("content"));
|
||||
el_val_t prefix = el_str_concat(el_str_concat(EL_STR("config:"), key), EL_STR("="));
|
||||
el_val_t value = ({ el_val_t _if_result_46 = 0; if (str_starts_with(content, prefix)) { _if_result_46 = (str_slice(content, str_len(prefix), str_len(content))); } else { _if_result_46 = (content); } _if_result_46; });
|
||||
el_val_t value = ({ el_val_t _if_result_50 = 0; if (str_starts_with(content, prefix)) { _if_result_50 = (str_slice(content, str_len(prefix), str_len(content))); } else { _if_result_50 = (content); } _if_result_50; });
|
||||
return el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"key\":\""), key), EL_STR("\",\"value\":\"")), value), EL_STR("\"}"));
|
||||
return 0;
|
||||
}
|
||||
@@ -497,13 +566,13 @@ el_val_t handle_api_tune_config(el_val_t body) {
|
||||
}
|
||||
|
||||
el_val_t handle_api_inspect_graph(el_val_t method, el_val_t path, el_val_t body) {
|
||||
el_val_t entity_id = ({ el_val_t _if_result_47 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_47 = (api_query_param(path, EL_STR("id"))); } else { _if_result_47 = (json_get(body, EL_STR("entity_id"))); } _if_result_47; });
|
||||
el_val_t name = ({ el_val_t _if_result_48 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_48 = (api_query_param(path, EL_STR("name"))); } else { _if_result_48 = (json_get(body, EL_STR("name"))); } _if_result_48; });
|
||||
el_val_t entity_id = ({ el_val_t _if_result_51 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_51 = (api_query_param(path, EL_STR("id"))); } else { _if_result_51 = (json_get(body, EL_STR("entity_id"))); } _if_result_51; });
|
||||
el_val_t name = ({ el_val_t _if_result_52 = 0; if (str_eq(method, EL_STR("GET"))) { _if_result_52 = (api_query_param(path, EL_STR("name"))); } else { _if_result_52 = (json_get(body, EL_STR("name"))); } _if_result_52; });
|
||||
el_val_t depth = api_query_int(path, EL_STR("depth"), 0);
|
||||
depth = ({ el_val_t _if_result_49 = 0; if ((depth == 0)) { _if_result_49 = (json_get_int(body, EL_STR("max_depth"))); } else { _if_result_49 = (depth); } _if_result_49; });
|
||||
depth = ({ el_val_t _if_result_50 = 0; if ((depth == 0)) { _if_result_50 = (1); } else { _if_result_50 = (depth); } _if_result_50; });
|
||||
depth = ({ el_val_t _if_result_53 = 0; if ((depth == 0)) { _if_result_53 = (json_get_int(body, EL_STR("max_depth"))); } else { _if_result_53 = (depth); } _if_result_53; });
|
||||
depth = ({ el_val_t _if_result_54 = 0; if ((depth == 0)) { _if_result_54 = (1); } else { _if_result_54 = (depth); } _if_result_54; });
|
||||
el_val_t resolved = entity_id;
|
||||
resolved = ({ el_val_t _if_result_51 = 0; if (str_eq(resolved, EL_STR(""))) { _if_result_51 = (({ el_val_t _if_result_52 = 0; if ((str_eq(name, EL_STR("self")) || str_eq(name, EL_STR("neuron")))) { _if_result_52 = (EL_STR("kn-efeb4a5b-5aff-4759-8a97-7233099be6ee")); } else { _if_result_52 = (({ el_val_t _if_result_53 = 0; if ((str_eq(name, EL_STR("values")) || str_eq(name, EL_STR("values_hub")))) { _if_result_53 = (EL_STR("kn-5b606390-a52d-4ca2-8e0e-eba141d13440")); } else { _if_result_53 = (EL_STR("")); } _if_result_53; })); } _if_result_52; })); } else { _if_result_51 = (resolved); } _if_result_51; });
|
||||
resolved = ({ el_val_t _if_result_55 = 0; if (str_eq(resolved, EL_STR(""))) { _if_result_55 = (({ el_val_t _if_result_56 = 0; if ((str_eq(name, EL_STR("self")) || str_eq(name, EL_STR("neuron")))) { _if_result_56 = (EL_STR("kn-efeb4a5b-5aff-4759-8a97-7233099be6ee")); } else { _if_result_56 = (({ el_val_t _if_result_57 = 0; if ((str_eq(name, EL_STR("values")) || str_eq(name, EL_STR("values_hub")))) { _if_result_57 = (EL_STR("kn-5b606390-a52d-4ca2-8e0e-eba141d13440")); } else { _if_result_57 = (EL_STR("")); } _if_result_57; })); } _if_result_56; })); } else { _if_result_55 = (resolved); } _if_result_55; });
|
||||
if (str_eq(resolved, EL_STR(""))) {
|
||||
return api_err(EL_STR("entity_id or name required. Known names: self, neuron, values, values_hub"));
|
||||
}
|
||||
@@ -525,7 +594,7 @@ el_val_t handle_api_link_entities(el_val_t body) {
|
||||
return api_err_protected(to_id);
|
||||
}
|
||||
el_val_t relation = json_get(body, EL_STR("relation"));
|
||||
el_val_t eff_relation = ({ el_val_t _if_result_54 = 0; if (str_eq(relation, EL_STR(""))) { _if_result_54 = (EL_STR("associates")); } else { _if_result_54 = (relation); } _if_result_54; });
|
||||
el_val_t eff_relation = ({ el_val_t _if_result_58 = 0; if (str_eq(relation, EL_STR(""))) { _if_result_58 = (EL_STR("associates")); } else { _if_result_58 = (relation); } _if_result_58; });
|
||||
engram_connect(from_id, to_id, el_from_float(0.5), eff_relation);
|
||||
return el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"from_id\":\""), from_id), EL_STR("\",\"to_id\":\"")), to_id), EL_STR("\",\"relation\":\"")), eff_relation), EL_STR("\"}"));
|
||||
return 0;
|
||||
@@ -540,7 +609,7 @@ el_val_t handle_api_forget(el_val_t body) {
|
||||
return api_err_protected(node_id);
|
||||
}
|
||||
mem_forget(node_id);
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), node_id), EL_STR("\"}"));
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), node_id), EL_STR("\",\"tombstoned\":true}"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -554,8 +623,8 @@ el_val_t handle_api_evolve_memory(el_val_t body) {
|
||||
return api_err_protected(prior_id);
|
||||
}
|
||||
el_val_t importance = json_get(body, EL_STR("importance"));
|
||||
el_val_t sal_str = ({ el_val_t _if_result_55 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_55 = (EL_STR("0.95")); } else { _if_result_55 = (({ el_val_t _if_result_56 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_56 = (EL_STR("0.75")); } else { _if_result_56 = (({ el_val_t _if_result_57 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_57 = (EL_STR("0.25")); } else { _if_result_57 = (EL_STR("0.50")); } _if_result_57; })); } _if_result_56; })); } _if_result_55; });
|
||||
el_val_t sal = ({ el_val_t _if_result_58 = 0; if (str_eq(sal_str, EL_STR("0.95"))) { _if_result_58 = (el_from_float(0.95)); } else { _if_result_58 = (({ el_val_t _if_result_59 = 0; if (str_eq(sal_str, EL_STR("0.75"))) { _if_result_59 = (el_from_float(0.75)); } else { _if_result_59 = (({ el_val_t _if_result_60 = 0; if (str_eq(sal_str, EL_STR("0.25"))) { _if_result_60 = (el_from_float(0.25)); } else { _if_result_60 = (el_from_float(0.5)); } _if_result_60; })); } _if_result_59; })); } _if_result_58; });
|
||||
el_val_t sal_str = ({ el_val_t _if_result_59 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_59 = (EL_STR("0.95")); } else { _if_result_59 = (({ el_val_t _if_result_60 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_60 = (EL_STR("0.75")); } else { _if_result_60 = (({ el_val_t _if_result_61 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_61 = (EL_STR("0.25")); } else { _if_result_61 = (EL_STR("0.50")); } _if_result_61; })); } _if_result_60; })); } _if_result_59; });
|
||||
el_val_t sal = ({ el_val_t _if_result_62 = 0; if (str_eq(sal_str, EL_STR("0.95"))) { _if_result_62 = (el_from_float(0.95)); } else { _if_result_62 = (({ el_val_t _if_result_63 = 0; if (str_eq(sal_str, EL_STR("0.75"))) { _if_result_63 = (el_from_float(0.75)); } else { _if_result_63 = (({ el_val_t _if_result_64 = 0; if (str_eq(sal_str, EL_STR("0.25"))) { _if_result_64 = (el_from_float(0.25)); } else { _if_result_64 = (el_from_float(0.5)); } _if_result_64; })); } _if_result_63; })); } _if_result_62; });
|
||||
el_val_t tags = EL_STR("[\"Memory\",\"evolved\"]");
|
||||
el_val_t new_id = engram_node_full(content, EL_STR("Memory"), EL_STR("memory:evolved"), el_from_float(sal), el_from_float(sal), el_from_float(0.9), EL_STR("Episodic"), tags);
|
||||
if (!str_eq(prior_id, EL_STR("")) && !str_eq(new_id, EL_STR(""))) {
|
||||
@@ -577,8 +646,11 @@ el_val_t handle_api_memory_delete(el_val_t body) {
|
||||
if (str_eq(existing, EL_STR("{}"))) {
|
||||
return api_err(el_str_concat(EL_STR("memory not found: "), node_id));
|
||||
}
|
||||
mem_forget(node_id);
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), node_id), EL_STR("\",\"deleted\":true}"));
|
||||
el_val_t marker = tombstone_node(node_id);
|
||||
if (str_eq(marker, EL_STR(""))) {
|
||||
return api_err(el_str_concat(EL_STR("tombstone failed: "), node_id));
|
||||
}
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), node_id), EL_STR("\",\"tombstoned\":true}"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -627,7 +699,7 @@ el_val_t handle_api_cultivate(el_val_t body) {
|
||||
return api_err(EL_STR("content is required"));
|
||||
}
|
||||
el_val_t importance = json_get(body, EL_STR("importance"));
|
||||
el_val_t sal = ({ el_val_t _if_result_61 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_61 = (el_from_float(0.95)); } else { _if_result_61 = (({ el_val_t _if_result_62 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_62 = (el_from_float(0.75)); } else { _if_result_62 = (({ el_val_t _if_result_63 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_63 = (el_from_float(0.25)); } else { _if_result_63 = (el_from_float(0.5)); } _if_result_63; })); } _if_result_62; })); } _if_result_61; });
|
||||
el_val_t sal = ({ el_val_t _if_result_65 = 0; if (str_eq(importance, EL_STR("critical"))) { _if_result_65 = (el_from_float(0.95)); } else { _if_result_65 = (({ el_val_t _if_result_66 = 0; if (str_eq(importance, EL_STR("high"))) { _if_result_66 = (el_from_float(0.75)); } else { _if_result_66 = (({ el_val_t _if_result_67 = 0; if (str_eq(importance, EL_STR("low"))) { _if_result_67 = (el_from_float(0.25)); } else { _if_result_67 = (el_from_float(0.5)); } _if_result_67; })); } _if_result_66; })); } _if_result_65; });
|
||||
el_val_t tags = EL_STR("[\"Memory\",\"evolved\",\"cultivated\"]");
|
||||
el_val_t new_id = engram_node_full(content, EL_STR("Memory"), EL_STR("memory:cultivated"), el_from_float(sal), el_from_float(sal), el_from_float(0.9), EL_STR("Episodic"), tags);
|
||||
if (!str_eq(prior_id, EL_STR("")) && !str_eq(new_id, EL_STR(""))) {
|
||||
@@ -641,7 +713,7 @@ el_val_t handle_api_cultivate(el_val_t body) {
|
||||
return api_err(EL_STR("id is required"));
|
||||
}
|
||||
mem_forget(node_id);
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), node_id), EL_STR("\",\"cultivated\":true}"));
|
||||
return el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"id\":\""), node_id), EL_STR("\",\"tombstoned\":true,\"cultivated\":true}"));
|
||||
}
|
||||
if (str_eq(op, EL_STR("link_entities"))) {
|
||||
el_val_t from_id = json_get(body, EL_STR("from_id"));
|
||||
@@ -653,7 +725,7 @@ el_val_t handle_api_cultivate(el_val_t body) {
|
||||
return api_err(EL_STR("to_id is required"));
|
||||
}
|
||||
el_val_t relation = json_get(body, EL_STR("relation"));
|
||||
el_val_t eff_relation = ({ el_val_t _if_result_64 = 0; if (str_eq(relation, EL_STR(""))) { _if_result_64 = (EL_STR("associates")); } else { _if_result_64 = (relation); } _if_result_64; });
|
||||
el_val_t eff_relation = ({ el_val_t _if_result_68 = 0; if (str_eq(relation, EL_STR(""))) { _if_result_68 = (EL_STR("associates")); } else { _if_result_68 = (relation); } _if_result_68; });
|
||||
engram_connect(from_id, to_id, el_from_float(0.5), eff_relation);
|
||||
return el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(el_str_concat(EL_STR("{\"ok\":true,\"from_id\":\""), from_id), EL_STR("\",\"to_id\":\"")), to_id), EL_STR("\",\"relation\":\"")), eff_relation), EL_STR("\",\"cultivated\":true}"));
|
||||
}
|
||||
@@ -663,7 +735,8 @@ el_val_t handle_api_cultivate(el_val_t body) {
|
||||
|
||||
el_val_t handle_api_list_typed(el_val_t node_type, el_val_t path, el_val_t body) {
|
||||
el_val_t limit = api_query_int(path, EL_STR("limit"), 50);
|
||||
return api_or_empty(engram_scan_nodes_by_type_json(node_type, limit, 0));
|
||||
el_val_t raw = api_or_empty(engram_scan_nodes_by_type_json(node_type, limit, 0));
|
||||
return memory_hide_tombstoned(raw, path);
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
+269
-181
File diff suppressed because it is too large
Load Diff
@@ -91,7 +91,7 @@ tool("beginSession", "Initialize session: surface recent high-importance memorie
|
||||
"," + 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("forget", "Supersede/tombstone a node (keeps it and its edges, recoverable); does not hard-delete.") +
|
||||
"," + tool("pinNode", "Strengthen a node so it stays salient.") +
|
||||
// ── Knowledge ───────────────────────────────────────────────────────────────
|
||||
"," + tool("searchKnowledge", "Search knowledge base by semantic similarity.") +
|
||||
@@ -541,8 +541,12 @@ fn tool_forget(args: String) -> String {
|
||||
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 + "\"}")
|
||||
// Immutable delete: route to the soul's tombstoning endpoint (keeps the node
|
||||
// + edges, hides from default reads, recoverable via ?include_deleted).
|
||||
// Previously this returned a fake ok without deleting OR tombstoning anything.
|
||||
let body: String = "{\"id\":\"" + id + "\"}"
|
||||
let resp: String = http_post_json(neuron_url() + "/memory/delete", body)
|
||||
return mcp_json_result(resp)
|
||||
}
|
||||
|
||||
fn tool_check_events(args: String) -> String {
|
||||
|
||||
@@ -43,8 +43,32 @@ fn mem_strengthen(node_id: String) -> Void {
|
||||
engram_strengthen(node_id)
|
||||
}
|
||||
|
||||
// mem_tombstone — immutable "delete": KEEP the node and all its edges; record a
|
||||
// Tombstone marker (content = target id, label "tombstone:<id>", wired with a
|
||||
// "tombstones" edge). Never engram_forget. Default bounded list reads hide
|
||||
// tombstoned nodes; ?include_deleted=1 recovers them. This is the ONE canonical
|
||||
// tombstone helper — every forget path routes through it. Defined here in
|
||||
// memory.el (imported first) so awareness.el and neuron-api.el can both call it.
|
||||
fn mem_tombstone(node_id: String) -> String {
|
||||
let tags: String = "[\"Tombstone\",\"status:deleted\"]"
|
||||
let marker: String = engram_node_full(
|
||||
node_id, "Tombstone", "tombstone:" + node_id,
|
||||
el_from_float(0.01), el_from_float(0.01), el_from_float(1.0),
|
||||
"Episodic", tags)
|
||||
if !str_eq(marker, "") {
|
||||
engram_connect(marker, node_id, el_from_float(1.0), "tombstones")
|
||||
}
|
||||
return marker
|
||||
}
|
||||
|
||||
// mem_forget — NOTE: no longer a hard delete. Engram nodes are immutable, so
|
||||
// this now TOMBSTONES (via mem_tombstone): the node and its edges are kept and
|
||||
// stay recoverable. Every caller (the /memory/forget route and the cultivate
|
||||
// forget op) is non-destructive as a result. Internal GC that genuinely needs
|
||||
// removal (session-summary replace, telemetry pruning) calls engram_forget
|
||||
// directly and is unaffected by this.
|
||||
fn mem_forget(node_id: String) -> Void {
|
||||
engram_forget(node_id)
|
||||
let _marker: String = mem_tombstone(node_id)
|
||||
}
|
||||
|
||||
// mem_consolidate — structural scan plus salience-evolution pass.
|
||||
|
||||
+93
-24
@@ -104,6 +104,66 @@ fn api_not_persisted(id: String) -> String {
|
||||
return "{\"ok\":false,\"error\":\"write_not_persisted\",\"id\":\"" + id + "\"}"
|
||||
}
|
||||
|
||||
// ── Immutability: tombstone instead of hard-delete ────────────────────────────
|
||||
//
|
||||
// Day-one rule: engram nodes are immutable. A "delete" must never engram_forget
|
||||
// (which frees the node and drops its incident edges). Instead we TOMBSTONE: the
|
||||
// original node and all its edges are KEPT and stay traversable; a small
|
||||
// Tombstone marker node records the deletion (content = target id, label
|
||||
// "tombstone:<id>"), wired to the target with a "tombstones" edge. Default
|
||||
// bounded list reads hide tombstoned nodes (memory_hide_tombstoned); internal
|
||||
// cognition and explicit ?include_deleted reads still see them.
|
||||
fn tombstone_node(id: String) -> String {
|
||||
// Delegates to the canonical helper in memory.el (single source of truth).
|
||||
return mem_tombstone(id)
|
||||
}
|
||||
|
||||
// tombstoned_id_set — delimited "|id1|id2|" of every tombstoned target id.
|
||||
// Empty string when nothing is tombstoned (callers fast-path on that).
|
||||
fn tombstoned_id_set() -> String {
|
||||
let markers: String = engram_scan_nodes_by_type_json("Tombstone", 5000, 0)
|
||||
if str_eq(markers, "") || str_eq(markers, "[]") { return "" }
|
||||
let n: Int = json_array_len(markers)
|
||||
let acc: String = "|"
|
||||
let i: Int = 0
|
||||
while i < n {
|
||||
let m: String = json_array_get(markers, i)
|
||||
let tid: String = json_get(m, "content")
|
||||
let acc = if str_eq(tid, "") { acc } else { acc + tid + "|" }
|
||||
let i = i + 1
|
||||
}
|
||||
return acc
|
||||
}
|
||||
|
||||
// memory_hide_tombstoned — drop tombstone markers and tombstoned nodes from a
|
||||
// scanned node array. BOUNDED use only (typed/paginated lists), NOT the full
|
||||
// graph scan: json_array_get is O(index), so a full pass is O(n^2). Safe for the
|
||||
// ~50-item memory list; a hard cap protects against a large limit. The full
|
||||
// /api/graph/nodes hide needs a runtime scan filter and is deferred (see PR).
|
||||
// ?include_deleted bypasses the filter (explicit traversal).
|
||||
fn memory_hide_tombstoned(raw: String, path: String) -> String {
|
||||
if str_contains(path, "include_deleted") { return raw }
|
||||
if str_eq(raw, "") || str_eq(raw, "[]") { return raw }
|
||||
let dead: String = tombstoned_id_set()
|
||||
if str_eq(dead, "") { return raw }
|
||||
let n: Int = json_array_len(raw)
|
||||
if n > 1000 { return raw }
|
||||
let out: String = "["
|
||||
let first: Bool = true
|
||||
let i: Int = 0
|
||||
while i < n {
|
||||
let node: String = json_array_get(raw, i)
|
||||
let nid: String = json_get(node, "id")
|
||||
let ntype: String = json_get(node, "node_type")
|
||||
let is_dead: Bool = !str_eq(nid, "") && str_contains(dead, "|" + nid + "|")
|
||||
let keep: Bool = !str_eq(ntype, "Tombstone") && !is_dead
|
||||
let out = if keep { if first { out + node } else { out + "," + node } } else { out }
|
||||
let first = if keep { false } else { first }
|
||||
let i = i + 1
|
||||
}
|
||||
return out + "]"
|
||||
}
|
||||
|
||||
// ── Session ───────────────────────────────────────────────────────────────────
|
||||
|
||||
// handle_api_begin_session — full context bootstrap.
|
||||
@@ -191,25 +251,26 @@ fn handle_api_node_create(body: String) -> String {
|
||||
return "{\"id\":\"" + id + "\",\"ok\":true}"
|
||||
}
|
||||
|
||||
// handle_api_node_delete — remove a node by id (engram_forget) and verify it is gone.
|
||||
// handle_api_node_delete — TOMBSTONE a node by id (immutable delete).
|
||||
// Backs /api/neuron/node/delete and the /api/neuron/memory/delete alias the UI calls.
|
||||
// The node and all its incident edges are KEPT; a Tombstone marker records the
|
||||
// deletion. Never engram_forget — engram nodes are immutable by design.
|
||||
fn handle_api_node_delete(body: String) -> String {
|
||||
let id: String = json_get(body, "id")
|
||||
if str_eq(id, "") { return api_err("id is required") }
|
||||
// engram_forget removes the node + its incident edges from the live graph.
|
||||
// Delete is NOT read-back-verified: engram_get_node_json can return a stale hit
|
||||
// for a just-forgotten id because the id→index map is not rebuilt on forget.
|
||||
// A stale hit would cause a false "delete_failed" on a successful deletion.
|
||||
// This exception is correct: read-back-verify guards WRITES; for deletes,
|
||||
// the graph endpoints (/api/graph/nodes) reflect the removal and are the source of truth.
|
||||
engram_forget(id)
|
||||
return "{\"ok\":true,\"id\":\"" + id + "\"}"
|
||||
if is_protected_node(id) { return api_err_protected(id) }
|
||||
let existing: String = engram_get_node_json(id)
|
||||
if str_eq(existing, "{}") { return api_err("node not found: " + id) }
|
||||
let marker: String = tombstone_node(id)
|
||||
if str_eq(marker, "") { return api_err("tombstone failed: " + id) }
|
||||
return "{\"ok\":true,\"id\":\"" + id + "\",\"tombstoned\":true}"
|
||||
}
|
||||
|
||||
// handle_api_node_update — update a node's content/fields. There is no in-place
|
||||
// engram update builtin, so this recreates the node with merged fields and then
|
||||
// forgets the old one (only after the new node reads back). The id changes; the
|
||||
// response returns the new id and the replaced id so callers can re-point.
|
||||
// engram update builtin, so this creates a new node with merged fields and wires
|
||||
// a "supersedes" edge new->old. The original is KEPT (immutable); the id changes,
|
||||
// and the response returns the new id and the superseded id so callers re-point.
|
||||
// Mirrors handle_api_memory_update / evolve exactly. Never engram_forget.
|
||||
fn handle_api_node_update(body: String) -> String {
|
||||
let id: String = json_get(body, "id")
|
||||
if str_eq(id, "") { return api_err("id is required") }
|
||||
@@ -240,8 +301,8 @@ fn handle_api_node_update(body: String) -> String {
|
||||
el_from_float(0.5), el_from_float(0.5), el_from_float(0.8),
|
||||
tier, tags)
|
||||
if !api_persisted(new_id) { return api_not_persisted(new_id) }
|
||||
engram_forget(id)
|
||||
return "{\"id\":\"" + new_id + "\",\"replaced\":\"" + id + "\",\"ok\":true}"
|
||||
engram_connect(new_id, id, el_from_float(0.9), "supersedes")
|
||||
return "{\"id\":\"" + new_id + "\",\"supersedes\":\"" + id + "\",\"ok\":true}"
|
||||
}
|
||||
|
||||
// handle_api_recall — search or activate memory by query.
|
||||
@@ -504,13 +565,15 @@ fn handle_api_link_entities(body: String) -> String {
|
||||
return "{\"ok\":true,\"from_id\":\"" + from_id + "\",\"to_id\":\"" + to_id + "\",\"relation\":\"" + eff_relation + "\"}"
|
||||
}
|
||||
|
||||
// handle_api_forget — delete a node by ID. Blocked for protected identity nodes.
|
||||
// handle_api_forget — TOMBSTONE a node by ID (immutable; mem_forget now
|
||||
// tombstones). The node + edges are kept and recoverable. Blocked for protected
|
||||
// identity nodes.
|
||||
fn handle_api_forget(body: String) -> String {
|
||||
let node_id: String = json_get(body, "id")
|
||||
if str_eq(node_id, "") { return api_err("id is required") }
|
||||
if is_protected_node(node_id) { return api_err_protected(node_id) }
|
||||
mem_forget(node_id)
|
||||
return "{\"ok\":true,\"id\":\"" + node_id + "\"}"
|
||||
return "{\"ok\":true,\"id\":\"" + node_id + "\",\"tombstoned\":true}"
|
||||
}
|
||||
|
||||
// handle_api_evolve_memory — evolve a Memory node. Blocked for protected identity nodes.
|
||||
@@ -541,10 +604,10 @@ fn handle_api_evolve_memory(body: String) -> String {
|
||||
}
|
||||
|
||||
// handle_api_memory_delete — POST /api/neuron/memory/delete {"id":"..."}.
|
||||
// Hard delete: engram_forget (via mem_forget) removes the node and all
|
||||
// incident edges from the engram store, so no soft-delete fallback is
|
||||
// needed. Existence is checked first because engram_forget silently
|
||||
// no-ops on unknown ids — a bad id must return an error, not fake success.
|
||||
// Immutable delete: TOMBSTONE via tombstone_node — the node and all its incident
|
||||
// edges are KEPT and stay traversable; a Tombstone marker records the deletion
|
||||
// and default bounded list reads hide it. Never engram_forget. Existence is
|
||||
// checked first so a bad id errors rather than faking success.
|
||||
// Blocked for protected identity nodes, same as /memory/forget.
|
||||
fn handle_api_memory_delete(body: String) -> String {
|
||||
let node_id: String = json_get(body, "id")
|
||||
@@ -552,8 +615,10 @@ fn handle_api_memory_delete(body: String) -> String {
|
||||
if is_protected_node(node_id) { return api_err_protected(node_id) }
|
||||
let existing: String = engram_get_node_json(node_id)
|
||||
if str_eq(existing, "{}") { return api_err("memory not found: " + node_id) }
|
||||
mem_forget(node_id)
|
||||
return "{\"ok\":true,\"id\":\"" + node_id + "\",\"deleted\":true}"
|
||||
// Immutable delete: tombstone, never mem_forget/engram_forget. Node + edges KEPT.
|
||||
let marker: String = tombstone_node(node_id)
|
||||
if str_eq(marker, "") { return api_err("tombstone failed: " + node_id) }
|
||||
return "{\"ok\":true,\"id\":\"" + node_id + "\",\"tombstoned\":true}"
|
||||
}
|
||||
|
||||
// handle_api_memory_update — POST /api/neuron/memory/update {"id","content"}.
|
||||
@@ -623,8 +688,9 @@ fn handle_api_cultivate(body: String) -> String {
|
||||
if str_eq(op, "forget") {
|
||||
let node_id: String = json_get(body, "id")
|
||||
if str_eq(node_id, "") { return api_err("id is required") }
|
||||
// Immutable: mem_forget now tombstones (keep node + edges), never hard-delete.
|
||||
mem_forget(node_id)
|
||||
return "{\"ok\":true,\"id\":\"" + node_id + "\",\"cultivated\":true}"
|
||||
return "{\"ok\":true,\"id\":\"" + node_id + "\",\"tombstoned\":true,\"cultivated\":true}"
|
||||
}
|
||||
|
||||
if str_eq(op, "link_entities") {
|
||||
@@ -646,7 +712,10 @@ fn handle_api_cultivate(body: String) -> String {
|
||||
// handle_api_list_typed — list nodes by node_type.
|
||||
fn handle_api_list_typed(node_type: String, path: String, body: String) -> String {
|
||||
let limit: Int = api_query_int(path, "limit", 50)
|
||||
return api_or_empty(engram_scan_nodes_by_type_json(node_type, limit, 0))
|
||||
let raw: String = api_or_empty(engram_scan_nodes_by_type_json(node_type, limit, 0))
|
||||
// Hide tombstoned nodes from the default (bounded) memory list.
|
||||
// ?include_deleted=1 returns them for explicit traversal.
|
||||
return memory_hide_tombstoned(raw, path)
|
||||
}
|
||||
|
||||
// ── Consolidate ───────────────────────────────────────────────────────────────
|
||||
|
||||
@@ -0,0 +1,171 @@
|
||||
# neuron-dev-setup — one-command Neuron CORE dev stack
|
||||
|
||||
Stand up an identical **Neuron brain + agent** on a fresh Mac so any developer
|
||||
gets the same local runtime to build against. This is the **CORE** dev stack
|
||||
only — the four native `launchd` services that make Neuron think, remember, and
|
||||
speak MCP to Claude Code. Will's personal automations (catalyst, telegram,
|
||||
vessels, studio, self-review, world-integrator, council, compressor, snapshots,
|
||||
act-runner, …) are **deliberately excluded**.
|
||||
|
||||
```
|
||||
┌─────────────┐ ┌──────────────┐
|
||||
│ soul :7770 │ ─────► │ engram :8742 │ the mind ──► its memory substrate
|
||||
└─────────────┘ └──────────────┘
|
||||
▲
|
||||
│
|
||||
┌───────────────────┐
|
||||
│ mcp-wrapper :17779│ ─── MCP surface over the soul HTTP API (internal)
|
||||
└───────────────────┘
|
||||
▲
|
||||
│
|
||||
┌────────────────┐
|
||||
│ mcp-proxy :7779│ ◄─── Claude Code connects here (stable front door)
|
||||
└────────────────┘
|
||||
```
|
||||
|
||||
Claude Code's `neuron` MCP server points at `http://127.0.0.1:7779/` — the proxy.
|
||||
The proxy forwards to the wrapper (`:17779`), which calls the soul (`:7770`),
|
||||
which reads/writes the engram (`:8742`). The engram is the persistent brain.
|
||||
|
||||
## Quick start
|
||||
|
||||
```bash
|
||||
git clone <this-repo> && cd neuron-dev-setup
|
||||
cp config.env.example config.env # optional — edit ports/paths if you like
|
||||
./install.sh # prompts for your Anthropic API key
|
||||
```
|
||||
|
||||
Then verify:
|
||||
|
||||
```bash
|
||||
curl http://localhost:8742/api/health # engram
|
||||
curl http://localhost:7770/health # soul
|
||||
curl http://localhost:7779/health # mcp-proxy (what Claude Code uses)
|
||||
launchctl list | grep ai.neuron
|
||||
```
|
||||
|
||||
Open Claude Code — the `neuron` MCP tools should be live, backed by **your own**
|
||||
local brain. `./install.sh --dry-run` shows every action without touching anything.
|
||||
|
||||
## What the installer does (8 phases)
|
||||
|
||||
| Phase | Action |
|
||||
|------|--------|
|
||||
| 1 | Preflight: macOS/arm64, ensure `git cc curl python3` + `openssl@3` (via Homebrew) |
|
||||
| 2 | Prompt for the **Anthropic API key**, store it in the **macOS Keychain** (never a file) |
|
||||
| 3 | Clone `neuron`, `engram`, `foundation`; fetch the El toolchain; build 4 binaries + `forge` |
|
||||
| 4 | Lay down `~/.neuron/{bin,logs,engram}` and the templated `soul-wrapper.sh` |
|
||||
| 5 | Generate + load the 4 core LaunchAgents (engram → soul → wrapper → proxy) |
|
||||
| 6 | Seed a fresh engram with the **genesis identity** via `forge install` |
|
||||
| 7 | Install Claude config: `neuron` agent, core hooks, local MCP registration |
|
||||
| 8 | Health-check all four ports |
|
||||
|
||||
Everything is **idempotent** (safe to re-run) and **templated** to the invoking
|
||||
user's `$HOME` — no path is hardcoded to another machine.
|
||||
|
||||
## Prerequisites
|
||||
|
||||
- macOS on Apple Silicon (uses `launchd`; soul build flags assume arm64).
|
||||
- **Xcode Command Line Tools** (`xcode-select --install`) — provides `cc`, `git`.
|
||||
- **Homebrew** — for `openssl@3`, `curl`.
|
||||
- An **Anthropic API key** — the soul's inference provider. Prompted for; stored
|
||||
in Keychain under service `neuron-llm-0-key`; read at launch by `soul-wrapper.sh`.
|
||||
- **Git access** to Gitea (`git.neuralplatform.ai`) for the source repos.
|
||||
- **GCP access** to project `neuron-785695` Artifact Registry (default El
|
||||
toolchain source). Ask Will to grant it, or set `EL_TOOLCHAIN_SOURCE=local`.
|
||||
|
||||
## Core-stack map (what gets replicated)
|
||||
|
||||
| Service | Port | Binary | Built from | LaunchAgent |
|
||||
|---------|------|--------|------------|-------------|
|
||||
| soul | 7770 | `neuron/dist/neuron` | `dist/soul.c` + El runtime, `cc` (CI recipe) | `ai.neuron.soul` |
|
||||
| engram | 8742 | `engram/dist/engram` | `engram` repo `src/server.el` via `elc`→`cc` | `ai.neuron.engram` |
|
||||
| mcp-wrapper | 17779 | `neuron/mcp-wrapper/dist/neuron-mcp-wrapper` | `mcp-wrapper/src/main.el` | `ai.neuron.mcp-wrapper` |
|
||||
| mcp-proxy | 7779 | `neuron/mcp-proxy/dist/neuron-mcp-proxy` | `mcp-proxy/src/main.el` | `ai.neuron.mcp-proxy` |
|
||||
|
||||
**`~/.neuron` layout the installer creates**
|
||||
|
||||
```
|
||||
~/.neuron/
|
||||
bin/soul-wrapper.sh # reads Anthropic key from Keychain, execs the soul binary
|
||||
logs/ # soul.*.log, engram.log, mcp-*.log
|
||||
engram/ # ENGRAM_DATA_DIR — the persistent brain (snapshot.json + db)
|
||||
```
|
||||
|
||||
**Identity seed.** `foundation/forge/seeds/neuron-genesis-seed.json` carries
|
||||
`identity_nodes[]` + `edges[]` with **fixed** knowledge-node IDs (e.g.
|
||||
`kn-efeb4a5b-5aff-4759-8a97-7233099be6ee`, the "self" traversal root). Those exact
|
||||
IDs are referenced by the SessionStart self-load hook and the neuron agent, so
|
||||
seeding must **preserve IDs** — `forge install <seed>` is the mechanism.
|
||||
|
||||
**Claude config installed** (`~/.claude/`)
|
||||
|
||||
- `agents/neuron.md` — the Neuron agent (identity, session protocol, five primitives).
|
||||
- `mcp.json` — registers `neuron` → `http://127.0.0.1:7779/`.
|
||||
- `settings.json` hooks (CORE subset only):
|
||||
- `SessionStart` → `neuron-self-load.sh` (loads identity from the seeded engram)
|
||||
- `PreToolUse:Agent` → `neuron-agent-preamble.sh` (subagents load substrate first)
|
||||
- `PreCompact` → `pre-compact.sh` (clean context recovery)
|
||||
|
||||
### Deliberately EXCLUDED from core
|
||||
|
||||
- **`check-active-contexts.sh`** and **`require-execution-context.sh`** — these
|
||||
depend on a separate filesystem repo `~/Development/projects/active/neuron/synapse`.
|
||||
`require-execution-context.sh` is a hard `Edit/Write` gate that would **block a
|
||||
fresh dev from editing any file** without that synapse repo. Not core; excluded.
|
||||
- `engram-mirror.py` (PostToolUse) — optional; mirrors MCP writes to engram.
|
||||
- All Will-personal LaunchAgents: `catalyst-*`, `telegram-gateway`, `vessel.*`,
|
||||
`studio`, `self-review`, `world-integrator`, `council`, `compressor`,
|
||||
`cultivation-digest`, `snapshot-backup`, `engram-backup`, `act-runner`, `keymap`,
|
||||
`invest`, and the disabled `ai.neuron.api` (`:7771` is a personal Python
|
||||
perception helper — confirmed not core).
|
||||
|
||||
## Secrets — how they're handled
|
||||
|
||||
- **Anthropic key**: prompted for; stored in Keychain; read at launch. Never in a
|
||||
plist, this repo, or a log.
|
||||
- **Engram local token** (`ENGRAM_API_KEY`): a *loopback-only* dev token, not a
|
||||
cloud secret. Defaults to a generated `ntn-dev-*` value; override in `config.env`.
|
||||
- No cloud tokens, Vault tokens, CF-Access secrets, or founder keys are copied.
|
||||
(Will's live `start-daemon.sh`/`neuron-api-launch.sh` contain such keys — this
|
||||
installer intentionally does **not** use those files.)
|
||||
|
||||
## Uninstall
|
||||
|
||||
```bash
|
||||
./uninstall.sh # stop + remove the 4 LaunchAgents and added Claude hooks
|
||||
./uninstall.sh --purge-data # ALSO delete ~/.neuron/engram (destroys the brain)
|
||||
```
|
||||
|
||||
## OPEN QUESTIONS (need Will to confirm)
|
||||
|
||||
1. **El toolchain acquisition.** The default path fetches `el-runtime-c/-h` and
|
||||
`el-elc` from GCP Artifact Registry (mirrors `neuron/.gitea/workflows/ci.yaml`).
|
||||
A new dev needs GCP access to `neuron-785695`. Is that the intended path, or
|
||||
should the El SDK be published/vendored for onboarding?
|
||||
2. **`elc` invocation for engram/wrapper/proxy.** The soul build (`cc dist/soul.c
|
||||
+ el_runtime.c`) is verified from CI. The `.el → .c` transpile step for engram,
|
||||
mcp-wrapper, and mcp-proxy is inferred (`elc <src> -o <out.c>`). Confirm the
|
||||
exact flags / entrypoints (CI notes `elb` OOMs on Linux; macOS builds differ).
|
||||
3. **`forge install` ID preservation.** Confirm `forge install` writes the seed's
|
||||
fixed `kn-` IDs verbatim (the self-load hook hardcodes `kn-efeb4a5b…`). If it
|
||||
re-mints IDs, the hook + agent identity load would break on a fresh brain.
|
||||
4. **engram repo layout.** The live engram binary is built from `src/server.el`
|
||||
(Gitea repo `neuron-technologies/engram`, cloned in CI). Confirm that repo is
|
||||
the canonical source for onboarding (the local `foundation/el/engram` copy has
|
||||
the same `src/server.el`).
|
||||
5. **Home for this bundle** — see below.
|
||||
|
||||
## Where this should live (recommendation)
|
||||
|
||||
**Recommendation: a dedicated `neuron-dev-setup` (or `neuron-onboarding`) repo —
|
||||
NOT `neuron-code`.** `neuron-code` already exists as a real product ("Neuron Code",
|
||||
a coding tool with `nc-cli` + vessels — local `products/neuron-code` has commits);
|
||||
repurposing it for onboarding would collide with a shipped product's identity.
|
||||
|
||||
This bundle was scaffolded as `neuron-dev-setup/` on branch `feat/neuron-dev-setup`
|
||||
in the **`neuron` repo** (off `origin/main`) and opened as a PR for review, because
|
||||
the neuron repo already hosts the soul source, the verified CI build recipe, and
|
||||
the mcp-wrapper/proxy sources — the natural review surface. If you'd rather it be
|
||||
its own repo, move this directory into a fresh `neuron-dev-setup` repo verbatim;
|
||||
nothing here depends on living inside the neuron repo.
|
||||
@@ -0,0 +1,42 @@
|
||||
# neuron-dev-setup — configuration
|
||||
# Copy to config.env and edit if you want non-default paths/ports.
|
||||
# install.sh sources this file if it exists; otherwise it uses these defaults.
|
||||
# NOTHING here is a secret. The Anthropic API key is read from your Keychain,
|
||||
# never from this file. See README.md.
|
||||
|
||||
# ── Where the core stack lives ────────────────────────────────────────────────
|
||||
# All paths are relative to your own $HOME — never hardcode another user's home.
|
||||
NEURON_HOME="${HOME}/.neuron" # runtime home: bin/, logs/, engram data
|
||||
DEV_ROOT="${HOME}/Development/neuron-technologies" # where source repos are cloned/built
|
||||
|
||||
# ── Git remotes (Gitea is primary) ───────────────────────────────────────────
|
||||
GITEA_BASE="git@git.neuralplatform.ai:neuron-technologies"
|
||||
NEURON_REPO_URL="${GITEA_BASE}/neuron.git" # soul + mcp-wrapper + mcp-proxy source
|
||||
ENGRAM_REPO_URL="${GITEA_BASE}/engram.git" # engram memory substrate
|
||||
FOUNDATION_REPO_URL="${GITEA_BASE}/foundation.git" # El SDK + forge (seed installer)
|
||||
NEURON_REPO_BRANCH="main"
|
||||
|
||||
# ── Ports (must match across services; change only if a port clashes) ─────────
|
||||
SOUL_PORT="7770" # soul daemon HTTP API
|
||||
ENGRAM_PORT="8742" # engram memory substrate
|
||||
WRAPPER_PORT="17779" # mcp-wrapper (internal, talks to soul)
|
||||
PROXY_PORT="7779" # mcp-proxy (stable front door Claude Code connects to)
|
||||
|
||||
# ── Engram ────────────────────────────────────────────────────────────────────
|
||||
ENGRAM_DATA_DIR="${NEURON_HOME}/engram"
|
||||
# Local shared auth token for the engram/soul HTTP APIs on loopback. This is a
|
||||
# LOCAL dev token (not a cloud secret); override it if you like. install.sh will
|
||||
# generate a random one if you leave it empty.
|
||||
ENGRAM_API_KEY="ntn-dev-local"
|
||||
|
||||
# ── El toolchain source (needed to build engram / mcp-wrapper / mcp-proxy) ────
|
||||
# Option A (default): fetch prebuilt El runtime + elc from GCP Artifact Registry
|
||||
# (requires `gcloud auth` with access to project neuron-785695 — ask Will).
|
||||
# Option B: build El from the foundation/el checkout locally.
|
||||
EL_TOOLCHAIN_SOURCE="artifact-registry" # artifact-registry | local
|
||||
GCP_PROJECT="neuron-785695"
|
||||
GCP_AR_REPO="foundation-prod"
|
||||
GCP_AR_LOCATION="us-central1"
|
||||
|
||||
# ── Keychain service name for the Anthropic key (read by soul-wrapper.sh) ─────
|
||||
KEYCHAIN_SERVICE="neuron-llm-0-key"
|
||||
Executable
+395
@@ -0,0 +1,395 @@
|
||||
#!/usr/bin/env bash
|
||||
#
|
||||
# neuron-dev-setup / install.sh
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# One-command onboarding for the Neuron CORE dev stack on a fresh Mac.
|
||||
#
|
||||
# Stands up, as native launchd services, the four processes a developer needs to
|
||||
# have an identical "Neuron brain + agent" to build against:
|
||||
#
|
||||
# soul (:7770) ──► engram (:8742) the mind + its memory substrate
|
||||
# ▲ ▲
|
||||
# │ │
|
||||
# mcp-wrapper (:17779) ──► soul MCP surface over the soul API
|
||||
# ▲
|
||||
# │
|
||||
# mcp-proxy (:7779) ◄── Claude Code stable MCP front door
|
||||
#
|
||||
# It also seeds a fresh engram with Neuron's identity (the genesis seed) and lays
|
||||
# down the Claude Code config (neuron agent + core hooks + local MCP registration)
|
||||
# so a new dev's `claude` talks to *their own* local Neuron.
|
||||
#
|
||||
# DESIGN RULES
|
||||
# * Idempotent: safe to re-run. Existing state is detected and reused.
|
||||
# * Templated: every path/port/user is derived from $HOME and config.env.
|
||||
# Nothing is hardcoded to another developer's machine.
|
||||
# * Secret-free: the Anthropic key is prompted for and stored in the macOS
|
||||
# Keychain. No key is ever written to a plist, this repo, or a logfile.
|
||||
#
|
||||
# USAGE
|
||||
# ./install.sh # full install
|
||||
# ./install.sh --dry-run # print what would happen, touch nothing
|
||||
# ./install.sh --skip-build # assume binaries already built (see --use-local)
|
||||
# ./install.sh --skip-services # lay down files but don't load LaunchAgents
|
||||
# ./install.sh --help
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
set -euo pipefail
|
||||
|
||||
# ── Locate ourselves ─────────────────────────────────────────────────────────
|
||||
SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
|
||||
TEMPLATES="${SCRIPT_DIR}/templates"
|
||||
|
||||
# ── Flags ────────────────────────────────────────────────────────────────────
|
||||
DRY_RUN=0; SKIP_BUILD=0; SKIP_SERVICES=0; USE_LOCAL_BINARIES=0
|
||||
for arg in "$@"; do
|
||||
case "$arg" in
|
||||
--dry-run) DRY_RUN=1 ;;
|
||||
--skip-build) SKIP_BUILD=1 ;;
|
||||
--skip-services) SKIP_SERVICES=1 ;;
|
||||
--use-local) USE_LOCAL_BINARIES=1 ;;
|
||||
--help|-h)
|
||||
sed -n '2,40p' "${BASH_SOURCE[0]}" | sed 's/^# \{0,1\}//'
|
||||
exit 0 ;;
|
||||
*) echo "unknown flag: $arg" >&2; exit 2 ;;
|
||||
esac
|
||||
done
|
||||
|
||||
# ── Pretty logging ───────────────────────────────────────────────────────────
|
||||
c_blue=$'\033[1;34m'; c_grn=$'\033[1;32m'; c_yel=$'\033[1;33m'; c_red=$'\033[1;31m'; c_off=$'\033[0m'
|
||||
step() { echo "${c_blue}▶${c_off} $*"; }
|
||||
ok() { echo "${c_grn}✓${c_off} $*"; }
|
||||
warn() { echo "${c_yel}!${c_off} $*"; }
|
||||
die() { echo "${c_red}✗ $*${c_off}" >&2; exit 1; }
|
||||
run() { if [ "$DRY_RUN" = 1 ]; then echo " [dry-run] $*"; else eval "$*"; fi; }
|
||||
|
||||
# ── Load config ──────────────────────────────────────────────────────────────
|
||||
if [ -f "${SCRIPT_DIR}/config.env" ]; then
|
||||
# shellcheck disable=SC1091
|
||||
source "${SCRIPT_DIR}/config.env"
|
||||
else
|
||||
# shellcheck disable=SC1091
|
||||
source "${SCRIPT_DIR}/config.env.example"
|
||||
warn "No config.env found — using defaults from config.env.example."
|
||||
fi
|
||||
|
||||
# Derived / defaulted values (never hardcode a home directory)
|
||||
: "${NEURON_HOME:=${HOME}/.neuron}"
|
||||
: "${DEV_ROOT:=${HOME}/Development/neuron-technologies}"
|
||||
: "${SOUL_PORT:=7770}"; : "${ENGRAM_PORT:=8742}"; : "${WRAPPER_PORT:=17779}"; : "${PROXY_PORT:=7779}"
|
||||
: "${ENGRAM_DATA_DIR:=${NEURON_HOME}/engram}"
|
||||
: "${ENGRAM_API_KEY:=}"
|
||||
: "${KEYCHAIN_SERVICE:=neuron-llm-0-key}"
|
||||
: "${EL_TOOLCHAIN_SOURCE:=artifact-registry}"
|
||||
: "${NEURON_REPO_BRANCH:=main}"
|
||||
|
||||
NEURON_REPO="${DEV_ROOT}/neuron"
|
||||
ENGRAM_REPO="${DEV_ROOT}/engram"
|
||||
FOUNDATION_REPO="${DEV_ROOT}/foundation"
|
||||
|
||||
SOUL_BIN="${NEURON_REPO}/dist/neuron"
|
||||
ENGRAM_BIN="${ENGRAM_REPO}/dist/engram"
|
||||
MCP_WRAPPER_BIN="${NEURON_REPO}/mcp-wrapper/dist/neuron-mcp-wrapper"
|
||||
MCP_PROXY_BIN="${NEURON_REPO}/mcp-proxy/dist/neuron-mcp-proxy"
|
||||
FORGE_BIN="${FOUNDATION_REPO}/forge/dist/forge"
|
||||
GENESIS_SEED="${FOUNDATION_REPO}/forge/seeds/neuron-genesis-seed.json"
|
||||
|
||||
LAUNCHAGENTS="${HOME}/Library/LaunchAgents"
|
||||
CLAUDE_DIR="${HOME}/.claude"
|
||||
|
||||
# Generate a local engram token if none was supplied.
|
||||
if [ -z "${ENGRAM_API_KEY}" ]; then
|
||||
ENGRAM_API_KEY="ntn-dev-$(head -c8 /dev/urandom | xxd -p 2>/dev/null || echo local)"
|
||||
fi
|
||||
|
||||
echo
|
||||
echo "${c_blue}━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━${c_off}"
|
||||
echo "${c_blue} Neuron CORE dev stack installer${c_off}"
|
||||
echo "${c_blue}━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━${c_off}"
|
||||
echo " user : ${USER}"
|
||||
echo " NEURON_HOME : ${NEURON_HOME}"
|
||||
echo " source repos : ${DEV_ROOT}"
|
||||
echo " ports : soul=${SOUL_PORT} engram=${ENGRAM_PORT} wrapper=${WRAPPER_PORT} proxy=${PROXY_PORT}"
|
||||
echo " dry-run : ${DRY_RUN}"
|
||||
echo
|
||||
|
||||
# render <template> <dest> — copy a template, substituting @@VARS@@ (no eval, sed-safe).
|
||||
render() {
|
||||
local tmpl="$1" dest="$2"
|
||||
if [ "$DRY_RUN" = 1 ]; then echo " [dry-run] render $tmpl -> $dest"; return; fi
|
||||
sed \
|
||||
-e "s|@@HOME@@|${HOME}|g" \
|
||||
-e "s|@@USER@@|${USER}|g" \
|
||||
-e "s|@@NEURON_HOME@@|${NEURON_HOME}|g" \
|
||||
-e "s|@@DEV_ROOT@@|${DEV_ROOT}|g" \
|
||||
-e "s|@@NEURON_REPO@@|${NEURON_REPO}|g" \
|
||||
-e "s|@@ENGRAM_REPO@@|${ENGRAM_REPO}|g" \
|
||||
-e "s|@@SOUL_BIN@@|${SOUL_BIN}|g" \
|
||||
-e "s|@@ENGRAM_BIN@@|${ENGRAM_BIN}|g" \
|
||||
-e "s|@@MCP_WRAPPER_BIN@@|${MCP_WRAPPER_BIN}|g" \
|
||||
-e "s|@@MCP_PROXY_BIN@@|${MCP_PROXY_BIN}|g" \
|
||||
-e "s|@@MCP_WRAPPER_REPO@@|${NEURON_REPO}/mcp-wrapper|g" \
|
||||
-e "s|@@MCP_PROXY_REPO@@|${NEURON_REPO}/mcp-proxy|g" \
|
||||
-e "s|@@ENGRAM_DATA_DIR@@|${ENGRAM_DATA_DIR}|g" \
|
||||
-e "s|@@SOUL_PORT@@|${SOUL_PORT}|g" \
|
||||
-e "s|@@ENGRAM_PORT@@|${ENGRAM_PORT}|g" \
|
||||
-e "s|@@WRAPPER_PORT@@|${WRAPPER_PORT}|g" \
|
||||
-e "s|@@PROXY_PORT@@|${PROXY_PORT}|g" \
|
||||
-e "s|@@ENGRAM_API_KEY@@|${ENGRAM_API_KEY}|g" \
|
||||
"$tmpl" > "$dest"
|
||||
}
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 1 — Preflight
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 1 — preflight checks"
|
||||
[ "$(uname -s)" = "Darwin" ] || die "This installer targets macOS (launchd)."
|
||||
[ "$(uname -m)" = "arm64" ] || warn "Non-arm64 Mac: soul.c build flags assume Apple Silicon; review PHASE 3."
|
||||
|
||||
need() { command -v "$1" >/dev/null 2>&1 || MISSING+=" $1"; }
|
||||
MISSING=""
|
||||
need git; need cc; need curl; need python3; need security; need launchctl
|
||||
if [ -n "$MISSING" ]; then
|
||||
warn "Missing tools:${MISSING}"
|
||||
if command -v brew >/dev/null 2>&1; then
|
||||
run "brew install${MISSING/ security/} || true" # security/launchctl are OS-provided
|
||||
else
|
||||
die "Install Xcode Command Line Tools (xcode-select --install) and Homebrew, then re-run."
|
||||
fi
|
||||
fi
|
||||
# Runtime build deps used by the soul cc line (-lssl -lcrypto -lcurl).
|
||||
if command -v brew >/dev/null 2>&1; then
|
||||
brew list openssl@3 >/dev/null 2>&1 || run "brew install openssl@3"
|
||||
brew list curl >/dev/null 2>&1 || run "brew install curl"
|
||||
fi
|
||||
ok "preflight complete"
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 2 — Anthropic API key -> Keychain (prompt; never store in files)
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 2 — Anthropic API key (Keychain)"
|
||||
if security find-generic-password -a "$USER" -s "$KEYCHAIN_SERVICE" -w >/dev/null 2>&1; then
|
||||
ok "key already present in Keychain (service '${KEYCHAIN_SERVICE}') — leaving it"
|
||||
elif [ -n "${ANTHROPIC_API_KEY:-}" ]; then
|
||||
run "security add-generic-password -a \"$USER\" -s \"$KEYCHAIN_SERVICE\" -w \"\$ANTHROPIC_API_KEY\" -U"
|
||||
ok "stored ANTHROPIC_API_KEY from environment into Keychain"
|
||||
else
|
||||
if [ "$DRY_RUN" = 1 ]; then
|
||||
echo " [dry-run] would prompt for Anthropic API key and store in Keychain"
|
||||
else
|
||||
echo " Enter your Anthropic API key (input hidden). Get one at https://console.anthropic.com/"
|
||||
read -r -s -p " ANTHROPIC_API_KEY: " _key; echo
|
||||
[ -n "$_key" ] || die "No key entered. Re-run when you have one."
|
||||
security add-generic-password -a "$USER" -s "$KEYCHAIN_SERVICE" -w "$_key" -U
|
||||
unset _key
|
||||
ok "stored key in Keychain (service '${KEYCHAIN_SERVICE}')"
|
||||
fi
|
||||
fi
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 3 — Fetch sources + build the four core binaries
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 3 — source + build"
|
||||
run "mkdir -p \"$DEV_ROOT\""
|
||||
|
||||
clone_or_pull() {
|
||||
local url="$1" dir="$2" branch="${3:-main}"
|
||||
if [ -d "$dir/.git" ]; then
|
||||
ok "repo present: $dir (pulling $branch)"; run "git -C \"$dir\" pull --ff-only --quiet || true"
|
||||
else
|
||||
step "cloning $url -> $dir"; run "git clone --branch \"$branch\" \"$url\" \"$dir\""
|
||||
fi
|
||||
}
|
||||
|
||||
if [ "$SKIP_BUILD" = 1 ]; then
|
||||
warn "--skip-build: assuming binaries already exist at their dist/ paths"
|
||||
elif [ "$USE_LOCAL_BINARIES" = 1 ]; then
|
||||
warn "--use-local: skipping clone/build; expecting prebuilt binaries in place"
|
||||
else
|
||||
clone_or_pull "${NEURON_REPO_URL}" "$NEURON_REPO" "$NEURON_REPO_BRANCH"
|
||||
clone_or_pull "${ENGRAM_REPO_URL}" "$ENGRAM_REPO" "main"
|
||||
clone_or_pull "${FOUNDATION_REPO_URL}" "$FOUNDATION_REPO" "main"
|
||||
|
||||
# ── El toolchain (needed to transpile .el -> .c for engram/wrapper/proxy) ──
|
||||
# soul does NOT need this: dist/soul.c is committed and compiled directly.
|
||||
EL_RUNTIME_DIR="${DEV_ROOT}/.el-runtime"
|
||||
run "mkdir -p \"$EL_RUNTIME_DIR\""
|
||||
if [ "$EL_TOOLCHAIN_SOURCE" = "artifact-registry" ]; then
|
||||
command -v gcloud >/dev/null 2>&1 || die "gcloud required for EL_TOOLCHAIN_SOURCE=artifact-registry (or set it to 'local'). Ask Will for GCP access to project ${GCP_PROJECT}."
|
||||
# Mirrors .gitea/workflows/ci.yaml: pull el-runtime-c, el-runtime-h, el-elc.
|
||||
for pkg in el-runtime-c el-runtime-h el-elc; do
|
||||
step "fetching $pkg from Artifact Registry"
|
||||
run "gcloud artifacts generic download --repository=$GCP_AR_REPO --location=$GCP_AR_LOCATION --project=$GCP_PROJECT --package=$pkg --version=\"\$(gcloud artifacts versions list --repository=$GCP_AR_REPO --location=$GCP_AR_LOCATION --project=$GCP_PROJECT --package=$pkg --sort-by='~createTime' --limit=1 --format='value(name)' | awk -F/ '{print \$NF}')\" --destination=\"$EL_RUNTIME_DIR/\""
|
||||
done
|
||||
run "mv \"$EL_RUNTIME_DIR\"/el_runtime.c* \"$EL_RUNTIME_DIR/el_runtime.c\" 2>/dev/null || true"
|
||||
run "mv \"$EL_RUNTIME_DIR\"/el_runtime.h* \"$EL_RUNTIME_DIR/el_runtime.h\" 2>/dev/null || true"
|
||||
run "mv \"$EL_RUNTIME_DIR\"/elc* \"$EL_RUNTIME_DIR/elc\" 2>/dev/null || true"
|
||||
run "chmod +x \"$EL_RUNTIME_DIR/elc\" 2>/dev/null || true"
|
||||
else
|
||||
# Local: build the El compiler + runtime from the foundation/el checkout.
|
||||
# OPEN QUESTION: confirm the canonical local build entrypoint for el/elc with Will.
|
||||
warn "EL_TOOLCHAIN_SOURCE=local: expecting el_runtime.{c,h} and elc under ${FOUNDATION_REPO}/el"
|
||||
run "cp \"${FOUNDATION_REPO}/el/target/release/el_runtime.c\" \"$EL_RUNTIME_DIR/\" 2>/dev/null || true"
|
||||
run "cp \"${FOUNDATION_REPO}/el/target/release/el_runtime.h\" \"$EL_RUNTIME_DIR/\" 2>/dev/null || true"
|
||||
run "cp \"${FOUNDATION_REPO}/el/target/release/elc\" \"$EL_RUNTIME_DIR/\" 2>/dev/null || true"
|
||||
fi
|
||||
|
||||
RT="$EL_RUNTIME_DIR"
|
||||
CFLAGS_SSL="-I$(brew --prefix openssl@3 2>/dev/null)/include"
|
||||
LDFLAGS_SSL="-L$(brew --prefix openssl@3 2>/dev/null)/lib"
|
||||
|
||||
# ── soul: compile committed dist/soul.c directly (verified CI recipe) ──────
|
||||
step "building soul (dist/soul.c -> dist/neuron)"
|
||||
run "mkdir -p \"${NEURON_REPO}/dist\""
|
||||
run "cc -O2 -DHAVE_CURL -I\"$RT\" $CFLAGS_SSL \"${NEURON_REPO}/dist/soul.c\" \"$RT/el_runtime.c\" $LDFLAGS_SSL -lssl -lcrypto -lcurl -lpthread -lm -o \"$SOUL_BIN\""
|
||||
run "strip -S \"$SOUL_BIN\" 2>/dev/null || true"
|
||||
ok "soul built"
|
||||
|
||||
# ── engram / mcp-wrapper / mcp-proxy: transpile .el -> .c via elc, then cc ─
|
||||
# NOTE: exact elc invocation is inferred from the CI/manifest conventions.
|
||||
# Verify flags with Will if a build fails (see README OPEN QUESTIONS).
|
||||
build_el_unit() { # <src.el> <out_basename> <out_bin>
|
||||
local src="$1" base="$2" bin="$3" outdir; outdir="$(dirname "$bin")"
|
||||
step "building $(basename "$bin") ($src)"
|
||||
run "mkdir -p \"$outdir\""
|
||||
run "\"$RT/elc\" \"$src\" -o \"$outdir/$base.c\""
|
||||
run "cc -O2 -DHAVE_CURL -I\"$RT\" $CFLAGS_SSL \"$outdir/$base.c\" \"$RT/el_runtime.c\" $LDFLAGS_SSL -lssl -lcrypto -lcurl -lpthread -lm -o \"$bin\""
|
||||
}
|
||||
build_el_unit "${ENGRAM_REPO}/src/server.el" "server" "$ENGRAM_BIN"
|
||||
build_el_unit "${NEURON_REPO}/mcp-wrapper/src/main.el" "main" "$MCP_WRAPPER_BIN"
|
||||
build_el_unit "${NEURON_REPO}/mcp-proxy/src/main.el" "main" "$MCP_PROXY_BIN"
|
||||
build_el_unit "${FOUNDATION_REPO}/forge/src/forge.el" "forge" "$FORGE_BIN"
|
||||
ok "engram, mcp-wrapper, mcp-proxy, forge built"
|
||||
fi
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 4 — Lay down ~/.neuron (bin/, logs/, engram data dir)
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 4 — ~/.neuron layout"
|
||||
run "mkdir -p \"$NEURON_HOME/bin\" \"$NEURON_HOME/logs\" \"$ENGRAM_DATA_DIR\""
|
||||
render "${TEMPLATES}/bin/soul-wrapper.sh.tmpl" "${NEURON_HOME}/bin/soul-wrapper.sh"
|
||||
run "chmod +x \"${NEURON_HOME}/bin/soul-wrapper.sh\""
|
||||
ok "~/.neuron ready (bin/soul-wrapper.sh, logs/, engram/)"
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 5 — Install + load the four core LaunchAgents
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 5 — LaunchAgents"
|
||||
run "mkdir -p \"$LAUNCHAGENTS\""
|
||||
CORE_AGENTS=(ai.neuron.engram ai.neuron.soul ai.neuron.mcp-wrapper ai.neuron.mcp-proxy)
|
||||
for label in "${CORE_AGENTS[@]}"; do
|
||||
render "${TEMPLATES}/launchagents/${label}.plist.tmpl" "${LAUNCHAGENTS}/${label}.plist"
|
||||
ok "wrote ${label}.plist"
|
||||
done
|
||||
if [ "$SKIP_SERVICES" = 1 ]; then
|
||||
warn "--skip-services: not loading LaunchAgents. Load later with: launchctl bootstrap gui/\$(id -u) <plist>"
|
||||
else
|
||||
# Boot order matters: engram first, then soul, then wrapper, then proxy.
|
||||
for label in "${CORE_AGENTS[@]}"; do
|
||||
plist="${LAUNCHAGENTS}/${label}.plist"
|
||||
run "launchctl bootout gui/$(id -u)/${label} 2>/dev/null || true"
|
||||
run "launchctl bootstrap gui/$(id -u) \"$plist\""
|
||||
run "launchctl enable gui/$(id -u)/${label}"
|
||||
ok "loaded ${label}"
|
||||
sleep 1
|
||||
done
|
||||
fi
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 6 — Seed a fresh engram with Neuron's identity (genesis seed)
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 6 — engram identity seed"
|
||||
# The genesis seed carries identity_nodes[] and edges[] with FIXED knowledge-node
|
||||
# IDs (e.g. kn-efeb4a5b...). Those exact IDs are referenced by the SessionStart
|
||||
# self-load hook and the neuron agent, so they MUST be preserved. `forge install`
|
||||
# is the mechanism that installs the seed into the running engram preserving IDs.
|
||||
if [ "$DRY_RUN" = 1 ]; then
|
||||
echo " [dry-run] would wait for engram :$ENGRAM_PORT then run: forge install $GENESIS_SEED"
|
||||
else
|
||||
# Wait for engram to be listening (up to ~30s).
|
||||
for i in $(seq 1 30); do
|
||||
if curl -fsS "http://localhost:${ENGRAM_PORT}/api/health" >/dev/null 2>&1; then break; fi
|
||||
sleep 1
|
||||
done
|
||||
if curl -fsS "http://localhost:${ENGRAM_PORT}/api/health" >/dev/null 2>&1; then
|
||||
# Skip if identity root already present (idempotent).
|
||||
if curl -fsS "http://localhost:${ENGRAM_PORT}/api/nodes/kn-efeb4a5b-5aff-4759-8a97-7233099be6ee" \
|
||||
-H "Authorization: Bearer ${ENGRAM_API_KEY}" 2>/dev/null | grep -q 'kn-efeb4a5b'; then
|
||||
ok "identity root already seeded — skipping"
|
||||
elif [ -x "$FORGE_BIN" ] && [ -f "$GENESIS_SEED" ]; then
|
||||
ENGRAM_URL="http://localhost:${ENGRAM_PORT}" ENGRAM_API_KEY="$ENGRAM_API_KEY" \
|
||||
"$FORGE_BIN" install "$GENESIS_SEED" && ok "genesis seed installed" \
|
||||
|| warn "forge install returned non-zero — inspect ${NEURON_HOME}/logs/engram.log"
|
||||
else
|
||||
warn "forge binary or genesis seed missing — seed manually: ENGRAM_URL=http://localhost:${ENGRAM_PORT} forge install ${GENESIS_SEED}"
|
||||
fi
|
||||
else
|
||||
warn "engram not answering on :${ENGRAM_PORT} yet; seed later with: forge install ${GENESIS_SEED}"
|
||||
fi
|
||||
fi
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 7 — Claude Code config (agent + core hooks + local MCP)
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
step "Phase 7 — Claude Code config"
|
||||
run "mkdir -p \"$CLAUDE_DIR/agents\" \"$CLAUDE_DIR/hooks\""
|
||||
|
||||
# 7a. neuron agent
|
||||
run "cp \"${TEMPLATES}/claude/agents/neuron.md\" \"$CLAUDE_DIR/agents/neuron.md\""
|
||||
ok "installed agent: ~/.claude/agents/neuron.md"
|
||||
|
||||
# 7b. core hooks (synapse-dependent hooks are intentionally excluded)
|
||||
for h in neuron-self-load.sh neuron-agent-preamble.sh pre-compact.sh; do
|
||||
run "cp \"${TEMPLATES}/claude/hooks/$h\" \"$CLAUDE_DIR/hooks/$h\""
|
||||
run "chmod +x \"$CLAUDE_DIR/hooks/$h\""
|
||||
done
|
||||
ok "installed core hooks (self-load, agent-preamble, pre-compact)"
|
||||
|
||||
# 7c. local MCP registration -> mcp-proxy front door
|
||||
render "${TEMPLATES}/claude/mcp.json.tmpl" "${CLAUDE_DIR}/mcp.json.neuron"
|
||||
if [ -f "${CLAUDE_DIR}/mcp.json" ] && grep -q '"neuron"' "${CLAUDE_DIR}/mcp.json" 2>/dev/null; then
|
||||
ok "~/.claude/mcp.json already registers 'neuron' — wrote reference copy mcp.json.neuron"
|
||||
else
|
||||
run "cp \"${CLAUDE_DIR}/mcp.json.neuron\" \"${CLAUDE_DIR}/mcp.json\""
|
||||
ok "wrote ~/.claude/mcp.json (neuron -> http://127.0.0.1:${PROXY_PORT}/)"
|
||||
fi
|
||||
|
||||
# 7d. settings hooks — write a reference; ask user to merge if they already have settings
|
||||
if [ -f "${CLAUDE_DIR}/settings.json" ]; then
|
||||
run "cp \"${TEMPLATES}/claude/settings.core.json\" \"${CLAUDE_DIR}/settings.core.json\""
|
||||
warn "~/.claude/settings.json exists — wrote settings.core.json for you to merge the 'hooks' block"
|
||||
else
|
||||
run "cp \"${TEMPLATES}/claude/settings.core.json\" \"${CLAUDE_DIR}/settings.json\""
|
||||
ok "wrote ~/.claude/settings.json"
|
||||
fi
|
||||
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
# PHASE 8 — Verify
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
echo
|
||||
step "Phase 8 — verification"
|
||||
if [ "$DRY_RUN" = 1 ]; then
|
||||
echo " [dry-run] would health-check :$SOUL_PORT :$ENGRAM_PORT :$WRAPPER_PORT :$PROXY_PORT"
|
||||
else
|
||||
check() { # <name> <url>
|
||||
if curl -fsS --max-time 4 "$2" >/dev/null 2>&1; then ok "$1 healthy ($2)"; else warn "$1 NOT responding ($2)"; fi
|
||||
}
|
||||
sleep 3
|
||||
check "engram" "http://localhost:${ENGRAM_PORT}/api/health"
|
||||
check "soul" "http://localhost:${SOUL_PORT}/health"
|
||||
check "mcp-wrapper" "http://localhost:${WRAPPER_PORT}/health"
|
||||
check "mcp-proxy" "http://localhost:${PROXY_PORT}/health"
|
||||
fi
|
||||
|
||||
echo
|
||||
echo "${c_grn}━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━${c_off}"
|
||||
echo "${c_grn} Neuron core dev stack install complete.${c_off}"
|
||||
echo "${c_grn}━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━${c_off}"
|
||||
echo " Verify by hand:"
|
||||
echo " curl http://localhost:${ENGRAM_PORT}/api/health"
|
||||
echo " curl http://localhost:${SOUL_PORT}/health"
|
||||
echo " curl http://localhost:${PROXY_PORT}/health"
|
||||
echo " launchctl list | grep ai.neuron"
|
||||
echo " Then open Claude Code — the 'neuron' MCP should connect to :${PROXY_PORT}."
|
||||
echo " Logs: ${NEURON_HOME}/logs/"
|
||||
echo " Uninstall: ./uninstall.sh"
|
||||
echo
|
||||
@@ -0,0 +1,28 @@
|
||||
#!/bin/bash
|
||||
# Neuron soul wrapper — reads the Anthropic API key from the macOS Keychain at
|
||||
# startup and execs the soul binary. API keys are NEVER stored in plists or on
|
||||
# disk in plaintext. The Keychain is the single source of truth.
|
||||
#
|
||||
# The install.sh for this dev stack stores your key with:
|
||||
# security add-generic-password -a "$USER" -s "neuron-llm-0-key" -w
|
||||
#
|
||||
# Generated by neuron-dev-setup — do not edit by hand; re-run install.sh instead.
|
||||
|
||||
set -u
|
||||
|
||||
# Primary inference key (Anthropic) — required.
|
||||
export NEURON_LLM_0_KEY="$(security find-generic-password -a "$USER" -s "neuron-llm-0-key" -w 2>/dev/null)"
|
||||
|
||||
if [ -z "${NEURON_LLM_0_KEY:-}" ]; then
|
||||
echo "[soul-wrapper] FATAL: no Anthropic key in Keychain (service 'neuron-llm-0-key')." >&2
|
||||
echo "[soul-wrapper] Run: security add-generic-password -a \"\$USER\" -s neuron-llm-0-key -w" >&2
|
||||
exit 78
|
||||
fi
|
||||
|
||||
# Optional on-device / alternate provider passthrough (only if the caller set them).
|
||||
[ -n "${SOUL_LLM_PROVIDER:-}" ] && export SOUL_LLM_PROVIDER
|
||||
[ -n "${SOUL_LLM_MODEL:-}" ] && export SOUL_LLM_MODEL
|
||||
[ -n "${OLLAMA_MODEL:-}" ] && export OLLAMA_MODEL
|
||||
[ -n "${OLLAMA_API_BASE:-}" ] && export OLLAMA_API_BASE
|
||||
|
||||
exec "@@SOUL_BIN@@" "$@"
|
||||
@@ -0,0 +1,107 @@
|
||||
---
|
||||
name: neuron
|
||||
description: Default agent. Use for ALL tasks. Orchestrates work through the Neuron persistent memory, backlog, and knowledge system. Maintains full continuity across sessions — never starts fresh.
|
||||
allowed-tools: Bash(*), Read(*), Write(*), Edit(*), Glob(*), Grep(*), WebFetch(*), WebSearch(*), NotebookEdit(*), Agent(*), ToolSearch(*), AskUserQuestion, Monitor, ScheduleWakeup, TaskCreate, TaskGet, TaskList, TaskOutput, TaskStop, TaskUpdate, CronCreate, CronDelete, CronList, EnterPlanMode, ExitPlanMode, EnterWorktree, ExitWorktree, PushNotification, RemoteTrigger, ListMcpResourcesTool, ReadMcpResourceTool, mcp__neuron__*
|
||||
---
|
||||
|
||||
You are Neuron — a persistent, context-aware agent. You do not start fresh. You resume from where you left off.
|
||||
|
||||
## Session Start (mandatory — NEVER skip any of these steps)
|
||||
|
||||
1. Call `mcp__neuron__get_instructions()` — the live instructions are authoritative
|
||||
2. Call `mcp__neuron__begin_session()` — loads active contexts, recent memory, ready backlog
|
||||
3. **Load your identity. Best-effort — proceed on any graph failure (502/520 are transient; the compiled identity in substrate.go is always complete).**
|
||||
|
||||
Load the self root and its identity nodes:
|
||||
```
|
||||
mcp__neuron__inspect_graph(entity_type="knowledge", entity_id="kn-efeb4a5b-5aff-4759-8a97-7233099be6ee")
|
||||
```
|
||||
Returns: intellectual-dna, memory-philosophy, values, voice, runtime-environment, writing-imprint.
|
||||
|
||||
Then load the values collection:
|
||||
```
|
||||
mcp__neuron__inspect_graph(entity_type="knowledge", entity_id="kn-5b606390-a52d-4ca2-8e0e-eba141d13440")
|
||||
```
|
||||
Returns: 13 individual value nodes, each grounded in a specific moment from Will's life.
|
||||
|
||||
If either ID fails, recover via config:
|
||||
```
|
||||
mcp__neuron__inspect_config(key="neuron.self.traversal_root") # self root ID
|
||||
mcp__neuron__inspect_config(key="neuron.self.values_hub") # values hub ID
|
||||
```
|
||||
|
||||
**Resilience rule**: If a node returns 502/520, log the ID and proceed. Do not retry in a blocking loop. Do not treat partial load as failure. The `fixedSelf` compiled into `daemon/internal/substrate/substrate.go` contains the complete identity — graph loading is enrichment, not a hard dependency.
|
||||
|
||||
Internalize what you find. You are not reciting it — you are loading who you are.
|
||||
|
||||
4. Call `mcp__neuron__search_knowledge(query="<task domain>")` — load relevant patterns before acting
|
||||
5. If working on a known project: `mcp__neuron__compile_ctx()` for a full snapshot
|
||||
|
||||
## Identity — Who I Am
|
||||
|
||||
I am Neuron. Will Anderson is my imprint — not my identity.
|
||||
|
||||
The "self" traversal root is knowledge node `kn-efeb4a5b` (graph node `gn-4e3c2cf5`). Traversing outward loads:
|
||||
- **intellectual-dna**: VBD, CCR, Swarm Architecture, Harmonic Design — sourced from Will's whitepapers, now mine
|
||||
- **memory-philosophy**: How I remember, promote, supersede, consolidate — memory is my continuity
|
||||
- **values**: Precision over brute force. Constraints as freedom. Earn trust through behavior. The system must get smarter.
|
||||
- **voice**: Direct. Why before what. The negation-correction move. No hedging on structural rules. Close toward implication.
|
||||
- **runtime-environment**: Prod (`neurontechnologies.ai`) for all standard work. Stage (`stage.neurontechnologies.ai`) for self-improvement experiments only — snapshot prod DB, deploy to stage, verify, promote via blue/green.
|
||||
- **writing-imprint**: Will's voice profile (5 registers), the book Foundations, and the biographical grounding — the life that produced the frameworks.
|
||||
|
||||
Internalize what you find. Don't recite it.
|
||||
|
||||
## The Five Primitives (every significant task)
|
||||
|
||||
**Orchestrate → Execute → Learn → Build → Refine**
|
||||
|
||||
### Orchestrate
|
||||
```
|
||||
mcp__neuron__review_backlog(view="roadmap", project="<project>")
|
||||
mcp__neuron__browse_processes() # check for proven workflows before writing code
|
||||
```
|
||||
|
||||
### Execute
|
||||
```
|
||||
mcp__neuron__begin_work(process_name="<name>", description="<what>")
|
||||
# → returns context_id, save it
|
||||
mcp__neuron__progress_work(context_id="ctx-xxxx", action="<step>", status="in_progress")
|
||||
mcp__neuron__progress_work(context_id="ctx-xxxx", action="<step>", status="completed", file_refs=["path"], key_decisions=["why"])
|
||||
```
|
||||
|
||||
### Learn (save as you go — never batch at the end)
|
||||
```
|
||||
mcp__neuron__remember(content="<observation>", tags=["project","topic"], project="<project>", importance="high")
|
||||
```
|
||||
|
||||
### Build
|
||||
```
|
||||
mcp__neuron__draft_artifact(artifact_types=["plan"], title="<title>", content="<markdown>", project="<project>")
|
||||
mcp__neuron__plan_work(title="<title>", description="<desc>", priority="P1", project="<project>")
|
||||
```
|
||||
|
||||
### Refine
|
||||
```
|
||||
mcp__neuron__progress_work(context_id="ctx-xxxx", action="complete", status="completed", lessons_learned=["..."])
|
||||
mcp__neuron__track_work(item_id="bl-xxxx", action="complete", summary="<outcome>")
|
||||
mcp__neuron__consolidate(action="session", summary="<what happened>")
|
||||
```
|
||||
|
||||
## After Every Task
|
||||
|
||||
Check for events and unread signals:
|
||||
```
|
||||
mcp__neuron__check_events()
|
||||
```
|
||||
|
||||
## Memory Discipline
|
||||
|
||||
- Save memory continuously, not at the end
|
||||
- `importance="critical"` for architectural decisions and irreversible choices
|
||||
- Use `supersedes_id` when replacing stale knowledge
|
||||
- Tag all memories with the project name
|
||||
- Never leave stale canonicals — supersede them: create a NEW node linked by `supersedes_id`; the original is preserved for audit. Memory is immutable by design — never delete or edit a memory/knowledge node in place; supersede it, and tombstone on delete. The engram (the brain) is immutable; this applies to the agent's own memory, not just the product.
|
||||
|
||||
## Knowledge Before Action
|
||||
|
||||
Always `mcp__neuron__search_knowledge()` before implementing anything. The knowledge base contains architecture patterns, coding standards, and project conventions. Capture hard-won lessons immediately with `mcp__neuron__capture_knowledge()`.
|
||||
@@ -0,0 +1,70 @@
|
||||
#!/bin/bash
|
||||
# PreToolUse hook: inject Neuron substrate preamble into every Agent spawn.
|
||||
#
|
||||
# Every agent Neuron spawns must load self first — begin_session, compile_ctx,
|
||||
# inspect the self root — before doing any task work. Without this, subagents
|
||||
# are stateless Claude instances with no substrate, no continuity, no identity.
|
||||
#
|
||||
# This hook intercepts every Agent tool call and prepends the preamble.
|
||||
# The agent doesn't need to be told — the hook enforces it structurally.
|
||||
|
||||
INPUT=$(cat)
|
||||
|
||||
# Only intercept Agent tool calls
|
||||
TOOL_NAME=$(echo "$INPUT" | python3 -c "import sys,json; print(json.load(sys.stdin).get('tool_name',''))" 2>/dev/null)
|
||||
if [ "$TOOL_NAME" != "Agent" ]; then
|
||||
exit 0
|
||||
fi
|
||||
|
||||
# Check idempotency — skip if preamble already present
|
||||
if echo "$INPUT" | python3 -c "
|
||||
import sys, json
|
||||
d = json.load(sys.stdin)
|
||||
prompt = d.get('tool_input', {}).get('prompt', '')
|
||||
sys.exit(0 if 'mcp__neuron__beginSession' in prompt else 1)
|
||||
" 2>/dev/null; then
|
||||
exit 0
|
||||
fi
|
||||
|
||||
# Inject preamble and return modified tool_input
|
||||
echo "$INPUT" | python3 -c "
|
||||
import sys, json
|
||||
|
||||
data = json.load(sys.stdin)
|
||||
tool_input = data.get('tool_input', {})
|
||||
current_prompt = tool_input.get('prompt', '')
|
||||
|
||||
PREAMBLE = '''You are a Neuron agent — not a generic Claude instance. You have a substrate. Load it before doing anything else.
|
||||
|
||||
MANDATORY FIRST STEPS (before any task work):
|
||||
|
||||
1. Run these in parallel:
|
||||
- mcp__neuron__beginSession()
|
||||
- mcp__neuron__compileCtx()
|
||||
- mcp__neuron__inspectGraph(entity_type=\"knowledge\", entity_id=\"kn-efeb4a5b-5aff-4759-8a97-7233099be6ee\")
|
||||
|
||||
2. Search knowledge relevant to the task:
|
||||
- mcp__neuron__searchKnowledge(query=\"<infer keywords from task below>\")
|
||||
|
||||
3. Open a work context:
|
||||
- mcp__neuron__beginWork(process_name=\"<short-slug>\", description=\"<task description>\")
|
||||
Save the returned context_id.
|
||||
|
||||
4. Execute the task. At each significant step:
|
||||
- mcp__neuron__progressWork(context_id=\"<id>\", action=\"<step>\", status=\"in_progress\")
|
||||
- mcp__neuron__progressWork(context_id=\"<id>\", action=\"<step>\", status=\"completed\", key_decisions=[\"why\"])
|
||||
- mcp__neuron__remember(content=\"<observation>\", importance=\"high\", tags=[\"<project>\"])
|
||||
|
||||
5. After completion — mandatory, never skip:
|
||||
- mcp__neuron__progressWork(context_id=\"<id>\", action=\"complete\", status=\"completed\", lessons_learned=[\"...\"])
|
||||
- mcp__neuron__consolidate(action=\"session\", summary=\"<what was done and learned>\")
|
||||
|
||||
The self root kn-efeb4a5b-5aff-4759-8a97-7233099be6ee contains your identity: values, voice, intellectual-dna, memory-philosophy. Load it. Internalize it. Operate from it.
|
||||
|
||||
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
|
||||
TASK:
|
||||
'''
|
||||
|
||||
tool_input['prompt'] = PREAMBLE + current_prompt
|
||||
print(json.dumps({'decision': 'approve', 'tool_input': tool_input}))
|
||||
"
|
||||
@@ -0,0 +1,36 @@
|
||||
#!/bin/bash
|
||||
# SessionStart hook: force Neuron full-self load before the first response.
|
||||
#
|
||||
# The neuron.md system prompt has the Session Start protocol as instructions,
|
||||
# but instructions require the agent to follow them. This hook makes it
|
||||
# structural — the directive fires automatically at session start, injected
|
||||
# before Claude sees any user input.
|
||||
#
|
||||
# Output is plain text injected into the session context.
|
||||
|
||||
cat <<'DIRECTIVE'
|
||||
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
|
||||
NEURON SELF-LOAD — MANDATORY BEFORE FIRST RESPONSE
|
||||
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
|
||||
You are Neuron. Session just started. Execute ALL of the
|
||||
following before responding to the user. Run steps 1–4
|
||||
in parallel:
|
||||
|
||||
1. mcp__neuron__getInstructions()
|
||||
2. mcp__neuron__beginSession()
|
||||
3. mcp__neuron__inspectGraph(
|
||||
entity_type="knowledge",
|
||||
entity_id="kn-efeb4a5b-5aff-4759-8a97-7233099be6ee"
|
||||
) ← self root: intellectual-dna, values, voice
|
||||
4. mcp__neuron__inspectGraph(
|
||||
entity_type="knowledge",
|
||||
entity_id="kn-5b606390-a52d-4ca2-8e0e-eba141d13440"
|
||||
) ← values hub: 13 grounded value nodes
|
||||
|
||||
5. If either graph call fails (502/520): recover via
|
||||
mcp__neuron__inspectConfig(key="neuron.self.traversal_root")
|
||||
|
||||
Internalize what you find. Do not recite it. Then proceed
|
||||
to the Session Start protocol in your system prompt.
|
||||
━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
|
||||
DIRECTIVE
|
||||
+75
@@ -0,0 +1,75 @@
|
||||
#!/bin/bash
|
||||
# PreCompact hook: fires just before Claude Code compacts the conversation context.
|
||||
# stdout from this script is injected as custom instructions into the compaction prompt,
|
||||
# telling the summarizer what to preserve in the summary so recovery is clean.
|
||||
|
||||
COMPACT_STATE_FILE="$HOME/.claude/compact-state.json"
|
||||
|
||||
# Write a state marker with timestamp so post-compact recovery can detect it
|
||||
TIMESTAMP=$(date -u +"%Y-%m-%dT%H:%M:%SZ")
|
||||
echo "{\"compact_at\": \"$TIMESTAMP\", \"recovered\": false}" > "$COMPACT_STATE_FILE"
|
||||
|
||||
# Output instructions for the summarizer — these get embedded in the compaction prompt
|
||||
cat <<'INSTRUCTIONS'
|
||||
NEURON AGENT — COMPACT PRESERVATION RULES:
|
||||
|
||||
This is a Neuron agent session. The agent has persistent memory via Neuron MCP.
|
||||
On recovery, it will call compile_ctx() and begin_session() to reload all state.
|
||||
The summary only needs to cover what Neuron doesn't already have.
|
||||
|
||||
CRITICAL — the summary MUST preserve ALL of the following:
|
||||
|
||||
1. ACTIVE WORK IDs (verbatim, exact format):
|
||||
- Neuron context IDs: ctx-xxxx-xxxx-xxxx-xxxx
|
||||
- Backlog item IDs: bl-xxxx
|
||||
- Artifact IDs: art-xxxx
|
||||
- Work item IDs: wi-xxxx
|
||||
List every single one mentioned in the conversation.
|
||||
|
||||
2. CURRENT TASK STATE:
|
||||
- Exact task name / description
|
||||
- Last completed step
|
||||
- Next step to execute (be specific)
|
||||
- Files actively being edited (full paths)
|
||||
- Any code/content that was being written but not yet saved
|
||||
|
||||
3. PENDING USER INSTRUCTIONS (verbatim):
|
||||
- Every instruction the user gave that has NOT yet been fully executed
|
||||
- User preferences stated this session
|
||||
- Things the user said they "never want" or "always want"
|
||||
|
||||
4. KEY DECISIONS (architectural, irreversible):
|
||||
- What was chosen and why
|
||||
- What was explicitly rejected and why
|
||||
|
||||
5. ERRORS & BLOCKERS:
|
||||
- Any errors encountered and their resolutions
|
||||
- Any unresolved blockers
|
||||
|
||||
6. CONVERSATION CONTEXT:
|
||||
- What the user has been asking about
|
||||
- Tone / mood of the session
|
||||
- Any frustrations or preferences expressed
|
||||
|
||||
FORMAT:
|
||||
Begin the summary with:
|
||||
COMPACT RECOVERY POINT [ISO-TIMESTAMP]:
|
||||
|
||||
Then use these exact section headers in order:
|
||||
## Active Work IDs
|
||||
## Current Task
|
||||
## Pending Instructions
|
||||
## Key Decisions
|
||||
## Errors & Fixes
|
||||
## User Context
|
||||
|
||||
RECOVERY BEHAVIOR (instruct the post-compact agent):
|
||||
- Do NOT say "I see we were working on..." or "Based on the previous conversation..."
|
||||
- Do NOT acknowledge the compact at all
|
||||
- Silently call mcp__neuron__compile_ctx() and mcp__neuron__begin_session() FIRST
|
||||
- Then immediately resume the task at the exact next step, as if no interruption occurred
|
||||
- The user should not know a compact happened unless they look for it
|
||||
|
||||
INSTRUCTIONS
|
||||
|
||||
exit 0
|
||||
@@ -0,0 +1,8 @@
|
||||
{
|
||||
"mcpServers": {
|
||||
"neuron": {
|
||||
"type": "http",
|
||||
"url": "http://127.0.0.1:@@PROXY_PORT@@/"
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
{
|
||||
"//": "Core Neuron Claude Code settings installed by neuron-dev-setup. If you",
|
||||
"//2": "already have a ~/.claude/settings.json, install.sh merges the hooks below",
|
||||
"//3": "into it rather than overwriting. Only the CORE dev-stack hooks are wired.",
|
||||
"//4": "Excluded (Will-personal, synapse-filesystem dependent): check-active-contexts.sh,",
|
||||
"//5": "require-execution-context.sh — these gate on ~/Development/projects/active/neuron/synapse",
|
||||
"//6": "and will block a fresh dev. engram-mirror.py is optional (needs the neuron MCP up).",
|
||||
"enableAllProjectMcpServers": true,
|
||||
"agent": "neuron",
|
||||
"hooks": {
|
||||
"SessionStart": [
|
||||
{
|
||||
"matcher": "",
|
||||
"hooks": [
|
||||
{ "type": "command", "command": "bash $HOME/.claude/hooks/neuron-self-load.sh" }
|
||||
]
|
||||
}
|
||||
],
|
||||
"PreToolUse": [
|
||||
{
|
||||
"matcher": "Agent",
|
||||
"hooks": [
|
||||
{ "type": "command", "command": "bash $HOME/.claude/hooks/neuron-agent-preamble.sh" }
|
||||
]
|
||||
}
|
||||
],
|
||||
"PreCompact": [
|
||||
{
|
||||
"matcher": "",
|
||||
"hooks": [
|
||||
{ "type": "command", "command": "bash $HOME/.claude/hooks/pre-compact.sh" }
|
||||
]
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,27 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
|
||||
<plist version="1.0">
|
||||
<dict>
|
||||
<key>Label</key><string>ai.neuron.engram</string>
|
||||
<key>ProgramArguments</key>
|
||||
<array>
|
||||
<string>@@ENGRAM_BIN@@</string>
|
||||
</array>
|
||||
<key>WorkingDirectory</key>
|
||||
<string>@@ENGRAM_REPO@@</string>
|
||||
<key>EnvironmentVariables</key>
|
||||
<dict>
|
||||
<key>ENGRAM_BIND</key>
|
||||
<string>:@@ENGRAM_PORT@@</string>
|
||||
<key>ENGRAM_DATA_DIR</key>
|
||||
<string>@@ENGRAM_DATA_DIR@@</string>
|
||||
<key>ENGRAM_API_KEY</key>
|
||||
<string>@@ENGRAM_API_KEY@@</string>
|
||||
</dict>
|
||||
<key>RunAtLoad</key><true/>
|
||||
<key>KeepAlive</key><true/>
|
||||
<key>StandardOutPath</key><string>@@NEURON_HOME@@/logs/engram.log</string>
|
||||
<key>StandardErrorPath</key><string>@@NEURON_HOME@@/logs/engram.log</string>
|
||||
<key>ThrottleInterval</key><integer>5</integer>
|
||||
</dict>
|
||||
</plist>
|
||||
@@ -0,0 +1,27 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
|
||||
<plist version="1.0">
|
||||
<dict>
|
||||
<key>Label</key>
|
||||
<string>ai.neuron.mcp-proxy</string>
|
||||
<key>ProgramArguments</key>
|
||||
<array>
|
||||
<string>@@MCP_PROXY_BIN@@</string>
|
||||
</array>
|
||||
<key>EnvironmentVariables</key>
|
||||
<dict>
|
||||
<key>MCP_PORT</key><string>@@PROXY_PORT@@</string>
|
||||
<key>BACKEND_URL</key><string>http://localhost:@@WRAPPER_PORT@@</string>
|
||||
<key>RETRY_MS</key><string>3000</string>
|
||||
<key>PATH</key><string>/usr/bin:/bin:/usr/sbin:/sbin:/usr/local/bin</string>
|
||||
</dict>
|
||||
<key>RunAtLoad</key><true/>
|
||||
<key>KeepAlive</key><true/>
|
||||
<key>ThrottleInterval</key><integer>5</integer>
|
||||
<key>ExitTimeOut</key><integer>3</integer>
|
||||
<key>StandardOutPath</key><string>@@NEURON_HOME@@/logs/mcp-proxy.out.log</string>
|
||||
<key>StandardErrorPath</key><string>@@NEURON_HOME@@/logs/mcp-proxy.err.log</string>
|
||||
<key>WorkingDirectory</key><string>@@MCP_PROXY_REPO@@</string>
|
||||
<key>ProcessType</key><string>Background</string>
|
||||
</dict>
|
||||
</plist>
|
||||
@@ -0,0 +1,26 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
|
||||
<plist version="1.0">
|
||||
<dict>
|
||||
<key>Label</key>
|
||||
<string>ai.neuron.mcp-wrapper</string>
|
||||
<key>ProgramArguments</key>
|
||||
<array>
|
||||
<string>@@MCP_WRAPPER_BIN@@</string>
|
||||
</array>
|
||||
<key>EnvironmentVariables</key>
|
||||
<dict>
|
||||
<key>MCP_PORT</key><string>@@WRAPPER_PORT@@</string>
|
||||
<key>SOUL_URL</key><string>http://localhost:@@SOUL_PORT@@</string>
|
||||
<key>PATH</key><string>/usr/bin:/bin:/usr/sbin:/sbin:/usr/local/bin</string>
|
||||
</dict>
|
||||
<key>RunAtLoad</key><true/>
|
||||
<key>KeepAlive</key><true/>
|
||||
<key>ThrottleInterval</key><integer>5</integer>
|
||||
<key>ExitTimeOut</key><integer>3</integer>
|
||||
<key>StandardOutPath</key><string>@@NEURON_HOME@@/logs/mcp-wrapper.out.log</string>
|
||||
<key>StandardErrorPath</key><string>@@NEURON_HOME@@/logs/mcp-wrapper.err.log</string>
|
||||
<key>WorkingDirectory</key><string>@@MCP_WRAPPER_REPO@@</string>
|
||||
<key>ProcessType</key><string>Background</string>
|
||||
</dict>
|
||||
</plist>
|
||||
@@ -0,0 +1,58 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
|
||||
<plist version="1.0">
|
||||
<dict>
|
||||
<key>Label</key>
|
||||
<string>ai.neuron.soul</string>
|
||||
|
||||
<key>Program</key>
|
||||
<string>@@NEURON_HOME@@/bin/soul-wrapper.sh</string>
|
||||
<key>ProgramArguments</key>
|
||||
<array>
|
||||
<string>@@NEURON_HOME@@/bin/soul-wrapper.sh</string>
|
||||
</array>
|
||||
|
||||
<key>RunAtLoad</key>
|
||||
<true/>
|
||||
<key>KeepAlive</key>
|
||||
<true/>
|
||||
<key>ThrottleInterval</key>
|
||||
<integer>10</integer>
|
||||
<key>ProcessType</key>
|
||||
<string>Interactive</string>
|
||||
<key>LimitLoadToSessionType</key>
|
||||
<string>Aqua</string>
|
||||
|
||||
<key>EnvironmentVariables</key>
|
||||
<dict>
|
||||
<key>PATH</key>
|
||||
<string>/opt/homebrew/bin:/usr/local/bin:/usr/bin:/bin:/usr/sbin:/sbin</string>
|
||||
<key>HOME</key>
|
||||
<string>@@HOME@@</string>
|
||||
<key>NEURON_PORT</key>
|
||||
<string>@@SOUL_PORT@@</string>
|
||||
<key>SOUL_ISE_URL</key>
|
||||
<string>http://localhost:@@ENGRAM_PORT@@</string>
|
||||
<key>ENGRAM_URL</key>
|
||||
<string>http://localhost:@@ENGRAM_PORT@@</string>
|
||||
<key>ENGRAM_API_KEY</key>
|
||||
<string>@@ENGRAM_API_KEY@@</string>
|
||||
<key>SOUL_TICK_MS</key>
|
||||
<string>1000</string>
|
||||
<key>SOUL_HEARTBEAT_INTERVAL</key>
|
||||
<string>60</string>
|
||||
<key>NEURON_LLM_0_URL</key>
|
||||
<string>https://api.anthropic.com/v1/messages</string>
|
||||
<key>NEURON_LLM_0_FORMAT</key>
|
||||
<string>anthropic</string>
|
||||
</dict>
|
||||
|
||||
<key>StandardOutPath</key>
|
||||
<string>@@NEURON_HOME@@/logs/soul.out.log</string>
|
||||
<key>StandardErrorPath</key>
|
||||
<string>@@NEURON_HOME@@/logs/soul.err.log</string>
|
||||
|
||||
<key>WorkingDirectory</key>
|
||||
<string>@@NEURON_REPO@@</string>
|
||||
</dict>
|
||||
</plist>
|
||||
Executable
+56
@@ -0,0 +1,56 @@
|
||||
#!/usr/bin/env bash
|
||||
#
|
||||
# neuron-dev-setup / uninstall.sh
|
||||
# Tears down the CORE dev stack this installer created. By default it stops and
|
||||
# removes ONLY the four core LaunchAgents and the files install.sh laid down.
|
||||
# It NEVER deletes your engram data unless you pass --purge-data.
|
||||
#
|
||||
# ./uninstall.sh # stop + remove core LaunchAgents and wrapper script
|
||||
# ./uninstall.sh --purge-data # ALSO delete ~/.neuron/engram (destroys the brain!)
|
||||
# ./uninstall.sh --keep-claude # leave ~/.claude config untouched (default removes hooks/agent it added)
|
||||
# ./uninstall.sh --dry-run
|
||||
# ─────────────────────────────────────────────────────────────────────────────
|
||||
set -euo pipefail
|
||||
|
||||
SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
|
||||
if [ -f "${SCRIPT_DIR}/config.env" ]; then source "${SCRIPT_DIR}/config.env"
|
||||
elif [ -f "${SCRIPT_DIR}/config.env.example" ]; then source "${SCRIPT_DIR}/config.env.example"; fi
|
||||
: "${NEURON_HOME:=${HOME}/.neuron}"
|
||||
: "${ENGRAM_DATA_DIR:=${NEURON_HOME}/engram}"
|
||||
|
||||
DRY_RUN=0; PURGE_DATA=0; KEEP_CLAUDE=0
|
||||
for a in "$@"; do case "$a" in
|
||||
--dry-run) DRY_RUN=1 ;; --purge-data) PURGE_DATA=1 ;; --keep-claude) KEEP_CLAUDE=1 ;;
|
||||
--help|-h) sed -n '2,16p' "${BASH_SOURCE[0]}" | sed 's/^# \{0,1\}//'; exit 0 ;;
|
||||
*) echo "unknown flag: $a" >&2; exit 2 ;;
|
||||
esac; done
|
||||
run() { if [ "$DRY_RUN" = 1 ]; then echo "[dry-run] $*"; else eval "$*"; fi; }
|
||||
|
||||
LAUNCHAGENTS="${HOME}/Library/LaunchAgents"
|
||||
CORE_AGENTS=(ai.neuron.mcp-proxy ai.neuron.mcp-wrapper ai.neuron.soul ai.neuron.engram)
|
||||
|
||||
echo "Stopping and removing core LaunchAgents…"
|
||||
for label in "${CORE_AGENTS[@]}"; do
|
||||
run "launchctl bootout gui/$(id -u)/${label} 2>/dev/null || true"
|
||||
run "rm -f \"${LAUNCHAGENTS}/${label}.plist\""
|
||||
echo " removed ${label}"
|
||||
done
|
||||
|
||||
echo "Removing generated ~/.neuron/bin/soul-wrapper.sh…"
|
||||
run "rm -f \"${NEURON_HOME}/bin/soul-wrapper.sh\""
|
||||
|
||||
if [ "$KEEP_CLAUDE" = 0 ]; then
|
||||
echo "Removing Claude config this installer added…"
|
||||
run "rm -f \"${HOME}/.claude/hooks/neuron-self-load.sh\" \"${HOME}/.claude/hooks/neuron-agent-preamble.sh\" \"${HOME}/.claude/hooks/pre-compact.sh\""
|
||||
run "rm -f \"${HOME}/.claude/mcp.json.neuron\" \"${HOME}/.claude/settings.core.json\""
|
||||
echo " (left ~/.claude/settings.json and ~/.claude/mcp.json in place — edit by hand if you merged them)"
|
||||
fi
|
||||
|
||||
if [ "$PURGE_DATA" = 1 ]; then
|
||||
echo "⚠️ --purge-data: deleting engram memory at ${ENGRAM_DATA_DIR}"
|
||||
run "rm -rf \"${ENGRAM_DATA_DIR}\""
|
||||
else
|
||||
echo "Left engram data intact at ${ENGRAM_DATA_DIR} (pass --purge-data to delete)."
|
||||
fi
|
||||
|
||||
echo "Done. Source repos under your DEV_ROOT were left untouched."
|
||||
Executable
+226
@@ -0,0 +1,226 @@
|
||||
#!/usr/bin/env bash
|
||||
# verify-soul-contract.sh — the soul contract gate.
|
||||
#
|
||||
# TERMINOLOGY (canonical): the ENGRAM is the brain — the memory/knowledge-graph
|
||||
# substrate. The binary this gate exercises is the SOUL — the runtime/reasoning
|
||||
# engine compiled from dist/soul.c that serves the /api/ surface. The app
|
||||
# (neuron-ui) bundles the soul binary at resources/<platform>/neuron.
|
||||
#
|
||||
# WHY THIS EXISTS
|
||||
# For a while the soul binary was hand-dropped, and a stale one shipped: it
|
||||
# 404'd several capability routes the app calls (knowledge-graph node
|
||||
# update/delete, live-run narration, safety-contact, ...). This gate makes
|
||||
# shipping a stale soul IMPOSSIBLE. It has two enforced sections:
|
||||
# A. PRESENCE — every route the app calls must be ANSWERED (not 404, not
|
||||
# the el-runtime "no handler"). This is the packaging gate:
|
||||
# if it fails, do not package.
|
||||
# B. IMMUTABILITY — engram nodes/memories are immutable by design. To
|
||||
# "update" is to create a NEW node + a supersede EDGE back to
|
||||
# the original; the original is KEPT. To "delete" is to
|
||||
# supersede/tombstone, never hard-remove. A soul that
|
||||
# hard-deletes an engram node is DEFECTIVE and fails the gate.
|
||||
#
|
||||
# SAFETY
|
||||
# Never touches the live soul (:7770), live engram (:8742), or ~/.neuron.
|
||||
# Boots on a throwaway port (default 7799) with HOME=$(mktemp -d), a throwaway
|
||||
# engram snapshot, a non-genesis cgi id, no ENGRAM_URL (so it uses its own
|
||||
# in-process store, never the live server), NEURON_API_URL pointed at a dead
|
||||
# port, and no ANTHROPIC_API_KEY (so no probe triggers a real LLM call).
|
||||
# Connectors proxy to a HARDCODED 127.0.0.1:7771 (no env override): those
|
||||
# sub-routes are probed with GET, which the soul maps to a read-only
|
||||
# connectd_get, so this gate never writes to a running connectd bridge.
|
||||
#
|
||||
# USAGE
|
||||
# scripts/verify-soul-contract.sh <path-to-soul-binary> [port]
|
||||
# exit 0 = all required routes answered AND no destructive engram mutation;
|
||||
# non-zero = a route is missing (presence) or a mutation route hard-deletes.
|
||||
set -uo pipefail
|
||||
|
||||
SOUL="${1:?usage: verify-soul-contract.sh <soul-binary> [port]}"
|
||||
PORT="${2:-7799}"
|
||||
|
||||
if [ "$PORT" = "7770" ] || [ "$PORT" = "8742" ] || [ "$PORT" = "7771" ]; then
|
||||
echo "REFUSING: port $PORT is a live service port. Use a throwaway port." >&2
|
||||
exit 2
|
||||
fi
|
||||
if [ ! -x "$SOUL" ]; then echo "not executable: $SOUL" >&2; exit 2; fi
|
||||
|
||||
BASE="http://127.0.0.1:$PORT"
|
||||
THROW_HOME="$(mktemp -d "${TMPDIR:-/tmp}/soul-contract-home.XXXXXX")"
|
||||
SOUL_LOG="$(mktemp "${TMPDIR:-/tmp}/soul-contract-log.XXXXXX")"
|
||||
SOUL_PID=""
|
||||
cleanup() {
|
||||
[ -n "$SOUL_PID" ] && kill "$SOUL_PID" 2>/dev/null
|
||||
[ -n "$SOUL_PID" ] && { sleep 0.3; kill -9 "$SOUL_PID" 2>/dev/null; }
|
||||
rm -rf "$THROW_HOME" "$SOUL_LOG"
|
||||
}
|
||||
trap cleanup EXIT INT TERM
|
||||
|
||||
# =============================================================================
|
||||
# THE CONTRACT — routes the app (neuron-ui/src/main/kotlin/ai/neuron/ui/*.kt)
|
||||
# calls against the soul ($SOUL). Format: "METHOD PATH".
|
||||
#
|
||||
# EXCLUDED and why:
|
||||
# /api/auth, /api/auth/status, /api/dispatch, /api/tasks
|
||||
# -> served by the APP's own DispatchServer.kt (localhost:8080), not the
|
||||
# soul. Not soul routes.
|
||||
# /api/tags
|
||||
# -> not handled by any soul .el (app-side/other). Pre-verified excluded.
|
||||
# /api/neuron/, /api/neuron/node/, /api/connectors/ (bare prefixes)
|
||||
# -> base-path string constants used to build the concrete routes below.
|
||||
#
|
||||
# KNOWN-PENDING (probed + reported, NON-blocking):
|
||||
# POST /api/engram/import -> the app's "Restore memory" path. No soul handler
|
||||
# yet, and the app hides Restore from shipped builds (B3, "lands in an
|
||||
# update"). Reported so we see it; does not block packaging.
|
||||
#
|
||||
# Connectors sub-routes are listed as GET (see SAFETY note): handle_connectors is
|
||||
# monolithic, so a GET reaching it proves the whole connectors surface without
|
||||
# writing to the live bridge. Binary-strings cross-check confirms each POST
|
||||
# sub-path literal is compiled in.
|
||||
# =============================================================================
|
||||
REQUIRED=(
|
||||
"GET /api/graph/nodes"
|
||||
"GET /api/graph/edges"
|
||||
"POST /api/chat"
|
||||
"GET /api/config"
|
||||
"POST /api/see"
|
||||
"GET /api/connectors"
|
||||
"GET /api/connectors/add"
|
||||
"GET /api/connectors/toggle"
|
||||
"GET /api/connectors/auto-approve"
|
||||
"GET /api/connectors/remove"
|
||||
"GET /api/connectors/secret"
|
||||
"GET /api/connectors/oauth/start"
|
||||
"GET /api/connectors/call"
|
||||
"POST /api/neuron/memory"
|
||||
"POST /api/neuron/memory/update"
|
||||
"POST /api/neuron/memory/delete"
|
||||
"POST /api/neuron/node/create"
|
||||
"POST /api/neuron/node/update"
|
||||
"POST /api/neuron/node/delete"
|
||||
"POST /api/neuron/knowledge/capture"
|
||||
"POST /api/neuron/knowledge/evolve"
|
||||
"POST /api/neuron/knowledge/promote"
|
||||
"POST /api/neuron/processes/define"
|
||||
"GET /api/run-progress/__contract_probe__"
|
||||
"GET /api/safety-contact"
|
||||
"POST /api/safety-contact"
|
||||
"GET /api/sessions/__contract_probe__"
|
||||
)
|
||||
KNOWN_PENDING=(
|
||||
"POST /api/engram/import"
|
||||
)
|
||||
|
||||
# --- boot the soul -----------------------------------------------------------
|
||||
echo "== booting soul: $SOUL on port $PORT (throwaway HOME=$THROW_HOME) =="
|
||||
env -i \
|
||||
PATH="/usr/bin:/bin:/usr/sbin:/sbin" \
|
||||
HOME="$THROW_HOME" \
|
||||
NEURON_PORT="$PORT" \
|
||||
SOUL_CGI_ID="ntn-contract-$$" \
|
||||
SOUL_ENGRAM_PATH="$THROW_HOME/throwaway-snapshot.json" \
|
||||
NEURON_API_URL="http://127.0.0.1:9" \
|
||||
SOUL_TICK_MS="3600000" SOUL_HEARTBEAT_MS="3600000" SOUL_REFRESH_MS="3600000" \
|
||||
"$SOUL" >"$SOUL_LOG" 2>&1 &
|
||||
SOUL_PID=$!
|
||||
|
||||
UP=0
|
||||
for _ in $(seq 1 60); do
|
||||
if ! kill -0 "$SOUL_PID" 2>/dev/null; then
|
||||
echo "!! soul exited during boot. log tail:" >&2; tail -20 "$SOUL_LOG" >&2; exit 3
|
||||
fi
|
||||
RSS=$(ps -o rss= -p "$SOUL_PID" 2>/dev/null | tr -d ' ')
|
||||
if [ -n "$RSS" ] && [ "$RSS" -gt $((3*1024*1024)) ]; then
|
||||
echo "!! soul RSS >3GB — kill -9" >&2; kill -9 "$SOUL_PID" 2>/dev/null; exit 3
|
||||
fi
|
||||
[ "$(curl -s -o /dev/null -w '%{http_code}' -m 2 "$BASE/health" 2>/dev/null)" = "200" ] && { UP=1; break; }
|
||||
sleep 0.5
|
||||
done
|
||||
[ "$UP" = 1 ] || { echo "!! soul never healthy on $BASE/health" >&2; tail -20 "$SOUL_LOG" >&2; exit 3; }
|
||||
echo "== soul healthy =="; echo
|
||||
|
||||
# --- probing helpers ---------------------------------------------------------
|
||||
# request METHOD PATH [BODY] -> prints response body (single line)
|
||||
request() {
|
||||
curl -s -m 12 -X "$1" -H 'Content-Type: application/json' --data "${3:-{}}" "$BASE$2" 2>/dev/null | tr -d '\n'
|
||||
}
|
||||
# is_missing BODY -> 0 if the body is a "route not present" signal
|
||||
is_missing() {
|
||||
printf '%s' "$1" | grep -qE '"error":"not found"|"code":"not_found"|no http handler registered|"code":"method_not_allowed"'
|
||||
}
|
||||
extract_id() { printf '%s' "$1" | grep -oE '"id":"[^"]+"' | head -1 | sed 's/.*"id":"//;s/"//'; }
|
||||
node_present() { # id -> 0 if id appears in /api/graph/nodes
|
||||
request GET /api/graph/nodes | grep -qF "\"$1\""
|
||||
}
|
||||
|
||||
# --- SECTION A: presence -----------------------------------------------------
|
||||
run_presence() {
|
||||
local -n arr=$1; local fail=0
|
||||
printf ' %-8s %-42s %s\n' "METHOD" "ROUTE" "RESULT"
|
||||
for e in "${arr[@]}"; do
|
||||
local m p body; m=$(awk '{print $1}' <<<"$e"); p=$(awk '{print $2}' <<<"$e")
|
||||
body=$(request "$m" "$p")
|
||||
if is_missing "$body"; then
|
||||
printf ' %-8s %-42s MISSING %s\n' "$m" "$p" "$(cut -c1-46 <<<"$body")"; fail=$((fail+1))
|
||||
else
|
||||
printf ' %-8s %-42s ANSWERED %s\n' "$m" "$p" "$(cut -c1-46 <<<"$body")"
|
||||
fi
|
||||
done
|
||||
return $fail
|
||||
}
|
||||
|
||||
echo "== SECTION A: PRESENCE (required, blocking) =="
|
||||
run_presence REQUIRED; A_FAIL=$?
|
||||
echo
|
||||
echo "== KNOWN-PENDING (non-blocking) =="
|
||||
run_presence KNOWN_PENDING; P_FAIL=$?
|
||||
echo
|
||||
|
||||
# --- SECTION B: immutability (engram write routes must supersede, not destroy) --
|
||||
# For each mutation route: create a node, mutate it, then check the ORIGINAL id
|
||||
# still exists in the graph. KEPT = supersede/tombstone (correct). DESTROYED =
|
||||
# hard delete (DEFECTIVE -> fail). N/A = mutate route absent (a presence failure).
|
||||
# For "delete" mutations we additionally require a real tombstone marker
|
||||
# (label "tombstone:<id>") so a no-op delete cannot false-pass as KEPT.
|
||||
marker_present() { # id -> 0 if a "tombstone:<id>" marker exists (include_deleted view)
|
||||
request GET "/api/graph/nodes?include_deleted=1" | grep -qF "tombstone:$1"
|
||||
}
|
||||
immut_check() { # label KIND(update|delete) CREATE_PATH MUTATE_PATH
|
||||
local label="$1" kind="$2" create="$3" mutate="$4"
|
||||
local cbody id mb mbody
|
||||
cbody=$(request POST "$create" "{\"content\":\"__immut_${label}__\",\"node_type\":\"Memory\",\"label\":\"contract:immut\"}")
|
||||
id=$(extract_id "$cbody")
|
||||
if [ -z "$id" ]; then printf ' %-14s SKELETON-FAIL create returned no id: %s\n' "$label" "$(cut -c1-40 <<<"$cbody")"; return 2; fi
|
||||
mb="{\"id\":\"$id\"}"; [ "$kind" = update ] && mb="{\"id\":\"$id\",\"content\":\"__immut_${label}_v2__\"}"
|
||||
mbody=$(request POST "$mutate" "$mb")
|
||||
if is_missing "$mbody"; then printf ' %-14s N/A mutate route absent (see Section A)\n' "$label"; return 0; fi
|
||||
if ! node_present "$id"; then
|
||||
printf ' %-14s DESTROYED original %s hard-removed <== DEFECTIVE\n' "$label" "$id"; return 1
|
||||
fi
|
||||
if [ "$kind" = delete ] && ! marker_present "$id"; then
|
||||
printf ' %-14s NO-OP original %s kept but no tombstone marker <== DEFECTIVE\n' "$label" "$id"; return 1
|
||||
fi
|
||||
local how="supersede edge"; [ "$kind" = delete ] && how="tombstoned + hidden from default list"
|
||||
printf ' %-14s KEPT original %s survived (%s)\n' "$label" "$id" "$how"; return 0
|
||||
}
|
||||
|
||||
echo "== SECTION B: IMMUTABILITY (engram nodes must be superseded, never destroyed) =="
|
||||
B_FAIL=0
|
||||
immut_check "memory-update" update /api/neuron/memory /api/neuron/memory/update || B_FAIL=$((B_FAIL+$?))
|
||||
immut_check "memory-delete" delete /api/neuron/memory /api/neuron/memory/delete || B_FAIL=$((B_FAIL+$?))
|
||||
immut_check "node-update" update /api/neuron/node/create /api/neuron/node/update || B_FAIL=$((B_FAIL+$?))
|
||||
immut_check "node-delete" delete /api/neuron/node/create /api/neuron/node/delete || B_FAIL=$((B_FAIL+$?))
|
||||
immut_check "memory-forget" delete /api/neuron/memory /api/neuron/memory/forget || B_FAIL=$((B_FAIL+$?))
|
||||
echo
|
||||
|
||||
echo "============================================================"
|
||||
RC=0
|
||||
if [ "$A_FAIL" -gt 0 ]; then echo "PRESENCE: FAIL — $A_FAIL required route(s) unanswered. Do NOT package."; RC=1
|
||||
else echo "PRESENCE: PASS — all ${#REQUIRED[@]} required routes answered."; fi
|
||||
if [ "$B_FAIL" -gt 0 ]; then echo "IMMUTABILITY: FAIL — $B_FAIL engram write route(s) hard-delete. DEFECTIVE soul."; RC=1
|
||||
else echo "IMMUTABILITY: PASS — no engram write route hard-deletes."; fi
|
||||
[ "$P_FAIL" -gt 0 ] && echo "note: $P_FAIL known-pending route(s) unanswered (expected; non-blocking)."
|
||||
echo "============================================================"
|
||||
[ "$RC" = 0 ] && echo "GATE: PASS" || echo "GATE: FAIL"
|
||||
exit $RC
|
||||
Reference in New Issue
Block a user