fix: new method to check if received all suite results

Author: Willian Cardoso

lib/reporter/global-reporter.js

@@ -31,6 +31,7 @@ module.exports = class GlobalReporter {
       endTimestamp: null
     };
   }
+  static totalSuites = 0;
 
   constructor(reporter = DefaultSettings.default_reporter, settings, {openReport = false, reportFileName = null} = {}) {
     this.suiteResults = [];
@@ -67,6 +68,8 @@ module.exports = class GlobalReporter {
   }
 
   addTestSuiteResults(testResults, httpOutput) {
+    GlobalReporter.totalSuites += 1;
+
     testResults = testResults || {};
     const loggerOutput = httpOutput || Logger.collectOutput();
     testResults.httpOutput = loggerOutput.map(item => {
@@ -459,6 +462,25 @@ module.exports = class GlobalReporter {
     return Promise.all(results);
   }
 
+  delay = ms => new Promise(resolve => setTimeout(resolve, ms));
+
+  async waitResultForAllSuites(totalSuitesExpected){
+    const timeout = 30000;
+    const pollInterval = 500;
+    let elapsedTime = 0;
+
+    while (elapsedTime < timeout) {
+      if (GlobalReporter.totalSuites >= totalSuitesExpected) {
+        return;
+      }
+
+      await this.delay(pollInterval);
+      elapsedTime += pollInterval;
+    }
+
+    return;
+  }
+
   save() {
     if (Concurrency.isWorker()) {
       return Promise.resolve();

lib/runner/test-runners/default.js

@@ -130,8 +130,12 @@ class DefaultRunner {
   /**
    * @return {Promise<boolean>}
    */
-  async reportResults() {
+  async reportResults(totalSuitesExpected) {
     if (!this.isTestWorker()) {
+      if (totalSuitesExpected){
+        await this.globalReporter.waitResultForAllSuites(totalSuitesExpected);
+      }
+
       this.printGlobalResults();
       await this.globalReporter.save();
     }
@@ -144,11 +148,12 @@ class DefaultRunner {
    * @return {Promise<number>}
    */
   async runConcurrent(testEnvArray, modules, isTestWorkerEnabled, isSafariEnvPresent) {
+    const totalSuitesExpected = Object.values(modules).reduce((total, currentArray) => total + currentArray.length, 0);
     this.concurrency = new Concurrency(this.settings, this.argv, isTestWorkerEnabled, isSafariEnvPresent);
     this.globalReporter.setupChildProcessListener(this.concurrency);
 
     const exitCode = await this.concurrency.runMultiple(testEnvArray, modules);
-    await this.reportResults();
+    await this.reportResults(totalSuitesExpected);
 
     return exitCode;
   }