mirror of
https://github.com/ilyakooo0/urbit.git
synced 2024-09-21 15:38:59 +03:00
e5ac690fd3
Also fix bug in eth-watcher that didn't cancel outstanding threads when config changes. And set default rift for ourselves to 0.
40 lines
951 B
Plaintext
40 lines
951 B
Plaintext
/- spider
|
|
/+ *strandio
|
|
=, strand=strand:spider
|
|
^- thread:spider
|
|
|= args=vase
|
|
=/ m (strand ,vase)
|
|
=+ !<(group=(list @tas) args)
|
|
;< =bowl:spider bind:m get-bowl
|
|
=/ threads=(list @tas)
|
|
?- group
|
|
~
|
|
:~ %ph-add
|
|
%ph-hi
|
|
%ph-child-sync
|
|
%ph-breach-multiple
|
|
%ph-breach-sudden
|
|
%ph-breach-hi-cousin
|
|
%ph-hi-linnup-az
|
|
%ph-moon-az
|
|
==
|
|
::
|
|
[%all ~]
|
|
=+ .^(=arch %cy /(scot %p our.bowl)/home/(scot %da now.bowl)/ted/ph)
|
|
%+ turn (turn ~(tap by dir.arch) head)
|
|
|= =term
|
|
(cat 3 'ph-' term)
|
|
::
|
|
*
|
|
(turn group |=(=term (cat 3 'ph-' term)))
|
|
==
|
|
::
|
|
=| results=(list [@tas thread-result])
|
|
|- ^- form:m
|
|
=* loop $
|
|
?~ threads
|
|
(pure:m !>(results))
|
|
;< =thread-result bind:m (await-thread i.threads *vase)
|
|
;< ~ bind:m (flog-text "ph-all: {<i.threads>} complete")
|
|
loop(threads t.threads, results [[i.threads thread-result] results])
|