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" 24 25func og_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n } 26func og_p(s: *u8) -> i64 { sys_write(1, s, og_slen(s)); return 0 } 27 28func og_cat(dst: *u8, off: i64, s: *u8) -> i64 { 29 var i: i64 = 0 30 while s[i] != (0 as u8) { dst[off + i] = s[i]; i = i + 1 } 31 return off + i 32} 33 34func og_catn(dst: *u8, off: i64, v: i64) -> i64 { 35 var o: i64 = off 36 var m: i64 = v 37 if m < 0 { dst[o] = 45 as u8; o = o + 1; m = 0 - m } 38 let t: *u8 = sys_mmap(28) 39 var k: i64 = 0 40 if m == 0 { t[0] = 48 as u8; k = 1 } 41 while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 } 42 var i: i64 = 0 43 while i < k { dst[o + i] = t[k - 1 - i]; i = i + 1 } 44 return o + k 45} 46 47func og_write(path: *u8, content: *u8) -> i64 { 48 let fd: i64 = sys_openat_wr(path, 0x1a4) 49 if fd < 0 { return 0 - 1 } 50 sys_write(fd, content, og_slen(content)) 51 sys_close(fd) 52 return 0 53} 54 55func og_readall(path: *u8, szout: *i64) -> *u8 { 56 let fd: i64 = sys_openat_rd(path) 57 if fd < 0 { szout[0] = 0 - 1; return 0 as *u8 } 58 let sz: i64 = sys_lseek(fd, 0, 2) 59 sys_lseek(fd, 0, 0) 60 let buf: *u8 = sys_mmap(sz + 64) 61 var got: i64 = 0 62 var n: i64 = 1 63 while n > 0 { n = sys_read(fd, (buf as i64 + got) as *u8, 65536); if n > 0 { got = got + n } } 64 sys_close(fd) 65 szout[0] = got 66 return buf 67} 68 69func og_runv(elf: *u8, args: *i64, outpath: *u8) -> i64 { 70 let pid: i64 = sys_fork() 71 if pid == 0 { 72 if (outpath as i64) != 0 { 73 let ofd: i64 = sys_openat_wr(outpath, 0x1a4) 74 if ofd >= 0 { sys_dup3(ofd, 1, 0); sys_dup3(ofd, 2, 0) } 75 } 76 let argv: *i64 = sys_mmap(128) as *i64 77 argv[0] = elf as i64 78 var i: i64 = 0 79 var go: i64 = 1 80 while go == 1 { if args[i] == 0 { go = 0 } else { argv[i + 1] = args[i]; i = i + 1 } } 81 argv[i + 1] = 0 82 let envp: *i64 = sys_mmap(16) as *i64 83 envp[0] = 0 84 sys_execve(elf, argv, envp) 85 sys_exit(127) 86 } 87 let st: *i64 = sys_mmap(16) as *i64 88 sys_wait4(pid, st, 0) 89 let sig: i64 = st[0] & 0x7f 90 if sig != 0 { return 128 + sig } 91 return (st[0] >> 8) & 0xff 92} 93 94func og_has(path: *u8, needle: *u8) -> i64 { 95 let szp: *i64 = sys_mmap(16) as *i64 96 let b: *u8 = og_readall(path, szp) 97 let sz: i64 = szp[0] 98 let n: i64 = og_slen(needle) 99 if sz < n { return 0 } 100 var i: i64 = 0 101 while i + n <= sz { 102 var ok: i64 = 1 103 var j: i64 = 0 104 while j < n { if b[i + j] != needle[j] { ok = 0; j = n } else { j = j + 1 } } 105 if ok == 1 { return 1 } 106 i = i + 1 107 } 108 return 0 109} 110 111func og_row(name: *u8, pass: i64) -> i64 { 112 og_p("ROW " as *u8); og_p(name) 113 if pass == 1 { og_p(" PASS\n" as *u8) } else { og_p(" FAIL\n" as *u8) } 114 return pass 115} 116 117func og_args(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8) -> *i64 { 118 let a: *i64 = sys_mmap(64) as *i64 119 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 120 return a 121} 122 123func main(argc: i64, argv: *i64) -> i64 { 124 og_p("=== VIZSLA DEAL GATE: business CRM pipeline (latest-stage-wins + weighted forecast) ===\n" as *u8) 125 var ob: *u8 = "/tmp/nx_vizsla_deal.sov.elf" as *u8 126 if argc > 1 { ob = argv[1] as *u8 } 127 let pr: i64 = sys_openat_rd(ob) 128 if pr >= 0 { sys_close(pr) } 129 else { 130 og_p(" instrument missing -> rebuilding via durable runner\n" as *u8) 131 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) 132 } 133 134 let pfx: *u8 = sys_mmap(128) 135 var po: i64 = 0 136 po = og_cat(pfx, po, "/tmp/vzdG" as *u8); po = og_catn(pfx, po, sys_now_us()); po = og_cat(pfx, po, "-" as *u8) 137 pfx[po] = 0 as u8 138 139 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) 140 og_write("/tmp/vzd_badstage.txt" as *u8, "DEAL x acme 100 t\nSTAGE 2026-06-01 x frobnicate\n" as *u8) 141 og_write("/tmp/vzd_badvalue.txt" as *u8, "DEAL y acme abc thing\n" as *u8) 142 143 var pass: i64 = 0 144 var r: i64 = 0 145 146 // row 1: load 147 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) 148 r = 0 149 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 } } 150 pass = pass + og_row("deal-load" as *u8, r) 151 152 // row 2: idempotent reload 153 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) 154 r = 0 155 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 } } 156 pass = pass + og_row("idempotent-reload" as *u8, r) 157 158 // rows 3-6: pipeline 159 og_runv(ob, og_args("pipeline" as *u8, pfx, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzd_pipe.txt" as *u8) 160 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) 161 pass = pass + og_row("latest-stage-wins" as *u8, r) 162 163 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) 164 pass = pass + og_row("weighted-open" as *u8, r) 165 166 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) 167 pass = pass + og_row("won-closed" as *u8, r) 168 169 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) 170 pass = pass + og_row("pipeline-verdict" as *u8, r) 171 172 // row 7: bad stage 173 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) 174 r = 0 175 if rc7 == 1 { r = 1 } 176 pass = pass + og_row("neg-bad-stage" as *u8, r) 177 178 // row 8: bad value 179 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) 180 r = 0 181 if rc8 == 1 { r = 1 } 182 pass = pass + og_row("neg-bad-value" as *u8, r) 183 184 let permil: i64 = (pass * 1000) / 8 185 let logfd: i64 = sys_openat_append("knowledge/status/vizsla_gate.log" as *u8, 0x1a4) 186 var fdi: i64 = 0 187 while fdi < 2 { 188 var fd: i64 = 1 189 if fdi == 1 { fd = logfd } 190 if fd > 0 { 191 let line: *u8 = sys_mmap(256) 192 var o: i64 = 0 193 o = og_cat(line, o, "VIZSLA-DEAL-GATE epoch=" as *u8) 194 o = og_catn(line, o, sys_now_realtime_sec()) 195 o = og_cat(line, o, " rows=8 pass=" as *u8) 196 o = og_catn(line, o, pass) 197 o = og_cat(line, o, " permil=" as *u8) 198 o = og_catn(line, o, permil) 199 if pass == 8 { o = og_cat(line, o, " verdict=GREEN\n" as *u8) } else { o = og_cat(line, o, " verdict=RED\n" as *u8) } 200 sys_write(fd, line, o) 201 } 202 fdi = fdi + 1 203 } 204 if logfd > 0 { sys_close(logfd) } 205 if pass == 8 { return 0 } 206 return 1 207}