code wiki / _hdl_build / nx_clawf_route.nx
nx_clawf_route.nx source
↩ module page · 278 lines · 12370 B
1// nx_clawf_route.nx -- SPLIT-BRAIN ROUTER ORGAN (TS01, 2026-07-21). OO-CONSOLIDATED onto nx_sovjson_lib.
2// Shift the 80% iterate-and-fix loop OFF Claude onto the 0-API local maker; keep Claude for
3// architecture. Reads the clawf- catalog (MEASURED from 221 historic Claude transcripts) and maps a
4// tool-transition SIGNATURE -> {route, organ, confidence}; deterministic, fail-closed (unrecognized
5// -> CLAUDE-ARCHITECT escalate). Token-efficiency lever measured by nx_seat shift. Helpers COMPOSED
6// from nx_sovjson_lib (sj_*) = DRY across the token subsystem, no inline dup.
7// route <sig> [clawfprefix] | table [clawfprefix] | plan [clawfprefix] | selftest [tmpprefix]
8// clawf- row = id class support route organ note (6-col plane).
9// license_tier: ORIGINAL No hw writes (Rule 26). expect_exit: 0
10import "nx_sovjson_lib.nx"
11import "nx_store_seed_lib.nx"
12import "nx_seg_store.nx"
13import "nx_gate_verdict.nx"
14import "nx_syscalls.nx"
15
16const CR_CAP: i64 = 1048576
17const CR_OUT: i64 = 8192
18const CR_SPAN: i64 = 16
19const CR_USAGE: i64 = 2
20const CR_HI: i64 = 1000
21const CR_MED: i64 = 100
22const CR_ROWCAP: i64 = 64
23const CR_ESC: i64 = 200
24
25func cr_route(sig: *u8, prefix: *u8, out: *u8) -> i64 {
26 let buf: *u8 = sys_mmap(CR_CAP)
27 let n: i64 = sts_load(prefix, buf, CR_CAP)
28 let c1: *i64 = sys_mmap(CR_SPAN) as *i64
29 let c2: *i64 = sys_mmap(CR_SPAN) as *i64
30 let c3: *i64 = sys_mmap(CR_SPAN) as *i64
31 let c4: *i64 = sys_mmap(CR_SPAN) as *i64
32 var bestprio: i64 = 0
33 var bestsup: i64 = 0
34 var brs: i64 = 0 - 1
35 var bre: i64 = 0 - 1
36 var bcls: i64 = 0 - 1
37 var bcle: i64 = 0 - 1
38 var i: i64 = 0
39 while i < n {
40 let le: i64 = sj_le(buf, i, n)
41 if sj_col(buf, i, le, 1, c1) == 1 {
42 var prio: i64 = 0
43 if sj_lit_eq(buf, c1[0], c1[1], sig) == 1 { prio = 2 } else {
44 if sj_span_has(buf, c1[0], c1[1], sig) == 1 { prio = 1 }
45 }
46 if prio > 0 {
47 var sup: i64 = 0
48 if sj_col(buf, i, le, 2, c2) == 1 { sup = sj_atoi_span(buf, c2[0], c2[1]) }
49 var take: i64 = 0
50 if prio > bestprio { take = 1 } else { if prio == bestprio { if sup > bestsup { take = 1 } } }
51 if take == 1 {
52 bestprio = prio
53 bestsup = sup
54 if sj_col(buf, i, le, 3, c3) == 1 { brs = c3[0]; bre = c3[1] }
55 if sj_col(buf, i, le, 4, c4) == 1 { bcls = c4[0]; bcle = c4[1] }
56 }
57 }
58 }
59 i = le + 1
60 }
61 var o: i64 = 0
62 o = sj_cat(out, o, "{\"organ\":\"nx_clawf_route\",\"verb\":\"route\",\"sig\":\"" as *u8)
63 o = sj_cat_esc(out, o, sig, 0, sj_vlen(sig), CR_ESC)
64 o = sj_cat(out, o, "\",\"route\":\"" as *u8)
65 if bestprio > 0 {
66 o = sj_cat_esc(out, o, buf, brs, bre, 60)
67 o = sj_cat(out, o, "\",\"organ\":\"" as *u8)
68 o = sj_cat_esc(out, o, buf, bcls, bcle, 60)
69 o = sj_cat(out, o, "\",\"support\":" as *u8)
70 o = sj_catn(out, o, bestsup)
71 o = sj_cat(out, o, ",\"match\":\"" as *u8)
72 if bestprio == 2 { o = sj_cat(out, o, "EXACT" as *u8) } else { o = sj_cat(out, o, "SUBSTR" as *u8) }
73 o = sj_cat(out, o, "\",\"confidence\":\"" as *u8)
74 if bestsup >= CR_HI { o = sj_cat(out, o, "HIGH" as *u8) } else { if bestsup >= CR_MED { o = sj_cat(out, o, "MED" as *u8) } else { o = sj_cat(out, o, "LOW" as *u8) } }
75 o = sj_cat(out, o, "\"" as *u8)
76 } else {
77 o = sj_cat(out, o, "CLAUDE-ARCHITECT\",\"organ\":\"claude-session\",\"support\":0,\"match\":\"NONE\",\"confidence\":\"ESCALATE\"" as *u8)
78 }
79 o = sj_cat(out, o, ",\"store_bytes\":" as *u8)
80 o = sj_catn(out, o, n)
81 o = sj_cat(out, o, ",\"authority\":\"catalog=clawf-;measured-221-transcripts;fail-closed=unknown->CLAUDE-ARCHITECT\"}" as *u8)
82 out[o] = 10 as u8
83 o = o + 1
84 return o
85}
86func cr_table(prefix: *u8, out: *u8) -> i64 {
87 let buf: *u8 = sys_mmap(CR_CAP)
88 let n: i64 = sts_load(prefix, buf, CR_CAP)
89 let c0: *i64 = sys_mmap(CR_SPAN) as *i64
90 let c1: *i64 = sys_mmap(CR_SPAN) as *i64
91 let c3: *i64 = sys_mmap(CR_SPAN) as *i64
92 var o: i64 = 0
93 o = sj_cat(out, o, "{\"organ\":\"nx_clawf_route\",\"verb\":\"table\",\"store_bytes\":" as *u8)
94 o = sj_catn(out, o, n)
95 o = sj_cat(out, o, ",\"rows\":[" as *u8)
96 var shown: i64 = 0
97 var tot: i64 = 0
98 var i: i64 = 0
99 while i < n {
100 let le: i64 = sj_le(buf, i, n)
101 if sj_col(buf, i, le, 0, c0) == 1 {
102 tot = tot + 1
103 if shown < CR_ROWCAP {
104 if sj_col(buf, i, le, 1, c1) == 1 { if sj_col(buf, i, le, 3, c3) == 1 {
105 if shown > 0 { o = sj_cat(out, o, "," as *u8) }
106 o = sj_cat(out, o, "{\"class\":\"" as *u8)
107 o = sj_cat_esc(out, o, buf, c1[0], c1[1], 60)
108 o = sj_cat(out, o, "\",\"route\":\"" as *u8)
109 o = sj_cat_esc(out, o, buf, c3[0], c3[1], 40)
110 o = sj_cat(out, o, "\"}" as *u8)
111 shown = shown + 1
112 } }
113 }
114 }
115 i = le + 1
116 }
117 o = sj_cat(out, o, "],\"rows_total\":" as *u8)
118 o = sj_catn(out, o, tot)
119 o = sj_cat(out, o, ",\"shown\":" as *u8)
120 o = sj_catn(out, o, shown)
121 o = sj_cat(out, o, ",\"cap\":" as *u8)
122 o = sj_catn(out, o, CR_ROWCAP)
123 o = sj_cat(out, o, "}" as *u8)
124 out[o] = 10 as u8
125 o = o + 1
126 return o
127}
128func cr_plan(prefix: *u8, out: *u8) -> i64 {
129 let buf: *u8 = sys_mmap(CR_CAP)
130 let n: i64 = sts_load(prefix, buf, CR_CAP)
131 let c2: *i64 = sys_mmap(CR_SPAN) as *i64
132 let c3: *i64 = sys_mmap(CR_SPAN) as *i64
133 var local: i64 = 0
134 var ctx: i64 = 0
135 var organ: i64 = 0
136 var other: i64 = 0
137 var rows: i64 = 0
138 var i: i64 = 0
139 while i < n {
140 let le: i64 = sj_le(buf, i, n)
141 if sj_col(buf, i, le, 3, c3) == 1 {
142 rows = rows + 1
143 var sup: i64 = 0
144 if sj_col(buf, i, le, 2, c2) == 1 { sup = sj_atoi_span(buf, c2[0], c2[1]) }
145 if sj_span_has(buf, c3[0], c3[1], "LOCAL" as *u8) == 1 { local = local + sup } else {
146 if sj_span_has(buf, c3[0], c3[1], "CONTEXT" as *u8) == 1 { ctx = ctx + sup } else {
147 if sj_span_has(buf, c3[0], c3[1], "ORGAN" as *u8) == 1 { organ = organ + sup } else { other = other + sup }
148 }
149 }
150 }
151 i = le + 1
152 }
153 let total: i64 = local + ctx + organ + other
154 var shift_permil: i64 = 0
155 var offload_permil: i64 = 0
156 if total > 0 { shift_permil = (local * 1000) / total }
157 if total > 0 { offload_permil = ((local + ctx + organ) * 1000) / total }
158 var o: i64 = 0
159 o = sj_cat(out, o, "{\"organ\":\"nx_clawf_route\",\"verb\":\"plan\",\"classes\":{\"local_maker\":" as *u8)
160 o = sj_catn(out, o, local)
161 o = sj_cat(out, o, ",\"context_trim\":" as *u8)
162 o = sj_catn(out, o, ctx)
163 o = sj_cat(out, o, ",\"organ_composite\":" as *u8)
164 o = sj_catn(out, o, organ)
165 o = sj_cat(out, o, ",\"other\":" as *u8)
166 o = sj_catn(out, o, other)
167 o = sj_cat(out, o, "},\"cataloged_support\":" as *u8)
168 o = sj_catn(out, o, total)
169 o = sj_cat(out, o, ",\"rows\":" as *u8)
170 o = sj_catn(out, o, rows)
171 o = sj_cat(out, o, ",\"shiftable_permil\":" as *u8)
172 o = sj_catn(out, o, shift_permil)
173 o = sj_cat(out, o, ",\"offload_permil\":" as *u8)
174 o = sj_catn(out, o, offload_permil)
175 o = sj_cat(out, o, ",\"store_bytes\":" as *u8)
176 o = sj_catn(out, o, n)
177 o = sj_cat(out, o, ",\"note\":\"denominator=cataloged-top-workflow-transition-support;uncataloged-escalate-to-CLAUDE-ARCHITECT;shiftable=LOCAL-routes\"}" as *u8)
178 out[o] = 10 as u8
179 o = o + 1
180 return o
181}
182func cr_selftest(base: *u8) -> i64 {
183 let ctr: *i64 = gv_ctr()
184 gv_head("nx_clawf_route selftest -- split-brain routing over the clawf- catalog (TS01, OO-consolidated)" as *u8)
185 let now: i64 = sys_now_realtime_sec()
186 let fp: *u8 = sys_mmap(256)
187 var fo: i64 = sj_cat(fp, 0, base)
188 fo = sj_catn(fp, fo, now)
189 fo = sj_cat(fp, fo, "clawf-" as *u8)
190 fp[fo] = 0 as u8
191 let seed: *u8 = sys_mmap(CR_CAP)
192 var so: i64 = 0
193 so = sj_cat(seed, so, "CW01 Edit_Write->PowerShell 7695 LOCAL-MAKER nx_autofix_ensemble n
194" as *u8)
195 so = sj_cat(seed, so, "CW03 Read->Edit 3073 LOCAL-MAKER nx_autofix_cascade n
196" as *u8)
197 so = sj_cat(seed, so, "CW04 Grep->Read->Edit 1017 CONTEXT-TRIM nx_seat n
198" as *u8)
199 so = sj_cat(seed, so, "CW99 tiny-thing 5 LOCAL nx_shelltool n
200" as *u8)
201 sts_seed(fp, seed, so)
202 let out: *u8 = sys_mmap(CR_OUT)
203 var l: i64 = cr_route("Edit_Write->PowerShell" as *u8, fp, out)
204 var t1: i64 = 0
205 if sj_span_has(out, 0, l, "LOCAL-MAKER" as *u8) == 1 { if sj_span_has(out, 0, l, "\"confidence\":\"HIGH\"" as *u8) == 1 { if sj_span_has(out, 0, l, "\"match\":\"EXACT\"" as *u8) == 1 { t1 = 1 } } }
206 gv_check("T1 exact hi-support -> LOCAL-MAKER HIGH EXACT" as *u8, t1, ctr)
207 l = cr_route("Read->Edit" as *u8, fp, out)
208 gv_check("T2 route carries the target organ" as *u8, sj_span_has(out, 0, l, "nx_autofix_cascade" as *u8), ctr)
209 l = cr_route("Grep->Read->Edit" as *u8, fp, out)
210 gv_check("T3 grep-read-edit -> CONTEXT-TRIM" as *u8, sj_span_has(out, 0, l, "CONTEXT-TRIM" as *u8), ctr)
211 l = cr_route("SomethingNovel->Xyz" as *u8, fp, out)
212 var t4: i64 = 0
213 if sj_span_has(out, 0, l, "CLAUDE-ARCHITECT" as *u8) == 1 { if sj_span_has(out, 0, l, "ESCALATE" as *u8) == 1 { t4 = 1 } }
214 gv_check("T4 unknown sig -> CLAUDE-ARCHITECT ESCALATE (fail-closed)" as *u8, t4, ctr)
215 l = cr_route("tiny-thing" as *u8, fp, out)
216 gv_check("T5 low-support -> LOW confidence" as *u8, sj_span_has(out, 0, l, "\"confidence\":\"LOW\"" as *u8), ctr)
217 l = cr_route("PowerShell" as *u8, fp, out)
218 gv_check("T6 substring sig matches a class SUBSTR" as *u8, sj_span_has(out, 0, l, "\"match\":\"SUBSTR\"" as *u8), ctr)
219 l = cr_table(fp, out)
220 var t7: i64 = 0
221 if sj_span_has(out, 0, l, "\"rows_total\":4" as *u8) == 1 { if sj_span_has(out, 0, l, "\"cap\":" as *u8) == 1 { t7 = 1 } }
222 gv_check("T7 table = all rows + envelope declared" as *u8, t7, ctr)
223 l = cr_plan(fp, out)
224 var t8: i64 = 0
225 if sj_span_has(out, 0, l, "\"shiftable_permil\":913" as *u8) == 1 { if sj_span_has(out, 0, l, "\"cataloged_support\":11790" as *u8) == 1 { t8 = 1 } }
226 gv_check("T8 plan aggregates shiftable_permil over cataloged support" as *u8, t8, ctr)
227 let rc: i64 = gv_verdict("CLAWF-ROUTE-GATE" as *u8, ctr, "split-brain router route/table/plan + fail-closed, OO-consolidated onto nx_sovjson_lib" as *u8)
228 return rc
229}
230func main(argc: i64, argv: *i64) -> i64 {
231 if argc < 2 {
232 sj_werr("usage: nx_clawf_route {route <sig> [clawfprefix] | table [clawfprefix] | plan [clawfprefix] | selftest [tmpprefix]}
233" as *u8)
234 sys_exit(CR_USAGE)
235 return CR_USAGE
236 }
237 let verb: *u8 = argv[1] as *u8
238 if sj_lit_eq(verb, 0, sj_vlen(verb), "route" as *u8) == 1 {
239 if argc < 3 { sj_werr("CLAWF-FAIL route needs <sig>
240" as *u8); sys_exit(CR_USAGE); return CR_USAGE }
241 var pfx: *u8 = "knowledge/store/clawf-" as *u8
242 if argc > 3 { pfx = argv[3] as *u8 }
243 let out: *u8 = sys_mmap(CR_OUT)
244 let n: i64 = cr_route(argv[2] as *u8, pfx, out)
245 sys_write(1, out, n)
246 sys_exit(0)
247 return 0
248 }
249 if sj_lit_eq(verb, 0, sj_vlen(verb), "table" as *u8) == 1 {
250 var pfx2: *u8 = "knowledge/store/clawf-" as *u8
251 if argc > 2 { pfx2 = argv[2] as *u8 }
252 let out: *u8 = sys_mmap(CR_OUT)
253 let n: i64 = cr_table(pfx2, out)
254 sys_write(1, out, n)
255 sys_exit(0)
256 return 0
257 }
258 if sj_lit_eq(verb, 0, sj_vlen(verb), "plan" as *u8) == 1 {
259 var pfx3: *u8 = "knowledge/store/clawf-" as *u8
260 if argc > 2 { pfx3 = argv[2] as *u8 }
261 let out: *u8 = sys_mmap(CR_OUT)
262 let n: i64 = cr_plan(pfx3, out)
263 sys_write(1, out, n)
264 sys_exit(0)
265 return 0
266 }
267 if sj_lit_eq(verb, 0, sj_vlen(verb), "selftest" as *u8) == 1 {
268 var base: *u8 = "/tmp/nxclawf_st" as *u8
269 if argc > 2 { base = argv[2] as *u8 }
270 let rc: i64 = cr_selftest(base)
271 sys_exit(rc)
272 return rc
273 }
274 sj_werr("CLAWF-FAIL unknown verb
275" as *u8)
276 sys_exit(CR_USAGE)
277 return CR_USAGE
278}