/- sur=btc-provider, json-rpc /+ *btc ^? =< [sur .] =, sur |% ++ address-to-cord |= =address ^- cord ?: ?=([%base58 *] address) (scot %uc +.address) +.address :: ++ address-from-cord |= addrc=@t ^- address ?. ?| =("bc1" (scag 3 (trip addrc))) =("tb1" (scag 3 (trip addrc))) == ~|("base58 addresses not yet supported" !!) [%bech32 addrc] :: ++ bytc-to-cord |= =bytc ^- cord (en:base16:mimes:html bytc) :: ++ txid-to-cord |= =txid ^- cord (en:base16:mimes:html txid) :: +from-epoch: time since Jan 1, 1970 in seconds. :: ++ from-epoch |= secs=@ud ^- (unit @da) ?: =(0 secs) ~ [~ (add ~1970.1.1 `@dr`(mul secs ~s1))] :: ++ to-hex |= h=@t ^- @ux ?: =('' h) 0x0 :: Add leading 00 :: =+ (lsh [3 2] h) :: Group by 4-size block :: =+ (rsh [3 2] -) :: Parse hex to atom :: `@ux`(rash - hex) :: ++ to-rawtx |= h=@t ^- rawtx =+ bs=(to-hex h) [(div (lent (trip h)) 2) bs] ++ to-hash256 |= h=@t (hash256 [32 (to-hex h)]) :: ++ to-bytc |= h=@t ^- bytc :- (div (lent (trip h)) 2) (to-hex h) :: ++ get-request |= url=@t ^- request:http [%'GET' url ~ ~] :: ++ post-request |= [url=@t body=json] ^- request:http :* %'POST' url ~[['Content-Type' 'application/json']] =, html %- some %- as-octt:mimes (en-json body) == :: ++ gen-request |= [=host-info ract=action:rpc-types] ^- request:http %+ rpc-action-to-http api-url.host-info ract :: ++ rpc |% ++ parse-result |= res=response:json-rpc |^ ^- result:rpc-types ~| -.res ?> ?=(%result -.res) ?+ id.res ~|([%unsupported-result id.res] !!) %get-address-info [id.res (address-info res.res)] :: %get-tx-vals [id.res (tx-vals res.res)] :: %get-raw-tx [id.res (raw-tx res.res)] :: %broadcast-tx [%broadcast-tx (broadcast-tx res.res)] :: %get-block-count [id.res (ni:dejs:format res.res)] :: %get-block-info [id.res (block-info res.res)] == ++ address-info %- ot:dejs:format :~ [%address (cu:dejs:format address-from-cord so:dejs:format)] [%utxos (as:dejs:format utxo)] [%used bo:dejs:format] [%block ni:dejs:format] == ++ utxo %- ot:dejs:format :~ ['tx_pos' ni:dejs:format] ['tx_hash' (cu:dejs:format to-hash256 so:dejs:format)] [%height ni:dejs:format] [%value ni:dejs:format] [%recvd (cu:dejs:format from-epoch ni:dejs:format)] == ++ tx-vals %- ot:dejs:format :~ [%included bo:dejs:format] [%txid (cu:dejs:format to-hash256 so:dejs:format)] [%confs ni:dejs:format] [%recvd (cu:dejs:format from-epoch ni:dejs:format)] [%inputs (ar:dejs:format tx-val)] [%outputs (ar:dejs:format tx-val)] == ++ tx-val %- ot:dejs:format :~ [%txid (cu:dejs:format to-hash256 so:dejs:format)] [%pos ni:dejs:format] [%address (cu:dejs:format address-from-cord so:dejs:format)] [%value ni:dejs:format] == ++ raw-tx %- ot:dejs:format :~ [%txid (cu:dejs:format to-hash256 so:dejs:format)] [%rawtx (cu:dejs:format to-bytc so:dejs:format)] == ++ broadcast-tx %- ot:dejs:format :~ [%txid (cu:dejs:format to-hash256 so:dejs:format)] [%broadcast bo:dejs:format] [%included bo:dejs:format] == ++ block-info %- ot:dejs:format :~ [%block ni:dejs:format] [%fee ni:dejs:format] [%blockhash (cu:dejs:format to-bytc so:dejs:format)] [%blockfilter (cu:dejs:format to-bytc so:dejs:format)] == -- -- :: ++ rpc-action-to-http |= [endpoint=@t ract=action:rpc-types] |^ ^- request:http ?- -.ract %get-address-info %- get-request %+ mk-url '/addresses/info/' (address-to-cord address.ract) :: %get-tx-vals %- get-request %+ mk-url '/gettxvals/' (txid-to-cord txid.ract) :: %get-raw-tx %- get-request %+ mk-url '/getrawtx/' (txid-to-cord txid.ract) :: %broadcast-tx %- get-request %+ mk-url '/broadcasttx/' (bytc-to-cord rawtx.ract) :: %get-block-count %- get-request (mk-url '/getblockcount' '') :: %get-block-info %- get-request (mk-url '/getblockinfo' '') == ++ mk-url |= [base=@t params=@t] %^ cat 3 (cat 3 endpoint base) params -- :: RPC/HTTP Utilities :: ++ httr-to-rpc-response |= hit=httr:eyre ^- response:json-rpc ~| hit =/ jon=json (need (de-json:html q:(need r.hit))) ?. =(%2 (div p.hit 100)) (parse-rpc-error jon) =, dejs-soft:format ^- response:json-rpc =; dere =+ res=((ar dere) jon) ?~ res (need (dere jon)) [%batch u.res] |= jon=json ^- (unit response:json-rpc) =/ res=[id=(unit @t) res=(unit json) err=(unit json)] %. jon =, dejs:format =- (ou -) :~ ['id' (uf ~ (mu so))] ['result' (uf ~ (mu same))] ['error' (uf ~ (mu same))] == ?: ?=([^ * ~] res) `[%result [u.id.res ?~(res.res ~ u.res.res)]] ~| jon `(parse-rpc-error jon) :: ++ get-rpc-response |= response=client-response:iris ^- response:json-rpc ?> ?=(%finished -.response) %- httr-to-rpc-response %+ to-httr:iris response-header.response full-file.response :: ++ parse-rpc-error |= =json ^- response:json-rpc :- %error ?~ json ['' '' ''] %. json =, dejs:format =- (ou -) :~ =- ['id' (uf '' (cu - (mu so)))] |*(a=(unit) ?~(a '' u.a)) :- 'error' =- (uf ['' ''] -) =- (cu |*(a=(unit) ?~(a ['' ''] u.a)) (mu (ou -))) :~ ['code' (uf '' no)] ['message' (uf '' so)] == == --