]> Piment Noir Git Repositories - poolifier.git/commitdiff
refactor: improve messaging worker id check error message
authorJérôme Benoit <jerome.benoit@piment-noir.org>
Mon, 7 Jul 2025 18:57:22 +0000 (20:57 +0200)
committerJérôme Benoit <jerome.benoit@piment-noir.org>
Mon, 7 Jul 2025 18:57:22 +0000 (20:57 +0200)
Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
src/pools/abstract-pool.ts
src/worker/abstract-worker.ts

index 3f146f8ae98cf1f3d625fbe762454b4f6166b295..43b1a1d6019000c73a8bc263a3672e3bf1eee809 100644 (file)
@@ -1469,11 +1469,13 @@ export abstract class AbstractPool<
    */
   private checkMessageWorkerId (message: MessageValue<Data | Response>): void {
     if (message.workerId == null) {
-      throw new Error('Worker message received without worker id')
+      throw new Error(
+        `Worker message '${JSON.stringify(message)}' received without worker id`
+      )
     }
     if (this.getWorkerNodeKeyByWorkerId(message.workerId) === -1) {
       throw new Error(
-        `Worker message received from unknown worker '${message.workerId.toString()}'`
+        `Worker message '${JSON.stringify(message)}' received from unknown worker ${message.workerId.toString()}`
       )
     }
   }
index 49536b0b7bdf21600e63ed1387d665011bc3bac2..084062d2b27874454f2689d3a857b35bda52647c 100644 (file)
@@ -582,11 +582,13 @@ export abstract class AbstractWorker<
    */
   private checkMessageWorkerId (message: MessageValue<Data>): void {
     if (message.workerId == null) {
-      throw new Error('Message worker id is not set')
+      throw new Error(
+        `Message worker id is not set: ${JSON.stringify(message)}`
+      )
     }
     if (message.workerId !== this.id) {
       throw new Error(
-        `Message worker id ${message.workerId.toString()} does not match the worker id ${this.id.toString()}`
+        `Message worker id ${message.workerId.toString()} does not match the worker id ${this.id.toString()}: ${JSON.stringify(message)}`
       )
     }
   }