mirror of
https://github.com/ZmnSCPxj/clboss.git
synced 2026-08-16 13:00:59 +02:00
39 lines
884 B
C++
39 lines
884 B
C++
#include"Boss/Mod/Rpc.hpp"
|
|
#include"Boss/ModG/RpcProxy.hpp"
|
|
#include"Boss/Msg/RequestRpcCommand.hpp"
|
|
#include"Boss/Msg/ResponseRpcCommand.hpp"
|
|
#include"Ev/Io.hpp"
|
|
#include"Jsmn/Object.hpp"
|
|
#include"Json/Out.hpp"
|
|
#include"S/Bus.hpp"
|
|
|
|
namespace Boss { namespace ModG {
|
|
|
|
RpcProxy::~RpcProxy() =default;
|
|
|
|
RpcProxy::RpcProxy(S::Bus& bus)
|
|
: core( bus
|
|
, [](Msg::RequestRpcCommand& m, void* p) {
|
|
m.requester = p;
|
|
}
|
|
, [](Msg::ResponseRpcCommand& m) {
|
|
return m.requester;
|
|
}
|
|
) { }
|
|
|
|
Ev::Io<Jsmn::Object>
|
|
RpcProxy::command( std::string const& command
|
|
, Json::Out params
|
|
) {
|
|
return core.execute(Msg::RequestRpcCommand{
|
|
nullptr, command, params
|
|
}).then([](Msg::ResponseRpcCommand resp) {
|
|
if (!resp.succeeded)
|
|
throw Mod::RpcError( std::move(resp.command)
|
|
, std::move(resp.result)
|
|
);
|
|
return Ev::lift(std::move(resp.result));
|
|
});
|
|
}
|
|
|
|
}}
|