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

↩ module page · 143 lines · 6788 B
1// nx_delivery_report.nx -- the HUMAN perspective on the wire (operator 2026-06-12):
2// the machine cares about the current beat; the human cares about WHEN IT DELIVERS,
3// the GROWTH RATE, the SUCCESS RATE.  This organ derives the management view from
4// the ledgers' TIMESTAMPED HISTORY (never a feeling, always a slope):
5//   - done velocity: done_rows across AUTMETER history -> rows/day (whole-window)
6//   - autonomy growth: permil first->last -> permil/day toward the C/B/A/S bars
7//   - beat success rate: PULSE-VERDICT ok/steps share across team_pulse history
8//   - backlog + naive-linear ETA: latest todo / done-velocity (LABELED naive-linear:
9//     assumes constant velocity and no new rows -- both false, which is WHY the
10//     novel-growth line sits next to it)
11//   - raised-hands growth: novel count first->last (the answer-consumption pressure)
12// Durable: DELIVERY block -> knowledge/channel/team_out.tsv (the human reads the
13// same wire) + DELIVERY row -> knowledge/status/delivery_report.log (the Examiner
14// grades presence).  Exit 0 = reported; exit 1 = unreadable world.
15// argv[1]=meter-log argv[2]=pulse-log argv[3]=team-out argv[4]=report-log (gates: scratch)
16// license_tier: ORIGINAL
17import "nx_syscalls.nx"
18const K_MAGIC_86400: i64 = 86400
19const K_MAGIC_1048576: i64 = 1048576
20const K_MAGIC_1048560: i64 = 1048560
21const K_MAGIC_3600: i64 = 3600
22func _p(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 }
23func _fp(fd: i64, s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(fd,s,n); return 0 }
24func _fn(fd: i64, v: i64) -> i64 { let bb: *u8=sys_mmap(28); var m: i64=v; if m<0{m=0-m; sys_write(fd,"-" as *u8,1)}; 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{bb[i]=t[k-1-i];i=i+1}; sys_write(fd,bb,k); return 0 }
25func dr_len(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
26func dr_read(path: *u8, buf: *u8, cap: i64) -> i64 {
  let fd: i64 = sys_openat_rd(path)
  if fd < 0 { return 0 }
  var n: i64 = 0
  var go: i64 = 1
  while go == 1 { let base: i64 = buf as i64; let r: i64 = sys_read(fd, (base + n) as *u8, cap - n); if r <= 0 { go = 0 } else { n = n + r } if n >= cap { go = 0 } }
  sys_close(fd)
  return n
34}
35// parse the integer right after pat within [a,b); -1 if absent
36func dr_num_after(buf: *u8, a: i64, b: i64, pat: *u8) -> i64 {
  let pl: i64 = dr_len(pat)
  var i: i64 = a
  while i + pl <= b {
      var k: i64 = 0
      var hit: i64 = 1
      while k < pl { if buf[i+k] != pat[k] { hit = 0; k = pl } else { k = k + 1 } }
      if hit == 1 {
          var j: i64 = i + pl
          var v: i64 = 0
          var any: i64 = 0
          var dg: i64 = 1
          while dg == 1 {
              if j >= b { dg = 0 }
              else { if buf[j] < (48 as u8) { dg = 0 } else { if buf[j] > (57 as u8) { dg = 0 } else { v = v * 10 + ((buf[j] as i64) - 48); j = j + 1; any = 1 } } }
          }
          if any == 1 { return v }
          return 0 - 1
      }
      i = i + 1
  }
  return 0 - 1
58}
59// scan a log: FIRST and LAST line holding anchor -> (epoch,val) pairs via field pat
60func dr_first_last(buf: *u8, n: i64, anchor: *u8, fld: *u8, out: *i64) -> i64 {
  var found: i64 = 0
  var i: i64 = 0
  while i < n {
      var le: i64 = i
      var s: i64 = 1
      while s == 1 { if le >= n { s = 0 } else { if buf[le] == (10 as u8) { s = 0 } else { le = le + 1 } } }
      let ep: i64 = dr_num_after(buf, i, le, anchor)
      if ep >= 0 {
          let v: i64 = dr_num_after(buf, i, le, fld)
          if v >= 0 {
              if found == 0 { out[0] = ep; out[1] = v; found = 1 }
              out[2] = ep
              out[3] = v
          }
      }
      i = le + 1
  }
  return found
79}
80func dr_rate_day(out: *i64) -> i64 {
  let dt: i64 = out[2] - out[0]
  if dt <= 0 { return 0 }
  return ((out[3] - out[1]) * K_MAGIC_86400) / dt
84}
85func main(argc: i64, argv: *i64) -> i64 {
  var mlp: *u8 = "knowledge/status/autonomy_meter.log" as *u8
  var plp: *u8 = "knowledge/status/team_pulse.log" as *u8
  var top: *u8 = "knowledge/channel/team_out.tsv" as *u8
  var rlp: *u8 = "knowledge/status/delivery_report.log" as *u8
  if argc >= 2 { mlp = argv[1] as *u8 }
  if argc >= 3 { plp = argv[2] as *u8 }
  if argc >= 4 { top = argv[3] as *u8 }
  if argc >= 5 { rlp = argv[4] as *u8 }
  _p("=== DELIVERY REPORT: the human view -- velocity, growth, success, naive ETA ===\n" as *u8)
  let mb: *u8 = sys_mmap(K_MAGIC_1048576)
  let mn: i64 = dr_read(mlp, mb, K_MAGIC_1048560)
  if mn <= 0 { _p(" meter history MISSING -- fail loud\n" as *u8); sys_exit(1); return 1 }
  let fl: *i64 = sys_mmap(64) as *i64
  // done velocity + autonomy growth from AUTMETER history
  if dr_first_last(mb, mn, "AUTMETER epoch=" as *u8, " done_rows=" as *u8, fl) == 0 { _p(" no AUTMETER rows -- fail loud\n" as *u8); sys_exit(1); return 1 }
  let done_first: i64 = fl[1]
  let done_last: i64 = fl[3]
  let done_rate: i64 = dr_rate_day(fl)
  let span_h: i64 = (fl[2] - fl[0]) / K_MAGIC_3600
  dr_first_last(mb, mn, "AUTMETER epoch=" as *u8, " permil=" as *u8, fl)
  let pm_first: i64 = fl[1]
  let pm_last: i64 = fl[3]
  let pm_rate: i64 = dr_rate_day(fl)
  // beat success share from pulse history
  let pb: *u8 = sys_mmap(K_MAGIC_1048576)
  let pn: i64 = dr_read(plp, pb, K_MAGIC_1048560)
  var ok_sum: i64 = 0
  var st_sum: i64 = 0
  var i: i64 = 0
  while i < pn {
      var le: i64 = i
      var s: i64 = 1
      while s == 1 { if le >= pn { s = 0 } else { if pb[le] == (10 as u8) { s = 0 } else { le = le + 1 } } }
      let stv: i64 = dr_num_after(pb, i, le, "PULSE-VERDICT steps=" as *u8)
      if stv > 0 {
          let okv: i64 = dr_num_after(pb, i, le, " ok=" as *u8)
          if okv >= 0 { st_sum = st_sum + stv; ok_sum = ok_sum + okv }
      }
      i = le + 1
  }
  var beat_permil: i64 = 0
  if st_sum > 0 { beat_permil = (ok_sum * 1000) / st_sum }
  // backlog + hands from team_out SITREP queue lines (epoch carried by SITREP line)
  let tb: *u8 = sys_mmap(K_MAGIC_1048576)
  let tn: i64 = dr_read(top, tb, K_MAGIC_1048560)
  var last_ep: i64 = 0
  var q_ep0: i64 = 0
  var q_td0: i64 = 0 - 1
  var q_nv0: i64 = 0
  var q_ep1: i64 = 0
  var q_td1: i64 = 0
  var q_nv1: i64 = 0
  i = 0
  while i < tn {
      var le2: i64 = i
      var s2: i64 = 1
      while s2 == 1 { if le2 >= tn { s2 = 0 } else { if tb[le2] == (10 as u8) { s2 = 0 } else { le2 = le2 + 1 } } }
      let se: i64 = dr_num_after(tb, i, le2, "SITREP epoch=" as *u8)
      if se >= 0 { last_
nx_delivery_report.nx source

`nx_delivery_report.nx` source
