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

↩ module page · 247 lines · 11782 B
1// nx_vizsla_segment_gate.nx -- VIZSLA saved-segments gate. Construction-known oracle + contact->segment integration.
2// Ingest 8 fields via BLESSED nx_vizsla_contact (date 2026-01-01):
3//   mom  city=Dallas tier=family    alex city=Dallas tier=colleague
4//   pat  city=Austin tier=colleague sam  city=Dallas tier=colleague
5// Segments:
6//   dallas        = city=Dallas                 -> mom,alex,sam (3) ; pat excluded
7//   dal-colleagues= city=Dallas AND tier=colleague -> alex,sam (2) ; mom excluded (family) = AND proof
8//   redefine dallas @2026-02-01 = city=Austin   -> pat (1) ; latest-def-per-name wins
9// Rows:
10//   1 ingest-fields    contact load new=8 seg-3101 (integration precondition)
11//   2 define           define dallas city=Dallas -> new=1
12//   3 apply-single     apply dallas -> mom+alex+sam present, pat ABSENT, matched=3
13//   4 apply-AND        dal-colleagues -> alex+sam present, mom ABSENT (AND excludes family), matched=2
14//   5 list             both names present, segments=2
15//   6 latest-def-wins  redefine dallas->Austin, apply -> pat present, mom ABSENT, matched=1
16//   7 idempotent       re-define dallas city=Dallas (same) -> new=0 (CID dedup)
17//   8 neg-unknown      apply ghost (never defined) -> fail loud exit 1
18//   9 neg-bad-pairs    define with odd criteria (3 tokens) -> fail loud exit 1
19// Evidence: VIZSLA-SEGMENT-GATE -> stdout + knowledge/status/vizsla_gate.log; exit 0 iff 9/9.
20// license_tier: ORIGINAL
21import "nx_syscalls.nx"
22
23func og_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
24func og_p(s: *u8) -> i64 { sys_write(1, s, og_slen(s)); return 0 }
25
26func 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
30}
31
32func 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
43}
44
45func 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
51}
52
53func 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
65}
66
67func 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
90}
91
92func og_idx(buf: *u8, sz: i64, needle: *u8) -> i64 {
  let n: i64 = og_slen(needle)
  if n == 0 { return 0 - 1 }
  var i: i64 = 0
  while i + n <= sz {
      var ok: i64 = 1
      var j: i64 = 0
      while j < n { if buf[i + j] != needle[j] { ok = 0; j = n } else { j = j + 1 } }
      if ok == 1 { return i }
      i = i + 1
  }
  return 0 - 1
104}
105
106func og_has(path: *u8, needle: *u8) -> i64 {
  let szp: *i64 = sys_mmap(16) as *i64
  let b: *u8 = og_readall(path, szp)
  if og_idx(b, szp[0], needle) >= 0 { return 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
117}
118
119func 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
123}
124
125func og_args8(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8, a6: *u8, a7: *u8, a8: *u8) -> *i64 {
  let a: *i64 = sys_mmap(80) 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] = a8 as i64; a[8] = 0
  return a
129}
130
131func main(argc: i64, argv: *i64) -> i64 {
  og_p("=== VIZSLA SEGMENT GATE: saved smart views + AND + latest-def + contact->segment ===\n" as *u8)
  var ob: *u8 = "/tmp/nx_vizsla_segment.sov.elf" as *u8
  if argc > 1 { ob = argv[1] as *u8 }
  let pr: i64 = sys_openat_rd(ob)
  if pr >= 0 { sys_close(pr) }
  else {
      og_p(" instrument missing -> rebuilding via durable runner\n" as *u8)
      og_runv("_offc/nx_sov_build_run.elf" as *u8, og_args("nx_vizsla_segment" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_rebuild.out" as *u8)
  }
141
  let pfx: *u8 = sys_mmap(128)
  var po: i64 = 0
  po = og_cat(pfx, po, "/tmp/vsgG" as *u8); po = og_catn(pfx, po, sys_now_us()); po = og_cat(pfx, po, "-" as *u8)
  pfx[po] = 0 as u8
146
  og_write("/tmp/vsg_fld.txt" as *u8, "FIELD 2026-01-01 mom city Dallas\nFIELD 2026-01-01 mom tier family\nFIELD 2026-01-01 alex city Dallas\nFIELD 2026-01-01 alex tier colleague\nFIELD 2026-01-01 pat city Austin\nFIELD 2026-01-01 pat tier colleague\nFIELD 2026-01-01 sam city Dallas\nFIELD 2026-01-01 sam tier colleague\n" as *u8)
148
  var pass: i64 = 0
  var r: i64 = 0
151
  // 1 ingest fields via blessed contact organ
  let rc1: i64 = og_runv("_offc/nx_vizsla_contact.elf" as *u8, og_args("load" as *u8, "/tmp/vsg_fld.txt" as *u8, pfx, "3101" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_ing.txt" as *u8)
  r = 0
  if rc1 == 0 { if og_has("/tmp/vsg_ing.txt" as *u8, "VIZSLA-CONTACT-LOAD scanned=8 new=8 dup_infile=0 dup_instore=0 segment=seg-3101" as *u8) == 1 { r = 1 } }
  pass = pass + og_row("ingest-fields" as *u8, r)
157
  // 2 define dallas
  let rc2: i64 = og_runv(ob, og_args("define" as *u8, pfx, "dallas" as *u8, "2026-01-01" as *u8, "city" as *u8, "Dallas" as *u8, 0 as *u8), "/tmp/vsg_d1.txt" as *u8)
  r = 0
  if rc2 == 0 { if og_has("/tmp/vsg_d1.txt" as *u8, "VIZSLA-SEGMENT-DEFINE name=dallas criteria=city=Dallas new=1" as *u8) == 1 { r = 1 } }
  pass = pass + og_row("define" as *u8, r)
163
  // 3 apply dallas -> 3, pat absent
  og_runv(ob, og_args("apply" as *u8, pfx, "dallas" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_a1.txt" as *u8)
  r = 0
  if og_has("/tmp/vsg_a1.txt" as *u8, "VIZSLA-SEGMENT-MATCH name=dallas contact=mom" as *u8) == 1 {
      if og_has("/tmp/vsg_a1.txt" as *u8, "VIZSLA-SEGMENT-MATCH name=dallas contact=alex" as *u8) == 1 {
          if og_has("/tmp/vsg_a1.txt" as *u8, "VIZSLA-SEGMENT-MATCH name=dallas contact=sam" as *u8) == 1 {
              if og_has("/tmp/vsg_a1.txt" as *u8, "contact=pat" as *u8) == 0 { if og_has("/tmp/vsg_a1.txt" as *u8, "matched=3" as *u8) == 1 { r = 1 } }
          }
      }
  }
  pass = pass + og_row("apply-single" as *u8, r)
175
  // 4 dal-colleagues AND (city=Dallas AND tier=colleague): alex+sam, mom absent, matched=2
  og_runv(ob, og_args8("define" as *u8, pfx, "dal-colleagues" as *u8, "2026-01-02" as *u8, "city" as *u8, "Dallas" as *u8, "tier" as *u8, "colleague" as *u8), "/tmp/vsg_d2b.txt" as *u8)
  og_runv(ob, og_args("apply" as *u8, pfx, "dal-colleagues" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_a2.txt" as *u8)
  r = 0
  if og_has("/tmp/vsg_a2.txt" as *u8, "VIZSLA-SEGMENT-MATCH name=dal-colleagues contact=alex" as *u8) == 1 {
      if og_has("/tmp/vsg_a2.txt" as *u8, "VIZSLA-SEGMENT-MATCH name=dal-colleagues contact=sam" as *u8) == 1 {
          if og_has("/tmp/vsg_a2.txt" as *u8, "contact=mom" as *u8) == 0 { if og_has("/tmp/vsg_a2.txt" as *u8, "matched=2" as *u8) == 1 { r = 1 } }
      }
  }
  pass = pass + og_row("apply-AND" as *u8, r)
186
  // 5 list
  og_runv(ob, og_args("list" as *u8, pfx, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_l.txt" as *u8)
  r = 0
  if og_has("/tmp/vsg_l.txt" as *u8, "VIZSLA-SEGMENT name=dallas " as *u8) == 1 {
      if og_has("/tmp/vsg_l.txt" as *u8, "VIZSLA-SEGMENT name=dal-colleagues " as *u8) == 1 {
          if og_has("/tmp/vsg_l.txt" as *u8, "VIZSLA-SEGMENT-LIST segments=2" as *u8) == 1 { r = 1 }
      }
  }
  pass = pass + og_row("list" as *u8, r)
196
  // 6 latest-def-wins: redefine dallas -> Austin (later date), apply -> pat, mom absent, matched=1
  og_runv(ob, og_args("define" as *u8, pfx, "dallas" as *u8, "2026-02-01" as *u8, "city" as *u8, "Austin" as *u8, 0 as *u8), "/tmp/vsg_d3.txt" as *u8)
  og_runv(ob, og_args("apply" as *u8, pfx, "dallas" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_a3.txt" as *u8)
  r = 0
  if og_has("/tmp/vsg_a3.txt" as *u8, "VIZSLA-SEGMENT-MATCH name=dallas contact=pat" as *u8) == 1 {
      if og_has("/tmp/vsg_a3.txt" as *u8, "contact=mom" as *u8) == 0 { if og_has("/tmp/vsg_a3.txt" as *u8, "matched=1" as *u8) == 1 { r = 1 } }
  }
  pass = pass + og_row("latest-def-wins" as *u8, r)
205
  // 7 idempotent: redefine dallas city=Dallas @2026-01-01 (the original) -> new=0
  let rc7: i64 = og_runv(ob, og_args("define" as *u8, pfx, "dallas" as *u8, "2026-01-01" as *u8, "city" as *u8, "Dallas" as *u8, 0 as *u8), "/tmp/vsg_d4.txt" as *u8)
  r = 0
  if rc7 == 0 { if og_has("/tmp/vsg_d4.txt" as *u8, "VIZSLA-SEGMENT-DEFINE name=dallas criteria=city=Dallas new=0" as *u8) == 1 { r = 1 } }
  pass = pass + og_row("idempotent" as *u8, r)
211
  // 8 neg-unknown: apply a segment never defined -> fail loud
  let rc8: i64 = og_runv(ob, og_args("apply" as *u8, pfx, "ghost" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vsg_g.txt" as *u8)
  r = 0
  if rc8 == 1 { r = 1 }
  pass = pass + og_row("neg-unknown" as *u8, r)
217
  // 9 neg-bad-pairs: define with 3 criteria tokens (odd) -> fail loud
  let rc9: i64 = og_runv(ob, og_args("define" as *u8, pfx, "badseg" as *u8, "2026-01-01" as *u8, "city" as *u8, "Dallas" as *u8, "tier" as *u8), "/tmp/vsg_b.txt" as *u8)
  r = 0
  if rc9 == 1 { r = 1 }
  pass = pass + og_row("neg-bad-pairs" as *u8, r)
223
  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-SEGMENT-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
247}
nx_vizsla_segment_gate.nx source

`nx_vizsla_segment_gate.nx` source
