code wiki / _hdl_build / nx_vizsla_docgen_gate.nx

nx_vizsla_docgen_gate.nx source

↩ module page · 281 lines · 12594 B

1// nx_vizsla_docgen_gate.nx -- VIZSLA OFFICE-DOC gate: coordination fields -> a real .docx -> the versioned 2// doc store, proven end-to-end by reading the record back with the INDEPENDENT nx_vizsla_doc organ (cross-checks 3// docgen's doc: framing matches) AND parsing it with nx_docx (proves it is a valid Word document). 4// 5// fields (a venue booking agreement -- the kind of fields a venue board supplies): 6// "Venue Booking Agreement" / Event / Venue: Lakeside Pavilion / Date / Time / Capacity / Cost: USD 350.00 / ... 7// 8// Rows: 1 docgen-build (stored, paras=9) 2 doc-get-roundtrip (real doc organ retrieves the .docx) 9// 3 docx-valid (nx_docx parses it -> title + venue + cost text present) 4 history-1 10// 5 idempotent-rebuild (CID dedup -> stored=0) 6 new-version (changed terms+later date -> versions=2) 11// 7 get-latest-v2 (get returns v2, docx read shows v2 terms) 8 loud-fail-missing-file[neg] 12// 9 loud-fail-bad-date[neg] 13// Evidence: VIZSLA-DOCGEN-GATE -> stdout + knowledge/status/vizsla_gate.log; exit 0 iff 9/9. 14// spec: knowledge/research/2026-06-22-vizsla-sclass-roadmap.md license_tier: ORIGINAL 15import "nx_syscalls.nx" 16import "nx_gate_verdict.nx" 17 18func og_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n } 19func og_p(s: *u8) -> i64 { sys_write(1, s, og_slen(s)); return 0 } 20 21func og_cat(dst: *u8, off: i64, s: *u8) -> i64 { 22 var i: i64 = 0 23 while s[i] != (0 as u8) { dst[off + i] = s[i]; i = i + 1 } 24 return off + i 25} 26 27func og_catn(dst: *u8, off: i64, v: i64) -> i64 { 28 var o: i64 = off 29 var m: i64 = v 30 if m < 0 { dst[o] = 45 as u8; o = o + 1; m = 0 - m } 31 let t: *u8 = sys_mmap(28) 32 var k: i64 = 0 33 if m == 0 { t[0] = 48 as u8; k = 1 } 34 while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 } 35 var i: i64 = 0 36 while i < k { dst[o + i] = t[k - 1 - i]; i = i + 1 } 37 return o + k 38} 39 40func og_write(path: *u8, content: *u8) -> i64 { 41 let fd: i64 = sys_openat_wr(path, 0x1a4) 42 if fd < 0 { return 0 - 1 } 43 sys_write(fd, content, og_slen(content)) 44 sys_close(fd) 45 return 0 46} 47 48func og_readall(path: *u8, szout: *i64) -> *u8 { 49 let fd: i64 = sys_openat_rd(path) 50 if fd < 0 { szout[0] = 0 - 1; return 0 as *u8 } 51 let sz: i64 = sys_lseek(fd, 0, 2) 52 sys_lseek(fd, 0, 0) 53 let buf: *u8 = sys_mmap(sz + 64) 54 var got: i64 = 0 55 var n: i64 = 1 56 while n > 0 { 57 n = sys_read(fd, (buf as i64 + got) as *u8, 65536) 58 if n > 0 { got = got + n } 59 } 60 sys_close(fd) 61 szout[0] = got 62 return buf 63} 64 65func og_runv(elf: *u8, args: *i64, outpath: *u8) -> i64 { 66 let pid: i64 = sys_fork() 67 if pid == 0 { 68 if (outpath as i64) != 0 { 69 let ofd: i64 = sys_openat_wr(outpath, 0x1a4) 70 if ofd >= 0 { sys_dup3(ofd, 1, 0); sys_dup3(ofd, 2, 0) } 71 } 72 let argv: *i64 = sys_mmap(128) as *i64 73 argv[0] = elf as i64 74 var i: i64 = 0 75 var go: i64 = 1 76 while go == 1 { 77 if args[i] == 0 { go = 0 } else { 78 argv[i + 1] = args[i] 79 i = i + 1 80 } 81 } 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 { 106 if b[i + j] != needle[j] { ok = 0; j = n } else { j = j + 1 } 107 } 108 if ok == 1 { return 1 } 109 i = i + 1 110 } 111 return 0 112} 113 114func og_row(name: *u8, pass: i64) -> i64 { 115 og_p("ROW " as *u8) 116 og_p(name) 117 if pass == 1 { og_p(" PASS\n" as *u8) } else { og_p(" FAIL\n" as *u8) } 118 return pass 119} 120 121func og_args(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8, a6: *u8, a7: *u8) -> *i64 { 122 let a: *i64 = sys_mmap(64) as *i64 123 a[0] = a1 as i64 124 a[1] = a2 as i64 125 a[2] = a3 as i64 126 a[3] = a4 as i64 127 a[4] = a5 as i64 128 a[5] = a6 as i64 129 a[6] = a7 as i64 130 a[7] = 0 131 return a 132} 133 134func og_ensure(elf: *u8, organ: *u8) -> i64 { 135 let pr: i64 = sys_openat_rd(elf) 136 if pr >= 0 { sys_close(pr); return 0 } 137 og_p(" instrument missing -> rebuilding via durable runner\n" as *u8) 138 og_runv("_offc/nx_sov_build_run.elf" as *u8, og_args(organ, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_rebuild.out" as *u8) 139 return 0 140} 141 142func main(argc: i64, argv: *i64) -> i64 { 143 og_p("=== VIZSLA DOCGEN GATE: coordination fields -> office .docx -> versioned doc store ===\n" as *u8) 144 let dgn: *u8 = "buildroot/_build/nx_vizsla_docgen.sov.elf" as *u8 145 let doc: *u8 = "_offc/nx_vizsla_doc.elf" as *u8 146 let docx: *u8 = "buildroot/_build/nx_docx.sov.elf" as *u8 147 og_ensure(dgn, "nx_vizsla_docgen" as *u8) 148 // nx_vizsla_doc blessed in _offc; nx_docx built into buildroot/_build/ if missing (NOT /tmp -- the 149 // durable runner anchors its CWD to buildroot/ and has written _build/ since 2026-07-30) 150 let pd: i64 = sys_openat_rd(doc) 151 if pd >= 0 { sys_close(pd) } else { 152 og_runv("_offc/nx_sov_build_run.elf" as *u8, og_args("nx_vizsla_doc" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_doc.out" as *u8) 153 } 154 og_ensure(docx, "nx_docx" as *u8) 155 156 let pfx: *u8 = sys_mmap(128) 157 var po: i64 = 0 158 po = og_cat(pfx, po, "/tmp/dggD" as *u8) 159 po = og_catn(pfx, po, sys_now_us()) 160 po = og_cat(pfx, po, "-" as *u8) 161 pfx[po] = 0 as u8 162 163 og_write("/tmp/dgg_fields.txt" as *u8, "Venue Booking Agreement\nEvent: lakeday\nVenue: Lakeside Pavilion\nDate: 2026-08-15\nTime: 18:00-21:00\nCapacity: 40 guests\nCost: USD 350.00\nContact: 555-0100\nTerms: 50% deposit due on signing; balance due on the event day.\n" as *u8) 164 165 var pass: i64 = 0 166 var r: i64 = 0 167 168 // row 1: build the agreement doc 169 let rc1: i64 = og_runv(dgn, og_args("build" as *u8, pfx, "agreement-lakeday" as *u8, "agreement" as *u8, "venue:lakeday" as *u8, "2026-07-08" as *u8, "/tmp/dgg_fields.txt" as *u8), "/tmp/dgg_r1.txt" as *u8) 170 r = 0 171 if rc1 == 0 { 172 if og_has("/tmp/dgg_r1.txt" as *u8, "VIZSLA-DOCGEN docid=agreement-lakeday doctype=agreement rel=venue:lakeday date=2026-07-08 paras=9 docx_bytes=" as *u8) == 1 { 173 if og_has("/tmp/dgg_r1.txt" as *u8, "stored=1 segment=seg-" as *u8) == 1 { r = 1 } 174 } 175 } 176 pass = pass + og_row("docgen-build" as *u8, r) 177 178 // row 2: the REAL doc organ retrieves the stored .docx (cross-checks docgen's record framing) 179 let rc2: i64 = og_runv(doc, og_args("get" as *u8, pfx, "agreement-lakeday" as *u8, "/tmp/dgg_out.docx" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_r2.txt" as *u8) 180 r = 0 181 if rc2 == 0 { 182 if og_has("/tmp/dgg_r2.txt" as *u8, "VIZSLA-DOC-GET docid=agreement-lakeday doctype=agreement" as *u8) == 1 { r = 1 } 183 } 184 pass = pass + og_row("doc-get-roundtrip" as *u8, r) 185 186 // row 3: nx_docx parses the retrieved file -> it is a VALID Word doc, text present 187 let rc3: i64 = og_runv(docx, og_args("read" as *u8, "/tmp/dgg_out.docx" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_r3.txt" as *u8) 188 r = 0 189 if rc3 == 0 { 190 if og_has("/tmp/dgg_r3.txt" as *u8, "Venue Booking Agreement" as *u8) == 1 { 191 if og_has("/tmp/dgg_r3.txt" as *u8, "Venue: Lakeside Pavilion" as *u8) == 1 { 192 if og_has("/tmp/dgg_r3.txt" as *u8, "Cost: USD 350.00" as *u8) == 1 { r = 1 } 193 } 194 } 195 } 196 pass = pass + og_row("docx-valid" as *u8, r) 197 198 // row 4: history = 1 version 199 let rc4: i64 = og_runv(doc, og_args("history" as *u8, pfx, "agreement-lakeday" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_r4.txt" as *u8) 200 r = 0 201 if rc4 == 0 { 202 if og_has("/tmp/dgg_r4.txt" as *u8, "VIZSLA-DOC-HISTORY docid=agreement-lakeday versions=1" as *u8) == 1 { r = 1 } 203 } 204 pass = pass + og_row("history-1" as *u8, r) 205 206 // row 5: identical re-build dedups (CID idempotent) 207 let rc5: i64 = og_runv(dgn, og_args("build" as *u8, pfx, "agreement-lakeday" as *u8, "agreement" as *u8, "venue:lakeday" as *u8, "2026-07-08" as *u8, "/tmp/dgg_fields.txt" as *u8), "/tmp/dgg_r5.txt" as *u8) 208 r = 0 209 if rc5 == 0 { 210 if og_has("/tmp/dgg_r5.txt" as *u8, "stored=0 segment=none" as *u8) == 1 { r = 1 } 211 } 212 pass = pass + og_row("idempotent-rebuild" as *u8, r) 213 214 // row 6: a revised agreement (changed terms + later date) = a NEW version (nothing destroyed) 215 og_write("/tmp/dgg_fields2.txt" as *u8, "Venue Booking Agreement\nEvent: lakeday\nVenue: Lakeside Pavilion\nDate: 2026-08-15\nTime: 18:00-21:00\nCapacity: 40 guests\nCost: USD 350.00\nContact: 555-0100\nTerms: FULL PAYMENT received; agreement final.\n" as *u8) 216 let rc6: i64 = og_runv(dgn, og_args("build" as *u8, pfx, "agreement-lakeday" as *u8, "agreement" as *u8, "venue:lakeday" as *u8, "2026-07-09" as *u8, "/tmp/dgg_fields2.txt" as *u8), "/tmp/dgg_r6.txt" as *u8) 217 og_runv(doc, og_args("history" as *u8, pfx, "agreement-lakeday" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_r6h.txt" as *u8) 218 r = 0 219 if rc6 == 0 { 220 if og_has("/tmp/dgg_r6.txt" as *u8, "stored=1 segment=seg-" as *u8) == 1 { 221 if og_has("/tmp/dgg_r6h.txt" as *u8, "VIZSLA-DOC-HISTORY docid=agreement-lakeday versions=2" as *u8) == 1 { r = 1 } 222 } 223 } 224 pass = pass + og_row("new-version" as *u8, r) 225 226 // row 7: get returns the LATEST (v2); nx_docx read shows the v2 terms 227 og_runv(doc, og_args("get" as *u8, pfx, "agreement-lakeday" as *u8, "/tmp/dgg_out2.docx" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_r7.txt" as *u8) 228 og_runv(docx, og_args("read" as *u8, "/tmp/dgg_out2.docx" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/dgg_r7t.txt" as *u8) 229 r = 0 230 if og_has("/tmp/dgg_r7t.txt" as *u8, "Terms: FULL PAYMENT received; agreement final." as *u8) == 1 { 231 if og_has("/tmp/dgg_r7t.txt" as *u8, "50% deposit due on signing" as *u8) == 0 { r = 1 } 232 } 233 pass = pass + og_row("get-latest-v2" as *u8, r) 234 235 // row 8: missing fields file (negative control) 236 let rc8: i64 = og_runv(dgn, og_args("build" as *u8, pfx, "ghost" as *u8, "agreement" as *u8, "-" as *u8, "2026-07-08" as *u8, "/tmp/dgg_nope.txt" as *u8), "/tmp/dgg_r8.txt" as *u8) 237 r = 0 238 if rc8 == 1 { r = 1 } 239 pass = pass + og_row("loud-fail-missing-file" as *u8, r) 240 241 // row 9: bad date (negative control) 242 let rc9: i64 = og_runv(dgn, og_args("build" as *u8, pfx, "agreement-lakeday" as *u8, "agreement" as *u8, "venue:lakeday" as *u8, "2026-13-99" as *u8, "/tmp/dgg_fields.txt" as *u8), "/tmp/dgg_r9.txt" as *u8) 243 r = 0 244 if rc9 == 1 { r = 1 } 245 pass = pass + og_row("loud-fail-bad-date" as *u8, r) 246 247 let permil: i64 = (pass * 1000) / 9 248 let logfd: i64 = sys_openat_append("knowledge/status/vizsla_gate.log" as *u8, 0x1a4) 249 var fdi: i64 = 0 250 while fdi < 2 { 251 var fd: i64 = 1 252 if fdi == 1 { fd = logfd } 253 if fd > 0 { 254 let line: *u8 = sys_mmap(256) 255 var o: i64 = 0 256 o = og_cat(line, o, "VIZSLA-DOCGEN-GATE epoch=" as *u8) 257 o = og_catn(line, o, sys_now_realtime_sec()) 258 o = og_cat(line, o, " rows=9 pass=" as *u8) 259 o = og_catn(line, o, pass) 260 o = og_cat(line, o, " permil=" as *u8) 261 o = og_catn(line, o, permil) 262 if pass == 9 { 263 o = og_cat(line, o, " verdict=GREEN\n" as *u8) 264 } else { 265 o = og_cat(line, o, " verdict=RED\n" as *u8) 266 } 267 sys_write(fd, line, o) 268 } 269 fdi = fdi + 1 270 } 271 if logfd > 0 { sys_close(logfd) } 272 // MIGRATED onto nx_gate_verdict by nx_gate_dry_apply (D001, minimal form): every check 273 // row above is untouched, so the PASS/FAIL vector cannot change; only the hand-rolled 274 // verdict emission is replaced by the ONE shared base class. Proven by nx_gate_migrate verify. 275 let ctr__dry: *i64 = gv_ctr() 276 ctr__dry[0] = pass 277 ctr__dry[1] = 9 278 let rc__dry: i64 = gv_verdict("VIZSLA-DOCGEN-GATE" as *u8, ctr__dry, "teeth unchanged; verdict emission migrated onto the shared base class" as *u8) 279 sys_exit(rc__dry) 280 return rc__dry 281}