nx_audio_gate.nx source

1// nx_audio_gate.nx -- end-to-end gate for AUDIO liberation into the omni .nmz (@kind=audio): 2// nx_mp3_fixture -> nishi_audio.mp3 (ID3v2 + MP3 frame) -> nx_audio_book -> reader/<slug>/ (audio.json + track0.mp3) 3// -> nx_nmz_pack <slug> audio -> .nmz @kind=audio. 4// Asserts the ID3 metadata is parsed (title/narrator), @kind=audio, and -- the binary-safety proof -- the MP3 bytes 5// (which contain "ID3" + embedded 0x00 frame bytes) round-trip BYTE-EXACT out of the binary-safe canon. GREEN = a 6// purchased audiobook (a 3rd media kind) is now a first-class .nmz alongside books + comics. expect_exit: 0 ORIGINAL 7import "nx_syscalls.nx" 8import "nx_canon_bin.nx" 9import "nx_uxf_cid.nx" 10import "nx_gate_verdict.nx" 11 12func gp(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 } 13func gnum(v0: i64) -> i64 { var v: i64=v0; if v<0 { sys_write(1,"-" as *u8,1); v=0-v } let b: *u8=sys_mmap(24); var k: i64=0; if v==0 {b[0]=48 as u8;k=1} while v>0 {b[k]=(48+(v%10)) as u8; v=v/10; k=k+1} let o: *u8=sys_mmap(24); var j: i64=0; while j<k {o[j]=b[k-1-j];j=j+1} sys_write(1,o,k); return 0 } 14func gstreq(a: *u8, b: *u8) -> i64 { var i: i64=0; while a[i]!=(0 as u8){ if a[i]!=b[i]{return 0} i=i+1 } if b[i]!=(0 as u8){return 0} return 1 } 15func ghas(hay: *u8, hl: i64, needle: *u8) -> i64 { 16 var nl: i64=0; while needle[nl]!=(0 as u8){nl=nl+1} 17 if nl == 0 { return 0 } 18 var i: i64 = 0 19 while i + nl <= hl { var k: i64=0; var hit: i64=1; while k<nl { if hay[i+k]!=needle[k]{hit=0;k=nl}else{k=k+1} } if hit==1 {return 1} i=i+1 } 20 return 0 21} 22func rd(path: *u8, lenp: *i64) -> *u8 { lenp[0]=0; return sys_read_file(path, lenp) } 23func spawn(path: *u8, a0: *u8, a1: *u8, redir: *u8) -> i64 { 24 let pid: i64 = sys_fork() 25 if pid == 0 { 26 let fd: i64 = sys_openat_wr(redir, 420) 27 if fd >= 0 { sys_dup3(fd, 1, 0); sys_dup3(fd, 2, 0) } 28 let argv: *i64 = sys_mmap(64) as *i64 29 var n: i64 = 0 30 argv[0] = path as i64; n = 1 31 if (a0 as i64) != 0 { argv[n] = a0 as i64; n = n + 1 } 32 if (a1 as i64) != 0 { argv[n] = a1 as i64; n = n + 1 } 33 argv[n] = 0 34 let envp: *i64 = sys_mmap(16) as *i64 35 envp[0] = "PATH=/usr/bin:/bin\x00" as *u8 as i64; envp[1] = 0 36 sys_execve(path, argv, envp) 37 sys_exit(127) 38 } 39 let st: *i64 = sys_mmap(16) as *i64 40 sys_wait4(pid, st, 0) 41 return (st[0] >> 8) & 0xff 42} 43 44func main() -> i64 { 45 gp("=== nx_audio_gate: MP3+ID3 audiobook -> .nmz @kind=audio (3rd media kind; audio bytes byte-exact) ===\n" as *u8) 46 let RUNNER: *u8 = "_offc/nx_sov_build_run.elf\x00" as *u8 47 let SC: *u8 = "knowledge/status/audio_gate_scratch.log\x00" as *u8 48 49 spawn(RUNNER, "nx_mp3_fixture\x00" as *u8, 0 as *u8, SC) 50 spawn(RUNNER, "nx_audio_book\x00" as *u8, 0 as *u8, SC) 51 let rc_d: i64 = spawn("_offc/nx_audio_book.elf\x00" as *u8, "knowledge/fixtures/nishi_audio.mp3\x00" as *u8, "nishi_audio_fixture\x00" as *u8, SC) 52 spawn(RUNNER, "nx_nmz_pack\x00" as *u8, 0 as *u8, SC) 53 let rc_p: i64 = spawn("_offc/nx_nmz_pack.elf\x00" as *u8, "nishi_audio_fixture\x00" as *u8, "audio\x00" as *u8, SC) 54 55 let la: *i64 = sys_mmap(8) as *i64; let aj: *u8 = rd("knowledge/staging/media/reader/nishi_audio_fixture/audio.json\x00" as *u8, la); let an: i64 = la[0] 56 let lm: *i64 = sys_mmap(8) as *i64; let m: *u8 = rd("knowledge/staging/media/nmz/nishi_audio_fixture.nmz\x00" as *u8, lm); let n: i64 = lm[0] 57 let kindb: *u8 = sys_mmap(64); var gk: i64 = 0-1 58 let ajb: *u8 = sys_mmap(4096); var ga: i64 = 0-1 59 let trkb: *u8 = sys_mmap(4096); var gt: i64 = 0-1 60 let cid: *u8 = sys_mmap(96); cid[0]=0 as u8 61 if (m as i64)!=0 { 62 gk = canon_get_bin(m, n, "@kind\x00" as *u8, kindb, 64) 63 ga = canon_get_bin(m, n, "audio.json\x00" as *u8, ajb, 4096) 64 gt = canon_get_bin(m, n, "track0.mp3\x00" as *u8, trkb, 4096) 65 uxf_cid_profiled(UXF_ARCHIVE, m, n, cid) 66 } 67 68 gp(" rc_decode=" as *u8); gnum(rc_d); gp(" rc_pack=" as *u8); gnum(rc_p); gp(" audio.json=" as *u8); gnum(an); gp("B nmz=" as *u8); gnum(n); gp("B\n" as *u8) 69 gp(" @kind=" as *u8); if gk>0 { gp(kindb) } gp(" track0.mp3_len=" as *u8); gnum(gt); gp(" cid=" as *u8); gp(cid); gp("\n" as *u8) 70 71 var pass: i64 = 0; var fail: i64 = 0 72 if rc_d == 0 { pass=pass+1 } else { fail=fail+1; gp(" FAIL audio_book-nonzero\n" as *u8) } 73 if rc_p == 0 { pass=pass+1 } else { fail=fail+1; gp(" FAIL nmz_pack-nonzero\n" as *u8) } 74 if (aj as i64)!=0 { if ghas(aj, an, "The Hobbit (Nishi Audio Fixture)" as *u8)==1 { pass=pass+1 } else { fail=fail+1; gp(" FAIL title-missing\n" as *u8) } } else { fail=fail+1; gp(" FAIL no-audio.json\n" as *u8) } 75 if (aj as i64)!=0 { if ghas(aj, an, "J.R.R. Tolkien" as *u8)==1 { pass=pass+1 } else { fail=fail+1; gp(" FAIL narrator-missing\n" as *u8) } } 76 if (aj as i64)!=0 { if ghas(aj, an, "\"format\":\"audio\"" as *u8)==1 { pass=pass+1 } else { fail=fail+1; gp(" FAIL format!=audio\n" as *u8) } } 77 if gk > 0 { if gstreq(kindb, "audio" as *u8)==1 { pass=pass+1 } else { fail=fail+1; gp(" FAIL kind!=audio\n" as *u8) } } else { fail=fail+1; gp(" FAIL no-@kind\n" as *u8) } 78 if ga > 0 { if ghas(ajb, ga, "\"format\":\"audio\"" as *u8)==1 { pass=pass+1 } else { fail=fail+1; gp(" FAIL nmz-audio.json-not-audio\n" as *u8) } } else { fail=fail+1; gp(" FAIL nmz-no-audio.json\n" as *u8) } 79 // binary-safety: the MP3 (ID3 magic + embedded NUL frame bytes) round-trips byte-exact 80 if gt == 143 { pass=pass+1 } else { fail=fail+1; gp(" FAIL track-len!=143 (binary truncated?)\n" as *u8) } 81 if gt >= 3 { if trkb[0]==(0x49 as u8) { if trkb[1]==(0x44 as u8) { if trkb[2]==(0x33 as u8) { pass=pass+1 } else { fail=fail+1; gp(" FAIL track-not-ID3\n" as *u8) } } else { fail=fail+1; gp(" FAIL track-byte1\n" as *u8) } } else { fail=fail+1; gp(" FAIL track-byte0\n" as *u8) } } else { fail=fail+1; gp(" FAIL track-too-short\n" as *u8) } 82 if uxf_codec_of_cid(cid) == UXF_ARCHIVE { pass=pass+1 } else { fail=fail+1; gp(" FAIL cid-codec\n" as *u8) } 83 84 gp("AUDIO-GATE pass=" as *u8); gnum(pass); gp(" fail=" as *u8); gnum(fail) 85 // MIGRATED onto nx_gate_verdict by nx_gate_dry_apply (D001, minimal form): every check 86 // row above is untouched, so the PASS/FAIL vector cannot change; only the hand-rolled 87 // verdict emission is replaced by the ONE shared base class. Proven by nx_gate_migrate verify. 88 let ctr__dry: *i64 = gv_ctr() 89 ctr__dry[0] = pass 90 ctr__dry[1] = pass + fail 91 let rc__dry: i64 = gv_verdict("AUDIO-GATE" as *u8, ctr__dry, "MP3+ID3 audiobook -> .nmz @kind=audio; metadata parsed + audio bytes incl ID3/NULs byte-exact; UXF_ARCHIVE CID)" as *u8) 92 sys_exit(rc__dry) 93 return rc__dry 94}