fix: add mutex to ensure correct result submission in multi-threaded tests

- Implemented a mutex to prevent duplicate result submissions when running tests in multiple threads.
- Ensured thread-safe result handling for improved reliability.

Author: gibiw

package-lock.json

@@ -1,3 +1,10 @@
+# [email protected]
+
+## What's new
+
+Added a mutex to ensure correct result submission when running tests in multiple threads, preventing potential
+duplication.
+
 # [email protected]
 
 ## What's new

qase-javascript-commons/changelog.md

@@ -1,6 +1,6 @@
 {
   "name": "qase-javascript-commons",
-  "version": "2.2.11",
+  "version": "2.2.12",
   "description": "Qase JS Reporters",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -34,7 +34,8 @@
     "mime-types": "^2.1.33",
     "qaseio": "~2.4.0",
     "strip-ansi": "^6.0.1",
-    "uuid": "^9.0.0"
+    "uuid": "^9.0.0",
+    "async-mutex": "~0.5.0"
   },
   "devDependencies": {
     "@jest/globals": "^29.5.0",

qase-javascript-commons/package.json

@@ -33,6 +33,7 @@ import { QaseError } from '../utils/qase-error';
 import { LoggerInterface } from '../utils/logger';
 import axios from 'axios';
 import { StateManager } from '../state/state';
+import { Mutex } from 'async-mutex';
 
 const defaultChunkSize = 200;
 
@@ -164,6 +165,8 @@ export class TestOpsReporter extends AbstractReporter {
    */
   private isTestRunReady = false;
 
+  private mutex = new Mutex();
+
   /**
    * @param {LoggerInterface} logger
    * @param {ReporterOptionsType & TestOpsOptionsType} options
@@ -224,18 +227,24 @@ export class TestOpsReporter extends AbstractReporter {
       }
     }
 
-    await super.addTestResult(result);
+    const release = await this.mutex.acquire();
+    try {
 
-    if (!this.isTestRunReady) {
-      return;
-    }
+      await super.addTestResult(result);
+
+      if (!this.isTestRunReady) {
+        return;
+      }
 
-    const countOfResults = this.batchSize + this.firstIndex;
+      const countOfResults = this.batchSize + this.firstIndex;
 
-    if (this.results.length >= countOfResults) {
-      const firstIndex = this.firstIndex;
-      this.firstIndex = countOfResults;
-      await this.publishResults(this.results.slice(firstIndex, countOfResults));
+      if (this.results.length >= countOfResults) {
+        const firstIndex = this.firstIndex;
+        this.firstIndex = countOfResults;
+        await this.publishResults(this.results.slice(firstIndex, countOfResults));
+      }
+    } finally {
+      release();
     }
   }
 
@@ -328,7 +337,12 @@ export class TestOpsReporter extends AbstractReporter {
    * @returns {Promise<void>}
    */
   public async publish(): Promise<void> {
-    await this.sendResults();
+    const release = await this.mutex.acquire();
+    try {
+      await this.sendResults();
+    } finally {
+      release();
+    }
     await this.complete();
   }