code wiki / _hdl_build / nx_estate_inventory.nx
`nx_estate_inventory.nx` source

↩ module page · 177 lines · 10091 B
1// nx_estate_inventory.nx -- FIRST RUNG of the Nishi Office/Storage suite for andelinwest: a NEVER-LOSE,
2// audit-trailed estate INVENTORY (the will's assets/beneficiaries) on the sovereign append-only content-
3// addressed store (nx_seg_store). Why this reduces EXECUTOR CONFLICT: the store is APPEND-ONLY IMMUTABLE --
4// every edit is a NEW version and OLD versions are never destroyed (the ADDITIVE law), commits are crash-safe
5// (temp+rename), and reads return ONE authoritative current value. So the executor + heirs get a single,
6// tamper-evident source of truth WITH a complete change history, instead of scattered disputable copies.
7//   nx_estate_inventory put     <prefix> <asset_id> <description> <value> <beneficiary>
8//   nx_estate_inventory get     <prefix> <asset_id>
9//   nx_estate_inventory history <prefix> <asset_id>     (the full audit trail = every version, oldest->newest)
10// prefix = a store path prefix, e.g. knowledge/store/estate-andelinwest-CLIENT-  license_tier: ORIGINAL
11import "nx_seg_store.nx"
12const K_MAGIC_8192: i64 = 8192
13const K_MAGIC_65536: i64 = 65536
14
15func ei_puts(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 }
16func ei_num(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 }
17func ei_strlen(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} return n }
18func ei_streq(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 }
19func ei_cat(dst: *u8, off: i64, s: *u8) -> i64 { var i: i64=0; while s[i]!=(0 as u8){ dst[off+i]=s[i]; i=i+1 } return off+i }
20
21// next segment id = the segment COUNT. ss_manifest fills segs[] with name-string POINTERS (not segids), so we
22// must NOT max over them; commits are sequential (each uses the prior count as its id), so count == next id.
23func ei_next_segid(prefix: *u8) -> i64 {
  let segs: *i64=sys_mmap(8*260) as *i64
  return ss_manifest(prefix, segs)
26}
27
28// build key "asset:<id>" (NUL-terminated) into kbuf
29func ei_key(kbuf: *u8, id: *u8) -> i64 {
  var o: i64=ei_cat(kbuf, 0, "asset:" as *u8)
  o=ei_cat(kbuf, o, id)
  kbuf[o]=0 as u8
  return o
34}
35
36// is `id` (idlen bytes) present as a whole line in buf[0..n)?
37func ei_id_present(buf: *u8, n: i64, id: *u8, idlen: i64) -> i64 {
  var ls: i64=0; var i: i64=0
  while i<=n {
      var eol: i64=0
      if i==n { eol=1 } else { if buf[i]==(10 as u8) { eol=1 } }
      if eol==1 {
          if i-ls==idlen { var j: i64=0; var same: i64=1; while j<idlen { if buf[ls+j]!=id[j] { same=0; j=idlen } else { j=j+1 } } if same==1 { return 1 } }
          ls=i+1
      }
      i=i+1
  }
  return 0
49}
50
51func main(argc: i64, argv: *i64) -> i64 {
  if argc<3 {
      ei_puts("usage: nx_estate_inventory put|get|history|list|export <prefix> ...\n" as *u8)
      sys_exit(2); return 2
  }
  let cmd: *u8=argv[1] as *u8
  let prefix: *u8=argv[2] as *u8
58
  if ei_streq(cmd, "put" as *u8)==1 {
      if argc<7 { ei_puts("usage: put <prefix> <asset_id> <description> <value> <beneficiary>\n" as *u8); sys_exit(2); return 2 }
      let id: *u8=argv[3] as *u8
      let kbuf: *u8=sys_mmap(256); ei_key(kbuf, id)
      // canonical record: description<TAB>value<TAB>beneficiary
      let vbuf: *u8=sys_mmap(K_MAGIC_8192); var vo: i64=0
      vo=ei_cat(vbuf, vo, argv[4] as *u8); vbuf[vo]=9 as u8; vo=vo+1
      vo=ei_cat(vbuf, vo, argv[5] as *u8); vbuf[vo]=9 as u8; vo=vo+1
      vo=ei_cat(vbuf, vo, argv[6] as *u8)
      let segid: i64=ei_next_segid(prefix)
      let w: *i64=ss_begin()
      ss_add(w, 1, kbuf, vbuf, vo)
      // maintain "__index__" (newline-separated asset ids) IN THE SAME COMMIT so `list` can enumerate the whole
      // will inventory atomically -- the asset record and the index advance together (no torn state).
      let ipo: *i64=sys_mmap(16) as *i64; let ilo: *i64=sys_mmap(16) as *i64
      let idxbuf: *u8=sys_mmap(K_MAGIC_65536); var ilen: i64=0
      if ss_get(prefix, "__index__" as *u8, ipo, ilo)>=0 { let src: *u8=ipo[0] as *u8; var c: i64=0; while c<ilo[0] { idxbuf[ilen]=src[c]; ilen=ilen+1; c=c+1 } }
      let idl: i64=ei_strlen(id)
      if ei_id_present(idxbuf, ilen, id, idl)==0 { var c2: i64=0; while c2<idl { idxbuf[ilen]=id[c2]; ilen=ilen+1; c2=c2+1 } idxbuf[ilen]=10 as u8; ilen=ilen+1 }
      ss_add(w, 1, "__index__" as *u8, idxbuf, ilen)
      let rc: i64=ss_commit(prefix, w, segid)
      if rc!=0 { ei_puts("ESTATE-PUT-FAIL rc=" as *u8); ei_num(rc); ei_puts("\n" as *u8); sys_exit(1); return 1 }
      ei_puts("ESTATE-PUT-OK asset=" as *u8); ei_puts(id); ei_puts(" version=" as *u8); ei_num(segid); ei_puts("\n" as *u8)
      sys_exit(0); return 0
  }
84
  if ei_streq(cmd, "get" as *u8)==1 {
      if argc<4 { ei_puts("usage: get <prefix> <asset_id>\n" as *u8); sys_exit(2); return 2 }
      let kbuf: *u8=sys_mmap(256); ei_key(kbuf, argv[3] as *u8)
      let po: *i64=sys_mmap(16) as *i64
      let lo: *i64=sys_mmap(16) as *i64
      let rc: i64=ss_get(prefix, kbuf, po, lo)
      if rc<0 { ei_puts("ESTATE-GET: asset not found\n" as *u8); sys_exit(1); return 1 }
      ei_puts("ESTATE-ASSET " as *u8); ei_puts(argv[3] as *u8); ei_puts(" = " as *u8)
      sys_write(1, po[0] as *u8, lo[0]); ei_puts("\n" as *u8)
      sys_exit(0); return 0
  }
96
  if ei_streq(cmd, "history" as *u8)==1 {
      if argc<4 { ei_puts("usage: history <prefix> <asset_id>\n" as *u8); sys_exit(2); return 2 }
      let kbuf: *u8=sys_mmap(256); ei_key(kbuf, argv[3] as *u8)
      let kinds: *i64=sys_mmap(8*260) as *i64
      let ptrs: *i64=sys_mmap(8*260) as *i64
      let lens: *i64=sys_mmap(8*260) as *i64
      let srcs: *i64=sys_mmap(8*260) as *i64
      let n: i64=ss_scan_all(prefix, kbuf, kinds, ptrs, lens, srcs)
      ei_puts("ESTATE-HISTORY " as *u8); ei_puts(argv[3] as *u8); ei_puts(" versions=" as *u8); ei_num(n); ei_puts(" (oldest->newest; immutable, never destroyed)\n" as *u8)
      var i: i64=0
      while i<n {
          ei_puts("  v" as *u8); ei_num(i); ei_puts(" seg=" as *u8); ei_num(srcs[i])
          if kinds[i]==2 { ei_puts(" [TOMBSTONE/soft-delete]" as *u8) } else { ei_puts(" = " as *u8); sys_write(1, ptrs[i] as *u8, lens[i]) }
          ei_puts("\n" as *u8)
          i=i+1
      }
      sys_exit(0); return 0
  }
115
  if ei_streq(cmd, "list" as *u8)==1 {
      // the WHOLE will inventory: every asset id (from __index__) with its current authoritative state.
      let ipo: *i64=sys_mmap(16) as *i64; let ilo: *i64=sys_mmap(16) as *i64
      if ss_get(prefix, "__index__" as *u8, ipo, ilo)<0 { ei_puts("ESTATE-LIST: (empty inventory)\nESTATE-LIST-OK assets=0\n" as *u8); sys_exit(0); return 0 }
      let idxp: *u8=ipo[0] as *u8; let idxn: i64=ilo[0]
      ei_puts("ESTATE-INVENTORY (all assets, current state; desc<TAB>value<TAB>beneficiary):\n" as *u8)
      var ls: i64=0; var i: i64=0; var cnt: i64=0
      while i<=idxn {
          var eol: i64=0
          if i==idxn { eol=1 } else { if idxp[i]==(10 as u8) { eol=1 } }
          if eol==1 {
              if i>ls {
                  let kbuf: *u8=sys_mmap(256); var ko: i64=ei_cat(kbuf, 0, "asset:" as *u8)
                  var c: i64=ls; while c<i { kbuf[ko]=idxp[c]; ko=ko+1; c=c+1 } kbuf[ko]=0 as u8
                  let po: *i64=sys_mmap(16) as *i64; let lo: *i64=sys_mmap(16) as *i64
                  ei_puts("  " as *u8); sys_write(1, ((idxp as i64)+ls) as *u8, i-ls); ei_puts(" = " as *u8)
                  if ss_get(prefix, kbuf, po, lo)>=0 { sys_write(1, po[0] as *u8, lo[0]) } else { ei_puts("(missing)" as *u8) }
                  ei_puts("\n" as *u8); cnt=cnt+1
              }
              ls=i+1
          }
          i=i+1
      }
      ei_puts("ESTATE-LIST-OK assets=" as *u8); ei_num(cnt); ei_puts("\n" as *u8)
      sys_exit(0); return 0
  }
142
  if ei_streq(cmd, "export" as *u8)==1 {
      // emit a MAIL-MERGE-READY TSV (header + one row per asset) so the inventory directly drives per-heir
      // document generation (nx_mailmerge). Columns: asset<TAB>description<TAB>value<TAB>beneficiary -- the
      // stored value is ALREADY description<TAB>value<TAB>beneficiary, so each row = asset-id + TAB + value.
      let tab: *u8=sys_mmap(1); tab[0]=9 as u8
      ei_puts("asset" as *u8); sys_write(1,tab,1); ei_puts("description" as *u8); sys_write(1,tab,1); ei_puts("value" as *u8); sys_write(1,tab,1); ei_puts("beneficiary\n" as *u8)
      let ipo: *i64=sys_mmap(16) as *i64; let ilo: *i64=sys_mmap(16) as *i64
      if ss_get(prefix, "__index__" as *u8, ipo, ilo)<0 { sys_exit(0); return 0 }
      let idxp: *u8=ipo[0] as *u8; let idxn: i64=ilo[0]
      var ls: i64=0; var i: i64=0
      while i<=idxn {
          var eol: i64=0
          if i==idxn { eol=1 } else { if idxp[i]==(10 as u8) { eol=1 } }
          if eol==1 {
              if i>ls {
                  let kbuf: *u8=sys_mmap(256); var ko: i64=ei_cat(kbuf, 0, "asset:" as *u8)
                  var c: i64=ls; while c<i { kbuf[ko]=idxp[c]; ko=ko+1; c=c+1 } kbuf[ko]=0 as u8
                  let po: *i64=sys_mmap(16) as *i64; let lo: *i64=sys_mmap(16) as *i64
                  if ss_get(prefix, kbuf, po, lo)>=0 {
                      sys_write(1, ((idxp as i64)+ls) as *u8, i-ls)  // asset id
                      sys_write(1, tab, 1)
                      sys_write(1, po[0] as *u8, lo[0])              // stored value = description<TAB>value<TAB>beneficiary
                      ei_puts("\n" as *u8)
                  }
              }
              ls=i+1
          }
          i=i+1
      }
      sys_exit(0); return 0
  }
174
  ei_puts("ESTATE: unknown command (put|get|history|list|export)\n" as *u8)
  sys_exit(2); return 2
177}
nx_estate_inventory.nx source

`nx_estate_inventory.nx` source
