This commit is contained in:
committed by
Jaco Greeff
parent
3cd724d056
commit
c05430e25e
@@ -93,21 +93,30 @@ export default class Ws extends JsonRpcBase {
|
||||
}
|
||||
|
||||
_onMessage = (event) => {
|
||||
const result = JSON.parse(event.data);
|
||||
const { method, params, json, resolve, reject } = this._messages[result.id];
|
||||
|
||||
Logging.send(method, params, { json, result });
|
||||
|
||||
if (result.error) {
|
||||
this.error(event.data);
|
||||
|
||||
reject(new Error(`${result.error.code}: ${result.error.message}`));
|
||||
delete this._messages[result.id];
|
||||
return;
|
||||
// Event sent by Signer Broadcaster
|
||||
if (event.data === 'new_message') {
|
||||
return false;
|
||||
}
|
||||
|
||||
resolve(result.result);
|
||||
delete this._messages[result.id];
|
||||
try {
|
||||
const result = JSON.parse(event.data);
|
||||
const { method, params, json, resolve, reject } = this._messages[result.id];
|
||||
|
||||
Logging.send(method, params, { json, result });
|
||||
|
||||
if (result.error) {
|
||||
this.error(event.data);
|
||||
|
||||
reject(new Error(`${result.error.code}: ${result.error.message}`));
|
||||
delete this._messages[result.id];
|
||||
return;
|
||||
}
|
||||
|
||||
resolve(result.result);
|
||||
delete this._messages[result.id];
|
||||
} catch (e) {
|
||||
console.error('ws::_onMessage', event.data, e);
|
||||
}
|
||||
}
|
||||
|
||||
_send = (id) => {
|
||||
|
||||
Reference in New Issue
Block a user