nx_vizsla_deal_gate.nx source

1// nx_vizsla_deal_gate.nx -- VIZSLA business-CRM deal gate: the pipeline is gate-proven against a construction- 2// known deal book with HAND-COMPUTED forecast (oracle in THIS header). 100% sovereign. 3// 4// deals (seg-7701): d1 acme $50,000 ; d2 globex $12,000 ; d3 initech $8,000. 5// stages: d1 qualified@06-01 then proposal@06-10 (latest WINS) ; d2 lead@06-05 ; d3 won@06-15. 6// probs: lead10 qualified30 proposal50 negotiation70 won100 lost0. 7// d1 proposal OPEN weighted = 5000000*50/100 = 2500000 8// d2 lead OPEN weighted = 1200000*10/100 = 120000 9// d3 won WON weighted = 0 ; won_value += 800000 10// => deals=3 open=2 won=1 lost=0 total=7000000 won_value=800000 weighted_pipeline=2620000 11// 12// Rows: 13// 1 deal-load 7 records -> new=7 seg-7701 14// 2 idempotent new=0 dup_instore=7 (law 10) 15// 3 latest-stage d1 stage=proposal (NOT the earlier qualified) -- additive latest-by-date wins 16// 4 weighted-open d2 lead value=1200000 prob=10 weighted=120000 state=OPEN 17// 5 won-closed d3 stage=won weighted=0 state=WON 18// 6 pipeline-verdict deals=3 open=2 won=1 lost=0 total_value=7000000 won_value=800000 weighted_pipeline=2620000 19// 7 neg-bad-stage STAGE ... frobnicate -> exit 1 20// 8 neg-bad-value DEAL value not digits -> exit 1 21// Evidence: VIZSLA-DEAL-GATE -> stdout + knowledge/status/vizsla_gate.log; exit 0 iff 8/8. 22// license_tier: ORIGINAL 23import "nx_syscalls.nx" 24import "nx_gate_verdict.nx" 25 26func og_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n } 27func og_p(s: *u8) -> i64 { sys_write(1, s, og_slen(s)); return 0 } 28 29func og_cat(dst: *u8, off: i64, s: *u8) -> i64 { 30 var i: i64 = 0 31 while s[i] != (0 as u8) { dst[off + i] = s[i]; i = i + 1 } 32 return off + i 33} 34 35func og_catn(dst: *u8, off: i64, v: i64) -> i64 { 36 var o: i64 = off 37 var m: i64 = v 38 if m < 0 { dst[o] = 45 as u8; o = o + 1; m = 0 - m } 39 let t: *u8 = sys_mmap(28) 40 var k: i64 = 0 41 if m == 0 { t[0] = 48 as u8; k = 1 } 42 while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 } 43 var i: i64 = 0 44 while i < k { dst[o + i] = t[k - 1 - i]; i = i + 1 } 45 return o + k 46} 47 48func og_write(path: *u8, content: *u8) -> i64 { 49 let fd: i64 = sys_openat_wr(path, 0x1a4) 50 if fd < 0 { return 0 - 1 } 51 sys_write(fd, content, og_slen(content)) 52 sys_close(fd) 53 return 0 54} 55 56func og_readall(path: *u8, szout: *i64) -> *u8 { 57 let fd: i64 = sys_openat_rd(path) 58 if fd < 0 { szout[0] = 0 - 1; return 0 as *u8 } 59 let sz: i64 = sys_lseek(fd, 0, 2) 60 sys_lseek(fd, 0, 0) 61 let buf: *u8 = sys_mmap(sz + 64) 62 var got: i64 = 0 63 var n: i64 = 1 64 while n > 0 { n = sys_read(fd, (buf as i64 + got) as *u8, 65536); if n > 0 { got = got + n } } 65 sys_close(fd) 66 szout[0] = got 67 return buf 68} 69 70func og_runv(elf: *u8, args: *i64, outpath: *u8) -> i64 { 71 let pid: i64 = sys_fork() 72 if pid == 0 { 73 if (outpath as i64) != 0 { 74 let ofd: i64 = sys_openat_wr(outpath, 0x1a4) 75 if ofd >= 0 { sys_dup3(ofd, 1, 0); sys_dup3(ofd, 2, 0) } 76 } 77 let argv: *i64 = sys_mmap(128) as *i64 78 argv[0] = elf as i64 79 var i: i64 = 0 80 var go: i64 = 1 81 while go == 1 { if args[i] == 0 { go = 0 } else { argv[i + 1] = args[i]; i = i + 1 } } 82 argv[i + 1] = 0 83 let envp: *i64 = sys_mmap(16) as *i64 84 envp[0] = 0 85 sys_execve(elf, argv, envp) 86 sys_exit(127) 87 } 88 let st: *i64 = sys_mmap(16) as *i64 89 sys_wait4(pid, st, 0) 90 let sig: i64 = st[0] & 0x7f 91 if sig != 0 { return 128 + sig } 92 return (st[0] >> 8) & 0xff 93} 94 95func og_has(path: *u8, needle: *u8) -> i64 { 96 let szp: *i64 = sys_mmap(16) as *i64 97 let b: *u8 = og_readall(path, szp) 98 let sz: i64 = szp[0] 99 let n: i64 = og_slen(needle) 100 if sz < n { return 0 } 101 var i: i64 = 0 102 while i + n <= sz { 103 var ok: i64 = 1 104 var j: i64 = 0 105 while j < n { if b[i + j] != needle[j] { ok = 0; j = n } else { j = j + 1 } } 106 if ok == 1 { return 1 } 107 i = i + 1 108 } 109 return 0 110} 111 112func og_row(name: *u8, pass: i64) -> i64 { 113 og_p("ROW " as *u8); og_p(name) 114 if pass == 1 { og_p(" PASS\n" as *u8) } else { og_p(" FAIL\n" as *u8) } 115 return pass 116} 117 118func og_args(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8) -> *i64 { 119 let a: *i64 = sys_mmap(64) as *i64 120 a[0] = a1 as i64; a[1] = a2 as i64; a[2] = a3 as i64; a[3] = a4 as i64; a[4] = a5 as i64; a[5] = 0 121 return a 122} 123 124func main(argc: i64, argv: *i64) -> i64 { 125 og_p("=== VIZSLA DEAL GATE: business CRM pipeline (latest-stage-wins + weighted forecast) ===\n" as *u8) 126 var ob: *u8 = "buildroot/_build/nx_vizsla_deal.sov.elf" as *u8 127 if argc > 1 { ob = argv[1] as *u8 } 128 let pr: i64 = sys_openat_rd(ob) 129 if pr >= 0 { sys_close(pr) } 130 else { 131 og_p(" instrument missing -> rebuilding via durable runner\n" as *u8) 132 og_runv("_offc/nx_sov_build_run.elf" as *u8, og_args("nx_vizsla_deal" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzd_rebuild.out" as *u8) 133 } 134 135 let pfx: *u8 = sys_mmap(128) 136 var po: i64 = 0 137 po = og_cat(pfx, po, "/tmp/vzdG" as *u8); po = og_catn(pfx, po, sys_now_us()); po = og_cat(pfx, po, "-" as *u8) 138 pfx[po] = 0 as u8 139 140 og_write("/tmp/vzd_deals.txt" as *u8, "DEAL d1 acme 5000000 enterprise-license\nDEAL d2 globex 1200000 pilot\nDEAL d3 initech 800000 renewal\nSTAGE 2026-06-01 d1 qualified\nSTAGE 2026-06-10 d1 proposal\nSTAGE 2026-06-05 d2 lead\nSTAGE 2026-06-15 d3 won\n" as *u8) 141 og_write("/tmp/vzd_badstage.txt" as *u8, "DEAL x acme 100 t\nSTAGE 2026-06-01 x frobnicate\n" as *u8) 142 og_write("/tmp/vzd_badvalue.txt" as *u8, "DEAL y acme abc thing\n" as *u8) 143 144 var pass: i64 = 0 145 var r: i64 = 0 146 147 // row 1: load 148 let rc1: i64 = og_runv(ob, og_args("load" as *u8, "/tmp/vzd_deals.txt" as *u8, pfx, "7701" as *u8, 0 as *u8), "/tmp/vzd_l1.txt" as *u8) 149 r = 0 150 if rc1 == 0 { if og_has("/tmp/vzd_l1.txt" as *u8, "VIZSLA-DEAL-LOAD scanned=7 new=7 dup_infile=0 dup_instore=0 segment=seg-7701" as *u8) == 1 { r = 1 } } 151 pass = pass + og_row("deal-load" as *u8, r) 152 153 // row 2: idempotent reload 154 let rc2: i64 = og_runv(ob, og_args("load" as *u8, "/tmp/vzd_deals.txt" as *u8, pfx, "7709" as *u8, 0 as *u8), "/tmp/vzd_l2.txt" as *u8) 155 r = 0 156 if rc2 == 0 { if og_has("/tmp/vzd_l2.txt" as *u8, "VIZSLA-DEAL-LOAD scanned=7 new=0 dup_infile=0 dup_instore=7 segment=none" as *u8) == 1 { r = 1 } } 157 pass = pass + og_row("idempotent-reload" as *u8, r) 158 159 // rows 3-6: pipeline 160 og_runv(ob, og_args("pipeline" as *u8, pfx, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzd_pipe.txt" as *u8) 161 r = og_has("/tmp/vzd_pipe.txt" as *u8, "VIZSLA-DEAL-PIPE deal=d1 account=acme stage=proposal value=5000000 prob=50 weighted=2500000 state=OPEN" as *u8) 162 pass = pass + og_row("latest-stage-wins" as *u8, r) 163 164 r = og_has("/tmp/vzd_pipe.txt" as *u8, "VIZSLA-DEAL-PIPE deal=d2 account=globex stage=lead value=1200000 prob=10 weighted=120000 state=OPEN" as *u8) 165 pass = pass + og_row("weighted-open" as *u8, r) 166 167 r = og_has("/tmp/vzd_pipe.txt" as *u8, "VIZSLA-DEAL-PIPE deal=d3 account=initech stage=won value=800000 prob=100 weighted=0 state=WON" as *u8) 168 pass = pass + og_row("won-closed" as *u8, r) 169 170 r = og_has("/tmp/vzd_pipe.txt" as *u8, "VIZSLA-DEAL-PIPE-VERDICT deals=3 open=2 won=1 lost=0 total_value=7000000 won_value=800000 weighted_pipeline=2620000" as *u8) 171 pass = pass + og_row("pipeline-verdict" as *u8, r) 172 173 // row 7: bad stage 174 let rc7: i64 = og_runv(ob, og_args("load" as *u8, "/tmp/vzd_badstage.txt" as *u8, "/tmp/vzdBSx-" as *u8, "1" as *u8, 0 as *u8), "/tmp/vzd_7.txt" as *u8) 175 r = 0 176 if rc7 == 1 { r = 1 } 177 pass = pass + og_row("neg-bad-stage" as *u8, r) 178 179 // row 8: bad value 180 let rc8: i64 = og_runv(ob, og_args("load" as *u8, "/tmp/vzd_badvalue.txt" as *u8, "/tmp/vzdBVx-" as *u8, "1" as *u8, 0 as *u8), "/tmp/vzd_8.txt" as *u8) 181 r = 0 182 if rc8 == 1 { r = 1 } 183 pass = pass + og_row("neg-bad-value" as *u8, r) 184 185 let permil: i64 = (pass * 1000) / 8 186 let logfd: i64 = sys_openat_append("knowledge/status/vizsla_gate.log" as *u8, 0x1a4) 187 var fdi: i64 = 0 188 while fdi < 2 { 189 var fd: i64 = 1 190 if fdi == 1 { fd = logfd } 191 if fd > 0 { 192 let line: *u8 = sys_mmap(256) 193 var o: i64 = 0 194 o = og_cat(line, o, "VIZSLA-DEAL-GATE epoch=" as *u8) 195 o = og_catn(line, o, sys_now_realtime_sec()) 196 o = og_cat(line, o, " rows=8 pass=" as *u8) 197 o = og_catn(line, o, pass) 198 o = og_cat(line, o, " permil=" as *u8) 199 o = og_catn(line, o, permil) 200 if pass == 8 { o = og_cat(line, o, " verdict=GREEN\n" as *u8) } else { o = og_cat(line, o, " verdict=RED\n" as *u8) } 201 sys_write(fd, line, o) 202 } 203 fdi = fdi + 1 204 } 205 if logfd > 0 { sys_close(logfd) } 206 // MIGRATED onto nx_gate_verdict by nx_gate_dry_apply (D001, minimal form): every check 207 // row above is untouched, so the PASS/FAIL vector cannot change; only the hand-rolled 208 // verdict emission is replaced by the ONE shared base class. Proven by nx_gate_migrate verify. 209 let ctr__dry: *i64 = gv_ctr() 210 ctr__dry[0] = pass 211 ctr__dry[1] = 8 212 let rc__dry: i64 = gv_verdict("VIZSLA-DEAL-GATE" as *u8, ctr__dry, "teeth unchanged; verdict emission migrated onto the shared base class" as *u8) 213 sys_exit(rc__dry) 214 return rc__dry 215}