Add support for performance storage on worker pool

Update poolifier to the latest version supporting the definition of a message
handler on the workers.

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>

diff --git a/package-lock.json b/package-lock.json
index 54efe9e720f65d85b92616286db5439fc6fe0c49..d370896dc4eb720006a2fc9dcd121dc2d3b0f5cb 100644 (file)
--- a/package-lock.json
+++ b/package-lock.json
@@ -11791,9 +11791,9 @@
       }
     },
     "poolifier": {
-      "version": "2.0.2",
-      "resolved": "https://registry.npmjs.org/poolifier/-/poolifier-2.0.2.tgz",
-      "integrity": "sha512-qibRFXZlhYJYf/jIoayoOb31S8EeMDF89H9ujOQh1xOxLreYZ0EzCEnnOR8OdpdAxyl+JKyt7sgFLHK78WTV5w=="
+      "version": "2.1.0",
+      "resolved": "https://registry.npmjs.org/poolifier/-/poolifier-2.1.0.tgz",
+      "integrity": "sha512-tUYviyPvVLnnxdL0ROKwTohZfbf4HGldRwO2Qw4X0wrO/X3eZIbs5OELW7tMqPN3BdmbYI7JdIWfw4woQRf+rQ=="
     },
     "postcss": {
       "version": "8.2.15",

diff --git a/package.json b/package.json
index 018fb963d21c9feb2820da8663bb0b1863a852d1..88d41d82afc2cc4e293e19b6d4ead49c6d8a03fc 100644 (file)
--- a/package.json
+++ b/package.json
@@ -67,7 +67,7 @@
     "chalk": "^4.1.2",
     "mongodb": "^4.1.1",
     "mysql2": "^2.3.0",
-    "poolifier": "^2.0.2",
+    "poolifier": "^2.1.0",
     "reflect-metadata": "^0.1.13",
     "source-map-support": "^0.5.19",
     "sqlite3": "^5.0.2",

diff --git a/src/worker/WorkerFactory.ts b/src/worker/WorkerFactory.ts
index 65d2f4d4050c761c4ffb69fe323be00449141a6a..d97e9604da5fe987eb63d0ce556ed6325fd391d8 100644 (file)
--- a/src/worker/WorkerFactory.ts
+++ b/src/worker/WorkerFactory.ts
@@ -21,7 +21,7 @@ export default class WorkerFactory {
     options = options ?? {} as WorkerOptions;
     options.startDelay = options.startDelay ?? Constants.WORKER_START_DELAY;
     options.poolOptions = options?.poolOptions ?? {} as PoolOptions<Worker>;
-    // options?.messageHandler && options.poolOptions.messageHandler = options.messageHandler;
+    options?.messageHandler && (options.poolOptions.messageHandler = options.messageHandler);
     let workerImplementation: WorkerAbstract = null;
     switch (workerProcessType) {
       case WorkerProcessType.WORKER_SET: