-
Notifications
You must be signed in to change notification settings - Fork 299
/
jsonrpc.js
119 lines (96 loc) · 3 KB
/
jsonrpc.js
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
/**
* Manages a JSON-RPC interface over a socket
*/
(function() {
const log = require("ko/logging").getLogger("jsonrpc");
this.ERROR_PARSING = -32700;
this.ERROR_INVALID_REQUEST = -32600;
this.ERROR_METHOD_NOT_FOUND = -32601;
this.ERROR_INVALID_PARAMS = -32602;
this.ERROR_INTERNAL = -32603;
var instance = function(socket)
{
var reqid = 0;
var callbacks = { all: [], errors: [] };
var init = () =>
{
socket.onData(onData);
log.debug("Created new JSONRPC Instance");
};
this.request = (method, args) =>
{
if (typeof method != "string")
{
log.error("Invalid method name, method name must be a string");
return;
}
if (typeof args == "function")
{
callback = args;
args = undefined;
}
var data = {
"jsonrpc": "2.0",
"method": method,
"id": ++reqid,
"params": []
};
if (args)
data.params = args;
try
{
data = JSON.stringify(data);
}
catch(e)
{
log.error("Failed serializing request for method: " + method);
return;
}
return new Promise((resolve, reject) =>
{
log.debug(`Sending request: ${data}`);
callbacks[reqid] = {};
callbacks[reqid].resolve = resolve;
callbacks[reqid].reject = reject;
socket.send(data);
});
};
this.onData = (callback) =>
{
callbacks.all.push(callback);
};
this.onError = (callback) =>
{
callbacks.errors.push(callback);
};
var onData = (data) =>
{
log.debug(`Received data: ${data}, length: ${data.length}`);
try
{
data = JSON.parse(data.trim());
}
catch (e)
{
log.error("Failed parsing JSON: " + data);
return;
}
for (let callback of callbacks.all)
callback(data);
if (data.id in callbacks)
{
if ("result" in data)
callbacks[data.id].resolve(data.result);
if ("error" in data)
callbacks[data.id].reject(data.error);
if (data.complete)
delete callbacks[data.id];
}
};
init();
};
this.create = (socket) =>
{
return new instance(socket);
};
}).apply(module.exports);