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

naive: hook up subscription to azimuth for %tx diffs

Browse Source
This commit is contained in:
yosoyubik 2021-05-23 15:49:55 +02:00
parent 001d58e539
commit 47813a189a
1 changed files with 72 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
pkg/arvo/app/aggregator.hoon
View File

@ -17,8 +17,6 @@
:: on %tx diff from naive, remove the matching tx from the frozen group.
::
::TODO remaining general work:
:: - hook up subscription to azimuth for %tx diffs
:: - hook up thread updates/results
:: - hook up timer callbacks
:: - cache state, upate after every azimuth %fact
:: - properly support private key changes
@ -62,6 +60,7 @@
[%setkey pk=@]
[%endpoint endpoint=@t]
[%nonce nonce=@ud]
[%subs ~]
::TODO contract address, chain..?
==
::
@ -95,7 +94,8 @@
^- (quip card _this)
::TODO set default frequency and endpoint?
=. frequency ~h1
[~ this]
:_ this
[%pass /azimuth %agent [our.bowl %azimuth] %watch /(scot %p our.bowl)]~
::
++ on-save !>(state)
++ on-load
@ -196,8 +196,16 @@
|= [=wire =sign:agent:gall]
^- (quip card _this)
~& wire+wire
?. ?=([%send @t *] wire)
|^
?: ?=([%send @t *] wire)
(process-thread i.t.wire sign)
?. =(%azimuth -.wire)
(on-agent:def wire sign)
(process-azimuth-update wire sign)
::
++ process-thread
|= [nonce=@t =sign:agent:gall]
^- (quip card _this)
?- -.sign
%poke-ack
?~ p.sign
@ -223,18 +231,38 @@
=+ !<([=term =tang] q.cage.sign)
%- (slog leaf+"{(trip dap.bowl)} failed" leaf+<term> tang)
=^ cards state
(on-thread-result:do (rash i.t.wire dem) %.n^'thread failed')
(on-thread-result:do (rash nonce dem) %.n^'thread failed')
[cards this]
::
%thread-done
~& ['all submitted to' t.wire]
:: is aggregator/send thread expected to maybe return an error?
=+ !<(result=(each @ud @t) q.cage.sign)
=^ cards state
(on-thread-result:do (rash i.t.wire dem) result)
(on-thread-result:do (rash nonce dem) result)
[cards this]
==
==
:: TODO: not tested
::
++ process-azimuth-update
|= [=^wire =sign:agent:gall]
^- (quip card _this)
?+ -.sign [~ this]
%watch-ack
?~ p.sign [~ this]
=/ =tank leaf+"{(trip dap.bowl)} couldn't start listen to %azimuth"
%- (slog tank u.p.sign)
[~ this]
::
%fact
?+ p.cage.sign (on-agent:def wire sign)
%azimuth-udiffs
=+ !<(=diff:naive q.cage.sign)
=^ cards state
(on-naive-diff:do diff)
[cards this]
==
==
--
--
::
|_ =bowl:gall
@ -256,8 +284,9 @@
|= [=wire thread=term arg=vase]
^- (list card)
=/ tid=@ta (rap 3 thread '--' (scot %uv eny.bowl) ~)
=/ args [~ `tid thread arg]
:~ [%pass wire %agent [our.bowl %spider] %watch /thread-result/[tid]]
[%pass wire %agent [our.bowl %spider] %poke %spider-start !>([~ `tid thread arg])]
[%pass wire %agent [our.bowl %spider] %poke %spider-start !>(args)]
==
::
++ leave
@ -339,6 +368,10 @@
%config [~ state(frequency frequency.action)]
%nonce [~ state(next-nonce nonce.action)]
%endpoint [~ state(endpoint endpoint.action)]
::
%subs
:_ state
[%pass /azimuth %agent [our.bowl %azimuth] %watch /(scot %p our.bowl)]~
::
%setkey
::TODO what about existing sending entries?