chore: Correct issue with timeouts when test misconfigured

Author: TimothyJones

packages/case-core/src/core/ReadingCaseContract.ts

@@ -84,7 +84,9 @@ export class ReadingCaseContract extends BaseCaseContract {
     this.initialContext.logger.maintainerDebug(
       `Verifying contract between '${this.currentContract.description.consumerName}' and '${this.currentContract.description.providerName}'. There are '${this.currentContract.examples.length}' examples`,
     );
-    const finishedIndicators = [];
+    const interactionFinishedIndicators: Promise<unknown>[] = [];
+    const interactionFinishers: Array<() => void> = [];
+
     this.currentContract.examples.forEach((example, index) => {
       if (example.result !== 'VERIFIED') {
         throw new CaseCoreError(
@@ -96,11 +98,20 @@ export class ReadingCaseContract extends BaseCaseContract {
       this.initialContext.logger.maintainerDebug(
         `Preparing test framework's callback for: ${names.mockName} `,
       );
-      let exampleFinished: () => void;
 
-      finishedIndicators.push(
-        new Promise<void>((resolve) => {
-          exampleFinished = resolve;
+      interactionFinishedIndicators.push(
+        new Promise<void>((resolve, reject) => {
+          const timeout = setTimeout(() => {
+            this.initialContext.logger.error(
+              `Timeout in interaction[${index}]`,
+            );
+            reject(new Error(names.mockName));
+          }, 30000);
+
+          interactionFinishers[index] = () => {
+            clearTimeout(timeout);
+            resolve();
+          };
         }),
       );
       runTestCb(names.mockName, () =>
@@ -134,16 +145,20 @@ export class ReadingCaseContract extends BaseCaseContract {
             );
           })
           .finally(() => {
+            this.initialContext.logger.deepMaintainerDebug(
+              `Interaction[${index}] type of finisher`,
+              interactionFinishers[index],
+            );
             this.initialContext.logger.maintainerDebug(
               `Interaction[${index}] completed: ${names.mockName}`,
             );
-            exampleFinished();
+            interactionFinishers[index]?.();
           }),
       );
     });
     let publishFinished: () => void;
-
-    finishedIndicators.push(
+    const publishFinishedIndicators = [];
+    publishFinishedIndicators.push(
       new Promise<void>((resolve) => {
         publishFinished = resolve;
       }),
@@ -156,20 +171,25 @@ export class ReadingCaseContract extends BaseCaseContract {
         this.initialContext.logger.maintainerDebug(
           'Test callback for ending record',
         );
-        return this.endRecord().finally(() => {
-          this.initialContext.logger.maintainerDebug(
-            `Publishing contract callback completed`,
-          );
-          publishFinished();
-        });
+        return Promise.allSettled(interactionFinishedIndicators)
+          .then(() => this.endRecord())
+          .finally(() => {
+            this.initialContext.logger.maintainerDebug(
+              `Publishing contract callback completed`,
+            );
+            publishFinished();
+          });
       },
     );
     if (
       this.initialContext['_case:currentRun:context:internals'] &&
       this.initialContext['_case:currentRun:context:internals']
         .asyncVerification
     ) {
-      return Promise.all(finishedIndicators).then(() => {});
+      return Promise.all([
+        ...interactionFinishedIndicators,
+        ...publishFinishedIndicators,
+      ]).then(() => {});
     }
     return undefined;
   }

packages/case-core/src/index.http.request.verification.misconfigured.spec.ts

@@ -1,6 +1,7 @@
 import type * as http from 'node:http';
 
 import { CaseConfigurationError } from '@contract-case/case-plugin-base';
+import { Mutex } from 'async-mutex';
 import type { RunTestCallback } from './core/executeExample/types';
 import type { StateHandlers } from './entities/states/types';
 
@@ -13,7 +14,6 @@ import { ReadingCaseContract } from './core';
 import { readerDependencies } from './connectors/dependencies';
 import { readContract } from './connectors/contractStore/contractReader';
 import { defaultPrinter } from './__tests__/jest/defaultTestPrinter';
-import { Mutex } from 'async-mutex';
 
 describe('Server verification', () => {
   let server: http.Server;