@scalecube/utils - npm Package Compare versions

Comparing version 0.0.2-snapshot.1563284510.9 to 0.0.2-snapshot.1563375651.10

es/connectWorkers.d.ts

 export declare const addWorker: (worker: Worker) => void;
+export declare const removeWorker: (worker: Worker) => void;

es/index.d.ts

 import * as check from './check';
 import { getFullAddress, validateAddress, getAddress } from './address';
 import * as constants from './constants';
-import { addWorker } from './connectWorkers';
-export { check, getFullAddress, validateAddress, constants, getAddress, addWorker };
+import { addWorker, removeWorker } from './connectWorkers';
+export { check, getFullAddress, validateAddress, constants, getAddress, addWorker, removeWorker };

es/index.js

@@ -155,25 +155,30 @@ var assert = function (predicate, msg) {
 }
-var addWorker = function (worker) {
-    worker.addEventListener('message', function (ev) {
-        if (!ev.data.workerId) {
-            ev.data.workerId = 1;
-            if (ev.data.type === 'ConnectWorkerEvent') {
-                workersMap[ev.data.detail.whoAmI] = worker;
+function workerEventHandler(ev) {
+    if (!ev.data.workerId) {
+        ev.data.workerId = 1;
+        if (ev.data.type === 'ConnectWorkerEvent') {
+            // @ts-ignore
+            workersMap[ev.data.detail.whoAmI] = this;
+        }
+        else {
+            var propogateTo = workersMap[ev.data.detail.to] || workersMap[ev.data.detail.address]; // discoveryEvents || rsocketEvents
+            // console.log('worker -> propogateTo', ev.data);
+            if (propogateTo) {
+                // @ts-ignore
+                propogateTo.postMessage(ev.data, ev.ports || undefined);
             }
             else {
-                var propogateTo = workersMap[ev.data.detail.to] || workersMap[ev.data.detail.address]; // discoveryEvents || rsocketEvents
-                // console.log('worker -> propogateTo', ev.data);
-                if (propogateTo) {
-                    // @ts-ignore
-                    propogateTo.postMessage(ev.data, ev.ports || undefined);
-                }
-                else {
-                    // @ts-ignore
-                    postMessage(ev.data, '*', ev.ports || undefined);
-                }
+                // @ts-ignore
+                postMessage(ev.data, '*', ev.ports || undefined);
             }
         }
-    });
+    }
+}
+var addWorker = function (worker) {
+    worker.addEventListener('message', workerEventHandler.bind(worker));
 };
+var removeWorker = function (worker) {
+    worker.removeEventListener('message', workerEventHandler.bind(worker));
+};
 
-export { addWorker, check, constants, getAddress, getFullAddress, validateAddress };
+export { addWorker, check, constants, getAddress, getFullAddress, removeWorker, validateAddress };

lib/connectWorkers.d.ts

 export declare const addWorker: (worker: Worker) => void;
+export declare const removeWorker: (worker: Worker) => void;

lib/index.d.ts

 import * as check from './check';
 import { getFullAddress, validateAddress, getAddress } from './address';
 import * as constants from './constants';
-import { addWorker } from './connectWorkers';
-export { check, getFullAddress, validateAddress, constants, getAddress, addWorker };
+import { addWorker, removeWorker } from './connectWorkers';
+export { check, getFullAddress, validateAddress, constants, getAddress, addWorker, removeWorker };

lib/index.js

@@ -159,24 +159,29 @@ 'use strict';
 }
-var addWorker = function (worker) {
-    worker.addEventListener('message', function (ev) {
-        if (!ev.data.workerId) {
-            ev.data.workerId = 1;
-            if (ev.data.type === 'ConnectWorkerEvent') {
-                workersMap[ev.data.detail.whoAmI] = worker;
+function workerEventHandler(ev) {
+    if (!ev.data.workerId) {
+        ev.data.workerId = 1;
+        if (ev.data.type === 'ConnectWorkerEvent') {
+            // @ts-ignore
+            workersMap[ev.data.detail.whoAmI] = this;
+        }
+        else {
+            var propogateTo = workersMap[ev.data.detail.to] || workersMap[ev.data.detail.address]; // discoveryEvents || rsocketEvents
+            // console.log('worker -> propogateTo', ev.data);
+            if (propogateTo) {
+                // @ts-ignore
+                propogateTo.postMessage(ev.data, ev.ports || undefined);
             }
             else {
-                var propogateTo = workersMap[ev.data.detail.to] || workersMap[ev.data.detail.address]; // discoveryEvents || rsocketEvents
-                // console.log('worker -> propogateTo', ev.data);
-                if (propogateTo) {
-                    // @ts-ignore
-                    propogateTo.postMessage(ev.data, ev.ports || undefined);
-                }
-                else {
-                    // @ts-ignore
-                    postMessage(ev.data, '*', ev.ports || undefined);
-                }
+                // @ts-ignore
+                postMessage(ev.data, '*', ev.ports || undefined);
             }
         }
-    });
+    }
+}
+var addWorker = function (worker) {
+    worker.addEventListener('message', workerEventHandler.bind(worker));
 };
+var removeWorker = function (worker) {
+    worker.removeEventListener('message', workerEventHandler.bind(worker));
+};
 
@@ -188,2 +193,3 @@ exports.addWorker = addWorker;
 exports.getFullAddress = getFullAddress;
+exports.removeWorker = removeWorker;
 exports.validateAddress = validateAddress;

package.json

 {
   "name": "@scalecube/utils",
-  "version": "0.0.2-snapshot.1563284510.9+953926c",
+  "version": "0.0.2-snapshot.1563375651.10+3624ead",
   "private": false,
@@ -39,3 +39,3 @@ "main": "lib/index.js",
   },
-  "gitHead": "953926c8142db148d945a31138b415a1de0827b4"
+  "gitHead": "3624ead74227f7b2ae51cd367fbc2b8eba74f207"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

32319

increased by1.49%

Lines of code

442

increased by3.03%

Number of medium supply chain risk alerts

1

decreased by-50%

No dependency changes