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

↩ module page · 442 lines · 18286 B
1// nx_user_journey.nx -- TEAM-OWNED real-user journey gate over the LIVE
2// Nishi sites (operator: "make sure our teams play testing isnt just api but
3// actually mimics real users interacting with the real site... the core
4// nishi ecosystem").  This is NOT an API check: it does what a visitor does,
5// over the real network, on the team's OWN sovereign HTTPS client
6// (nx_https_get: DNS -> TCP -> TLS 1.3 -> GET, validated certs from the
7// bits-up trust store; NO curl, NO OpenSSL):
8//
9//   * load the homepage like a browser would,
10//   * READ it: assert the content a human would see is actually there,
11//   * CLICK what it shows: extract internal links from the live HTML and
12//     follow them, asserting each lands on a real page,
13//   * visit the published app contracts (e.g. /tictactoe must serve the
14//     9-cell board contract from the May C0 ship).
15//
16// First live run 2026-06-09 ALREADY caught a real user-facing regression:
17// nishifamily.com serves a 745B hub for EVERY path -- /tictactoe (smoke-green
18// in May, "every endpoint bits-up") returns the hub, not the game.  A user
19// today cannot play.  API-level gates never saw it; this gate exists so the
20// team always does.  Composes [[feedback-real-playtest-loop-not-just-logs]].
21//
22// TRANSPORT IS A TEMPORARY TRANSLATION LAYER (named honestly, Playwright
23// precedent): /usr/bin/curl as a forked child.  The sovereign client
24// (nx_https_get + trust store) was tried FIRST and is BLOCKED by two filed
25// defects on this host (2026-06-09): (1) sovereign DNS resolve fails here
26// (known_good build returns rr=-3, env: WSL resolv stub); (2) the CURRENT
27// compiler lineage SEGFAULTS on that error path where known_good returns the
28// error -- compiler divergence repro = _uj_probe.nx.  When both close, swap
29// uj_fetch's body back to nx_https_get with NO caller-side change
30// (Cardinal 19).  Journey logic, contracts, parsing: all bits-up NishiLang.
31//
32// JOURNEY lines -> stdout + /tmp/nishi_user_journey.log; exit = fails.
33// Honest scope: HTML-over-the-wire user mimicry.  Pixel/DOM-event mimicry in
34// a real browser engine still needs the SS22.5 sovereign browser-test-runner
35// (PM plan item; do NOT fake it with claims here).
36//
37// license_tier: ORIGINAL
38import "nx_syscalls.nx"
39const UJ_MAGIC_1200: i64 = 1200
40const UJ_MAGIC_2000: i64 = 2000
41const UJ_MAGIC_10000: i64 = 10000
42const UJ_MAGIC_50000: i64 = 50000
43const UJ_MAGIC_5000: i64 = 5000
44
45const UJ_BUF_CAP: i64 = 262144
46const UJ_PAUSE_MS: i64 = 400      // polite inter-request pacing, human-ish
47
48func uj_puts(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } sys_write(1, s, n); return 0 }
49func uj_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 }
50func uj_cat_n(dst: *u8, off: i64, v: i64) -> i64 {
  var o: i64 = off
  var m: i64 = v
  if m < 0 { dst[o] = 45; o = o + 1; m = 0 - m }
  let t: *u8 = sys_mmap(28)
  var k: i64 = 0
  if m == 0 { t[0] = 48; k = 1 }
  while m > 0 { t[k] = 48 + (m % 10); 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
61}
62
63// find needle in hay[0..n); returns first offset or -1
64func uj_find(hay: *u8, n: i64, needle: *u8) -> i64 {
  var nl: i64 = 0
  while needle[nl] != (0 as u8) { nl = nl + 1 }
  if nl == 0 { return 0 - 1 }
  var i: i64 = 0
  while i + nl <= n {
      var j: i64 = 0
      var hit: i64 = 1
      while j < nl {
          if hay[i+j] != needle[j] { hit = 0; j = nl }
          if j < nl { j = j + 1 }
      }
      if hit == 1 { return i }
      i = i + 1
  }
  return 0 - 1
80}
81
82// count occurrences of needle in hay[0..n)
83func uj_count(hay: *u8, n: i64, needle: *u8) -> i64 {
  var nl: i64 = 0
  while needle[nl] != (0 as u8) { nl = nl + 1 }
  if nl == 0 { return 0 }
  var c: i64 = 0
  var i: i64 = 0
  while i + nl <= n {
      var j: i64 = 0
      var hit: i64 = 1
      while j < nl {
          if hay[i+j] != needle[j] { hit = 0; j = nl }
          if j < nl { j = j + 1 }
      }
      if hit == 1 { c = c + 1; i = i + nl }
      if hit == 0 { i = i + 1 }
  }
  return c
100}
101
102// HTTP response: find body offset (after \r\n\r\n); -1 if not found
103func uj_body_off(resp: *u8, n: i64) -> i64 {
  var i: i64 = 0
  while i + 4 <= n {
      if resp[i] == 13 { if resp[i+1] == 10 { if resp[i+2] == 13 { if resp[i+3] == 10 { return i + 4 } } } }
      i = i + 1
  }
  return 0 - 1
110}
111
112// parse "HTTP/1.1 NNN" status from the head of the response; -1 unknown
113func uj_status(resp: *u8, n: i64) -> i64 {
  if n < 12 { return 0 - 1 }
  // first space then 3 digits
  var i: i64 = 0
  while i < 20 {
      if resp[i] == 32 {
          let d0: i64 = resp[i+1] as i64
          let d1: i64 = resp[i+2] as i64
          let d2: i64 = resp[i+3] as i64
          if d0 >= 48 { if d0 <= 57 { if d1 >= 48 { if d1 <= 57 { if d2 >= 48 { if d2 <= 57 {
              return (d0-48)*100 + (d1-48)*10 + (d2-48)
          } } } } } }
          return 0 - 1
      }
      i = i + 1
  }
  return 0 - 1
130}
131
132// fetch url like a real visitor.  TEMPORARY transport: forked curl child
133// (see module header for the two filed defects blocking the sovereign
134// client).  Writes body ptr/len + HTTP status through out-params; returns
135// total body bytes (<=0 fail).
136func uj_fetch_once(url: *u8, buf: *u8, body_ptr: *i64, body_len: *i64, status: *i64) -> i64 {
  body_ptr[0] = 0
  body_len[0] = 0
  status[0] = 0 - 1
  let body_file: *u8 = "/tmp/uj_body.bin" as *u8
  // truncate stale body first -- a failed fetch must NEVER inherit the
  // previous page's bytes (silent false-PASS class)
  let tfd: i64 = sys_openat_wr(body_file, 0x1a4)
  if tfd >= 0 { sys_close(tfd) }
  let code_fd: i64 = sys_openat_wr("/tmp/uj_code.txt" as *u8, 0x1a4)
  let pid: i64 = sys_fork()
  if pid == 0 {
      if code_fd >= 0 { sys_dup3(code_fd, 1, 0) }
      let argv: *i64 = sys_mmap(8*13) as *i64
      argv[0] = "/usr/bin/curl" as *u8 as i64
      argv[1] = "-s" as *u8 as i64
      argv[2] = "-L" as *u8 as i64          // browsers follow redirects; so does a user
      argv[3] = "-o" as *u8 as i64
      argv[4] = body_file as i64
      argv[5] = "-w" as *u8 as i64
      argv[6] = "%{http_code}" as *u8 as i64
      argv[7] = "-m" as *u8 as i64
      argv[8] = "15" as *u8 as i64
      argv[9] = "-A" as *u8 as i64
      argv[10] = "NishiUserJourney/1 (team gate; mimics a visitor)" as *u8 as i64
      argv[11] = url as i64
      argv[12] = 0
      let envp: *i64 = sys_mmap(16) as *i64
      envp[0] = "PATH=/usr/bin:/bin" as *u8 as i64; envp[1] = 0
      sys_execve("/usr/bin/curl" as *u8, argv, envp)
      sys_exit(127)
  }
  let st: *i64 = sys_mmap(16) as *i64
  sys_wait4(pid, st, 0)
  if code_fd >= 0 { sys_close(code_fd) }
  // status from curl's -w output
  let clen_p: *i64 = sys_mmap(8) as *i64
  let cbuf: *u8 = sys_read_file("/tmp/uj_code.txt" as *u8, clen_p)
  if (cbuf as i64) != 0 {
      if clen_p[0] >= 3 {
          let d0: i64 = cbuf[0] as i64
          let d1: i64 = cbuf[1] as i64
          let d2: i64 = cbuf[2] as i64
          if d0 >= 48 { if d0 <= 57 { status[0] = (d0-48)*100 + (d1-48)*10 + (d2-48) } }
      }
  }
  // body bytes
  let blen_p: *i64 = sys_mmap(8) as *i64
  let bbuf: *u8 = sys_read_file(body_file, blen_p)
  if (bbuf as i64) == 0 { return 0 - 1 }
  let n: i64 = blen_p[0]
  if n <= 0 { return 0 - 1 }
  body_ptr[0] = bbuf as i64
  body_len[0] = n
  sys_sleep_ms(UJ_PAUSE_MS)
  return n
192}
193
194// fetch with ONE retry on connection-level failure (no HTTP status at all)
195// -- a user hits refresh on a blip.  HTTP errors (404/500) never retry;
196// those are real verdicts.  Repeated status-0 = an availability finding.
197func uj_fetch(url: *u8, buf: *u8, body_ptr: *i64, body_len: *i64, status: *i64) -> i64 {
  var rr_final: i64 = uj_fetch_once(url, buf, body_ptr, body_len, status)
  if status[0] <= 0 {
      sys_sleep_ms(UJ_MAGIC_1200)
      rr_final = uj_fetch_once(url, buf, body_ptr, body_len, status)
  }
  return rr_final
204}
205
206// one JOURNEY report line
207func uj_report(logfd: i64, ts: i64, label: *u8, ok: i64, detail: *u8, num: i64) -> i64 {
  let line: *u8 = sys_mmap(512)
  var o: i64 = 0
  o = uj_cat(line, o, "JOURNEY ts=" as *u8)
  o = uj_cat_n(line, o, ts)
  o = uj_cat(line, o, " step=" as *u8)
  o = uj_cat(line, o, label)
  o = uj_cat(line, o, " verdict=" as *u8)
  if ok == 1 { o = uj_cat(line, o, "PASS" as *u8) }
  if ok != 1 { o = uj_cat(line, o, "FAIL" as *u8) }
  o = uj_cat(line, o, " " as *u8)
  o = uj_cat(line, o, detail)
  o = uj_cat_n(line, o, num)
  o = uj_cat(line, o, "\n" as *u8)
  sys_write(1, line, o)
  if logfd >= 0 { sys_write(logfd, line, o) }
  return 0
224}
225
226func uj_streq(a: *u8, b: *u8) -> i64 {
  var i: i64 = 0
  while a[i] != (0 as u8) {
      if a[i] != b[i] { return 0 }
      i = i + 1
  }
  if b[i] != (0 as u8) { return 0 }
  return 1
234}
235
236// follow up to `cap` distinct internal links found on page body (what a user
237// can click); each must come back 200 with a non-trivial body.  Returns fails.
238func uj_click_links(host: *u8, body: *u8, blen: i64, logfd: i64, ts: i64, cap: i64) -> i64 {
  var fails: i64 = 0
  var followed: i64 = 0
  var pos: i64 = 0
  // dedup: a user doesn't open the same link twice; remember followed urls
  let seen: *i64 = sys_mmap(8 * 8) as *i64
  var n_seen: i64 = 0
  while followed < cap {
      let rel: i64 = uj_find(((body as i64) + pos) as *u8, blen - pos, "href=\"/" as *u8)
      if rel < 0 { followed = cap }
      if rel >= 0 {
          let hstart: i64 = pos + rel + 6      // at the leading '/'
          // capture path until closing quote (cap 180)
          let path: *u8 = sys_mmap(200)
          var pi: i64 = 0
          while pi < 180 {
              let c: u8 = body[hstart + pi]
              if c == (34 as u8) { pi = 200 }   // closing quote
              if pi < 180 {
                  if pi != 200 { path[pi] = c; pi = pi + 1 }
              }
          }
          // pi landed at 200 via quote, recompute real len
          var plen: i64 = 0
          while plen < 180 {
              if path[plen] == (34 as u8) { plen = 180 }
              if plen < 180 {
                  if path[plen] == (0 as u8) { plen = 180 }
              }
              if plen < 180 { plen = plen + 1 }
          }
          // build absolute url
          let url: *u8 = sys_mmap(512)
          var o: i64 = 0
          o = uj_cat(url, o, "https://" as *u8)
          o = uj_cat(url, o, host)
          var ci: i64 = 0
          while ci < 180 {
              let c2: u8 = path[ci]
              if c2 == (0 as u8) { ci = 180 }
              if c2 == (34 as u8) { ci = 180 }
              if ci < 180 { url[o] = c2; o = o + 1; ci = ci + 1 }
          }
          url[o] = 0 as u8
          // skip if already clicked
          var dup: i64 = 0
          var si: i64 = 0
          while si < n_seen {
              if uj_streq(url, seen[si] as *u8) == 1 { dup = 1; si = n_seen }
              if si < n_seen { si = si + 1 }
          }
          if dup == 0 {
              if n_seen < 8 { seen[n_seen] = url as i64; n_seen = n_seen + 1 }
              let buf: *u8 = sys_mmap(UJ_BUF_CAP)
              let bp: *i64 = sys_mmap(8) as *i64
              let bl: *i64 = sys_mmap(8) as *i64
              let stx: *i64 = sys_mmap(8) as *i64
              let rr: i64 = uj_fetch(url, buf, bp, bl, stx)
              var ok: i64 = 0
              if rr > 0 { if stx[0] == 200 { if bl[0] > 100 { ok = 1 } } }
              uj_report(logfd, ts, url, ok, "click-follow status=" as *u8, stx[0])
              if ok == 0 { fails = fails + 1 }
              followed = followed + 1
          }
          pos = hstart
      }
  }
  return fails
306}
307
308func main() -> i64 {
  let logfd: i64 = sys_openat_append("/tmp/nishi_user_journey.log" as *u8, 0x1a4)
  let ts: i64 = sys_now_realtime_sec()
  var fails: i64 = 0
312
  // ---- visitor journey: andelinwest.com (the live legal site) ----
  let buf1: *u8 = sys_mmap(UJ_BUF_CAP)
  let bp: *i64 = sys_mmap(8) as *i64
  let bl: *i64 = sys_mmap(8) as *i64
  let stx: *i64 = sys_mmap(8) as *i64
  let rr1: i64 = uj_fetch("https://andelinwest.com/" as *u8, buf1, bp, bl, stx)
  var ok1: i64 = 0
  if rr1 > 0 { if stx[0] == 200 { if bl[0] > UJ_MAGIC_2000 { if uj_find(bp[0] as *u8, bl[0], "Law" as *u8) >= 0 { ok1 = 1 } } } }
  uj_report(logfd, ts, "andelinwest-home" as *u8, ok1, "status+content-Law len=" as *u8, bl[0])
  if ok1 == 0 { fails = fails + 1 }
  if ok1 == 1 {
      fails = fails + uj_click_links("andelinwest.com" as *u8, bp[0] as *u8, bl[0], logfd, ts, 3)
  }
326
  // ---- visitor journey: nishifamily.com hub ----
  let buf2: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr2: i64 = uj_fetch("https://nishifamily.com/" as *u8, buf2, bp, bl, stx)
  var ok2: i64 = 0
  if rr2 > 0 { if stx[0] == 200 { if bl[0] > 400 { if uj_find(bp[0] as *u8, bl[0], "Nishi" as *u8) >= 0 { ok2 = 1 } } } }
  uj_report(logfd, ts, "nishifamily-home" as *u8, ok2, "status+content-Nishi len=" as *u8, bl[0])
  if ok2 == 0 { fails = fails + 1 }
  if ok2 == 1 {
      fails = fails + uj_click_links("nishifamily.com" as *u8, bp[0] as *u8, bl[0], logfd, ts, 2)
  }
337
  // ---- published app contract: /tictactoe must serve the GAME ----
  // Current (mount-era) page contract: the ttt-root mount point must be in
  // the HTML a user receives, AND the wasm the page loads must be served
  // with valid WebAssembly magic (\0asm) at real size -- the user gets the
  // gated game bytes, not a fallback hub page.  (The old May contract was
  // 9 static data-cell-idx cells; the page design moved to nishi-host
  // mount 2026-05-20, cells are rendered by the bits-up runtime.)
  let buf3: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr3: i64 = uj_fetch("https://nishifamily.com/tictactoe/" as *u8, buf3, bp, bl, stx)
  var ok3: i64 = 0
  if rr3 > 0 { if stx[0] == 200 { if uj_find(bp[0] as *u8, bl[0], "ttt-root" as *u8) >= 0 { ok3 = 1 } } }
  uj_report(logfd, ts, "nishifamily-tictactoe-page" as *u8, ok3, "ttt-root-present len=" as *u8, bl[0])
  if ok3 == 0 { fails = fails + 1 }
351
  let buf4: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr4: i64 = uj_fetch("https://nishifamily.com/tictactoe/nx_tictactoe.wasm" as *u8, buf4, bp, bl, stx)
  var ok4: i64 = 0
  if rr4 > UJ_MAGIC_10000 {
      if stx[0] == 200 {
          let wb: *u8 = bp[0] as *u8
          if wb[0] == (0 as u8) {
              if wb[1] == (97 as u8) {       // 'a'
                  if wb[2] == (115 as u8) {  // 's'
                      if wb[3] == (109 as u8) { ok4 = 1 }   // 'm'
                  }
              }
          }
      }
  }
  uj_report(logfd, ts, "nishifamily-tictactoe-wasm" as *u8, ok4, "wasm-magic+size=" as *u8, bl[0])
  if ok4 == 0 { fails = fails + 1 }
369
  // ---- published app contract: /voxels must serve the SEEDABLE world ----
  // (operator 2026-06-10: seedable so people have unique experiences.)
  // Contract: page has the canvas mount + the world-seed share element +
  // calls init_seed; the runtime wasm serves with valid magic.
  let buf5: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr5: i64 = uj_fetch("https://nishifamily.com/voxels/" as *u8, buf5, bp, bl, stx)
  var ok5: i64 = 0
  if rr5 > 0 { if stx[0] == 200 {
      if uj_find(bp[0] as *u8, bl[0], "voxel-canvas" as *u8) >= 0 {
          if uj_find(bp[0] as *u8, bl[0], "world-seed" as *u8) >= 0 {
              if uj_find(bp[0] as *u8, bl[0], "init_seed" as *u8) >= 0 { ok5 = 1 }
          }
      }
  } }
  uj_report(logfd, ts, "nishifamily-voxels-seedable-page" as *u8, ok5, "canvas+seed-ui+init_seed len=" as *u8, bl[0])
  if ok5 == 0 { fails = fails + 1 }
386
  let buf6: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr6: i64 = uj_fetch("https://nishifamily.com/voxels/nx_voxel_runtime.wasm" as *u8, buf6, bp, bl, stx)
  var ok6: i64 = 0
  if rr6 > UJ_MAGIC_50000 {
      if stx[0] == 200 {
          let vb: *u8 = bp[0] as *u8
          if vb[0] == (0 as u8) {
              if vb[1] == (97 as u8) {
                  if vb[2] == (115 as u8) {
                      if vb[3] == (109 as u8) { ok6 = 1 }
                  }
              }
          }
      }
  }
  uj_report(logfd, ts, "nishifamily-voxels-wasm" as *u8, ok6, "wasm-magic+size=" as *u8, bl[0])
  if ok6 == 0 { fails = fails + 1 }
404
  // ---- published app contract: /vn must serve the visual novel ----
  // (VN0/VN1, beat-Ren'Py arc: engine+story in a ~15KB wasm.)
  let buf7: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr7: i64 = uj_fetch("https://nishifamily.com/vn/" as *u8, buf7, bp, bl, stx)
  var ok7: i64 = 0
  if rr7 > 0 { if stx[0] == 200 { if uj_find(bp[0] as *u8, bl[0], "vn-root" as *u8) >= 0 { ok7 = 1 } } }
  uj_report(logfd, ts, "nishifamily-vn-page" as *u8, ok7, "vn-root-present len=" as *u8, bl[0])
  if ok7 == 0 { fails = fails + 1 }
413
  let buf8: *u8 = sys_mmap(UJ_BUF_CAP)
  let rr8: i64 = uj_fetch("https://nishifamily.com/vn/nx_visual_novel.wasm" as *u8, buf8, bp, bl, stx)
  var ok8: i64 = 0
  if rr8 > UJ_MAGIC_5000 {
      if stx[0] == 200 {
          let nb: *u8 = bp[0] as *u8
          if nb[0] == (0 as u8) {
              if nb[1] == (97 as u8) {
                  if nb[2] == (115 as u8) {
                      if nb[3] == (109 as u8) { ok8 = 1 }
                  }
              }
          }
      }
  }
  uj_report(logfd, ts, "nishifamily-vn-wasm" as *u8, ok8, "wasm-magic+size=" as *u8, bl[0])
  if ok8 == 0 { fails = fails + 1 }
431
  let sline: *u8 = sys_mmap(256)
  var o: i64 = 0
  o = uj_cat(sline, o, "JOURNEY SUMMARY ts=" as *u8)
  o = uj_cat_n(sline, o, ts)
  o = uj_cat(sline, o, " fails=" as *u8)
  o = uj_cat_n(sline, o, fails)
  o = uj_cat(sline, o, "\n" as *u8)
  sys_write(1, sline, o)
  if logfd >= 0 { sys_write(logfd, sline, o); sys_close(logfd) }
  return fails
442}
nx_user_journey.nx source

`nx_user_journey.nx` source
