urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-20 09:21:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

gall: include sub-nonce in unsubscribe wire

Browse Source
This commit is contained in:
yosoyubik 2022-04-01 09:37:45 +02:00
parent 674c9e95a0
commit 0a96d69785
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/arvo/sys/vane/gall.hoon
View File

@ -1751,8 +1751,22 @@
?: ?=([* %pass * %g %deal * * %leave *] move) ?: ?=([* %pass * %g %deal * * %leave *] move)
=/ =wire p.move.move =/ =wire p.move.move
?> ?=([%use @ @ %out @ @ *] wire) ?> ?=([%use @ @ %out @ @ *] wire)
=/ sub-wire t.t.t.t.t.t.wire =/ =dock [q.p q]:q.move.move
=/ =dock [q.p q]:q.move.move =/ sys-wire=^wire (scag 6 `^wire`wire)
=/ sub-wire=^wire (slag 6 `^wire`wire)
::
?. (~(has by outbound.watches.yoke) sub-wire dock)
=. ap-core
=/ =tang
:~ leaf+"got %leave for missing subscription"
>agent-name< >sub-wire< >dock<
==
(ap-error %leave-missing-subscription tang)
$(moves t.moves)
=/ have=[acked=? =path nonce=@]
(~(got by outbound.watches.yoke) sub-wire dock)
=. p.move.move
(weld sys-wire [(scot %ud nonce.have) sub-wire])
=. outbound.watches.yoke =. outbound.watches.yoke
(~(del by outbound.watches.yoke) [sub-wire dock]) (~(del by outbound.watches.yoke) [sub-wire dock])
$(moves t.moves, new-moves [move new-moves]) $(moves t.moves, new-moves [move new-moves])