:: Standard input/input functions. :: :: These are all asynchronous computations, which means they produce a :: form:(trad A) for some type A. You can always tell what they :: produce by checking their first three lines. :: :: Functions with the word "raw" in their name are for internal use :: only because they carry a high salmonella risk. More specifcally, :: improper use of them may result in side effects that the tapp :: runtime doesn't know about and can't undo in case the transaction :: fails. :: /- tapp-sur=tapp /+ trad |* poke-data=mold =/ tapp-sur (tapp-sur poke-data) =, card=card:tapp-sur =, sign=sign:tapp-sur =, contract=contract:tapp-sur =+ (trad sign card contract) |% :: :: Raw power :: ++ send-raw-card |= =card =/ m (trad ,~) ^- form:m |= trad-input [[/ card]~ ~ ~ %done ~] :: :: Add or remove a contract :: ++ set-raw-contract |= [add=? =contract] =/ m (trad ,~) ^- form:m |= trad-input [~ ~ (silt [add contract]~) %done ~] :: :: Send effect :: ++ send-effect |= =card =/ m (trad ,~) ^- form:m |= trad-input [~ [card]~ ~ %done ~] :: :: ---- :: :: HTTP requests :: ++ send-hiss |= =hiss:eyre =/ m (trad ,~) ^- form:m ;< ~ bind:m (send-raw-card %hiss / ~ %httr %hiss hiss) (set-raw-contract & %hiss ~) :: :: Wait until we get an HTTP response :: ++ take-sigh-raw =/ m (trad ,httr:eyre) ^- form:m |= =trad-input :^ ~ ~ ~ ?~ in.trad-input [%wait ~] ?. ?=(%sigh -.sign.u.in.trad-input) [%fail %expected-sigh >got=-.sign.u.in.trad-input< ~] [%done httr.sign.u.in.trad-input] :: :: Wait until we get an HTTP response and unset contract :: ++ take-sigh =/ m (trad ,httr:eyre) ^- form:m ;< =httr:eyre bind:m take-sigh-raw ;< ~ bind:m (set-raw-contract | %hiss ~) (pure:m httr) :: :: Extract body from raw httr :: ++ extract-httr-body |= =httr:eyre =/ m (trad ,cord) ^- form:m ?. =(2 (div p.httr 100)) (trad-fail %httr-error >p.httr< >+.httr< ~) ?~ r.httr (trad-fail %expected-httr-body >httr< ~) (pure:m q.u.r.httr) :: :: Parse cord to json :: ++ parse-json |= =cord =/ m (trad ,json) ^- form:m =/ json=(unit json) (de-json:html cord) ?~ json (trad-fail %json-parse-error ~) (pure:m u.json) :: :: Fetch json at given url :: ++ fetch-json |= url=tape =/ m (trad ,json) ^- form:m =/ =hiss:eyre :* purl=(scan url auri:de-purl:html) meth=%get math=~ body=~ == ;< ~ bind:m (send-hiss hiss) ;< =httr:eyre bind:m take-sigh ;< =cord bind:m (extract-httr-body httr) (parse-json cord) :: :: ---- :: :: Time is what keeps everything from happening at once :: ++ get-time =/ m (trad ,@da) ^- form:m |= =trad-input [~ ~ ~ %done now.bowl.trad-input] :: :: Set a timer :: ++ send-wait |= at=@da =/ m (trad ,~) ^- form:m ;< ~ bind:m (send-raw-card %wait /(scot %da at) at) (set-raw-contract & %wait at) :: :: Wait until we get a wake event :: ++ take-wake-raw =/ m (trad ,@da) ^- form:m |= =trad-input :^ ~ ~ ~ ?~ in.trad-input [%wait ~] ?. ?=(%wake -.sign.u.in.trad-input) [%fail %expected-wake >got=-.sign.u.in.trad-input< ~] ?~ wire.u.in.trad-input [%fail %expected-wake-time ~] =/ at=(unit @da) (slaw %da i.wire.u.in.trad-input) ?~ at [%fail %expected-wake-time-da >wire< ~] [%done u.at] :: :: Wait until we get a wake event and unset contract :: ++ take-wake =/ m (trad ,~) ^- form:m ;< at=@da bind:m take-wake-raw (set-raw-contract | %wait at) :: :: Wait until time :: ++ wait |= until=@da =/ m (trad ,~) ^- form:m ;< ~ bind:m (send-wait until) take-wake :: :: Cancel computation if not done by time :: ++ set-timeout |* computation-result=mold =/ m (trad ,computation-result) |= [when=@da computation=form:m] ^- form:m ;< ~ bind:m (send-wait when) |= =trad-input =* loop $ ?: ?& ?=([~ * %wake *] in.trad-input) =(/(scot %da when) wire.u.in.trad-input) == [~ ~ (silt [| %wait when]~) %fail %trad-timeout ~] =/ c-res (computation trad-input) ?. ?=(%cont -.next.c-res) c-res c-res(self.next ..loop(computation self.next.c-res)) :: :: ---- :: :: Apps :: ++ poke-app |= [[her=ship app=term] =poke-data] =/ m (trad ,~) ^- form:m (send-effect %poke / [her app] poke-data) --