unified topic to area_count

akenza-io · Jan 9, 2025 · 4a0d6a9 · 4a0d6a9
1 parent 07a9890
commit 4a0d6a9
Show file tree

Hide file tree

Showing 5 changed files with 28 additions and 28 deletions.
diff --git a/types/vergeSense/cloudConnector/area_count.schema.json b/types/vergeSense/cloudConnector/area_count.schema.json
@@ -0,0 +1,18 @@
+{
+  "$id": "https://akenza.io/vergeSense/cloudConnector/area_count.schema.json",
+  "$schema": "http://json-schema.org/draft-07/schema#",
+  "type": "object",
+  "processingType": "uplink_decoder",
+  "topic": "area_count",
+  "title": "Area count",
+  "properties": {
+    "peopleCount": {
+      "title": "People count",
+      "description": "People in Area",
+      "type": "integer"
+    }
+  },
+  "required": [
+    "peopleCount"
+  ]
+}
diff --git a/types/vergeSense/cloudConnector/meta.json b/types/vergeSense/cloudConnector/meta.json
@@ -13,7 +13,7 @@
   "outputTopics": [
     "occupancy",
     "space_availability",
-    "space_report"
+    "area_count"
   ],
   "encoding": "JSON",
   "connectivity": "HTTP"

diff --git a/types/vergeSense/cloudConnector/space_report.schema.json b/types/vergeSense/cloudConnector/space_report.schema.json
diff --git a/types/vergeSense/cloudConnector/uplink.js b/types/vergeSense/cloudConnector/uplink.js
@@ -3,10 +3,10 @@ function consume(event) {
   const payload = {};
 
   if (event.data.event_type === 'space_report') {
-    topic = 'space_report';
-    payload.personCount = event.data.person_count;
+    topic = 'area_count';
+    payload.peopleCount = event.data.person_count;
 
-    if (payload.personCount > 0) {
+    if (payload.peopleCount > 0) {
       emit('sample', { data: { "occupancy": 2, "occupied": true }, topic: "occupancy" });
     } else {
       emit('sample', { data: { "occupancy": 0, "occupied": false }, topic: "occupancy" });

diff --git a/types/vergeSense/cloudConnector/uplink.spec.js b/types/vergeSense/cloudConnector/uplink.spec.js
@@ -29,12 +29,12 @@ describe("Verge Sense Uplink", () => {
       });
   });
 
-  let spaceReportSchema = null;
+  let areaCountReportSchema = null;
   before((done) => {
     utils
-      .loadSchema(`${__dirname}/space_report.schema.json`)
+      .loadSchema(`${__dirname}/area_count.schema.json`)
       .then((parsedSchema) => {
-        spaceReportSchema = parsedSchema;
+        areaCountReportSchema = parsedSchema;
         done();
       });
   });
@@ -86,10 +86,10 @@ describe("Verge Sense Uplink", () => {
         assert.isNotNull(value);
         assert.typeOf(value.data, "object");
 
-        assert.equal(value.topic, "space_report");
-        assert.equal(value.data.personCount, 0);
+        assert.equal(value.topic, "area_count");
+        assert.equal(value.data.peopleCount, 0);
 
-        utils.validateSchema(value.data, spaceReportSchema, {
+        utils.validateSchema(value.data, areaCountReportSchema, {
           throwError: true,
         });
       });