New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@remote-ui/rpc

Package Overview
Dependencies
Maintainers
1
Versions
55
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@remote-ui/rpc - npm Package Compare versions

Comparing version

to
0.0.2

175

build/cjs/endpoint.js

@@ -78,4 +78,2 @@ "use strict";

function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
function _toConsumableArray(arr) { return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _nonIterableSpread(); }

@@ -89,2 +87,4 @@

function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
function _slicedToArray(arr, i) { return _arrayWithHoles(arr) || _iterableToArrayLimit(arr, i) || _nonIterableRest(); }

@@ -98,2 +98,6 @@

function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } }
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; }
var APPLY = 0;

@@ -144,81 +148,90 @@ var RESULT = 1;

function listener(event) {
var _i, _arr, _listener, data, stackFrame, _data, id, target, args, func, result, _toWire, _toWire2, serializedResult, transferables, name, message, stack;
function listener(_x) {
return _listener.apply(this, arguments);
}
return regeneratorRuntime.async(function listener$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
for (_i = 0, _arr = _toConsumableArray(eventListeners); _i < _arr.length; _i++) {
_listener = _arr[_i];
function _listener() {
_listener = _asyncToGenerator(
/*#__PURE__*/
regeneratorRuntime.mark(function _callee(event) {
var _i3, _arr2, _listener2, data, stackFrame, _data2, id, target, args, func, result, _toWire7, _toWire8, serializedResult, transferables, name, message, stack;
_listener(event);
}
return regeneratorRuntime.wrap(function _callee$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
for (_i3 = 0, _arr2 = _toConsumableArray(eventListeners); _i3 < _arr2.length; _i3++) {
_listener2 = _arr2[_i3];
data = event.data;
_listener2(event);
}
if (!(data == null)) {
_context.next = 4;
break;
}
data = event.data;
return _context.abrupt("return");
if (!(data == null)) {
_context.next = 4;
break;
}
case 4:
_context.t0 = data[0];
_context.next = _context.t0 === TERMINATE ? 7 : _context.t0 === APPLY ? 9 : 30;
break;
return _context.abrupt("return");
case 7:
terminate();
return _context.abrupt("break", 30);
case 4:
_context.t0 = data[0];
_context.next = _context.t0 === TERMINATE ? 7 : _context.t0 === APPLY ? 9 : 30;
break;
case 9:
stackFrame = new _memory.StackFrame();
_data = _slicedToArray(data, 4), id = _data[1], target = _data[2], args = _data[3];
func = activeApi.get(target);
_context.prev = 12;
case 7:
terminate();
return _context.abrupt("break", 30);
if (!(func == null)) {
_context.next = 15;
break;
}
case 9:
stackFrame = new _memory.StackFrame();
_data2 = _slicedToArray(data, 4), id = _data2[1], target = _data2[2], args = _data2[3];
func = activeApi.get(target);
_context.prev = 12;
throw new Error("No '".concat(target, "' method is exposed on this endpoint"));
if (!(func == null)) {
_context.next = 15;
break;
}
case 15:
_context.next = 17;
return regeneratorRuntime.awrap(func.apply(void 0, _toConsumableArray(fromWire(args, [stackFrame]))));
throw new Error("No '".concat(target, "' method is exposed on this endpoint"));
case 17:
result = _context.sent;
_toWire = toWire(result), _toWire2 = _slicedToArray(_toWire, 2), serializedResult = _toWire2[0], transferables = _toWire2[1];
messenger.postMessage([RESULT, id, undefined, serializedResult], transferables);
_context.next = 26;
break;
case 15:
_context.next = 17;
return func.apply(void 0, _toConsumableArray(fromWire(args, [stackFrame])));
case 22:
_context.prev = 22;
_context.t1 = _context["catch"](12);
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack;
messenger.postMessage([RESULT, id, {
name: name,
message: message,
stack: stack
}]);
case 17:
result = _context.sent;
_toWire7 = toWire(result), _toWire8 = _slicedToArray(_toWire7, 2), serializedResult = _toWire8[0], transferables = _toWire8[1];
messenger.postMessage([RESULT, id, undefined, serializedResult], transferables);
_context.next = 26;
break;
case 26:
_context.prev = 26;
stackFrame.release();
return _context.finish(26);
case 22:
_context.prev = 22;
_context.t1 = _context["catch"](12);
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack;
messenger.postMessage([RESULT, id, {
name: name,
message: message,
stack: stack
}]);
case 29:
return _context.abrupt("break", 30);
case 26:
_context.prev = 26;
stackFrame.release();
return _context.finish(26);
case 30:
case "end":
return _context.stop();
case 29:
return _context.abrupt("break", 30);
case 30:
case "end":
return _context.stop();
}
}
}
}, null, null, [[12, 22, 26, 29]]);
}, _callee, null, [[12, 22, 26, 29]]);
}));
return _listener.apply(this, arguments);
}

@@ -246,5 +259,5 @@

var _data2 = _slicedToArray(data, 4),
errorResult = _data2[2],
value = _data2[3];
var _data = _slicedToArray(data, 4),
errorResult = _data[2],
value = _data[3];

@@ -265,6 +278,6 @@ if (errorResult == null) {

var _toWire3 = toWire(args),
_toWire4 = _slicedToArray(_toWire3, 2),
serializedArgs = _toWire4[0],
transferables = _toWire4[1];
var _toWire = toWire(args),
_toWire2 = _slicedToArray(_toWire, 2),
serializedArgs = _toWire2[0],
transferables = _toWire2[1];

@@ -326,7 +339,7 @@ messenger.postMessage([APPLY, id, property, serializedArgs], transferables);

var _result = value.map(function (item) {
var _toWire5 = toWire(item),
_toWire6 = _slicedToArray(_toWire5, 2),
result = _toWire6[0],
_toWire6$ = _toWire6[1],
nestedTransferables = _toWire6$ === void 0 ? [] : _toWire6$;
var _toWire3 = toWire(item),
_toWire4 = _slicedToArray(_toWire3, 2),
result = _toWire4[0],
_toWire4$ = _toWire4[1],
nestedTransferables = _toWire4$ === void 0 ? [] : _toWire4$;

@@ -341,7 +354,7 @@ transferables.push.apply(transferables, _toConsumableArray(nestedTransferables));

var result = Object.keys(value).reduce(function (object, key) {
var _toWire7 = toWire(value[key]),
_toWire8 = _slicedToArray(_toWire7, 2),
result = _toWire8[0],
_toWire8$ = _toWire8[1],
nestedTransferables = _toWire8$ === void 0 ? [] : _toWire8$;
var _toWire5 = toWire(value[key]),
_toWire6 = _slicedToArray(_toWire5, 2),
result = _toWire6[0],
_toWire6$ = _toWire6[1],
nestedTransferables = _toWire6$ === void 0 ? [] : _toWire6$;

@@ -348,0 +361,0 @@ transferables.push.apply(transferables, _toConsumableArray(nestedTransferables));

@@ -67,3 +67,3 @@ "use strict";

function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }

@@ -70,0 +70,0 @@ function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }

@@ -60,2 +60,6 @@ "use strict";

function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } }
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; }
function _slicedToArray(arr, i) { return _arrayWithHoles(arr) || _iterableToArrayLimit(arr, i) || _nonIterableRest(); }

@@ -99,70 +103,82 @@

portToFunction.set(port1, func);
port1.addEventListener('message', function listener(_ref5) {
var data, stackFrame, _data, _id2, args, _func, retainedBy, result, _toWire2, _toWire3, serializedResult, transferables, name, message, stack;
port1.addEventListener('message',
/*#__PURE__*/
function () {
var _listener = _asyncToGenerator(
/*#__PURE__*/
regeneratorRuntime.mark(function _callee(_ref5) {
var data, stackFrame, _data, _id2, args, _func, retainedBy, result, _toWire2, _toWire3, serializedResult, transferables, name, message, stack;
return regeneratorRuntime.async(function listener$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
data = _ref5.data;
return regeneratorRuntime.wrap(function _callee$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
data = _ref5.data;
if (!(data == null)) {
_context.next = 3;
if (!(data == null)) {
_context.next = 3;
break;
}
return _context.abrupt("return");
case 3:
_context.t0 = data[0];
_context.next = _context.t0 === RELEASE ? 6 : _context.t0 === APPLY ? 10 : 30;
break;
}
return _context.abrupt("return");
case 6:
port1.removeEventListener('message', listener);
port1.close();
functionStore["delete"](func);
return _context.abrupt("break", 30);
case 3:
_context.t0 = data[0];
_context.next = _context.t0 === RELEASE ? 6 : _context.t0 === APPLY ? 10 : 30;
break;
case 10:
stackFrame = new _memory.StackFrame();
_data = _slicedToArray(data, 3), _id2 = _data[1], args = _data[2];
_func = portToFunction.get(port1);
_context.prev = 13;
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame];
_context.next = 17;
return _func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy)));
case 6:
port1.removeEventListener('message', listener);
port1.close();
functionStore["delete"](func);
return _context.abrupt("break", 30);
case 17:
result = _context.sent;
_toWire2 = _toWire(result), _toWire3 = _slicedToArray(_toWire2, 2), serializedResult = _toWire3[0], transferables = _toWire3[1];
port1.postMessage([RESULT, _id2, undefined, serializedResult], transferables);
_context.next = 26;
break;
case 10:
stackFrame = new _memory.StackFrame();
_data = _slicedToArray(data, 3), _id2 = _data[1], args = _data[2];
_func = portToFunction.get(port1);
_context.prev = 13;
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame];
_context.next = 17;
return regeneratorRuntime.awrap(_func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy))));
case 22:
_context.prev = 22;
_context.t1 = _context["catch"](13);
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack;
port1.postMessage([RESULT, _id2, {
name: name,
message: message,
stack: stack
}]);
case 17:
result = _context.sent;
_toWire2 = _toWire(result), _toWire3 = _slicedToArray(_toWire2, 2), serializedResult = _toWire3[0], transferables = _toWire3[1];
port1.postMessage([RESULT, _id2, undefined, serializedResult], transferables);
_context.next = 26;
break;
case 26:
_context.prev = 26;
stackFrame.release();
return _context.finish(26);
case 22:
_context.prev = 22;
_context.t1 = _context["catch"](13);
name = _context.t1.name, message = _context.t1.message, stack = _context.t1.stack;
port1.postMessage([RESULT, _id2, {
name: name,
message: message,
stack: stack
}]);
case 29:
return _context.abrupt("break", 30);
case 26:
_context.prev = 26;
stackFrame.release();
return _context.finish(26);
case 30:
case "end":
return _context.stop();
}
}
}, _callee, null, [[13, 22, 26, 29]]);
}));
case 29:
return _context.abrupt("break", 30);
function listener(_x) {
return _listener.apply(this, arguments);
}
case 30:
case "end":
return _context.stop();
}
}
}, null, null, [[13, 22, 26, 29]]);
});
return listener;
}());
port1.start();

@@ -169,0 +185,0 @@ return [[id, port2], [port2]];

@@ -66,2 +66,6 @@ "use strict";

function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } }
function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; }
var APPLY = 11;

@@ -82,100 +86,109 @@ var RESULT = 12;

function listener(_ref2) {
var data, _data, id, _data2, _id, func, _data3, callId, _error, _result, stackFrame, _data4, _callId, funcId, args, _func, _ref3, name, message, stack, retainedBy, _result2, _toWire, _toWire2, serializedResult, transferables, _name, _message, _stack;
function listener(_x) {
return _listener.apply(this, arguments);
}
return regeneratorRuntime.async(function listener$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
data = _ref2.data;
function _listener() {
_listener = _asyncToGenerator(
/*#__PURE__*/
regeneratorRuntime.mark(function _callee(_ref2) {
var data, _data, id, _data2, _id2, func, _data3, callId, _error2, _result, stackFrame, _data4, _callId, funcId, args, _func, _ref3, name, message, stack, retainedBy, _result2, _toWire3, _toWire4, serializedResult, transferables, _name, _message, _stack;
if (!(data == null)) {
_context.next = 3;
break;
}
return regeneratorRuntime.wrap(function _callee$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
data = _ref2.data;
return _context.abrupt("return");
if (!(data == null)) {
_context.next = 3;
break;
}
case 3:
_context.t0 = data[0];
_context.next = _context.t0 === REVOKE ? 6 : _context.t0 === RELEASE ? 9 : _context.t0 === RESULT ? 13 : _context.t0 === APPLY ? 17 : 41;
break;
return _context.abrupt("return");
case 6:
_data = _slicedToArray(data, 2), id = _data[1];
idsToProxy["delete"](id);
return _context.abrupt("break", 41);
case 3:
_context.t0 = data[0];
_context.next = _context.t0 === REVOKE ? 6 : _context.t0 === RELEASE ? 9 : _context.t0 === RESULT ? 13 : _context.t0 === APPLY ? 17 : 41;
break;
case 9:
_data2 = _slicedToArray(data, 2), _id = _data2[1];
func = idsToFunction.get(_id);
case 6:
_data = _slicedToArray(data, 2), id = _data[1];
idsToProxy["delete"](id);
return _context.abrupt("break", 41);
if (func) {
idsToFunction["delete"](_id);
functionsToId["delete"](func);
}
case 9:
_data2 = _slicedToArray(data, 2), _id2 = _data2[1];
func = idsToFunction.get(_id2);
return _context.abrupt("break", 41);
if (func) {
idsToFunction["delete"](_id2);
functionsToId["delete"](func);
}
case 13:
_data3 = _slicedToArray(data, 4), callId = _data3[1], _error = _data3[2], _result = _data3[3];
callIdsToResolver.get(callId)(_error, _result);
callIdsToResolver["delete"](callId);
return _context.abrupt("break", 41);
return _context.abrupt("break", 41);
case 17:
stackFrame = new _memory.StackFrame();
_data4 = _slicedToArray(data, 4), _callId = _data4[1], funcId = _data4[2], args = _data4[3];
_func = idsToFunction.get(funcId);
case 13:
_data3 = _slicedToArray(data, 4), callId = _data3[1], _error2 = _data3[2], _result = _data3[3];
callIdsToResolver.get(callId)(_error2, _result);
callIdsToResolver["delete"](callId);
return _context.abrupt("break", 41);
if (!(_func == null)) {
_context.next = 24;
break;
}
case 17:
stackFrame = new _memory.StackFrame();
_data4 = _slicedToArray(data, 4), _callId = _data4[1], funcId = _data4[2], args = _data4[3];
_func = idsToFunction.get(funcId);
_ref3 = new Error('You attempted to call a function that was already revoked.'), name = _ref3.name, message = _ref3.message, stack = _ref3.stack;
messenger.postMessage([RESULT, _callId, {
name: name,
message: message,
stack: stack
}]);
return _context.abrupt("return");
if (!(_func == null)) {
_context.next = 24;
break;
}
case 24:
_context.prev = 24;
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame];
_context.next = 28;
return regeneratorRuntime.awrap(_func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy))));
_ref3 = new Error('You attempted to call a function that was already revoked.'), name = _ref3.name, message = _ref3.message, stack = _ref3.stack;
messenger.postMessage([RESULT, _callId, {
name: name,
message: message,
stack: stack
}]);
return _context.abrupt("return");
case 28:
_result2 = _context.sent;
_toWire = toWire(_result2), _toWire2 = _slicedToArray(_toWire, 2), serializedResult = _toWire2[0], transferables = _toWire2[1];
messenger.postMessage([RESULT, _callId, undefined, serializedResult], transferables);
_context.next = 37;
break;
case 24:
_context.prev = 24;
retainedBy = (0, _memory.isMemoryManageable)(_func) ? [stackFrame].concat(_toConsumableArray(_func[_types.RETAINED_BY])) : [stackFrame];
_context.next = 28;
return _func.apply(void 0, _toConsumableArray(_fromWire(args, retainedBy)));
case 33:
_context.prev = 33;
_context.t1 = _context["catch"](24);
_name = _context.t1.name, _message = _context.t1.message, _stack = _context.t1.stack;
messenger.postMessage([RESULT, _callId, {
name: _name,
message: _message,
stack: _stack
}]);
case 28:
_result2 = _context.sent;
_toWire3 = toWire(_result2), _toWire4 = _slicedToArray(_toWire3, 2), serializedResult = _toWire4[0], transferables = _toWire4[1];
messenger.postMessage([RESULT, _callId, undefined, serializedResult], transferables);
_context.next = 37;
break;
case 37:
_context.prev = 37;
stackFrame.release();
return _context.finish(37);
case 33:
_context.prev = 33;
_context.t1 = _context["catch"](24);
_name = _context.t1.name, _message = _context.t1.message, _stack = _context.t1.stack;
messenger.postMessage([RESULT, _callId, {
name: _name,
message: _message,
stack: _stack
}]);
case 40:
return _context.abrupt("break", 41);
case 37:
_context.prev = 37;
stackFrame.release();
return _context.finish(37);
case 41:
case "end":
return _context.stop();
case 40:
return _context.abrupt("break", 41);
case 41:
case "end":
return _context.stop();
}
}
}
}, null, null, [[24, 33, 37, 40]]);
}, _callee, null, [[24, 33, 37, 40]]);
}));
return _listener.apply(this, arguments);
}

@@ -187,5 +200,5 @@

if (functionsToId.has(func)) {
var _id2 = functionsToId.get(func);
var _id = functionsToId.get(func);
return [_id2];
return [_id];
}

@@ -256,5 +269,5 @@

} else {
var _error2 = new Error();
var _error = new Error();
Object.assign(_error2, errorResult);
Object.assign(_error, errorResult);
reject(errorResult);

@@ -265,6 +278,6 @@ }

var _toWire3 = toWire(args),
_toWire4 = _slicedToArray(_toWire3, 2),
serializedArgs = _toWire4[0],
transferables = _toWire4[1];
var _toWire = toWire(args),
_toWire2 = _slicedToArray(_toWire, 2),
serializedArgs = _toWire2[0],
transferables = _toWire2[1];

@@ -271,0 +284,0 @@ messenger.postMessage([APPLY, callId, id, serializedArgs], transferables);

{
"name": "@remote-ui/rpc",
"version": "0.0.1",
"version": "0.0.2",
"publishConfig": {

@@ -9,6 +9,6 @@ "access": "public"

"devDependencies": {
"@types/uuid": "^3.4.6",
"uuid": "^3.3.3"
"@types/uuid": "^3.4.7",
"uuid": "^3.4.0"
},
"gitHead": "c983682d8602256e4f8fef925d098785b300d0c8"
"gitHead": "c40615dd893295f310c5b726f1463e70cc45be3c"
}

Sorry, the diff of this file is not supported yet