`nx_project.nx` source

↩ module page · 3026 lines · 128039 B
1// nx_project.nx -- NISHI PROJECT: the team + contractor project layer for nishifamily.com/project.
2// Operator 2026-07-09: "get beyond microsoft project and leantime ... work with my team and contractors".
3// COMPOSES the existing substrate rather than re-implementing it: tasks/deps/completions live in the
4// nx_vizsla_plan record plane (tsk:/don: records; plan field == project id). This organ adds the layer
5// the projectmgmt census measured ABSENT:
6//   prj: PROJECT meta (pid, owner, title)
7//   mem: MEMBERSHIP with roles (owner|team|contractor) + data-driven capacity (cap = minutes, or -)
8//   fail-closed ROLE-SCOPED VIEW: owner/team see all tasks; contractor sees ONLY own tasks; a
9//     non-member is DENIED (deny by default -- access is granted by a record, never assumed)
10//   WORKLOAD rollup: per-member open effort vs recorded capacity (over-flag only when cap is data)
11// Task state derives from the plan records: DONE (don: exists) / BLOCKED (a dep lacks don:) / READY.
12// Records (load <file> <prefix> [segid], additive + CID-idempotent):
13//   PROJ <pid> <owner> <title>
14//   MEMBER <pid> <person> <role> <cap|->
15// Commands (pj_cli; built via the _hdl_build wrapper; ARGLESS = selftest gate incl a fork of the
16// REAL blessed nx_vizsla_plan.elf as the independent tsk:/don: writer -- cross-organ compose proof):
17//   load <file> <prefix> [segid] | view <prefix> <pid> <person> | workload <prefix> <pid>
18// expect_exit: 0  license_tier: ORIGINAL
19import "nx_syscalls.nx"
20import "nx_canon_cid.nx"
21import "nx_seg_store.nx"
22const K_MAGIC_1970: i64 = 1970
23const K_MAGIC_146097: i64 = 146097
24const K_MAGIC_719468: i64 = 719468
25const K_MAGIC_2048: i64 = 2048
26const K_MAGIC_1024: i64 = 1024
27const K_MAGIC_65536: i64 = 65536
28const K_MAGIC_146096: i64 = 146096
29const K_MAGIC_1460: i64 = 1460
30const K_MAGIC_36524: i64 = 36524
31
32func pj_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
33func pj_p(s: *u8) -> i64 { sys_write(1, s, pj_slen(s)); return 0 }
34
35func pj_eq(a: *u8, b: *u8) -> i64 {
  var i: i64 = 0
  var go: i64 = 1
  while go == 1 {
      if a[i] != b[i] { return 0 }
      if a[i] == (0 as u8) { return 1 }
      i = i + 1
  }
  return 0
44}
45
46func pj_cmpgt(a: *u8, b: *u8) -> i64 {
  var i: i64 = 0
  var go: i64 = 1
  while go == 1 {
      let ca: i64 = a[i] as i64
      let cb: i64 = b[i] as i64
      if ca > cb { return 1 }
      if ca < cb { return 0 }
      if ca == 0 { return 0 }
      i = i + 1
  }
  return 0
58}
59
60func pj_dup(s: *u8) -> *u8 {
  let n: i64 = pj_slen(s)
  let d: *u8 = sys_mmap(n + 2)
  var i: i64 = 0
  while i <= n { d[i] = s[i]; i = i + 1 }
  return d
66}
67
68func pj_atoi(s: *u8) -> i64 {
  var v: i64 = 0
  var i: i64 = 0
  while s[i] != (0 as u8) {
      let d: i64 = (s[i] as i64) - 48
      if d >= 0 { if d <= 9 { v = v * 10 + d } }
      i = i + 1
  }
  return v
77}
78
79func pj_digits(s: *u8) -> i64 {
  if s[0] == (0 as u8) { return 0 }
  var i: i64 = 0
  while s[i] != (0 as u8) {
      let d: i64 = (s[i] as i64) - 48
      if d < 0 { return 0 }
      if d > 9 { return 0 }
      i = i + 1
  }
  return 1
89}
90
91func pj_isws(c: i64) -> i64 {
  if c == 32 { return 1 }
  if c == 13 { return 1 }
  if c == 9 { return 1 }
  return 0
96}
97
98func pj_tok(b: *u8, off: i64, lend: i64, dst: *u8, cap: i64) -> i64 {
  var p: i64 = off
  var go: i64 = 1
  while go == 1 {
      if p >= lend { go = 0 } else {
          if pj_isws(b[p] as i64) == 1 { p = p + 1 } else { go = 0 }
      }
  }
  var t: i64 = 0
  go = 1
  while go == 1 {
      if p >= lend { go = 0 } else {
          if pj_isws(b[p] as i64) == 1 { go = 0 } else {
              if t < cap - 1 { dst[t] = b[p]; t = t + 1 }
              p = p + 1
          }
      }
  }
  dst[t] = 0 as u8
  return p
118}
119
120func pj_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
124}
125
126func pj_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
137}
138
139func pj_kmemeq(b: *u8, off: i64, n: i64, s: *u8) -> i64 {
  if pj_slen(s) != n { return 0 }
  var i: i64 = 0
  while i < n {
      if b[off + i] != s[i] { return 0 }
      i = i + 1
  }
  return 1
147}
148
149func pj_field(rec: *u8, rl: i64, want: *u8, out: *u8, cap: i64) -> i64 {
  if rl < 8 { return 0 }
  let nf: i64 = ss_r32(rec, 4)
  var off: i64 = 8
  var fi: i64 = 0
  while fi < nf {
      if off + 8 > rl { return 0 }
      let kl: i64 = ss_r32(rec, off)
      let koff: i64 = off + 4
      let vl: i64 = ss_r32(rec, koff + kl)
      let voff: i64 = koff + kl + 4
      if pj_kmemeq(rec, koff, kl, want) == 1 {
          var t: i64 = 0
          while t < vl {
              if t < cap - 1 { out[t] = rec[voff + t] }
              t = t + 1
          }
          if t > cap - 1 { t = cap - 1 }
          out[t] = 0 as u8
          return 1
      }
      off = voff + vl
      fi = fi + 1
  }
  return 0
174}
175
176func pj_iskind(b: *u8, koff: i64, kl: i64, pfx: *u8) -> i64 {
  if kl <= 4 { return 0 }
  return pj_kmemeq(b, koff, 4, pfx)
179}
180
181func pj_find(list: *i64, n: i64, s: *u8) -> i64 {
  var i: i64 = 0
  while i < n {
      if pj_eq(list[i] as *u8, s) == 1 { return i }
      i = i + 1
  }
  return 0 - 1
188}
189
190// civil date "YYYY-MM-DD" -> days since epoch; -1 on malformed (mirrors the proven planner date math)
191func pj_datedays(s: *u8) -> i64 {
  let nums: *i64 = sys_mmap(8 * 4) as *i64
  var nn: i64 = 0
  var cur: i64 = 0
  var indig: i64 = 0
  var i: i64 = 0
  var go: i64 = 1
  while go == 1 {
      let c: i64 = s[i] as i64
      var isd: i64 = 0
      if c >= 48 { if c <= 57 { isd = 1 } }
      if isd == 1 { cur = cur * 10 + (c - 48); indig = 1 }
      if isd == 0 {
          if indig == 1 {
              if nn < 4 { nums[nn] = cur; nn = nn + 1 }
              cur = 0
              indig = 0
          }
      }
      if c == 0 { go = 0 }
      i = i + 1
  }
  if nn != 3 { return 0 - 1 }
  var y: i64 = nums[0]
  let m: i64 = nums[1]
  let d: i64 = nums[2]
  if y < K_MAGIC_1970 { return 0 - 1 }
  if m < 1 { return 0 - 1 }
  if m > 12 { return 0 - 1 }
  if d < 1 { return 0 - 1 }
  if d > 31 { return 0 - 1 }
  if m <= 2 { y = y - 1 }
  let era: i64 = y / 400
  let yoe: i64 = y - era * 400
  var mp: i64 = m - 3
  if m <= 2 { mp = m + 9 }
  let doy: i64 = (153 * mp + 2) / 5 + d - 1
  let doe: i64 = yoe * 365 + yoe / 4 - yoe / 100 + doy
  return era * K_MAGIC_146097 + doe - K_MAGIC_719468
230}
231
232func pj_contains(b: *u8, sz: i64, s: *u8) -> i64 {
  let n: i64 = pj_slen(s)
  if n == 0 { return 1 }
  var i: i64 = 0
  while i + n <= sz {
      var k: i64 = 0
      var hit: i64 = 1
      while k < n {
          if b[i + k] != s[k] { hit = 0; k = n } else { k = k + 1 }
      }
      if hit == 1 { return 1 }
      i = i + 1
  }
  return 0
246}
247
248func pj_wfile(path: *u8, s: *u8) -> i64 {
  let fd: i64 = sys_openat_wr(path, 0x1a4)
  if fd < 0 { return 1 }
  sys_write(fd, s, pj_slen(s))
  sys_close(fd)
  return 0
254}
255
256func pj_starts(s: *u8, pfx: *u8) -> i64 {
  var i: i64 = 0
  while pfx[i] != (0 as u8) {
      if s[i] != pfx[i] { return 0 }
      i = i + 1
  }
  return 1
263}
264
265// boundary guard for MCP callers: store paths live under knowledge/project/ or /tmp/, no dot-dot
266func pj_pathok(s: *u8) -> i64 {
  var i: i64 = 0
  while s[i] != (0 as u8) {
      if s[i] == (46 as u8) { if s[i + 1] == (46 as u8) { return 0 } }
      i = i + 1
  }
  if pj_starts(s, "knowledge/project/" as *u8) == 1 { return 1 }
  if pj_starts(s, "/tmp/" as *u8) == 1 { return 1 }
  return 0
275}
276
277func pj_pathfail() -> i64 {
  pj_p("PROJECT path must live under knowledge/project/ or /tmp/ with no dot-dot -- fail loud\n" as *u8)
  return 1
280}
281
282// content-addressed additive put (mirrors the proven planner writer; CID-idempotent by construction)
283func pj_put(keys: *i64, vals: *i64, nf: i64, kp: *u8, st: *i64) -> i64 {
  let enc: *u8 = sys_mmap(K_MAGIC_2048)
  let el: i64 = canon_encode(keys, vals, nf, enc)
  let cid: *u8 = sys_mmap(96)
  cid_of(enc, el, cid)
  let kbuf: *u8 = sys_mmap(128)
  var ko: i64 = 0
  ko = pj_cat(kbuf, ko, kp)
  ko = pj_cat(kbuf, ko, cid)
  kbuf[ko] = 0 as u8
  let seen: *i64 = st[1] as *i64
  var fresh: i64 = 1
  if pj_find(seen, st[2], kbuf) >= 0 { fresh = 0; st[4] = st[4] + 1 }
  if fresh == 1 {
      if st[2] < K_MAGIC_2048 {
          let dk: *u8 = pj_dup(kbuf)
          seen[st[2]] = dk as i64
          st[2] = st[2] + 1
      }
  }
  if fresh == 1 {
      let pp: *i64 = sys_mmap(16) as *i64
      let ll: *i64 = sys_mmap(16) as *i64
      if ss_get_idx(st[6] as *u8, kbuf, pp, ll) == 1 { fresh = 0; st[5] = st[5] + 1 }
  }
  if fresh == 1 {
      if ss_add(st[0] as *i64, 1, kbuf, enc, el) != 0 { return 0 - 1 }
      st[3] = st[3] + 1
  }
  return 0
313}
314
315// ---------------- LOAD (PROJ / MEMBER lines -> prj: / mem: records) ----------------
316func pj_cmd_load(argc: i64, argv: *i64) -> i64 {
  if argc < 4 { pj_p("PROJECT load needs <file> <prefix> -- fail loud\n" as *u8); return 1 }
  let efile: *u8 = argv[2] as *u8
  let prefix: *u8 = argv[3] as *u8
  if pj_pathok(efile) == 0 { return pj_pathfail() }
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  var segid: i64 = 0
  if argc > 4 { segid = pj_atoi(argv[4] as *u8) }
  if segid == 0 { segid = sys_now_us() }
325
  let szp: *i64 = sys_mmap(16) as *i64
  let b: *u8 = ss_readall(efile, szp)
  let sz: i64 = szp[0]
  if sz <= 0 { pj_p("PROJECT file MISSING/EMPTY -- fail loud\n" as *u8); return 1 }
330
  let pkeys: *i64 = sys_mmap(8 * 8) as *i64
  let pvals: *i64 = sys_mmap(8 * 8) as *i64
  pkeys[0] = "kind" as *u8 as i64
  pkeys[1] = "pid" as *u8 as i64
  pkeys[2] = "owner" as *u8 as i64
  pkeys[3] = "title" as *u8 as i64
  pvals[0] = "prj" as *u8 as i64
  let mkeys: *i64 = sys_mmap(8 * 8) as *i64
  let mvals: *i64 = sys_mmap(8 * 8) as *i64
  mkeys[0] = "kind" as *u8 as i64
  mkeys[1] = "pid" as *u8 as i64
  mkeys[2] = "person" as *u8 as i64
  mkeys[3] = "role" as *u8 as i64
  mkeys[4] = "cap" as *u8 as i64
  mvals[0] = "mem" as *u8 as i64
  let bkeys: *i64 = sys_mmap(8 * 8) as *i64
  let bvals: *i64 = sys_mmap(8 * 8) as *i64
  bkeys[0] = "kind" as *u8 as i64
  bkeys[1] = "pid" as *u8 as i64
  bkeys[2] = "amount" as *u8 as i64
  bvals[0] = "bud" as *u8 as i64
  let ckeys: *i64 = sys_mmap(8 * 8) as *i64
  let cvals: *i64 = sys_mmap(8 * 8) as *i64
  ckeys[0] = "kind" as *u8 as i64
  ckeys[1] = "pid" as *u8 as i64
  ckeys[2] = "tid" as *u8 as i64
  ckeys[3] = "amount" as *u8 as i64
  ckeys[4] = "date" as *u8 as i64
  cvals[0] = "cst" as *u8 as i64
  let wkeys: *i64 = sys_mmap(8 * 8) as *i64
  let wvals: *i64 = sys_mmap(8 * 8) as *i64
  wkeys[0] = "kind" as *u8 as i64
  wkeys[1] = "pid" as *u8 as i64
  wkeys[2] = "mpd" as *u8 as i64
  wkeys[3] = "tight" as *u8 as i64
  wvals[0] = "wcf" as *u8 as i64
  let lkeys: *i64 = sys_mmap(8 * 8) as *i64
  let lvals: *i64 = sys_mmap(8 * 8) as *i64
  lkeys[0] = "kind" as *u8 as i64
  lkeys[1] = "pid" as *u8 as i64
  lkeys[2] = "tid" as *u8 as i64
  lkeys[3] = "person" as *u8 as i64
  lkeys[4] = "date" as *u8 as i64
  lkeys[5] = "min" as *u8 as i64
  lvals[0] = "log" as *u8 as i64
  let nkeys: *i64 = sys_mmap(8 * 8) as *i64
  let nvals: *i64 = sys_mmap(8 * 8) as *i64
  nkeys[0] = "kind" as *u8 as i64
  nkeys[1] = "pid" as *u8 as i64
  nkeys[2] = "tid" as *u8 as i64
  nkeys[3] = "person" as *u8 as i64
  nkeys[4] = "date" as *u8 as i64
  nkeys[5] = "text" as *u8 as i64
  nvals[0] = "not" as *u8 as i64
  let akeys: *i64 = sys_mmap(8 * 8) as *i64
  let avals: *i64 = sys_mmap(8 * 8) as *i64
  akeys[0] = "kind" as *u8 as i64
  akeys[1] = "pid" as *u8 as i64
  akeys[2] = "tid" as *u8 as i64
  akeys[3] = "person" as *u8 as i64
  akeys[4] = "date" as *u8 as i64
  avals[0] = "asg" as *u8 as i64
  let bkeys2: *i64 = sys_mmap(8 * 8) as *i64
  let bvals2: *i64 = sys_mmap(8 * 8) as *i64
  bkeys2[0] = "kind" as *u8 as i64
  bkeys2[1] = "pid" as *u8 as i64
  bkeys2[2] = "tid" as *u8 as i64
  bkeys2[3] = "due" as *u8 as i64
  bkeys2[4] = "effort" as *u8 as i64
  bkeys2[5] = "date" as *u8 as i64
  bvals2[0] = "bas" as *u8 as i64
402
  let st: *i64 = sys_mmap(8 * 8) as *i64
  st[0] = ss_begin() as i64
  st[1] = sys_mmap(8 * K_MAGIC_2048)
  st[2] = 0
  st[3] = 0
  st[4] = 0
  st[5] = 0
  st[6] = prefix as i64
411
  let t0: *u8 = sys_mmap(128)
  let f1: *u8 = sys_mmap(128)
  let f2: *u8 = sys_mmap(128)
  let f3: *u8 = sys_mmap(128)
  let f4: *u8 = sys_mmap(256)
  let f5b: *u8 = sys_mmap(64)
  let txt: *u8 = sys_mmap(256)
  var scanned: i64 = 0
420
  var i: i64 = 0
  while i < sz {
      var e: i64 = i
      var go: i64 = 1
      while go == 1 {
          if e >= sz { go = 0 } else {
              if b[e] == (10 as u8) { go = 0 } else { e = e + 1 }
          }
      }
      var p: i64 = pj_tok(b, i, e, t0, 128)
      if t0[0] == (35 as u8) { t0[0] = 0 as u8 }
      if pj_eq(t0, "PROJ" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f4, 256)
          if f1[0] == (0 as u8) { pj_p("PROJECT PROJ missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT PROJ missing owner -- fail loud\n" as *u8); return 1 }
          if f4[0] == (0 as u8) { pj_p("PROJECT PROJ missing title -- fail loud\n" as *u8); return 1 }
          pvals[1] = f1 as i64
          pvals[2] = f2 as i64
          pvals[3] = f4 as i64
          if pj_put(pkeys, pvals, 4, "prj:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "MEMBER" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          p = pj_tok(b, p, e, f4, 256)
          if f1[0] == (0 as u8) { pj_p("PROJECT MEMBER missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT MEMBER missing person -- fail loud\n" as *u8); return 1 }
          var rok: i64 = 0
          if pj_eq(f3, "owner" as *u8) == 1 { rok = 1 }
          if pj_eq(f3, "team" as *u8) == 1 { rok = 1 }
          if pj_eq(f3, "contractor" as *u8) == 1 { rok = 1 }
          if rok == 0 { pj_p("PROJECT MEMBER role must be owner|team|contractor -- fail loud\n" as *u8); return 1 }
          var cok: i64 = 0
          if f4[0] == (45 as u8) { if f4[1] == (0 as u8) { cok = 1 } }
          if cok == 0 { if pj_digits(f4) == 1 { cok = 1 } }
          if cok == 0 { pj_p("PROJECT MEMBER cap must be minutes or - -- fail loud\n" as *u8); return 1 }
          mvals[1] = f1 as i64
          mvals[2] = f2 as i64
          mvals[3] = f3 as i64
          mvals[4] = f4 as i64
          if pj_put(mkeys, mvals, 5, "mem:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "BUDGET" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          if f1[0] == (0 as u8) { pj_p("PROJECT BUDGET missing pid -- fail loud\n" as *u8); return 1 }
          if pj_digits(f2) == 0 { pj_p("PROJECT BUDGET amount must be cents digits -- fail loud\n" as *u8); return 1 }
          bvals[1] = f1 as i64
          bvals[2] = f2 as i64
          if pj_put(bkeys, bvals, 3, "bud:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "COST" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          p = pj_tok(b, p, e, f4, 256)
          if f1[0] == (0 as u8) { pj_p("PROJECT COST missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT COST missing tid -- fail loud\n" as *u8); return 1 }
          if pj_digits(f3) == 0 { pj_p("PROJECT COST amount must be cents digits -- fail loud\n" as *u8); return 1 }
          if pj_datedays(f4) < 0 { pj_p("PROJECT COST bad date -- fail loud\n" as *u8); return 1 }
          cvals[1] = f1 as i64
          cvals[2] = f2 as i64
          cvals[3] = f3 as i64
          cvals[4] = f4 as i64
          if pj_put(ckeys, cvals, 5, "cst:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "WCONF" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          if f1[0] == (0 as u8) { pj_p("PROJECT WCONF missing pid -- fail loud\n" as *u8); return 1 }
          if pj_digits(f2) == 0 { pj_p("PROJECT WCONF min-per-day must be digits -- fail loud\n" as *u8); return 1 }
          if pj_atoi(f2) < 1 { pj_p("PROJECT WCONF min-per-day must be >= 1 -- fail loud\n" as *u8); return 1 }
          if pj_digits(f3) == 0 { pj_p("PROJECT WCONF tight-days must be digits -- fail loud\n" as *u8); return 1 }
          wvals[1] = f1 as i64
          wvals[2] = f2 as i64
          wvals[3] = f3 as i64
          if pj_put(wkeys, wvals, 4, "wcf:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "LOG" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          p = pj_tok(b, p, e, f4, 256)
          p = pj_tok(b, p, e, f5b, 64)
          if f1[0] == (0 as u8) { pj_p("PROJECT LOG missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT LOG missing tid -- fail loud\n" as *u8); return 1 }
          if f3[0] == (0 as u8) { pj_p("PROJECT LOG missing person -- fail loud\n" as *u8); return 1 }
          if pj_datedays(f4) < 0 { pj_p("PROJECT LOG bad date -- fail loud\n" as *u8); return 1 }
          if pj_digits(f5b) == 0 { pj_p("PROJECT LOG minutes must be digits -- fail loud\n" as *u8); return 1 }
          if pj_atoi(f5b) < 1 { pj_p("PROJECT LOG minutes must be >= 1 -- fail loud\n" as *u8); return 1 }
          lvals[1] = f1 as i64
          lvals[2] = f2 as i64
          lvals[3] = f3 as i64
          lvals[4] = f4 as i64
          lvals[5] = f5b as i64
          if pj_put(lkeys, lvals, 6, "log:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "ASSIGN" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          p = pj_tok(b, p, e, f4, 256)
          if f1[0] == (0 as u8) { pj_p("PROJECT ASSIGN missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT ASSIGN missing tid -- fail loud\n" as *u8); return 1 }
          if f3[0] == (0 as u8) { pj_p("PROJECT ASSIGN missing person -- fail loud\n" as *u8); return 1 }
          if pj_datedays(f4) < 0 { pj_p("PROJECT ASSIGN bad date -- fail loud\n" as *u8); return 1 }
          avals[1] = f1 as i64
          avals[2] = f2 as i64
          avals[3] = f3 as i64
          avals[4] = f4 as i64
          if pj_put(akeys, avals, 5, "asg:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "BASE" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          p = pj_tok(b, p, e, f5b, 64)
          p = pj_tok(b, p, e, f4, 256)
          if f1[0] == (0 as u8) { pj_p("PROJECT BASE missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT BASE missing tid -- fail loud\n" as *u8); return 1 }
          if pj_datedays(f3) < 0 { pj_p("PROJECT BASE bad baseline due date -- fail loud\n" as *u8); return 1 }
          if pj_digits(f5b) == 0 { pj_p("PROJECT BASE effort must be digits -- fail loud\n" as *u8); return 1 }
          if pj_datedays(f4) < 0 { pj_p("PROJECT BASE bad snapshot date -- fail loud\n" as *u8); return 1 }
          bvals2[1] = f1 as i64
          bvals2[2] = f2 as i64
          bvals2[3] = f3 as i64
          bvals2[4] = f5b as i64
          bvals2[5] = f4 as i64
          if pj_put(bkeys2, bvals2, 6, "bas:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      if pj_eq(t0, "NOTE" as *u8) == 1 {
          scanned = scanned + 1
          p = pj_tok(b, p, e, f1, 128)
          p = pj_tok(b, p, e, f2, 128)
          p = pj_tok(b, p, e, f3, 128)
          p = pj_tok(b, p, e, f4, 256)
          if f1[0] == (0 as u8) { pj_p("PROJECT NOTE missing pid -- fail loud\n" as *u8); return 1 }
          if f2[0] == (0 as u8) { pj_p("PROJECT NOTE missing tid -- fail loud\n" as *u8); return 1 }
          if f3[0] == (0 as u8) { pj_p("PROJECT NOTE missing person -- fail loud\n" as *u8); return 1 }
          if pj_datedays(f4) < 0 { pj_p("PROJECT NOTE bad date -- fail loud\n" as *u8); return 1 }
          // text = the rest of the line, whitespace-trimmed both ends (multi-word)
          var ts: i64 = p
          var g1: i64 = 1
          while g1 == 1 {
              if ts >= e { g1 = 0 } else {
                  if pj_isws(b[ts] as i64) == 1 { ts = ts + 1 } else { g1 = 0 }
              }
          }
          var te: i64 = e
          var g2: i64 = 1
          while g2 == 1 {
              if te <= ts { g2 = 0 } else {
                  if pj_isws(b[te - 1] as i64) == 1 { te = te - 1 } else { g2 = 0 }
              }
          }
          var tn: i64 = 0
          while ts < te { if tn < 239 { txt[tn] = b[ts]; tn = tn + 1 } ts = ts + 1 }
          txt[tn] = 0 as u8
          if txt[0] == (0 as u8) { pj_p("PROJECT NOTE missing text -- fail loud\n" as *u8); return 1 }
          nvals[1] = f1 as i64
          nvals[2] = f2 as i64
          nvals[3] = f3 as i64
          nvals[4] = f4 as i64
          nvals[5] = txt as i64
          if pj_put(nkeys, nvals, 6, "not:" as *u8, st) != 0 { pj_p("PROJECT writer full -- fail loud\n" as *u8); return 1 }
      }
      i = e + 1
  }
601
  var committed: i64 = 0
  if st[3] > 0 {
      if ss_commit(prefix, st[0] as *i64, segid) != 0 { pj_p("PROJECT commit FAILED -- fail loud\n" as *u8); return 1 }
      committed = 1
  }
  let rep: *u8 = sys_mmap(K_MAGIC_1024)
  var o: i64 = 0
  o = pj_cat(rep, o, "PROJECT-LOAD scanned=" as *u8)
  o = pj_catn(rep, o, scanned)
  o = pj_cat(rep, o, " new=" as *u8)
  o = pj_catn(rep, o, st[3])
  o = pj_cat(rep, o, " dup_infile=" as *u8)
  o = pj_catn(rep, o, st[4])
  o = pj_cat(rep, o, " dup_instore=" as *u8)
  o = pj_catn(rep, o, st[5])
  o = pj_cat(rep, o, " segment=" as *u8)
  if committed == 1 {
      o = pj_cat(rep, o, "seg-" as *u8)
      o = pj_catn(rep, o, segid)
  } else {
      o = pj_cat(rep, o, "none" as *u8)
  }
  o = pj_cat(rep, o, "\n" as *u8)
  sys_write(1, rep, o)
  return 0
627}
628
629// ---------------- GATHER (prj:/mem: + the planner's tsk:/don: for one project) ----------------
630// st slots: 0=ntask 1=tids 2=towners 3=tdeps 4=tefforts(values) 5=ttitles
631//           6=ndone 7=dtids  8=nmem 9=mpersons 10=mroles 11=mcaps
632//           12=projfound 13=projowner 14=projtitle
633//           15=budfound 16=bud_cents 17=ac_cents_sum 18=wcffound 19=wcf_min_per_day 20=wcf_tight_days
634//           21=tdues  22=nlog 23=ltids 24=lpersons 25=lmins(values)
635//           26=nnote 27=ntids 28=npersons 29=ntexts 30=ndates
636//           31=nasg 32=atids 33=apersons 34=adays(values)  (effective owner = latest ASSIGN wins)
637//           35=ddates(done dates parallel to dtids)  36=nbase 37=btids 38=bdues 39=befforts(values)
638func pj_st_new() -> *i64 {
  let st: *i64 = sys_mmap(8 * 48) as *i64
  st[0] = 0
  st[1] = sys_mmap(8 * 128)
  st[2] = sys_mmap(8 * 128)
  st[3] = sys_mmap(8 * 128)
  st[4] = sys_mmap(8 * 128)
  st[5] = sys_mmap(8 * 128)
  st[6] = 0
  st[7] = sys_mmap(8 * 256)
  st[8] = 0
  st[9] = sys_mmap(8 * 64)
  st[10] = sys_mmap(8 * 64)
  st[11] = sys_mmap(8 * 64)
  st[12] = 0
  st[13] = 0
  st[14] = 0
  st[15] = 0
  st[16] = 0
  st[17] = 0
  st[18] = 0
  st[19] = 0
  st[20] = 0
  st[21] = sys_mmap(8 * 128)
  st[22] = 0
  st[23] = sys_mmap(8 * 256)
  st[24] = sys_mmap(8 * 256)
  st[25] = sys_mmap(8 * 256)
  st[26] = 0
  st[27] = sys_mmap(8 * 128)
  st[28] = sys_mmap(8 * 128)
  st[29] = sys_mmap(8 * 128)
  st[30] = sys_mmap(8 * 128)
  st[31] = 0
  st[32] = sys_mmap(8 * 256)
  st[33] = sys_mmap(8 * 256)
  st[34] = sys_mmap(8 * 256)
  st[35] = sys_mmap(8 * 256)
  st[36] = 0
  st[37] = sys_mmap(8 * 128)
  st[38] = sys_mmap(8 * 128)
  st[39] = sys_mmap(8 * 128)
  return st
681}
682
683func pj_gather(prefix: *u8, pid: *u8, st: *i64) -> i64 {
  let segp: *i64 = sys_mmap(16) as *i64
  let ns: i64 = ss_manifest_dyn(prefix, segp)   // uncapped: sees the WHOLE store
  let segs: *i64 = segp[0] as *i64
  let fp: *u8 = sys_mmap(128)
  let fa: *u8 = sys_mmap(256)
  let fb: *u8 = sys_mmap(256)
  let fc: *u8 = sys_mmap(256)
  let fd2: *u8 = sys_mmap(256)
  let fe: *u8 = sys_mmap(256)
  let fg: *u8 = sys_mmap(256)
  var s: i64 = 0
  while s < ns {
      let path: *u8 = sys_mmap(512)
      var po: i64 = 0
      po = pj_cat(path, po, prefix)
      po = pj_cat(path, po, segs[s] as *u8)
      po = pj_cat(path, po, ".docs" as *u8)
      path[po] = 0 as u8
      let szp: *i64 = sys_mmap(16) as *i64
      let b: *u8 = ss_readall(path, szp)
      let sz: i64 = szp[0]
      var j: i64 = 0
      while j + 9 <= sz {
          let kind: i64 = b[j]
          let kl: i64 = ss_r32(b, j + 1)
          let koff: i64 = j + 5
          let vl: i64 = ss_r32(b, koff + kl)
          let voff: i64 = koff + kl + 4
          let rec: *u8 = (b as i64 + voff) as *u8
          var isprj: i64 = 0
          var ismem: i64 = 0
          var istsk: i64 = 0
          var isdon: i64 = 0
          var isbud: i64 = 0
          var iscst: i64 = 0
          var iswcf: i64 = 0
          var islog: i64 = 0
          var isnot: i64 = 0
          var isasg: i64 = 0
          var isbas: i64 = 0
          if kind == 1 { isprj = pj_iskind(b, koff, kl, "prj:" as *u8) }
          if kind == 1 { ismem = pj_iskind(b, koff, kl, "mem:" as *u8) }
          if kind == 1 { istsk = pj_iskind(b, koff, kl, "tsk:" as *u8) }
          if kind == 1 { isdon = pj_iskind(b, koff, kl, "don:" as *u8) }
          if kind == 1 { isbud = pj_iskind(b, koff, kl, "bud:" as *u8) }
          if kind == 1 { iscst = pj_iskind(b, koff, kl, "cst:" as *u8) }
          if kind == 1 { iswcf = pj_iskind(b, koff, kl, "wcf:" as *u8) }
          if kind == 1 { islog = pj_iskind(b, koff, kl, "log:" as *u8) }
          if kind == 1 { isnot = pj_iskind(b, koff, kl, "not:" as *u8) }
          if kind == 1 { isasg = pj_iskind(b, koff, kl, "asg:" as *u8) }
          if kind == 1 { isbas = pj_iskind(b, koff, kl, "bas:" as *u8) }
          if isprj == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 { if st[12] == 0 {
                  pj_field(rec, vl, "owner" as *u8, fa, 256)
                  pj_field(rec, vl, "title" as *u8, fb, 256)
                  let d1: *u8 = pj_dup(fa)
                  let d2: *u8 = pj_dup(fb)
                  st[13] = d1 as i64
                  st[14] = d2 as i64
                  st[12] = 1
              } } }
          }
          if ismem == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  pj_field(rec, vl, "person" as *u8, fa, 256)
                  let mp: *i64 = st[9] as *i64
                  if pj_find(mp, st[8], fa) < 0 {
                      if st[8] >= 64 { pj_p("PROJECT gather members full -- fail loud\n" as *u8); return 1 }
                      pj_field(rec, vl, "role" as *u8, fb, 256)
                      pj_field(rec, vl, "cap" as *u8, fc, 256)
                      let mr: *i64 = st[10] as *i64
                      let mc: *i64 = st[11] as *i64
                      let n: i64 = st[8]
                      let d1: *u8 = pj_dup(fa)
                      let d2: *u8 = pj_dup(fb)
                      let d3: *u8 = pj_dup(fc)
                      mp[n] = d1 as i64
                      mr[n] = d2 as i64
                      mc[n] = d3 as i64
                      st[8] = n + 1
                  }
              } }
          }
          if istsk == 1 {
              if pj_field(rec, vl, "plan" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  pj_field(rec, vl, "tid" as *u8, fa, 256)
                  let tt: *i64 = st[1] as *i64
                  if pj_find(tt, st[0], fa) < 0 {
                      if st[0] >= 128 { pj_p("PROJECT gather tasks full -- fail loud\n" as *u8); return 1 }
                      pj_field(rec, vl, "owner" as *u8, fb, 256)
                      pj_field(rec, vl, "dep" as *u8, fc, 256)
                      pj_field(rec, vl, "effort" as *u8, fd2, 256)
                      pj_field(rec, vl, "title" as *u8, fe, 256)
                      pj_field(rec, vl, "due" as *u8, fg, 256)
                      let ow: *i64 = st[2] as *i64
                      let dp: *i64 = st[3] as *i64
                      let ef: *i64 = st[4] as *i64
                      let tl: *i64 = st[5] as *i64
                      let du: *i64 = st[21] as *i64
                      let n: i64 = st[0]
                      let d1: *u8 = pj_dup(fa)
                      let d2: *u8 = pj_dup(fb)
                      let d3: *u8 = pj_dup(fc)
                      let d4: *u8 = pj_dup(fe)
                      let d5: *u8 = pj_dup(fg)
                      let ev: i64 = pj_atoi(fd2)
                      tt[n] = d1 as i64
                      ow[n] = d2 as i64
                      dp[n] = d3 as i64
                      ef[n] = ev
                      tl[n] = d4 as i64
                      du[n] = d5 as i64
                      st[0] = n + 1
                  }
              } }
          }
          if isdon == 1 {
              if pj_field(rec, vl, "plan" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  pj_field(rec, vl, "tid" as *u8, fa, 256)
                  let dt: *i64 = st[7] as *i64
                  if pj_find(dt, st[6], fa) < 0 {
                      if st[6] >= 256 { pj_p("PROJECT gather done full -- fail loud\n" as *u8); return 1 }
                      pj_field(rec, vl, "date" as *u8, fb, 256)
                      let dd: *i64 = st[35] as *i64
                      let n: i64 = st[6]
                      let d1: *u8 = pj_dup(fa)
                      dt[n] = d1 as i64
                      dd[n] = pj_datedays(fb)
                      st[6] = n + 1
                  }
              } }
          }
          if isbas == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  if st[36] >= 128 { pj_p("PROJECT gather baseline full -- fail loud\n" as *u8); return 1 }
                  pj_field(rec, vl, "tid" as *u8, fa, 256)
                  let bt: *i64 = st[37] as *i64
                  if pj_find(bt, st[36], fa) < 0 {
                      pj_field(rec, vl, "due" as *u8, fb, 256)
                      pj_field(rec, vl, "effort" as *u8, fc, 256)
                      let bd: *i64 = st[38] as *i64
                      let be: *i64 = st[39] as *i64
                      let n: i64 = st[36]
                      let d1: *u8 = pj_dup(fa)
                      bt[n] = d1 as i64
                      bd[n] = pj_datedays(fb)
                      be[n] = pj_atoi(fc)
                      st[36] = n + 1
                  }
              } }
          }
          if isbud == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 { if st[15] == 0 {
                  pj_field(rec, vl, "amount" as *u8, fa, 256)
                  st[16] = pj_atoi(fa)
                  st[15] = 1
              } } }
          }
          if iscst == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  pj_field(rec, vl, "amount" as *u8, fa, 256)
                  st[17] = st[17] + pj_atoi(fa)
              } }
          }
          if iswcf == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 { if st[18] == 0 {
                  pj_field(rec, vl, "mpd" as *u8, fa, 256)
                  pj_field(rec, vl, "tight" as *u8, fb, 256)
                  st[19] = pj_atoi(fa)
                  st[20] = pj_atoi(fb)
                  if st[19] > 0 { st[18] = 1 }
              } } }
          }
          if islog == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  if st[22] >= 256 { pj_p("PROJECT gather logs full -- fail loud\n" as *u8); return 1 }
                  pj_field(rec, vl, "tid" as *u8, fa, 256)
                  pj_field(rec, vl, "person" as *u8, fb, 256)
                  pj_field(rec, vl, "min" as *u8, fc, 256)
                  let lt: *i64 = st[23] as *i64
                  let lp: *i64 = st[24] as *i64
                  let lm: *i64 = st[25] as *i64
                  let n: i64 = st[22]
                  let d1: *u8 = pj_dup(fa)
                  let d2: *u8 = pj_dup(fb)
                  let mv: i64 = pj_atoi(fc)
                  lt[n] = d1 as i64
                  lp[n] = d2 as i64
                  lm[n] = mv
                  st[22] = n + 1
              } }
          }
          if isasg == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  if st[31] >= 256 { pj_p("PROJECT gather assignments full -- fail loud\n" as *u8); return 1 }
                  pj_field(rec, vl, "tid" as *u8, fa, 256)
                  pj_field(rec, vl, "person" as *u8, fb, 256)
                  pj_field(rec, vl, "date" as *u8, fc, 256)
                  let at2: *i64 = st[32] as *i64
                  let ap2: *i64 = st[33] as *i64
                  let ad2: *i64 = st[34] as *i64
                  let n: i64 = st[31]
                  let d1: *u8 = pj_dup(fa)
                  let d2: *u8 = pj_dup(fb)
                  let dv: i64 = pj_datedays(fc)
                  at2[n] = d1 as i64
                  ap2[n] = d2 as i64
                  ad2[n] = dv
                  st[31] = n + 1
              } }
          }
          if isnot == 1 {
              if pj_field(rec, vl, "pid" as *u8, fp, 128) == 1 { if pj_eq(fp, pid) == 1 {
                  if st[26] >= 128 { pj_p("PROJECT gather notes full -- fail loud\n" as *u8); return 1 }
                  pj_field(rec, vl, "tid" as *u8, fa, 256)
                  pj_field(rec, vl, "person" as *u8, fb, 256)
                  pj_field(rec, vl, "text" as *u8, fd2, 256)
                  pj_field(rec, vl, "date" as *u8, fe, 256)
                  let nt: *i64 = st[27] as *i64
                  let np: *i64 = st[28] as *i64
                  let nx: *i64 = st[29] as *i64
                  let nd: *i64 = st[30] as *i64
                  let n: i64 = st[26]
                  let d1: *u8 = pj_dup(fa)
                  let d2: *u8 = pj_dup(fb)
                  let d3: *u8 = pj_dup(fd2)
                  let d4: *u8 = pj_dup(fe)
                  nt[n] = d1 as i64
                  np[n] = d2 as i64
                  nx[n] = d3 as i64
                  nd[n] = d4 as i64
                  st[26] = n + 1
              } }
          }
          j = voff + vl
      }
      s = s + 1
  }
  // effective owner: the LATEST ASSIGN (by date) overrides the task's authored owner.
  // Tie on date -> lexicographically greater person (deterministic regardless of scan order).
  if st[31] > 0 {
      let tt2: *i64 = st[1] as *i64
      let ow2: *i64 = st[2] as *i64
      let at3: *i64 = st[32] as *i64
      let ap3: *i64 = st[33] as *i64
      let ad3: *i64 = st[34] as *i64
      var ti: i64 = 0
      while ti < st[0] {
          var bestd: i64 = 0 - 1
          var bestp: i64 = 0
          var ai: i64 = 0
          while ai < st[31] {
              if pj_eq(at3[ai] as *u8, tt2[ti] as *u8) == 1 {
                  var take: i64 = 0
                  if ad3[ai] > bestd { take = 1 }
                  if ad3[ai] == bestd { if bestp != 0 { if pj_cmpgt(ap3[ai] as *u8, bestp as *u8) == 1 { take = 1 } } }
                  if take == 1 { bestd = ad3[ai]; bestp = ap3[ai] }
              }
              ai = ai + 1
          }
          if bestp != 0 { ow2[ti] = bestp }
          ti = ti + 1
      }
  }
  return 0
949}
950
951// all deps of a task satisfied? dep field is "-" or "a,b,c"
952func pj_depsok(dep: *u8, dt: *i64, nd: i64) -> i64 {
  if dep[0] == (45 as u8) { if dep[1] == (0 as u8) { return 1 } }
  let nm: *u8 = sys_mmap(128)
  var i: i64 = 0
  var t: i64 = 0
  var go: i64 = 1
  while go == 1 {
      let c: i64 = dep[i] as i64
      var fin: i64 = 0
      if c == 44 { fin = 1 }
      if c == 0 { fin = 1 }
      if fin == 1 {
          nm[t] = 0 as u8
          if t > 0 { if pj_find(dt, nd, nm) < 0 { return 0 } }
          t = 0
          if c == 0 { go = 0 }
      } else {
          if t < 127 { nm[t] = dep[i]; t = t + 1 }
      }
      i = i + 1
  }
  return 1
974}
975
976// 0=READY 1=BLOCKED 2=DONE for task index idx in a gathered st
977func pj_state(st: *i64, idx: i64) -> i64 {
  let tids: *i64 = st[1] as *i64
  let deps: *i64 = st[3] as *i64
  let dt: *i64 = st[7] as *i64
  let nd: i64 = st[6]
  if pj_find(dt, nd, tids[idx] as *u8) >= 0 { return 2 }
  if pj_depsok(deps[idx] as *u8, dt, nd) == 0 { return 1 }
  return 0
985}
986
987// role of person in a gathered st: project owner is implicitly owner; else the mem: record; 0 = none
988func pj_roleof(st: *i64, person: *u8) -> i64 {
  if st[12] == 1 { if pj_eq(st[13] as *u8, person) == 1 { return "owner" as *u8 as i64 } }
  let mp: *i64 = st[9] as *i64
  let mr: *i64 = st[10] as *i64
  let idx: i64 = pj_find(mp, st[8], person)
  if idx >= 0 { return mr[idx] }
  return 0
995}
996
997func pj_statename(v: i64) -> i64 {
  if v == 2 { return "DONE" as *u8 as i64 }
  if v == 1 { return "BLOCKED" as *u8 as i64 }
  return "READY" as *u8 as i64
1001}
1002
1003// ---------------- VIEW (fail-closed role-scoped) ----------------
1004// rc: 0 ok, 1 project not found, 2 access denied. out[0]=total tasks, out[1]=shown
1005func pj_view(prefix: *u8, pid: *u8, person: *u8, out: *i64) -> i64 {
  out[0] = 0
  out[1] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  if st[12] == 0 {
      var o0: i64 = 0
      o0 = pj_cat(rep, o0, "PROJECT-NOTFOUND pid=" as *u8)
      o0 = pj_cat(rep, o0, pid)
      o0 = pj_cat(rep, o0, " -- fail loud\n" as *u8)
      sys_write(1, rep, o0)
      return 1
  }
  let role: i64 = pj_roleof(st, person)
  if role == 0 {
      var o1: i64 = 0
      o1 = pj_cat(rep, o1, "PROJECT-DENY pid=" as *u8)
      o1 = pj_cat(rep, o1, pid)
      o1 = pj_cat(rep, o1, " person=" as *u8)
      o1 = pj_cat(rep, o1, person)
      o1 = pj_cat(rep, o1, " -- not a member, access denied by default\n" as *u8)
      sys_write(1, rep, o1)
      return 2
  }
  var own_only: i64 = 0
  if pj_eq(role as *u8, "contractor" as *u8) == 1 { own_only = 1 }
  var o: i64 = 0
  o = pj_cat(rep, o, "PROJECT-VIEW pid=" as *u8)
  o = pj_cat(rep, o, pid)
  o = pj_cat(rep, o, " title=" as *u8)
  o = pj_cat(rep, o, st[14] as *u8)
  o = pj_cat(rep, o, " person=" as *u8)
  o = pj_cat(rep, o, person)
  o = pj_cat(rep, o, " role=" as *u8)
  o = pj_cat(rep, o, role as *u8)
  o = pj_cat(rep, o, " scope=" as *u8)
  if own_only == 1 { o = pj_cat(rep, o, "own\n" as *u8) } else { o = pj_cat(rep, o, "all\n" as *u8) }
  sys_write(1, rep, o)
  let tids: *i64 = st[1] as *i64
  let owners: *i64 = st[2] as *i64
  let titles: *i64 = st[5] as *i64
  let efforts: *i64 = st[4] as *i64
  var shown: i64 = 0
  var i: i64 = 0
  while i < st[0] {
      var vis: i64 = 1
      if own_only == 1 { if pj_eq(owners[i] as *u8, person) == 0 { vis = 0 } }
      if vis == 1 {
          let sv: i64 = pj_state(st, i)
          let sn: i64 = pj_statename(sv)
          var t: i64 = 0
          t = pj_cat(rep, t, "PROJECT-TASK tid=" as *u8)
          t = pj_cat(rep, t, tids[i] as *u8)
          t = pj_cat(rep, t, " owner=" as *u8)
          t = pj_cat(rep, t, owners[i] as *u8)
          t = pj_cat(rep, t, " state=" as *u8)
          t = pj_cat(rep, t, sn as *u8)
          t = pj_cat(rep, t, " effort_min=" as *u8)
          t = pj_catn(rep, t, efforts[i])
          t = pj_cat(rep, t, " title=" as *u8)
          t = pj_cat(rep, t, titles[i] as *u8)
          t = pj_cat(rep, t, "\n" as *u8)
          sys_write(1, rep, t)
          shown = shown + 1
      }
      i = i + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-VIEW-END total=" as *u8)
  z = pj_catn(rep, z, st[0])
  z = pj_cat(rep, z, " shown=" as *u8)
  z = pj_catn(rep, z, shown)
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  out[0] = st[0]
  out[1] = shown
  return 0
1084}
1085
1086// per-person open effort (not-done tasks owned by person); -1 if project missing
1087func pj_open_min(prefix: *u8, pid: *u8, person: *u8) -> i64 {
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 0 - 1 }
  if st[12] == 0 { return 0 - 1 }
  let owners: *i64 = st[2] as *i64
  let efforts: *i64 = st[4] as *i64
  var sum: i64 = 0
  var i: i64 = 0
  while i < st[0] {
      if pj_eq(owners[i] as *u8, person) == 1 {
          let sv: i64 = pj_state(st, i)
          if sv != 2 { sum = sum + efforts[i] }
      }
      i = i + 1
  }
  return sum
1103}
1104
1105// over-capacity: 1 over, 0 within, -1 no recorded capacity (or not a member)
1106func pj_over(prefix: *u8, pid: *u8, person: *u8) -> i64 {
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 0 - 1 }
  let mp: *i64 = st[9] as *i64
  let mc: *i64 = st[11] as *i64
  let idx: i64 = pj_find(mp, st[8], person)
  if idx < 0 { return 0 - 1 }
  let cap: *u8 = mc[idx] as *u8
  if pj_digits(cap) == 0 { return 0 - 1 }
  let open: i64 = pj_open_min(prefix, pid, person)
  if open > pj_atoi(cap) { return 1 }
  return 0
1118}
1119
1120// task visibility for a person: 1 visible, 0 hidden, -1 no such task, -2 denied
1121func pj_visible(prefix: *u8, pid: *u8, person: *u8, tid: *u8) -> i64 {
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 0 - 2 }
  if st[12] == 0 { return 0 - 2 }
  let role: i64 = pj_roleof(st, person)
  if role == 0 { return 0 - 2 }
  let tids: *i64 = st[1] as *i64
  let idx: i64 = pj_find(tids, st[0], tid)
  if idx < 0 { return 0 - 1 }
  if pj_eq(role as *u8, "contractor" as *u8) == 1 {
      let owners: *i64 = st[2] as *i64
      if pj_eq(owners[idx] as *u8, person) == 0 { return 0 }
  }
  return 1
1135}
1136
1137// per-task state by id: -1 missing, else pj_state code
1138func pj_task_state(prefix: *u8, pid: *u8, tid: *u8) -> i64 {
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 0 - 1 }
  let tids: *i64 = st[1] as *i64
  let idx: i64 = pj_find(tids, st[0], tid)
  if idx < 0 { return 0 - 1 }
  return pj_state(st, idx)
1145}
1146
1147// open critical-chain minutes to finish task idx (own effort + deepest unfinished dep chain);
1148// -1 = dependency cycle (loud upstream). Done tasks contribute 0.
1149func pj_chain_min(st: *i64, idx: i64, depth: i64) -> i64 {
  if depth > st[0] { return 0 - 1 }
  if pj_state(st, idx) == 2 { return 0 }
  let tids: *i64 = st[1] as *i64
  let deps: *i64 = st[3] as *i64
  let efforts: *i64 = st[4] as *i64
  let dep: *u8 = deps[idx] as *u8
  var mx: i64 = 0
  var isdash: i64 = 0
  if dep[0] == (45 as u8) { if dep[1] == (0 as u8) { isdash = 1 } }
  if isdash == 0 {
      let nm: *u8 = sys_mmap(128)
      var i: i64 = 0
      var t: i64 = 0
      var go: i64 = 1
      while go == 1 {
          let c: i64 = dep[i] as i64
          var fin: i64 = 0
          if c == 44 { fin = 1 }
          if c == 0 { fin = 1 }
          if fin == 1 {
              nm[t] = 0 as u8
              if t > 0 {
                  let di: i64 = pj_find(tids, st[0], nm)
                  if di >= 0 {
                      let cm: i64 = pj_chain_min(st, di, depth + 1)
                      if cm < 0 { return 0 - 1 }
                      if cm > mx { mx = cm }
                  }
              }
              t = 0
              if c == 0 { go = 0 }
          } else {
              if t < 127 { nm[t] = dep[i]; t = t + 1 }
          }
          i = i + 1
      }
  }
  return efforts[idx] + mx
1188}
1189
1190// ---------------- LEVEL (workload leveling; aply="-" = advisory, aply=<date> = APPLY as ASSIGN records) ----------------
1191// out[0]=moves, out[1]=members still over capacity after the moves
1192func pj_cmd_level(prefix: *u8, pid: *u8, out: *i64, aply: *u8) -> i64 {
  out[0] = 0
  out[1] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  var apdays: i64 = 0 - 1
  if pj_eq(aply, "-" as *u8) == 0 {
      apdays = pj_datedays(aply)
      if apdays < 0 { pj_p("PROJECT level apply bad date -- fail loud\n" as *u8); return 1 }
  }
  let akeys2: *i64 = sys_mmap(8 * 8) as *i64
  let avals2: *i64 = sys_mmap(8 * 8) as *i64
  akeys2[0] = "kind" as *u8 as i64
  akeys2[1] = "pid" as *u8 as i64
  akeys2[2] = "tid" as *u8 as i64
  akeys2[3] = "person" as *u8 as i64
  akeys2[4] = "date" as *u8 as i64
  avals2[0] = "asg" as *u8 as i64
  let ast: *i64 = sys_mmap(8 * 8) as *i64
  if apdays >= 0 {
      ast[0] = ss_begin() as i64
      ast[1] = sys_mmap(8 * K_MAGIC_2048)
      ast[2] = 0
      ast[3] = 0
      ast[4] = 0
      ast[5] = 0
      ast[6] = prefix as i64
  }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  if st[12] == 0 {
      var o0: i64 = 0
      o0 = pj_cat(rep, o0, "PROJECT-NOTFOUND pid=" as *u8)
      o0 = pj_cat(rep, o0, pid)
      o0 = pj_cat(rep, o0, " -- fail loud\n" as *u8)
      sys_write(1, rep, o0)
      return 1
  }
  let mp: *i64 = st[9] as *i64
  let mc: *i64 = st[11] as *i64
  let owners: *i64 = st[2] as *i64
  let efforts: *i64 = st[4] as *i64
  let tids: *i64 = st[1] as *i64
  let tst: *i64 = sys_mmap(8 * 128) as *i64
  var i: i64 = 0
  while i < st[0] {
      let sv: i64 = pj_state(st, i)
      tst[i] = sv
      i = i + 1
  }
  let loads: *i64 = sys_mmap(8 * 64) as *i64
  var m: i64 = 0
  while m < st[8] {
      var sum: i64 = 0
      i = 0
      while i < st[0] {
          if pj_eq(owners[i] as *u8, mp[m] as *u8) == 1 { if tst[i] != 2 { sum = sum + efforts[i] } }
          i = i + 1
      }
      loads[m] = sum
      m = m + 1
  }
  let moved: *i64 = sys_mmap(8 * 128) as *i64
  var moves: i64 = 0
  m = 0
  while m < st[8] {
      var capm: i64 = 0 - 1
      if pj_digits(mc[m] as *u8) == 1 { capm = pj_atoi(mc[m] as *u8) }
      if capm >= 0 {
          var moving: i64 = 1
          var giter: i64 = 0
          while moving == 1 {
              if loads[m] <= capm { moving = 0 } else {
                  giter = giter + 1
                  if giter > st[0] + 1 { moving = 0 } else {
                      var found: i64 = 0 - 1
                      i = 0
                      while i < st[0] {
                          if found < 0 { if moved[i] == 0 { if tst[i] == 0 { if pj_eq(owners[i] as *u8, mp[m] as *u8) == 1 { found = i } } } }
                          i = i + 1
                      }
                      if found < 0 {
                          var s1: i64 = 0
                          s1 = pj_cat(rep, s1, "PROJECT-LEVEL-STUCK person=" as *u8)
                          s1 = pj_cat(rep, s1, mp[m] as *u8)
                          s1 = pj_cat(rep, s1, " over_min=" as *u8)
                          s1 = pj_catn(rep, s1, loads[m] - capm)
                          s1 = pj_cat(rep, s1, " -- no READY task to move (blocked work cannot be leveled)\n" as *u8)
                          sys_write(1, rep, s1)
                          moving = 0
                      } else {
                          let e: i64 = efforts[found]
                          var best: i64 = 0 - 1
                          var besthr: i64 = 0 - 1
                          var t2: i64 = 0
                          while t2 < st[8] {
                              if t2 != m { if pj_digits(mc[t2] as *u8) == 1 {
                                  let hr: i64 = pj_atoi(mc[t2] as *u8) - loads[t2]
                                  if hr >= e { if hr > besthr { best = t2; besthr = hr } }
                              } }
                              t2 = t2 + 1
                          }
                          if best < 0 {
                              moved[found] = 1
                              var s2: i64 = 0
                              s2 = pj_cat(rep, s2, "PROJECT-LEVEL-NOTARGET tid=" as *u8)
                              s2 = pj_cat(rep, s2, tids[found] as *u8)
                              s2 = pj_cat(rep, s2, " -- no member has recorded headroom for it\n" as *u8)
                              sys_write(1, rep, s2)
                          } else {
                              var s3: i64 = 0
                              s3 = pj_cat(rep, s3, "PROJECT-LEVEL move tid=" as *u8)
                              s3 = pj_cat(rep, s3, tids[found] as *u8)
                              s3 = pj_cat(rep, s3, " from=" as *u8)
                              s3 = pj_cat(rep, s3, mp[m] as *u8)
                              s3 = pj_cat(rep, s3, " to=" as *u8)
                              s3 = pj_cat(rep, s3, mp[best] as *u8)
                              s3 = pj_cat(rep, s3, " effort_min=" as *u8)
                              s3 = pj_catn(rep, s3, e)
                              s3 = pj_cat(rep, s3, "\n" as *u8)
                              sys_write(1, rep, s3)
                              if apdays >= 0 {
                                  avals2[1] = pid as i64
                                  avals2[2] = tids[found]
                                  avals2[3] = mp[best]
                                  avals2[4] = aply as i64
                                  if pj_put(akeys2, avals2, 5, "asg:" as *u8, ast) != 0 { pj_p("PROJECT level apply writer full -- fail loud\n" as *u8); return 1 }
                              }
                              loads[m] = loads[m] - e
                              loads[best] = loads[best] + e
                              moved[found] = 1
                              moves = moves + 1
                          }
                      }
                  }
              }
          }
      }
      m = m + 1
  }
  var over_after: i64 = 0
  m = 0
  while m < st[8] {
      if pj_digits(mc[m] as *u8) == 1 { if loads[m] > pj_atoi(mc[m] as *u8) { over_after = over_after + 1 } }
      m = m + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-LEVEL-END moves=" as *u8)
  z = pj_catn(rep, z, moves)
  z = pj_cat(rep, z, " over_after=" as *u8)
  z = pj_catn(rep, z, over_after)
  if apdays >= 0 { z = pj_cat(rep, z, " mode=APPLY\n" as *u8) } else { z = pj_cat(rep, z, " mode=advisory (records untouched)\n" as *u8) }
  sys_write(1, rep, z)
  if apdays >= 0 {
      if ast[3] > 0 {
          if ss_commit(prefix, ast[0] as *i64, sys_now_us()) != 0 { pj_p("PROJECT level apply commit FAILED -- fail loud\n" as *u8); return 1 }
      }
      var z2: i64 = 0
      z2 = pj_cat(rep, z2, "PROJECT-LEVEL-APPLIED assigns=" as *u8)
      z2 = pj_catn(rep, z2, ast[3])
      z2 = pj_cat(rep, z2, " date=" as *u8)
      z2 = pj_cat(rep, z2, aply)
      z2 = pj_cat(rep, z2, " -- ASSIGN records on the additive plane (latest wins)\n" as *u8)
      sys_write(1, rep, z2)
  }
  out[0] = moves
  out[1] = over_after
  return 0
1360}
1361
1362// ---------------- RISK (register + delay prediction; duration risk only when WCONF is recorded) ----------------
1363// out: 0=overdue 1=late 2=tight 3=ok 4=unrated
1364func pj_cmd_risk(prefix: *u8, pid: *u8, today: *u8, out: *i64) -> i64 {
  out[0] = 0
  out[1] = 0
  out[2] = 0
  out[3] = 0
  out[4] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let td: i64 = pj_datedays(today)
  if td < 0 { pj_p("PROJECT risk bad today date -- fail loud\n" as *u8); return 1 }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  if st[12] == 0 {
      var o0: i64 = 0
      o0 = pj_cat(rep, o0, "PROJECT-NOTFOUND pid=" as *u8)
      o0 = pj_cat(rep, o0, pid)
      o0 = pj_cat(rep, o0, " -- fail loud\n" as *u8)
      sys_write(1, rep, o0)
      return 1
  }
  let tids: *i64 = st[1] as *i64
  let dues: *i64 = st[21] as *i64
  var i: i64 = 0
  while i < st[0] {
      let sv: i64 = pj_state(st, i)
      if sv != 2 {
          let dd: i64 = pj_datedays(dues[i] as *u8)
          if dd < 0 { pj_p("PROJECT risk bad stored due date -- fail loud\n" as *u8); return 1 }
          let dl: i64 = dd - td
          var t: i64 = 0
          t = pj_cat(rep, t, "PROJECT-RISK tid=" as *u8)
          t = pj_cat(rep, t, tids[i] as *u8)
          t = pj_cat(rep, t, " due=" as *u8)
          t = pj_cat(rep, t, dues[i] as *u8)
          t = pj_cat(rep, t, " days_left=" as *u8)
          t = pj_catn(rep, t, dl)
          if dl < 0 {
              out[0] = out[0] + 1
              t = pj_cat(rep, t, " level=OVERDUE" as *u8)
          } else {
              if st[18] == 1 {
                  let cm: i64 = pj_chain_min(st, i, 0)
                  if cm < 0 { pj_p("\nPROJECT-RISK-CYCLE dependency cycle -- fail loud\n" as *u8); return 1 }
                  let dn: i64 = (cm + st[19] - 1) / st[19]
                  let slack: i64 = dl - dn
                  t = pj_cat(rep, t, " chain_min=" as *u8)
                  t = pj_catn(rep, t, cm)
                  t = pj_cat(rep, t, " days_needed=" as *u8)
                  t = pj_catn(rep, t, dn)
                  t = pj_cat(rep, t, " slack_days=" as *u8)
                  t = pj_catn(rep, t, slack)
                  if slack < 0 {
                      out[1] = out[1] + 1
                      t = pj_cat(rep, t, " level=LATE" as *u8)
                  } else {
                      if slack <= st[20] {
                          out[2] = out[2] + 1
                          t = pj_cat(rep, t, " level=TIGHT" as *u8)
                      } else {
                          out[3] = out[3] + 1
                          t = pj_cat(rep, t, " level=OK" as *u8)
                      }
                  }
              } else {
                  out[4] = out[4] + 1
                  t = pj_cat(rep, t, " level=UNRATED (no WCONF min-per-day recorded)" as *u8)
              }
          }
          t = pj_cat(rep, t, "\n" as *u8)
          sys_write(1, rep, t)
      }
      i = i + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-RISK-END overdue=" as *u8)
  z = pj_catn(rep, z, out[0])
  z = pj_cat(rep, z, " late=" as *u8)
  z = pj_catn(rep, z, out[1])
  z = pj_cat(rep, z, " tight=" as *u8)
  z = pj_catn(rep, z, out[2])
  z = pj_cat(rep, z, " ok=" as *u8)
  z = pj_catn(rep, z, out[3])
  z = pj_cat(rep, z, " unrated=" as *u8)
  z = pj_catn(rep, z, out[4])
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  return 0
1451}
1452
1453// ---------------- EVM (budget / cost / earned value; integer permil, no floats) ----------------
1454// out: 0=scope_done_permil 1=cpi_permil(-1 when no spend) 2=over_budget
1455func pj_cmd_evm(prefix: *u8, pid: *u8, out: *i64) -> i64 {
  out[0] = 0
  out[1] = 0 - 1
  out[2] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_1024)
  if st[12] == 0 {
      var o0: i64 = 0
      o0 = pj_cat(rep, o0, "PROJECT-NOTFOUND pid=" as *u8)
      o0 = pj_cat(rep, o0, pid)
      o0 = pj_cat(rep, o0, " -- fail loud\n" as *u8)
      sys_write(1, rep, o0)
      return 1
  }
  if st[15] == 0 { pj_p("PROJECT evm: no BUDGET recorded for this project -- fail loud\n" as *u8); return 1 }
  let efforts: *i64 = st[4] as *i64
  var total: i64 = 0
  var done: i64 = 0
  var i: i64 = 0
  while i < st[0] {
      total = total + efforts[i]
      let sv: i64 = pj_state(st, i)
      if sv == 2 { done = done + efforts[i] }
      i = i + 1
  }
  if total == 0 { pj_p("PROJECT evm: no tasks recorded -- fail loud\n" as *u8); return 1 }
  let scope: i64 = done * 1000 / total
  let bac: i64 = st[16]
  let ac: i64 = st[17]
  let ev: i64 = bac * scope / 1000
  var cpi: i64 = 0 - 1
  if ac > 0 { cpi = ev * 1000 / ac }
  var over: i64 = 0
  if ac > bac { over = 1 }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-EVM bac_cents=" as *u8)
  z = pj_catn(rep, z, bac)
  z = pj_cat(rep, z, " ac_cents=" as *u8)
  z = pj_catn(rep, z, ac)
  z = pj_cat(rep, z, " scope_done_permil=" as *u8)
  z = pj_catn(rep, z, scope)
  z = pj_cat(rep, z, " earned_value_cents=" as *u8)
  z = pj_catn(rep, z, ev)
  z = pj_cat(rep, z, " cpi_permil=" as *u8)
  if cpi < 0 { z = pj_cat(rep, z, "-" as *u8) } else { z = pj_catn(rep, z, cpi) }
  z = pj_cat(rep, z, " over_budget=" as *u8)
  z = pj_catn(rep, z, over)
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  out[0] = scope
  out[1] = cpi
  out[2] = over
  return 0
1510}
1511
1512// ---------------- HTML (organ-emitted 0-JS scoped page; the /project surface) ----------------
1513// pj_head/pj_foot = the shared APP SHELL at the fleet UI bar (feedback-ui-quality-is-not-presence):
1514// canonical --nx- tokens + dark mode (prefers-color-scheme) + clamp() fluid type + skip-link +
1515// header/nav/main landmarks + :focus-visible + reduced-motion + entrance stagger + tablewrap
1516// (wide tables scroll INSIDE their container -- the page body never scrolls sideways on a phone).
1517func pj_head(hb: *u8, o0: i64, title: *u8) -> i64 {
  var o: i64 = o0
  o = pj_cat(hb, o, "<" as *u8)
  hb[o] = 33 as u8
  o = o + 1
  o = pj_cat(hb, o, "DOCTYPE html><html lang=\"en\"><head><meta charset='utf-8'><meta name='viewport' content='width=device-width, initial-scale=1'><title>" as *u8)
  o = pj_cat(hb, o, title)
  o = pj_cat(hb, o, "</title><style>:root{--nx-color-bg:rgb(247,248,250);--nx-color-surface:rgb(255,255,255);--nx-color-ink:rgb(24,28,35);--nx-color-muted:rgb(95,102,112);--nx-color-line:rgb(216,220,228);--nx-color-accent:rgb(11,84,196);--nx-color-ok:rgb(18,122,62);--nx-color-warn:rgb(176,108,14);--nx-color-bad:rgb(178,38,38);--nx-radius:10px}@media (prefers-color-scheme:dark){:root{--nx-color-bg:rgb(16,18,22);--nx-color-surface:rgb(26,29,35);--nx-color-ink:rgb(232,235,240);--nx-color-muted:rgb(150,157,167);--nx-color-line:rgb(58,63,72);--nx-color-accent:rgb(112,164,248);--nx-color-ok:rgb(96,196,136);--nx-color-warn:rgb(230,174,84);--nx-color-bad:rgb(240,126,126)}}*{box-sizing:border-box}body{font-family:system-ui,sans-serif;background:var(--nx-color-bg);color:var(--nx-color-ink);margin:0;font-size:clamp(15px,1vw + 12px,17px);line-height:1.55}.skip-link{position:absolute;left:-999px;top:0;background:var(--nx-color-accent);color:rgb(255,255,255);padding:12px 16px;border-radius:0 0 8px 0;z-index:9}.skip-link:focus{left:0}.hd{background:linear-gradient(90deg,var(--nx-color-accent),rgb(9,58,136))}.hd nav{display:flex;align-items:center;gap:10px;max-width:1040px;margin:0 auto;padding:8px clamp(12px,4vw,28px)}.hd a{color:rgb(255,255,255);text-decoration:none;padding:10px 14px;border-radius:8px;font-weight:600;min-height:44px;display:inline-flex;align-items:center}.hd a:hover{background:rgba(255,255,255,0.16)}.hd svg{color:rgb(255,255,255)}main{max-width:1040px;margin:0 auto;padding:clamp(14px,3vw,28px)}h1{font-size:clamp(22px,3vw,30px);margin:12px 0 6px}h2{font-size:clamp(16px,2vw,19px);margin:26px 0 8px}.meta{color:var(--nx-color-muted);font-size:13px}.tablewrap{overflow-x:auto;background:var(--nx-color-surface);border:1px solid var(--nx-color-line);border-radius:var(--nx-radius);box-shadow:0 1px 3px rgba(16,20,28,0.08)}table{border-collapse:collapse;width:100%;min-width:640px}td,th{border-bottom:1px solid var(--nx-color-line);padding:10px 12px;text-align:left;font-size:14px}th{color:var(--nx-color-muted);font-weight:600;text-transform:uppercase;font-size:12px;letter-spacing:0.4px}tr:hover td{background:rgba(11,84,196,0.06)}.DONE{color:var(--nx-color-ok);font-weight:700}.BLOCKED{color:var(--nx-color-bad);font-weight:700}.READY{color:var(--nx-color-accent);font-weight:700}.warn{color:var(--nx-color-warn);font-weight:700}@keyframes rise{from{opacity:0;transform:translateY(8px)}to{opacity:1;transform:none}}main>*{animation:rise 0.5s ease both}main>*:nth-child(2){animation-delay:0.05s}main>*:nth-child(3){animation-delay:0.1s}main>*:nth-child(4){animation-delay:0.15s}main>*:nth-child(5){animation-delay:0.2s}@media (prefers-reduced-motion:reduce){main>*{animation:none}}:focus-visible{outline:3px solid var(--nx-color-accent);outline-offset:2px}.gr{display:flex;align-items:center;margin:6px 0}.gl{width:70px;font-size:12px;color:var(--nx-color-muted)}.gwrap{flex:1;background:var(--nx-color-surface);border:1px solid var(--nx-color-line);border-radius:6px}.gb{height:14px;border-radius:6px}.gbR{background:var(--nx-color-accent)}.gbB{background:var(--nx-color-bad)}.gbD{background:var(--nx-color-ok)}a.card{display:block;padding:16px;margin:10px 0;background:var(--nx-color-surface);border:1px solid var(--nx-color-line);border-radius:var(--nx-radius);color:var(--nx-color-ink);text-decoration:none;box-shadow:0 1px 3px rgba(16,20,28,0.08)}a.card:hover{border-color:var(--nx-color-accent);box-shadow:0 4px 14px rgba(11,84,196,0.15)}@media (max-width:720px){td,th{padding:8px;font-size:13px}.gl{width:52px}}</style></head><body><a class='skip-link' href='" as *u8)
  hb[o] = 35 as u8
  o = o + 1
  o = pj_cat(hb, o, "main'>Skip to content</a><header class='hd'><nav><svg viewBox='0 0 24 24' width='22' height='22' aria-hidden='true'><circle cx='12' cy='12' r='9' fill='none' stroke='currentColor' stroke-width='2'/><path d='M7 12h10M12 7v10' stroke='currentColor' stroke-width='2'/></svg><a href='/project'>Projects</a><a href='/project/demo'>Demo</a></nav></header><main id='main'>" as *u8)
  return o
1529}
1530
1531func pj_foot(hb: *u8, o0: i64) -> i64 {
  var o: i64 = o0
  o = pj_cat(hb, o, "<p class='meta'>Generated by nx_project - sovereign 0-JS - additive never-lose records - access is role-scoped fail-closed</p></main></body></html>" as *u8)
  return o
1535}
1536// build the page into caller buffer hb; returns length, or -1 notfound, -2 deny, -3 bad path/date.
1537// SILENT on failure (the gateway daemon chooses the HTTP response); the CLI wrapper prints loud.
1538func pj_html_build(prefix: *u8, pid: *u8, person: *u8, today: *u8, hb: *u8) -> i64 {
  if pj_pathok(prefix) == 0 { return 0 - 3 }
  let td: i64 = pj_datedays(today)
  if td < 0 { return 0 - 3 }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 0 - 1 }
  if st[12] == 0 { return 0 - 1 }
  let role: i64 = pj_roleof(st, person)
  if role == 0 { return 0 - 2 }
  var own_only: i64 = 0
  if pj_eq(role as *u8, "contractor" as *u8) == 1 { own_only = 1 }
  let ttl: *u8 = sys_mmap(256)
  var to: i64 = 0
  to = pj_cat(ttl, to, "Nishi Project - " as *u8)
  to = pj_cat(ttl, to, pid)
  ttl[to] = 0 as u8
  var o: i64 = 0
  o = pj_head(hb, o, ttl)
  o = pj_cat(hb, o, "<h1>Nishi Project - " as *u8)
  o = pj_cat(hb, o, st[14] as *u8)
  o = pj_cat(hb, o, "</h1><p class='meta'>project=" as *u8)
  o = pj_cat(hb, o, pid)
  o = pj_cat(hb, o, " viewer=" as *u8)
  o = pj_cat(hb, o, person)
  o = pj_cat(hb, o, " role=" as *u8)
  o = pj_cat(hb, o, role as *u8)
  o = pj_cat(hb, o, " scope=" as *u8)
  if own_only == 1 { o = pj_cat(hb, o, "own-tasks-only" as *u8) } else { o = pj_cat(hb, o, "all-tasks" as *u8) }
  o = pj_cat(hb, o, " as-of=" as *u8)
  o = pj_cat(hb, o, today)
  o = pj_cat(hb, o, "</p><h2>Tasks</h2><div class='tablewrap'><table><tr><th>task</th><th>owner</th><th>state</th><th>due</th><th>days left</th><th>risk</th><th>effort min</th><th>title</th></tr>" as *u8)
  let tids: *i64 = st[1] as *i64
  let owners: *i64 = st[2] as *i64
  let titles: *i64 = st[5] as *i64
  let efforts: *i64 = st[4] as *i64
  let dues: *i64 = st[21] as *i64
  var r_ov: i64 = 0
  var r_la: i64 = 0
  var r_ti: i64 = 0
  var r_ok: i64 = 0
  var i: i64 = 0
  while i < st[0] {
      var vis: i64 = 1
      if own_only == 1 { if pj_eq(owners[i] as *u8, person) == 0 { vis = 0 } }
      if vis == 1 {
          let sv: i64 = pj_state(st, i)
          let sn: i64 = pj_statename(sv)
          o = pj_cat(hb, o, "<tr><td>" as *u8)
          o = pj_cat(hb, o, tids[i] as *u8)
          o = pj_cat(hb, o, "</td><td>" as *u8)
          o = pj_cat(hb, o, owners[i] as *u8)
          o = pj_cat(hb, o, "</td><td class='" as *u8)
          o = pj_cat(hb, o, sn as *u8)
          o = pj_cat(hb, o, "'>" as *u8)
          o = pj_cat(hb, o, sn as *u8)
          o = pj_cat(hb, o, "</td><td>" as *u8)
          o = pj_cat(hb, o, dues[i] as *u8)
          o = pj_cat(hb, o, "</td><td>" as *u8)
          let dd: i64 = pj_datedays(dues[i] as *u8)
          if dd >= 0 { o = pj_catn(hb, o, dd - td) } else { o = pj_cat(hb, o, "-" as *u8) }
          o = pj_cat(hb, o, "</td><td>" as *u8)
          // risk cell: OVERDUE by pure dates; LATE/TIGHT/OK by chain-slack when WCONF is recorded
          var rlvl: i64 = 0 - 1
          if sv != 2 { if dd >= 0 {
              let dl2: i64 = dd - td
              if dl2 < 0 { rlvl = 3 } else {
                  if st[18] == 1 {
                      let cm: i64 = pj_chain_min(st, i, 0)
                      if cm < 0 { rlvl = 4 } else {
                          let dnd: i64 = (cm + st[19] - 1) / st[19]
                          let sl: i64 = dl2 - dnd
                          if sl < 0 { rlvl = 2 } else {
                              if sl <= st[20] { rlvl = 1 } else { rlvl = 0 }
                          }
                      }
                  }
              }
          } }
          if rlvl == 0 { r_ok = r_ok + 1; o = pj_cat(hb, o, "OK" as *u8) }
          if rlvl == 1 { r_ti = r_ti + 1; o = pj_cat(hb, o, "<span class='warn'>TIGHT</span>" as *u8) }
          if rlvl == 2 { r_la = r_la + 1; o = pj_cat(hb, o, "<span class='BLOCKED'>LATE</span>" as *u8) }
          if rlvl == 3 { r_ov = r_ov + 1; o = pj_cat(hb, o, "<span class='BLOCKED'>OVERDUE</span>" as *u8) }
          if rlvl == 4 { o = pj_cat(hb, o, "<span class='BLOCKED'>CYCLE</span>" as *u8) }
          if rlvl < 0 { o = pj_cat(hb, o, "-" as *u8) }
          o = pj_cat(hb, o, "</td><td>" as *u8)
          o = pj_catn(hb, o, efforts[i])
          o = pj_cat(hb, o, "</td><td>" as *u8)
          o = pj_cat(hb, o, titles[i] as *u8)
          o = pj_cat(hb, o, "</td></tr>" as *u8)
      }
      i = i + 1
  }
  if st[18] == 1 {
      o = pj_cat(hb, o, "</table></div><p class='meta'>risk: overdue=" as *u8)
      o = pj_catn(hb, o, r_ov)
      o = pj_cat(hb, o, " late=" as *u8)
      o = pj_catn(hb, o, r_la)
      o = pj_cat(hb, o, " tight=" as *u8)
      o = pj_catn(hb, o, r_ti)
      o = pj_cat(hb, o, " ok=" as *u8)
      o = pj_catn(hb, o, r_ok)
      o = pj_cat(hb, o, " (chain-slack vs WCONF " as *u8)
      o = pj_catn(hb, o, st[19])
      o = pj_cat(hb, o, " min/day, tight band " as *u8)
      o = pj_catn(hb, o, st[20])
      o = pj_cat(hb, o, " days)</p><h2>Workload</h2><div class='tablewrap'><table><tr><th>person</th><th>role</th><th>open min</th><th>cap min</th><th>over</th></tr>" as *u8)
  } else {
      o = pj_cat(hb, o, "</table></div><h2>Workload</h2><div class='tablewrap'><table><tr><th>person</th><th>role</th><th>open min</th><th>cap min</th><th>over</th></tr>" as *u8)
  }
  let mp: *i64 = st[9] as *i64
  let mr: *i64 = st[10] as *i64
  let mc: *i64 = st[11] as *i64
  var m: i64 = 0
  while m < st[8] {
      var sum: i64 = 0
      i = 0
      while i < st[0] {
          if pj_eq(owners[i] as *u8, mp[m] as *u8) == 1 {
              let sv2: i64 = pj_state(st, i)
              if sv2 != 2 { sum = sum + efforts[i] }
          }
          i = i + 1
      }
      o = pj_cat(hb, o, "<tr><td>" as *u8)
      o = pj_cat(hb, o, mp[m] as *u8)
      o = pj_cat(hb, o, "</td><td>" as *u8)
      o = pj_cat(hb, o, mr[m] as *u8)
      o = pj_cat(hb, o, "</td><td>" as *u8)
      o = pj_catn(hb, o, sum)
      o = pj_cat(hb, o, "</td><td>" as *u8)
      o = pj_cat(hb, o, mc[m] as *u8)
      o = pj_cat(hb, o, "</td><td>" as *u8)
      var overm: i64 = 0 - 1
      if pj_digits(mc[m] as *u8) == 1 {
          overm = 0
          if sum > pj_atoi(mc[m] as *u8) { overm = 1 }
      }
      if overm == 1 { o = pj_cat(hb, o, "<span class='BLOCKED'>over</span>" as *u8) }
      if overm == 0 { o = pj_cat(hb, o, "within" as *u8) }
      if overm < 0 { o = pj_cat(hb, o, "-" as *u8) }
      o = pj_cat(hb, o, "</td></tr>" as *u8)
      m = m + 1
  }
  o = pj_cat(hb, o, "</table></div>" as *u8)
  if st[15] == 1 {
      let efforts2: *i64 = st[4] as *i64
      var total: i64 = 0
      var done: i64 = 0
      i = 0
      while i < st[0] {
          total = total + efforts2[i]
          let sv3: i64 = pj_state(st, i)
          if sv3 == 2 { done = done + efforts2[i] }
          i = i + 1
      }
      if total > 0 {
          let scope: i64 = done * 1000 / total
          let ev: i64 = st[16] * scope / 1000
          o = pj_cat(hb, o, "<h2>Budget</h2><p>budget cents=" as *u8)
          o = pj_catn(hb, o, st[16])
          o = pj_cat(hb, o, " spent cents=" as *u8)
          o = pj_catn(hb, o, st[17])
          o = pj_cat(hb, o, " scope done permil=" as *u8)
          o = pj_catn(hb, o, scope)
          o = pj_cat(hb, o, " earned value cents=" as *u8)
          o = pj_catn(hb, o, ev)
          if st[17] > st[16] { o = pj_cat(hb, o, " <span class='BLOCKED'>OVER BUDGET</span>" as *u8) }
          o = pj_cat(hb, o, "</p>" as *u8)
      }
  }
  // ---- Schedule (latest-safe windows): bar = own-effort days ending at due; needs WCONF ----
  if st[18] == 1 { if st[0] > 0 {
      let gs: *i64 = sys_mmap(8 * 128) as *i64
      let gw: *i64 = sys_mmap(8 * 128) as *i64
      let gv: *i64 = sys_mmap(8 * 128) as *i64
      var minS: i64 = 0
      var maxD: i64 = 0
      var haveg: i64 = 0
      var gi: i64 = 0
      while gi < st[0] {
          gv[gi] = 0
          var visg: i64 = 1
          if own_only == 1 { if pj_eq(owners[gi] as *u8, person) == 0 { visg = 0 } }
          if visg == 1 {
              let gdd: i64 = pj_datedays(dues[gi] as *u8)
              if gdd >= 0 {
                  var gdn: i64 = (efforts[gi] + st[19] - 1) / st[19]
                  if gdn < 1 { gdn = 1 }
                  let gst2: i64 = gdd - gdn
                  gs[gi] = gst2
                  gw[gi] = gdn
                  gv[gi] = 1
                  if haveg == 0 { minS = gst2; maxD = gdd; haveg = 1 } else {
                      if gst2 < minS { minS = gst2 }
                      if gdd > maxD { maxD = gdd }
                  }
              }
          }
          gi = gi + 1
      }
      if haveg == 1 {
          var rng: i64 = maxD - minS
          if rng < 1 { rng = 1 }
          o = pj_cat(hb, o, "<h2>Schedule (latest-safe windows)</h2>" as *u8)
          gi = 0
          while gi < st[0] {
              if gv[gi] == 1 {
                  let svg: i64 = pj_state(st, gi)
                  let lpct: i64 = (gs[gi] - minS) * 100 / rng
                  var wpct: i64 = gw[gi] * 100 / rng
                  if wpct < 2 { wpct = 2 }
                  if lpct + wpct > 100 { wpct = 100 - lpct }
                  if wpct < 1 { wpct = 1 }
                  o = pj_cat(hb, o, "<div class='gr'><span class='gl'>" as *u8)
                  o = pj_cat(hb, o, tids[gi] as *u8)
                  o = pj_cat(hb, o, "</span><div class='gwrap'><div class='gb " as *u8)
                  if svg == 2 { o = pj_cat(hb, o, "gbD" as *u8) }
                  if svg == 1 { o = pj_cat(hb, o, "gbB" as *u8) }
                  if svg == 0 { o = pj_cat(hb, o, "gbR" as *u8) }
                  o = pj_cat(hb, o, "' style='margin-left:" as *u8)
                  o = pj_catn(hb, o, lpct)
                  o = pj_cat(hb, o, "%;width:" as *u8)
                  o = pj_catn(hb, o, wpct)
                  o = pj_cat(hb, o, "%'></div></div></div>" as *u8)
              }
              gi = gi + 1
          }
          o = pj_cat(hb, o, "<p class='meta'>bars = own-effort window ending at due (WCONF " as *u8)
          o = pj_catn(hb, o, st[19])
          o = pj_cat(hb, o, " min/day) - blue ready, red blocked, green done</p>" as *u8)
      }
  } }
  // ---- Timesheet (logged minutes; contractor sees own logs only) ----
  if st[22] > 0 {
      let lp2: *i64 = st[24] as *i64
      let lm2: *i64 = st[25] as *i64
      var hdr2: i64 = 0
      let seen2: *i64 = sys_mmap(8 * 256) as *i64
      var ns2: i64 = 0
      var li: i64 = 0
      while li < st[22] {
          let lper: *u8 = lp2[li] as *u8
          var okp: i64 = 1
          if own_only == 1 { if pj_eq(lper, person) == 0 { okp = 0 } }
          if okp == 1 { if pj_find(seen2, ns2, lper) < 0 {
              if hdr2 == 0 {
                  o = pj_cat(hb, o, "<h2>Timesheet</h2><div class='tablewrap'><table><tr><th>person</th><th>logged min</th></tr>" as *u8)
                  hdr2 = 1
              }
              seen2[ns2] = lper as i64
              ns2 = ns2 + 1
              var lsum: i64 = 0
              var lk: i64 = 0
              while lk < st[22] {
                  if pj_eq(lp2[lk] as *u8, lper) == 1 { lsum = lsum + lm2[lk] }
                  lk = lk + 1
              }
              o = pj_cat(hb, o, "<tr><td>" as *u8)
              o = pj_cat(hb, o, lper)
              o = pj_cat(hb, o, "</td><td>" as *u8)
              o = pj_catn(hb, o, lsum)
              o = pj_cat(hb, o, "</td></tr>" as *u8)
          } }
          li = li + 1
      }
      if hdr2 == 1 { o = pj_cat(hb, o, "</table></div>" as *u8) }
  }
  // ---- Notes (task discussion; a note is visible only when its TASK is visible) ----
  if st[26] > 0 {
      let nt2: *i64 = st[27] as *i64
      let np2: *i64 = st[28] as *i64
      let nx2: *i64 = st[29] as *i64
      let nd2: *i64 = st[30] as *i64
      var hdr3: i64 = 0
      var ni: i64 = 0
      while ni < st[26] {
          var okn: i64 = 1
          if own_only == 1 {
              let ti2: i64 = pj_find(tids, st[0], nt2[ni] as *u8)
              if ti2 < 0 { okn = 0 } else { if pj_eq(owners[ti2] as *u8, person) == 0 { okn = 0 } }
          }
          if okn == 1 {
              if hdr3 == 0 { o = pj_cat(hb, o, "<h2>Notes</h2>" as *u8); hdr3 = 1 }
              o = pj_cat(hb, o, "<p class='meta'><b>" as *u8)
              o = pj_cat(hb, o, nt2[ni] as *u8)
              o = pj_cat(hb, o, "</b> " as *u8)
              o = pj_cat(hb, o, np2[ni] as *u8)
              o = pj_cat(hb, o, " " as *u8)
              o = pj_cat(hb, o, nd2[ni] as *u8)
              o = pj_cat(hb, o, " - " as *u8)
              o = pj_cat(hb, o, nx2[ni] as *u8)
              o = pj_cat(hb, o, "</p>" as *u8)
          }
          ni = ni + 1
      }
  }
  o = pj_foot(hb, o)
  return o
1836}
1837
1838// CLI wrapper: build + write to outfile (or - for stdout); loud on failure (the MCP/CLI surface)
1839func pj_html(prefix: *u8, pid: *u8, person: *u8, today: *u8, outpath: *u8) -> i64 {
  let hb: *u8 = sys_mmap(K_MAGIC_65536)
  let n: i64 = pj_html_build(prefix, pid, person, today, hb)
  if n == 0 - 3 { pj_p("PROJECT html bad path or today date -- fail loud\n" as *u8); return 1 }
  if n == 0 - 2 { pj_p("PROJECT-DENY -- not a member\n" as *u8); return 2 }
  if n < 0 { pj_p("PROJECT-NOTFOUND -- fail loud\n" as *u8); return 1 }
  var fd: i64 = 1
  var opened: i64 = 0
  var isdash: i64 = 0
  if outpath[0] == (45 as u8) { if outpath[1] == (0 as u8) { isdash = 1 } }
  if isdash == 0 {
      let f2: i64 = sys_openat_wr(outpath, 0x1a4)
      if f2 < 0 { pj_p("PROJECT html cannot open outfile -- fail loud\n" as *u8); return 1 }
      fd = f2
      opened = 1
  }
  sys_write(fd, hb, n)
  if opened == 1 { sys_close(fd) }
  return 0
1858}
1859
1860// epoch-days -> civil (Howard Hinnant); out = y,m,d
1861func pj_civil(z0: i64, out: *i64) -> i64 {
  var z: i64 = z0 + K_MAGIC_719468
  var era: i64 = z / K_MAGIC_146097
  if z < 0 { era = (z - K_MAGIC_146096) / K_MAGIC_146097 }
  let doe: i64 = z - era * K_MAGIC_146097
  let yoe: i64 = (doe - doe / K_MAGIC_1460 + doe / K_MAGIC_36524 - doe / K_MAGIC_146096) / 365
  let y0: i64 = yoe + era * 400
  let doy: i64 = doe - (365 * yoe + yoe / 4 - yoe / 100)
  let mp: i64 = (5 * doy + 2) / 153
  let d: i64 = doy - (153 * mp + 2) / 5 + 1
  var m: i64 = mp + 3
  if mp >= 10 { m = mp - 9 }
  var y: i64 = y0
  if m <= 2 { y = y0 + 1 }
  out[0] = y
  out[1] = m
  out[2] = d
  return 0
1879}
1880
1881// epoch-days -> "YYYY-MM-DD" into out; returns length
1882func pj_fmtdate(days: i64, out: *u8) -> i64 {
  let ymd: *i64 = sys_mmap(32) as *i64
  pj_civil(days, ymd)
  var o: i64 = 0
  o = pj_catn(out, o, ymd[0])
  out[o] = 45 as u8
  o = o + 1
  if ymd[1] < 10 { out[o] = 48 as u8; o = o + 1 }
  o = pj_catn(out, o, ymd[1])
  out[o] = 45 as u8
  o = o + 1
  if ymd[2] < 10 { out[o] = 48 as u8; o = o + 1 }
  o = pj_catn(out, o, ymd[2])
  out[o] = 0 as u8
  return o
1897}
1898
1899// ---------------- TIMESHEET (logged minutes per person; out: 0=total 1=persons-with-logs) ----------------
1900func pj_cmd_timesheet(prefix: *u8, pid: *u8, out: *i64) -> i64 {
  out[0] = 0
  out[1] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  if st[12] == 0 {
      var o0: i64 = 0
      o0 = pj_cat(rep, o0, "PROJECT-NOTFOUND pid=" as *u8)
      o0 = pj_cat(rep, o0, pid)
      o0 = pj_cat(rep, o0, " -- fail loud\n" as *u8)
      sys_write(1, rep, o0)
      return 1
  }
  let lp: *i64 = st[24] as *i64
  let lm: *i64 = st[25] as *i64
  let seen: *i64 = sys_mmap(8 * 256) as *i64
  var nseen: i64 = 0
  var total: i64 = 0
  var i: i64 = 0
  while i < st[22] { total = total + lm[i]; i = i + 1 }
  i = 0
  while i < st[22] {
      let person: *u8 = lp[i] as *u8
      if pj_find(seen, nseen, person) < 0 {
          seen[nseen] = person as i64
          nseen = nseen + 1
          var sum: i64 = 0
          var k: i64 = 0
          while k < st[22] {
              if pj_eq(lp[k] as *u8, person) == 1 { sum = sum + lm[k] }
              k = k + 1
          }
          var t: i64 = 0
          t = pj_cat(rep, t, "PROJECT-TIME person=" as *u8)
          t = pj_cat(rep, t, person)
          t = pj_cat(rep, t, " logged_min=" as *u8)
          t = pj_catn(rep, t, sum)
          t = pj_cat(rep, t, "\n" as *u8)
          sys_write(1, rep, t)
      }
      i = i + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-TIME-END persons=" as *u8)
  z = pj_catn(rep, z, nseen)
  z = pj_cat(rep, z, " total_min=" as *u8)
  z = pj_catn(rep, z, total)
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  out[0] = total
  out[1] = nseen
  return 0
1954}
1955
1956// ---------------- NOTES (task discussion; out: 0=count shown) ----------------
1957func pj_cmd_notes(prefix: *u8, pid: *u8, tid: *u8, out: *i64) -> i64 {
  out[0] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  if st[12] == 0 { pj_p("PROJECT-NOTFOUND -- fail loud\n" as *u8); return 1 }
  let tids: *i64 = st[1] as *i64
  if pj_find(tids, st[0], tid) < 0 { pj_p("PROJECT notes: no such task -- fail loud\n" as *u8); return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  let nt: *i64 = st[27] as *i64
  let np: *i64 = st[28] as *i64
  let nx: *i64 = st[29] as *i64
  let nd: *i64 = st[30] as *i64
  var shown: i64 = 0
  var i: i64 = 0
  while i < st[26] {
      if pj_eq(nt[i] as *u8, tid) == 1 {
          var t: i64 = 0
          t = pj_cat(rep, t, "PROJECT-NOTE tid=" as *u8)
          t = pj_cat(rep, t, tid)
          t = pj_cat(rep, t, " person=" as *u8)
          t = pj_cat(rep, t, np[i] as *u8)
          t = pj_cat(rep, t, " date=" as *u8)
          t = pj_cat(rep, t, nd[i] as *u8)
          t = pj_cat(rep, t, " text=" as *u8)
          t = pj_cat(rep, t, nx[i] as *u8)
          t = pj_cat(rep, t, "\n" as *u8)
          sys_write(1, rep, t)
          shown = shown + 1
      }
      i = i + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-NOTES-END tid=" as *u8)
  z = pj_cat(rep, z, tid)
  z = pj_cat(rep, z, " count=" as *u8)
  z = pj_catn(rep, z, shown)
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  out[0] = shown
  return 0
1998}
1999
2000// ---------------- TEMPLATE (blueprint -> dated TASK/MILE file the planner loads) ----------------
2001// tpl rows: TPLTASK <tid> <owner> <offset-days> <effort> <imp> <deps|-> <title>
2002//           TPLMILE <mid> <offset-days> <title>
2003func pj_cmd_template(argc: i64, argv: *i64) -> i64 {
  if argc < 6 { pj_p("PROJECT template needs <tplfile> <pid> <startdate> <outfile> -- fail loud\n" as *u8); return 1 }
  let tplf: *u8 = argv[2] as *u8
  let pid: *u8 = argv[3] as *u8
  let start: *u8 = argv[4] as *u8
  let outf: *u8 = argv[5] as *u8
  if pj_pathok(tplf) == 0 { return pj_pathfail() }
  if pj_pathok(outf) == 0 { return pj_pathfail() }
  let sd: i64 = pj_datedays(start)
  if sd < 0 { pj_p("PROJECT template bad start date -- fail loud\n" as *u8); return 1 }
  let szp: *i64 = sys_mmap(16) as *i64
  let b: *u8 = ss_readall(tplf, szp)
  let sz: i64 = szp[0]
  if sz <= 0 { pj_p("PROJECT template file MISSING/EMPTY -- fail loud\n" as *u8); return 1 }
  let ob: *u8 = sys_mmap(K_MAGIC_65536)
  var oo: i64 = 0
  let t0: *u8 = sys_mmap(128)
  let g1: *u8 = sys_mmap(128)
  let g2: *u8 = sys_mmap(128)
  let g3: *u8 = sys_mmap(128)
  let g4: *u8 = sys_mmap(128)
  let g5: *u8 = sys_mmap(128)
  let g6: *u8 = sys_mmap(256)
  let g7: *u8 = sys_mmap(256)
  let dbuf: *u8 = sys_mmap(32)
  var rows: i64 = 0
  var i: i64 = 0
  while i < sz {
      var e: i64 = i
      var go: i64 = 1
      while go == 1 {
          if e >= sz { go = 0 } else {
              if b[e] == (10 as u8) { go = 0 } else { e = e + 1 }
          }
      }
      var p: i64 = pj_tok(b, i, e, t0, 128)
      if t0[0] == (35 as u8) { t0[0] = 0 as u8 }
      if pj_eq(t0, "TPLTASK" as *u8) == 1 {
          p = pj_tok(b, p, e, g1, 128)
          p = pj_tok(b, p, e, g2, 128)
          p = pj_tok(b, p, e, g3, 128)
          p = pj_tok(b, p, e, g4, 128)
          p = pj_tok(b, p, e, g5, 128)
          p = pj_tok(b, p, e, g6, 256)
          p = pj_tok(b, p, e, g7, 256)
          if g1[0] == (0 as u8) { pj_p("PROJECT template TPLTASK missing tid -- fail loud\n" as *u8); return 1 }
          if g2[0] == (0 as u8) { pj_p("PROJECT template TPLTASK missing owner -- fail loud\n" as *u8); return 1 }
          if pj_digits(g3) == 0 { pj_p("PROJECT template TPLTASK offset must be digits -- fail loud\n" as *u8); return 1 }
          if pj_digits(g4) == 0 { pj_p("PROJECT template TPLTASK effort must be digits -- fail loud\n" as *u8); return 1 }
          if pj_digits(g5) == 0 { pj_p("PROJECT template TPLTASK imp must be digits -- fail loud\n" as *u8); return 1 }
          if g6[0] == (0 as u8) { pj_p("PROJECT template TPLTASK missing deps -- fail loud\n" as *u8); return 1 }
          if g7[0] == (0 as u8) { pj_p("PROJECT template TPLTASK missing title -- fail loud\n" as *u8); return 1 }
          pj_fmtdate(sd + pj_atoi(g3), dbuf)
          oo = pj_cat(ob, oo, "TASK " as *u8)
          oo = pj_cat(ob, oo, pid)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g1)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g2)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, dbuf)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g4)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g5)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g6)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g7)
          oo = pj_cat(ob, oo, "\n" as *u8)
          rows = rows + 1
      }
      if pj_eq(t0, "TPLMILE" as *u8) == 1 {
          p = pj_tok(b, p, e, g1, 128)
          p = pj_tok(b, p, e, g3, 128)
          p = pj_tok(b, p, e, g7, 256)
          if g1[0] == (0 as u8) { pj_p("PROJECT template TPLMILE missing mid -- fail loud\n" as *u8); return 1 }
          if pj_digits(g3) == 0 { pj_p("PROJECT template TPLMILE offset must be digits -- fail loud\n" as *u8); return 1 }
          if g7[0] == (0 as u8) { pj_p("PROJECT template TPLMILE missing title -- fail loud\n" as *u8); return 1 }
          pj_fmtdate(sd + pj_atoi(g3), dbuf)
          oo = pj_cat(ob, oo, "MILE " as *u8)
          oo = pj_cat(ob, oo, pid)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g1)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, dbuf)
          ob[oo] = 32 as u8
          oo = oo + 1
          oo = pj_cat(ob, oo, g7)
          oo = pj_cat(ob, oo, "\n" as *u8)
          rows = rows + 1
      }
      i = e + 1
  }
  if rows == 0 { pj_p("PROJECT template: no TPLTASK/TPLMILE rows -- fail loud\n" as *u8); return 1 }
  if pj_wfile(outf, ob) != 0 { pj_p("PROJECT template cannot write outfile -- fail loud\n" as *u8); return 1 }
  let rep: *u8 = sys_mmap(256)
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-TEMPLATE rows=" as *u8)
  z = pj_catn(rep, z, rows)
  z = pj_cat(rep, z, " start=" as *u8)
  z = pj_cat(rep, z, start)
  z = pj_cat(rep, z, " -- load the outfile with the planner to instantiate\n" as *u8)
  sys_write(1, rep, z)
  return 0
2117}
2118
2119// ---------------- SNAPSHOT (write a BASELINE = each task's current due+effort, dated) ----------------
2120func pj_cmd_snapshot(prefix: *u8, pid: *u8, snapdate: *u8, outfile: *u8) -> i64 {
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  if pj_pathok(outfile) == 0 { return pj_pathfail() }
  if pj_datedays(snapdate) < 0 { pj_p("PROJECT snapshot bad date -- fail loud\n" as *u8); return 1 }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  if st[12] == 0 { pj_p("PROJECT-NOTFOUND -- fail loud\n" as *u8); return 1 }
  let tids: *i64 = st[1] as *i64
  let dues: *i64 = st[21] as *i64
  let efforts: *i64 = st[4] as *i64
  let ob: *u8 = sys_mmap(K_MAGIC_65536)
  var o: i64 = 0
  var i: i64 = 0
  while i < st[0] {
      o = pj_cat(ob, o, "BASE " as *u8)
      o = pj_cat(ob, o, pid)
      ob[o] = 32 as u8
      o = o + 1
      o = pj_cat(ob, o, tids[i] as *u8)
      ob[o] = 32 as u8
      o = o + 1
      o = pj_cat(ob, o, dues[i] as *u8)
      ob[o] = 32 as u8
      o = o + 1
      o = pj_catn(ob, o, efforts[i])
      ob[o] = 32 as u8
      o = o + 1
      o = pj_cat(ob, o, snapdate)
      o = pj_cat(ob, o, "\n" as *u8)
      i = i + 1
  }
  ob[o] = 0 as u8
  if pj_wfile(outfile, ob) != 0 { pj_p("PROJECT snapshot cannot write -- fail loud\n" as *u8); return 1 }
  let rep: *u8 = sys_mmap(256)
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-SNAPSHOT tasks=" as *u8)
  z = pj_catn(rep, z, st[0])
  z = pj_cat(rep, z, " date=" as *u8)
  z = pj_cat(rep, z, snapdate)
  z = pj_cat(rep, z, " -- load the outfile to record the baseline (BASE records, additive)\n" as *u8)
  sys_write(1, rep, z)
  return 0
2162}
2163
2164// ---------------- BASELINE VARIANCE (current plan vs the recorded baseline) ----------------
2165// out: 0=tasks-with-baseline 1=total-slip-days 2=tasks-slipped 3=tasks-no-baseline
2166func pj_cmd_baseline(prefix: *u8, pid: *u8, out: *i64) -> i64 {
  out[0] = 0; out[1] = 0; out[2] = 0; out[3] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  if st[12] == 0 { pj_p("PROJECT-NOTFOUND -- fail loud\n" as *u8); return 1 }
  if st[36] == 0 { pj_p("PROJECT baseline: none recorded (run snapshot first) -- fail loud\n" as *u8); return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  let tids: *i64 = st[1] as *i64
  let dues: *i64 = st[21] as *i64
  let efforts: *i64 = st[4] as *i64
  let bt: *i64 = st[37] as *i64
  let bd: *i64 = st[38] as *i64
  let be: *i64 = st[39] as *i64
  var i: i64 = 0
  while i < st[0] {
      let bi: i64 = pj_find(bt, st[36], tids[i] as *u8)
      if bi < 0 {
          out[3] = out[3] + 1
      } else {
          let curdue: i64 = pj_datedays(dues[i] as *u8)
          let slip: i64 = curdue - bd[bi]
          let edelta: i64 = efforts[i] - be[bi]
          out[0] = out[0] + 1
          out[1] = out[1] + slip
          if slip > 0 { out[2] = out[2] + 1 }
          var t: i64 = 0
          t = pj_cat(rep, t, "PROJECT-BASELINE tid=" as *u8)
          t = pj_cat(rep, t, tids[i] as *u8)
          t = pj_cat(rep, t, " due_slip_days=" as *u8)
          t = pj_catn(rep, t, slip)
          t = pj_cat(rep, t, " effort_delta_min=" as *u8)
          t = pj_catn(rep, t, edelta)
          if slip > 0 { t = pj_cat(rep, t, " SLIPPED" as *u8) }
          t = pj_cat(rep, t, "\n" as *u8)
          sys_write(1, rep, t)
      }
      i = i + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-BASELINE-END baselined=" as *u8)
  z = pj_catn(rep, z, out[0])
  z = pj_cat(rep, z, " total_slip_days=" as *u8)
  z = pj_catn(rep, z, out[1])
  z = pj_cat(rep, z, " slipped=" as *u8)
  z = pj_catn(rep, z, out[2])
  z = pj_cat(rep, z, " no_baseline=" as *u8)
  z = pj_catn(rep, z, out[3])
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  return 0
2217}
2218
2219// ---------------- BURNDOWN (remaining effort over time from DONE + effort records) ----------------
2220// out: 0=total_effort 1=done_effort 2=remaining 3=done_points
2221func pj_cmd_burndown(prefix: *u8, pid: *u8, out: *i64) -> i64 {
  out[0] = 0; out[1] = 0; out[2] = 0; out[3] = 0
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  if st[12] == 0 { pj_p("PROJECT-NOTFOUND -- fail loud\n" as *u8); return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  let tids: *i64 = st[1] as *i64
  let efforts: *i64 = st[4] as *i64
  var total: i64 = 0
  var i: i64 = 0
  while i < st[0] { total = total + efforts[i]; i = i + 1 }
  // sort done entries by date (insertion sort on parallel dtids/ddates copies)
  let dt: *i64 = st[7] as *i64
  let dd: *i64 = st[35] as *i64
  let sidx: *i64 = sys_mmap(8 * 260) as *i64
  var nd: i64 = st[6]
  i = 0
  while i < nd { sidx[i] = i; i = i + 1 }
  i = 1
  while i < nd {
      let key: i64 = sidx[i]
      var j: i64 = i - 1
      var go: i64 = 1
      while go == 1 {
          if j < 0 { go = 0 } else {
              if dd[sidx[j]] > dd[key] { sidx[j + 1] = sidx[j]; j = j - 1 } else { go = 0 }
          }
      }
      sidx[j + 1] = key
      i = i + 1
  }
  var remaining: i64 = total
  var done_pts: i64 = 0
  i = 0
  while i < nd {
      let de: i64 = sidx[i]
      let ti: i64 = pj_find(tids, st[0], dt[de] as *u8)
      var eff: i64 = 0
      if ti >= 0 { eff = efforts[ti] }
      remaining = remaining - eff
      done_pts = done_pts + eff
      let ymd: *i64 = sys_mmap(32) as *i64
      pj_civil(dd[de], ymd)
      var t: i64 = 0
      t = pj_cat(rep, t, "PROJECT-BURN date=" as *u8)
      t = pj_catn(rep, t, ymd[0]); rep[t] = 45 as u8; t = t + 1
      if ymd[1] < 10 { rep[t] = 48 as u8; t = t + 1 }
      t = pj_catn(rep, t, ymd[1]); rep[t] = 45 as u8; t = t + 1
      if ymd[2] < 10 { rep[t] = 48 as u8; t = t + 1 }
      t = pj_catn(rep, t, ymd[2])
      t = pj_cat(rep, t, " tid=" as *u8)
      t = pj_cat(rep, t, dt[de] as *u8)
      t = pj_cat(rep, t, " burned=" as *u8)
      t = pj_catn(rep, t, eff)
      t = pj_cat(rep, t, " remaining_min=" as *u8)
      t = pj_catn(rep, t, remaining)
      t = pj_cat(rep, t, "\n" as *u8)
      sys_write(1, rep, t)
      i = i + 1
  }
  var z: i64 = 0
  z = pj_cat(rep, z, "PROJECT-BURN-END total_min=" as *u8)
  z = pj_catn(rep, z, total)
  z = pj_cat(rep, z, " done_min=" as *u8)
  z = pj_catn(rep, z, done_pts)
  z = pj_cat(rep, z, " remaining_min=" as *u8)
  z = pj_catn(rep, z, remaining)
  z = pj_cat(rep, z, " done_points=" as *u8)
  z = pj_catn(rep, z, st[6])
  z = pj_cat(rep, z, "\n" as *u8)
  sys_write(1, rep, z)
  out[0] = total
  out[1] = done_pts
  out[2] = remaining
  out[3] = st[6]
  return 0
2298}
2299
2300// ---------------- WORKLOAD ----------------
2301func pj_cmd_workload(prefix: *u8, pid: *u8) -> i64 {
  if pj_pathok(prefix) == 0 { return pj_pathfail() }
  let st: *i64 = pj_st_new()
  if pj_gather(prefix, pid, st) != 0 { return 1 }
  let rep: *u8 = sys_mmap(K_MAGIC_2048)
  if st[12] == 0 {
      var o0: i64 = 0
      o0 = pj_cat(rep, o0, "PROJECT-NOTFOUND pid=" as *u8)
      o0 = pj_cat(rep, o0, pid)
      o0 = pj_cat(rep, o0, " -- fail loud\n" as *u8)
      sys_write(1, rep, o0)
      return 1
  }
  let mp: *i64 = st[9] as *i64
  let mr: *i64 = st[10] as *i64
  let mc: *i64 = st[11] as *i64
  let owners: *i64 = st[2] as *i64
  let efforts: *i64 = st[4] as *i64
  var o: i64 = 0
  o = pj_cat(rep, o, "PROJECT-WORKLOAD pid=" as *u8)
  o = pj_cat(rep, o, pid)
  o = pj_cat(rep, o, " members=" as *u8)
  o = pj_catn(rep, o, st[8])
  o = pj_cat(rep, o, " tasks=" as *u8)
  o = pj_catn(rep, o, st[0])
  o = pj_cat(rep, o, "\n" as *u8)
  sys_write(1, rep, o)
  var m: i64 = 0
  while m < st[8] {
      let person: *u8 = mp[m] as *u8
      var sum: i64 = 0
      var i: i64 = 0
      while i < st[0] {
          if pj_eq(owners[i] as *u8, person) == 1 {
              let sv: i64 = pj_state(st, i)
              if sv != 2 { sum = sum + efforts[i] }
          }
          i = i + 1
      }
      let cap: *u8 = mc[m] as *u8
      var over: i64 = 0 - 1
      if pj_digits(cap) == 1 {
          over = 0
          if sum > pj_atoi(cap) { over = 1 }
      }
      var t: i64 = 0
      t = pj_cat(rep, t, "PROJECT-LOAD person=" as *u8)
      t = pj_cat(rep, t, person)
      t = pj_cat(rep, t, " role=" as *u8)
      t = pj_cat(rep, t, mr[m] as *u8)
      t = pj_cat(rep, t, " open_min=" as *u8)
      t = pj_catn(rep, t, sum)
      t = pj_cat(rep, t, " cap_min=" as *u8)
      t = pj_cat(rep, t, cap)
      t = pj_cat(rep, t, " over=" as *u8)
      if over == 1 { t = pj_cat(rep, t, "1" as *u8) }
      if over == 0 { t = pj_cat(rep, t, "0" as *u8) }
      if over < 0 { t = pj_cat(rep, t, "-" as *u8) }
      t = pj_cat(rep, t, "\n" as *u8)
      sys_write(1, rep, t)
      m = m + 1
  }
  // orphan owners: tasks assigned to someone with NO membership record (loud visibility)
  var i2: i64 = 0
  while i2 < st[0] {
      let ow: *u8 = owners[i2] as *u8
      var ismem: i64 = 0
      if pj_find(mp, st[8], ow) >= 0 { ismem = 1 }
      if st[12] == 1 { if pj_eq(st[13] as *u8, ow) == 1 { ismem = 1 } }
      if ismem == 0 {
          var t2: i64 = 0
          t2 = pj_cat(rep, t2, "PROJECT-LOAD-ORPHAN owner=" as *u8)
          t2 = pj_cat(rep, t2, ow)
          t2 = pj_cat(rep, t2, " -- task owner has no MEMBER record\n" as *u8)
          sys_write(1, rep, t2)
      }
      i2 = i2 + 1
  }
  return 0
2380}
2381
2382// ---------------- SELFTEST (the gate; forks the REAL blessed planner as the tsk:/don: writer) ----------------
2383func pj_run(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 stp: *i64 = sys_mmap(16) as *i64
  sys_wait4(pid, stp, 0)
  let sig: i64 = stp[0] & 0x7f
  if sig != 0 { return 128 + sig }
  return (stp[0] >> 8) & 0xff
2411}
2412
2413func pj_check(idx: i64, ok: i64, name: *u8) -> i64 {
  let rep: *u8 = sys_mmap(256)
  var o: i64 = 0
  o = pj_cat(rep, o, "PJ-GATE T" as *u8)
  o = pj_catn(rep, o, idx)
  o = pj_cat(rep, o, " " as *u8)
  o = pj_cat(rep, o, name)
  if ok == 1 { o = pj_cat(rep, o, " PASS\n" as *u8) } else { o = pj_cat(rep, o, " FAIL\n" as *u8) }
  sys_write(1, rep, o)
  return ok
2423}
2424
2425func pj_selftest() -> i64 {
  let uniq: i64 = sys_now_us()
  let planfile: *u8 = sys_mmap(256)
  var o: i64 = 0
  o = pj_cat(planfile, o, "/tmp/pjt_" as *u8)
  o = pj_catn(planfile, o, uniq)
  o = pj_cat(planfile, o, "_plan.txt" as *u8)
  planfile[o] = 0 as u8
  let projfile: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(projfile, o, "/tmp/pjt_" as *u8)
  o = pj_catn(projfile, o, uniq)
  o = pj_cat(projfile, o, "_proj.txt" as *u8)
  projfile[o] = 0 as u8
  let badfile: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(badfile, o, "/tmp/pjt_" as *u8)
  o = pj_catn(badfile, o, uniq)
  o = pj_cat(badfile, o, "_bad.txt" as *u8)
  badfile[o] = 0 as u8
  let prefix: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(prefix, o, "/tmp/pjt_" as *u8)
  o = pj_catn(prefix, o, uniq)
  o = pj_cat(prefix, o, "_st-" as *u8)
  prefix[o] = 0 as u8
  let outf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(outf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(outf, o, uniq)
  o = pj_cat(outf, o, "_run.out" as *u8)
  outf[o] = 0 as u8
2457
  pj_wfile(planfile, "TASK demo t1 alice 2026-07-10 60 3 - setup\nTASK demo t2 bob 2026-07-12 120 4 t1 build\nTASK demo t3 carol 2026-07-14 90 5 t2 install\nDONE demo t1 2026-07-09\n" as *u8)
  pj_wfile(projfile, "PROJ demo elder website-build\nMEMBER demo alice team -\nMEMBER demo bob team -\nMEMBER demo carol contractor 60\n" as *u8)
  pj_wfile(badfile, "MEMBER demo dave boss -\n" as *u8)
2461
  var pass: i64 = 0
  // T1 the INDEPENDENT planner organ writes tsk:/don: records into the shared store
  let a1: *i64 = sys_mmap(8 * 8) as *i64
  a1[0] = "load" as *u8 as i64
  a1[1] = planfile as i64
  a1[2] = prefix as i64
  a1[3] = "7001" as *u8 as i64
  a1[4] = 0
  let rc1: i64 = pj_run("_offc/nx_vizsla_plan.elf" as *u8, a1, outf)
  var ok: i64 = 0
  if rc1 == 0 { ok = 1 }
  pass = pass + pj_check(1, ok, "planner-writes-store" as *u8)
  // T2 our loader adds prj:/mem: beside them
  let av: *i64 = sys_mmap(8 * 8) as *i64
  av[0] = "pj" as *u8 as i64
  av[1] = "load" as *u8 as i64
  av[2] = projfile as i64
  av[3] = prefix as i64
  av[4] = "7002" as *u8 as i64
  let rc2: i64 = pj_cmd_load(5, av)
  ok = 0
  if rc2 == 0 { ok = 1 }
  pass = pass + pj_check(2, ok, "project-load" as *u8)
  // T3 states: t1 DONE, t2 READY (dep done), t3 BLOCKED (dep open)
  ok = 0
  let s1: i64 = pj_task_state(prefix, "demo" as *u8, "t1" as *u8)
  let s2: i64 = pj_task_state(prefix, "demo" as *u8, "t2" as *u8)
  let s3: i64 = pj_task_state(prefix, "demo" as *u8, "t3" as *u8)
  if s1 == 2 { if s2 == 0 { if s3 == 1 { ok = 1 } } }
  pass = pass + pj_check(3, ok, "dep-states" as *u8)
  // T4 contractor sees ONLY own task
  let out4: *i64 = sys_mmap(32) as *i64
  let rc4: i64 = pj_view(prefix, "demo" as *u8, "carol" as *u8, out4)
  ok = 0
  if rc4 == 0 { if out4[0] == 3 { if out4[1] == 1 { ok = 1 } } }
  pass = pass + pj_check(4, ok, "contractor-scope-own" as *u8)
  // T5 NEG: carol must NOT see t1; must see t3
  ok = 0
  let v1: i64 = pj_visible(prefix, "demo" as *u8, "carol" as *u8, "t1" as *u8)
  let v3: i64 = pj_visible(prefix, "demo" as *u8, "carol" as *u8, "t3" as *u8)
  if v1 == 0 { if v3 == 1 { ok = 1 } }
  pass = pass + pj_check(5, ok, "neg-contractor-hidden" as *u8)
  // T6 NEG: non-member denied fail-closed
  let out6: *i64 = sys_mmap(32) as *i64
  let rc6: i64 = pj_view(prefix, "demo" as *u8, "mallory" as *u8, out6)
  ok = 0
  if rc6 == 2 { ok = 1 }
  pass = pass + pj_check(6, ok, "neg-nonmember-deny" as *u8)
  // T7 NEG: unknown project fails loud
  let out7: *i64 = sys_mmap(32) as *i64
  let rc7: i64 = pj_view(prefix, "ghost" as *u8, "carol" as *u8, out7)
  ok = 0
  if rc7 == 1 { ok = 1 }
  pass = pass + pj_check(7, ok, "neg-unknown-project" as *u8)
  // T8 workload sums + data-driven over-capacity
  ok = 0
  let w1: i64 = pj_open_min(prefix, "demo" as *u8, "carol" as *u8)
  let w2: i64 = pj_open_min(prefix, "demo" as *u8, "alice" as *u8)
  let w3: i64 = pj_open_min(prefix, "demo" as *u8, "bob" as *u8)
  let ov1: i64 = pj_over(prefix, "demo" as *u8, "carol" as *u8)
  let ov2: i64 = pj_over(prefix, "demo" as *u8, "bob" as *u8)
  if w1 == 90 { if w2 == 0 { if w3 == 120 { if ov1 == 1 { if ov2 == 0 - 1 { ok = 1 } } } } }
  pass = pass + pj_check(8, ok, "workload-capacity" as *u8)
  // T9 NEG: malformed role refuses load
  let av9: *i64 = sys_mmap(8 * 8) as *i64
  av9[0] = "pj" as *u8 as i64
  av9[1] = "load" as *u8 as i64
  av9[2] = badfile as i64
  av9[3] = prefix as i64
  av9[4] = "7003" as *u8 as i64
  let rc9: i64 = pj_cmd_load(5, av9)
  ok = 0
  if rc9 != 0 { ok = 1 }
  pass = pass + pj_check(9, ok, "neg-bad-role-refused" as *u8)
  // T10 idempotent re-load: no duplicate members
  let av10: *i64 = sys_mmap(8 * 8) as *i64
  av10[0] = "pj" as *u8 as i64
  av10[1] = "load" as *u8 as i64
  av10[2] = projfile as i64
  av10[3] = prefix as i64
  av10[4] = "7004" as *u8 as i64
  let rc10: i64 = pj_cmd_load(5, av10)
  let st10: *i64 = pj_st_new()
  pj_gather(prefix, "demo" as *u8, st10)
  ok = 0
  if rc10 == 0 { if st10[8] == 3 { if st10[0] == 3 { ok = 1 } } }
  pass = pass + pj_check(10, ok, "idempotent-reload" as *u8)
  // T11 owner sees all
  let out11: *i64 = sys_mmap(32) as *i64
  let rc11: i64 = pj_view(prefix, "demo" as *u8, "elder" as *u8, out11)
  ok = 0
  if rc11 == 0 { if out11[1] == 3 { ok = 1 } }
  pass = pass + pj_check(11, ok, "owner-sees-all" as *u8)
  // T12 NEG: path guard refuses out-of-namespace and dot-dot stores
  let av12: *i64 = sys_mmap(8 * 8) as *i64
  av12[0] = "pj" as *u8 as i64
  av12[1] = "load" as *u8 as i64
  av12[2] = projfile as i64
  av12[3] = "knowledge/evil-" as *u8 as i64
  av12[4] = "7005" as *u8 as i64
  let rc12a: i64 = pj_cmd_load(5, av12)
  let av12b: *i64 = sys_mmap(8 * 8) as *i64
  av12b[0] = "pj" as *u8 as i64
  av12b[1] = "load" as *u8 as i64
  av12b[2] = "/tmp/../etc/passwd" as *u8 as i64
  av12b[3] = prefix as i64
  av12b[4] = "7006" as *u8 as i64
  let rc12b: i64 = pj_cmd_load(5, av12b)
  ok = 0
  if rc12a != 0 { if rc12b != 0 { ok = 1 } }
  pass = pass + pj_check(12, ok, "neg-path-guard" as *u8)
2573
  // ---- fence project fixtures (level / risk / evm / html) ----
  let plan2: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(plan2, o, "/tmp/pjt_" as *u8)
  o = pj_catn(plan2, o, uniq)
  o = pj_cat(plan2, o, "_plan2.txt" as *u8)
  plan2[o] = 0 as u8
  let proj2: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(proj2, o, "/tmp/pjt_" as *u8)
  o = pj_catn(proj2, o, uniq)
  o = pj_cat(proj2, o, "_proj2.txt" as *u8)
  proj2[o] = 0 as u8
  let prefix2: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(prefix2, o, "/tmp/pjt_" as *u8)
  o = pj_catn(prefix2, o, uniq)
  o = pj_cat(prefix2, o, "_st2-" as *u8)
  prefix2[o] = 0 as u8
  let htmlfile: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(htmlfile, o, "/tmp/pjt_" as *u8)
  o = pj_catn(htmlfile, o, uniq)
  o = pj_cat(htmlfile, o, "_page.html" as *u8)
  htmlfile[o] = 0 as u8
  pj_wfile(plan2, "TASK fence f0 amber 2026-07-01 30 1 - permits\nTASK fence f1 amber 2026-07-20 200 3 - posts\nTASK fence f2 bo 2026-07-18 100 4 - rails\nTASK fence f3 bo 2026-07-19 80 2 f2 gates\nTASK fence f4 cade 2026-07-21 60 3 - paint\nTASK fence f5 cade 2026-08-15 60 2 - cleanup\nDONE fence f4 2026-07-16\n" as *u8)
  pj_wfile(proj2, "PROJ fence elder fence-build\nMEMBER fence amber team 240\nMEMBER fence bo contractor 120\nMEMBER fence cade team 480\nBUDGET fence 100000\nWCONF fence 120 1\nCOST fence f2 30000 2026-07-15\nCOST fence f4 10000 2026-07-16\n" as *u8)
  let a2: *i64 = sys_mmap(8 * 8) as *i64
  a2[0] = "load" as *u8 as i64
  a2[1] = plan2 as i64
  a2[2] = prefix2 as i64
  a2[3] = "7101" as *u8 as i64
  a2[4] = 0
  let rcf1: i64 = pj_run("_offc/nx_vizsla_plan.elf" as *u8, a2, outf)
  let avf: *i64 = sys_mmap(8 * 8) as *i64
  avf[0] = "pj" as *u8 as i64
  avf[1] = "load" as *u8 as i64
  avf[2] = proj2 as i64
  avf[3] = prefix2 as i64
  avf[4] = "7102" as *u8 as i64
  let rcf2: i64 = pj_cmd_load(5, avf)
  if rcf1 != 0 { pj_p("PJ-GATE fence planner load FAILED\n" as *u8) }
  if rcf2 != 0 { pj_p("PJ-GATE fence project load FAILED\n" as *u8) }
  // time logs + task notes into the same fence store (T19-24 substrate)
  let logsf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(logsf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(logsf, o, uniq)
  o = pj_cat(logsf, o, "_logs.txt" as *u8)
  logsf[o] = 0 as u8
  pj_wfile(logsf, "LOG fence f2 bo 2026-07-16 60\nLOG fence f2 bo 2026-07-17 30\nLOG fence f1 amber 2026-07-16 45\nNOTE fence f2 bo 2026-07-16 rails cut and primed\nNOTE fence f1 amber 2026-07-17 posts delivered late\n" as *u8)
  let avl: *i64 = sys_mmap(8 * 8) as *i64
  avl[0] = "pj" as *u8 as i64
  avl[1] = "load" as *u8 as i64
  avl[2] = logsf as i64
  avl[3] = prefix2 as i64
  avl[4] = "7103" as *u8 as i64
  let rcl: i64 = pj_cmd_load(5, avl)
  if rcl != 0 { pj_p("PJ-GATE logs load FAILED\n" as *u8) }
  // T13 leveling KAT: bo (cap 120, open 180) moves READY f2 (100) to cade (headroom 420) -> balanced
  let out13: *i64 = sys_mmap(32) as *i64
  let rc13: i64 = pj_cmd_level(prefix2, "fence" as *u8, out13, "-" as *u8)
  ok = 0
  if rc13 == 0 { if out13[0] == 1 { if out13[1] == 0 { ok = 1 } } }
  pass = pass + pj_check(13, ok, "level-move-kat" as *u8)
  // T14 NEG: demo carol is over-cap but her only task is BLOCKED -> no move, still over (named STUCK)
  let out14: *i64 = sys_mmap(32) as *i64
  let rc14: i64 = pj_cmd_level(prefix, "demo" as *u8, out14, "-" as *u8)
  ok = 0
  if rc14 == 0 { if out14[0] == 0 { if out14[1] == 1 { ok = 1 } } }
  pass = pass + pj_check(14, ok, "neg-level-blocked-stuck" as *u8)
  // T15 risk KATs (today 2026-07-17, WCONF 120/1): f0 OVERDUE; f1/f2/f3 TIGHT; f5 OK; f4 done skipped
  let out15: *i64 = sys_mmap(48) as *i64
  let rc15: i64 = pj_cmd_risk(prefix2, "fence" as *u8, "2026-07-17" as *u8, out15)
  ok = 0
  if rc15 == 0 { if out15[0] == 1 { if out15[1] == 0 { if out15[2] == 3 { if out15[3] == 1 { if out15[4] == 0 { ok = 1 } } } } } }
  pass = pass + pj_check(15, ok, "risk-slack-kats" as *u8)
  // T16 risk without WCONF (demo, today 2026-07-13): t2 OVERDUE, t3 UNRATED (honest no-duration-claim)
  let out16: *i64 = sys_mmap(48) as *i64
  let rc16: i64 = pj_cmd_risk(prefix, "demo" as *u8, "2026-07-13" as *u8, out16)
  ok = 0
  if rc16 == 0 { if out16[0] == 1 { if out16[1] == 0 { if out16[2] == 0 { if out16[3] == 0 { if out16[4] == 1 { ok = 1 } } } } } }
  pass = pass + pj_check(16, ok, "risk-no-wconf-unrated" as *u8)
  // T17 evm KAT: scope 60/530 -> 113 permil; cpi 11300*1000/40000 -> 282; not over budget
  let out17: *i64 = sys_mmap(32) as *i64
  let rc17: i64 = pj_cmd_evm(prefix2, "fence" as *u8, out17)
  ok = 0
  if rc17 == 0 { if out17[0] == 113 { if out17[1] == 282 { if out17[2] == 0 { ok = 1 } } } }
  pass = pass + pj_check(17, ok, "evm-kat" as *u8)
  // T18 NEG: evm without a BUDGET record fails loud
  let out18: *i64 = sys_mmap(32) as *i64
  let rc18: i64 = pj_cmd_evm(prefix, "demo" as *u8, out18)
  ok = 0
  if rc18 != 0 { ok = 1 }
  pass = pass + pj_check(18, ok, "neg-evm-no-budget" as *u8)
  // T19 html: contractor bo sees f2+f3 only; own note visible, amber's note HIDDEN; own timesheet row
  let rc19: i64 = pj_html(prefix2, "fence" as *u8, "bo" as *u8, "2026-07-17" as *u8, htmlfile)
  ok = 0
  if rc19 == 0 {
      let hszp: *i64 = sys_mmap(16) as *i64
      let hbuf: *u8 = ss_readall(htmlfile, hszp)
      let hsz: i64 = hszp[0]
      if hsz > 0 {
          let c1: i64 = pj_contains(hbuf, hsz, "<td>f2</td>" as *u8)
          let c2: i64 = pj_contains(hbuf, hsz, "<td>f3</td>" as *u8)
          let c3: i64 = pj_contains(hbuf, hsz, "<td>f1</td>" as *u8)
          let c4: i64 = pj_contains(hbuf, hsz, "<script" as *u8)
          let c5: i64 = pj_contains(hbuf, hsz, "<table" as *u8)
          let c6: i64 = pj_contains(hbuf, hsz, "posts delivered late" as *u8)
          let c7: i64 = pj_contains(hbuf, hsz, "rails cut and primed" as *u8)
          let c8: i64 = pj_contains(hbuf, hsz, "Timesheet" as *u8)
          if c1 == 1 { if c2 == 1 { if c3 == 0 { if c4 == 0 { if c5 == 1 { if c6 == 0 { if c7 == 1 { if c8 == 1 { ok = 1 } } } } } } } }
      }
  }
  pass = pass + pj_check(19, ok, "html-scoped-notes-timesheet" as *u8)
  // T20 timesheet KAT: bo 90 + amber 45 = 135 across 2 persons
  let out20: *i64 = sys_mmap(32) as *i64
  let rc20: i64 = pj_cmd_timesheet(prefix2, "fence" as *u8, out20)
  ok = 0
  if rc20 == 0 { if out20[0] == 135 { if out20[1] == 2 { ok = 1 } } }
  pass = pass + pj_check(20, ok, "timesheet-kat" as *u8)
  // T21 notes: f2 has exactly one; unknown tid fails loud
  let out21: *i64 = sys_mmap(32) as *i64
  let rc21: i64 = pj_cmd_notes(prefix2, "fence" as *u8, "f2" as *u8, out21)
  let out21b: *i64 = sys_mmap(32) as *i64
  let rc21b: i64 = pj_cmd_notes(prefix2, "fence" as *u8, "zz9" as *u8, out21b)
  ok = 0
  if rc21 == 0 { if out21[0] == 1 { if rc21b != 0 { ok = 1 } } }
  pass = pass + pj_check(21, ok, "notes-roundtrip-neg" as *u8)
  // T22 template: blueprint -> dated TASK/MILE file -> the REAL planner loads it (E2E)
  let tplf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(tplf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(tplf, o, uniq)
  o = pj_cat(tplf, o, "_tpl.txt" as *u8)
  tplf[o] = 0 as u8
  let genf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(genf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(genf, o, uniq)
  o = pj_cat(genf, o, "_gen.txt" as *u8)
  genf[o] = 0 as u8
  let prefixC: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(prefixC, o, "/tmp/pjt_" as *u8)
  o = pj_catn(prefixC, o, uniq)
  o = pj_cat(prefixC, o, "_stC-" as *u8)
  prefixC[o] = 0 as u8
  pj_wfile(tplf, "TPLTASK t1 amber 0 60 3 - dig\nTPLTASK t2 bo 9 120 4 t1 pour\nTPLMILE m1 12 done-pour\n" as *u8)
  let av22: *i64 = sys_mmap(8 * 8) as *i64
  av22[0] = "pj" as *u8 as i64
  av22[1] = "template" as *u8 as i64
  av22[2] = tplf as i64
  av22[3] = "shed" as *u8 as i64
  av22[4] = "2026-07-25" as *u8 as i64
  av22[5] = genf as i64
  let rc22: i64 = pj_cmd_template(6, av22)
  ok = 0
  if rc22 == 0 {
      let gszp: *i64 = sys_mmap(16) as *i64
      let gbuf: *u8 = ss_readall(genf, gszp)
      let gsz: i64 = gszp[0]
      if gsz > 0 {
          let k1: i64 = pj_contains(gbuf, gsz, "TASK shed t1 amber 2026-07-25 60 3 - dig" as *u8)
          let k2: i64 = pj_contains(gbuf, gsz, "TASK shed t2 bo 2026-08-03 120 4 t1 pour" as *u8)
          let k3: i64 = pj_contains(gbuf, gsz, "MILE shed m1 2026-08-06 done-pour" as *u8)
          if k1 == 1 { if k2 == 1 { if k3 == 1 {
              let a22: *i64 = sys_mmap(8 * 8) as *i64
              a22[0] = "load" as *u8 as i64
              a22[1] = genf as i64
              a22[2] = prefixC as i64
              a22[3] = "7401" as *u8 as i64
              a22[4] = 0
              let rc22b: i64 = pj_run("_offc/nx_vizsla_plan.elf" as *u8, a22, outf)
              if rc22b == 0 {
                  let st22: *i64 = pj_st_new()
                  pj_gather(prefixC, "shed" as *u8, st22)
                  if st22[0] == 2 { ok = 1 }
              }
          } } }
      }
  }
  pass = pass + pj_check(22, ok, "template-to-planner-e2e" as *u8)
  // T23 owner html carries the schedule bars + risk summary
  let htmlf2: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(htmlf2, o, "/tmp/pjt_" as *u8)
  o = pj_catn(htmlf2, o, uniq)
  o = pj_cat(htmlf2, o, "_page2.html" as *u8)
  htmlf2[o] = 0 as u8
  let rc23: i64 = pj_html(prefix2, "fence" as *u8, "elder" as *u8, "2026-07-17" as *u8, htmlf2)
  ok = 0
  if rc23 == 0 {
      let hszp2: *i64 = sys_mmap(16) as *i64
      let hbuf2: *u8 = ss_readall(htmlf2, hszp2)
      let hsz2: i64 = hszp2[0]
      if hsz2 > 0 {
          let d1: i64 = pj_contains(hbuf2, hsz2, "Schedule (latest-safe windows)" as *u8)
          let d2: i64 = pj_contains(hbuf2, hsz2, "risk: overdue=" as *u8)
          let d3: i64 = pj_contains(hbuf2, hsz2, "posts delivered late" as *u8)
          if d1 == 1 { if d2 == 1 { if d3 == 1 { ok = 1 } } }
      }
  }
  pass = pass + pj_check(23, ok, "html-gantt-risk-owner" as *u8)
  // T24 NEG: non-digit LOG minutes refused
  let badl: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(badl, o, "/tmp/pjt_" as *u8)
  o = pj_catn(badl, o, uniq)
  o = pj_cat(badl, o, "_badlog.txt" as *u8)
  badl[o] = 0 as u8
  pj_wfile(badl, "LOG fence f2 bo 2026-07-16 abc\n" as *u8)
  let av24: *i64 = sys_mmap(8 * 8) as *i64
  av24[0] = "pj" as *u8 as i64
  av24[1] = "load" as *u8 as i64
  av24[2] = badl as i64
  av24[3] = prefix2 as i64
  av24[4] = "7104" as *u8 as i64
  let rc24: i64 = pj_cmd_load(5, av24)
  ok = 0
  if rc24 != 0 { ok = 1 }
  pass = pass + pj_check(24, ok, "neg-bad-log-minutes" as *u8)
  // T25 ASSIGN override: t2 (bob's) reassigned to carol -> effective owner flips everywhere
  let asgf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(asgf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(asgf, o, uniq)
  o = pj_cat(asgf, o, "_asg.txt" as *u8)
  asgf[o] = 0 as u8
  pj_wfile(asgf, "ASSIGN demo t2 carol 2026-07-15\n" as *u8)
  let av25: *i64 = sys_mmap(8 * 8) as *i64
  av25[0] = "pj" as *u8 as i64
  av25[1] = "load" as *u8 as i64
  av25[2] = asgf as i64
  av25[3] = prefix as i64
  av25[4] = "7501" as *u8 as i64
  let rc25: i64 = pj_cmd_load(5, av25)
  let out25: *i64 = sys_mmap(32) as *i64
  let rc25b: i64 = pj_view(prefix, "demo" as *u8, "carol" as *u8, out25)
  let w25: i64 = pj_open_min(prefix, "demo" as *u8, "carol" as *u8)
  ok = 0
  if rc25 == 0 { if rc25b == 0 { if out25[1] == 2 { if w25 == 210 { ok = 1 } } } }
  pass = pass + pj_check(25, ok, "assign-effective-owner" as *u8)
  // T26 level APPLY: the fence move becomes ASSIGN records; a re-run finds nothing left to move
  let out26: *i64 = sys_mmap(32) as *i64
  let rc26: i64 = pj_cmd_level(prefix2, "fence" as *u8, out26, "2026-07-18" as *u8)
  let out26b: *i64 = sys_mmap(32) as *i64
  let rc26b: i64 = pj_cmd_level(prefix2, "fence" as *u8, out26b, "-" as *u8)
  let st26: *i64 = pj_st_new()
  pj_gather(prefix2, "fence" as *u8, st26)
  let t26i: i64 = pj_find(st26[1] as *i64, st26[0], "f2" as *u8)
  var f2owner_ok: i64 = 0
  if t26i >= 0 {
      let ow26: *i64 = st26[2] as *i64
      if pj_eq(ow26[t26i] as *u8, "cade" as *u8) == 1 { f2owner_ok = 1 }
  }
  ok = 0
  if rc26 == 0 { if out26[0] == 1 { if rc26b == 0 { if out26b[0] == 0 { if out26b[1] == 0 { if f2owner_ok == 1 { ok = 1 } } } } } }
  pass = pass + pj_check(26, ok, "level-apply-assign-e2e" as *u8)
  // T27 latest-date wins (an EARLIER assign never regresses the owner) + NEG bad assign date
  let asgf2: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(asgf2, o, "/tmp/pjt_" as *u8)
  o = pj_catn(asgf2, o, uniq)
  o = pj_cat(asgf2, o, "_asg2.txt" as *u8)
  asgf2[o] = 0 as u8
  pj_wfile(asgf2, "ASSIGN demo t2 dave 2026-07-14\n" as *u8)
  let av27: *i64 = sys_mmap(8 * 8) as *i64
  av27[0] = "pj" as *u8 as i64
  av27[1] = "load" as *u8 as i64
  av27[2] = asgf2 as i64
  av27[3] = prefix as i64
  av27[4] = "7502" as *u8 as i64
  let rc27: i64 = pj_cmd_load(5, av27)
  let st27: *i64 = pj_st_new()
  pj_gather(prefix, "demo" as *u8, st27)
  let t27i: i64 = pj_find(st27[1] as *i64, st27[0], "t2" as *u8)
  var still_carol: i64 = 0
  if t27i >= 0 {
      let ow27: *i64 = st27[2] as *i64
      if pj_eq(ow27[t27i] as *u8, "carol" as *u8) == 1 { still_carol = 1 }
  }
  let badaf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(badaf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(badaf, o, uniq)
  o = pj_cat(badaf, o, "_badasg.txt" as *u8)
  badaf[o] = 0 as u8
  pj_wfile(badaf, "ASSIGN demo t2 carol not-a-date\n" as *u8)
  let av27b: *i64 = sys_mmap(8 * 8) as *i64
  av27b[0] = "pj" as *u8 as i64
  av27b[1] = "load" as *u8 as i64
  av27b[2] = badaf as i64
  av27b[3] = prefix as i64
  av27b[4] = "7503" as *u8 as i64
  let rc27b: i64 = pj_cmd_load(5, av27b)
  ok = 0
  if rc27 == 0 { if still_carol == 1 { if rc27b != 0 { ok = 1 } } }
  pass = pass + pj_check(27, ok, "assign-latest-wins-neg" as *u8)
2873
  // T28 snapshot -> BASE records; T29 baseline variance detects a due slip
  let snapf: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(snapf, o, "/tmp/pjt_" as *u8)
  o = pj_catn(snapf, o, uniq)
  o = pj_cat(snapf, o, "_snap.txt" as *u8)
  snapf[o] = 0 as u8
  let rc28: i64 = pj_cmd_snapshot(prefix2, "fence" as *u8, "2026-07-05" as *u8, snapf)
  let av28: *i64 = sys_mmap(8 * 8) as *i64
  av28[0] = "pj" as *u8 as i64
  av28[1] = "load" as *u8 as i64
  av28[2] = snapf as i64
  av28[3] = prefix2 as i64
  av28[4] = "7601" as *u8 as i64
  let rc28b: i64 = pj_cmd_load(5, av28)
  ok = 0
  if rc28 == 0 { if rc28b == 0 {
      let st28: *i64 = pj_st_new()
      pj_gather(prefix2, "fence" as *u8, st28)
      if st28[36] == 6 { ok = 1 }
  } }
  pass = pass + pj_check(28, ok, "snapshot-writes-baseline" as *u8)
  // T29 slip detection in a FRESH store: one task due 2026-07-20, baseline due 2026-07-12 -> +8 days slipped
  let prefixV: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(prefixV, o, "/tmp/pjt_" as *u8)
  o = pj_catn(prefixV, o, uniq)
  o = pj_cat(prefixV, o, "_stV-" as *u8)
  prefixV[o] = 0 as u8
  let vplan: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(vplan, o, "/tmp/pjt_" as *u8)
  o = pj_catn(vplan, o, uniq)
  o = pj_cat(vplan, o, "_vplan.txt" as *u8)
  vplan[o] = 0 as u8
  let vproj: *u8 = sys_mmap(256)
  o = 0
  o = pj_cat(vproj, o, "/tmp/pjt_" as *u8)
  o = pj_catn(vproj, o, uniq)
  o = pj_cat(vproj, o, "_vproj.txt" as *u8)
  vproj[o] = 0 as u8
  pj_wfile(vplan, "TASK dam d1 amber 2026-07-20 100 3 - build\n" as *u8)
  pj_wfile(vproj, "PROJ dam elder dam-build\nMEMBER dam amber team -\nBASE dam d1 2026-07-12 100 2026-07-01\n" as *u8)
  let avp: *i64 = sys_mmap(8 * 8) as *i64
  avp[0] = "load" as *u8 as i64
  avp[1] = vplan as i64
  avp[2] = prefixV as i64
  avp[3] = "7602" as *u8 as i64
  avp[4] = 0
  let rc29p: i64 = pj_run("_offc/nx_vizsla_plan.elf" as *u8, avp, outf)
  let av29: *i64 = sys_mmap(8 * 8) as *i64
  av29[0] = "pj" as *u8 as i64
  av29[1] = "load" as *u8 as i64
  av29[2] = vproj as i64
  av29[3] = prefixV as i64
  av29[4] = "7603" as *u8 as i64
  let rc29: i64 = pj_cmd_load(5, av29)
  let out29: *i64 = sys_mmap(32) as *i64
  let rc29b: i64 = pj_cmd_baseline(prefixV, "dam" as *u8, out29)
  ok = 0
  if rc29 == 0 { if rc29p == 0 { if rc29b == 0 { if out29[0] == 1 { if out29[1] == 8 { if out29[2] == 1 { ok = 1 } } } } } }
  pass = pass + pj_check(29, ok, "baseline-slip-detected" as *u8)
  // T30 burndown: fence has f4 DONE (effort 60); remaining = total - 60, done_points=1
  let out30: *i64 = sys_mmap(32) as *i64
  let rc30: i64 = pj_cmd_burndown(prefix2, "fence" as *u8, out30)
  ok = 0
  if rc30 == 0 { if out30[1] == 60 { if out30[3] == 1 { if out30[2] == out30[0] - 60 { ok = 1 } } } }
  pass = pass + pj_check(30, ok, "burndown-from-done" as *u8)
  // T31 NEG: baseline with no BASE records fails loud (demo has none)
  let out31: *i64 = sys_mmap(32) as *i64
  let rc31: i64 = pj_cmd_baseline(prefix, "demo" as *u8, out31)
  ok = 0
  if rc31 != 0 { ok = 1 }
  pass = pass + pj_check(31, ok, "neg-baseline-none" as *u8)
2948
  let rep: *u8 = sys_mmap(256)
  var z: i64 = 0
  z = pj_cat(rep, z, "NX-PROJECT-GATE pass=" as *u8)
  z = pj_catn(rep, z, pass)
  z = pj_cat(rep, z, "/31 verdict=" as *u8)
  if pass == 31 { z = pj_cat(rep, z, "GREEN\n" as *u8) } else { z = pj_cat(rep, z, "RED\n" as *u8) }
  sys_write(1, rep, z)
  if pass == 31 { return 0 }
  return 1
2958}
2959
2960// ---------------- CLI ----------------
2961func pj_usage() -> i64 {
  pj_p("nx_project: load | view | workload | level [apply <date>] | risk <today> | evm | timesheet | notes <tid> | template <tpl> <pid> <start> <out> | snapshot <prefix> <pid> <date> <out> | baseline <prefix> <pid> | burndown <prefix> <pid> | html <prefix> <pid> <person> <today> <out|-> | (argless = selftest)\n" as *u8)
  return 1
2964}
2965
2966func pj_cli(argc: i64, argv: *i64) -> i64 {
  if argc < 2 { return pj_selftest() }
  let cmd: *u8 = argv[1] as *u8
  if pj_eq(cmd, "load" as *u8) == 1 { return pj_cmd_load(argc, argv) }
  if pj_eq(cmd, "view" as *u8) == 1 {
      if argc < 5 { pj_p("PROJECT view needs <prefix> <pid> <person> -- fail loud\n" as *u8); return 1 }
      let out: *i64 = sys_mmap(32) as *i64
      return pj_view(argv[2] as *u8, argv[3] as *u8, argv[4] as *u8, out)
  }
  if pj_eq(cmd, "workload" as *u8) == 1 {
      if argc < 4 { pj_p("PROJECT workload needs <prefix> <pid> -- fail loud\n" as *u8); return 1 }
      return pj_cmd_workload(argv[2] as *u8, argv[3] as *u8)
  }
  if pj_eq(cmd, "level" as *u8) == 1 {
      if argc < 4 { pj_p("PROJECT level needs <prefix> <pid> [apply <date>] -- fail loud\n" as *u8); return 1 }
      let out2: *i64 = sys_mmap(32) as *i64
      var aply: *u8 = "-" as *u8
      if argc >= 6 { if pj_eq(argv[4] as *u8, "apply" as *u8) == 1 { aply = argv[5] as *u8 } }
      return pj_cmd_level(argv[2] as *u8, argv[3] as *u8, out2, aply)
  }
  if pj_eq(cmd, "risk" as *u8) == 1 {
      if argc < 5 { pj_p("PROJECT risk needs <prefix> <pid> <today> -- fail loud\n" as *u8); return 1 }
      let out3: *i64 = sys_mmap(48) as *i64
      return pj_cmd_risk(argv[2] as *u8, argv[3] as *u8, argv[4] as *u8, out3)
  }
  if pj_eq(cmd, "evm" as *u8) == 1 {
      if argc < 4 { pj_p("PROJECT evm needs <prefix> <pid> -- fail loud\n" as *u8); return 1 }
      let out4: *i64 = sys_mmap(32) as *i64
      return pj_cmd_evm(argv[2] as *u8, argv[3] as *u8, out4)
  }
  if pj_eq(cmd, "html" as *u8) == 1 {
      if argc < 7 { pj_p("PROJECT html needs <prefix> <pid> <person> <today> <outfile|-> -- fail loud\n" as *u8); return 1 }
      return pj_html(argv[2] as *u8, argv[3] as *u8, argv[4] as *u8, argv[5] as *u8, argv[6] as *u8)
  }
  if pj_eq(cmd, "timesheet" as *u8) == 1 {
      if argc < 4 { pj_p("PROJECT timesheet needs <prefix> <pid> -- fail loud\n" as *u8); return 1 }
      let out5: *i64 = sys_mmap(32) as *i64
      return pj_cmd_timesheet(argv[2] as *u8, argv[3] as *u8, out5)
  }
  if pj_eq(cmd, "notes" as *u8) == 1 {
      if argc < 5 { pj_p("PROJECT notes needs <prefix> <pid> <tid> -- fail loud\n" as *u8); return 1 }
      let out6: *i64 = sys_mmap(32) as *i64
      return pj_cmd_notes(argv[2] as *u8, argv[3] as *u8, argv[4] as *u8, out6)
  }
  if pj_eq(cmd, "template" as *u8) == 1 { return pj_cmd_template(argc, argv) }
  if pj_eq(cmd, "snapshot" as *u8) == 1 {
      if argc < 6 { pj_p("PROJECT snapshot needs <prefix> <pid> <date> <outfile> -- fail loud\n" as *u8); return 1 }
      return pj_cmd_snapshot(argv[2] as *u8, argv[3] as *u8, argv[4] as *u8, argv[5] as *u8)
  }
  if pj_eq(cmd, "baseline" as *u8) == 1 {
      if argc < 4 { pj_p("PROJECT baseline needs <prefix> <pid> -- fail loud\n" as *u8); return 1 }
      let out7: *i64 = sys_mmap(32) as *i64
      return pj_cmd_baseline(argv[2] as *u8, argv[3] as *u8, out7)
  }
  if pj_eq(cmd, "burndown" as *u8) == 1 {
      if argc < 4 { pj_p("PROJECT burndown needs <prefix> <pid> -- fail loud\n" as *u8); return 1 }
      let out8: *i64 = sys_mmap(32) as *i64
      return pj_cmd_burndown(argv[2] as *u8, argv[3] as *u8, out8)
  }
  return pj_usage()
3026}
nx_project.nx source

`nx_project.nx` source
