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

↩ module page · 310 lines · 13084 B
1// nx_vizsla_notify_gate.nx -- VIZSLA OUTWARD-DELIVERY gate: reminders REACH you. COMPOSITION: the
2// calendar store is loaded through the blessed calendar organ; notify forks the blessed remind engine
3// for the due computation; the notification store is the once-only delivery ledger.
4//
5// fixture: calendar mtg 2026-07-08 10:00, gala 2026-08-20 18:00; contacts mom 07-14, dad 07-08.
6//   deliver today=2026-07-08 leads=6,0 -> mtg(event in0) + dad(bday in0) + mom(bday in6) = 3 delivered
7//   re-deliver same -> 0 delivered / 3 skipped (own store is the ledger)
8//   deliver today=2026-08-14 leads=6,0 -> gala(event in6, NEW occurrence) = 1 delivered
9//   feed -> 4 notifications; feed birthday -> 2 (mom, dad)
10//   email today=2026-07-08 -> RFC5322 digest, 3 reminders, Date: Wed, 08 Jul 2026 09:00:00 +0000
11//
12// Rows: 1 fixture-loads 2 deliver-onsite 3 feed-lists 4 deliver-idempotent 5 deliver-new-occurrence
13//       6 feed-after 7 feed-kind-filter 8 email-compose 9 email-date-header 10 email-body-bullet
14//       11 feed-determinism 12 loud-fail-bad-today[neg] 13 loud-fail-bad-leads[neg]
15// Evidence: VIZSLA-NOTIFY-GATE -> stdout + knowledge/status/vizsla_gate.log; exit 0 iff 13/13.
16// spec: knowledge/research/2026-06-22-vizsla-sclass-roadmap.md   license_tier: ORIGINAL
17import "nx_syscalls.nx"
18
19func ng_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
20func ng_p(s: *u8) -> i64 { sys_write(1, s, ng_slen(s)); return 0 }
21
22func ng_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
26}
27
28func ng_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
39}
40
41func ng_write(path: *u8, content: *u8) -> i64 {
  let fd: i64 = sys_openat_wr(path, 0x1a4)
  if fd < 0 { return 0 - 1 }
  sys_write(fd, content, ng_slen(content))
  sys_close(fd)
  return 0
47}
48
49func ng_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
64}
65
66func ng_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
94}
95
96func ng_has(path: *u8, needle: *u8) -> i64 {
  let szp: *i64 = sys_mmap(16) as *i64
  let b: *u8 = ng_readall(path, szp)
  let sz: i64 = szp[0]
  let n: i64 = ng_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
113}
114
115func ng_fileeq(p1: *u8, p2: *u8) -> i64 {
  let s1: *i64 = sys_mmap(16) as *i64
  let s2: *i64 = sys_mmap(16) as *i64
  let b1: *u8 = ng_readall(p1, s1)
  let b2: *u8 = ng_readall(p2, s2)
  if s1[0] != s2[0] { return 0 }
  if s1[0] <= 0 { return 0 }
  var i: i64 = 0
  while i < s1[0] {
      if b1[i] != b2[i] { return 0 }
      i = i + 1
  }
  return 1
128}
129
130func ng_row(name: *u8, pass: i64) -> i64 {
  ng_p("ROW " as *u8)
  ng_p(name)
  if pass == 1 { ng_p(" PASS\n" as *u8) } else { ng_p(" FAIL\n" as *u8) }
  return pass
135}
136
137func ng_args(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8, a6: *u8, a7: *u8, a8: *u8) -> *i64 {
  let a: *i64 = sys_mmap(128) 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
149}
150
151func ng_ensure(elf: *u8, organ: *u8) -> i64 {
  let pr: i64 = sys_openat_rd(elf)
  if pr >= 0 { sys_close(pr); return 0 }
  ng_p(" instrument missing -> rebuilding via durable runner\n" as *u8)
  ng_runv("_offc/nx_sov_build_run.elf" as *u8, ng_args(organ, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_rebuild.out" as *u8)
  return 0
157}
158
159func main(argc: i64, argv: *i64) -> i64 {
  ng_p("=== VIZSLA NOTIFY GATE: outward delivery (on-site once-only + RFC5322 email compose) ===\n" as *u8)
  let ntf: *u8 = "/tmp/nx_vizsla_notify.sov.elf" as *u8
  let cal: *u8 = "/tmp/nx_vizsla_calendar.sov.elf" as *u8
  ng_ensure(ntf, "nx_vizsla_notify" as *u8)
  ng_ensure(cal, "nx_vizsla_calendar" as *u8)
  // notify forks the BLESSED _offc/nx_vizsla_remind.elf -- ensure it exists
  let rp: i64 = sys_openat_rd("_offc/nx_vizsla_remind.elf" as *u8)
  if rp >= 0 { sys_close(rp) } else {
      ng_runv("_offc/nx_sov_build_run.elf" as *u8, ng_args("nx_vizsla_remind" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_rem.out" as *u8)
  }
170
  let us: i64 = sys_now_us()
  let cpfx: *u8 = sys_mmap(128)
  var po: i64 = 0
  po = ng_cat(cpfx, po, "/tmp/vznC" as *u8)
  po = ng_catn(cpfx, po, us)
  po = ng_cat(cpfx, po, "-" as *u8)
  cpfx[po] = 0 as u8
  let npfx: *u8 = sys_mmap(128)
  po = 0
  po = ng_cat(npfx, po, "/tmp/vznN" as *u8)
  po = ng_catn(npfx, po, us)
  po = ng_cat(npfx, po, "-" as *u8)
  npfx[po] = 0 as u8
184
  ng_write("/tmp/vzn_cal.txt" as *u8, "EVENT mtg 2026-07-08 600 60 standup-mtg\nEVENT gala 2026-08-20 1080 120 summer-gala\n" as *u8)
  ng_write("/tmp/vzn_ct.txt" as *u8, "TIER inner 7\nCONTACT mom Mom inner 07-14\nCONTACT dad Dad inner 07-08\n" as *u8)
187
  var pass: i64 = 0
  var r: i64 = 0
190
  // row 1: calendar loads
  let rc1: i64 = ng_runv(cal, ng_args("load" as *u8, "/tmp/vzn_cal.txt" as *u8, cpfx, "7501" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_l1.txt" as *u8)
  r = 0
  if rc1 == 0 { if ng_has("/tmp/vzn_l1.txt" as *u8, "VIZSLA-CAL-LOAD scanned=2 new=2" as *u8) == 1 { r = 1 } }
  pass = pass + ng_row("fixture-loads" as *u8, r)
196
  // row 2: deliver on-site
  let rc2: i64 = ng_runv(ntf, ng_args("deliver" as *u8, npfx, cpfx, "/tmp/vzn_ct.txt" as *u8, "2026-07-08" as *u8, "6,0" as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r2.txt" as *u8)
  r = 0
  if rc2 == 0 { if ng_has("/tmp/vzn_r2.txt" as *u8, "VIZSLA-NOTIFY-DELIVER channel=onsite today=2026-07-08 delivered=3 skipped=0" as *u8) == 1 { r = 1 } }
  pass = pass + ng_row("deliver-onsite" as *u8, r)
202
  // row 3: feed lists the delivered notices
  let rc3: i64 = ng_runv(ntf, ng_args("feed" as *u8, npfx, "-" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r3.txt" as *u8)
  r = 0
  if rc3 == 0 {
      if ng_has("/tmp/vzn_r3.txt" as *u8, "VIZSLA-NOTIFY channel=onsite kind=birthday id=mom date=2026-07-14 on=2026-07-08 title=Mom" as *u8) == 1 {
          if ng_has("/tmp/vzn_r3.txt" as *u8, "VIZSLA-NOTIFY-FEED kind=- notifications=3" as *u8) == 1 { r = 1 }
      }
  }
  pass = pass + ng_row("feed-lists" as *u8, r)
212
  // row 4: idempotent re-deliver
  let rc4: i64 = ng_runv(ntf, ng_args("deliver" as *u8, npfx, cpfx, "/tmp/vzn_ct.txt" as *u8, "2026-07-08" as *u8, "6,0" as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r4.txt" as *u8)
  r = 0
  if rc4 == 0 { if ng_has("/tmp/vzn_r4.txt" as *u8, "delivered=0 skipped=3 segment=none" as *u8) == 1 { r = 1 } }
  pass = pass + ng_row("deliver-idempotent" as *u8, r)
218
  // row 5: a genuinely new occurrence delivers
  let rc5: i64 = ng_runv(ntf, ng_args("deliver" as *u8, npfx, cpfx, "/tmp/vzn_ct.txt" as *u8, "2026-08-14" as *u8, "6,0" as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r5.txt" as *u8)
  r = 0
  if rc5 == 0 { if ng_has("/tmp/vzn_r5.txt" as *u8, "today=2026-08-14 delivered=1 skipped=0" as *u8) == 1 { r = 1 } }
  pass = pass + ng_row("deliver-new-occurrence" as *u8, r)
224
  // row 6: feed now shows 4
  let rc6: i64 = ng_runv(ntf, ng_args("feed" as *u8, npfx, "-" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r6.txt" as *u8)
  r = 0
  if rc6 == 0 { if ng_has("/tmp/vzn_r6.txt" as *u8, "VIZSLA-NOTIFY-FEED kind=- notifications=4" as *u8) == 1 { r = 1 } }
  pass = pass + ng_row("feed-after" as *u8, r)
230
  // row 7: kind filter
  let rc7: i64 = ng_runv(ntf, ng_args("feed" as *u8, npfx, "birthday" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r7.txt" as *u8)
  r = 0
  if rc7 == 0 {
      if ng_has("/tmp/vzn_r7.txt" as *u8, "VIZSLA-NOTIFY-FEED kind=birthday notifications=2" as *u8) == 1 {
          if ng_has("/tmp/vzn_r7.txt" as *u8, "kind=event" as *u8) == 0 { r = 1 }
      }
  }
  pass = pass + ng_row("feed-kind-filter" as *u8, r)
240
  // row 8: email compose
  let rc8: i64 = ng_runv(ntf, ng_args("email" as *u8, cpfx, "/tmp/vzn_ct.txt" as *u8, "2026-07-08" as *u8, "6,0" as *u8, "vizsla@jasonewest.com" as *u8, "you@example.com" as *u8, "/tmp/vzn_out.eml" as *u8), "/tmp/vzn_r8.txt" as *u8)
  r = 0
  if rc8 == 0 {
      if ng_has("/tmp/vzn_r8.txt" as *u8, "VIZSLA-NOTIFY-EMAIL today=2026-07-08 reminders=3" as *u8) == 1 {
          if ng_has("/tmp/vzn_out.eml" as *u8, "From: vizsla@jasonewest.com" as *u8) == 1 {
              if ng_has("/tmp/vzn_out.eml" as *u8, "To: you@example.com" as *u8) == 1 {
                  if ng_has("/tmp/vzn_out.eml" as *u8, "Subject: Your reminders for 2026-07-08" as *u8) == 1 { r = 1 }
              }
          }
      }
  }
  pass = pass + ng_row("email-compose" as *u8, r)
254
  // row 9: valid RFC5322 Date header (DOW math end-to-end: 2026-07-08 = Wednesday)
  r = ng_has("/tmp/vzn_out.eml" as *u8, "Date: Wed, 08 Jul 2026 09:00:00 +0000" as *u8)
  pass = pass + ng_row("email-date-header" as *u8, r)
258
  // row 10: the digest body carries the reminders
  r = 0
  if ng_has("/tmp/vzn_out.eml" as *u8, "Nishi Vizsla reminders:" as *u8) == 1 {
      if ng_has("/tmp/vzn_out.eml" as *u8, "* Mom (birthday) on 2026-07-14 -- in 6 days" as *u8) == 1 { r = 1 }
  }
  pass = pass + ng_row("email-body-bullet" as *u8, r)
265
  // row 11: feed determinism
  ng_runv(ntf, ng_args("feed" as *u8, npfx, "-" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r11.txt" as *u8)
  r = ng_fileeq("/tmp/vzn_r6.txt" as *u8, "/tmp/vzn_r11.txt" as *u8)
  pass = pass + ng_row("feed-determinism" as *u8, r)
270
  // row 12: bad today (negative control)
  let rc12: i64 = ng_runv(ntf, ng_args("deliver" as *u8, npfx, cpfx, "/tmp/vzn_ct.txt" as *u8, "2026-13-99" as *u8, "6,0" as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r12.txt" as *u8)
  r = 0
  if rc12 == 1 { r = 1 }
  pass = pass + ng_row("loud-fail-bad-today" as *u8, r)
276
  // row 13: bad leads propagate from remind (negative control)
  let rc13: i64 = ng_runv(ntf, ng_args("deliver" as *u8, npfx, cpfx, "/tmp/vzn_ct.txt" as *u8, "2026-07-08" as *u8, "x,1" as *u8, 0 as *u8, 0 as *u8), "/tmp/vzn_r13.txt" as *u8)
  r = 0
  if rc13 == 1 { r = 1 }
  pass = pass + ng_row("loud-fail-bad-leads" as *u8, r)
282
  let permil: i64 = (pass * 1000) / 13
  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 = ng_cat(line, o, "VIZSLA-NOTIFY-GATE epoch=" as *u8)
          o = ng_catn(line, o, sys_now_realtime_sec())
          o = ng_cat(line, o, " rows=13 pass=" as *u8)
          o = ng_catn(line, o, pass)
          o = ng_cat(line, o, " permil=" as *u8)
          o = ng_catn(line, o, permil)
          if pass == 13 {
              o = ng_cat(line, o, " verdict=GREEN\n" as *u8)
          } else {
              o = ng_cat(line, o, " verdict=RED\n" as *u8)
          }
          sys_write(fd, line, o)
      }
      fdi = fdi + 1
  }
  if logfd > 0 { sys_close(logfd) }
  if pass == 13 { return 0 }
  return 1
310}
nx_vizsla_notify_gate.nx source

`nx_vizsla_notify_gate.nx` source
