relay much more robust

1 files changed, 203 insertions, 0 deletions

diff --git a/backupdesk/lib/nostrill/mutations.hoon b/backupdesk/lib/nostrill/mutations.hoon
new file mode 100644
index 0000000..6a27e4f
--- /dev/null
+++ b/backupdesk/lib/nostrill/mutations.hoon
@@ -0,0 +1,203 @@
+/-  sur=nostrill, nsur=nostr,
+    post=trill-post, gate=trill-gate, feed=trill-feed
+    
+/+  appjs=json-nostrill,
+    njs=json-nostr,
+    postlib=trill-post,
+    shim,
+    sr=sortug
+
+|_  [=state:sur =bowl:gall]
++$  card  card:agent:gall
+++  debug-own-feed
+  =/  postlist  (tap:orm:feed feed.state)  
+  =/  lol
+  |-  ?~  postlist  ~
+    ~&  >>  poast=+.i.postlist
+    $(postlist t.postlist)
+  ~
+::  TODO  not a mutation but fuck it
+++  get-poast  |=  [host=@p id=@]  ^-  (unit post:post)
+  =/  poast  ?:  .=(host our.bowl)
+    (get:orm:feed feed.state id)
+    ~
+  poast
+  
+:: state
+++  add-to-feed  |=  p=post:post
+  =.  feed.state  (put:orm:feed feed.state id.p p)
+  state
+:: events
+++  process-events  ^-  (quip card _state)
+  :: =/  l  events.state
+  :: =|  cards=(list card:agent:gall)
+  :: |-  ?~  l  [cards state]
+  :: =/  n  (event-parsing i.l)
+  :: $(cards -.n, state +.n, l t.l)
+  :: TODO
+  `state
+  
+:: ++  parse-events
+::   |=  evs=(list event:nsur)
+::   ^-  (quip card _state)
+::   =|  cards=(list card)
+::   =^  cards  state
+::   |-  ?~  evs  [cards state]
+::     =^  cards  state  (handle-event i.evs)
+::     $(evs t.evs)
+::   [cards state]
+
+++  handle-shim-msg  |=  [relay=@t msg=relay-msg:nsur]
+  =/  rs  (~(get by relays.state) relay)
+  ?~  rs  `state
+  =^  cards  state
+  ?-  -.msg
+    %event  (handle-event relay sub-id.msg event.msg)
+    %ok     (handle-ok relay +.msg)
+    %eose    =/  creq  (~(get by reqs.u.rs) +.msg)
+             ?~  creq  `state
+             =.  reqs.u.rs  (~(del by reqs.u.rs) +.msg)
+             =.  relays.state  (~(put by relays.state) relay u.rs)
+             `state
+    %closed  =.  reqs.u.rs  (~(del by reqs.u.rs) sub-id.msg)
+             =.  relays.state  (~(put by relays.state) relay u.rs)
+             `state
+    %auth    ~&  >>  auth=+.msg  :: TODO handle auth challenges?
+              `state
+    %notice  ~&  >>  notice=+.msg  :: TODO pass to UI?
+              `state
+    %error  ~&  >>>  relay-error=+.msg
+      =.  relays.state  (~(del by relays.state) relay)
+      `state
+  ==
+  [cards state]
+    :: =.  relays  (update-relay-stats:mutat url.u.msg sub-id.u.msg)
+    :: =^  cards  state  (handle-event:mutat url.u.msg sub-id.u.msg event.u.msg)
+    :: ::  TODO not just stash events
+    :: =/  relay  (~(get by relays) url.u.msg)
+    :: =/  nevents=(list event:nsur)  ?~  relay  [event.u.msg ~]  [event.u.msg u.relay]
+    :: =/  nevents2  (scag 100 nevents)
+
+    :: =.  relays  (~(put by relays) url.u.msg nevents2)
+    :: :: TODO respond better
+    :: =/  response  (ebail:rout id.order)
+    :: =/  ncards  (weld cards response)
+    
+    ::  [ncards this]
+  :: `state
+    
+++  update-relay-stats
+  |=  [relay=@t sub-id=@t]  ^+  relays.state
+  =/  cur  (~(get by relays.state) relay)
+  =/  curr  ?~  cur  *relay-stats:nsur  u.cur
+  =?  connected.curr  ?=(%~ connected.curr)  (some now.bowl)
+  =/  creq  (~(get by reqs.curr) sub-id)
+  ?~  creq  relays.state  :: bail
+  =/  nreq  u.creq(received +(received.u.creq))
+  =.  reqs.curr  (~(put by reqs.curr) sub-id nreq)
+  (~(put by relays.state) relay curr)
+
+++  handle-ok  |=  [relay=@t event-id=@ux accepted=? msg=@t]
+  ^-  (quip card _state)
+  :: TODO pass to UI
+  `state
+
+
+++  handle-event
+  |=  [relay=@t sub-id=@t =event:nsur]
+  ^-  (quip card _state)
+  |^
+  ~&  parsing-nostr-event=kind.event
+:: https://nostrdata.github.io/kinds/
+  ?:  .=(kind.event 666)  :: one_off subs eose  cf. 999
+    parse-shim-oneose
+  ?:  .=(kind.event 0)  ::  user metadata
+    parse-metadata
+  ?:  .=(kind.event 1)  ::  apparently a poast
+    parse-poast
+  ?:  .=(kind.event 3)  ::  follow list
+    parse-follow
+  :: ?:  .=(kind.event 5)  ::  delete
+  ?:  .=(kind.event 6)  ::  RT
+    parse-follow
+  ?:  .=(kind.event 7)  ::  Reaction
+    parse-follow
+
+    `state
+
+  ++  parse-metadata
+  ^-  (quip card _state)
+    =/  jstring  content.event
+    =/  ujon  (de:json:html jstring)
+    ?~  ujon  ~&  failed-parse-metadata=ujon  `state
+    =/  umeta  (user-meta:de:njs u.ujon)
+    ?~  umeta  ~&  >>  failed-dejs-metadata=ujon  `state
+    =.  profiles.state  (~(put by profiles.state) pubkey.event u.umeta)
+    `state
+
+
+  ++  parse-poast
+  ^-  (quip card _state)
+    =.  nostr-feed.state  (put:norm:sur nostr-feed.state created-at.event event)
+    =/  uprof  (~(get by profiles.state) pubkey.event)
+    ?~  uprof
+      =/  shimm  ~(. shim [state bowl])
+      =^  cards  state  (get-profiles:shimm (silt ~[pubkey.event]))
+      [cards state]
+
+
+    :: =/  fid  (~(get by following.state) pubkey.event)
+    :: ?~  fid  `state  ::  don't save post if we don't follow the fucker
+
+    :: =/  cl  (tokenize:postlib content.event)
+
+    :: =/  ts  (from-unix:jikan:sr created-at.event)
+    :: :: TODO wtf
+    :: =/  cm=content-map:post  (init-content-map:postlib cl ts)
+
+    :: =/  p=post:post  :*
+    ::   id=ts
+    ::   host=`@p`pubkey.event
+    ::   author=`@p`pubkey.event
+    ::   thread=ts
+    ::   parent=~
+    ::   children=~
+    ::   contents=cm
+    ::   read=*lock:gate
+    ::   write=*lock:gate
+    ::   *engagement:post
+    ::   0v0
+    ::   *signature:post
+    ::   tags=~
+    :: ==  
+    :: =/  nfid  (put:orm:feed u.fid ts p)
+    :: =.  following.state  (~(put by following.state) pubkey.event nfid)
+  `state
+  
+
+  ++  parse-follow
+  ^-  (quip card _state)
+    =/  following  (~(get by follow-graph.state) pubkey.event)
+    =/  follow-set  ?~  following  *(set follow:sur)  u.following
+    |-  ?~  tags.event  `state
+      =/  t=tag:nsur  i.tags.event
+      :: ?.  .=('p' key.t)  $(tags.event t.tags.event)
+      :: =/  pubkeys  value.t
+      :: =/  pubkey  (slaw:sr %ux pubkeys)
+      :: ?~  pubkey  ~&  "parsing hex error"  $(tags.event t.tags.event)
+      :: =/  relay  (snag 0 rest.t)
+      :: =/  rel  ?:  .=(relay '')  ~  (some relay)
+      :: =/  nickname  (snag 1 rest.t)
+      :: =/  meta=follow:sur  [u.pubkey nickname rel]
+      :: =.  follow-set  (~(put in follow-set) meta)
+      :: =.  follow-graph.state  (~(put by follow-graph.state) pubkey.event follow-set)
+      $(tags.event t.tags.event)
+  ++  parse-shim-oneose
+  ^-  (quip card _state)
+    =/  rs  (~(get by relays.state) relay)
+    ?~  rs  `state
+    =.  reqs.u.rs  (~(del by reqs.u.rs) sub-id)
+    =.  relays.state  (~(put by relays.state) relay u.rs)
+  `state
+  --
+--