code wiki / _hdl_build / nx_vizsla_docgen_gate.nx
`nx_vizsla_docgen_gate.nx` source

↩ module page · 272 lines · 11905 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"
16
17func og_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
18func og_p(s: *u8) -> i64 { sys_write(1, s, og_slen(s)); return 0 }
19
20func og_cat(dst: *u8, off: i64, s: *u8) -> i64 {
  var i: i64 = 0
  while s[i] != (0 as u8) { dst[off + i] = s[i]; i = i + 1 }
  return off + i
24}
25
26func og_catn(dst: *u8, off: i64, v: i64) -> i64 {
  var o: i64 = off
  var m: i64 = v
  if m < 0 { dst[o] = 45 as u8; o = o + 1; m = 0 - m }
  let t: *u8 = sys_mmap(28)
  var k: i64 = 0
  if m == 0 { t[0] = 48 as u8; k = 1 }
  while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 }
  var i: i64 = 0
  while i < k { dst[o + i] = t[k - 1 - i]; i = i + 1 }
  return o + k
37}
38
39func og_write(path: *u8, content: *u8) -> i64 {
  let fd: i64 = sys_openat_wr(path, 0x1a4)
  if fd < 0 { return 0 - 1 }
  sys_write(fd, content, og_slen(content))
  sys_close(fd)
  return 0
45}
46
47func og_readall(path: *u8, szout: *i64) -> *u8 {
  let fd: i64 = sys_openat_rd(path)
  if fd < 0 { szout[0] = 0 - 1; return 0 as *u8 }
  let sz: i64 = sys_lseek(fd, 0, 2)
  sys_lseek(fd, 0, 0)
  let buf: *u8 = sys_mmap(sz + 64)
  var got: i64 = 0
  var n: i64 = 1
  while n > 0 {
      n = sys_read(fd, (buf as i64 + got) as *u8, 65536)
      if n > 0 { got = got + n }
  }
  sys_close(fd)
  szout[0] = got
  return buf
62}
63
64func og_runv(elf: *u8, args: *i64, outpath: *u8) -> i64 {
  let pid: i64 = sys_fork()
  if pid == 0 {
      if (outpath as i64) != 0 {
          let ofd: i64 = sys_openat_wr(outpath, 0x1a4)
          if ofd >= 0 { sys_dup3(ofd, 1, 0); sys_dup3(ofd, 2, 0) }
      }
      let argv: *i64 = sys_mmap(128) as *i64
      argv[0] = elf as i64
      var i: i64 = 0
      var go: i64 = 1
      while go == 1 {
          if args[i] == 0 { go = 0 } else {
              argv[i + 1] = args[i]
              i = i + 1
          }
      }
      argv[i + 1] = 0
      let envp: *i64 = sys_mmap(16) as *i64
      envp[0] = 0
      sys_execve(elf, argv, envp)
      sys_exit(127)
  }
  let st: *i64 = sys_mmap(16) as *i64
  sys_wait4(pid, st, 0)
  let sig: i64 = st[0] & 0x7f
  if sig != 0 { return 128 + sig }
  return (st[0] >> 8) & 0xff
92}
93
94func og_has(path: *u8, needle: *u8) -> i64 {
  let szp: *i64 = sys_mmap(16) as *i64
  let b: *u8 = og_readall(path, szp)
  let sz: i64 = szp[0]
  let n: i64 = og_slen(needle)
  if sz < n { return 0 }
  var i: i64 = 0
  while i + n <= sz {
      var ok: i64 = 1
      var j: i64 = 0
      while j < n {
          if b[i + j] != needle[j] { ok = 0; j = n } else { j = j + 1 }
      }
      if ok == 1 { return 1 }
      i = i + 1
  }
  return 0
111}
112
113func og_row(name: *u8, pass: i64) -> i64 {
  og_p("ROW " as *u8)
  og_p(name)
  if pass == 1 { og_p(" PASS\n" as *u8) } else { og_p(" FAIL\n" as *u8) }
  return pass
118}
119
120func og_args(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8, a6: *u8, a7: *u8) -> *i64 {
  let a: *i64 = sys_mmap(64) as *i64
  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] = a6 as i64
  a[6] = a7 as i64
  a[7] = 0
  return a
131}
132
133func og_ensure(elf: *u8, organ: *u8) -> i64 {
  let pr: i64 = sys_openat_rd(elf)
  if pr >= 0 { sys_close(pr); return 0 }
  og_p(" instrument missing -> rebuilding via durable runner\n" as *u8)
  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)
  return 0
139}
140
141func main(argc: i64, argv: *i64) -> i64 {
  og_p("=== VIZSLA DOCGEN GATE: coordination fields -> office .docx -> versioned doc store ===\n" as *u8)
  let dgn: *u8 = "/tmp/nx_vizsla_docgen.sov.elf" as *u8
  let doc: *u8 = "_offc/nx_vizsla_doc.elf" as *u8
  let docx: *u8 = "/tmp/nx_docx.sov.elf" as *u8
  og_ensure(dgn, "nx_vizsla_docgen" as *u8)
  // nx_vizsla_doc blessed in _offc; nx_docx build to /tmp if missing
  let pd: i64 = sys_openat_rd(doc)
  if pd >= 0 { sys_close(pd) } else {
      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)
  }
  og_ensure(docx, "nx_docx" as *u8)
153
  let pfx: *u8 = sys_mmap(128)
  var po: i64 = 0
  po = og_cat(pfx, po, "/tmp/dggD" as *u8)
  po = og_catn(pfx, po, sys_now_us())
  po = og_cat(pfx, po, "-" as *u8)
  pfx[po] = 0 as u8
160
  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)
162
  var pass: i64 = 0
  var r: i64 = 0
165
  // row 1: build the agreement doc
  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)
  r = 0
  if rc1 == 0 {
      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 {
          if og_has("/tmp/dgg_r1.txt" as *u8, "stored=1 segment=seg-" as *u8) == 1 { r = 1 }
      }
  }
  pass = pass + og_row("docgen-build" as *u8, r)
175
  // row 2: the REAL doc organ retrieves the stored .docx (cross-checks docgen's record framing)
  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)
  r = 0
  if rc2 == 0 {
      if og_has("/tmp/dgg_r2.txt" as *u8, "VIZSLA-DOC-GET docid=agreement-lakeday doctype=agreement" as *u8) == 1 { r = 1 }
  }
  pass = pass + og_row("doc-get-roundtrip" as *u8, r)
183
  // row 3: nx_docx parses the retrieved file -> it is a VALID Word doc, text present
  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)
  r = 0
  if rc3 == 0 {
      if og_has("/tmp/dgg_r3.txt" as *u8, "Venue Booking Agreement" as *u8) == 1 {
          if og_has("/tmp/dgg_r3.txt" as *u8, "Venue: Lakeside Pavilion" as *u8) == 1 {
              if og_has("/tmp/dgg_r3.txt" as *u8, "Cost: USD 350.00" as *u8) == 1 { r = 1 }
          }
      }
  }
  pass = pass + og_row("docx-valid" as *u8, r)
195
  // row 4: history = 1 version
  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)
  r = 0
  if rc4 == 0 {
      if og_has("/tmp/dgg_r4.txt" as *u8, "VIZSLA-DOC-HISTORY docid=agreement-lakeday versions=1" as *u8) == 1 { r = 1 }
  }
  pass = pass + og_row("history-1" as *u8, r)
203
  // row 5: identical re-build dedups (CID idempotent)
  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)
  r = 0
  if rc5 == 0 {
      if og_has("/tmp/dgg_r5.txt" as *u8, "stored=0 segment=none" as *u8) == 1 { r = 1 }
  }
  pass = pass + og_row("idempotent-rebuild" as *u8, r)
211
  // row 6: a revised agreement (changed terms + later date) = a NEW version (nothing destroyed)
  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)
  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)
  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)
  r = 0
  if rc6 == 0 {
      if og_has("/tmp/dgg_r6.txt" as *u8, "stored=1 segment=seg-" as *u8) == 1 {
          if og_has("/tmp/dgg_r6h.txt" as *u8, "VIZSLA-DOC-HISTORY docid=agreement-lakeday versions=2" as *u8) == 1 { r = 1 }
      }
  }
  pass = pass + og_row("new-version" as *u8, r)
223
  // row 7: get returns the LATEST (v2); nx_docx read shows the v2 terms
  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)
  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)
  r = 0
  if og_has("/tmp/dgg_r7t.txt" as *u8, "Terms: FULL PAYMENT received; agreement final." as *u8) == 1 {
      if og_has("/tmp/dgg_r7t.txt" as *u8, "50% deposit due on signing" as *u8) == 0 { r = 1 }
  }
  pass = pass + og_row("get-latest-v2" as *u8, r)
232
  // row 8: missing fields file (negative control)
  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)
  r = 0
  if rc8 == 1 { r = 1 }
  pass = pass + og_row("loud-fail-missing-file" as *u8, r)
238
  // row 9: bad date (negative control)
  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)
  r = 0
  if rc9 == 1 { r = 1 }
  pass = pass + og_row("loud-fail-bad-date" as *u8, r)
244
  let permil: i64 = (pass * 1000) / 9
  let logfd: i64 = sys_openat_append("knowledge/status/vizsla_gate.log" as *u8, 0x1a4)
  var fdi: i64 = 0
  while fdi < 2 {
      var fd: i64 = 1
      if fdi == 1 { fd = logfd }
      if fd > 0 {
          let line: *u8 = sys_mmap(256)
          var o: i64 = 0
          o = og_cat(line, o, "VIZSLA-DOCGEN-GATE epoch=" as *u8)
          o = og_catn(line, o, sys_now_realtime_sec())
          o = og_cat(line, o, " rows=9 pass=" as *u8)
          o = og_catn(line, o, pass)
          o = og_cat(line, o, " permil=" as *u8)
          o = og_catn(line, o, permil)
          if pass == 9 {
              o = og_cat(line, o, " verdict=GREEN\n" as *u8)
          } else {
              o = og_cat(line, o, " verdict=RED\n" as *u8)
          }
          sys_write(fd, line, o)
      }
      fdi = fdi + 1
  }
  if logfd > 0 { sys_close(logfd) }
  if pass == 9 { return 0 }
  return 1
272}
nx_vizsla_docgen_gate.nx source

`nx_vizsla_docgen_gate.nx` source
