nx_estate_docs_gate.nx source

1// nx_estate_docs_gate.nx -- proves the WHOLE Nishi estate-office pipeline end to end, all sovereign, by driving 2// the real elfs: nx_estate_inventory (authoritative will inventory) -> `export` (mail-merge-ready TSV) -> 3// nx_mailmerge (against a bequest template) -> one personalized .docx per beneficiary -> nx_docx `read` to 4// verify each. This is the operator's executor-conflict-reducer realized as ONE flow: the single source of 5// truth for the estate auto-generates the per-heir distribution documents (no hand transcription to dispute). 6// GREEN iff 7/7. Requires /tmp/nx_estate_inventory.sov.elf + /tmp/nx_docx.sov.elf + /tmp/nx_mailmerge.sov.elf. 7// Durable knowledge/status/estate_docs_gate.log. license_tier: ORIGINAL 8import "nx_syscalls.nx" 9import "nx_g_puts_lib.nx" 10 11func 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 } 12func 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 } 13func 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 } 14func g_strlen(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} return n } 15func g_read(path: *u8, buf: *u8, cap: i64) -> i64 { 16 let fd: i64=sys_openat_rd(path); if fd<0 { return 0 } 17 var total: i64=0; var nrd: i64=sys_read(fd, buf, cap) 18 while nrd>0 { total=total+nrd; if total>=cap { nrd=0 } else { nrd=sys_read(fd, ((buf as i64)+total) as *u8, cap-total) } } 19 sys_close(fd); return total 20} 21func g_contains(hay: *u8, n: i64, needle: *u8) -> i64 { 22 let nl: i64=g_strlen(needle); if nl==0 { return 0 } 23 var i: i64=0 24 while i+nl<=n { var j: i64=0; var hit: i64=1; while j<nl { if hay[i+j]!=needle[j] { hit=0; j=nl } else { j=j+1 } } if hit==1 { return 1 } i=i+1 } 25 return 0 26} 27func g_run(elf: *u8, args: *i64, nargs: i64, out_path: *u8) -> i64 { 28 let pid: i64=sys_fork() 29 if pid==0 { 30 let o: i64=sys_openat_wr(out_path, 0x1a4); if o>=0 { sys_dup3(o,1,0) } 31 let argv: *i64=sys_mmap(8*16) as *i64 32 argv[0]=elf as i64 33 var i: i64=0; while i<nargs { argv[1+i]=args[i]; i=i+1 } argv[1+nargs]=0 34 let envp: *i64=sys_mmap(16) as *i64; envp[0]="PATH=/usr/bin:/bin" as *u8 as i64; envp[1]=0 35 sys_execve(elf, argv, envp); sys_exit(127) 36 } 37 let st: *i64=sys_mmap(16) as *i64; sys_wait4(pid, st, 0); return (st[0]>>8)&0xff 38} 39 40func main() -> i64 { 41 g_puts("=== ESTATE -> DOCUMENTS PIPELINE GATE (inventory -> export -> mail merge -> per-heir .docx) ===\n" as *u8) 42 let ESTATE: *u8="/tmp/nx_estate_inventory.sov.elf" as *u8 43 let DOCX: *u8="/tmp/nx_docx.sov.elf" as *u8 44 let MM: *u8="/tmp/nx_mailmerge.sov.elf" as *u8 45 let PFX: *u8="/tmp/estate_docs-" as *u8 46 let TSV: *u8="/tmp/estate_docs_assets.tsv" as *u8 47 let TMPL: *u8="/tmp/estate_docs_tmpl.docx" as *u8 48 let OUT: *u8="/tmp/estate_docs_out_" as *u8 49 let O1: *u8="/tmp/estate_docs_out_1.docx" as *u8 50 let O2: *u8="/tmp/estate_docs_out_2.docx" as *u8 51 let scr: *u8="/tmp/estate_docs_scratch.txt" as *u8 52 let obuf: *u8=sys_mmap(262144) 53 let a: *i64=sys_mmap(8*8) as *i64 54 55 // 1) authoritative inventory: two assets with beneficiaries 56 a[0]="put" as *u8 as i64; a[1]=PFX as i64; a[2]="house" as *u8 as i64; a[3]="House at 123 Main" as *u8 as i64; a[4]="510000" as *u8 as i64; a[5]="Sarah Heir" as *u8 as i64 57 g_run(ESTATE, a, 6, scr) 58 a[2]="car" as *u8 as i64; a[3]="Tesla Model 3" as *u8 as i64; a[4]="35000" as *u8 as i64; a[5]="Sam Heir" as *u8 as i64 59 g_run(ESTATE, a, 6, scr) 60 // 2) export the inventory as a mail-merge TSV (stdout -> TSV file) 61 a[0]="export" as *u8 as i64; a[1]=PFX as i64 62 g_run(ESTATE, a, 2, TSV) 63 var tn: i64=g_read(TSV, obuf, 262144) 64 65 var pass: i64=0; let rows: i64=7 66 g_puts(" R1 export TSV has header + both beneficiaries (Sarah Heir, Sam Heir)? " as *u8) 67 if g_contains(obuf,tn,"beneficiary" as *u8)==1 { if g_contains(obuf,tn,"Sarah Heir" as *u8)==1 { if g_contains(obuf,tn,"Sam Heir" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } } else { g_puts("NO FAIL\n" as *u8) } } else { g_puts("NO FAIL\n" as *u8) } 68 69 // 3) bequest template (placeholders match the export header field names) 70 a[0]="write" as *u8 as i64; a[1]=TMPL as i64 71 a[2]="Distribution notice. To {{beneficiary}}: the estate transfers to you the asset '{{asset}}' ({{description}}), appraised at {{value}}." as *u8 as i64 72 g_run(DOCX, a, 3, scr) 73 // 4) mail merge inventory -> per-heir documents 74 a[0]=TMPL as i64; a[1]=TSV as i64; a[2]=OUT as i64 75 g_run(MM, a, 3, scr); var mn: i64=g_read(scr, obuf, 262144) 76 g_puts(" R2 merge produced documents=2? " as *u8); if g_contains(obuf,mn,"documents=2" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } 77 78 // 5) verify doc 1 (house -> Sarah) 79 a[0]="read" as *u8 as i64; a[1]=O1 as i64 80 g_run(DOCX, a, 2, scr); var n1: i64=g_read(scr, obuf, 262144) 81 g_puts(" R3 doc1 addressed to 'Sarah Heir'? " as *u8); if g_contains(obuf,n1,"To Sarah Heir" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } 82 g_puts(" R4 doc1 carries the asset description 'House at 123 Main'? " as *u8); if g_contains(obuf,n1,"House at 123 Main" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } 83 g_puts(" R5 doc1 carries the appraised value '510000'? " as *u8); if g_contains(obuf,n1,"510000" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } 84 85 // 6) verify doc 2 (car -> Sam) 86 a[0]="read" as *u8 as i64; a[1]=O2 as i64 87 g_run(DOCX, a, 2, scr); var n2: i64=g_read(scr, obuf, 262144) 88 g_puts(" R6 doc2 addressed to 'Sam Heir'? " as *u8); if g_contains(obuf,n2,"To Sam Heir" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } 89 g_puts(" R7 doc2 carries its own asset 'Tesla Model 3'? " as *u8); if g_contains(obuf,n2,"Tesla Model 3" as *u8)==1 { pass=pass+1; g_puts("YES PASS\n" as *u8) } else { g_puts("NO FAIL\n" as *u8) } 90 91 g_puts("----\nESTATE-DOCS rows=" as *u8); g_num(rows); g_puts(" pass=" as *u8); g_num(pass); g_puts("\n" as *u8) 92 let lg: i64=sys_openat_append("knowledge/status/estate_docs_gate.log" as *u8, 0x1a4) 93 if lg>=0 { g_w(lg, "ESTATE-DOCS rows=" as *u8); g_wn(lg, rows); g_w(lg, " pass=" as *u8); g_wn(lg, pass); if pass==rows { g_w(lg, " verdict=GREEN\n" as *u8) } else { g_w(lg, " verdict=RED\n" as *u8) } sys_close(lg) } 94 if pass==rows { g_puts("ESTATE-DOCS GREEN (one authoritative inventory -> per-heir distribution documents, fully sovereign)\n" as *u8); sys_exit(0); return 0 } 95 g_puts("ESTATE-DOCS RED\n" as *u8); sys_exit(1); return 1 96}