blob: b767703fc27db8e9444434fdf9790e6db23c42d4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
#pragma once
#include "StarJson.hpp"
#include "StarByteArray.hpp"
#include "StarRpcPromise.hpp"
namespace Star {
STAR_CLASS(JsonRpcInterface);
STAR_CLASS(JsonRpc);
STAR_EXCEPTION(JsonRpcException, StarException);
typedef function<Json(Json const&)> JsonRpcRemoteFunction;
typedef StringMap<JsonRpcRemoteFunction> JsonRpcHandlers;
// Simple interface to just the method invocation part of JsonRpc.
class JsonRpcInterface {
public:
virtual ~JsonRpcInterface();
virtual RpcPromise<Json> invokeRemote(String const& handler, Json const& arguments) = 0;
};
// Simple class to handle remote methods based on Json types. Does not
// handle any of the network details, simply turns rpc calls into ByteArray
// messages to be sent and received.
class JsonRpc : public JsonRpcInterface {
public:
JsonRpc();
void registerHandler(String const& handler, JsonRpcRemoteFunction func);
void registerHandlers(JsonRpcHandlers const& handlers);
void removeHandler(String const& handler);
void clearHandlers();
RpcPromise<Json> invokeRemote(String const& handler, Json const& arguments) override;
bool sendPending() const;
ByteArray send();
void receive(ByteArray const& inbuffer);
private:
JsonRpcHandlers m_handlers;
Map<uint64_t, RpcPromiseKeeper<Json>> m_pendingResponse;
List<Json> m_pending;
uint64_t m_requestId;
};
}
|