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

↩ module page · 253 lines · 9310 B
1// nx_sponsor_core.nx -- EXECUTIVE-SPONSOR decision core (mainless; operator
2// doctrine 2026-06-11): the sponsor is NOT a gate on objective work -- parity
3// rungs, kernels, conformance counts flow TODO->DONE on evidence with no
4// human in the path.  The sponsor's viewpoint enters at exactly TWO points:
5//   spec time:   NOVEL rows tagged ||ASK=spec  (subjective feature choices --
6//                "the novel needs us both", sponsor + tutor co-spec batch)
7//   result time: rows tagged ||ASK=result reach VIEW (flipped by reconcile
8//                when their objective evidence is green) and wait for a
9//                VIEWPOINT: APPROVE -> DONE; DENY+feedback -> NOVEL (iterate)
10//                with the feedback appended to planning_prefs.tsv -- the
11//                registry future planning READS (preference learning as DATA).
12// Decisions arrive via knowledge/registry/sponsor_decisions.tsv (hand rows
13// today; the nishifamily intake form lands the same contract later):
14//   APPROVE <id>
15//   DENY <id> <feedback...>
16// Transitions are a strict state machine (only VIEW moves); anything else =
17// loud REFUSED row, repeated decisions = silent no-ops (idempotent).
18// license_tier: ORIGINAL
19
20import "nx_wd_core.nx"
21const K_MAGIC_65536: i64 = 65536
22const K_MAGIC_65535: i64 = 65535
23
24// status byte of id in queue (fresh load each call; flips rewrite the file)
25func sr_status(qp: *u8, id: *u8) -> i64 {
  let cx: *i64 = an_newcx()
  if an_load(qp, cx) <= 0 { return 0 - 1 }
  let r: i64 = an_find(cx, id)
  if r < 0 { return 0 - 1 }
  let st: *i64 = cx[4] as *i64
  return st[r]
32}
33
34// every decision's reason is TRAINING DATA (operator 2026-06-11: "capture
35// feedback on all decisions so we can use it to train and improve the team
36// system including the ai pieces") -- PREF rows carry the verb too.
37func sr_pref_append(prefs: *u8, id: *u8, action: *u8, fb: *u8) -> i64 {
  let fd: i64 = sys_openat_append(prefs, 0x1a4)
  if fd < 0 { return 0 }
  wd_w(fd, "PREF id=" as *u8)
  wd_w(fd, id)
  wd_w(fd, " action=" as *u8)
  wd_w(fd, action)
  wd_w(fd, " feedback=" as *u8)
  wd_w(fd, fb)
  wd_w(fd, " epoch=" as *u8)
  wd_wn(fd, sys_now_realtime_sec())
  wd_w(fd, "\n" as *u8)
  sys_close(fd)
  return 1
51}
52
53// apply one decision; returns 1 applied, 0 no-op, -1 refused (loud).
54// verbs: 1=APPROVE (VIEW->DONE, ship), 2=REWORK (VIEW->NOVEL, refine the
55// deliverable), 3=RESTART (VIEW->NOVEL, re-spec from zero -- the distinction
56// from REWORK lives in the learned action), 4=DENY (VIEW->KILLED, terminal
57// business kill: duplicative / no ROI; never resurrected by evidence).
58func sr_apply(qp: *u8, prefs: *u8, verb: i64, id: *u8, fb: *u8) -> i64 {
  let st: i64 = sr_status(qp, id)
  if st < 0 { return 0 - 1 }
  if verb == 1 {
      if st == 86 {
          wd_flip_status(qp, id, "DONE" as *u8)
          sr_pref_append(prefs, id, "APPROVE" as *u8, fb)
          return 1
      }
      if st == 68 { return 0 }
      return 0 - 1
  }
  if verb == 2 {
      if st == 86 {
          wd_flip_status(qp, id, "NOVEL" as *u8)
          sr_pref_append(prefs, id, "REWORK" as *u8, fb)
          return 1
      }
      if st == 78 { return 0 }
      return 0 - 1
  }
  if verb == 3 {
      if st == 86 {
          wd_flip_status(qp, id, "NOVEL" as *u8)
          sr_pref_append(prefs, id, "RESTART" as *u8, fb)
          return 1
      }
      if st == 78 { return 0 }
      return 0 - 1
  }
  if st == 86 {
      wd_flip_status(qp, id, "KILLED" as *u8)
      sr_pref_append(prefs, id, "DENY" as *u8, fb)
      return 1
  }
  // DENY is ALSO legal on NOVEL: the sponsor flags a raised hand as
  // duplicative/no-ROI BEFORE tutor time burns ("flagging the novel",
  // operator 2026-06-11).  Reason captured like every verb.
  if st == 78 {
      wd_flip_status(qp, id, "KILLED" as *u8)
      sr_pref_append(prefs, id, "DENY" as *u8, fb)
      return 1
  }
  if st == 75 { return 0 }
  return 0 - 1
103}
104
105// census: NOVEL rows tagged ||ASK=spec = the sponsor+tutor co-spec batch
106func sr_askspec(qp: *u8, lfd: i64) -> i64 {
  let cx: *i64 = an_newcx()
  if an_load(qp, cx) <= 0 { return 0 }
  let st: *i64 = cx[4] as *i64
  var cnt: i64 = 0
  var r: i64 = 0
  while r < cx[0] {
      if st[r] == 78 {
          let g: *u8 = an_gate_at(cx, r)
          var gl: i64 = 0
          while g[gl] != (0 as u8) { gl = gl + 1 }
          var j: i64 = 0
          var hit: i64 = 0
          while j < gl {
              if wd_at(g, gl, j, "||ASK=spec" as *u8, 10) == 1 { hit = 1; j = gl } else { j = j + 1 }
          }
          if hit == 1 {
              cnt = cnt + 1
              wd_w(1, "SPONSOR-SPEC id=" as *u8)
              wd_w(1, an_id_at(cx, r))
              wd_w(1, " (needs sponsor+tutor co-spec)\n" as *u8)
              if lfd >= 0 {
                  wd_w(lfd, "SPONSOR-SPEC id=" as *u8)
                  wd_w(lfd, an_id_at(cx, r))
                  wd_w(lfd, "\n" as *u8)
              }
          }
      }
      r = r + 1
  }
  return cnt
137}
138
139// skip spaces/tabs from p (bounded by le); returns new p
140func sr_skipws(buf: *u8, p: i64, le: i64) -> i64 {
  var q: i64 = p
  var sk: i64 = 1
  while sk == 1 {
      if q >= le { sk = 0 } else {
          var sp: i64 = 0
          if buf[q] == (32 as u8) { sp = 1 }
          if buf[q] == (9 as u8) { sp = 1 }
          if sp == 1 { q = q + 1 } else { sk = 0 }
      }
  }
  return q
152}
153
154// scx block: scx[0]=qp scx[1]=prefs scx[2]=applied-counter scx[3]=refused
155// scx[4]=lfd.  Process one decision line [ls, le) -- hoisted out of sr_run
156// to keep the if-nesting flat (the 4-deep miscompile law).
157func sr_line(scx: *i64, buf: *u8, n: i64, ls: i64, le: i64) -> i64 {
  if le <= ls { return 0 }
  if buf[ls] == (35 as u8) { return 0 }
  var verb: i64 = 0 - 1
  var p: i64 = ls
  if wd_at(buf, n, p, "APPROVE" as *u8, 7) == 1 { verb = 1; p = p + 7 }
  if verb < 0 { if wd_at(buf, n, p, "REWORK" as *u8, 6) == 1 { verb = 2; p = p + 6 } }
  if verb < 0 { if wd_at(buf, n, p, "RESTART" as *u8, 7) == 1 { verb = 3; p = p + 7 } }
  if verb < 0 { if wd_at(buf, n, p, "DENY" as *u8, 4) == 1 { verb = 4; p = p + 4 } }
  if verb < 0 { return 0 }
  p = sr_skipws(buf, p, le)
  let id: *u8 = sys_mmap(64)
  var k: i64 = 0
  var go: i64 = 1
  while go == 1 {
      if p >= le { go = 0 } else {
          var sp: i64 = 0
          if buf[p] == (32 as u8) { sp = 1 }
          if buf[p] == (9 as u8) { sp = 1 }
          if sp == 1 { go = 0 } else {
              if k < 63 { id[k] = buf[p]; k = k + 1 }
              p = p + 1
          }
      }
  }
  id[k] = 0 as u8
  if k == 0 { return 0 }
  p = sr_skipws(buf, p, le)
  let fb: *u8 = sys_mmap(512)
  var f: i64 = 0
  while p < le { if f < 511 { fb[f] = buf[p]; f = f + 1 } p = p + 1 }
  fb[f] = 0 as u8
  let rv: i64 = sr_apply(scx[0] as *u8, scx[1] as *u8, verb, id, fb)
  let lfd: i64 = scx[4]
  if rv == 1 {
      scx[2] = scx[2] + 1
      wd_w(1, "SPONSOR applied id=" as *u8); wd_w(1, id)
      if verb == 1 { wd_w(1, " -> DONE\n" as *u8) }
      if verb == 2 { wd_w(1, " -> NOVEL (rework w/ feedback)\n" as *u8) }
      if verb == 3 { wd_w(1, " -> NOVEL (restart from spec)\n" as *u8) }
      if verb == 4 { wd_w(1, " -> KILLED (business kill)\n" as *u8) }
      if lfd >= 0 { wd_w(lfd, "SPONSOR applied id=" as *u8); wd_w(lfd, id); wd_w(lfd, "\n" as *u8) }
  }
  if rv < 0 {
      scx[3] = scx[3] + 1
      wd_w(1, "SPONSOR REFUSED id=" as *u8); wd_w(1, id)
      wd_w(1, " (unknown id or illegal transition)\n" as *u8)
      if lfd >= 0 { wd_w(lfd, "SPONSOR REFUSED id=" as *u8); wd_w(lfd, id); wd_w(lfd, "\n" as *u8) }
  }
  return 0
207}
208
209// the full review pass; returns 0 (loud rows carry the news, beat stays green)
210func sr_run(qp: *u8, dec: *u8, prefs: *u8, logpath: *u8) -> i64 {
  let lfd: i64 = sys_openat_append(logpath, 0x1a4)
  let buf: *u8 = sys_mmap(K_MAGIC_65536)
  var n: i64 = 0
  let fd: i64 = sys_openat_rd(dec)
  if fd >= 0 {
      var rr: i64 = sys_read(fd, buf, K_MAGIC_65535)
      while rr > 0 { n = n + rr; rr = sys_read(fd, buf + n, K_MAGIC_65535 - n) }
      sys_close(fd)
  }
  let scx: *i64 = sys_mmap(64) as *i64
  scx[0] = qp as i64
  scx[1] = prefs as i64
  scx[2] = 0
  scx[3] = 0
  scx[4] = lfd
  var ls: i64 = 0
  var i: i64 = 0
  while i <= n {
      var eol: i64 = 0
      if i == n { eol = 1 } else { if buf[i] == (10 as u8) { eol = 1 } }
      if eol == 1 {
          sr_line(scx, buf, n, ls, i)
          ls = i + 1
      }
      i = i + 1
  }
  let ask: i64 = sr_askspec(qp, lfd)
  var p2: i64 = 0
  while p2 < 2 {
      var ofd: i64 = 1
      if p2 == 1 { ofd = lfd }
      if ofd >= 0 {
          wd_w(ofd, "SPONSOR applied=" as *u8); wd_wn(ofd, scx[2])
          wd_w(ofd, " refused=" as *u8); wd_wn(ofd, scx[3])
          wd_w(ofd, " askspec=" as *u8); wd_wn(ofd, ask)
          wd_w(ofd, " epoch=" as *u8); wd_wn(ofd, sys_now_realtime_sec())
          wd_w(ofd, " verdict=GREEN\n" as *u8)
      }
      p2 = p2 + 1
  }
  if lfd >= 0 { sys_close(lfd) }
  return 0
253}
nx_sponsor_core.nx source

`nx_sponsor_core.nx` source
