`nx_janitor.nx` source

1// nx_janitor.nx -- the CARETAKER/JANITOR's FRESHNESS evaluator (operator 2026-06-12:
2// freshness + sprawl evaluator, janitorial quality to S-class).  Is the system ALIVE
3// and are its derived surfaces FRESH?  Reads the latest beat + key derived-surface
4// epochs, compares to now -- STALE = the daemon stopped or a surface stopped
5// regenerating (the silent-death signal a janitor catches).  Freshness half here;
6// sprawl half (dup/dead-organ/scratch-accumulation) = X-JAN-002 (getdents walk).
7// Durable: JANITOR row -> knowledge/status/janitor.log.  Exit 0 = fresh.
8// argv override: none (live surfaces).  license_tier: ORIGINAL
9import "nx_syscalls.nx"
10const K_MAGIC_1048576: i64 = 1048576
11const K_MAGIC_1048560: i64 = 1048560
12const K_MAGIC_4000: i64 = 4000
13const K_MAGIC_8000: i64 = 8000
14func _p(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 }
15func _fp(fd: i64, s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(fd,s,n); return 0 }
16func _fn(fd: i64, v: i64) -> i64 { let bb: *u8=sys_mmap(28); var m: i64=v; if m<0{m=0-m; sys_write(fd,"-" 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(fd,bb,k); return 0 }
17func jn_read(path: *u8, buf: *u8, cap: i64) -> i64 {
18    let fd: i64 = sys_openat_rd(path)
19    if fd < 0 { return 0 }
20    var n: i64 = 0
21    var go: i64 = 1
22    while go == 1 { let base: i64 = buf as i64; let r: i64 = sys_read(fd, (base + n) as *u8, cap - n); if r <= 0 { go = 0 } else { n = n + r } if n >= cap { go = 0 } }
23    sys_close(fd)
24    return n
25}
26// last integer after `key` in buf, or -1 (the freshness epoch of a surface)
27func jn_last_epoch(buf: *u8, n: i64, key: *u8) -> i64 {
28    var kl: i64 = 0
29    while key[kl] != (0 as u8) { kl = kl + 1 }
30    var last: i64 = 0 - 1
31    var i: i64 = 0
32    while i + kl <= n {
33        var k: i64 = 0
34        var hit: i64 = 1
35        while k < kl { if buf[i+k] != key[k] { hit = 0; k = kl } else { k = k + 1 } }
36        if hit == 1 {
37            var p: i64 = i + kl
38            var v: i64 = 0
39            var any: i64 = 0
40            while p < n { if buf[p] < (48 as u8) { p = n } else { if buf[p] > (57 as u8) { p = n } else { v = v*10 + ((buf[p] as i64)-48); p = p + 1; any = 1 } } }
41            if any == 1 { last = v }
42        }
43        i = i + 1
44    }
45    return last
46}
47// grade one surface freshness: age = now - last_epoch; STALE if age > limit
48func jn_surface(lfd: i64, name: *u8, path: *u8, key: *u8, now: i64, limit: i64, stale: *i64) -> i64 {
49    let b: *u8 = sys_mmap(K_MAGIC_1048576)
50    let n: i64 = jn_read(path, b, K_MAGIC_1048560)
51    let ep: i64 = jn_last_epoch(b, n, key)
52    _fp(lfd, "JANITOR-SURFACE name=" as *u8); _fp(lfd, name)
53    if ep < 0 {
54        _fp(lfd, " epoch=NONE verdict=MISSING\n" as *u8)
55        stale[0] = stale[0] + 1
56        return 0
57    }
58    let age: i64 = now - ep
59    _fp(lfd, " age_s=" as *u8); _fn(lfd, age)
60    if age > limit { _fp(lfd, " verdict=STALE\n" as *u8); stale[0] = stale[0] + 1 } else { _fp(lfd, " verdict=FRESH\n" as *u8) }
61    return 0
62}
63func main() -> i64 {
64    _p("=== JANITOR (Caretaker): freshness -- is the system alive + surfaces regenerating? ===\n" as *u8)
65    let now: i64 = sys_now_realtime_sec()
66    let lfd: i64 = sys_openat_append("knowledge/status/janitor.log" as *u8, 0x1a4)
67    if lfd < 0 { _p(" janitor log open failed\n" as *u8); sys_exit(1); return 1 }
68    let stale: *i64 = sys_mmap(16) as *i64
69    stale[0] = 0
70    // 2 beat intervals (~32min each) = 4000s freshness limit; SITREP/tempo tighter
71    jn_surface(lfd, "pulse-beat" as *u8, "knowledge/status/team_pulse.log" as *u8, "PULSE-RUN epoch=" as *u8, now, K_MAGIC_4000, stale)
72    jn_surface(lfd, "sitrep" as *u8, "knowledge/channel/team_out.tsv" as *u8, "SITREP epoch=" as *u8, now, K_MAGIC_4000, stale)
73    jn_surface(lfd, "tempo" as *u8, "knowledge/status/tempo.log" as *u8, "TEMPO epoch=" as *u8, now, K_MAGIC_4000, stale)
74    jn_surface(lfd, "autonomy" as *u8, "knowledge/status/autonomy_meter.log" as *u8, "AUTMETER epoch=" as *u8, now, K_MAGIC_4000, stale)
75    jn_surface(lfd, "ark" as *u8, "knowledge/status/ark_push.log" as *u8, "ARKPUSH epoch=" as *u8, now, K_MAGIC_8000, stale)
76    _fp(lfd, "JANITOR epoch=" as *u8); _fn(lfd, now)
77    _fp(lfd, " surfaces=5 stale=" as *u8); _fn(lfd, stale[0])
78    if stale[0] == 0 { _fp(lfd, " verdict=FRESH\n" as *u8) } else { _fp(lfd, " verdict=STALE\n" as *u8) }
79    sys_close(lfd)
80    _p(" stale_surfaces=" as *u8); _fn(1, stale[0])
81    if stale[0] == 0 { _p(" -- JANITOR: FRESH (system alive, surfaces regenerating)\n" as *u8); sys_exit(0); return 0 }
82    _p(" -- JANITOR: STALE (a surface stopped regenerating -- the silent-death signal)\n" as *u8)
83    sys_exit(1)
84    return 1
85}
nx_janitor.nx source

`nx_janitor.nx` source
