code wiki / _hdl_build / nx_media_inventory_gate.nx
nx_media_inventory_gate.nx source
↩ module page · 160 lines · 7200 B
1// nx_media_inventory_gate.nx -- self-validating, anti-fabrication gate for the media-content census.
2// T1 store round-trip a real performer. T2 union-across-roots proven. T3 reconcile math (0<=stale<=catalog).
3// T4 NSFW default (fail-closed). T5 no-fabrication: independent re-walk matches the STORED count. license_tier: ORIGINAL
4import "nx_media_inventory_lib.nx"
5import "nx_gate.nx"
6
7// parse the decimal that follows `needle` in buf[0..n). -1 if needle absent or no digits.
8func mg_field(buf: *u8, n: i64, needle: *u8) -> i64 {
9 let nl: i64 = iv_slen(needle)
10 var i: i64 = 0
11 while i + nl <= n {
12 var j: i64 = 0
13 var hit: i64 = 1
14 while j < nl { if buf[i+j] != needle[j] { hit = 0; j = nl } else { j = j + 1 } }
15 if hit == 1 {
16 var p: i64 = i + nl
17 var v: i64 = 0
18 var any: i64 = 0
19 while p < n { let c: i64 = buf[p] as i64; if c >= 48 { if c <= 57 { v = v*10 + (c-48); any = 1; p = p + 1 } else { p = n } } else { p = n } }
20 if any == 1 { return v }
21 return 0 - 1
22 }
23 i = i + 1
24 }
25 return 0 - 1
26}
27
28// if newline-table buf has a line "<name>\t<count>\t...", return count; else -1.
29func mg_perf_count(buf: *u8, n: i64, name: *u8) -> i64 {
30 let ln: i64 = iv_slen(name)
31 var ls: i64 = 0
32 var i: i64 = 0
33 while i <= n {
34 var eol: i64 = 0
35 if i == n { eol = 1 } else { if buf[i] == (10 as u8) { eol = 1 } }
36 if eol == 1 {
37 if i - ls > ln {
38 var m: i64 = 1
39 var k: i64 = 0
40 while k < ln { if buf[ls+k] != name[k] { m = 0; k = ln } else { k = k + 1 } }
41 if m == 1 { if buf[ls+ln] == (9 as u8) {
42 var p: i64 = ls + ln + 1
43 var v: i64 = 0
44 while p < i { let c: i64 = buf[p] as i64; if c >= 48 { if c <= 57 { v = v*10 + (c-48); p = p + 1 } else { p = i } } else { p = i } }
45 return v
46 } }
47 }
48 ls = i + 1
49 }
50 i = i + 1
51 }
52 return 0 - 1
53}
54
55// count lines whose roots column == both (byte pattern TAB b o t h TAB) -> union proof.
56func mg_both_count(buf: *u8, n: i64) -> i64 {
57 var ls: i64 = 0
58 var i: i64 = 0
59 var both: i64 = 0
60 while i <= n {
61 var eol: i64 = 0
62 if i == n { eol = 1 } else { if buf[i] == (10 as u8) { eol = 1 } }
63 if eol == 1 {
64 var p: i64 = ls
65 while p + 6 <= i { if buf[p]==(9 as u8) { if buf[p+1]==(98 as u8) { if buf[p+2]==(111 as u8) { if buf[p+3]==(116 as u8) { if buf[p+4]==(104 as u8) { if buf[p+5]==(9 as u8) { both = both + 1; p = i } } } } } } p = p + 1 }
66 ls = i + 1
67 }
68 i = i + 1
69 }
70 return both
71}
72
73// independent re-walk oracle: performer-dirs (>=1 .ts) directly under root.
74func mg_recount_root(root: *u8, dirbuf: *u8, cbuf: *u8, child: *u8) -> i64 {
75 let rfd: i64 = sys_openat_rd(root)
76 if rfd < 0 { return 0 }
77 let rlen: i64 = iv_slen(root)
78 var found: i64 = 0
79 var done: i64 = 0
80 while done == 0 {
81 let nb: i64 = sys_getdents64(rfd, dirbuf, 1048576)
82 if nb <= 0 { done = 1 } else {
83 var off: i64 = 0
84 while off < nb {
85 let rec: *u8 = (dirbuf as i64 + off) as *u8
86 let rl: i64 = dirent_reclen(rec)
87 if rl <= 0 { off = nb } else {
88 let nm: *u8 = dirent_name(rec)
89 var skip: i64 = 0
90 if nm[0] == (46 as u8) { if nm[1] == (0 as u8) { skip = 1 } else { if nm[1] == (46 as u8) { if nm[2] == (0 as u8) { skip = 1 } } } }
91 if skip == 0 {
92 var w: i64 = 0
93 while w < rlen { child[w] = root[w]; w = w + 1 }
94 child[w] = 47 as u8; w = w + 1
95 var z: i64 = 0
96 while nm[z] != (0 as u8) { child[w] = nm[z]; w = w + 1; z = z + 1 }
97 child[w] = 0 as u8
98 if iv_count_ts(child, cbuf) > 0 { found = found + 1 }
99 }
100 off = off + rl
101 }
102 }
103 }
104 }
105 sys_close(rfd)
106 return found
107}
108
109func main() -> i64 {
110 gw("=== nx_media_inventory_gate: sovereign content census (store-law, anti-fabrication) ===\n" as *u8)
111 let brc: i64 = iv_build("all" as *u8)
112 var pass: i64 = 0
113 var tot: i64 = 0
114 let po: *i64 = sys_mmap(16) as *i64
115 let lo: *i64 = sys_mmap(16) as *i64
116
117 tot = tot + 1
118 var perfc: i64 = 0 - 1
119 if iv_get("inv:rec:table" as *u8, po, lo) >= 1 { perfc = mg_perf_count(po[0] as *u8, lo[0], "beckymadsons" as *u8) }
120 if perfc > 0 { pass = pass + 1; gw(" [PASS] " as *u8) } else { gw(" [FAIL] " as *u8) }
121 gw("T1 store round-trip: performer beckymadsons resolves from inv:rec:table, count=" as *u8); gn(perfc); gw("\n" as *u8)
122
123 tot = tot + 1
124 var bc: i64 = 0
125 if iv_get("inv:rec:table" as *u8, po, lo) >= 1 { bc = mg_both_count(po[0] as *u8, lo[0]) }
126 if bc > 0 { pass = pass + 1; gw(" [PASS] " as *u8) } else { gw(" [FAIL] " as *u8) }
127 gw("T2 union-across-roots dedupe: performers present in BOTH logs+logging=" as *u8); gn(bc); gw("\n" as *u8)
128
129 tot = tot + 1
130 var cl: i64 = 0 - 1
131 var sc: i64 = 0 - 1
132 if iv_get("inv:stale" as *u8, po, lo) >= 1 { cl = mg_field(po[0] as *u8, lo[0], "catalog_lines=" as *u8); sc = mg_field(po[0] as *u8, lo[0], "stale_count=" as *u8) }
133 var t3: i64 = 0
134 if cl >= 0 { if sc >= 0 { if sc <= cl { t3 = 1 } } }
135 if t3 == 1 { pass = pass + 1; gw(" [PASS] " as *u8) } else { gw(" [FAIL] " as *u8) }
136 gw("T3 reconcile: catalog_lines=" as *u8); gn(cl); gw(" stale_count=" as *u8); gn(sc); gw(" exist=" as *u8); gn(cl-sc); gw("\n" as *u8)
137
138 tot = tot + 1
139 var t4: i64 = 0
140 if iv_category("recordings" as *u8) == 1 { if iv_category("movies" as *u8) == 0 { t4 = 1 } }
141 if t4 == 1 { pass = pass + 1; gw(" [PASS] " as *u8) } else { gw(" [FAIL] " as *u8) }
142 gw("T4 category default: recordings=NSFW (fail-closed), movies=general\n" as *u8)
143
144 tot = tot + 1
145 let dirbuf: *u8 = sys_mmap(1048640)
146 let cbuf: *u8 = sys_mmap(1048640)
147 let child: *u8 = sys_mmap(8192)
148 let rewalk: i64 = mg_recount_root(INV_ROOT_LOGS, dirbuf, cbuf, child)
149 var stored: i64 = 0 - 1
150 if iv_get("inv:summary" as *u8, po, lo) >= 1 { stored = mg_field(po[0] as *u8, lo[0], "performers_logs=" as *u8) }
151 var t5: i64 = 0
152 if rewalk == stored { if rewalk > 0 { t5 = 1 } }
153 if t5 == 1 { pass = pass + 1; gw(" [PASS] " as *u8) } else { gw(" [FAIL] " as *u8) }
154 gw("T5 no-fabrication: re-walk /volume1/logs performers=" as *u8); gn(rewalk); gw(" == stored performers_logs=" as *u8); gn(stored); gw("\n" as *u8)
155
156 gw("\n=== nx_media_inventory_gate " as *u8); gn(pass); gw("/" as *u8); gn(tot); gw(" ===\n" as *u8)
157 if brc != 0 { gw("(build returned nonzero -- see FAIL rows)\n" as *u8) }
158 if pass == tot { gw("MEDIA-INVENTORY GREEN -- store-law, union-proven, reconcile-consistent, NSFW-default, walk-not-fabricated\n" as *u8); sys_exit(0); return 0 }
159 gw("MEDIA-INVENTORY RED\n" as *u8); sys_exit(1); return 1
160}