code wiki / (root) / nx_orchestrate_raci_evaluate_gate_t144.nx
`nx_orchestrate_raci_evaluate_gate_t144.nx` source

1// nx_orchestrate_raci_evaluate_gate_t144.nx -- Configures and validates a workflow evaluation process with snapshot retention and binding checks.
2import "nx_orchestrate_raci_evaluate_t144.nx"
3import "nx_gate_verdict.nx"
4import "nx_store_seed_lib.nx"
5func main(argc:i64,argv:*i64)->i64 {
if argc!=2{return 2};if or_slen(argv[1] as *u8)>OR_BIND_CELL-32{return 2}
if sys_mkdir(argv[1] as *u8,448)!=0{return 2}
let ctr:*i64=gv_ctr();gv_head("RACI-CONFIGURED-EVALUATION-PRIVATE")
let cells:*u8=sys_mmap_shared(OR_BIND_CELL*4)
let organ:*u8=cells;let verb:*u8=cells+OR_BIND_CELL;let id:*u8=cells+OR_BIND_CELL*2;let prefix:*u8=cells+OR_BIND_CELL*3
let legacy:*u8="analyze\tnx_wfcost\n"
var rc:i64=orch_binding_buffer(legacy,or_slen(legacy),"analyze",organ,verb,id,prefix)
gv_check("legacy two column binding preserved",rc==1&&or_eq(organ,"nx_wfcost")==1&&verb[0]==(0 as u8)&&id[0]==(0 as u8),ctr)
let extended:*u8="analyze\tnx_wfcost\tevaluate-config\tbaseline\n"
rc=orch_binding_buffer(extended,or_slen(extended),"analyze",organ,verb,id,prefix)
gv_check("explicit verb and configuration selected",rc==1&&or_eq(verb,"evaluate-config")==1&&or_eq(id,"baseline")==1&&prefix[0]==(0 as u8),ctr)
let config_dir:*u8=sys_mmap_shared(OR_BIND_CELL*4);var co:i64=or_cat(config_dir,0,argv[1] as *u8)
var di:i64=0;var made:i64=1
while di<4{co=or_cat(config_dir,co,"/configuration-snapshot-location");if sys_mkdir(config_dir,448)!=0{made=0};di=di+1}
gv_check("long valid configuration directory exists",made==1&&or_slen(config_dir)>=OR_BIND_CELL,ctr)
let cfg_prefix:*u8=sys_mmap_shared(OR_BIND_CELL*4);co=or_cat(cfg_prefix,0,config_dir);co=or_cat(cfg_prefix,co,"/config-")
let snapshot:*u8=sys_mmap_shared(OR_BIND_CELL);co=or_cat(snapshot,0,argv[1] as *u8);co=or_cat(snapshot,co,"/consumed-bindings.tsv")
let cfg:*u8=sys_mmap_shared(OR_BIND_CELL*8)
co=or_cat(cfg,0,"baseline\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t1789076880\t1789077120\t/tmp/wfcost-binding-t144-b/retained-bindings-\tenabled\t")
co=or_cat(cfg,co,snapshot);co=or_cat(cfg,co,"\npaused\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t1789076880\t1789077120\t-\tpaused\n")
gv_check("isolated configured workflow explicitly selects snapshot retention",sts_seed(cfg_prefix,cfg,co)==2,ctr)
let row:*u8=sys_mmap_shared(OR_BIND_CELL*4);co=or_cat(row,0,"analyze\tnx_wfcost_outcomes_t144\tevaluate-config\tbaseline\t");co=or_cat(row,co,cfg_prefix);co=or_cat(row,co,"\n")
rc=orch_binding_buffer(row,or_slen(row),"analyze",organ,verb,id,prefix)
gv_check("legacy cell wrapper refuses long path without truncation",rc<0&&prefix[0]==(0 as u8),ctr)
let duplicate:*u8="analyze\tnx_wfcost\nanalyze\tnx_tokroi\n"
gv_check("duplicate selected activity refuses",orch_binding_buffer(duplicate,or_slen(duplicate),"analyze",organ,verb,id,prefix)<0,ctr)
let partial:*u8="analyze\tnx_wfcost\tevaluate-config\n"
gv_check("verb without configuration refuses",orch_binding_buffer(partial,or_slen(partial),"analyze",organ,verb,id,prefix)<0,ctr)
let missing:*u8="organize\tnx_librarian_review_gate\n"
gv_check("unbound activity remains explicitly unbound",orch_binding_buffer(missing,or_slen(missing),"analyze",organ,verb,id,prefix)==0,ctr)
let command:*u8="analyze\tnx_wfcost;evil\tevaluate-config\tbaseline\n"
gv_check("organ shell punctuation refused",orch_binding_buffer(command,or_slen(command),"analyze",organ,verb,id,prefix)<0,ctr)
let invalid_verb:*u8="analyze\tnx_wfcost\t--install\tbaseline\n"
gv_check("option-shaped verb must refuse",orch_binding_buffer(invalid_verb,or_slen(invalid_verb),"analyze",organ,verb,id,prefix)<0,ctr)
let invalid_id:*u8="analyze\tnx_wfcost\tevaluate-config\t--install\n"
gv_check("option-shaped configuration ID refuses before dispatch",orch_binding_buffer(invalid_id,or_slen(invalid_id),"analyze",organ,verb,id,prefix)<0,ctr)
let path:*u8=sys_mmap_shared(OR_BIND_CELL);var o:i64=or_cat(path,0,argv[1] as *u8);o=or_cat(path,o,"/workstreams.conf")
let fd:i64=sys_openat_exclusive(path,384)
gv_check("private workstream configuration exclusive create",fd>=0,ctr)
let wsbytes:i64=OR_MAGIC_16384+1+or_slen(row)
let ws:*u8=sys_mmap_shared(wsbytes+or_slen(row)+1);var wi:i64=0;while wi<OR_MAGIC_16384{ws[wi]=35 as u8;wi=wi+1};ws[wi]=10 as u8;wi=wi+1;or_cat(ws,wi,row)
if fd>=0{gv_check("private workstream beyond old16KiB complete",sys_write(fd,ws,wsbytes)==wsbytes&&sys_fsync(fd)==0&&sys_close(fd)==0,ctr)}
let owned:*NxOrBinding=sys_mmap_shared(__size_of(NxOrBinding)) as *NxOrBinding
gv_check("selected binding after16KiB retains full valid config path",orch_binding_read(path,"analyze",owned)==1&&or_eq(owned.prefix,cfg_prefix)==1&&or_slen(owned.prefix)>=OR_BIND_CELL,ctr)
gv_check("owned selected file released",or_binding_release(owned)==0,ctr)
let spans:*i64=sys_mmap_shared(OR_BIND_FIELDS*2*8) as *i64
gv_check("negative caller buffer extent refuses",orch_binding_select(ws,-1,"analyze",spans)==-4,ctr)
or_cat(ws,wsbytes,row)
gv_check("duplicate selected row after old file ceiling refuses",orch_binding_select(ws,wsbytes+or_slen(row),"analyze",spans)==-4,ctr)
let long_id:*u8=sys_mmap_shared(OR_BIND_CELL*4);var li:i64=or_cat(long_id,0,"analyze\tnx_wfcost\tevaluate-config\t");var lk:i64=0;while lk<OR_BIND_CELL*2{long_id[li]=97 as u8;li=li+1;lk=lk+1};long_id[li]=10 as u8;li=li+1;long_id[li]=0
gv_check("selected configuration ID longer than legacy cell accepted",orch_binding_select(long_id,li,"analyze",spans)==1&&spans[7]==OR_BIND_CELL*2,ctr)
let empty_path:*u8=sys_mmap_shared(OR_BIND_CELL);var eo:i64=or_cat(empty_path,0,argv[1] as *u8);eo=or_cat(empty_path,eo,"/empty.conf")
let efd:i64=sys_openat_exclusive(empty_path,384);gv_check("explicit empty workstream file created",efd>=0&&sys_fsync(efd)==0&&sys_close(efd)==0,ctr)
gv_check("explicit empty file is unbound not missing",orch_binding_read(empty_path,"analyze",owned)==0&&or_eq(owned.stage,"unbound")==1,ctr);or_binding_release(owned)
eo=or_cat(empty_path,0,argv[1] as *u8);eo=or_cat(empty_path,eo,"/absent.conf")
gv_check("missing workstreams remains observed missing",orch_binding_read(empty_path,"analyze",owned)==-2&&owned.code==(0-2)&&or_eq(owned.stage,"missing")==1,ctr);or_binding_release(owned)
gv_check("directory cannot masquerade as empty workstreams",orch_binding_read(argv[1] as *u8,"analyze",owned)<0,ctr);or_binding_release(owned)
gv_check("selected-reader gate workspace released",sys_munmap(ws,wsbytes+or_slen(row)+1)==0&&sys_munmap(owned as *u8,__size_of(NxOrBinding))==0&&sys_munmap(spans as *u8,OR_BIND_FIELDS*2*8)==0&&sys_munmap(long_id,OR_BIND_CELL*4)==0&&sys_munmap(empty_path,OR_BIND_CELL)==0,ctr)
let record_prefix:*u8=sys_mmap_shared(OR_BIND_CELL);o=or_cat(record_prefix,0,argv[1] as *u8);o=or_cat(record_prefix,o,"/engagement-")
gv_check("real estate RACI context resolves",ep_anchor()>=0,ctr)
let acct:*u8=sys_mmap_shared(OR_BIND_CELL)
gv_check("actual analyze accountability resolves",orch_accountable("analyze",acct)==1&&or_eq(acct,"analyst")==1,ctr)
let engaged:i64=orch_engage_from("analyze",1,path,record_prefix)
gv_check("actual configured child evaluation exits successfully",engaged==1,ctr)
let h:*i64=ss_open(record_prefix);let p:*i64=sys_mmap_shared(16) as *i64;let n:*i64=sys_mmap_shared(16) as *i64
var recorded:i64=0
if (h as i64)!=0{if ss_hget(h,"orch:engage:analyze",p,n)==1{
let v:*u8=p[0] as *u8;var i:i64=0;let needle:*u8="|verb_hex=6576616c756174652d636f6e666967|configuration_id_hex=626173656c696e65|configuration_plane_hex="
while i+or_slen(needle)<=n[0]{var k:i64=0;var same:i64=1;while k<or_slen(needle){if v[i+k]!=needle[k]{same=0};k=k+1};if same==1{recorded=1};i=i+1}
};ss_close(h)}
gv_check("engagement record retains exact invoked configuration fields",recorded==1,ctr)
77
let paused_path:*u8=sys_mmap_shared(OR_BIND_CELL);o=or_cat(paused_path,0,argv[1] as *u8);o=or_cat(paused_path,o,"/paused.conf")
let paused_row:*u8=sys_mmap_shared(OR_BIND_CELL*4);co=or_cat(paused_row,0,"analyze\tnx_wfcost_outcomes_t144\tevaluate-config\tpaused\t");co=or_cat(paused_row,co,cfg_prefix);co=or_cat(paused_row,co,"\n")
let pfd:i64=sys_openat_exclusive(paused_path,384)
gv_check("paused workstream fixture created exclusively",pfd>=0,ctr)
if pfd>=0{gv_check("paused workstream fixture complete",sys_write(pfd,paused_row,or_slen(paused_row))==or_slen(paused_row)&&sys_fsync(pfd)==0&&sys_close(pfd)==0,ctr)}
gv_check("actual paused child is RAN-NONZERO not successful engagement",orch_engage_from("analyze",1,paused_path,record_prefix)==0,ctr)
gv_check("paused path released",sys_munmap(paused_path,OR_BIND_CELL)==0,ctr)
gv_check("configured snapshot fixture buffers released",sys_munmap(cfg_prefix,OR_BIND_CELL*4)==0&&sys_munmap(config_dir,OR_BIND_CELL*4)==0&&sys_munmap(snapshot,OR_BIND_CELL)==0&&sys_munmap(cfg,OR_BIND_CELL*8)==0&&sys_munmap(row,OR_BIND_CELL*4)==0&&sys_munmap(paused_row,OR_BIND_CELL*4)==0,ctr)
86
gv_check("gate owned buffers released",sys_munmap(cells,OR_BIND_CELL*4)==0&&sys_munmap(path,OR_BIND_CELL)==0&&sys_munmap(record_prefix,OR_BIND_CELL)==0&&sys_munmap(acct,OR_BIND_CELL)==0&&sys_munmap(p as *u8,16)==0&&sys_munmap(n as *u8,16)==0,ctr)
return gv_verdict("RACI-CONFIGURED-EVALUATION-PRIVATE",ctr,"legacy binding preserved; real RACI child dispatch and retained invocation")
89}
nx_orchestrate_raci_evaluate_gate_t144.nx source

`nx_orchestrate_raci_evaluate_gate_t144.nx` source
