@loaders.gl/worker-utils - npm Package Compare versions

Comparing version 4.0.0-beta.2 to 4.0.0-beta.3

dist/null-worker-node.js

@@ -0,1 +1,3 @@
+"use strict";
+
 // src/lib/async-queue/async-queue.ts
@@ -8,8 +10,14 @@ var AsyncQueue = class {
   }
+  /** Return an async iterator for this queue */
   [Symbol.asyncIterator]() {
     return this;
   }
+  /** Push a new value - the async iterator will yield a promise resolved to this value */
   push(value) {
     return this.enqueue(value);
   }
+  /**
+   * Push a new value - the async iterator will yield a promise resolved to this value
+   * Add an error - the async iterator will yield a promise rejected with this value
+   */
   enqueue(value) {
@@ -33,2 +41,3 @@ if (this._closed) {
   }
+  /** Indicate that we not waiting for more values - The async iterator will be done */
   close() {
@@ -41,2 +50,4 @@ while (this._settlers.length > 0) {
   }
+  // ITERATOR IMPLEMENTATION
+  /** @returns a Promise for an IteratorResult */
   next() {
@@ -64,3 +75,3 @@ if (this._values.length > 0) {
 function getTransferList(object, recursive = true, transfers) {
-  const transfersSet = transfers || new Set();
+  const transfersSet = transfers || /* @__PURE__ */ new Set();
   if (!object) {
@@ -108,7 +119,11 @@ } else if (isTransferable(object)) {
 }
-var onMessageWrapperMap = new Map();
+var onMessageWrapperMap = /* @__PURE__ */ new Map();
 var WorkerBody = class {
+  /** Check that we are actually in a worker thread */
   static inWorkerThread() {
     return typeof self !== "undefined" || Boolean(getParentPort());
   }
+  /*
+   * (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+   */
   static set onmessage(onMessage) {
@@ -157,2 +172,7 @@ function handleMessage(message) {
   }
+  /**
+   * Send a message from a worker to creating thread (main thread)
+   * @param type
+   * @param payload
+   */
   static postMessage(type, payload) {
@@ -159,0 +179,0 @@ const data = { source: "loaders.gl", type, payload };

dist/null-worker.js

@@ -0,4 +1,8 @@
+"use strict";
 (() => {
   // src/lib/async-queue/async-queue.ts
   var AsyncQueue = class {
+    _values;
+    _settlers;
+    _closed;
     constructor() {
@@ -9,8 +13,14 @@ this._values = [];
     }
+    /** Return an async iterator for this queue */
     [Symbol.asyncIterator]() {
       return this;
     }
+    /** Push a new value - the async iterator will yield a promise resolved to this value */
     push(value) {
       return this.enqueue(value);
     }
+    /**
+     * Push a new value - the async iterator will yield a promise resolved to this value
+     * Add an error - the async iterator will yield a promise rejected with this value
+     */
     enqueue(value) {
@@ -34,2 +44,3 @@ if (this._closed) {
     }
+    /** Indicate that we not waiting for more values - The async iterator will be done */
     close() {
@@ -42,2 +53,4 @@ while (this._settlers.length > 0) {
     }
+    // ITERATOR IMPLEMENTATION
+    /** @returns a Promise for an IteratorResult */
     next() {
@@ -65,3 +78,3 @@ if (this._values.length > 0) {
   function getTransferList(object, recursive = true, transfers) {
-    const transfersSet = transfers || new Set();
+    const transfersSet = transfers || /* @__PURE__ */ new Set();
     if (!object) {
@@ -109,7 +122,11 @@ } else if (isTransferable(object)) {
   }
-  var onMessageWrapperMap = new Map();
+  var onMessageWrapperMap = /* @__PURE__ */ new Map();
   var WorkerBody = class {
+    /** Check that we are actually in a worker thread */
     static inWorkerThread() {
       return typeof self !== "undefined" || Boolean(getParentPort());
     }
+    /*
+     * (type: WorkerMessageType, payload: WorkerMessagePayload) => any
+     */
     static set onmessage(onMessage) {
@@ -158,2 +175,7 @@ function handleMessage(message) {
     }
+    /**
+     * Send a message from a worker to creating thread (main thread)
+     * @param type
+     * @param payload
+     */
     static postMessage(type, payload) {
@@ -160,0 +182,0 @@ const data = { source: "loaders.gl", type, payload };

package.json

 {
   "name": "@loaders.gl/worker-utils",
-  "version": "4.0.0-beta.2",
+  "version": "4.0.0-beta.3",
   "description": "Utilities for running tasks on worker threads",
   "license": "MIT",
+  "type": "module",
   "publishConfig": {
@@ -19,4 +20,11 @@ "access": "public"
   "types": "dist/index.d.ts",
-  "main": "dist/es5/index.js",
-  "module": "dist/esm/index.js",
+  "main": "dist/index.cjs",
+  "module": "dist/index.js",
+  "exports": {
+    ".": {
+      "import": "./dist/index.js",
+      "require": "./dist/index.cjs",
+      "types": "./dist/index.d.ts"
+    }
+  },
   "sideEffects": false,
@@ -45,4 +53,2 @@ "files": [
     "pre-build": "npm run build-worker && npm run build-worker-node",
-    "pre-build-disabled": "npm run build-bundle && npm run build-workers",
-    "build-bundle": "esbuild src/bundle.ts --outfile=dist/dist.min.js",
     "build-worker": "esbuild src/workers/null-worker.ts --outfile=dist/null-worker.js --target=esnext --bundle --sourcemap --define:__VERSION__=\\\"$npm_package_version\\\"",
@@ -54,3 +60,3 @@ "build-worker-node": "esbuild src/workers/null-worker.ts --outfile=dist/null-worker-node.js --platform=node --target=node16 --bundle --sourcemap --define:__VERSION__=\\\"$npm_package_version\\\""
   },
-  "gitHead": "79c2033f755e88e11bc30a04428e3666b177b8fc"
+  "gitHead": "7ba9621cc51c7a26c407086ac86171f35b8712af"
 }

src/lib/library-utils/library-utils.ts

@@ -87,5 +87,12 @@ /* global importScripts */
   if (!isBrowser) {
+    // TODO - Node doesn't yet support dynamic import from https URLs
+    // try {
+    //   return await import(libraryUrl);
+    // } catch (error) {
+    //   console.error(error);
+    // }
     try {
       return node && node.requireFromFile && (await node.requireFromFile(libraryUrl));
-    } catch {
+    } catch (error) {
+      console.error(error); // eslint-disable-line no-console
       return null;
@@ -92,0 +99,0 @@ }

src/lib/node/require-utils.node.ts

@@ -53,3 +53,4 @@ // Fork of https://github.com/floatdrop/require-from-string/blob/master/index.js
   }
-  return require(filename);
+  const code = await fs.readFileSync(filename, 'utf8');
+  return requireFromString(code);
 }
@@ -83,3 +84,4 @@
 
-  const parent = module.parent;
+  const parent = typeof module !== 'undefined' && module?.parent;
+
   // @ts-ignore
@@ -86,0 +88,0 @@ const newModule = new Module(filename, parent);

src/lib/node/worker_threads-browser.ts

@@ -6,3 +6,2 @@ // Browser fills for Node.js built-in `worker_threads` module.
 export class Worker {
-  // eslint-disable-next-line @typescript-eslint/no-empty-function
   terminate() {}
@@ -9,0 +8,0 @@ }

src/lib/worker-farm/worker-pool.ts

@@ -157,2 +157,5 @@ import type {WorkerMessageType, WorkerMessagePayload} from '../../types';
         await job.result;
+      } catch (error) {
+        // eslint-disable-next-line no-console
+        console.error(`Worker exception: ${error}`);
       } finally {
@@ -159,0 +162,0 @@ this.returnWorkerToQueue(workerThread);

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

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

Shell access

Supply chain risk

This module accesses the system shell. Accessing the system shell increases the risk of executing arbitrary code.

Found 1 instance in 1 package

Debug access

Supply chain risk

Uses debug, reflection and dynamic code execution features.

Found 1 instance in 1 package

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Number of low supply chain risk alerts

2

decreased by-66.67%

Number of medium supply chain risk alerts

11

decreased by-38.89%

Is type module

Yes

Worsened metrics

Total package byte prevSize

327015

decreased by-35.98%

Number of package files

133

decreased by-26.92%

Lines of code

4916

decreased by-17.46%

No dependency changes