`nx_minerhub.nx` source

↩ module page · 508 lines · 24396 B
1// nx_minerhub.nx -- MINER SYNTHESIS HUB (miner-sota, 2026-07-23). The measurement layer's FRONT DOOR.
2// The 8 miners each emit JSON; nobody COMPOSED them. This forks each declared miner (allowlist-resolved
3// via the SHARED sj_allow_path), extracts its ONE headline metric, classifies it against DATA-DRIVEN
4// thresholds (GOOD/WATCH/BAD), and emits a single ecosystem-health index + a page. OO by construction:
5// it READS the miners, duplicates none of them; a new miner = ONE conf row, zero code. now-free/pure at
6// the parser (gate); the fork-compose path runs live. Composes nx_sovjson_lib. Read-only. Rule 26.
7//   mine <sourceconf>            -> JSON: per-source value+status + health_index_permil
8//   page <sourceconf> <outfile>  -> HTML board
9//   selftest <scratch-prefix>    -> gate T1..T9 (metric extract + classify + index math, deterministic)
10// conf cols: id TAB dir(hi|lo) TAB good TAB warn TAB metric TAB miner TAB arg1 TAB arg2 ...
11//   dir hi = higher is better (coverage, green, done); lo = lower is better (unowned, eroded, dangling)
12// license_tier: ORIGINAL
13import "nx_sovjson_lib.nx"
14import "nx_syscalls.nx"
15import "nx_gate_verdict.nx"
16import "nx_tool_run.nx"
17const MH_MAGIC_1024: i64 = 1024
18
19const MH_CONF: i64 = 65536
20const MH_CAP: i64 = 262144
21const MH_OUT: i64 = 65536
22const MH_PATH: i64 = 512
23const MH_ARENA: i64 = 8192
24const MH_ARGS: i64 = 24
25const MH_ROWS: i64 = 64
26const MH_PERMIL: i64 = 1000
27const MH_NAME_MAX: i64 = 120
28const MH_MODE_644: i64 = 420
29const MH_SENT: i64 = -999999
30
31func mh_read(path: *u8, buf: *u8, cap: i64) -> i64 {
  let fd: i64 = sys_openat_rd(path)
  if fd < 0 { return -1 }
  var n: i64 = 0
  var go: i64 = 1
  while go == 1 { let r: i64 = sys_read(fd, ((buf as i64)+n) as *u8, cap-n); if r <= 0 { go = 0 } else { n = n + r } if n >= cap { go = 0 } }
  sys_close(fd)
  return n
39}
40func mh_find_from(q: *u8, from: i64, n: i64, lit: *u8) -> i64 {
  let ll: i64 = sj_vlen(lit)
  if ll == 0 { return -1 }
  var i: i64 = from
  while i + ll <= n {
      var k: i64 = 0
      var ok: i64 = 1
      while k < ll { if q[i+k] != lit[k] { ok = 0; k = ll } else { k = k + 1 } }
      if ok == 1 { return i }
      i = i + 1
  }
  return -1
52}
53func mh_find(q: *u8, n: i64, lit: *u8) -> i64 {
  if mh_find_from(q, 0, n, lit) >= 0 { return 1 }
  return 0
56}
57// extract the integer value of "<key>": from q. foundp[0]=1 if the key is present. MH_SENT if absent.
58func mh_extract(q: *u8, n: i64, key: *u8, foundp: *i64) -> i64 {
  let tok: *u8 = sys_mmap(256)
  var t: i64 = 0
  tok[t] = 34 as u8; t = t + 1
  t = sj_cat(tok, t, key)
  tok[t] = 34 as u8; t = t + 1
  tok[t] = 58 as u8; t = t + 1
  tok[t] = 0 as u8
  let p: i64 = mh_find_from(q, 0, n, tok)
  if p < 0 { foundp[0] = 0; return MH_SENT }
  foundp[0] = 1
  // skip spaces after the token, then optional minus, then digits
  var s: i64 = p + t
  var go: i64 = 1
  while go == 1 { if s >= n { go = 0 } else { if q[s] == (32 as u8) { s = s + 1 } else { go = 0 } } }
  var neg: i64 = 0
  if s < n { if q[s] == (45 as u8) { neg = 1; s = s + 1 } }
  var v: i64 = 0
  var g2: i64 = 1
  while g2 == 1 { if s >= n { g2 = 0 } else { let c: i64 = q[s] as i64; if c >= 48 { if c <= 57 { v = v * 10 + (c - 48); s = s + 1 } else { g2 = 0 } } else { g2 = 0 } } }
  if neg == 1 { v = 0 - v }
  return v
80}
81// 2 GOOD, 1 WATCH, 0 BAD. dir 0 = higher-better, dir 1 = lower-better.
82func mh_class(val: i64, dir: i64, good: i64, warn: i64) -> i64 {
  if dir == 0 { if val >= good { return 2 } if val >= warn { return 1 } return 0 }
  if val <= good { return 2 } if val <= warn { return 1 } return 0
85}
86func mh_key(d: *u8, o: i64, name: *u8) -> i64 {
  d[o] = 34 as u8
  var p: i64 = o + 1
  p = sj_cat(d, p, name)
  d[p] = 34 as u8
  p = p + 1
  d[p] = 58 as u8
  p = p + 1
  return p
95}
96func mh_status_str(d: *u8, o: i64, score: i64) -> i64 {
  var p: i64 = o
  d[p] = 34 as u8; p = p + 1
  if score == 2 { p = sj_cat(d, p, "GOOD" as *u8) } else { if score == 1 { p = sj_cat(d, p, "WATCH" as *u8) } else { p = sj_cat(d, p, "BAD" as *u8) } }
  d[p] = 34 as u8; p = p + 1
  return p
102}
103// fork one miner row (cols 5.. = miner + args), capture, extract its metric (col 4). ran=0 on fork fail.
104func mh_run(cq: *u8, ls: i64, le: i64, valp: *i64, ranp: *i64) -> i64 {
  ranp[0] = 0
  valp[0] = MH_SENT
  let sp: *i64 = sys_mmap(16) as *i64
  if sj_col(cq, ls, le, 5, sp) == 0 { return 0 }
  let mname: *u8 = sys_mmap(MH_PATH)
  var k: i64 = 0
  while sp[0]+k < sp[1] { if k < MH_PATH - 2 { mname[k] = cq[sp[0]+k] } k = k + 1 }
  mname[k] = 0 as u8
  let mpath: *u8 = sys_mmap(MH_PATH)
  if sj_allow_path(mname, mpath) == 0 { return 0 }
  let arena: *u8 = sys_mmap(MH_ARENA)
  let av: *i64 = sys_mmap(8 * MH_ARGS) as *i64
  av[0] = mpath as i64
  var ac: i64 = 1
  var ao: i64 = 0
  var c: i64 = 6
  var more: i64 = 1
  while more == 1 {
      if sj_col(cq, ls, le, c, sp) == 0 { more = 0 } else {
          if ac >= MH_ARGS - 1 { more = 0 } else {
              av[ac] = ((arena as i64) + ao) as i64
              var z: i64 = sp[0]
              while z < sp[1] { if ao < MH_ARENA - 2 { arena[ao] = cq[z]; ao = ao + 1 } z = z + 1 }
              arena[ao] = 0 as u8; ao = ao + 1
              ac = ac + 1
              c = c + 1
          }
      }
  }
  av[ac] = 0
  let cout: *u8 = sys_mmap(MH_CAP)
  let clen: *i64 = sys_mmap(16) as *i64
  let ex: i64 = tr_run_capture(mpath, av, cout, MH_CAP - 8, clen)
  if ex != 0 { return 0 }
  ranp[0] = 1
  let metric: *u8 = sys_mmap(128)
  if sj_col(cq, ls, le, 4, sp) == 1 {
      var m: i64 = 0
      while sp[0]+m < sp[1] { if m < 120 { metric[m] = cq[sp[0]+m] } m = m + 1 }
      metric[m] = 0 as u8
  }
  let fnd: *i64 = sys_mmap(16) as *i64
  valp[0] = mh_extract(cout, clen[0], metric, fnd)
  return 1
149}
150func mh_emit(conf: *u8, wantpage: i64, outp: *u8, d: *u8) -> i64 {
  let cb: *u8 = sys_mmap(MH_CONF)
  let cn: i64 = mh_read(conf, cb, MH_CONF - 8)
  if cn <= 0 { return -1 }
  let sp: *i64 = sys_mmap(16) as *i64
  let valp: *i64 = sys_mmap(16) as *i64
  let ranp: *i64 = sys_mmap(16) as *i64
  var p: i64 = 0
  if wantpage == 0 {
      d[p] = 123 as u8; p = p + 1
      p = mh_key(d, p, "v" as *u8); p = sj_catn(d, p, 1); d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "tool" as *u8)
      d[p] = 34 as u8; p = p + 1
      p = sj_cat(d, p, "nx_minerhub" as *u8)
      d[p] = 34 as u8; p = p + 1
      d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "sources" as *u8)
      d[p] = 91 as u8; p = p + 1
  } else {
      d[p] = 60 as u8; p = p + 1
      d[p] = 33 as u8; p = p + 1
      p = sj_cat(d, p, "doctype html><html><head><meta charset=\"utf-8\"><title>Miner Hub</title></head><body><h1>Ecosystem Health — Miner Hub</h1><p>each row = one class-miner's headline metric, classified GOOD/WATCH/BAD; the index is the composed health of the measurement layer.</p><table border=\"1\" cellpadding=\"5\"><tr><th>source</th><th>metric</th><th>value</th><th>status</th></tr>" as *u8)
  }
  var nsrc: i64 = 0
  var ran: i64 = 0
  var scoresum: i64 = 0
  var good: i64 = 0
  var watch: i64 = 0
  var bad: i64 = 0
  var efirst: i64 = 1
  var i: i64 = 0
  while i < cn {
      let le: i64 = sj_le(cb, i, cn)
      var ok: i64 = 0
      if le > i { if cb[i] != (35 as u8) { if sj_col(cb, i, le, 5, sp) == 1 { ok = 1 } } }
      if ok == 1 {
          nsrc = nsrc + 1
          let dir: *i64 = sys_mmap(16) as *i64
          sj_col(cb, i, le, 1, dir)
          var dv: i64 = 0
          if sj_lit_eq(cb, dir[0], dir[1], "lo" as *u8) == 1 { dv = 1 }
          let gd: *i64 = sys_mmap(16) as *i64
          sj_col(cb, i, le, 2, gd)
          let good_t: i64 = sj_atoi_span(cb, gd[0], gd[1])
          sj_col(cb, i, le, 3, gd)
          let warn_t: i64 = sj_atoi_span(cb, gd[0], gd[1])
          mh_run(cb, i, le, valp, ranp)
          var score: i64 = 0
          if ranp[0] == 1 { if valp[0] != MH_SENT { score = mh_class(valp[0], dv, good_t, warn_t); ran = ran + 1 } }
          if ranp[0] == 1 { if valp[0] != MH_SENT {
              scoresum = scoresum + score
              if score == 2 { good = good + 1 } else { if score == 1 { watch = watch + 1 } else { bad = bad + 1 } }
          } }
          if wantpage == 0 {
              if efirst == 0 { d[p] = 44 as u8; p = p + 1 }
              efirst = 0
              d[p] = 123 as u8; p = p + 1
              p = mh_key(d, p, "id" as *u8)
              sj_col(cb, i, le, 0, sp)
              d[p] = 34 as u8; p = p + 1
              p = sj_cat_esc(d, p, cb, sp[0], sp[1], MH_NAME_MAX)
              d[p] = 34 as u8; p = p + 1
              d[p] = 44 as u8; p = p + 1
              p = mh_key(d, p, "metric" as *u8)
              sj_col(cb, i, le, 4, sp)
              d[p] = 34 as u8; p = p + 1
              p = sj_cat_esc(d, p, cb, sp[0], sp[1], MH_NAME_MAX)
              d[p] = 34 as u8; p = p + 1
              d[p] = 44 as u8; p = p + 1
              p = mh_key(d, p, "value" as *u8)
              if valp[0] == MH_SENT { p = sj_cat(d, p, "null" as *u8) } else { p = sj_catn(d, p, valp[0]) }
              d[p] = 44 as u8; p = p + 1
              p = mh_key(d, p, "ran" as *u8); p = sj_catn(d, p, ranp[0]); d[p] = 44 as u8; p = p + 1
              p = mh_key(d, p, "status" as *u8)
              p = mh_status_str(d, p, score)
              d[p] = 125 as u8; p = p + 1
          } else {
              p = sj_cat(d, p, "<tr><td>" as *u8)
              sj_col(cb, i, le, 0, sp)
              p = sj_cat_esc(d, p, cb, sp[0], sp[1], MH_NAME_MAX)
              p = sj_cat(d, p, "</td><td>" as *u8)
              sj_col(cb, i, le, 4, sp)
              p = sj_cat_esc(d, p, cb, sp[0], sp[1], MH_NAME_MAX)
              p = sj_cat(d, p, "</td><td>" as *u8)
              if valp[0] == MH_SENT { p = sj_cat(d, p, "n/a" as *u8) } else { p = sj_catn(d, p, valp[0]) }
              p = sj_cat(d, p, "</td><td>" as *u8)
              if score == 2 { p = sj_cat(d, p, "GOOD" as *u8) } else { if score == 1 { p = sj_cat(d, p, "WATCH" as *u8) } else { p = sj_cat(d, p, "BAD" as *u8) } }
              p = sj_cat(d, p, "</td></tr>" as *u8)
          }
      }
      i = le + 1
  }
  var idx: i64 = 0 - 1
  if nsrc > 0 { idx = scoresum * MH_PERMIL / (2 * nsrc) }
  if wantpage == 0 {
      d[p] = 93 as u8; p = p + 1
      d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "sources_total" as *u8); p = sj_catn(d, p, nsrc); d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "ran" as *u8); p = sj_catn(d, p, ran); d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "good" as *u8); p = sj_catn(d, p, good); d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "watch" as *u8); p = sj_catn(d, p, watch); d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "bad" as *u8); p = sj_catn(d, p, bad); d[p] = 44 as u8; p = p + 1
      p = mh_key(d, p, "health_index_permil" as *u8); p = sj_catn(d, p, idx)
      d[p] = 125 as u8; p = p + 1
      d[p] = 10 as u8; p = p + 1
  } else {
      p = sj_cat(d, p, "</table><p style=\"font-size:48px\">health_index=" as *u8)
      p = sj_catn(d, p, idx)
      p = sj_cat(d, p, "&permil;</p><p>good=" as *u8)
      p = sj_catn(d, p, good)
      p = sj_cat(d, p, " watch=" as *u8)
      p = sj_catn(d, p, watch)
      p = sj_cat(d, p, " bad=" as *u8)
      p = sj_catn(d, p, bad)
      p = sj_cat(d, p, " ran=" as *u8)
      p = sj_catn(d, p, ran)
      p = sj_cat(d, p, "/" as *u8)
      p = sj_catn(d, p, nsrc)
      p = sj_cat(d, p, "</p><p><a href=\"/outsidegap\">outsidegap</a> <a href=\"/wsmine\">wsmine</a> <a href=\"/frontier\">frontier</a></p></body></html>" as *u8)
      let fd: i64 = sys_openat_wr(outp, MH_MODE_644)
      if fd < 0 { return -3 }
      sys_write(fd, d, p)
      sys_close(fd)
  }
  return p
275}
276// flag: each BAD source auto-files ONE intake REQ through the ALLOWLIST-RESOLVED filer. Shares mh_run +
277// mh_class with mine (the DECISION logic is DRY -- a flag can never disagree with the board). Marker
278// [HUB:<id>] makes it idempotent: one open ticket per source, no spam while it stays BAD (re-file after
279// triage-close is a declared v-next, matching the nx_feeder discipline). Filer INJECTABLE (argecho in gate).
280func mh_flag(conf: *u8, ipath: *u8, filer: *u8, d: *u8) -> i64 {
  let cb: *u8 = sys_mmap(MH_CONF)
  let cn: i64 = mh_read(conf, cb, MH_CONF - 8)
  if cn <= 0 { return -1 }
  let ib: *u8 = sys_mmap(MH_CAP)
  let ibn: i64 = mh_read(ipath, ib, MH_CAP - 8)
  var iblen: i64 = ibn
  if iblen < 0 { iblen = 0 }
  let fpath: *u8 = sys_mmap(MH_PATH)
  let fok: i64 = sj_allow_path(filer, fpath)
  let sp: *i64 = sys_mmap(16) as *i64
  let valp: *i64 = sys_mmap(16) as *i64
  let ranp: *i64 = sys_mmap(16) as *i64
  var bad: i64 = 0
  var flagged: i64 = 0
  var skipped: i64 = 0
  var i: i64 = 0
  while i < cn {
      let le: i64 = sj_le(cb, i, cn)
      var ok: i64 = 0
      if le > i { if cb[i] != (35 as u8) { if sj_col(cb, i, le, 5, sp) == 1 { ok = 1 } } }
      if ok == 1 {
          let dir: *i64 = sys_mmap(16) as *i64
          sj_col(cb, i, le, 1, dir)
          var dv: i64 = 0
          if sj_lit_eq(cb, dir[0], dir[1], "lo" as *u8) == 1 { dv = 1 }
          let gd: *i64 = sys_mmap(16) as *i64
          sj_col(cb, i, le, 2, gd)
          let good_t: i64 = sj_atoi_span(cb, gd[0], gd[1])
          sj_col(cb, i, le, 3, gd)
          let warn_t: i64 = sj_atoi_span(cb, gd[0], gd[1])
          mh_run(cb, i, le, valp, ranp)
          if ranp[0] == 1 { if valp[0] != MH_SENT {
              let score: i64 = mh_class(valp[0], dv, good_t, warn_t)
              if score == 0 {
                  bad = bad + 1
                  // marker [HUB:<id>]
                  let mk: *u8 = sys_mmap(256)
                  var mo: i64 = sj_cat(mk, 0, "[HUB:" as *u8)
                  sj_col(cb, i, le, 0, sp)
                  var z: i64 = sp[0]
                  while z < sp[1] { if mo < 200 { mk[mo] = cb[z]; mo = mo + 1 } z = z + 1 }
                  mk[mo] = 93 as u8; mo = mo + 1
                  mk[mo] = 0 as u8
                  var already: i64 = 0
                  if iblen > 0 { if mh_find(ib, iblen, mk) == 1 { already = 1 } }
                  if already == 1 { skipped = skipped + 1 } else { if fok == 1 {
                      let txt: *u8 = sys_mmap(MH_MAGIC_1024)
                      var to: i64 = sj_cat(txt, 0, mk)
                      to = sj_cat(txt, to, " " as *u8)
                      sj_col(cb, i, le, 4, sp)
                      var z2: i64 = sp[0]
                      while z2 < sp[1] { if to < 900 { txt[to] = cb[z2]; to = to + 1 } z2 = z2 + 1 }
                      to = sj_cat(txt, to, "=" as *u8)
                      to = sj_catn(txt, to, valp[0])
                      to = sj_cat(txt, to, " classified BAD by nx_minerhub - triage the owning class-miner's finding (see /minerhub)" as *u8)
                      txt[to] = 0 as u8
                      let av: *i64 = sys_mmap(64) as *i64
                      av[0] = fpath as i64
                      av[1] = "ask" as *u8 as i64
                      av[2] = ipath as i64
                      av[3] = "nx_minerhub" as *u8 as i64
                      av[4] = txt as i64
                      av[5] = 0
                      let cout: *u8 = sys_mmap(MH_OUT)
                      let clen: *i64 = sys_mmap(16) as *i64
                      let ex: i64 = tr_run_capture(fpath, av, cout, MH_OUT - 8, clen)
                      if ex == 0 { flagged = flagged + 1 }
                  } }
              }
          } }
      }
      i = le + 1
  }
  var p: i64 = 0
  d[p] = 123 as u8; p = p + 1
  p = mh_key(d, p, "v" as *u8); p = sj_catn(d, p, 1); d[p] = 44 as u8; p = p + 1
  p = mh_key(d, p, "tool" as *u8)
  d[p] = 34 as u8; p = p + 1
  p = sj_cat(d, p, "nx_minerhub" as *u8)
  d[p] = 34 as u8; p = p + 1
  d[p] = 44 as u8; p = p + 1
  p = mh_key(d, p, "averb" as *u8)
  d[p] = 34 as u8; p = p + 1
  p = sj_cat(d, p, "flag" as *u8)
  d[p] = 34 as u8; p = p + 1
  d[p] = 44 as u8; p = p + 1
  p = mh_key(d, p, "filer_resolved" as *u8); p = sj_catn(d, p, fok); d[p] = 44 as u8; p = p + 1
  p = mh_key(d, p, "bad" as *u8); p = sj_catn(d, p, bad); d[p] = 44 as u8; p = p + 1
  p = mh_key(d, p, "flagged" as *u8); p = sj_catn(d, p, flagged); d[p] = 44 as u8; p = p + 1
  p = mh_key(d, p, "skipped_already" as *u8); p = sj_catn(d, p, skipped)
  d[p] = 125 as u8; p = p + 1
  d[p] = 10 as u8; p = p + 1
  return p
374}
375func mh_selftest(prefix: *u8) -> i64 {
  let ctr: *i64 = gv_ctr()
  gv_head("nx_minerhub selftest -- metric extract + classify + index math (deterministic, no fork)" as *u8)
  let js: *u8 = sys_mmap(MH_MAGIC_1024)
  var o: i64 = sj_cat(js, 0, "{\"v\":1,\"coverage_permil\":1000,\"eat_permil\":283,\"avg_hold_s\":-1,\"eroded\":0}\n" as *u8)
  let jn: i64 = o
  let fnd: *i64 = sys_mmap(16) as *i64
  // T1 extract a present positive key
  var ok1: i64 = 0
  if mh_extract(js, jn, "coverage_permil" as *u8, fnd) == 1000 { if fnd[0] == 1 { ok1 = 1 } }
  gv_check("T1 extract exact value of a present key (1000)" as *u8, ok1, ctr)
  // T2 a substring key must NOT match a longer key (permil vs coverage_permil)
  var ok2: i64 = 0
  if mh_extract(js, jn, "eat_permil" as *u8, fnd) == 283 { ok2 = 1 }
  gv_check("T2 key match is exact-boundary (eat_permil=283, not confused with coverage_permil)" as *u8, ok2, ctr)
  // T3 negative value parsed as negative (refusal sentinel from a miner)
  var ok3: i64 = 0
  if mh_extract(js, jn, "avg_hold_s" as *u8, fnd) == (0 - 1) { ok3 = 1 }
  gv_check("T3 negative value parsed as -1 (a miner refusal survives synthesis)" as *u8, ok3, ctr)
  // T4 absent key -> found=0 + sentinel, never fabricated as 0
  var ok4: i64 = 0
  let av4: i64 = mh_extract(js, jn, "nonexistent_key" as *u8, fnd)
  if fnd[0] == 0 { if av4 == MH_SENT { ok4 = 1 } }
  gv_check("T4 absent key -> found=0 + sentinel, never a fabricated zero" as *u8, ok4, ctr)
  // T5 hi-is-good classification
  var ok5: i64 = 0
  if mh_class(1000, 0, 900, 700) == 2 { if mh_class(800, 0, 900, 700) == 1 { if mh_class(500, 0, 900, 700) == 0 { ok5 = 1 } } }
  gv_check("T5 higher-is-better: 1000 GOOD, 800 WATCH, 500 BAD" as *u8, ok5, ctr)
  // T6 lo-is-good classification
  var ok6: i64 = 0
  if mh_class(0, 1, 0, 5) == 2 { if mh_class(3, 1, 0, 5) == 1 { if mh_class(20, 1, 0, 5) == 0 { ok6 = 1 } } }
  gv_check("T6 lower-is-better: 0 GOOD, 3 WATCH, 20 BAD" as *u8, ok6, ctr)
  // T7 boundary is inclusive (val==good is GOOD, val==warn is WATCH)
  var ok7: i64 = 0
  if mh_class(900, 0, 900, 700) == 2 { if mh_class(700, 0, 900, 700) == 1 { ok7 = 1 } }
  gv_check("T7 thresholds inclusive at the boundary" as *u8, ok7, ctr)
  // T8 index math: 2 GOOD + 1 WATCH + 1 BAD over 4 = (2+2+1+0)/8 = 625 permil
  var ok8: i64 = 0
  let ssum: i64 = 2 + 2 + 1 + 0
  if ssum * MH_PERMIL / (2 * 4) == 625 { ok8 = 1 }
  gv_check("T8 health_index math exact: 2G/1W/1B of 4 = 625 permil" as *u8, ok8, ctr)
  // T9 live compose over a real conf that forks nx_minecov -> the hub actually runs the suite
  let cf: *u8 = sys_mmap(MH_PATH)
  o = sj_cat(cf, 0, prefix)
  o = sj_catn(cf, o, sys_now_realtime_sec())
  o = sj_cat(cf, o, ".conf" as *u8)
  cf[o] = 0 as u8
  let fd: i64 = sys_openat_wr(cf, MH_MODE_644)
  let lb: *u8 = sys_mmap(MH_MAGIC_1024)
  var lo: i64 = sj_cat(lb, 0, "cov\thi\t900\t700\tcoverage_permil\tnx_minecov\tcensus\tknowledge/status/minecov_classes.conf\n" as *u8)
  sys_write(fd, lb, lo)
  sys_close(fd)
  let d: *u8 = sys_mmap(MH_OUT)
  let dl: i64 = mh_emit(cf, 0, "-" as *u8, d)
  var ok9: i64 = 0
  if dl > 0 { if mh_find(d, dl, "\"id\":\"cov\"" as *u8) == 1 { if mh_find(d, dl, "\"ran\":1" as *u8) == 1 { if mh_find(d, dl, "\"status\":\"GOOD\"" as *u8) == 1 { ok9 = 1 } } } }
  gv_check("T9 LIVE compose: forks nx_minecov, extracts coverage_permil, classifies GOOD" as *u8, ok9, ctr)
  // T10/T11 flag: a BAD source auto-files ONE ticket through the injected argecho filer, idempotent.
  // conf forks nx_minecov census reading mined_permil(=1000) with dir=lo good=100 warn=500 => 1000>500
  // => BAD by construction (inverted thresholds; the tooth is the FILING mechanism, not the threshold).
  let bc: *u8 = sys_mmap(MH_PATH)
  o = sj_cat(bc, 0, prefix)
  o = sj_catn(bc, o, sys_now_realtime_sec())
  o = sj_cat(bc, o, ".bad" as *u8)
  bc[o] = 0 as u8
  let bfd: i64 = sys_openat_wr(bc, MH_MODE_644)
  var blo: i64 = sj_cat(lb, 0, "cov\tlo\t100\t500\tmined_permil\tnx_minecov\tcensus\tknowledge/status/minecov_classes.conf\n" as *u8)
  sys_write(bfd, lb, blo)
  sys_close(bfd)
  let ij: *u8 = sys_mmap(MH_PATH)
  o = sj_cat(ij, 0, prefix)
  o = sj_catn(ij, o, sys_now_realtime_sec())
  o = sj_cat(ij, o, ".ij" as *u8)
  ij[o] = 0 as u8
  let fr1: i64 = mh_flag(bc, ij, "argecho" as *u8, d)
  var ok10: i64 = 0
  if fr1 > 0 { if mh_find(d, fr1, "\"bad\":1" as *u8) == 1 { if mh_find(d, fr1, "\"flagged\":1" as *u8) == 1 { if mh_find(d, fr1, "\"skipped_already\":0" as *u8) == 1 { ok10 = 1 } } } }
  gv_check("T10 a BAD source files exactly one ticket through the injected filer" as *u8, ok10, ctr)
  // seed the marker the argecho filer would have written (argecho does not persist), then re-flag
  let sfd: i64 = sys_openat_append(ij, MH_MODE_644)
  var slo: i64 = sj_cat(lb, 0, "REQ seeded [HUB:cov] marker\n" as *u8)
  sys_write(sfd, lb, slo)
  sys_close(sfd)
  let fr2: i64 = mh_flag(bc, ij, "argecho" as *u8, d)
  var ok11: i64 = 0
  if fr2 > 0 { if mh_find(d, fr2, "\"bad\":1" as *u8) == 1 { if mh_find(d, fr2, "\"flagged\":0" as *u8) == 1 { if mh_find(d, fr2, "\"skipped_already\":1" as *u8) == 1 { ok11 = 1 } } } }
  gv_check("T11 marker present -> re-flag files NOTHING (idempotent, no ticket spam)" as *u8, ok11, ctr)
  let rc: i64 = gv_verdict("MINERHUB-GATE" as *u8, ctr, "synthesis + flag: exact extract, boundary classify, honest sentinel, index math, live compose, idempotent auto-file" as *u8)
  return rc
464}
465
466func main(argc: i64, argv: *i64) -> i64 {
  if argc < 3 { sj_puts("usage: nx_minerhub {mine <sourceconf> | page <sourceconf> <outfile> | flag <sourceconf> <intake_jrnl> [filer] | selftest <scratch-prefix>}\n" as *u8); sys_exit(2); return 2 }
  let verb: *u8 = argv[1] as *u8
  let vl: i64 = sj_vlen(verb)
  if sj_lit_eq(verb, 0, vl, "selftest" as *u8) == 1 {
      let rc: i64 = mh_selftest(argv[2] as *u8)
      sys_exit(rc)
      return rc
  }
  if sj_lit_eq(verb, 0, vl, "mine" as *u8) == 1 {
      let d: *u8 = sys_mmap(MH_OUT)
      let dl: i64 = mh_emit(argv[2] as *u8, 0, "-" as *u8, d)
      if dl < 0 { sj_puts("REFUSED source conf missing or empty\n" as *u8); sys_exit(3); return 3 }
      sys_write(1, d, dl)
      sys_exit(0)
      return 0
  }
  if sj_lit_eq(verb, 0, vl, "page" as *u8) == 1 {
      if argc < 4 { sj_puts("page needs <sourceconf> <outfile>\n" as *u8); sys_exit(2); return 2 }
      let d: *u8 = sys_mmap(MH_OUT)
      let dl: i64 = mh_emit(argv[2] as *u8, 1, argv[3] as *u8, d)
      if dl < 0 { sj_puts("PAGE FAIL\n" as *u8); sys_exit(1); return 1 }
      sj_puts("PAGE OK\n" as *u8)
      sys_exit(0)
      return 0
  }
  if sj_lit_eq(verb, 0, vl, "flag" as *u8) == 1 {
      if argc < 4 { sj_puts("flag needs <sourceconf> <intake_jrnl> [filer]\n" as *u8); sys_exit(2); return 2 }
      let filer: *u8 = sys_mmap(128)
      var fo: i64 = 0
      if argc >= 5 { fo = sj_cat(filer, 0, argv[4] as *u8) } else { fo = sj_cat(filer, 0, "nx_pm_intake" as *u8) }
      filer[fo] = 0 as u8
      let d: *u8 = sys_mmap(MH_OUT)
      let dl: i64 = mh_flag(argv[2] as *u8, argv[3] as *u8, filer, d)
      if dl < 0 { sj_puts("REFUSED source conf missing or empty\n" as *u8); sys_exit(3); return 3 }
      sys_write(1, d, dl)
      sys_exit(0)
      return 0
  }
  sj_puts("unknown verb\n" as *u8)
  sys_exit(2)
  return 2
508}
nx_minerhub.nx source

`nx_minerhub.nx` source
