:: btc-wallet-hook.hoon :: :: Subscribes to: :: btc-provider: :: - connection status :: - RPC call results/errors :: :: btc-wallet-store :: - requests for address info :: - updates to existing address info :: :: Sends updates to: :: none :: /- *btc, *btc-wallet-hook, bws=btc-wallet-store, bp=btc-provider /+ dbug, default-agent, bwsl=btc-wallet-store |% +$ versioned-state $% state-0 == :: provdider: maybe ship if provider is set :: +$ state-0 $: %0 provider=(unit [host=ship connected=?]) =btc-state def-wallet=(unit xpub) =pend-addr =pend-txbu =piym =poym =piym-watch =poym-watch == :: +$ card card:agent:gall -- =| state-0 =* state - %- agent:dbug ^- agent:gall =< |_ =bowl:gall +* this . def ~(. (default-agent this %|) bowl) hc ~(. +> bowl) :: ++ on-init ^- (quip card _this) ~& > '%btc-wallet-hook initialized' :_ this :~ [%pass /r/[(scot %da now.bowl)] %agent [our.bowl %btc-wallet-store] %watch /requests] [%pass /u/[(scot %da now.bowl)] %agent [our.bowl %btc-wallet-store] %watch /updates] == ++ on-save ^- vase !>(state) ++ on-load |= old-state=vase ^- (quip card _this) ~& > '%btc-wallet-hook recompiled' `this(state !<(versioned-state old-state)) ++ on-poke |= [=mark =vase] ^- (quip card _this) =^ cards state ?+ mark (on-poke:def mark vase) %btc-wallet-hook-action (handle-action:hc !<(action vase)) == [cards this] :: ++ on-watch on-watch:def ++ on-leave on-leave:def ++ on-peek on-peek:def ++ on-agent |= [=wire =sign:agent:gall] ^- (quip card _this) ?+ -.sign (on-agent:def wire sign) %kick ?~ provider `this ?: ?& ?=(%set-provider -.wire) =(host.u.provider src.bowl) == `this(provider ~) `this :: %fact =^ cards state ?+ p.cage.sign `state %btc-provider-status (handle-provider-status:hc !<(status:bp q.cage.sign)) :: %btc-provider-update (handle-provider-update:hc !<(update:bp q.cage.sign)) :: %btc-wallet-store-request (handle-wallet-store-request:hc !<(request:bws q.cage.sign)) :: %btc-wallet-store-update (handle-wallet-store-update:hc wire !<(update:bws q.cage.sign)) == [cards this] == ++ on-arvo on-arvo:def ++ on-fail on-fail:def -- |_ =bowl:gall ++ handle-action |= act=action ^- (quip card _state) ?- -.act %set-provider =* sub-card [%pass /set-provider %agent [provider.act %btc-provider] %watch /clients] :_ state(provider [~ provider.act %.n]) ?~ provider ~[sub-card] :~ [%pass /set-provider %agent [host.u.provider %btc-provider] %leave ~] sub-card == :: %set-default-wallet =/ xs=(list xpub) scry-scanned ?. (gth (lent xs) 0) `state `state(def-wallet `(snag 0 xs)) :: %req-pay-address :: TODO: add whitelisting here instead of comet block :: can't pay yourself; comets can't pay (could spam requests) :: forwards poke to payee if payee isn't us :: wire is /payer/value/timestamp :: ?< =(src.bowl payee.act) ?< ?=(%pawn (clan:title src.bowl)) :_ state ?. =(payee.act our.bowl) ~[(poke-wallet-hook payee.act act)] ?~ def-wallet ~|("btc-wallet-hook: no def-wallet set" !!) ~[(poke-wallet-store / [%generate-address u.def-wallet %0 `[src.bowl value.act]])] :: %pay-address :: TODO: update poym :: send tx request out for poym :: TODO: ask wallet to generate txbu for poym `state :: %force-retry [(retry pend-addr) state] == :: if status is %connected, retry all pending address lookups :: ++ handle-provider-status |= s=status:bp ^- (quip card _state) ?~ provider `state ?. =(host.u.provider src.bowl) `state ?- -.s %connected :: only retry if previously disconnected :- ?:(connected.u.provider ~ (retry pend-addr)) %= state provider `[host.u.provider %.y] btc-state [blockcount.s fee.s now.bowl] == %disconnected `state(provider `[host.u.provider %.n]) == :: ++ handle-provider-update |= =update:bp ^- (quip card _state) ?. ?=(%& -.update) `state ?- -.body.p.update %address-info =/ ureq (~(get by pend-addr) req-id.p.update) ?~ ureq `state :_ state(pend-addr (~(del by pend-addr) req-id.p.update)) :~ %+ poke-wallet-store / :* %address-info xpub.u.ureq chyg.u.ureq idx.u.ureq utxos.body.p.update used.body.p.update blockcount.body.p.update == == == :: ++ handle-wallet-store-request |= req=request:bws ^- (quip card _state) ?- -.req %scan-address =/ ri=req-id:bp (mk-req-id (hash-xpub:bwsl +>.req)) :_ state(pend-addr (~(put by pend-addr) ri req)) ?~ provider ~ ?: provider-connected ~[(get-address-info ri host.u.provider a.req)] ~& > "provider not connected" ~ == :: ++ handle-wallet-store-update |= [=wire upd=update:bws] ^- (quip card _state) ?- -.upd %generate-address :: TODO if there's meta, add to piym :: moons go in a jar with parent as the key :: this will let me implement moon rate-limiting :: ?~ meta.upd ~& > address.upd `state =/ [payer=ship value=sats] u.meta.upd =/ fam=ship ?: =(%earl (clan:title payer)) (sein:title our.bowl now.bowl payer) payer :- ~[(poke-wallet-hook payer [%pay-address address.upd payer value])] state(piym (~(add ja piym) fam [address.upd payer value])) :: %scan-done ?~ def-wallet `state(def-wallet `xpub.upd) `state == :: ++ retry |= p=^pend-addr ^- (list card) ?~ provider ~|("provider not set" !!) %+ turn ~(tap by p) |= [ri=req-id:bp req=request:bws] (get-address-info ri host.u.provider a.req) :: ++ get-address-info |= [ri=req-id:bp host=ship a=address] ^- card :* %pass /[(scot %da now.bowl)] %agent [host %btc-provider] %poke %btc-provider-action !>([ri %address-info a]) == ++ mk-req-id |= hash=@ux ^- req-id:bp (scot %ux hash) ++ provider-connected ^- ? ?~ provider %.n connected.u.provider :: ++ poke-wallet-hook |= [target=ship act=action] ^- card :* %pass /[(scot %da now.bowl)] %agent [target %btc-wallet-hook] %poke %btc-wallet-hook-action !>(act) == :: ++ poke-wallet-store |= [prefix=wire act=action:bws] ^- card :* %pass (weld prefix /[(scot %da now.bowl)]) %agent [our.bowl %btc-wallet-store] %poke %btc-wallet-store-action !>(act) == :: ++ scry-scanned .^ (list xpub) %gx (scot %p our.bowl) %btc-wallet-store (scot %da now.bowl) %scanned %noun == --