rpc-websockets
Advanced tools
rpc-websockets - npm Package Compare versions
Comparing version 2.0.2 to 2.0.3
@@ -477,3 +477,3 @@ /** | ||
| var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(message, socket_id) { | ||
| var results, _iteratorNormalCompletion4, _didIteratorError4, _iteratorError4, _iterator4, _step4, name, _iteratorNormalCompletion5, _didIteratorError5, _iteratorError5, _iterator5, _step5, event, _results, _iteratorNormalCompletion6, _didIteratorError6, _iteratorError6, _iterator6, _step6, _name, index, response; | ||
| var results, event_names, _iteratorNormalCompletion4, _didIteratorError4, _iteratorError4, _iterator4, _step4, name, index, _results, _iteratorNormalCompletion5, _didIteratorError5, _iteratorError5, _iterator5, _step5, _name, _index, response; | ||
@@ -545,3 +545,3 @@ return _regenerator2.default.wrap(function _callee2$(_context2) { | ||
| if (!(message.method === "rpc.on")) { | ||
| _context2.next = 71; | ||
| _context2.next = 48; | ||
| break; | ||
@@ -563,11 +563,12 @@ } | ||
| results = {}; | ||
| event_names = (0, _keys2.default)(this.events); | ||
| _iteratorNormalCompletion4 = true; | ||
| _didIteratorError4 = false; | ||
| _iteratorError4 = undefined; | ||
| _context2.prev = 17; | ||
| _context2.prev = 18; | ||
| _iterator4 = (0, _getIterator3.default)(message.params); | ||
| case 19: | ||
| case 20: | ||
| if (_iteratorNormalCompletion4 = (_step4 = _iterator4.next()).done) { | ||
| _context2.next = 52; | ||
| _context2.next = 31; | ||
| break; | ||
@@ -577,83 +578,36 @@ } | ||
| name = _step4.value; | ||
| _iteratorNormalCompletion5 = true; | ||
| _didIteratorError5 = false; | ||
| _iteratorError5 = undefined; | ||
| _context2.prev = 24; | ||
| _iterator5 = (0, _getIterator3.default)((0, _keys2.default)(this.events)); | ||
| index = event_names.indexOf(name); | ||
| case 26: | ||
| if (_iteratorNormalCompletion5 = (_step5 = _iterator5.next()).done) { | ||
| _context2.next = 35; | ||
| if (!(index === -1)) { | ||
| _context2.next = 26; | ||
| break; | ||
| } | ||
| event = _step5.value; | ||
| results[name] = "provided event invalid"; | ||
| return _context2.abrupt("continue", 28); | ||
| if (!(event === name)) { | ||
| _context2.next = 32; | ||
| break; | ||
| } | ||
| case 26: | ||
| this.events[event].push(socket_id); | ||
| this.events[event_names[index]].push(socket_id); | ||
| results[name] = "ok"; | ||
| return _context2.abrupt("break", 35); | ||
| case 32: | ||
| _iteratorNormalCompletion5 = true; | ||
| _context2.next = 26; | ||
| break; | ||
| case 35: | ||
| _context2.next = 41; | ||
| break; | ||
| case 37: | ||
| _context2.prev = 37; | ||
| _context2.t0 = _context2["catch"](24); | ||
| _didIteratorError5 = true; | ||
| _iteratorError5 = _context2.t0; | ||
| case 41: | ||
| _context2.prev = 41; | ||
| _context2.prev = 42; | ||
| if (!_iteratorNormalCompletion5 && _iterator5.return) { | ||
| _iterator5.return(); | ||
| } | ||
| case 44: | ||
| _context2.prev = 44; | ||
| if (!_didIteratorError5) { | ||
| _context2.next = 47; | ||
| break; | ||
| } | ||
| throw _iteratorError5; | ||
| case 47: | ||
| return _context2.finish(44); | ||
| case 48: | ||
| return _context2.finish(41); | ||
| case 49: | ||
| case 28: | ||
| _iteratorNormalCompletion4 = true; | ||
| _context2.next = 19; | ||
| _context2.next = 20; | ||
| break; | ||
| case 52: | ||
| _context2.next = 58; | ||
| case 31: | ||
| _context2.next = 37; | ||
| break; | ||
| case 54: | ||
| _context2.prev = 54; | ||
| _context2.t1 = _context2["catch"](17); | ||
| case 33: | ||
| _context2.prev = 33; | ||
| _context2.t0 = _context2["catch"](18); | ||
| _didIteratorError4 = true; | ||
| _iteratorError4 = _context2.t1; | ||
| _iteratorError4 = _context2.t0; | ||
| case 58: | ||
| _context2.prev = 58; | ||
| _context2.prev = 59; | ||
| case 37: | ||
| _context2.prev = 37; | ||
| _context2.prev = 38; | ||
@@ -664,7 +618,7 @@ if (!_iteratorNormalCompletion4 && _iterator4.return) { | ||
| case 61: | ||
| _context2.prev = 61; | ||
| case 40: | ||
| _context2.prev = 40; | ||
| if (!_didIteratorError4) { | ||
| _context2.next = 64; | ||
| _context2.next = 43; | ||
| break; | ||
@@ -675,23 +629,11 @@ } | ||
| case 64: | ||
| return _context2.finish(61); | ||
| case 43: | ||
| return _context2.finish(40); | ||
| case 65: | ||
| return _context2.finish(58); | ||
| case 44: | ||
| return _context2.finish(37); | ||
| case 66: | ||
| if ((0, _keys2.default)(results).length) { | ||
| _context2.next = 68; | ||
| break; | ||
| } | ||
| case 45: | ||
| return _context2.abrupt("return", { | ||
| jsonrpc: "2.0", | ||
| result: "provided event invalid", | ||
| id: message.id || null | ||
| }); | ||
| case 68: | ||
| return _context2.abrupt("return", { | ||
| jsonrpc: "2.0", | ||
| result: results, | ||
@@ -701,5 +643,5 @@ id: message.id || null | ||
| case 71: | ||
| case 48: | ||
| if (!(message.method === "rpc.off")) { | ||
| _context2.next = 109; | ||
| _context2.next = 86; | ||
| break; | ||
@@ -709,3 +651,3 @@ } | ||
| if (message.params) { | ||
| _context2.next = 74; | ||
| _context2.next = 51; | ||
| break; | ||
@@ -720,20 +662,20 @@ } | ||
| case 74: | ||
| case 51: | ||
| _results = {}; | ||
| _iteratorNormalCompletion6 = true; | ||
| _didIteratorError6 = false; | ||
| _iteratorError6 = undefined; | ||
| _context2.prev = 78; | ||
| _iterator6 = (0, _getIterator3.default)(message.params); | ||
| _iteratorNormalCompletion5 = true; | ||
| _didIteratorError5 = false; | ||
| _iteratorError5 = undefined; | ||
| _context2.prev = 55; | ||
| _iterator5 = (0, _getIterator3.default)(message.params); | ||
| case 80: | ||
| if (_iteratorNormalCompletion6 = (_step6 = _iterator6.next()).done) { | ||
| _context2.next = 94; | ||
| case 57: | ||
| if (_iteratorNormalCompletion5 = (_step5 = _iterator5.next()).done) { | ||
| _context2.next = 71; | ||
| break; | ||
| } | ||
| _name = _step6.value; | ||
| _name = _step5.value; | ||
| if (this.events[_name]) { | ||
| _context2.next = 85; | ||
| _context2.next = 62; | ||
| break; | ||
@@ -743,9 +685,9 @@ } | ||
| _results[_name] = "provided event invalid"; | ||
| return _context2.abrupt("continue", 91); | ||
| return _context2.abrupt("continue", 68); | ||
| case 85: | ||
| index = this.events[_name].indexOf(socket_id); | ||
| case 62: | ||
| _index = this.events[_name].indexOf(socket_id); | ||
| if (!(index === -1)) { | ||
| _context2.next = 89; | ||
| if (!(_index === -1)) { | ||
| _context2.next = 66; | ||
| break; | ||
@@ -755,49 +697,49 @@ } | ||
| _results[_name] = "not subscribed"; | ||
| return _context2.abrupt("continue", 91); | ||
| return _context2.abrupt("continue", 68); | ||
| case 89: | ||
| case 66: | ||
| this.events[_name].splice(index, 1); | ||
| this.events[_name].splice(_index, 1); | ||
| _results[_name] = "ok"; | ||
| case 91: | ||
| _iteratorNormalCompletion6 = true; | ||
| _context2.next = 80; | ||
| case 68: | ||
| _iteratorNormalCompletion5 = true; | ||
| _context2.next = 57; | ||
| break; | ||
| case 94: | ||
| _context2.next = 100; | ||
| case 71: | ||
| _context2.next = 77; | ||
| break; | ||
| case 96: | ||
| _context2.prev = 96; | ||
| _context2.t2 = _context2["catch"](78); | ||
| _didIteratorError6 = true; | ||
| _iteratorError6 = _context2.t2; | ||
| case 73: | ||
| _context2.prev = 73; | ||
| _context2.t1 = _context2["catch"](55); | ||
| _didIteratorError5 = true; | ||
| _iteratorError5 = _context2.t1; | ||
| case 100: | ||
| _context2.prev = 100; | ||
| _context2.prev = 101; | ||
| case 77: | ||
| _context2.prev = 77; | ||
| _context2.prev = 78; | ||
| if (!_iteratorNormalCompletion6 && _iterator6.return) { | ||
| _iterator6.return(); | ||
| if (!_iteratorNormalCompletion5 && _iterator5.return) { | ||
| _iterator5.return(); | ||
| } | ||
| case 103: | ||
| _context2.prev = 103; | ||
| case 80: | ||
| _context2.prev = 80; | ||
| if (!_didIteratorError6) { | ||
| _context2.next = 106; | ||
| if (!_didIteratorError5) { | ||
| _context2.next = 83; | ||
| break; | ||
| } | ||
| throw _iteratorError6; | ||
| throw _iteratorError5; | ||
| case 106: | ||
| return _context2.finish(103); | ||
| case 83: | ||
| return _context2.finish(80); | ||
| case 107: | ||
| return _context2.finish(100); | ||
| case 84: | ||
| return _context2.finish(77); | ||
| case 108: | ||
| case 85: | ||
| return _context2.abrupt("return", { | ||
@@ -809,5 +751,5 @@ jsonrpc: "2.0", | ||
| case 109: | ||
| case 86: | ||
| if (this.rpc_methods[message.method]) { | ||
| _context2.next = 111; | ||
| _context2.next = 88; | ||
| break; | ||
@@ -822,19 +764,19 @@ } | ||
| case 111: | ||
| case 88: | ||
| response = null; | ||
| _context2.prev = 112; | ||
| _context2.next = 115; | ||
| _context2.prev = 89; | ||
| _context2.next = 92; | ||
| return this.rpc_methods[message.method](message.params); | ||
| case 115: | ||
| case 92: | ||
| response = _context2.sent; | ||
| _context2.next = 125; | ||
| _context2.next = 102; | ||
| break; | ||
| case 118: | ||
| _context2.prev = 118; | ||
| _context2.t3 = _context2["catch"](112); | ||
| case 95: | ||
| _context2.prev = 95; | ||
| _context2.t2 = _context2["catch"](89); | ||
| if (message.id) { | ||
| _context2.next = 122; | ||
| _context2.next = 99; | ||
| break; | ||
@@ -845,5 +787,5 @@ } | ||
| case 122: | ||
| if (!(_context2.t3 instanceof Error)) { | ||
| _context2.next = 124; | ||
| case 99: | ||
| if (!(_context2.t2 instanceof Error)) { | ||
| _context2.next = 101; | ||
| break; | ||
@@ -856,4 +798,4 @@ } | ||
| code: -32000, | ||
| message: _context2.t3.name, | ||
| data: _context2.t3.message | ||
| message: _context2.t2.name, | ||
| data: _context2.t2.message | ||
| }, | ||
@@ -863,12 +805,12 @@ id: message.id | ||
| case 124: | ||
| case 101: | ||
| return _context2.abrupt("return", { | ||
| jsonrpc: "2.0", | ||
| error: _context2.t3, | ||
| error: _context2.t2, | ||
| id: message.id | ||
| }); | ||
| case 125: | ||
| case 102: | ||
| if (message.id) { | ||
| _context2.next = 127; | ||
| _context2.next = 104; | ||
| break; | ||
@@ -879,3 +821,3 @@ } | ||
| case 127: | ||
| case 104: | ||
| return _context2.abrupt("return", { | ||
@@ -887,3 +829,3 @@ jsonrpc: "2.0", | ||
| case 128: | ||
| case 105: | ||
| case "end": | ||
@@ -893,3 +835,3 @@ return _context2.stop(); | ||
| } | ||
| }, _callee2, this, [[17, 54, 58, 66], [24, 37, 41, 49], [42,, 44, 48], [59,, 61, 65], [78, 96, 100, 108], [101,, 103, 107], [112, 118]]); | ||
| }, _callee2, this, [[18, 33, 37, 45], [38,, 40, 44], [55, 73, 77, 85], [78,, 80, 84], [89, 95]]); | ||
| })); | ||
@@ -896,0 +838,0 @@ |
| { | ||
| "name": "rpc-websockets", | ||
| "version": "2.0.2", | ||
| "version": "2.0.3", | ||
| "description": "JSON-RPC 2.0 implementation over WebSockets for Node.js", | ||
@@ -5,0 +5,0 @@ "main": "./dist/index.js", |
Sorry, the diff of this file is not supported yet
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Worsened metrics
- Total package byte prevSize
- decreased by-4.33%
56142
- Lines of code
- decreased by-4.47%
1004
No dependency changes