code wiki / _hdl_build / nx_vizsla_dedup_gate.nx
nx_vizsla_dedup_gate.nx source
↩ module page · 233 lines · 10837 B
1// nx_vizsla_dedup_gate.nx -- VIZSLA dedup/merge gate. Construction-known oracle + contact->dedup integration.
2// Ingest 5 fields via BLESSED nx_vizsla_contact (date 2026-01-01) -- TWO records of the same person:
3// momA email=mom@x.com name=Mom momB email=mom@x.com phone=5551212 dad email=dad@x.com
4// momA+momB share email mom@x.com => duplicate candidates. dad's email is unique => NOT a candidate.
5// merge survivor=momA loser=momB @2026-02-01 ; unified view of momA = email+name+phone (phone pulled from the
6// merged-in loser) = 3 fields. canonical(momB)=momA. After merge mommaster<-momA, canonical(momB)=mommaster.
7// Rows:
8// 1 ingest-fields contact load new=5 seg-4101 (integration precondition)
9// 2 detect candidate value=mom@x.com count=2 ; dad@x.com NOT a candidate ; candidates=1
10// 3 merge survivor=momA loser=momB new=1 (additive mrg: record, loser NOT destroyed)
11// 4 canonical-loser canonical momB -> momA
12// 5 unified-view view momA -> fields=3 AND key=phone value=5551212 (UNION pulled loser's field)
13// 6 view-via-loser view momB -> SUMMARY contact=momA fields=3 (query loser, get survivor's merged profile)
14// 7 transitive merge mommaster<-momA ; canonical momB -> mommaster (chain momB->momA->mommaster)
15// 8 idempotent re-merge momA<-momB same date -> new=0 (CID dedup)
16// 9 neg-self-merge merge momA<-momA -> fail loud exit 1
17// Evidence: VIZSLA-DEDUP-GATE -> stdout + knowledge/status/vizsla_gate.log; exit 0 iff 9/9.
18// license_tier: ORIGINAL
19import "nx_syscalls.nx"
20import "nx_gate_verdict.nx"
21
22func og_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
23func og_p(s: *u8) -> i64 { sys_write(1, s, og_slen(s)); return 0 }
24
25func og_cat(dst: *u8, off: i64, s: *u8) -> i64 {
26 var i: i64 = 0
27 while s[i] != (0 as u8) { dst[off + i] = s[i]; i = i + 1 }
28 return off + i
29}
30
31func og_catn(dst: *u8, off: i64, v: i64) -> i64 {
32 var o: i64 = off
33 var m: i64 = v
34 if m < 0 { dst[o] = 45 as u8; o = o + 1; m = 0 - m }
35 let t: *u8 = sys_mmap(28)
36 var k: i64 = 0
37 if m == 0 { t[0] = 48 as u8; k = 1 }
38 while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 }
39 var i: i64 = 0
40 while i < k { dst[o + i] = t[k - 1 - i]; i = i + 1 }
41 return o + k
42}
43
44func og_write(path: *u8, content: *u8) -> i64 {
45 let fd: i64 = sys_openat_wr(path, 0x1a4)
46 if fd < 0 { return 0 - 1 }
47 sys_write(fd, content, og_slen(content))
48 sys_close(fd)
49 return 0
50}
51
52func og_readall(path: *u8, szout: *i64) -> *u8 {
53 let fd: i64 = sys_openat_rd(path)
54 if fd < 0 { szout[0] = 0 - 1; return 0 as *u8 }
55 let sz: i64 = sys_lseek(fd, 0, 2)
56 sys_lseek(fd, 0, 0)
57 let buf: *u8 = sys_mmap(sz + 64)
58 var got: i64 = 0
59 var n: i64 = 1
60 while n > 0 { n = sys_read(fd, (buf as i64 + got) as *u8, 65536); if n > 0 { got = got + n } }
61 sys_close(fd)
62 szout[0] = got
63 return buf
64}
65
66func og_runv(elf: *u8, args: *i64, outpath: *u8) -> i64 {
67 let pid: i64 = sys_fork()
68 if pid == 0 {
69 if (outpath as i64) != 0 {
70 let ofd: i64 = sys_openat_wr(outpath, 0x1a4)
71 if ofd >= 0 { sys_dup3(ofd, 1, 0); sys_dup3(ofd, 2, 0) }
72 }
73 let argv: *i64 = sys_mmap(128) as *i64
74 argv[0] = elf as i64
75 var i: i64 = 0
76 var go: i64 = 1
77 while go == 1 { if args[i] == 0 { go = 0 } else { argv[i + 1] = args[i]; i = i + 1 } }
78 argv[i + 1] = 0
79 let envp: *i64 = sys_mmap(16) as *i64
80 envp[0] = 0
81 sys_execve(elf, argv, envp)
82 sys_exit(127)
83 }
84 let st: *i64 = sys_mmap(16) as *i64
85 sys_wait4(pid, st, 0)
86 let sig: i64 = st[0] & 0x7f
87 if sig != 0 { return 128 + sig }
88 return (st[0] >> 8) & 0xff
89}
90
91func og_idx(buf: *u8, sz: i64, needle: *u8) -> i64 {
92 let n: i64 = og_slen(needle)
93 if n == 0 { return 0 - 1 }
94 var i: i64 = 0
95 while i + n <= sz {
96 var ok: i64 = 1
97 var j: i64 = 0
98 while j < n { if buf[i + j] != needle[j] { ok = 0; j = n } else { j = j + 1 } }
99 if ok == 1 { return i }
100 i = i + 1
101 }
102 return 0 - 1
103}
104
105func og_has(path: *u8, needle: *u8) -> i64 {
106 let szp: *i64 = sys_mmap(16) as *i64
107 let b: *u8 = og_readall(path, szp)
108 if og_idx(b, szp[0], needle) >= 0 { return 1 }
109 return 0
110}
111
112func og_row(name: *u8, pass: i64) -> i64 {
113 og_p("ROW " as *u8); og_p(name)
114 if pass == 1 { og_p(" PASS\n" as *u8) } else { og_p(" FAIL\n" as *u8) }
115 return pass
116}
117
118func og_args(a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8, a6: *u8) -> *i64 {
119 let a: *i64 = sys_mmap(64) as *i64
120 a[0] = a1 as i64; a[1] = a2 as i64; a[2] = a3 as i64; a[3] = a4 as i64; a[4] = a5 as i64; a[5] = a6 as i64; a[6] = 0
121 return a
122}
123
124func main(argc: i64, argv: *i64) -> i64 {
125 og_p("=== VIZSLA DEDUP GATE: detect/merge/canonical/view + contact->dedup ===\n" as *u8)
126 var ob: *u8 = "buildroot/_build/nx_vizsla_dedup.sov.elf" as *u8
127 if argc > 1 { ob = argv[1] as *u8 }
128 let pr: i64 = sys_openat_rd(ob)
129 if pr >= 0 { sys_close(pr) }
130 else {
131 og_p(" instrument missing -> rebuilding via durable runner\n" as *u8)
132 og_runv("_offc/nx_sov_build_run.elf" as *u8, og_args("nx_vizsla_dedup" as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_rebuild.out" as *u8)
133 }
134
135 let pfx: *u8 = sys_mmap(128)
136 var po: i64 = 0
137 po = og_cat(pfx, po, "/tmp/vddG" as *u8); po = og_catn(pfx, po, sys_now_us()); po = og_cat(pfx, po, "-" as *u8)
138 pfx[po] = 0 as u8
139
140 og_write("/tmp/vdd_fld.txt" as *u8, "FIELD 2026-01-01 momA email mom@x.com\nFIELD 2026-01-01 momA name Mom\nFIELD 2026-01-01 momB email mom@x.com\nFIELD 2026-01-01 momB phone 5551212\nFIELD 2026-01-01 dad email dad@x.com\n" as *u8)
141
142 var pass: i64 = 0
143 var r: i64 = 0
144
145 // 1 ingest fields via blessed contact organ
146 let rc1: i64 = og_runv("_offc/nx_vizsla_contact.elf" as *u8, og_args("load" as *u8, "/tmp/vdd_fld.txt" as *u8, pfx, "4101" as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_ing.txt" as *u8)
147 r = 0
148 if rc1 == 0 { if og_has("/tmp/vdd_ing.txt" as *u8, "VIZSLA-CONTACT-LOAD scanned=5 new=5 dup_infile=0 dup_instore=0 segment=seg-4101" as *u8) == 1 { r = 1 } }
149 pass = pass + og_row("ingest-fields" as *u8, r)
150
151 // 2 detect by email
152 og_runv(ob, og_args("detect" as *u8, pfx, "email" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_det.txt" as *u8)
153 r = 0
154 if og_has("/tmp/vdd_det.txt" as *u8, "VIZSLA-DEDUP-CANDIDATE key=email value=mom@x.com count=2" as *u8) == 1 {
155 if og_has("/tmp/vdd_det.txt" as *u8, "VIZSLA-DEDUP-DETECT key=email candidates=1" as *u8) == 1 {
156 if og_has("/tmp/vdd_det.txt" as *u8, "dad@x.com" as *u8) == 0 { r = 1 }
157 }
158 }
159 pass = pass + og_row("detect" as *u8, r)
160
161 // 3 merge survivor=momA loser=momB
162 let rc3: i64 = og_runv(ob, og_args("merge" as *u8, pfx, "momA" as *u8, "momB" as *u8, "2026-02-01" as *u8, 0 as *u8), "/tmp/vdd_m1.txt" as *u8)
163 r = 0
164 if rc3 == 0 { if og_has("/tmp/vdd_m1.txt" as *u8, "VIZSLA-DEDUP-MERGE survivor=momA loser=momB new=1" as *u8) == 1 { r = 1 } }
165 pass = pass + og_row("merge" as *u8, r)
166
167 // 4 canonical of the loser
168 og_runv(ob, og_args("canonical" as *u8, pfx, "momB" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_c1.txt" as *u8)
169 r = og_has("/tmp/vdd_c1.txt" as *u8, "VIZSLA-DEDUP-CANONICAL id=momB canonical=momA" as *u8)
170 pass = pass + og_row("canonical-loser" as *u8, r)
171
172 // 5 unified view of survivor: 3 fields incl phone pulled from loser
173 og_runv(ob, og_args("view" as *u8, pfx, "momA" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_v1.txt" as *u8)
174 r = 0
175 if og_has("/tmp/vdd_v1.txt" as *u8, "VIZSLA-DEDUP-VIEW-SUMMARY contact=momA fields=3" as *u8) == 1 {
176 if og_has("/tmp/vdd_v1.txt" as *u8, "VIZSLA-DEDUP-VIEW contact=momA key=phone value=5551212" as *u8) == 1 { r = 1 }
177 }
178 pass = pass + og_row("unified-view" as *u8, r)
179
180 // 6 view via the loser id -> resolves to survivor
181 og_runv(ob, og_args("view" as *u8, pfx, "momB" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_v2.txt" as *u8)
182 r = og_has("/tmp/vdd_v2.txt" as *u8, "VIZSLA-DEDUP-VIEW-SUMMARY contact=momA fields=3" as *u8)
183 pass = pass + og_row("view-via-loser" as *u8, r)
184
185 // 7 transitive: merge mommaster<-momA then canonical momB -> mommaster
186 og_runv(ob, og_args("merge" as *u8, pfx, "mommaster" as *u8, "momA" as *u8, "2026-03-01" as *u8, 0 as *u8), "/tmp/vdd_m2.txt" as *u8)
187 og_runv(ob, og_args("canonical" as *u8, pfx, "momB" as *u8, 0 as *u8, 0 as *u8, 0 as *u8), "/tmp/vdd_c2.txt" as *u8)
188 r = og_has("/tmp/vdd_c2.txt" as *u8, "VIZSLA-DEDUP-CANONICAL id=momB canonical=mommaster" as *u8)
189 pass = pass + og_row("transitive" as *u8, r)
190
191 // 8 idempotent re-merge momA<-momB
192 let rc8: i64 = og_runv(ob, og_args("merge" as *u8, pfx, "momA" as *u8, "momB" as *u8, "2026-02-01" as *u8, 0 as *u8), "/tmp/vdd_m3.txt" as *u8)
193 r = 0
194 if rc8 == 0 { if og_has("/tmp/vdd_m3.txt" as *u8, "VIZSLA-DEDUP-MERGE survivor=momA loser=momB new=0" as *u8) == 1 { r = 1 } }
195 pass = pass + og_row("idempotent" as *u8, r)
196
197 // 9 neg self-merge
198 let rc9: i64 = og_runv(ob, og_args("merge" as *u8, pfx, "momA" as *u8, "momA" as *u8, "2026-01-01" as *u8, 0 as *u8), "/tmp/vdd_neg.txt" as *u8)
199 r = 0
200 if rc9 == 1 { r = 1 }
201 pass = pass + og_row("neg-self-merge" as *u8, r)
202
203 let permil: i64 = (pass * 1000) / 9
204 let logfd: i64 = sys_openat_append("knowledge/status/vizsla_gate.log" as *u8, 0x1a4)
205 var fdi: i64 = 0
206 while fdi < 2 {
207 var fd: i64 = 1
208 if fdi == 1 { fd = logfd }
209 if fd > 0 {
210 let line: *u8 = sys_mmap(256)
211 var o: i64 = 0
212 o = og_cat(line, o, "VIZSLA-DEDUP-GATE epoch=" as *u8)
213 o = og_catn(line, o, sys_now_realtime_sec())
214 o = og_cat(line, o, " rows=9 pass=" as *u8)
215 o = og_catn(line, o, pass)
216 o = og_cat(line, o, " permil=" as *u8)
217 o = og_catn(line, o, permil)
218 if pass == 9 { o = og_cat(line, o, " verdict=GREEN\n" as *u8) } else { o = og_cat(line, o, " verdict=RED\n" as *u8) }
219 sys_write(fd, line, o)
220 }
221 fdi = fdi + 1
222 }
223 if logfd > 0 { sys_close(logfd) }
224 // MIGRATED onto nx_gate_verdict by nx_gate_dry_apply (D001, minimal form): every check
225 // row above is untouched, so the PASS/FAIL vector cannot change; only the hand-rolled
226 // verdict emission is replaced by the ONE shared base class. Proven by nx_gate_migrate verify.
227 let ctr__dry: *i64 = gv_ctr()
228 ctr__dry[0] = pass
229 ctr__dry[1] = 9
230 let rc__dry: i64 = gv_verdict("VIZSLA-DEDUP-GATE" as *u8, ctr__dry, "teeth unchanged; verdict emission migrated onto the shared base class" as *u8)
231 sys_exit(rc__dry)
232 return rc__dry
233}