Add WSS tests

.github/workflows/registry-build-publish.yaml

@@ -77,6 +77,7 @@ jobs:
       - name: Execute tests
         run: |
           export MQTTS_TEST_URL=${{ secrets.MQTTS_URL }}
+          export WSS_TEST_URL=${{ secrets.WSS_URL }}
           yarn test
 
   build-and-push-images:

.github/workflows/registry-pr-purge.yaml

@@ -3,7 +3,6 @@ name: Purge Pull Request Image
 # https://docs.github.com/en/actions/reference/events-that-trigger-workflows#registry_package
 # Run cleanup job if a new package was published or updated
 on:
-  workflow_dispatch:
   pull_request:
     types: [closed]
 
@@ -17,5 +16,4 @@ jobs:
           token: ${{ secrets.GHCR_TOKEN}}
           organization: ${{ github.repository_owner}}
           container: ${{ github.event.repository.name }}
-          tag-regex: /pr-${{github.event.pull_request.number}}$/
-          dry-run: true
+          tag-regex: pr-${{github.event.pull_request.number}}$

.github/workflows/registry-purge.yaml

@@ -3,7 +3,6 @@ name: Docker Registry Cleanup
 # https://docs.github.com/en/actions/reference/events-that-trigger-workflows#registry_package
 # Run cleanup job if a new package was published or updated
 on:
-  workflow_dispatch:
   registry_package:
 
 jobs:

config/custom-environment-variables.json

@@ -13,5 +13,8 @@
   },
   "mqtts_test_client": {
     "url": "MQTTS_TEST_URL"
+  },
+  "wss_test_client": {
+    "url": "WSS_TEST_URL"
   }
 }

config/default.json

@@ -13,5 +13,8 @@
   },
   "mqtts_test_client:": {
     "url": ""
+  },
+  "wss_test_client:": {
+    "url": ""
   }
 }

test/helpers/wss.js

@@ -0,0 +1,29 @@
+'use strict';
+
+const config = require('config').get('wss_test_client');
+
+module.exports = function wssBox (
+  // parameter destructuring
+  { enabled, url, topic, connectionOptions, decodeOptions, messageFormat } = {
+    // defaults
+    enabled: true,
+    url: config.get('url'),
+    topic: 'generalTestTopic',
+    messageFormat: 'csv',
+  }
+) {
+  return {
+    name: 'wssTestSenseBox',
+    location: [7.62, 51.96],
+    exposure: 'outdoor',
+    model: 'homeEthernet',
+    mqtt: {
+      enabled,
+      url,
+      topic,
+      connectionOptions,
+      decodeOptions,
+      messageFormat,
+    },
+  };
+};

test/test-ws.js

@@ -8,6 +8,7 @@ const expect = require('chai').expect,
     Box,
   } = require('@sensebox/opensensemap-api-models'),
   wsBox = require('./helpers/ws'),
+  wssBox = require('./helpers/wss'),
   mqttClient = require('../src/client'),
   mqtt = require('mqtt');
 
@@ -30,7 +31,7 @@ describe('ws client', function () {
           );
           setTimeout(() => {
             resolve();
-          }, 100);
+          }, 1000);
         }, 100);
       });
     });
@@ -46,3 +47,39 @@ describe('ws client', function () {
     }
   });
 });
+
+describe('wss client', function () {
+  let testBox;
+  before(async function () {
+    await connect(dbConnectionString({ db: 'mqttTest' }));
+
+    testBox = await Box.initNew(wssBox());
+    mqttClient.connect(testBox);
+    const mqclient = mqtt.connect(testBox.integrations.mqtt.url);
+
+    return new Promise((resolve) => {
+      mqclient.on('connect', () => {
+        setTimeout(() => {
+          mqclient.subscribe(testBox.integrations.mqtt.topic);
+          mqclient.publish(
+            testBox.integrations.mqtt.topic,
+            testBox.sensors.map((s) => `${s._id},12`).join('\n')
+          );
+          setTimeout(() => {
+            resolve();
+          }, 1000);
+        }, 100);
+      });
+    });
+  });
+
+  it('should accept measurements via wss message', async function () {
+    const box = await Box.findBoxById(testBox._id, {
+      onlyLastMeasurements: true,
+    });
+
+    for (const sensor of box.sensors) {
+      expect(sensor.lastMeasurement.value).equal('12');
+    }
+  });
+});