fix regular mode 3

Author: DenysKuchma

lib/command/workers/runTests.js

@@ -215,17 +215,33 @@ initPromise = (async function () {
       await new Promise(resolve => setTimeout(resolve, 100))
       // Remove message listener before closing to prevent event loop hanging
       if (global.parentMessageHandler) {
-        parentPort?.off('message', global.parentMessageHandler)
+        try {
+          parentPort?.off('message', global.parentMessageHandler)
+        } catch (err) {
+          // Ignore errors when removing listener
+        }
+      }
+      try {
+        parentPort?.close()
+      } catch (err) {
+        // Ignore errors when closing port
       }
-      parentPort?.close()
     } else {
       // No tests to run, close the worker
       console.error(`[Worker ${workerIndex}] ERROR: No tests found after filtering! Assigned ${tests.length} UIDs but none matched.`)
       // Remove message listener before closing to prevent event loop hanging
       if (global.parentMessageHandler) {
-        parentPort?.off('message', global.parentMessageHandler)
+        try {
+          parentPort?.off('message', global.parentMessageHandler)
+        } catch (err) {
+          // Ignore errors when removing listener
+        }
+      }
+      try {
+        parentPort?.close()
+      } catch (err) {
+        // Ignore errors when closing port
       }
-      parentPort?.close()
     }
   } catch (err) {
     if (global.container?.tsFileMapping && fixErrorStack) {

lib/workers.js

@@ -691,6 +691,7 @@ class Workers extends EventEmitter {
           break
         case event.step.finished:
           this.emit(event.step.finished, message.data)
+          event.dispatcher.emit(event.step.finished, message.data)
           break
         case event.step.started:
           this.emit(event.step.started, message.data)
@@ -708,6 +709,7 @@ class Workers extends EventEmitter {
           // Hook failures are already reported as test failures by the worker
           // Just emit the hook.failed event for listeners
           this.emit(event.hook.failed, message.data)
+          event.dispatcher.emit(event.hook.failed, message.data)
           break
 
       }
@@ -772,20 +774,16 @@ class Workers extends EventEmitter {
           for (const state of states) {
             if (state.isFailed) {
               this.emit(event.test.failed, deserializeTest(state.data))
-              event.dispatcher.emit(event.test.failed, deserializeTest(state.data))
             } else {
               this.emit(event.test.passed, deserializeTest(state.data))
-              event.dispatcher.emit(event.test.passed, deserializeTest(state.data))
             }
           }
         } else {
           // For non-retries (like step failures), emit only the final state
           if (lastState.isFailed) {
             this.emit(event.test.failed, deserializeTest(lastState.data))
-            event.dispatcher.emit(event.test.failed, deserializeTest(lastState.data))
           } else {
             this.emit(event.test.passed, deserializeTest(lastState.data))
-            event.dispatcher.emit(event.test.passed, deserializeTest(lastState.data))
           }
         }
       }