:: btc-provider.hoon :: Proxy that serves a BTC full node and ElectRS address indexer :: :: Subscriptions: none :: To Subscribers: /clients :: current connection state :: results/errors of RPC calls :: :: Scrys :: x/is-whitelisted/SHIP: bool, whether ship is whitelisted :: /- *bitcoin, json-rpc, *btc-provider /+ dbug, default-agent, bl=btc, groupl=group, resource ~% %btc-provider-top ..part ~ |% +$ card card:agent:gall +$ versioned-state $% state-0 == :: +$ state-0 [%0 =host-info =whitelist] -- %- agent:dbug =| state-0 =* state - ^- agent:gall =< ~% %btc-provider-agent ..send-status ~ |_ =bowl:gall +* this . def ~(. (default-agent this %|) bowl) hc ~(. +> bowl) :: ++ on-init ^- (quip card _this) ~& > '%btc-provider initialized successfully' =| wl=^whitelist :- ~ %_ this host-info ['' connected=%.n %main block=0 clients=*(set ship)] whitelist wl(public %.n, kids %.n) == :: ++ on-save ^- vase !>(state) :: ++ on-load |= old-state=vase ^- (quip card _this) ~& > '%btc-provider recompiled successfully ' `this(state !<(versioned-state old-state)) :: ++ on-poke ~/ %on-poke |= [=mark =vase] ^- (quip card _this) |^ ?> ?|((team:title our.bowl src.bowl) (is-client:hc src.bowl)) =^ cards state ?+ mark (on-poke:def mark vase) %btc-provider-command ?> (team:title our.bowl src.bowl) (handle-command !<(command vase)) :: %btc-provider-action (handle-action !<(action vase)) == [cards this] :: ++ handle-command |= comm=command ^- (quip card _state) ?- -.comm %set-credentials :_ state(host-info [api-url.comm %.n network.comm 0 *(set ship)]) ~[(start-ping-timer:hc ~s30)] :: %add-whitelist :- ~ ?- -.wt.comm %public state(public.whitelist %.y) :: %kids state(kids.whitelist %.y) :: %users state(users.whitelist (~(uni in users.whitelist) users.wt.comm)) :: %groups state(groups.whitelist (~(uni in groups.whitelist) groups.wt.comm)) == :: %remove-whitelist =. state ?- -.wt.comm %public state(public.whitelist %.n) :: %kids state(kids.whitelist %.n) :: %users state(users.whitelist (~(dif in users.whitelist) users.wt.comm)) :: %groups state(groups.whitelist (~(dif in groups.whitelist) groups.wt.comm)) == clean-client-list == :: :: +clean-client-list: remove clients who are no longer whitelisted :: called after a whitelist change :: ++ clean-client-list ^- (quip card _state) =/ to-kick=(set ship) %- silt %+ murn ~(tap in clients.host-info) |= c=ship ^- (unit ship) ?:((is-whitelisted:hc c) ~ `c) :_ state(clients.host-info (~(dif in clients.host-info) to-kick)) %+ turn ~(tap in to-kick) |=(c=ship [%give %kick ~[/clients] `c]) :: :: if not connected, only %ping action is allowed :: ++ handle-action |= act=action ^- (quip card _state) :_ state ?. ?|(connected.host-info ?=(%ping -.act)) ~& >>> "Not connected to RPC" ~[(send-update:hc [%| %not-connected 500])] :_ ~ %+ req-card act ^- action:rpc-types ?- -.act %address-info [%get-address-info address.act] %tx-info [%get-tx-vals txid.act] %raw-tx [%get-raw-tx txid.act] %broadcast-tx [%broadcast-tx rawtx.act] %ping [%get-block-info ~] %block-info [%get-block-info block.act] == :: ++ req-card |= [act=action ract=action:rpc-types] =/ req=request:http (gen-request:bl host-info ract) [%pass (rpc-wire act) %arvo %i %request req *outbound-config:iris] :: ++ rpc-wire |= act=action ^- wire /[-.act]/[(scot %ux (cut 3 [0 20] eny.bowl))] -- :: ++ on-watch ~/ %on-watch |= pax=path ^- (quip card _this) :: checking provider permissions before trying to subscribe :: terrible hack until we have cross-ship scries :: ?: ?=([%permitted @ ~] pax) :_ this =/ jon=json %+ frond:enjs:format %'providerStatus' %- pairs:enjs:format :~ provider+s+(scot %p our.bowl) permitted+b+(is-whitelisted:hc src.bowl) == [%give %fact ~ %json !>(jon)]~ :: ?> ?=([%clients *] pax) ?. (is-whitelisted:hc src.bowl) ~|("btc-provider: blocked client {}" !!) ~& > "btc-provider: accepted client {}" `this(clients.host-info (~(put in clients.host-info) src.bowl)) :: ++ on-arvo ~/ %on-arvo |= [wir=wire =sign-arvo] |^ ^- (quip card _this) :: check for connectivity every 30 seconds :: ?: ?=([%ping-timer *] wir) :_ this :~ do-ping (start-ping-timer:hc ~s30) == =^ cards state ?+ +<.sign-arvo (on-arvo:def wir sign-arvo) %http-response (handle-rpc-response wir client-response.sign-arvo) == [cards this] :: ++ do-ping ^- card =/ act=action [%ping ~] :* %pass /ping/[(scot %da now.bowl)] %agent [our.bowl %btc-provider] %poke %btc-provider-action !>(act) == :: :: Handles HTTP responses from RPC servers. Parses for errors, :: then handles response. For actions that require collating multiple :: RPC calls, uses req-card to call out to RPC again if more :: information is required. ++ handle-rpc-response |= [=wire response=client-response:iris] ^- (quip card _state) ?. ?=(%finished -.response) `state =* status status-code.response-header.response :: handle error types: connection errors, RPC errors (in order) :: =^ conn-err state (connection-error status) ?^ conn-err :_ state(connected.host-info %.n) :~ (send-status:hc [%disconnected ~]) (send-update:hc [%| u.conn-err]) == :: %+ handle-rpc-result wire %- parse-result:rpc:bl (get-rpc-response:bl response) :: ++ handle-rpc-result |= [=wire r=result:rpc-types] ^- (quip card _state) ?+ -.wire ~|("Unexpected HTTP response" !!) %address-info ?> ?=([%get-address-info *] r) :_ state ~[(send-update:hc [%.y %address-info +.r])] :: %tx-info ?> ?=([%get-tx-vals *] r) :_ state ~[(send-update:hc [%.y %tx-info +.r])] :: %raw-tx ?> ?=([%get-raw-tx *] r) :_ state ~[(send-update:hc [%.y %raw-tx +.r])] :: %broadcast-tx ?> ?=([%broadcast-tx *] r) :_ state ~[(send-update:hc [%.y %broadcast-tx +.r])] :: %ping ?> ?=([%get-block-info *] r) :_ state(connected.host-info %.y, block.host-info block.r) :_ ~ %- send-status:hc ?: =(block.host-info block.r) [%connected network.host-info block.r fee.r] [%new-block network.host-info block.r fee.r blockhash.r blockfilter.r] :: %block-info ?> ?=([%get-block-info *] r) :_ state ~[(send-update:hc [%.y %block-info network.host-info +.r])] == :: ++ connection-error |= status=@ud ^- [(unit error) _state] ?+ status [`[%rpc-error ~] state] %200 [~ state] %400 [`[%bad-request status] state] %401 [`[%no-auth status] state(connected.host-info %.n)] %502 [`[%not-connected status] state(connected.host-info %.n)] %504 [`[%not-connected status] state(connected.host-info %.n)] == -- :: ++ on-peek ~/ %on-peek |= pax=path ^- (unit (unit cage)) ?+ pax (on-peek:def pax) [%x %is-whitelisted @t ~] ``noun+!>((is-whitelisted:hc (ship (slav %p +>-.pax)))) :: [%x %is-client @t ~] ``noun+!>((is-client:hc (ship (slav %p +>-.pax)))) == :: ++ on-leave on-leave:def ++ on-agent on-agent:def ++ on-fail on-fail:def -- :: helper core ~% %btc-provider-helper ..card ~ |_ =bowl:gall ++ send-status |= =status ^- card %- ?: ?=(%new-block -.status) ~&(>> "%new-block: {}" same) same [%give %fact ~[/clients] %btc-provider-status !>(status)] :: ++ send-update |= =update ^- card =+ c=[%give %fact ~[/clients] %btc-provider-update !>(update)] ?: ?=(%.y -.update) c ~& >> "prov. err: {}" c :: ++ is-whitelisted ~/ %is-whitelisted |= user=ship ^- ? |^ ?| public.whitelist =(our.bowl user) ?&(kids.whitelist is-kid) (~(has in users.whitelist) user) in-group == :: ++ is-kid =(our.bowl (sein:title our.bowl now.bowl user)) :: ++ in-group =/ gs ~(tap in groups.whitelist) |- ?~ gs %.n ?: (~(is-member groupl bowl) user i.gs) %.y $(gs t.gs) -- :: ++ is-client |= user=ship ^- ? (~(has in clients.host-info) user) :: ++ start-ping-timer |= interval=@dr ^- card [%pass /ping-timer %arvo %b %wait (add now.bowl interval)] --