mirror of
https://github.com/urbit/shrub.git
synced 2024-12-22 10:21:31 +03:00
290 lines
7.7 KiB
Plaintext
290 lines
7.7 KiB
Plaintext
:: ethio: Asynchronous Ethereum input/output functions.
|
|
::
|
|
/- rpc=json-rpc
|
|
/+ ethereum, strandio
|
|
=, ethereum-types
|
|
=, jael
|
|
::
|
|
=> |%
|
|
+$ topics (list ?(@ux (list @ux)))
|
|
--
|
|
|%
|
|
:: +request-rpc: send rpc request, with retry
|
|
::
|
|
++ request-rpc
|
|
|= [url=@ta id=(unit @t) req=request:rpc:ethereum]
|
|
=/ m (strand:strandio ,json)
|
|
^- form:m
|
|
;< res=(list [id=@t =json]) bind:m
|
|
(request-batch-rpc-strict url [id req]~)
|
|
?: ?=([* ~] res)
|
|
(pure:m json.i.res)
|
|
%+ strand-fail:strandio
|
|
%unexpected-multiple-results
|
|
[>(lent res)< ~]
|
|
:: +request-batch-rpc-strict: send rpc requests, with retry
|
|
::
|
|
:: sends a batch request. produces results for all requests in the batch,
|
|
:: but only if all of them are successful.
|
|
::
|
|
++ request-batch-rpc-strict
|
|
|= [url=@ta reqs=(list [id=(unit @t) req=request:rpc:ethereum])]
|
|
|^ %+ (retry:strandio results)
|
|
`10
|
|
attempt-request
|
|
::
|
|
+$ results (list [id=@t =json])
|
|
::
|
|
++ attempt-request
|
|
=/ m (strand:strandio ,(unit results))
|
|
^- form:m
|
|
;< responses=(list response:rpc) bind:m
|
|
(request-batch-rpc-loose url reqs)
|
|
=- ?~ err
|
|
(pure:m `res)
|
|
(pure:m ~)
|
|
%+ roll responses
|
|
|= $: rpc=response:rpc
|
|
[res=results err=(list [id=@t code=@t message=@t])]
|
|
==
|
|
?: ?=(%error -.rpc)
|
|
[res [+.rpc err]]
|
|
?. ?=(%result -.rpc)
|
|
[res [['' 'ethio-rpc-fail' (crip <rpc>)] err]]
|
|
[[+.rpc res] err]
|
|
--
|
|
:: +request-batch-rpc-loose: send rpc requests, with retry
|
|
::
|
|
:: sends a batch request. produces results for all requests in the batch,
|
|
:: including the ones that are unsuccessful.
|
|
::
|
|
++ request-batch-rpc-loose
|
|
|= [url=@ta reqs=(list [id=(unit @t) req=request:rpc:ethereum])]
|
|
|^ %+ (retry:strandio results)
|
|
`10
|
|
attempt-request
|
|
::
|
|
+$ result response:rpc
|
|
+$ results (list response:rpc)
|
|
::
|
|
++ attempt-request
|
|
=/ m (strand:strandio ,(unit results))
|
|
^- form:m
|
|
=/ =request:http
|
|
:* method=%'POST'
|
|
url=url
|
|
header-list=['Content-Type'^'application/json' ~]
|
|
::
|
|
^= body
|
|
%- some %- as-octs:mimes:html
|
|
%- en:json:html
|
|
a+(turn reqs request-to-json:rpc:ethereum)
|
|
==
|
|
;< ~ bind:m
|
|
(send-request:strandio request)
|
|
;< rep=(unit client-response:iris) bind:m
|
|
take-maybe-response:strandio
|
|
?~ rep
|
|
(pure:m ~)
|
|
(parse-responses u.rep)
|
|
::
|
|
++ parse-responses
|
|
|= =client-response:iris
|
|
=/ m (strand:strandio ,(unit results))
|
|
^- form:m
|
|
?> ?=(%finished -.client-response)
|
|
?~ full-file.client-response
|
|
(pure:m ~)
|
|
=/ body=@t q.data.u.full-file.client-response
|
|
=/ jon=(unit json) (de:json:html body)
|
|
?~ jon
|
|
(pure:m ~)
|
|
=/ array=(unit (list response:rpc))
|
|
((ar:dejs-soft:format parse-one-response) u.jon)
|
|
?~ array
|
|
(strand-fail:strandio %rpc-result-incomplete-batch >u.jon< ~)
|
|
(pure:m array)
|
|
::
|
|
++ parse-one-response
|
|
|= =json
|
|
^- (unit response:rpc)
|
|
?. &(?=([%o *] json) (~(has by p.json) 'error'))
|
|
=/ res=(unit [@t ^json])
|
|
%. json
|
|
=, dejs-soft:format
|
|
(ot id+so result+some ~)
|
|
?~ res ~
|
|
`[%result u.res]
|
|
~| parse-one-response=json
|
|
=/ error=(unit [id=@t ^json code=@ta mssg=@t])
|
|
%. json
|
|
=, dejs-soft:format
|
|
:: A 'result' member is present in the error
|
|
:: response when using ganache, even though
|
|
:: that goes against the JSON-RPC spec
|
|
::
|
|
(ot id+so result+some error+(ot code+no message+so ~) ~)
|
|
?~ error ~
|
|
=* err u.error
|
|
`[%error id.err code.err mssg.err]
|
|
--
|
|
::
|
|
:: +read-contract: calls a read function on a contract, produces result hex
|
|
::
|
|
++ read-contract
|
|
|= [url=@t req=proto-read-request:rpc:ethereum]
|
|
=/ m (strand:strandio ,@t)
|
|
;< res=(list [id=@t res=@t]) bind:m
|
|
(batch-read-contract-strict url [req]~)
|
|
?: ?=([* ~] res)
|
|
(pure:m res.i.res)
|
|
%+ strand-fail:strandio
|
|
%unexpected-multiple-results
|
|
[>(lent res)< ~]
|
|
:: +batch-read-contract-strict: calls read functions on contracts
|
|
::
|
|
:: sends a batch request. produces results for all requests in the batch,
|
|
:: but only if all of them are successful.
|
|
::
|
|
++ batch-read-contract-strict
|
|
|= [url=@t reqs=(list proto-read-request:rpc:ethereum)]
|
|
|^ =/ m (strand:strandio ,results)
|
|
^- form:m
|
|
;< res=(list [id=@t =json]) bind:m
|
|
%+ request-batch-rpc-strict url
|
|
(turn reqs proto-to-rpc)
|
|
=+ ^- [=results =failures]
|
|
(roll res response-to-result)
|
|
?~ failures (pure:m results)
|
|
(strand-fail:strandio %batch-read-failed-for >failures< ~)
|
|
::
|
|
+$ results (list [id=@t res=@t])
|
|
+$ failures (list [id=@t =json])
|
|
::
|
|
++ proto-to-rpc
|
|
|= proto-read-request:rpc:ethereum
|
|
^- [(unit @t) request:rpc:ethereum]
|
|
:- id
|
|
:+ %eth-call
|
|
^- call:rpc:ethereum
|
|
[~ to ~ ~ ~ `tape`(encode-call:rpc:ethereum function arguments)]
|
|
[%label %latest]
|
|
::
|
|
++ response-to-result
|
|
|= [[id=@t =json] =results =failures]
|
|
^+ [results failures]
|
|
?: ?=(%s -.json)
|
|
[[id^p.json results] failures]
|
|
[results [id^json failures]]
|
|
--
|
|
::
|
|
::
|
|
++ get-latest-block
|
|
|= url=@ta
|
|
=/ m (strand:strandio ,block)
|
|
^- form:m
|
|
;< =json bind:m
|
|
(request-rpc url `'block number' %eth-block-number ~)
|
|
(get-block-by-number url (parse-eth-block-number:rpc:ethereum json))
|
|
::
|
|
++ get-block-by-number
|
|
|= [url=@ta =number:block]
|
|
=/ m (strand:strandio ,block)
|
|
^- form:m
|
|
|^
|
|
%+ (retry:strandio ,block) `10
|
|
=/ m (strand:strandio ,(unit block))
|
|
^- form:m
|
|
;< =json bind:m
|
|
%+ request-rpc url
|
|
:- `'block by number'
|
|
[%eth-get-block-by-number number |]
|
|
(pure:m (parse-block json))
|
|
::
|
|
++ parse-block
|
|
|= =json
|
|
^- (unit block)
|
|
=< ?~(. ~ `[[&1 &2] |2]:u)
|
|
^- (unit [@ @ @])
|
|
~| json
|
|
%. json
|
|
=, dejs-soft:format
|
|
%- ot
|
|
:~ hash+parse-hex
|
|
number+parse-hex
|
|
'parentHash'^parse-hex
|
|
==
|
|
::
|
|
++ parse-hex |=(=json `(unit @)`(some (parse-hex-result:rpc:ethereum json)))
|
|
--
|
|
::
|
|
++ get-tx-by-hash
|
|
|= [url=@ta tx-hash=@ux]
|
|
=/ m (strand:strandio transaction-result:rpc:ethereum)
|
|
^- form:m
|
|
;< =json bind:m
|
|
%+ request-rpc url
|
|
:* `'tx by hash'
|
|
%eth-get-transaction-by-hash
|
|
tx-hash
|
|
==
|
|
%- pure:m
|
|
(parse-transaction-result:rpc:ethereum json)
|
|
::
|
|
++ get-logs-by-hash
|
|
|= [url=@ta =hash:block contracts=(list address) =topics]
|
|
=/ m (strand:strandio (list event-log:rpc:ethereum))
|
|
^- form:m
|
|
;< =json bind:m
|
|
%+ request-rpc url
|
|
:* `'logs by hash'
|
|
%eth-get-logs-by-hash
|
|
hash
|
|
contracts
|
|
topics
|
|
==
|
|
%- pure:m
|
|
(parse-event-logs:rpc:ethereum json)
|
|
::
|
|
++ get-logs-by-range
|
|
|= $: url=@ta
|
|
contracts=(list address)
|
|
=topics
|
|
=from=number:block
|
|
=to=number:block
|
|
==
|
|
=/ m (strand:strandio (list event-log:rpc:ethereum))
|
|
^- form:m
|
|
;< =json bind:m
|
|
%+ request-rpc url
|
|
:* `'logs by range'
|
|
%eth-get-logs
|
|
`number+from-number
|
|
`number+to-number
|
|
contracts
|
|
topics
|
|
==
|
|
%- pure:m
|
|
(parse-event-logs:rpc:ethereum json)
|
|
::
|
|
++ get-next-nonce
|
|
|= [url=@ta =address]
|
|
=/ m (strand:strandio ,@ud)
|
|
^- form:m
|
|
;< =json bind:m
|
|
%^ request-rpc url `'nonce'
|
|
[%eth-get-transaction-count address [%label %latest]]
|
|
%- pure:m
|
|
(parse-eth-get-transaction-count:rpc:ethereum json)
|
|
::
|
|
++ get-balance
|
|
|= [url=@ta =address]
|
|
=/ m (strand:strandio ,@ud)
|
|
^- form:m
|
|
;< =json bind:m
|
|
%^ request-rpc url `'balance'
|
|
[%eth-get-balance address [%label %latest]]
|
|
%- pure:m
|
|
(parse-eth-get-balance:rpc:ethereum json)
|
|
--
|