urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-14 11:08:45 +03:00
Code Issues Packages Projects Releases Wiki Activity

Don't reset ost.

Browse Source
This commit is contained in:
C. Guy Yarvin 2014-12-10 20:29:09 -08:00
parent b6c448e8a9
commit 70d4766518
1 changed files with 19 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
main/app/rodeo/core.hook
View File

@ -262,16 +262,16 @@
++ pa-watch :: watch presence
|= her=ship
?. (pa-admire her)
(pa-sauce [[%mean ~ %radio-watch-unauthorized ~] ~])
(pa-sauce ost [[%mean ~ %radio-watch-unauthorized ~] ~])
=. viewers (~(put in viewers) ost)
(pa-sauce [[%rust %radio-report %group present] ~])
(pa-sauce ost [[%rust %radio-report %group present] ~])
::
++ pa-master :: hear config
|= her=ship
?. (pa-admire her)
(pa-sauce [[%mean ~ %radio-master-unauthorized ~] ~])
(pa-sauce ost [[%mean ~ %radio-master-unauthorized ~] ~])
=. owners (~(put in owners) ost)
(pa-sauce [[%rust %radio-report %config shape] ~])
(pa-sauce ost [[%rust %radio-report %config shape] ~])
::
++ pa-display :: update presence
=+ vew=viewers
@ -279,7 +279,7 @@
?~ vew +>
=. +> $(vew l.vew)
=. +> $(vew r.vew)
(pa-sauce(ost n.vew) [[%rust %radio-report %group present] ~])
(pa-sauce n.vew [[%rust %radio-report %group present] ~])
::
::
++ pa-monitor :: update config
@ -289,7 +289,7 @@
=. +> $(owe l.owe)
=. +> $(owe r.owe)
~& [%monitor n.owe]
(pa-sauce(ost n.owe) [[%rust %radio-report %config shape] ~])
(pa-sauce n.owe [[%rust %radio-report %config shape] ~])
::
++ pa-friend :: subscribed update
|= sih=sign
@ -303,14 +303,14 @@
==
::
++ pa-scrub :: pass forward
|= bub=(list (pair path note))
|= [ost=bone bub=(list (pair path note))]
%_ +>.$
moves
(welp (flop (turn bub |=(a=(pair path note) [0 %pass a]))) moves)
(welp (flop (turn bub |=(a=(pair path note) [ost %pass a]))) moves)
==
::
++ pa-sauce :: send backward
|= gub=(list gift)
|= [ost=bone gub=(list gift)]
%_ +>.$
moves
(welp (flop (turn gub |=(a=gift [ost %give a]))) moves)
@ -318,7 +318,8 @@
::
++ pa-abjure :: unsubscribe move
|= tal=(list station)
%- pa-scrub %+ turn tal
%+ pa-scrub 0
%+ turn tal
|= tay=station
?- -.tay
%| !!
@ -328,7 +329,8 @@
::
++ pa-acquire :: subscribe to
|= tal=(list station)
%- pa-scrub %+ turn tal
%+ pa-scrub 0
%+ turn tal
|= tay=station
=+ num=(fall (~(get by sequence) tay) 0)
?- -.tay
@ -352,7 +354,7 @@
^+ .
~& [%pa-cancel ost]
=. guests (~(del in guests) ost)
(pa-sauce [[%mean ~] ~])
(pa-sauce ost [[%mean ~] ~])
::
++ pa-notify :: new presence
|= [her=ship per=presence]
@ -362,9 +364,9 @@
++ pa-start :: start stream
|= riv=river
^+ +>
=- =. +>.$ (pa-sauce [[%rust %radio-report %grams q.lab r.lab] ~])
=- =. +>.$ (pa-sauce ost [[%rust %radio-report %grams q.lab r.lab] ~])
?: p.lab
(pa-sauce [[%mean ~] ~])
(pa-sauce ost [[%mean ~] ~])
+>.$(guests (~(put by guests) ost riv))
^= lab
=+ [end=count gaz=grams dun=| zeg=*(list telegram)]
@ -387,7 +389,7 @@
|= [her=ship pax=path]
^+ +>
?. (pa-admire her)
(pa-sauce [[%mean ~ %radio-listen-unauthorized ~] ~])
(pa-sauce ost [[%mean ~ %radio-listen-unauthorized ~] ~])
=+ ^= ruv ^- (unit river)
?: ?=(~ pax)
`[[%ud count] [%da (dec (bex 128))]]
@ -401,7 +403,7 @@
?. ?=([~ %$ ?(%ud %da) @] den) ~
`[(point +>.say) (point +>.den)]
?~ ruv
(pa-sauce [[%mean ~ %radio-malformed ~] ~])
(pa-sauce ost [[%mean ~ %radio-malformed ~] ~])
(pa-start u.ruv)
::
++ pa-refresh :: update stream
@ -442,6 +444,7 @@
?. (pa-admire p.gam)
~& %pa-admire-rejected
+>.$
=. q.q.gam (~(put by q.q.gam) [%& our.hid man] %received)
=+ old=(~(get by known) p.q.gam)
?~ old
(pa-append gam)