ilyakooo0/urbit
1
0
Fork 0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-15 01:52:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

arvo: supports both old and new %crud events

Browse Source
This commit is contained in:
Joe Bryan 2020-02-10 21:51:46 -08:00
parent df970ed417
commit 9915e7f645
1 changed files with 38 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
pkg/arvo/sys/arvo.hoon
View File

@ -633,6 +633,20 @@
?> ?=([%$ *] wire.ovum) ?> ?=([%$ *] wire.ovum)
[duct=~ %pass t.wire.ovum vane mill] [duct=~ %pass t.wire.ovum vane mill]
(emit %$ move ~) (emit %$ move ~)
:: +crud: prepare a worklist-of-one with error report from outside
::
++ crud
|= [vane=term =goof =ovum]
^+ this
~? !lac ["" %unix %crud p.card.ovum wire.ovum now]
=/ =mill
=/ =type [%cell [%atom %tas `%soft] %noun]
[%& type [%soft card.ovum]]
=/ =move
~| [%crud %bad-wire wire.ovum]
?> ?=([%$ *] wire.ovum)
[duct=~ %hurl goof t.wire.ovum vane mill]
(emit %$ move ~)
:: +spam: prepare a worklist for all targets :: +spam: prepare a worklist for all targets
:: ::
++ spam ++ spam
@ -1134,6 +1148,30 @@
(turn vanes |=([a=@tas =vane] [a vase.vane *worm])) (turn vanes |=([a=@tas =vane] [a vase.vane *worm]))
[zef +>.$] [zef +>.$]
:: ::
:: Error notifications are unwrapped and routed as usual
::
?: ?=(%crud p.q.ovo)
?. ?=(^ q.q.ovo)
~|([%unknown-crud q.ovo] !!)
::
=^ zef vanes
=* el
~(. le:part [our now eny lac vil (~(gas by *(map term vane)) vanes)])
::
=< abet:loop
?@ -.q.q.ovo
::
:: legacy %crud, directly routed
::
(poke:el (dint:$:is p.ovo) ovo)
::
:: modern %crud, unwrapped and routed w/ $goof
::
=/ =goof ;;(goof -.q.q.ovo)
=/ =curd ;;(curd +.q.q.ovo)
(crud:el (dint:$:is p.ovo) goof p.ovo curd)
::
[zef +>.$]
:: Normal events are routed to a single vane :: Normal events are routed to a single vane
:: ::
=^ zef vanes =^ zef vanes