mirror of
https://github.com/urbit/shrub.git
synced 2024-12-23 19:05:48 +03:00
149 lines
3.7 KiB
Plaintext
149 lines
3.7 KiB
Plaintext
:: Azimuth RPC API
|
|
::
|
|
/- rpc=json-rpc
|
|
/+ naive,
|
|
azimuth-rpc,
|
|
json-rpc,
|
|
*server,
|
|
default-agent,
|
|
verb,
|
|
dbug,
|
|
version,
|
|
agentio
|
|
|%
|
|
+$ card card:agent:gall
|
|
::
|
|
+$ state-0 [%0 ~]
|
|
--
|
|
::
|
|
%+ verb |
|
|
%- agent:dbug
|
|
::
|
|
=| state-0
|
|
=* state -
|
|
::
|
|
^- agent:gall
|
|
=<
|
|
|_ =bowl:gall
|
|
+* this .
|
|
do ~(. +> bowl)
|
|
def ~(. (default-agent this %|) bowl)
|
|
::
|
|
++ on-init
|
|
^- (quip card _this)
|
|
~& > 'init'
|
|
:_ this
|
|
[%pass /bind %arvo %e %connect [~ [%v1 %azimuth ~]] dap.bowl]~
|
|
::
|
|
++ on-save !>(state)
|
|
++ on-load
|
|
|= old=vase
|
|
^- (quip card _this)
|
|
[~ this(state !<(state-0 old))]
|
|
::
|
|
++ on-poke
|
|
|= [=mark =vase]
|
|
^- (quip card _this)
|
|
|^
|
|
?> (team:title our.bowl src.bowl)
|
|
?+ mark (on-poke:def mark vase)
|
|
%handle-http-request
|
|
=+ !<([id=@ta req=inbound-request:eyre] vase)
|
|
:_ this
|
|
(handle-http-request id req)
|
|
::
|
|
%azimuth-action
|
|
=+ !<([%disconnect bind=binding:eyre] vase)
|
|
~& >>> "disconnecting at {<bind>}"
|
|
:_ this
|
|
[[%pass /bind %arvo %e %disconnect bind]]~
|
|
==
|
|
::
|
|
++ handle-http-request
|
|
|= [id=@ta =inbound-request:eyre]
|
|
^- (list card)
|
|
|^
|
|
=* req request.inbound-request
|
|
=* headers header-list.req
|
|
=/ req-line (parse-request-line url.req)
|
|
?. =(method.req %'POST')
|
|
:: TODO: method not supported
|
|
::
|
|
(give-simple-payload:app id not-found:gen)
|
|
?~ rpc-request=(validate-request:json-rpc body.req parse-method)
|
|
:: TODO: malformed request
|
|
::
|
|
(give-simple-payload:app id not-found:gen)
|
|
=/ [data=(unit cage) response=simple-payload:http]
|
|
(process-rpc-request:do u.rpc-request)
|
|
%+ weld
|
|
(give-simple-payload:app id response)
|
|
?~ data ~
|
|
:_ ~
|
|
^- card
|
|
[%pass / %agent [our.bowl %dice] %poke u.data]
|
|
:: TODO: validate that format is e.g. 'getPoint'
|
|
:: TODO: maybe use getPoint and translate to %get-point
|
|
::
|
|
++ parse-method |=(t=@t `term`t)
|
|
--
|
|
--
|
|
::
|
|
++ on-watch
|
|
|= =path
|
|
^- (quip card _this)
|
|
?> (team:title our.bowl src.bowl)
|
|
?+ path (on-watch:def path)
|
|
[%http-response *] [~ this]
|
|
==
|
|
::
|
|
++ on-arvo
|
|
|= [=wire =sign-arvo]
|
|
^- (quip card _this)
|
|
?+ sign-arvo (on-arvo:def wire sign-arvo)
|
|
[%eyre %bound *]
|
|
~? !accepted.sign-arvo
|
|
[dap.bowl 'bind rejected!' binding.sign-arvo]
|
|
[~ this]
|
|
==
|
|
::
|
|
++ on-leave on-leave:def
|
|
++ on-peek on-peek:def
|
|
++ on-agent on-agent:def
|
|
++ on-fail on-fail:def
|
|
--
|
|
::
|
|
|_ =bowl:gall
|
|
++ process-rpc-request
|
|
|= request:rpc
|
|
^- [(unit cage) simple-payload:http]
|
|
=; [data=(unit cage) =response:rpc]
|
|
:- data
|
|
%- json-response:gen
|
|
(response-to-json:json-rpc response)
|
|
=, azimuth-rpc
|
|
?. ?=([%map *] params)
|
|
[~ ~(parse error id)]
|
|
?+ method [~ ~(method error id)]
|
|
%get-point [~ (get-point id +.params scry-point)]
|
|
%transfer-point (transfer-point id +.params)
|
|
%configure-keys (configure-keys id +.params)
|
|
%spawn (spawn id +.params)
|
|
%escape (escape id +.params)
|
|
%cancel-escape (cancel-escape id +.params)
|
|
%adopt (adopt id +.params)
|
|
%detach (detach id +.params)
|
|
%reject (reject id +.params)
|
|
%set-management-proxy (management-proxy id +.params)
|
|
%set-spawn-proxy (spawn-proxy id +.params)
|
|
%set-transfer-proxy (transfer-proxy id +.params)
|
|
==
|
|
::
|
|
++ scry-point
|
|
|= =ship
|
|
.^ (unit point:naive)
|
|
%gx
|
|
(~(scry agentio bowl) %azimuth /nas/[(scot %p ship)]/noun)
|
|
==
|
|
--
|