test: mark test-worker-debug as flaky

Also try to make more traceable. PR-URL: #28035 Reviewed-By: Rich Trott <[email protected]> Reviewed-By: Ruben Bridgewater <[email protected]> Reviewed-By: Benjamin Gruenbaum <[email protected]> Reviewed-By: Sam Roberts <[email protected]>

Author: refack

test/parallel/parallel.status

@@ -17,6 +17,8 @@ test-worker-memory: PASS,FLAKY
 # https://github.com/nodejs/node/issues/20750
 test-http2-client-upload: PASS,FLAKY
 test-http2-client-upload-reject: PASS,FLAKY
+# https://github.com/nodejs/node/issues/28106
+test-worker-debug: PASS,FLAKY
 
 [$system==linux]
 

test/parallel/test-worker-debug.js

@@ -91,14 +91,14 @@ class WorkerSession extends EventEmitter{
 this.emit(message.method,message);
 return;
 }
-constcallback=this._requestCallbacks.get(message.id);
-if(callback){
-this._requestCallbacks.delete(message.id);
-if(message.error)
-callback[1](message.error.message);
-else
-callback[0](message.result);
-}
+if(!this._requestCallbacks.has(message.id))
+return;
+const[resolve,reject]=this._requestCallbacks.get(message.id);
+this._requestCallbacks.delete(message.id);
+if(message.error)
+reject(newError(message.error.message));
+else
+resolve(message.result);
 }
 
 asyncwaitForBreakAfterCommand(command,script,line){
@@ -144,7 +144,7 @@ async function testBasicWorkerDebug(session, post){
 assert.strictEqual(waitingForDebugger,true);
 constdetached=waitForWorkerDetach(session,sessionId);
 constworkerSession=newWorkerSession(session,sessionId);
-constcontextEvents=Promise.all([
+constcontextEventPromises=Promise.all([
 waitForEvent(workerSession,'Runtime.executionContextCreated'),
 waitForEvent(workerSession,'Runtime.executionContextDestroyed')
 ]);
@@ -156,9 +156,10 @@ async function testBasicWorkerDebug(session, post){
 'Runtime.runIfWaitingForDebugger',__filename,1);
 awaitworkerSession.waitForBreakAfterCommand(
 'Debugger.resume',__filename,26);// V8 line number is zero-based
-assert.strictEqual(awaitconsolePromise,workerMessage);
+constmsg=awaitconsolePromise;
+assert.strictEqual(msg,workerMessage);
 workerSession.post('Debugger.resume');
-awaitPromise.all([worker,detached,contextEvents]);
+awaitPromise.all([worker,detached,contextEventPromises]);
 }
 
 asyncfunctiontestNoWaitOnStart(session,post){
@@ -252,7 +253,7 @@ async function testWaitForDisconnectInWorker(session, post){
 sessionWithoutWaiting.disconnect();
 }
 
-asyncfunctiontest(){
+(asyncfunctiontest(){
 constsession=newSession();
 session.connect();
 constpost=doPost.bind(null,session);
@@ -264,11 +265,14 @@ async function test(){
 awaitrunWorker(1);
 
 awaittestNoWaitOnStart(session,post);
+
 awaittestTwoWorkers(session,post);
+
 awaittestWaitForDisconnectInWorker(session,post);
 
 session.disconnect();
 console.log('Test done');
-}
-
-test();
+})().catch((err)=>{
+console.error(err);
+process.abort();
+});