simplify integration test folder structure

package.json

@@ -19,7 +19,7 @@
   },
   "homepage": "https://github.com/asyncapi/nodejs-template#readme",
   "scripts": {
-    "test": "rimraf test/temp && jest --modulePathIgnorePatterns='./template'",
+    "test": "rimraf test/temp && jest --forceExit --modulePathIgnorePatterns='./template'",
     "test:updateSnapshot": "rimraf test/temp && jest --updateSnapshot --modulePathIgnorePatterns='./template'",
     "lint": "eslint --max-warnings 0 --config .eslintrc .",
     "lint:fix": "eslint --fix --config .eslintrc .",

test/integration-tests/mqtt/subscribe/nodejs-client/src/api/handlers/smartylighting-streetlights-1-0-event-{streetlightId}-lighting-measured.js → test/integration-tests/mqtt/nodejs-client/src/api/handlers/smartylighting-streetlights-1-0-event-{streetlightId}-lighting-measured.js

@@ -13,6 +13,7 @@ const receiveLightMeasurementMiddlewares = [];
  * @throws {TypeError} If middlewareFn is not a function.
  */
 handler.registerReceiveLightMeasurementMiddleware = (middlewareFn) => {
+  console.log("registering middleware");
   if (typeof middlewareFn !== 'function') {
     throw new TypeError('middlewareFn must be a function');
   }

test/integration-tests/mqtt/publish/package.json → test/integration-tests/mqtt/package.json

@@ -1,7 +1,7 @@
 {
   "config": {
-    "example_name": "mqtt/publish",
-    "root_dir": "../../../.."
+    "example_name": "mqtt",
+    "root_dir": "../../.."
   },
   "scripts": {
     "setup": "npm run generate:client && npm install",

test/integration-tests/mqtt/publish/index.js → test/integration-tests/mqtt/publish-utils.js

@@ -26,7 +26,7 @@ async function waitForMessage() {
  */
 async function setupSubscribe() {
   const mqtt = require('mqtt');
-  const client = mqtt.connect(brokerUrl);
+  const client = mqtt.connect(BROKER_URL);
 
   return new Promise((resolve, reject) => {
     const topic = TURN_ON_TOPIC;

test/integration-tests/mqtt/publish/index.spec.js → test/integration-tests/mqtt/publish.spec.js

@@ -4,15 +4,15 @@ const {
   setupSubscribe,
   setupPublishMiddleware,
   setupPublish,
-} = require('./index');
+} = require('./publish-utils');
 
 // Mocking the console.debug function to prevent console output during testing
 jest.spyOn(global.console, 'debug').mockImplementation(() => {
   return;
 });
 const consoleDebugSpy = jest.spyOn(global.console, 'debug');
 
-describe('MQTT Connection Setup and Message Processing', () => {
+describe('[PUBLISH] MQTT Connection Setup and Message Processing', () => {
   jest.setTimeout(10000);
 
   beforeAll(() => {
@@ -41,8 +41,7 @@ describe('MQTT Connection Setup and Message Processing', () => {
 
     // Parsing and comparing the received JSON payload
     const jsonMessage = JSON.stringify(JSON.parse(message));
-    console.log('bois the json message is ', jsonMessage);
-
     expect(jsonMessage).toBe('{"command":"on"}');
   });
 });
+