urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2025-01-03 01:54:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

eth-watcher: move types into /sur file

Browse Source
This commit is contained in:
Fang 2019-10-29 20:51:58 +01:00
parent 4e9ece6cea
commit 277f2955c3
No known key found for this signature in database
GPG Key ID: EB035760C1BBA972
2 changed files with 49 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
pkg/arvo/app/eth-watcher.hoon
View File

@ -1,3 +1,6 @@
:: eth-watcher: ethereum event log collector
::
/- *eth-watcher
/+ tapp, stdio
=, ethereum-types
=, able:jael
@ -7,6 +10,7 @@
dogs=(map path watchdog)
==
::
+$ context [=path dog=watchdog]
+$ watchdog
$: config
=number:block
@ -14,45 +18,20 @@
blocks=(list block)
==
::
+$ config
$: url=@ta
from-block=@ud
to-block=(unit @ud) ::TODO use or remove
contracts=(list address:ethereum)
=topics
==
::
+$ pending-logs (map number:block loglist)
+$ loglist (list event-log:rpc:ethereum)
::
+$ topics (list ?(@ux (list @ux)))
::
+$ context [=path dog=watchdog]
::
+$ peek-data
[%atom =next-block=number:block]
+$ in-poke-data
$: %eth-watcher-poke
$% [%watch =path =config]
[%clear =path]
== ==
poke
==
+$ out-poke-data ~
+$ in-peer-data ~
+$ out-peer-data
$: %eth-watcher-diff
$% :: %history: full event log history
::
[%history =loglist]
:: %log: newly added log
::
[%log =event-log:rpc:ethereum]
:: %disavow: forget logs
::
:: this is sent when a reorg happens that invalidates
:: previously-sent logs
::
[%disavow =id:block]
== ==
diff
==
++ tapp
%: ^tapp
app-state
@ -246,11 +225,11 @@
loop(loglist t.loglist)
::
++ send-update
|= [=path out=_+:*out-peer-data]
|= [=path =diff]
=/ m (async:stdio ,~)
^- form:m
=. path [%logs path]
(give-result:stdio path %eth-watcher-diff out)
(give-result:stdio path %eth-watcher-diff diff)
--
::
:: Main loop
@ -266,7 +245,7 @@
%+ get-updates path
%_ dog
- config
number from-block.config
number from.config
==
::
:: Get updates since last checked

38
pkg/arvo/sur/eth-watcher.hoon Normal file
View File

@ -0,0 +1,38 @@
:: eth-watcher: ethereum event log collector
::
=, able:jael
|%
+$ config
$: url=@ta
from=number:block
contracts=(list address:ethereum)
=topics
==
::
+$ loglist (list event-log:rpc:ethereum)
+$ topics (list ?(@ux (list @ux)))
::
+$ poke
$% :: %watch: configure a watchdog and fetch initial logs
::
[%watch =path =config]
:: %clear: remove a watchdog
::
[%clear =path]
==
::
+$ diff
$% :: %history: full event log history
::
[%history =loglist]
:: %log: newly added log
::
[%log =event-log:rpc:ethereum]
:: %disavow: forget logs
::
:: this is sent when a reorg happens that invalidates
:: previously-sent logs
::
[%disavow =id:block]
==
--