urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2025-01-04 18:43:46 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5188 from urbit/ixv/notify-fixes

Browse Source 
notify: cleanup %watch-not-unique cases
This commit is contained in:
ixv 2021-08-30 15:01:07 -07:00 committed by GitHub
commit 01aaeb7883
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
pkg/arvo/app/notify.hoon
View File

@ -57,7 +57,7 @@
?- -.old
%0
:_ this(state old)
?. (~(has by wex.bowl) [/hark our.bowl %hark-store])
?: (~(has by wex.bowl) [/hark our.bowl %hark-store])
~
[(~(watch-our pass:io /hark) %hark-store /updates)]~
==
@ -106,18 +106,23 @@
?. (is-whitelisted:do src.bowl u.entry)
~|("permission denied" !!)
=. clients.u.entry (~(put by clients.u.entry) src.bowl ~)
:_ state(provider-state (~(put by provider-state) service.act u.entry))
:~ %: register-binding:do
service.act
u.entry
binding-endpoint.u.entry
src.bowl
address.act
==
%+ watch:pass
[src.bowl %notify]
/notify/(scot %p src.bowl)/[service.act]
==
=/ cards=(list card)
:_ ~
%: register-binding:do
service.act
u.entry
binding-endpoint.u.entry
src.bowl
address.act
==
=/ =wire /agentio-watch/notify/(scot %p src.bowl)/[service.act]
=? cards !(~(has by wex.bowl) wire src.bowl %notify)
:_ cards
%+ watch:pass
[src.bowl %notify]
/notify/(scot %p src.bowl)/[service.act]
:- cards
state(provider-state (~(put by provider-state) service.act u.entry))
::
%client-leave
=/ entry=(unit provider-entry) (~(get by provider-state) service.act)