nx_hr_migrate_gate.nx source

1// nx_hr_migrate_gate.nx -- referee proving nx_hr_migrate is LOSSLESS: build a real nx_hr TAB-log (the storage torrent 2// still uses) via base nx_hr, migrate it into a seg_store, and assert that EVERY cred resolves IDENTICALLY under the 3// new store as the old (hrs_resolve_level == hr_resolve_level), the active roster count is preserved, and a member's 4// FULL history (every version) survives. This is the de-risk artifact the torrent/HR teams need before flipping base 5// nx_hr -> seg_store. GREEN iff every row matches. Durable -> knowledge/status/hr_migrate_gate.log. 6import "nx_hr_migrate.nx" // hrm_migrate 7import "nx_g_puts_lib.nx" 8import "nx_hr.nx" // hr_enroll / hr_set_role / hr_resolve_level (build + read the OLD TAB-log) 9import "nx_hr_sov.nx" // hrs_resolve_level / hrs_roster_count / HRS_ST_ACTIVE (read the NEW seg_store) 10import "nx_seg_store.nx" // ss_scan_all (history version count) 11import "nx_syscalls.nx" 12 13func 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 } 14func 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 } 15func 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 } 16func gtrunc(path: *u8) -> i64 { let fd: i64 = sys_openat_wr(path, 0x1a4); if fd>=0 { sys_close(fd) } return 0 } 17func g_mkpfx(base: *u8, ms: i64, out: *u8) -> i64 { var o: i64=0; while base[o]!=(0 as u8){out[o]=base[o];o=o+1} let t: *u8=sys_mmap(28); var m: i64=ms; 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 z: i64=k-1; while z>=0{out[o]=t[z];o=o+1;z=z-1} out[o]=0 as u8; return o } 18func scan_count(prefix: *u8, cred: *u8) -> i64 { let kinds: *i64=sys_mmap(256*8) as *i64; let ptrs: *i64=sys_mmap(256*8) as *i64; let lens: *i64=sys_mmap(256*8) as *i64; let srcs: *i64=sys_mmap(256*8) as *i64; return ss_scan_all(prefix, cred, kinds, ptrs, lens, srcs) } 19func chk(got: i64, want: i64, label: *u8) -> i64 { 20 g_puts(" "); g_puts(label); g_puts(" got="); g_num(got); g_puts(" want="); g_num(want) 21 if got == want { g_puts(" PASS\n"); return 1 } 22 g_puts(" FAIL\n"); return 0 23} 24 25func main() -> i64 { 26 g_puts("=== NISHI HR MIGRATE GATE (TAB-log -> seg_store, LOSSLESS, history-preserving) ===\n" as *u8) 27 var pass: i64=0; var rows: i64=0 28 let ms: i64 = sys_now_ms() 29 let log: *u8 = sys_mmap(96); g_mkpfx("/tmp/nx_hrm_log_" as *u8, ms, log) // the OLD nx_hr TAB-log file 30 let pfx: *u8 = sys_mmap(96); g_mkpfx("/tmp/nx_hrm_pfx_" as *u8, ms, pfx) // the NEW seg_store prefix 31 let R: *u8 = "nishi_hub_test" as *u8; let RN: i64 = 14 32 let fam: *u8 = "hub" as *u8 33 gtrunc(log) 34 35 // --- build a realistic nx_hr TAB-log via BASE nx_hr (what torrent uses today): owner + brad (promoted) + jensen --- 36 let co: *u8=sys_mmap(96); let cb: *u8=sys_mmap(96); let cj: *u8=sys_mmap(96) 37 hr_enroll(log, R, RN, "owner" as *u8, 5, 3, fam, 1000, "system" as *u8, co) // owner active@3 38 hr_enroll(log, R, RN, "brad" as *u8, 4, 1, fam, 1001, "elderwesto" as *u8, cb) // brad active@1 39 hr_set_role(log, cb, "brad" as *u8, 3, fam, 1002, "elderwesto" as *u8) // brad -> active@3 (2nd version = history) 40 hr_enroll(log, R, RN, "jensen" as *u8, 6, 1, fam, 1003, "elderwesto" as *u8, cj) // jensen active@1 41 42 // --- MIGRATE the TAB-log into the seg_store --- 43 let m: i64 = hrm_migrate(log, pfx) 44 rows=rows+1; pass=pass+chk(m, 4, "migrated all 4 TAB-log records" as *u8) 45 46 // --- LOSSLESS: every cred resolves IDENTICALLY new-store vs old-store --- 47 rows=rows+1; pass=pass+chk(hrs_resolve_level(pfx, co), hr_resolve_level(log, co, 64), "owner resolve IDENTICAL (seg_store == tab-log)" as *u8) 48 rows=rows+1; pass=pass+chk(hrs_resolve_level(pfx, cb), hr_resolve_level(log, cb, 64), "brad resolve IDENTICAL (latest-wins preserved)" as *u8) 49 rows=rows+1; pass=pass+chk(hrs_resolve_level(pfx, cj), hr_resolve_level(log, cj, 64), "jensen resolve IDENTICAL" as *u8) 50 // explicit expected values (so the test isn't tautological if BOTH were wrong) 51 rows=rows+1; pass=pass+chk(hrs_resolve_level(pfx, co), 3, "owner = 3 (explicit)" as *u8) 52 rows=rows+1; pass=pass+chk(hrs_resolve_level(pfx, cb), 3, "brad = 3 latest-wins, NOT the earlier 1 (explicit)" as *u8) 53 rows=rows+1; pass=pass+chk(hrs_resolve_level(pfx, cj), 1, "jensen = 1 (explicit)" as *u8) 54 55 // --- roster + history preserved --- 56 rows=rows+1; pass=pass+chk(hrs_roster_count(pfx, HRS_ST_ACTIVE), 3, "3 active creds in migrated roster (owner/brad/jensen)" as *u8) 57 rows=rows+1; pass=pass+chk(scan_count(pfx, cb), 2, "brad's 2 versions preserved (history intact, append-only #13)" as *u8) 58 rows=rows+1; pass=pass+chk(scan_count(pfx, co), 1, "owner's single version (no spurious dup)" as *u8) 59 60 // --- idempotent: re-migrating the SAME log adds NOTHING (auto-segid dedup) --- 61 hrm_migrate(log, pfx) 62 rows=rows+1; pass=pass+chk(scan_count(pfx, cb), 2, "re-migrate is idempotent: brad STILL 2 versions (no dup)" as *u8) 63 rows=rows+1; pass=pass+chk(hrs_roster_count(pfx, HRS_ST_ACTIVE), 3, "re-migrate idempotent: still 3 active" as *u8) 64 65 g_puts("----\nNISHI-HR-MIGRATE-GATE rows=" as *u8); g_num(rows); g_puts(" pass=" as *u8); g_num(pass) 66 if pass==rows { g_puts(" verdict=GREEN\n" as *u8) } else { g_puts(" verdict=RED\n" as *u8) } 67 let lg: i64=sys_openat_append("knowledge/status/hr_migrate_gate.log" as *u8, 0x1a4) 68 if lg>=0 { 69 g_w(lg, "NISHI-HR-MIGRATE-GATE rows=" as *u8); g_wn(lg, rows); g_w(lg, " pass=" as *u8); g_wn(lg, pass) 70 if pass==rows { g_w(lg, " verdict=GREEN\n" as *u8) } else { g_w(lg, " verdict=RED\n" as *u8) } 71 sys_close(lg) 72 } 73 if pass==rows { sys_exit(0); return 0 } 74 sys_exit(1); return 1 75}