`nx_pm_board.nx` source

↩ module page · 380 lines · 16034 B
1// nx_pm_board.nx -- THE PM DASHBOARD (operator 2026-07-18: "the pm to give us based on my executive,
2// management, and operations layer a dashboard and feedback ... oversight into what work is happening
3// and the return on investment ... with non fake numbers but real estimates").
4// THREE LAYERS, all DERIVED from the sovereign planes (never asserted):
5//   executive : frontier done/total + open-debt posture + sev>=7 incidents + maturity permil
6//               (read from the rollup's durable log; unreadable -> -1 flagged, never invented)
7//   management: per RACI lane (raci- plane): open debts / open work / ready frontier rows owned by R
8//   operations: mutation activity per plane (hist row counts = provenanced writes = the real work log)
9//   roi       : NON-FAKE BY CONSTRUCTION -- measured counts (debts closed, work closed, frontier done,
10//               plane mutations) + assumption rows from the roi- plane {id metric value basis note};
11//               derived figures computed ONLY from rows whose basis != SET-ME; SET-ME rows are emitted
12//               under needs_decision (feedback TO the executive) instead of being faked.
13//   nx_pm_board [frontierpfx] [debtpfx] [workpfx] [racipfx] [roipfx]   -> JSON on stdout
14// Debt rows are schema-aware per row (legacy epoch 5-col sev@1 vs v2 7-col sev@2/status@3/owner@4).
15// Fail-closed: unseeded frontier or debt plane -> error exit (no dashboard over missing data).
16// license_tier: ORIGINAL   No hw writes (Rule 26).   expect_exit: 0
17import "nx_store_seed_lib.nx"
18import "nx_seg_store.nx"
19import "nx_deploy_lib.nx"
20import "nx_syscalls.nx"
21const PB_MAGIC_4096: i64 = 4096
22
23const PB_CAP: i64 = 1048576
24const PB_OUT: i64 = 262144
25const PB_NL: i64 = 10
26const PB_TAB: i64 = 9
27const PB_MAXCOL: i64 = 16
28const PB_PAIR: i64 = 2
29const PB_SPB: i64 = 256
30const PB_STDERR: i64 = 2
31const PB_EXIT_IO: i64 = 1
32const PB_ZERO: i64 = 48
33const PB_NINE: i64 = 57
34const PB_B10: i64 = 10
35const PB_MAXLANE: i64 = 24
36const PB_INCSEV: i64 = 7
37
38func pb_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
39func pb_werr(s: *u8) -> i64 { sys_write(PB_STDERR, s, pb_slen(s)); return 0 }
40func pb_cols(q: *u8, ls: i64, le: i64, sp: *i64) -> i64 {
  var c: i64 = 0
  var p: i64 = ls
  while c < PB_MAXCOL {
      var e: i64 = p
      var s: i64 = 1
      while s == 1 { if e >= le { s = 0 } else { if q[e] == (PB_TAB as u8) { s = 0 } else { e = e + 1 } } }
      sp[c*PB_PAIR] = p
      sp[c*PB_PAIR+1] = e
      c = c + 1
      if e >= le { return c }
      p = e + 1
  }
  return c
54}
55func pb_int(q: *u8, a: i64, b: i64) -> i64 {
  var v: i64 = 0
  var i: i64 = a
  while i < b { let c: i64 = q[i]; if c >= PB_ZERO { if c <= PB_NINE { v = v * PB_B10 + (c - PB_ZERO) } } i = i + 1 }
  return v
60}
61func pb_sl_eq(q: *u8, a: i64, b: i64, s: *u8) -> i64 {
  let sn: i64 = pb_slen(s)
  if b - a != sn { return 0 }
  var i: i64 = 0
  while i < sn { if q[a+i] != s[i] { return 0 } i = i + 1 }
  return 1
67}
68func pb_sl_eq2(q: *u8, a: i64, b: i64, r: *u8, c: i64, d: i64) -> i64 {
  if b - a != d - c { return 0 }
  var i: i64 = 0
  while a + i < b { if q[a+i] != r[c+i] { return 0 } i = i + 1 }
  return 1
73}
74func pb_legacy(q: *u8, ls: i64, le: i64, sp: *i64) -> i64 {
  if pb_cols(q, ls, le, sp) < 1 { return 0 }
  if sp[1] - sp[0] < 8 { return 0 }
  var i: i64 = sp[0]
  while i < sp[1] { let c: i64 = q[i]; if c < PB_ZERO { return 0 } if c > PB_NINE { return 0 } i = i + 1 }
  return 1
80}
81func pb_lines(q: *u8, n: i64) -> i64 { var k: i64 = 0; var i: i64 = 0; while i < n { if q[i] == (PB_NL as u8) { k = k + 1 } i = i + 1 } return k }
82// raw verbatim copy (for pre-quoted lists built with literal '\x22' -- must NOT be re-escaped)
83func pb_raw(d: *u8, o: i64, q: *u8, a: i64, b: i64) -> i64 {
  var oo: i64 = o
  var i: i64 = a
  while i < b { d[oo] = q[i]; oo = oo + 1; i = i + 1 }
  return oo
88}
89func pb_esc(d: *u8, o: i64, q: *u8, a: i64, b: i64) -> i64 {
  var oo: i64 = o
  var i: i64 = a
  while i < b {
      var c: i64 = q[i]
      if c == 34 { c = 39 }
      if c == 92 { c = 47 }
      if c < 32 { c = 32 }
      d[oo] = c as u8
      oo = oo + 1
      i = i + 1
  }
  return oo
102}
103// scan the durable maturity log for " = NNN permil" -> NNN; -1 if unreadable/absent (flag, never invent)
104func pb_maturity() -> i64 {
  let b: *u8 = sys_mmap(PB_CAP)
  let n: i64 = dp_read("knowledge/status/ecosystem_maturity.log" as *u8, b, PB_CAP - 4)
  if n <= 0 { return 0 - 1 }
  let pat: *u8 = " permil" as *u8
  var found: i64 = 0 - 1
  var i: i64 = 0
  while i + 7 <= n {
      var hit: i64 = 1
      var j: i64 = 0
      while j < 7 { if b[i+j] != pat[j] { hit = 0; j = 7 } else { j = j + 1 } }
      if hit == 1 { found = i }
      i = i + 1
  }
  if found < 0 { return 0 - 1 }
  var s: i64 = found
  while s > 0 { let c: i64 = b[s-1]; if c >= PB_ZERO { if c <= PB_NINE { s = s - 1 } else { s = 0 - s } } else { s = 0 - s } }
  if s < 0 { s = 0 - s }
  if s == found { return 0 - 1 }
  return pb_int(b, s, found)
124}
125
126func main(argc: i64, argv: *i64) -> i64 {
  var fpx: *u8 = "knowledge/store/frontier-" as *u8
  var dpx: *u8 = "knowledge/store/debt-" as *u8
  var wpx: *u8 = "knowledge/store/work-" as *u8
  var rpx: *u8 = "knowledge/store/raci-" as *u8
  var opx: *u8 = "knowledge/store/roi-" as *u8
  if argc > 1 { fpx = argv[1] as *u8 }
  if argc > 2 { dpx = argv[2] as *u8 }
  if argc > 3 { wpx = argv[3] as *u8 }
  if argc > 4 { rpx = argv[4] as *u8 }
  if argc > 5 { opx = argv[5] as *u8 }
137
  let fb: *u8 = sys_mmap(PB_CAP)
  let fn: i64 = sts_load(fpx, fb, PB_CAP)
  if fn <= 0 { pb_werr("frontier plane unseeded (fail-closed)\n" as *u8); sys_exit(PB_EXIT_IO); return PB_EXIT_IO }
  let db: *u8 = sys_mmap(PB_CAP)
  let dn: i64 = sts_load(dpx, db, PB_CAP)
  if dn <= 0 { pb_werr("debt plane unseeded (fail-closed)\n" as *u8); sys_exit(PB_EXIT_IO); return PB_EXIT_IO }
  let wb: *u8 = sys_mmap(PB_CAP)
  var wn: i64 = sts_load(wpx, wb, PB_CAP)
  if wn < 0 { wn = 0 }
  let rb: *u8 = sys_mmap(PB_CAP)
  var rn: i64 = sts_load(rpx, rb, PB_CAP)
  if rn < 0 { rn = 0 }
  let ob: *u8 = sys_mmap(PB_CAP)
  var on: i64 = sts_load(opx, ob, PB_CAP)
  if on < 0 { on = 0 }
  let sp: *i64 = sys_mmap(PB_SPB) as *i64
  let out: *u8 = sys_mmap(PB_OUT)
155
  // ---- frontier tallies (9-col: status col5, owner col4)
  var ftot: i64 = 0
  var fdone: i64 = 0
  var i: i64 = 0
  while i < fn {
      var le: i64 = i
      var s: i64 = 1
      while s == 1 { if le >= fn { s = 0 } else { if fb[le] == (PB_NL as u8) { s = 0 } else { le = le + 1 } } }
      if le > i { if pb_cols(fb, i, le, sp) >= 6 {
          ftot = ftot + 1
          if pb_sl_eq(fb, sp[10], sp[11], "D" as *u8) == 1 { fdone = fdone + 1 }
      } }
      i = le + 1
  }
  // ---- debt tallies (schema-aware) + incidents (open sev>=7) collected as id list
  var dtot: i64 = 0
  var dopen: i64 = 0
  var dclosed: i64 = 0
  var inc_o: i64 = 0
  let incb: *u8 = sys_mmap(PB_MAGIC_4096)
  var ninc: i64 = 0
  i = 0
  while i < dn {
      var le2: i64 = i
      var s2: i64 = 1
      while s2 == 1 { if le2 >= dn { s2 = 0 } else { if db[le2] == (PB_NL as u8) { s2 = 0 } else { le2 = le2 + 1 } } }
      if le2 > i {
          let nc: i64 = pb_cols(db, i, le2, sp)
          if nc >= 4 {
              dtot = dtot + 1
              var sevcol: i64 = 2
              if pb_legacy(db, i, le2, sp) == 1 { sevcol = 1 }
              pb_cols(db, i, le2, sp)
              var isopen: i64 = 0
              if pb_sl_eq(db, sp[6], sp[7], "open" as *u8) == 1 { isopen = 1 }
              if isopen == 1 { dopen = dopen + 1 } else { dclosed = dclosed + 1 }
              if isopen == 1 {
                  let sev: i64 = pb_int(db, sp[sevcol*PB_PAIR], sp[sevcol*PB_PAIR+1])
                  if sev >= PB_INCSEV {
                      if ninc > 0 { incb[inc_o] = 44 as u8; inc_o = inc_o + 1 }
                      incb[inc_o] = 34 as u8
                      inc_o = inc_o + 1
                      inc_o = pb_esc(incb, inc_o, db, sp[0], sp[1])
                      incb[inc_o] = 34 as u8
                      inc_o = inc_o + 1
                      ninc = ninc + 1
                  }
              }
          }
      }
      i = le2 + 1
  }
  // ---- work tallies (7-col: status col3)
  var wtot: i64 = 0
  var wopen: i64 = 0
  var wclosed: i64 = 0
  i = 0
  while i < wn {
      var le3: i64 = i
      var s3: i64 = 1
      while s3 == 1 { if le3 >= wn { s3 = 0 } else { if wb[le3] == (PB_NL as u8) { s3 = 0 } else { le3 = le3 + 1 } } }
      if le3 > i { if pb_cols(wb, i, le3, sp) >= 4 {
          wtot = wtot + 1
          if pb_sl_eq(wb, sp[6], sp[7], "open" as *u8) == 1 { wopen = wopen + 1 } else { wclosed = wclosed + 1 }
      } }
      i = le3 + 1
  }
  // ---- hist activity (operations layer): line counts of the mutation ledgers
  let hb: *u8 = sys_mmap(PB_CAP)
  let hp: *u8 = sys_mmap(256)
  var n0: i64 = pb_slen(dpx)
  if n0 > 0 { if dpx[n0-1] == (45 as u8) { n0 = n0 - 1 } }
  var hh: i64 = 0
  var t: i64 = 0
  while t < n0 { hp[t] = dpx[t]; t = t + 1 }
  var ho: i64 = ss_cat(hp, n0, "hist-" as *u8)
  hp[ho] = 0 as u8
  var dhn: i64 = sts_load(hp, hb, PB_CAP)
  if dhn < 0 { dhn = 0 }
  let dmut: i64 = pb_lines(hb, dhn)
  n0 = pb_slen(wpx)
  if n0 > 0 { if wpx[n0-1] == (45 as u8) { n0 = n0 - 1 } }
  t = 0
  while t < n0 { hp[t] = wpx[t]; t = t + 1 }
  ho = ss_cat(hp, n0, "hist-" as *u8)
  hp[ho] = 0 as u8
  var whn: i64 = sts_load(hp, hb, PB_CAP)
  if whn < 0 { whn = 0 }
  let wmut: i64 = pb_lines(hb, whn)
  if hh == 0 { hh = 0 }
  // ---- maturity from the durable instrument log (never invented)
  let mat: i64 = pb_maturity()
248
  // ---- emit
  var o: i64 = 0
  o = ss_cat(out, o, "{\x22pm_board\x22:\x22v1\x22,\x22executive\x22:{\x22frontier_done\x22:" as *u8)
  o = ss_catn(out, o, fdone)
  o = ss_cat(out, o, ",\x22frontier_total\x22:" as *u8)
  o = ss_catn(out, o, ftot)
  o = ss_cat(out, o, ",\x22debts_open\x22:" as *u8)
  o = ss_catn(out, o, dopen)
  o = ss_cat(out, o, ",\x22debts_closed\x22:" as *u8)
  o = ss_catn(out, o, dclosed)
  o = ss_cat(out, o, ",\x22maturity_permil\x22:" as *u8)
  if mat < 0 { o = ss_cat(out, o, "-1,\x22maturity_note\x22:\x22instrument log unreadable here -- run nx_ecosystem_maturity_rollup\x22" as *u8) } else { o = ss_catn(out, o, mat) }
  o = ss_cat(out, o, ",\x22incidents_sev7plus\x22:[" as *u8)
  o = pb_raw(out, o, incb, 0, inc_o)
  o = ss_cat(out, o, "]},\x22management\x22:[" as *u8)
  // per raci lane: {lane,R,debts_open,work_open}
  var nlane: i64 = 0
  i = 0
  while i < rn {
      var le4: i64 = i
      var s4: i64 = 1
      while s4 == 1 { if le4 >= rn { s4 = 0 } else { if rb[le4] == (PB_NL as u8) { s4 = 0 } else { le4 = le4 + 1 } } }
      if le4 > i { if nlane < PB_MAXLANE { if pb_cols(rb, i, le4, sp) >= 2 {
          let la: i64 = sp[0]
          let lb2: i64 = sp[1]
          let ra: i64 = sp[2]
          let rb2: i64 = sp[3]
          // count open debts + open work owned by R (owner col4 both planes)
          var cd: i64 = 0
          var cw: i64 = 0
          var j2: i64 = 0
          let spd: *i64 = sys_mmap(PB_SPB) as *i64
          while j2 < dn {
              var led: i64 = j2
              var sd: i64 = 1
              while sd == 1 { if led >= dn { sd = 0 } else { if db[led] == (PB_NL as u8) { sd = 0 } else { led = led + 1 } } }
              if led > j2 { if pb_cols(db, j2, led, spd) >= 5 {
                  if pb_sl_eq(db, spd[6], spd[7], "open" as *u8) == 1 { if pb_sl_eq2(db, spd[8], spd[9], rb, ra, rb2) == 1 { cd = cd + 1 } }
              } }
              j2 = led + 1
          }
          j2 = 0
          while j2 < wn {
              var lew: i64 = j2
              var sw: i64 = 1
              while sw == 1 { if lew >= wn { sw = 0 } else { if wb[lew] == (PB_NL as u8) { sw = 0 } else { lew = lew + 1 } } }
              if lew > j2 { if pb_cols(wb, j2, lew, spd) >= 5 {
                  if pb_sl_eq(wb, spd[6], spd[7], "open" as *u8) == 1 { if pb_sl_eq2(wb, spd[8], spd[9], rb, ra, rb2) == 1 { cw = cw + 1 } }
              } }
              j2 = lew + 1
          }
          if nlane > 0 { out[o] = 44 as u8; o = o + 1 }
          o = ss_cat(out, o, "{\x22lane\x22:\x22" as *u8)
          o = pb_esc(out, o, rb, la, lb2)
          o = ss_cat(out, o, "\x22,\x22r\x22:\x22" as *u8)
          o = pb_esc(out, o, rb, ra, rb2)
          o = ss_cat(out, o, "\x22,\x22debts_open\x22:" as *u8)
          o = ss_catn(out, o, cd)
          o = ss_cat(out, o, ",\x22work_open\x22:" as *u8)
          o = ss_catn(out, o, cw)
          o = ss_cat(out, o, "}" as *u8)
          nlane = nlane + 1
      } } }
      i = le4 + 1
  }
  o = ss_cat(out, o, "],\x22operations\x22:{\x22debt_mutations\x22:" as *u8)
  o = ss_catn(out, o, dmut)
  o = ss_cat(out, o, ",\x22work_mutations\x22:" as *u8)
  o = ss_catn(out, o, wmut)
  o = ss_cat(out, o, ",\x22work_open\x22:" as *u8)
  o = ss_catn(out, o, wopen)
  o = ss_cat(out, o, ",\x22work_closed\x22:" as *u8)
  o = ss_catn(out, o, wclosed)
  o = ss_cat(out, o, "},\x22roi\x22:{\x22measured\x22:{\x22debts_closed\x22:" as *u8)
  o = ss_catn(out, o, dclosed)
  o = ss_cat(out, o, ",\x22work_closed\x22:" as *u8)
  o = ss_catn(out, o, wclosed)
  o = ss_cat(out, o, ",\x22frontier_done\x22:" as *u8)
  o = ss_catn(out, o, fdone)
  o = ss_cat(out, o, ",\x22plane_mutations\x22:" as *u8)
  o = ss_catn(out, o, dmut + wmut)
  o = ss_cat(out, o, "},\x22assumptions\x22:[" as *u8)
  // roi- rows: id metric value basis note; derived only from basis != SET-ME
  var na: i64 = 0
  var derived_min: i64 = 0 - 1
  var need_o: i64 = 0
  let needb: *u8 = sys_mmap(PB_MAGIC_4096)
  var nneed: i64 = 0
  i = 0
  while i < on {
      var le5: i64 = i
      var s5: i64 = 1
      while s5 == 1 { if le5 >= on { s5 = 0 } else { if ob[le5] == (PB_NL as u8) { s5 = 0 } else { le5 = le5 + 1 } } }
      if le5 > i { if pb_cols(ob, i, le5, sp) >= 4 {
          if na > 0 { out[o] = 44 as u8; o = o + 1 }
          o = ss_cat(out, o, "{\x22id\x22:\x22" as *u8)
          o = pb_esc(out, o, ob, sp[0], sp[1])
          o = ss_cat(out, o, "\x22,\x22metric\x22:\x22" as *u8)
          o = pb_esc(out, o, ob, sp[2], sp[3])
          o = ss_cat(out, o, "\x22,\x22value\x22:" as *u8)
          o = ss_catn(out, o, pb_int(ob, sp[4], sp[5]))
          o = ss_cat(out, o, ",\x22basis\x22:\x22" as *u8)
          o = pb_esc(out, o, ob, sp[6], sp[7])
          o = ss_cat(out, o, "\x22}" as *u8)
          na = na + 1
          if pb_sl_eq(ob, sp[6], sp[7], "SET-ME" as *u8) == 1 {
              if nneed > 0 { needb[need_o] = 44 as u8; need_o = need_o + 1 }
              needb[need_o] = 34 as u8
              need_o = need_o + 1
              need_o = pb_esc(needb, need_o, ob, sp[0], sp[1])
              needb[need_o] = 34 as u8
              need_o = need_o + 1
              nneed = nneed + 1
          } else {
              if pb_sl_eq(ob, sp[2], sp[3], "manual_minutes_per_debt" as *u8) == 1 {
                  derived_min = dclosed * pb_int(ob, sp[4], sp[5])
              }
          }
      } }
      i = le5 + 1
  }
  o = ss_cat(out, o, "],\x22derived\x22:{\x22est_minutes_saved_debt_eating\x22:" as *u8)
  if derived_min < 0 { o = ss_cat(out, o, "\x22AWAITING-ASSUMPTION\x22" as *u8) } else { o = ss_catn(out, o, derived_min) }
  o = ss_cat(out, o, "},\x22needs_decision\x22:[" as *u8)
  o = pb_raw(out, o, needb, 0, need_o)
  o = ss_cat(out, o, "]}}" as *u8)
  out[o] = PB_NL as u8
  o = o + 1
  sys_write(1, out, o)
  sys_exit(0)
  return 0
380}
nx_pm_board.nx source

`nx_pm_board.nx` source
