code wiki / (root) / nx_gtm_svc_test.nx
`nx_gtm_svc_test.nx` source

↩ module page · 220 lines · 11615 B
1// nx_gtm_svc_test.nx -- gate for the GTM service facade. Drives the dispatcher
2// exactly as an agent or a workflow stage would -- build an argv, call, read
3// the JSON -- and checks the envelope, the routed values, structured errors,
4// and the exit-code contract. It also proves the facade adds NO domain logic:
5// the numbers it emits equal the numbers the libraries compute directly.
6// expect_exit: 0   license_tier: ORIGINAL
7import "nx_syscalls.nx"
8import "nx_service.nx"
9import "nx_supp_ingredient.nx"
10import "nx_supp_channel.nx"
11import "nx_trial_ethics.nx"
12import "nx_gtm_svc.nx"
13
14func t_puts(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } sys_write(1, s, n); return 0 }
15func t_putn(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 }
16
17// Does j's buffer contain the needle substring? (structured-reply spot check)
18func j_has(j: *NxJson, needle: *u8) -> i64 {
  var nn: i64 = 0
  while needle[nn] != (0 as u8) { nn = nn + 1 }
  if nn == 0 { return 0 }
  let b: *u8 = j.buf
  let last: i64 = j.off - nn
  var i: i64 = 0
  var found: i64 = 0
  while i <= last {
      if found == 0 {
          var m: i64 = 0
          var ok: i64 = 1
          while m < nn {
              if b[i + m] != needle[m] { ok = 0 }
              m = m + 1
          }
          if ok == 1 { found = 1 }
      }
      i = i + 1
  }
  return found
39}
40
41// Build an argv of up to 6 string tokens for the dispatcher.
42func mk_argv(a0: *u8, a1: *u8, a2: *u8, a3: *u8, a4: *u8, a5: *u8) -> *i64 {
  let av: *i64 = sys_mmap(64)
  av[0] = a0 as i64
  av[1] = a1 as i64
  av[2] = a2 as i64
  av[3] = a3 as i64
  av[4] = a4 as i64
  av[5] = a5 as i64
  return av
51}
52
53func main() -> i64 {
  var pass: i64 = 0
  var total: i64 = 0
  let NUL: *u8 = "\x00" as *u8
57
  // --- T1  describe emits the verb catalog (agentic discovery) ---
  total = total + 1
  let j1: *NxJson = nx_json_new(8192)
  let av1: *i64 = mk_argv("nx_gtm_svc" as *u8, "describe" as *u8, NUL, NUL, NUL, NUL)
  let rc1: i64 = gtm_dispatch(2, av1, j1)
  let d1: i64 = j_has(j1, "\"verb_count\":8" as *u8)
  let d2: i64 = j_has(j1, "ingredient.info" as *u8)
  let d3: i64 = j_has(j1, "supply.effective" as *u8)
  t_puts("T1 describe: rc=" as *u8); t_putn(rc1); t_puts(" verb_count+catalog present=" as *u8); t_putn(d1); t_putn(d2); t_putn(d3); t_puts(": " as *u8)
  var ok1: i64 = 1
  if rc1 != 0 { ok1 = 0 }
  if d1 != 1 { ok1 = 0 }
  if d2 != 1 { ok1 = 0 }
  if d3 != 1 { ok1 = 0 }
  if ok1 == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) }
73
  // --- T2  ingredient.info routes and matches the library directly ---
  total = total + 1
  let j2: *NxJson = nx_json_new(4096)
  let av2: *i64 = mk_argv("nx_gtm_svc" as *u8, "ingredient.info" as *u8, "3" as *u8, NUL, NUL, NUL)
  gtm_dispatch(3, av2, j2)
  let env_ok: i64 = j_has(j2, "\"ok\":true" as *u8)
  let name_ok: i64 = j_has(j2, "Ashwagandha" as *u8)
  let lawful_ok: i64 = j_has(j2, "\"lawful_dietary\":true" as *u8)
  t_puts("T2 ingredient.info id=3 (ashwagandha): env=" as *u8); t_putn(env_ok); t_puts(" name=" as *u8); t_putn(name_ok); t_puts(" lawful=" as *u8); t_putn(lawful_ok); t_puts(": " as *u8)
  var ok2: i64 = 1
  if env_ok != 1 { ok2 = 0 }
  if name_ok != 1 { ok2 = 0 }
  if lawful_ok != 1 { ok2 = 0 }
  if ok2 == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) }
88
  // --- T3  a peptide routes to a NOT_DIETARY class via the facade ---
  total = total + 1
  let j3: *NxJson = nx_json_new(4096)
  let av3: *i64 = mk_argv("nx_gtm_svc" as *u8, "ingredient.info" as *u8, "9" as *u8, NUL, NUL, NUL)
  gtm_dispatch(3, av3, j3)
  let kp_class: i64 = j_has(j3, "\"class\":4" as *u8)
  let kp_unlawful: i64 = j_has(j3, "\"lawful_dietary\":false" as *u8)
  t_puts("T3 ingredient.info id=9 (kisspeptin): class4=" as *u8); t_putn(kp_class); t_puts(" unlawful=" as *u8); t_putn(kp_unlawful); t_puts(": " as *u8)
  if kp_class == 1 { if kp_unlawful == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) } } else { t_puts("FAIL\n" as *u8) }
98
  // --- T4  claims.classify joins a multi-word sentence and classifies it ---
  total = total + 1
  let j4: *NxJson = nx_json_new(4096)
  let av4: *i64 = mk_argv("nx_gtm_svc" as *u8, "claims.classify" as *u8, "supports" as *u8, "healthy" as *u8, "libido" as *u8, NUL)
  gtm_dispatch(5, av4, j4)
  let sent_ok: i64 = j_has(j4, "\"sentence\":\"supports healthy libido\"" as *u8)
  let law_ok: i64 = j_has(j4, "\"lawful\":true" as *u8)
  let notify_ok: i64 = j_has(j4, "\"fda_notification_days\":30" as *u8)
  t_puts("T4 claims.classify joined 3 words: sentence=" as *u8); t_putn(sent_ok); t_puts(" lawful=" as *u8); t_putn(law_ok); t_puts(" notify30=" as *u8); t_putn(notify_ok); t_puts(": " as *u8)
  var ok4: i64 = 1
  if sent_ok != 1 { ok4 = 0 }
  if law_ok != 1 { ok4 = 0 }
  if notify_ok != 1 { ok4 = 0 }
  if ok4 == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) }
113
  // --- T5  a disease claim classifies as unlawful through the facade ---
  total = total + 1
  let j5: *NxJson = nx_json_new(4096)
  let av5: *i64 = mk_argv("nx_gtm_svc" as *u8, "claims.classify" as *u8, "treats" as *u8, "erectile" as *u8, "dysfunction" as *u8, NUL)
  gtm_dispatch(5, av5, j5)
  let unlaw: i64 = j_has(j5, "\"lawful\":false" as *u8)
  let cls2: i64 = j_has(j5, "\"classification\":2" as *u8)
  t_puts("T5 'treats erectile dysfunction' unlawful=" as *u8); t_putn(unlaw); t_puts(" class2=" as *u8); t_putn(cls2); t_puts(": " as *u8)
  if unlaw == 1 { if cls2 == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) } } else { t_puts("FAIL\n" as *u8) }
123
  // --- T6  ethics.rank matches the library value exactly (no drift) ---
  total = total + 1
  let j6: *NxJson = nx_json_new(4096)
  let av6: *i64 = mk_argv("nx_gtm_svc" as *u8, "ethics.rank" as *u8, "0" as *u8, NUL, NUL, NUL)
  gtm_dispatch(3, av6, j6)
  let dk_score: i64 = te_integrity_score(TE_DENMARK)
  let has_denmark: i64 = j_has(j6, "Denmark" as *u8)
  let has_score: i64 = j_has(j6, "\"integrity_score\":130" as *u8)
  t_puts("T6 ethics.rank Denmark: library score=" as *u8); t_putn(dk_score); t_puts(" facade emits 130=" as *u8); t_putn(has_score); t_puts(" name=" as *u8); t_putn(has_denmark); t_puts(": " as *u8)
  var ok6: i64 = 1
  if dk_score != 130 { ok6 = 0 }
  if has_score != 1 { ok6 = 0 }
  if has_denmark != 1 { ok6 = 0 }
  if ok6 == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) }
138
  // --- T7  supply.effective routes numeric args and computes ---
  total = total + 1
  let j7: *NxJson = nx_json_new(4096)
  let av7: *i64 = mk_argv("nx_gtm_svc" as *u8, "supply.effective" as *u8, "4" as *u8, "10000" as *u8, NUL, NUL)
  gtm_dispatch(4, av7, j7)
  let has_poland: i64 = j_has(j7, "Poland" as *u8)
  let has_eff: i64 = j_has(j7, "\"effective_cost_k\":7720" as *u8)
  t_puts("T7 supply.effective base=4 spend=10000: Poland=" as *u8); t_putn(has_poland); t_puts(" eff=7720=" as *u8); t_putn(has_eff); t_puts(": " as *u8)
  if has_poland == 1 { if has_eff == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) } } else { t_puts("FAIL\n" as *u8) }
148
  // --- T8  UNKNOWN VERB is a structured 404 and a non-zero exit code ---
  total = total + 1
  let j8: *NxJson = nx_json_new(4096)
  let av8: *i64 = mk_argv("nx_gtm_svc" as *u8, "does.not.exist" as *u8, NUL, NUL, NUL, NUL)
  let rc8: i64 = gtm_dispatch(2, av8, j8)
  let is_err: i64 = j_has(j8, "\"ok\":false" as *u8)
  let is_404: i64 = j_has(j8, "\"status\":404" as *u8)
  let slug: i64 = j_has(j8, "\"code\":\"UNKNOWN_VERB\"" as *u8)
  t_puts("T8 unknown verb: rc=" as *u8); t_putn(rc8); t_puts(" ok:false=" as *u8); t_putn(is_err); t_puts(" 404=" as *u8); t_putn(is_404); t_puts(" slug=" as *u8); t_putn(slug); t_puts(": " as *u8)
  var ok8: i64 = 1
  if rc8 == 0 { ok8 = 0 }
  if is_err != 1 { ok8 = 0 }
  if is_404 != 1 { ok8 = 0 }
  if slug != 1 { ok8 = 0 }
  if ok8 == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) }
164
  // --- T9  bad args are a structured 400 (not a crash, not a wrong number) ---
  total = total + 1
  let j9: *NxJson = nx_json_new(4096)
  let av9: *i64 = mk_argv("nx_gtm_svc" as *u8, "supply.effective" as *u8, "99" as *u8, "10000" as *u8, NUL, NUL)
  gtm_dispatch(4, av9, j9)
  let nf: i64 = j_has(j9, "\"status\":404" as *u8)
  let j9b: *NxJson = nx_json_new(4096)
  let av9b: *i64 = mk_argv("nx_gtm_svc" as *u8, "formula.assess" as *u8, "0" as *u8, "700" as *u8, "30" as *u8, "2" as *u8)
  gtm_dispatch(6, av9b, j9b)
  let ba: i64 = j_has(j9b, "\"status\":400" as *u8)
  t_puts("T9 unknown base=404(" as *u8); t_putn(nf); t_puts(") zero-retail=400(" as *u8); t_putn(ba); t_puts("): " as *u8)
  if nf == 1 { if ba == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) } } else { t_puts("FAIL\n" as *u8) }
177
  // --- T10  no-arg invocation defaults to describe (friendly entrypoint) ---
  total = total + 1
  let j10: *NxJson = nx_json_new(8192)
  let av10: *i64 = mk_argv("nx_gtm_svc" as *u8, NUL, NUL, NUL, NUL, NUL)
  let rc10: i64 = gtm_dispatch(1, av10, j10)
  let desc: i64 = j_has(j10, "\"verb\":\"describe\"" as *u8)
  t_puts("T10 no verb -> describe: rc=" as *u8); t_putn(rc10); t_puts(" describe=" as *u8); t_putn(desc); t_puts(": " as *u8)
  if rc10 == 0 { if desc == 1 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) } } else { t_puts("FAIL\n" as *u8) }
186
  // --- T11  WORKFLOW SHAPE: fan a list through one verb, feed the next.
  //          Screen 3 ingredients for lawfulness; a pipeline would keep the
  //          survivors. Proves the verbs compose without shared state. ---
  total = total + 1
  let ids: *i64 = sys_mmap(32)
  ids[0] = SI_L_CITRULLINE
  ids[1] = SI_OXYTOCIN
  ids[2] = SI_ASHWAGANDHA
  var lawful_survivors: i64 = 0
  var i11: i64 = 0
  while i11 < 3 {
      let jx: *NxJson = nx_json_new(2048)
      let avx: *i64 = sys_mmap(64)
      avx[0] = "nx_gtm_svc" as i64
      avx[1] = "channel.best" as i64
      let idbuf: *u8 = sys_mmap(8)
      let idv: i64 = ids[i11]
      idbuf[0] = (48 + idv / 10) as u8
      idbuf[1] = (48 + idv % 10) as u8
      idbuf[2] = 0 as u8
      avx[2] = idbuf as i64
      gtm_dispatch(3, avx, jx)
      if j_has(jx, "\"has_lawful_route\":true" as *u8) == 1 {
          if j_has(jx, "\"requires_prescriber\":false" as *u8) == 1 { lawful_survivors = lawful_survivors + 1 }
      }
      i11 = i11 + 1
  }
  t_puts("T11 workflow fan-out: of citrulline/oxytocin/ashwagandha, OTC-lawful survivors=" as *u8); t_putn(lawful_survivors); t_puts(" want 2: " as *u8)
  if lawful_survivors == 2 { pass = pass + 1; t_puts("PASS\n" as *u8) } else { t_puts("FAIL\n" as *u8) }
216
  t_puts("GTM-SVC-GATE passed " as *u8); t_putn(pass); t_puts("/" as *u8); t_putn(total)
  if pass == total { t_puts(" verdict=GREEN\n" as *u8); sys_exit(0); return 0 }
  t_puts(" verdict=RED\n" as *u8); sys_exit(1); return 1
220}
nx_gtm_svc_test.nx source

`nx_gtm_svc_test.nx` source
