@lage-run/worker-threads-pool - npm Package Compare versions

Comparing version 0.4.2 to 0.4.3

CHANGELOG.json

@@ -5,3 +5,24 @@ {
     {
-      "date": "Tue, 01 Nov 2022 20:42:50 GMT",
+      "date": "Tue, 01 Nov 2022 22:25:35 GMT",
+      "tag": "@lage-run/worker-threads-pool_v0.4.3",
+      "version": "0.4.3",
+      "comments": {
+        "patch": [
+          {
+            "author": "[e-mail]",
+            "package": "@lage-run/worker-threads-pool",
+            "commit": "1664f38eca34da2d51b6a581c92caba5fc51e5fd",
+            "comment": "adds import extensions of .js to prepare of esmodule switchover"
+          },
+          {
+            "author": "beachball",
+            "package": "@lage-run/worker-threads-pool",
+            "comment": "Bump @lage-run/logger to v1.2.2",
+            "commit": "1664f38eca34da2d51b6a581c92caba5fc51e5fd"
+          }
+        ]
+      }
+    },
+    {
+      "date": "Tue, 01 Nov 2022 20:43:17 GMT",
       "tag": "@lage-run/worker-threads-pool_v0.4.2",
@@ -21,3 +42,3 @@ "version": "0.4.2",
             "comment": "Bump @lage-run/logger to v1.2.1",
-            "commit": "d93ffd227f46718fafd1062f9107bde2c98d4f37"
+            "commit": "92379d166d2abb696a1080ff3865bb6828f67b03"
           }
@@ -24,0 +45,0 @@ ]

CHANGELOG.md

 # Change Log - @lage-run/worker-threads-pool
 
-This log was last generated on Tue, 01 Nov 2022 20:42:50 GMT and should not be manually modified.
+This log was last generated on Tue, 01 Nov 2022 22:25:35 GMT and should not be manually modified.
 
 <!-- Start content -->
 
+## 0.4.3
+
+Tue, 01 Nov 2022 22:25:35 GMT
+
+### Patches
+
+- adds import extensions of .js to prepare of esmodule switchover ([e-mail])
+- Bump @lage-run/logger to v1.2.2
+
 ## 0.4.2
 
-Tue, 01 Nov 2022 20:42:50 GMT
+Tue, 01 Nov 2022 20:43:17 GMT
 
@@ -11,0 +20,0 @@ ### Patches

lib/AggregatedPool.d.ts

@@ -5,5 +5,5 @@ /// <reference types="node" />
 import type { Worker, WorkerOptions } from "worker_threads";
-import type { Pool } from "./types/Pool";
+import type { Pool } from "./types/Pool.js";
 import type { Logger } from "@lage-run/logger";
-import { WorkerPool } from "./WorkerPool";
+import { WorkerPool } from "./WorkerPool.js";
 interface AggregatedPoolOptions {
@@ -10,0 +10,0 @@ groupBy: (data: any) => string;

lib/AggregatedPool.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.AggregatedPool = void 0;
-const WorkerPool_1 = require("./WorkerPool");
+const WorkerPool_js_1 = require("./WorkerPool.js");
 class AggregatedPool {
@@ -12,3 +12,3 @@ constructor(options) {
         for (const [group, groupMaxWorkers] of maxWorkersByGroup.entries()) {
-            const pool = new WorkerPool_1.WorkerPool({
+            const pool = new WorkerPool_js_1.WorkerPool({
                 maxWorkers: groupMaxWorkers,
@@ -27,3 +27,3 @@ workerOptions,
         if (defaultPoolWorkersCount > 0) {
-            this.defaultPool = new WorkerPool_1.WorkerPool({
+            this.defaultPool = new WorkerPool_js_1.WorkerPool({
                 maxWorkers: defaultPoolWorkersCount,
@@ -30,0 +30,0 @@ workerOptions,

lib/createFilteredStreamTransform.js

@@ -5,3 +5,3 @@ "use strict";
 const stream_1 = require("stream");
-const stdioStreamMarkers_1 = require("./stdioStreamMarkers");
+const stdioStreamMarkers_js_1 = require("./stdioStreamMarkers.js");
 function createFilteredStreamTransform() {
@@ -11,7 +11,7 @@ const transform = new stream_1.Transform({
             let str = chunk.toString();
-            if (str.includes(stdioStreamMarkers_1.START_MARKER_PREFIX)) {
-                str = str.replace(new RegExp(stdioStreamMarkers_1.START_MARKER_PREFIX + "[0-9a-z]{64}\n"), "");
+            if (str.includes(stdioStreamMarkers_js_1.START_MARKER_PREFIX)) {
+                str = str.replace(new RegExp(stdioStreamMarkers_js_1.START_MARKER_PREFIX + "[0-9a-z]{64}\n"), "");
             }
-            if (str.includes(stdioStreamMarkers_1.END_MARKER_PREFIX)) {
-                str = str.replace(new RegExp(stdioStreamMarkers_1.END_MARKER_PREFIX + "[0-9a-z]{64}\n"), "");
+            if (str.includes(stdioStreamMarkers_js_1.END_MARKER_PREFIX)) {
+                str = str.replace(new RegExp(stdioStreamMarkers_js_1.END_MARKER_PREFIX + "[0-9a-z]{64}\n"), "");
             }
@@ -18,0 +18,0 @@ callback(null, str);

lib/index.d.ts

@@ -1,4 +0,4 @@
-export { registerWorker } from "./registerWorker";
-export { WorkerPool } from "./WorkerPool";
-export { AggregatedPool } from "./AggregatedPool";
-export type { Pool } from "./types/Pool";
+export { registerWorker } from "./registerWorker.js";
+export { WorkerPool } from "./WorkerPool.js";
+export { AggregatedPool } from "./AggregatedPool.js";
+export type { Pool } from "./types/Pool.js";

lib/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.AggregatedPool = exports.WorkerPool = exports.registerWorker = void 0;
-var registerWorker_1 = require("./registerWorker");
-Object.defineProperty(exports, "registerWorker", { enumerable: true, get: function () { return registerWorker_1.registerWorker; } });
-var WorkerPool_1 = require("./WorkerPool");
-Object.defineProperty(exports, "WorkerPool", { enumerable: true, get: function () { return WorkerPool_1.WorkerPool; } });
-var AggregatedPool_1 = require("./AggregatedPool");
-Object.defineProperty(exports, "AggregatedPool", { enumerable: true, get: function () { return AggregatedPool_1.AggregatedPool; } });
+var registerWorker_js_1 = require("./registerWorker.js");
+Object.defineProperty(exports, "registerWorker", { enumerable: true, get: function () { return registerWorker_js_1.registerWorker; } });
+var WorkerPool_js_1 = require("./WorkerPool.js");
+Object.defineProperty(exports, "WorkerPool", { enumerable: true, get: function () { return WorkerPool_js_1.WorkerPool; } });
+var AggregatedPool_js_1 = require("./AggregatedPool.js");
+Object.defineProperty(exports, "AggregatedPool", { enumerable: true, get: function () { return AggregatedPool_js_1.AggregatedPool; } });
 //# sourceMappingURL=index.js.map

lib/registerWorker.js

@@ -6,3 +6,3 @@ "use strict";
 const abort_controller_1 = require("abort-controller");
-const stdioStreamMarkers_1 = require("./stdioStreamMarkers");
+const stdioStreamMarkers_js_1 = require("./stdioStreamMarkers.js");
 function registerWorker(fn) {
@@ -23,4 +23,4 @@ worker_threads_1.parentPort === null || worker_threads_1.parentPort === void 0 ? void 0 : worker_threads_1.parentPort.on("message", async (message) => {
         try {
-            process.stdout.write(`${(0, stdioStreamMarkers_1.startMarker)(workerTaskId)}\n`);
-            process.stderr.write(`${(0, stdioStreamMarkers_1.startMarker)(workerTaskId)}\n`);
+            process.stdout.write(`${(0, stdioStreamMarkers_js_1.startMarker)(workerTaskId)}\n`);
+            process.stderr.write(`${(0, stdioStreamMarkers_js_1.startMarker)(workerTaskId)}\n`);
             const results = await fn(task, abortSignal);
@@ -33,4 +33,4 @@ worker_threads_1.parentPort === null || worker_threads_1.parentPort === void 0 ? void 0 : worker_threads_1.parentPort.postMessage({ type: "status", err: undefined, results });
         finally {
-            process.stdout.write(`${(0, stdioStreamMarkers_1.endMarker)(workerTaskId)}\n`);
-            process.stderr.write(`${(0, stdioStreamMarkers_1.endMarker)(workerTaskId)}\n`);
+            process.stdout.write(`${(0, stdioStreamMarkers_js_1.endMarker)(workerTaskId)}\n`);
+            process.stderr.write(`${(0, stdioStreamMarkers_js_1.endMarker)(workerTaskId)}\n`);
         }
@@ -37,0 +37,0 @@ }

lib/WorkerPool.d.ts

@@ -8,6 +8,6 @@ /**
 import { Worker } from "worker_threads";
-import type { Pool } from "./types/Pool";
+import type { Pool } from "./types/Pool.js";
 import type { Readable } from "stream";
 import type { AbortSignal } from "abort-controller";
-import type { WorkerPoolOptions } from "./types/WorkerPoolOptions";
+import type { WorkerPoolOptions } from "./types/WorkerPoolOptions.js";
 interface QueueItem {
@@ -14,0 +14,0 @@ setup?: (worker: Worker, stdout: Readable, stderr: Readable) => void;

lib/WorkerPool.js

@@ -12,5 +12,5 @@ "use strict";
 const async_hooks_1 = require("async_hooks");
-const createFilteredStreamTransform_1 = require("./createFilteredStreamTransform");
+const createFilteredStreamTransform_js_1 = require("./createFilteredStreamTransform.js");
 const readline_1 = require("readline");
-const stdioStreamMarkers_1 = require("./stdioStreamMarkers");
+const stdioStreamMarkers_js_1 = require("./stdioStreamMarkers.js");
 const events_1 = require("events");
@@ -108,3 +108,3 @@ const worker_threads_1 = require("worker_threads");
             return (line) => {
-                if (line.includes((0, stdioStreamMarkers_1.startMarker)(worker[kTaskInfo].id))) {
+                if (line.includes((0, stdioStreamMarkers_js_1.startMarker)(worker[kTaskInfo].id))) {
                     lines = [];
@@ -118,3 +118,3 @@ if (outputType === "stdout") {
                 }
-                else if (line.includes((0, stdioStreamMarkers_1.endMarker)(worker[kTaskInfo].id))) {
+                else if (line.includes((0, stdioStreamMarkers_js_1.endMarker)(worker[kTaskInfo].id))) {
                     resolve();
@@ -138,4 +138,4 @@ }
         this.captureWorkerStdioStreams(worker);
-        worker["filteredStdout"] = worker.stdout.pipe((0, createFilteredStreamTransform_1.createFilteredStreamTransform)());
-        worker["filteredStderr"] = worker.stderr.pipe((0, createFilteredStreamTransform_1.createFilteredStreamTransform)());
+        worker["filteredStdout"] = worker.stdout.pipe((0, createFilteredStreamTransform_js_1.createFilteredStreamTransform)());
+        worker["filteredStderr"] = worker.stderr.pipe((0, createFilteredStreamTransform_js_1.createFilteredStreamTransform)());
         const msgHandler = (data) => {
@@ -142,0 +142,0 @@ var _a;

package.json

 {
   "name": "@lage-run/worker-threads-pool",
-  "version": "0.4.2",
+  "version": "0.4.3",
   "description": "A worker_threads pool implementation based on the official Node.js async_hooks documentation",
@@ -18,3 +18,3 @@ "repository": {
   "dependencies": {
-    "@lage-run/logger": "^1.2.1",
+    "@lage-run/logger": "^1.2.2",
     "abort-controller": "^3.0.0"
@@ -21,0 +21,0 @@ },

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

Improved metrics

Total package byte prevSize

48847

increased by2.12%

Lines of code

788

increased by2.74%

Dependency changes

• Updated@lage-run/logger@^1.2.2