Socket
Socket
Sign inDemoInstall

broker-factory

Package Overview
Dependencies
Maintainers
1
Versions
194
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

broker-factory - npm Package Compare versions

Comparing version 3.0.72 to 3.0.73

89

build/es5/bundle.js

@@ -7,9 +7,2 @@ (function (global, factory) {

function _interopDefaultLegacy (e) { return e && typeof e === 'object' && 'default' in e ? e : { 'default': e }; }
var _defineProperty__default = /*#__PURE__*/_interopDefaultLegacy(_defineProperty);
var _slicedToArray__default = /*#__PURE__*/_interopDefaultLegacy(_slicedToArray);
var _asyncToGenerator__default = /*#__PURE__*/_interopDefaultLegacy(_asyncToGenerator);
var _regeneratorRuntime__default = /*#__PURE__*/_interopDefaultLegacy(_regeneratorRuntime);
var isMessagePort = function isMessagePort(sender) {

@@ -22,3 +15,3 @@ return typeof sender.start === 'function';

function ownKeys$1(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); enumerableOnly && (symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; })), keys.push.apply(keys, symbols); } return keys; }
function _objectSpread$1(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys$1(Object(source), !0).forEach(function (key) { _defineProperty__default["default"](target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys$1(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }
function _objectSpread$1(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys$1(Object(source), !0).forEach(function (key) { _defineProperty(target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys$1(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }
var extendBrokerImplementation = function extendBrokerImplementation(partialBrokerImplementation) {

@@ -28,21 +21,19 @@ return _objectSpread$1(_objectSpread$1({}, partialBrokerImplementation), {}, {

var call = _ref.call;
return /*#__PURE__*/_asyncToGenerator__default["default"]( /*#__PURE__*/_regeneratorRuntime__default["default"].mark(function _callee() {
return /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/_regeneratorRuntime.mark(function _callee() {
var _MessageChannel, port1, port2, portId;
return _regeneratorRuntime__default["default"].wrap(function _callee$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
_MessageChannel = new MessageChannel(), port1 = _MessageChannel.port1, port2 = _MessageChannel.port2;
_context.next = 3;
return call('connect', {
port: port1
}, [port1]);
case 3:
portId = _context.sent;
PORT_MAP.set(port2, portId);
return _context.abrupt("return", port2);
case 6:
case "end":
return _context.stop();
}
return _regeneratorRuntime.wrap(function _callee$(_context) {
while (1) switch (_context.prev = _context.next) {
case 0:
_MessageChannel = new MessageChannel(), port1 = _MessageChannel.port1, port2 = _MessageChannel.port2;
_context.next = 3;
return call('connect', {
port: port1
}, [port1]);
case 3:
portId = _context.sent;
PORT_MAP.set(port2, portId);
return _context.abrupt("return", port2);
case 6:
case "end":
return _context.stop();
}

@@ -55,23 +46,21 @@ }, _callee);

return /*#__PURE__*/function () {
var _ref4 = _asyncToGenerator__default["default"]( /*#__PURE__*/_regeneratorRuntime__default["default"].mark(function _callee2(port) {
var _ref4 = _asyncToGenerator( /*#__PURE__*/_regeneratorRuntime.mark(function _callee2(port) {
var portId;
return _regeneratorRuntime__default["default"].wrap(function _callee2$(_context2) {
while (1) {
switch (_context2.prev = _context2.next) {
case 0:
portId = PORT_MAP.get(port);
if (!(portId === undefined)) {
_context2.next = 3;
break;
}
throw new Error('The given port is not connected.');
case 3:
_context2.next = 5;
return call('disconnect', {
portId: portId
});
case 5:
case "end":
return _context2.stop();
}
return _regeneratorRuntime.wrap(function _callee2$(_context2) {
while (1) switch (_context2.prev = _context2.next) {
case 0:
portId = PORT_MAP.get(port);
if (!(portId === undefined)) {
_context2.next = 3;
break;
}
throw new Error('The given port is not connected.');
case 3:
_context2.next = 5;
return call('disconnect', {
portId: portId
});
case 5:
case "end":
return _context2.stop();
}

@@ -95,3 +84,3 @@ }, _callee2);

function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); enumerableOnly && (symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; })), keys.push.apply(keys, symbols); } return keys; }
function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys(Object(source), !0).forEach(function (key) { _defineProperty__default["default"](target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }
function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys(Object(source), !0).forEach(function (key) { _defineProperty(target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }
var ONGOING_REQUESTS = new WeakMap();

@@ -162,6 +151,6 @@ var createOrGetOngoingRequests = function createOrGetOngoingRequests(sender) {

for (var _i = 0, _Object$entries = Object.entries(fullBrokerImplementation); _i < _Object$entries.length; _i++) {
var _Object$entries$_i = _slicedToArray__default["default"](_Object$entries[_i], 2),
var _Object$entries$_i = _slicedToArray(_Object$entries[_i], 2),
key = _Object$entries$_i[0],
handler = _Object$entries$_i[1];
functions = _objectSpread(_objectSpread({}, functions), {}, _defineProperty__default["default"]({}, key, handler({
functions = _objectSpread(_objectSpread({}, functions), {}, _defineProperty({}, key, handler({
call: call,

@@ -177,4 +166,2 @@ notify: notify

Object.defineProperty(exports, '__esModule', { value: true });
}));

@@ -12,25 +12,25 @@ {

"dependencies": {
"@babel/runtime": "^7.20.6",
"fast-unique-numbers": "^6.0.25",
"@babel/runtime": "^7.20.7",
"fast-unique-numbers": "^7.0.0",
"tslib": "^2.4.1",
"worker-factory": "^6.0.73"
"worker-factory": "^6.0.74"
},
"description": "A little factory function to create a broker for a JSON-RPC based Web Worker.",
"devDependencies": {
"@babel/core": "^7.20.5",
"@babel/core": "^7.20.12",
"@babel/plugin-external-helpers": "^7.18.6",
"@babel/plugin-transform-runtime": "^7.19.6",
"@babel/preset-env": "^7.20.2",
"@commitlint/cli": "^17.3.0",
"@commitlint/config-angular": "^17.3.0",
"@rollup/plugin-babel": "^5.3.1",
"@commitlint/cli": "^17.4.2",
"@commitlint/config-angular": "^17.4.2",
"@rollup/plugin-babel": "^6.0.3",
"chai": "^4.3.7",
"commitizen": "^4.2.5",
"commitizen": "^4.2.6",
"cz-conventional-changelog": "^3.3.0",
"eslint": "^8.28.0",
"eslint-config-holy-grail": "^52.0.33",
"eslint": "^8.31.0",
"eslint-config-holy-grail": "^55.0.1",
"grunt": "^1.5.3",
"grunt-cli": "^1.4.3",
"grunt-sh": "^0.2.0",
"husky": "^8.0.2",
"husky": "^8.0.3",
"karma": "^6.4.1",

@@ -45,14 +45,14 @@ "karma-chrome-launcher": "^3.1.1",

"load-grunt-config": "^4.0.1",
"mocha": "^10.1.0",
"prettier": "^2.8.0",
"mocha": "^10.2.0",
"prettier": "^2.8.3",
"pretty-quick": "^3.1.3",
"rimraf": "^3.0.2",
"rollup": "^2.79.1",
"sinon": "^14.0.2",
"rimraf": "^4.0.4",
"rollup": "^3.10.0",
"sinon": "^15.0.1",
"sinon-chai": "^3.7.0",
"ts-loader": "^9.4.2",
"tsconfig-holy-grail": "^11.1.36",
"tsconfig-holy-grail": "^12.0.0",
"tslint": "^6.1.3",
"tslint-config-holy-grail": "^53.2.34",
"typescript": "^4.9.3",
"tslint-config-holy-grail": "^54.0.0",
"typescript": "^4.9.4",
"webpack": "^5.75.0"

@@ -80,3 +80,3 @@ },

"types": "build/es2019/module.d.ts",
"version": "3.0.72"
"version": "3.0.73"
}

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc