refactor: improve messaging worker id check error message

Signed-off-by: Jérôme Benoit <[email protected]>

Author: jerome-benoit

deno.json

@@ -3,9 +3,7 @@
   "version": "0.5.3",
   "exports": "./src/mod.ts",
   "compilerOptions": {
-    "lib": [
-      "deno.worker"
-    ],
+    "lib": ["deno.worker"],
     "strict": true
   },
   "tasks": {
@@ -26,9 +24,7 @@
     "documentation": "deno doc ./src/mod.ts"
   },
   "test": {
-    "include": [
-      "./tests/**/*.test.mjs"
-    ]
+    "include": ["./tests/**/*.test.mjs"]
   },
   "fmt": {
     "semiColons": false,
@@ -41,18 +37,8 @@
     "@std/testing": "jsr:@std/testing@^1.0.14"
   },
   "publish": {
-    "include": [
-      "LICENSE",
-      "README.md",
-      "deno.json",
-      "src/**/*.ts"
-    ]
+    "include": ["LICENSE", "README.md", "deno.json", "src/**/*.ts"]
   },
   "lock": false,
-  "exclude": [
-    "./coverage",
-    "./dist/browser",
-    "./dist/esm",
-    "./npm"
-  ]
+  "exclude": ["./coverage", "./dist/browser", "./dist/esm", "./npm"]
 }

src/pools/abstract-pool.ts

@@ -546,15 +546,19 @@ 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()}`,
       )
     }
   }

src/worker/abstract-worker.ts

@@ -468,11 +468,17 @@ 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}`,
+        `Message worker id ${message.workerId.toString()} does not match the worker id ${this.id}: ${
+          JSON.stringify(
+            message,
+          )
+        }`,
       )
     }
   }