nx_hr_autoraci_gate.nx source

1// nx_hr_autoraci_gate.nx -- referee for HR rung B (auto-keep RACI from live work). PROVES the sweep flags every 2// active area with no Accountable coverage as a STAFFING GAP, marks covered areas COVERED, and counts gaps. 3// GREEN iff every row matches. Prints verdict=GREEN to STDOUT + returns the exit code. 4// Durable -> knowledge/status/hr_autoraci_gate.log. license_tier: ORIGINAL 5import "nx_hr_autoraci.nx" 6import "nx_g_puts_lib.nx" 7import "nx_syscalls.nx" 8 9func g_num(v: i64) -> i64 { let bb: *u8=sys_mmap(28); var m: i64=v; if m<0{m=0-m;sys_write(1,"-" as *u8,1)}; let t: *u8=sys_mmap(28); var k: i64=0; if m==0{t[0]=(48 as u8);k=1}; while m>0{t[k]=((48+(m%10)) as u8);m=m/10;k=k+1}; var i: i64=0; while i<k{bb[i]=t[k-1-i];i=i+1}; sys_write(1,bb,k); return 0 } 10func g_w(fd: i64, s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(fd,s,n); return 0 } 11func g_wn(fd: i64, v: i64) -> i64 { let bb: *u8=sys_mmap(28); var m: i64=v; if m<0{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{bb[i]=t[k-1-i];i=i+1}; sys_write(fd,bb,k); return 0 } 12func rput(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 } 13func gwrite(path: *u8, s: *u8, n: i64) -> i64 { let fd: i64 = sys_openat_wr(path, 0x1a4); if fd<0 { return 0 } if n>0 { sys_write(fd, s, n) } sys_close(fd); return 0 } 14func hrow(buf: *u8, o: i64, area: *u8, role: *u8, lc: i64) -> i64 { var p: i64=rput(buf,o,area); buf[p]=9 as u8;p=p+1; p=rput(buf,p,role); buf[p]=9 as u8;p=p+1; buf[p]=lc as u8;p=p+1; buf[p]=10 as u8;p=p+1; return p } 15func has(path: *u8, needle: *u8) -> i64 { 16 let buf: *u8 = sys_mmap(262144); let fd: i64 = sys_openat_rd(path); if fd<0 { return 0 } 17 var n: i64=0; var go: i64=1; while go==1 { let r: i64=sys_read(fd, buf+n, 262144-n); if r<=0 {go=0} else { n=n+r; if n>=262144 {go=0} } } sys_close(fd) 18 var nl: i64=0; while needle[nl]!=(0 as u8){nl=nl+1}; if nl<=0 { return 0 } 19 var i: i64=0; while i+nl<=n { var j: i64=0; var m: i64=1; while j<nl { if buf[i+j]!=needle[j] {m=0;j=nl} else {j=j+1} } if m==1 { return 1 } i=i+1 } return 0 20} 21func chk(got: i64, want: i64, label: *u8) -> i64 { 22 g_puts(" "); g_puts(label); g_puts(" got="); g_num(got); g_puts(" want="); g_num(want) 23 if got == want { g_puts(" PASS\n"); return 1 } 24 g_puts(" FAIL\n"); return 0 25} 26 27func main() -> i64 { 28 g_puts("=== NISHI HR AUTO-RACI GATE (sweep live work-areas -> flag uncovered = staffing gaps) ===\n" as *u8) 29 var pass: i64=0 30 var rows: i64=0 31 let raci: *u8 = "/tmp/nx_hra_raci" as *u8 32 let areas:*u8 = "/tmp/nx_hra_areas" as *u8 33 let rep: *u8 = "/tmp/nx_hra_report" as *u8 34 35 let rb: *u8 = sys_mmap(1024); var o: i64 = 0 36 o = hrow(rb, o, "deploy" as *u8, "release_master" as *u8, HRT_A) 37 o = hrow(rb, o, "deploy" as *u8, "engineer" as *u8, HRT_R) 38 o = hrow(rb, o, "review" as *u8, "engineer" as *u8, HRT_R) // no Accountable -> gap 39 o = hrow(rb, o, "ship" as *u8, "release_master" as *u8, HRT_A) // no Responsible -> gap 40 gwrite(raci, rb, o) 41 // active work-areas (as the WMS would feed them): deploy(covered), review(gap), ship(gap), docs(absent->gap) 42 gwrite(areas, "deploy\nreview\nship\ndocs\n" as *u8, 24) 43 44 rows=rows+1; pass=pass+chk(hra_emit_report(areas, raci, rep), 3, "sweep -> 3 staffing gaps (review/ship/docs)" as *u8) 45 rows=rows+1; pass=pass+chk(hra_gap_count(areas, raci), 3, "gap_count -> 3" as *u8) 46 rows=rows+1; pass=pass+chk(has(rep, "deploy\tCOVERED" as *u8), 1, "report: deploy COVERED" as *u8) 47 rows=rows+1; pass=pass+chk(has(rep, "review\tGAP" as *u8), 1, "report: review GAP (no Accountable)" as *u8) 48 rows=rows+1; pass=pass+chk(has(rep, "ship\tGAP" as *u8), 1, "report: ship GAP (no Responsible)" as *u8) 49 rows=rows+1; pass=pass+chk(has(rep, "docs\tGAP" as *u8), 1, "report: docs GAP (work with no RACI at all)" as *u8) 50 51 // a fully-staffed area list -> 0 gaps (no false alarms) 52 gwrite(areas, "deploy\n" as *u8, 7) 53 rows=rows+1; pass=pass+chk(hra_gap_count(areas, raci), 0, "fully-covered list -> 0 gaps (no false alarm)" as *u8) 54 55 g_puts("----\nNISHI-HR-AUTORACI-GATE rows=" as *u8); g_num(rows); g_puts(" pass=" as *u8); g_num(pass) 56 if pass==rows { g_puts(" verdict=GREEN\n" as *u8) } else { g_puts(" verdict=RED\n" as *u8) } 57 let lg: i64=sys_openat_append("knowledge/status/hr_autoraci_gate.log" as *u8, 0x1a4) 58 if lg>=0 { 59 g_w(lg, "NISHI-HR-AUTORACI-GATE rows=" as *u8); g_wn(lg, rows); g_w(lg, " pass=" as *u8); g_wn(lg, pass) 60 if pass==rows { g_w(lg, " verdict=GREEN\n" as *u8) } else { g_w(lg, " verdict=RED\n" as *u8) } 61 sys_close(lg) 62 } 63 if pass==rows { sys_exit(0); return 0 } 64 sys_exit(1); return 1 65}