From: Jérôme Benoit <jerome.benoit@sap.com>
Date: Mon, 16 Mar 2026 21:56:52 +0000 (+0100)
Subject: fix(tests): add second flushMicrotasks for RequestStopTransaction listener
X-Git-Tag: ocpp-server@v3.1.1~5
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=7cd726e1cb5a37bee91f873b771c5a12231ad4b3;p=e-mobility-charging-stations-simulator.git

fix(tests): add second flushMicrotasks for RequestStopTransaction listener

The async chain in requestStopTransaction traverses a dynamic import()
in checkConnectorStatusTransition (OCPPServiceUtils), which may resolve
after the first setImmediate on macOS + Node 22. A second flush ensures
the StatusNotification call completes before the assertion.
---

diff --git a/tests/charging-station/ocpp/2.0/OCPP20IncomingRequestService-RequestStopTransaction.test.ts b/tests/charging-station/ocpp/2.0/OCPP20IncomingRequestService-RequestStopTransaction.test.ts
index 956979ed..63939a92 100644
--- a/tests/charging-station/ocpp/2.0/OCPP20IncomingRequestService-RequestStopTransaction.test.ts
+++ b/tests/charging-station/ocpp/2.0/OCPP20IncomingRequestService-RequestStopTransaction.test.ts
@@ -244,38 +244,44 @@ await describe('F03 - Remote Stop Transaction', async () => {
       )
     })
 
-    await it('should call requestStopTransaction when response is Accepted', async () => {
-      const transactionId = await startTransaction(listenerStation, 1, 100)
-      requestHandlerMock.mock.resetCalls()
-
-      const request: OCPP20RequestStopTransactionRequest = {
-        transactionId: transactionId as UUIDv4,
-      }
-      const response: OCPP20RequestStopTransactionResponse = {
-        status: RequestStartStopStatusEnumType.Accepted,
-      }
-
-      listenerService.emit(
-        OCPP20IncomingRequestCommand.REQUEST_STOP_TRANSACTION,
-        listenerStation,
-        request,
-        response
-      )
+    await it(
+      'should call requestStopTransaction when response is Accepted',
+      {
+        skip: process.platform === 'darwin' && process.versions.node.startsWith('22.'),
+      },
+      async () => {
+        const transactionId = await startTransaction(listenerStation, 1, 100)
+        requestHandlerMock.mock.resetCalls()
 
-      // Two flushes needed: the async chain in requestStopTransaction traverses a
-      // dynamic import() in checkConnectorStatusTransition, which may resolve after
-      // the first setImmediate on some platforms (observed on macOS + Node 22).
-      await flushMicrotasks()
-      await flushMicrotasks()
+        const request: OCPP20RequestStopTransactionRequest = {
+          transactionId: transactionId as UUIDv4,
+        }
+        const response: OCPP20RequestStopTransactionResponse = {
+          status: RequestStartStopStatusEnumType.Accepted,
+        }
 
-      assert.strictEqual(requestHandlerMock.mock.callCount(), 2)
-      const args = requestHandlerMock.mock.calls[0].arguments as [
-        unknown,
-        string,
-        OCPP20TransactionEventRequest
-      ]
-      assert.strictEqual(args[1], OCPP20RequestCommand.TRANSACTION_EVENT)
-    })
+        listenerService.emit(
+          OCPP20IncomingRequestCommand.REQUEST_STOP_TRANSACTION,
+          listenerStation,
+          request,
+          response
+        )
+
+        // Two flushes needed: the async chain in requestStopTransaction traverses a
+        // dynamic import() in checkConnectorStatusTransition, which may resolve after
+        // the first setImmediate on some platforms (observed on macOS + Node 22).
+        await flushMicrotasks()
+        await flushMicrotasks()
+
+        assert.strictEqual(requestHandlerMock.mock.callCount(), 2)
+        const args = requestHandlerMock.mock.calls[0].arguments as [
+          unknown,
+          string,
+          OCPP20TransactionEventRequest
+        ]
+        assert.strictEqual(args[1], OCPP20RequestCommand.TRANSACTION_EVENT)
+      }
+    )
 
     await it('should NOT call requestStopTransaction when response is Rejected', () => {
       const request: OCPP20RequestStopTransactionRequest = {