`nx_vroom.nx` source

↩ module page · 216 lines · 9270 B
1// nx_vroom.nx -- the sovereign video-room request HANDLER (the daemon's brain),
2// kept separate from sockets/TLS so it is unit-gateable. Composes nx_room_relay
3// (per-room peer frames) into HTTP responses for the relay routes:
4//   POST /video/post?room=R&id=N   body=frame      -> rr_post, "200 ok"
5//   GET  /video/frames?room=R&id=N                 -> octet body of OTHER peers'
6//        frames as length-prefixed records: [id u64 LE][len u32 LE][frame bytes]*
7//   GET  /video/roster?room=R&id=N                 -> JSON [id,id,...]
8// Returns response length in `out`, or 0 if the route isn't a relay route (the
9// TLS/fork shell then serves the static page / client.wasm / 404).
10// Server-relay = ZERO WebRTC/STUN/TURN. All flag-style loops (no break/continue
11// in nested ifs -- that miscompiles and hangs, per the sites-daemon note).
12// license_tier: ORIGINAL
13import "nx_room_relay.nx"
14const K_MAGIC_2166136261: i64 = 2166136261
15const K_MAGIC_16777619: i64 = 16777619
16
17func vr_strlen(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} return n }
18func vr_lower(c: u8) -> u8 { if c >= (65 as u8) { if c <= (90 as u8) { return c + (32 as u8) } } return c }
19
20func vr_contains(hay: *u8, hlen: i64, needle: *u8, nlen: i64) -> i64 {
  if nlen <= 0 { return 0 }
  if hlen < nlen { return 0 }
  var i: i64 = 0
  let last: i64 = hlen - nlen
  while i <= last {
      var j: i64 = 0; var ok: i64 = 1
      while j < nlen { if hay[i+j] != needle[j] { ok = 0; j = nlen } else { j = j + 1 } }
      if ok == 1 { return 1 }
      i = i + 1
  }
  return 0
32}
33
34// body offset after CRLFCRLF, or hlen if absent
35func vr_body_start(hay: *u8, hlen: i64) -> i64 {
  var i: i64 = 0
  while i + 4 <= hlen {
      if hay[i]==(13 as u8) { if hay[i+1]==(10 as u8) { if hay[i+2]==(13 as u8) { if hay[i+3]==(10 as u8) { return i + 4 } } } }
      i = i + 1
  }
  return hlen
42}
43
44func vr_content_length(req: *u8, reqn: i64) -> i64 {
  let key: *u8 = "content-length:" as *u8
  var i: i64 = 0
  while i + 15 <= reqn {
      var j: i64 = 0; var ok: i64 = 1
      while j < 15 { if vr_lower(req[i+j]) != key[j] { ok = 0; j = 15 } else { j = j + 1 } }
      if ok == 1 {
          var k: i64 = i + 15
          var sk: i64 = 1
          while sk == 1 { if k < reqn { if req[k]==(32 as u8) { k = k + 1 } else { sk = 0 } } else { sk = 0 } }
          var v: i64 = 0; var got: i64 = 0; var run: i64 = 1
          while run == 1 {
              if k >= reqn { run = 0 } else {
                  let c: i64 = req[k] as i64
                  var dig: i64 = 0
                  if c >= 48 { if c <= 57 { dig = 1 } }
                  if dig == 1 { v = v*10 + (c-48); got = 1; k = k + 1 } else { run = 0 }
              }
          }
          if got == 1 { return v }
          return 0 - 1
      }
      i = i + 1
  }
  return 0 - 1
69}
70
71// FNV-1a over the request-line value of key (e.g. "room="); 0 if absent.
72// Hash keeps rooms isolated without storing names. Always nonzero-ized (|1).
73func vr_room_hash(req: *u8, reqn: i64) -> i64 {
  let key: *u8 = "room=" as *u8
  // limit to request line
  var lim: i64 = 0; var sc: i64 = 1
  while sc == 1 { if lim < reqn { if req[lim]==(13 as u8) { sc = 0 } else { lim = lim + 1 } } else { sc = 0 } }
  var found: i64 = 0 - 1; var i: i64 = 0
  while i + 5 <= lim {
      if found < 0 {
          var j: i64 = 0; var ok: i64 = 1
          while j < 5 { if req[i+j] != key[j] { ok = 0; j = 5 } else { j = j + 1 } }
          if ok == 1 { found = i + 5 }
      }
      i = i + 1
  }
  if found < 0 { return 0 }
  var h: i64 = K_MAGIC_2166136261
  var k: i64 = found; var run: i64 = 1
  while run == 1 {
      if k >= lim { run = 0 } else {
          let c: u8 = vr_lower(req[k])
          var keepc: i64 = 0
          if c >= (97 as u8) { if c <= (122 as u8) { keepc = 1 } }
          if c >= (48 as u8) { if c <= (57 as u8) { keepc = 1 } }
          if c == (45 as u8) { keepc = 1 }
          if keepc == 0 { run = 0 } else { h = (h ^ (c as i64)) * K_MAGIC_16777619; h = h & 0xffffffff; k = k + 1 }
      }
  }
  return h | 1
101}
102
103// integer value of the request-line value of "id=" (digits only), or -1
104func vr_id(req: *u8, reqn: i64) -> i64 {
  let key: *u8 = "id=" as *u8
  var lim: i64 = 0; var sc: i64 = 1
  while sc == 1 { if lim < reqn { if req[lim]==(13 as u8) { sc = 0 } else { lim = lim + 1 } } else { sc = 0 } }
  var found: i64 = 0 - 1; var i: i64 = 0
  while i + 3 <= lim {
      if found < 0 {
          var j: i64 = 0; var ok: i64 = 1
          while j < 3 { if req[i+j] != key[j] { ok = 0; j = 3 } else { j = j + 1 } }
          if ok == 1 { found = i + 3 }
      }
      i = i + 1
  }
  if found < 0 { return 0 - 1 }
  var v: i64 = 0; var got: i64 = 0; var k: i64 = found; var run: i64 = 1
  while run == 1 {
      if k >= lim { run = 0 } else {
          let c: i64 = req[k] as i64
          var dig: i64 = 0
          if c >= 48 { if c <= 57 { dig = 1 } }
          if dig == 1 { v = v*10 + (c-48); got = 1; k = k + 1 } else { run = 0 }
      }
  }
  if got == 0 { return 0 - 1 }
  return v
129}
130
131func vr_app(dst: *u8, off: i64, src: *u8, n: i64) -> i64 { var i: i64=0; while i<n { dst[off+i]=src[i]; i=i+1 } return off+n }
132func vr_apps(dst: *u8, off: i64, s: *u8) -> i64 { return vr_app(dst, off, s, vr_strlen(s)) }
133func vr_wu64(dst: *u8, off: i64, v: i64) -> i64 { var i: i64=0; while i<8 { dst[off+i]=((v >> (i*8)) & 0xff) as u8; i=i+1 } return off+8 }
134func vr_wu32(dst: *u8, off: i64, v: i64) -> i64 { var i: i64=0; while i<4 { dst[off+i]=((v >> (i*8)) & 0xff) as u8; i=i+1 } return off+4 }
135func vr_wdec(dst: *u8, off: i64, v: i64) -> i64 {
  if v == 0 { dst[off]=48; return off+1 }
  var d: i64=0; var y: i64=v
  while y>0 { d=d+1; y=y/10 }
  var i: i64=d-1; y=v
  while i>=0 { dst[off+i]=(48+(y%10)) as u8; y=y/10; i=i-1 }
  return off+d
142}
143
144// Handle a relay route. Returns response bytes written to out, or 0 if not a relay route.
145func vr_handle(plain: *u8, plain_n: i64, rr_st: *i64, rr_arena: *u8, now: i64, ttl: i64,
             out: *u8, out_cap: i64, ids: *i64) -> i64 {
  let slotb: i64 = rr_st[1]
148
  if vr_contains(plain, plain_n, "/post" as *u8, 5) == 1 {
      let rm: i64 = vr_room_hash(plain, plain_n)
      let pr: i64 = vr_id(plain, plain_n)
      if rm == 0 { return vr_apps(out, 0, "HTTP/1.1 400 Bad Request\r\nContent-Length: 0\r\nConnection: keep-alive\r\n\r\n" as *u8) }
      if pr < 0 { return vr_apps(out, 0, "HTTP/1.1 400 Bad Request\r\nContent-Length: 0\r\nConnection: keep-alive\r\n\r\n" as *u8) }
      let bs: i64 = vr_body_start(plain, plain_n)
      var fl: i64 = plain_n - bs
      let cl: i64 = vr_content_length(plain, plain_n)
      if cl >= 0 { if cl < fl { fl = cl } }
      if fl < 0 { fl = 0 }
      rr_post(rr_st, rr_arena, rm, pr, now, now, (plain as i64 + bs) as *u8, fl)
      return vr_apps(out, 0, "HTTP/1.1 200 OK\r\nContent-Length: 2\r\nConnection: keep-alive\r\n\r\nok" as *u8)
  }
162
  if vr_contains(plain, plain_n, "/frames" as *u8, 7) == 1 {
      let rm: i64 = vr_room_hash(plain, plain_n)
      let pr: i64 = vr_id(plain, plain_n)
      let cnt: i64 = rr_roster(rr_st, rm, pr, now, ttl, ids)
      // pass 1: body length
      var blen: i64 = 0; var a: i64 = 0
      while a < cnt {
          let s: i64 = rr_live(rr_st, rm, ids[a], now, ttl)
          if s >= 0 { blen = blen + 12 + rr_flen(rr_st, s) }
          a = a + 1
      }
      var o: i64 = vr_apps(out, 0, "HTTP/1.1 200 OK\r\nContent-Type: application/octet-stream\r\nContent-Length: " as *u8)
      o = vr_wdec(out, o, blen)
      o = vr_apps(out, o, "\r\nConnection: keep-alive\r\n\r\n" as *u8)
      // pass 2: body records [id u64][len u32][frame]
      var b: i64 = 0
      while b < cnt {
          let s: i64 = rr_live(rr_st, rm, ids[b], now, ttl)
          if s >= 0 {
              let fl: i64 = rr_flen(rr_st, s)
              o = vr_wu64(out, o, ids[b])
              o = vr_wu32(out, o, fl)
              o = vr_app(out, o, (rr_arena as i64 + s*slotb) as *u8, fl)
          }
          b = b + 1
      }
      return o
  }
191
  if vr_contains(plain, plain_n, "/roster" as *u8, 7) == 1 {
      let rm: i64 = vr_room_hash(plain, plain_n)
      let pr: i64 = vr_id(plain, plain_n)
      let cnt: i64 = rr_roster(rr_st, rm, pr, now, ttl, ids)
      // build JSON body in the tail of out, then header (Content-Length)
      let bodycap: i64 = out_cap - 256
      var jb: i64 = bodycap
      jb = vr_app(out, jb, "[" as *u8, 1)
      var a: i64 = 0
      while a < cnt {
          if a > 0 { jb = vr_app(out, jb, "," as *u8, 1) }
          jb = vr_wdec(out, jb, ids[a])
          a = a + 1
      }
      jb = vr_app(out, jb, "]" as *u8, 1)
      let blen: i64 = jb - bodycap
      var o: i64 = vr_apps(out, 0, "HTTP/1.1 200 OK\r\nContent-Type: application/json\r\nContent-Length: " as *u8)
      o = vr_wdec(out, o, blen)
      o = vr_apps(out, o, "\r\nConnection: keep-alive\r\n\r\n" as *u8)
      o = vr_app(out, o, (out as i64 + bodycap) as *u8, blen)
      return o
  }
214
  return 0
216}
nx_vroom.nx source

`nx_vroom.nx` source
