mirror of
https://github.com/urbit/shrub.git
synced 2024-12-22 10:21:31 +03:00
338 lines
8.3 KiB
Plaintext
338 lines
8.3 KiB
Plaintext
:: hark-graph-hook: notifications for graph-store [landscape]
|
|
::
|
|
/- store=hark-store, post, group-store, metadata-store, hook=hark-graph-hook
|
|
/+ resource, metadata, default-agent, dbug, graph-store, graph, grouplib=group
|
|
::
|
|
::
|
|
~% %hark-graph-hook-top ..part ~
|
|
|%
|
|
+$ card card:agent:gall
|
|
+$ versioned-state
|
|
$% state-0
|
|
==
|
|
::
|
|
+$ state-0
|
|
$: %0
|
|
watching=(set [resource index:post])
|
|
mentions=_&
|
|
watch-on-self=_&
|
|
==
|
|
::
|
|
+$ notif-kind
|
|
[name=@t parent-lent=@ud mode=?(%each %count) watch=?]
|
|
::
|
|
--
|
|
::
|
|
=| state-0
|
|
=* state -
|
|
::
|
|
=>
|
|
|_ =bowl:gall
|
|
::
|
|
++ scry
|
|
|* [=mold p=path]
|
|
?> ?=(^ p)
|
|
?> ?=(^ t.p)
|
|
.^(mold i.p (scot %p our.bowl) i.t.p (scot %da now.bowl) t.t.p)
|
|
::
|
|
++ give
|
|
|= [paths=(list path) =update:hook]
|
|
^- (list card)
|
|
[%give %fact paths hark-graph-hook-update+!>(update)]~
|
|
::
|
|
++ watch-graph
|
|
^- card
|
|
[%pass /graph %agent [our.bowl %graph-store] %watch /updates]
|
|
--
|
|
%- agent:dbug
|
|
^- agent:gall
|
|
~% %hark-graph-hook-agent ..card ~
|
|
|_ =bowl:gall
|
|
+* this .
|
|
ha ~(. +> bowl)
|
|
def ~(. (default-agent this %|) bowl)
|
|
met ~(. metadata bowl)
|
|
grp ~(. grouplib bowl)
|
|
gra ~(. graph bowl)
|
|
::
|
|
++ on-init
|
|
:_ this
|
|
~[watch-graph:ha]
|
|
::
|
|
++ on-save !>(state)
|
|
++ on-load
|
|
|= old=vase
|
|
^- (quip card _this)
|
|
:_ this(state !<(state-0 old))
|
|
%+ welp
|
|
?: (~(has by wex.bowl) [/graph our.bowl %graph-store])
|
|
~
|
|
~[watch-graph:ha]
|
|
%+ turn
|
|
^- (list mark)
|
|
:~ %graph-validator-chat
|
|
%graph-validator-link
|
|
%graph-validator-publish
|
|
==
|
|
|= =mark
|
|
^- card
|
|
=/ =wire /validator/[mark]
|
|
=/ =rave:clay [%sing %c [%da now.bowl] /[mark]/notification-kind]
|
|
[%pass wire %arvo %c %warp our.bowl [%home `rave]]
|
|
::
|
|
++ on-watch
|
|
|= =path
|
|
^- (quip card _this)
|
|
=^ cards state
|
|
?+ path (on-watch:def path)
|
|
::
|
|
[%updates ~]
|
|
:_ state
|
|
%+ give:ha ~
|
|
:* %initial
|
|
watching
|
|
mentions
|
|
watch-on-self
|
|
==
|
|
==
|
|
[cards this]
|
|
::
|
|
++ on-poke
|
|
~/ %hark-graph-hook-poke
|
|
|= [=mark =vase]
|
|
^- (quip card _this)
|
|
|^
|
|
?> (team:title our.bowl src.bowl)
|
|
=^ cards state
|
|
?+ mark (on-poke:def mark vase)
|
|
%hark-graph-hook-action
|
|
(hark-graph-hook-action !<(action:hook vase))
|
|
==
|
|
[cards this]
|
|
::
|
|
++ hark-graph-hook-action
|
|
|= =action:hook
|
|
^- (quip card _state)
|
|
|^
|
|
:- (give:ha ~[/updates] action)
|
|
?- -.action
|
|
%listen (listen +.action)
|
|
%ignore (ignore +.action)
|
|
%set-mentions (set-mentions +.action)
|
|
%set-watch-on-self (set-watch-on-self +.action)
|
|
==
|
|
++ listen
|
|
|= [graph=resource =index:post]
|
|
^+ state
|
|
state(watching (~(put in watching) [graph index]))
|
|
::
|
|
++ ignore
|
|
|= [graph=resource =index:post]
|
|
^+ state
|
|
state(watching (~(del in watching) [graph index]))
|
|
::
|
|
++ set-mentions
|
|
|= ment=?
|
|
^+ state
|
|
state(mentions ment)
|
|
::
|
|
++ set-watch-on-self
|
|
|= self=?
|
|
^+ state
|
|
state(watch-on-self self)
|
|
--
|
|
--
|
|
::
|
|
++ on-agent
|
|
~/ %hark-graph-hook-agent
|
|
|= [=wire =sign:agent:gall]
|
|
^- (quip card _this)
|
|
|^
|
|
?+ -.sign (on-agent:def wire sign)
|
|
%kick
|
|
:_ this
|
|
?. ?=([%graph ~] wire)
|
|
~
|
|
~[watch-graph:ha]
|
|
::
|
|
%fact
|
|
?. ?=(%graph-update p.cage.sign)
|
|
(on-agent:def wire sign)
|
|
=^ cards state
|
|
(graph-update !<(update:graph-store q.cage.sign))
|
|
[cards this]
|
|
==
|
|
++ add-graph
|
|
|= [rid=resource =graph:graph-store]
|
|
^- (quip card _state)
|
|
=/ group-rid=(unit resource)
|
|
(group-from-app-resource:met %graph rid)
|
|
?~ group-rid
|
|
~& no-group+rid
|
|
`state
|
|
=/ is-hidden=?
|
|
!(is-managed:grp u.group-rid)
|
|
=/ should-watch
|
|
|(is-hidden &(watch-on-self =(our.bowl entity.rid)))
|
|
?. should-watch
|
|
`state
|
|
:- (give:ha ~[/updates] %listen [rid ~])
|
|
state(watching (~(put in watching) [rid ~]))
|
|
::
|
|
++ graph-update
|
|
|= =update:graph-store
|
|
^- (quip card _state)
|
|
?: ?=(%add-graph -.q.update)
|
|
(add-graph resource.q.update graph.q.update)
|
|
?. ?=(%add-nodes -.q.update)
|
|
[~ state]
|
|
=* rid resource.q.update
|
|
(check-nodes ~(tap by nodes.q.update) rid)
|
|
::
|
|
++ check-nodes
|
|
|= $: nodes=(list [p=index:graph-store q=node:graph-store])
|
|
rid=resource
|
|
==
|
|
=/ group=resource
|
|
(need (group-from-app-resource:met %graph rid))
|
|
=/ =metadata:metadata-store
|
|
(need (peek-metadata:met %graph group rid))
|
|
=+ %+ scry:ha
|
|
,mark=(unit mark)
|
|
/gx/graph-store/graph-mark/(scot %p entity.rid)/[name.rid]/noun
|
|
=+ %+ scry:ha
|
|
,=tube:clay
|
|
/cc/[q.byk.bowl]/[(fall mark %graph-validator-link)]/notification-kind
|
|
=| cards=(list card)
|
|
|^
|
|
?~ nodes
|
|
[cards state]
|
|
=* index p.i.nodes
|
|
=* node q.i.nodes
|
|
=^ node-cards state
|
|
(check-node node tube)
|
|
%_ $
|
|
nodes t.nodes
|
|
cards (weld node-cards cards)
|
|
==
|
|
::
|
|
++ check-node-children
|
|
|= [=node:graph-store =tube:clay]
|
|
^- (quip card _state)
|
|
?: ?=(%empty -.children.node)
|
|
[~ state]
|
|
=/ children=(list [=atom =node:graph-store])
|
|
(tap:orm:graph-store p.children.node)
|
|
=| cards=(list card)
|
|
|- ^- (quip card _state)
|
|
?~ children
|
|
[cards state]
|
|
=^ new-cards state
|
|
(check-node node.i.children tube)
|
|
%_ $
|
|
cards (weld cards new-cards)
|
|
children t.children
|
|
==
|
|
::
|
|
++ check-node
|
|
|= [=node:graph-store =tube:clay]
|
|
^- (quip card _state)
|
|
=^ child-cards state
|
|
(check-node-children node tube)
|
|
=+ !< notif-kind=(unit notif-kind)
|
|
(tube !>([0 post.node]))
|
|
?~ notif-kind
|
|
[child-cards state]
|
|
=/ desc=@t
|
|
?: (is-mention contents.post.node)
|
|
%mention
|
|
name.u.notif-kind
|
|
=/ parent=index:post
|
|
(scag parent-lent.u.notif-kind index.post.node)
|
|
=/ notif-index=index:store
|
|
[%graph group rid module.metadata desc parent]
|
|
?: =(our.bowl author.post.node)
|
|
=^ self-cards state
|
|
(self-post node notif-index [mode watch]:u.notif-kind)
|
|
:_ state
|
|
(weld child-cards self-cards)
|
|
:_ state
|
|
%+ weld child-cards
|
|
%+ weld
|
|
%^ update-unread-count
|
|
mode.u.notif-kind notif-index
|
|
[time-sent index]:post.node
|
|
?. ?| =(desc %mention)
|
|
(~(has in watching) [rid parent])
|
|
==
|
|
~
|
|
=/ =contents:store
|
|
[%graph (limo post.node ~)]
|
|
~[(add-unread notif-index [time-sent.post.node %.n contents])]
|
|
::
|
|
++ is-mention
|
|
|= contents=(list content:post)
|
|
^- ?
|
|
?. mentions %.n
|
|
?~ contents %.n
|
|
?. ?=(%mention -.i.contents)
|
|
$(contents t.contents)
|
|
?: =(our.bowl ship.i.contents)
|
|
%.y
|
|
$(contents t.contents)
|
|
::
|
|
++ self-post
|
|
|= $: =node:graph-store
|
|
=index:store
|
|
mode=?(%count %each)
|
|
watch=?
|
|
==
|
|
^- (quip card _state)
|
|
=| cards=(list card)
|
|
=? cards ?=(%count mode)
|
|
:_ cards
|
|
(poke-hark %read-count index)
|
|
?. &(watch watch-on-self)
|
|
[cards state]
|
|
:- cards
|
|
state(watching (~(put in watching) [rid index.post.node]))
|
|
::
|
|
++ poke-hark
|
|
|= =action:store
|
|
^- card
|
|
=- [%pass / %agent [our.bowl %hark-store] %poke -]
|
|
hark-action+!>(action)
|
|
::
|
|
++ update-unread-count
|
|
|= [mode=?(%count %each %none) =index:store time=@da ref=index:graph-store]
|
|
?- mode
|
|
%count ~[(poke-hark %unread-count index time)]
|
|
%each ~[(poke-hark %unread-each index ref time)]
|
|
%none ~
|
|
==
|
|
::
|
|
++ add-unread
|
|
|= [=index:store =notification:store]
|
|
(poke-hark %add-note index notification)
|
|
::
|
|
--
|
|
--
|
|
::
|
|
++ on-peek on-peek:def
|
|
::
|
|
++ on-leave on-leave:def
|
|
++ on-arvo
|
|
|= [=wire =sign-arvo]
|
|
^- (quip card _this)
|
|
?+ wire (on-arvo:def wire sign-arvo)
|
|
::
|
|
[%validator @ ~]
|
|
:_ this
|
|
=* validator i.t.wire
|
|
=/ =rave:clay [%next %c [%da now.bowl] /[validator]/notification-kind]
|
|
[%pass wire %arvo %c %warp our.bowl [%home `rave]]~
|
|
==
|
|
++ on-fail on-fail:def
|
|
--
|
|
|