nx_vroom_gate.nx source

1// nx_vroom_gate.nx -- proves the sovereign video-room handler (nx_vroom) end to end 2// WITHOUT sockets/TLS: POST stores a peer's frame; GET /frames returns OTHER peers' 3// frames as [id u64][len u32][bytes] records (not self); GET /roster returns JSON; 4// rooms stay isolated. Built nx_cc_sovereign -> nxasm_x86 (no gcc, no .sh). 5// license_tier: ORIGINAL 6import "nx_syscalls.nx" 7import "nx_gate_emit_lib.nx" 8import "nx_room_relay.nx" 9import "nx_vroom.nx" 10 11func rd_u64(b: *u8, o: i64) -> i64 { var v: i64=0; var i: i64=0; while i<8 { v = v | ((b[o+i] as i64) << (i*8)); i=i+1 } return v } 12func rd_u32(b: *u8, o: i64) -> i64 { var v: i64=0; var i: i64=0; while i<4 { v = v | ((b[o+i] as i64) << (i*8)); i=i+1 } return v } 13 14func main() -> i64 { 15 g_puts("nx_vroom gate (sovereign video-room handler, server-relay, no WebRTC)\n" as *u8) 16 var pass: i64 = 0; var total: i64 = 0 17 18 let N: i64 = 8 19 let SB: i64 = 65536 20 let st: *i64 = sys_mmap((2 + 5*N) * 8) as *i64 21 let arena: *u8 = sys_mmap(N * SB) 22 rr_init(st, N, SB) 23 let ids: *i64 = sys_mmap(N * 8) as *i64 24 let out: *u8 = sys_mmap(131072) 25 let now: i64 = 1000 26 let ttl: i64 = 8000 27 28 let req_p100: *u8 = "POST /video/post?room=fam&id=100 HTTP/1.1\r\nContent-Length: 5\r\n\r\nHELLO" as *u8 29 let req_p101: *u8 = "POST /video/post?room=fam&id=101 HTTP/1.1\r\nContent-Length: 6\r\n\r\nWORLD!" as *u8 30 let req_fr: *u8 = "GET /video/frames?room=fam&id=100 HTTP/1.1\r\n\r\n" as *u8 31 let req_ros: *u8 = "GET /video/roster?room=fam&id=100 HTTP/1.1\r\n\r\n" as *u8 32 let req_iso: *u8 = "GET /video/frames?room=other&id=999 HTTP/1.1\r\n\r\n" as *u8 33 34 let rm_fam: i64 = vr_room_hash(req_p100, vr_strlen(req_p100)) 35 36 // 1) POST 100 -> 200 + stored frame "HELLO" 37 let rp1: i64 = vr_handle(req_p100, vr_strlen(req_p100), st, arena, now, ttl, out, 131072, ids) 38 var c1: i64 = vr_contains(out, rp1, "200 OK" as *u8, 6) 39 let s100: i64 = rr_live(st, rm_fam, 100, now, ttl) 40 if s100 < 0 { c1 = 0 } else { 41 if rr_flen(st, s100) != 5 { c1 = 0 } 42 if arena[s100*SB+0] != (72 as u8) { c1 = 0 } // 'H' 43 if arena[s100*SB+4] != (79 as u8) { c1 = 0 } // 'O' 44 } 45 pass = pass + g_check("POST stores peer 100 frame (HELLO), returns 200" as *u8, c1); total=total+1 46 47 // 2) POST 101 48 let rp2: i64 = vr_handle(req_p101, vr_strlen(req_p101), st, arena, now, ttl, out, 131072, ids) 49 let c2: i64 = vr_contains(out, rp2, "200 OK" as *u8, 6) 50 pass = pass + g_check("POST stores peer 101 (WORLD!), returns 200" as *u8, c2); total=total+1 51 52 // 3) GET frames from 100 -> exactly peer 101's record [101][6]["WORLD!"], not self 53 let rf: i64 = vr_handle(req_fr, vr_strlen(req_fr), st, arena, now, ttl, out, 131072, ids) 54 let bs: i64 = vr_body_start(out, rf) 55 var c3: i64 = 1 56 let blen: i64 = rf - bs 57 if blen != 18 { c3 = 0 } // exactly one record: 12 + 6 58 if c3 == 1 { 59 if rd_u64(out, bs) != 101 { c3 = 0 } 60 if rd_u32(out, bs+8) != 6 { c3 = 0 } 61 if out[bs+12] != (87 as u8) { c3 = 0 } // 'W' 62 if out[bs+17] != (33 as u8) { c3 = 0 } // '!' 63 } 64 pass = pass + g_check("GET /frames returns other peer 101's frame (not self 100)" as *u8, c3); total=total+1 65 66 // 4) roster from 100 -> JSON contains 101, not 100 67 let rr: i64 = vr_handle(req_ros, vr_strlen(req_ros), st, arena, now, ttl, out, 131072, ids) 68 var c4: i64 = vr_contains(out, rr, "101" as *u8, 3) 69 if vr_contains(out, rr, "100" as *u8, 3) == 1 { c4 = 0 } 70 pass = pass + g_check("GET /roster lists 101 (other), excludes self 100" as *u8, c4); total=total+1 71 72 // 5) room isolation -- different room sees nothing 73 let ri: i64 = vr_handle(req_iso, vr_strlen(req_iso), st, arena, now, ttl, out, 131072, ids) 74 let bsi: i64 = vr_body_start(out, ri) 75 pass = pass + g_check("room isolation: other room has 0 frames" as *u8, (ri - bsi) == 0); total=total+1 76 77 g_puts("---- vroom gate: passed " as *u8); g_pn(pass); g_puts(" / " as *u8); g_pn(total); g_puts(" ----\n" as *u8) 78 if pass == total { g_puts("verdict=GREEN\n" as *u8); sys_exit(0); return 0 } 79 g_puts("verdict=RED\n" as *u8); sys_exit(1); return 1 80}