add getter for measurements

src/api/sensor/controller.js

@@ -5,9 +5,10 @@ import City from "../../models/city";
 import {
   getBySensor,
   getHistoryByDate,
-  getLastValuesByDate,
   getLastValueTypeByDate,
+  getLastValuesByDate,
   getMaxValuesByDate,
+  getMeasurements,
   getMessagesByDate,
 } from "../../models/measurement";
 import logger from "../../utils/logger";
@@ -274,6 +275,23 @@ export default {
     try {
       const result = await getBySensor(sensor, start, end);
 
+      res.send({
+        result,
+      });
+    } catch (error) {
+      logger.error(error.toString());
+      res.send({
+        error: "Error",
+      });
+    }
+  },
+  async measurements(req, res) {
+    const start = req.params.start;
+    const end = req.params.end;
+
+    try {
+      const result = await getMeasurements(start, end);
+
       res.send({
         result,
       });

src/api/sensor/route.js

@@ -10,6 +10,7 @@ router.get("/messages/:start/:end", controller.messages);
 router.get("/max/:start/:end/:type", controller.max);
 router.get("/csv/:start/:end/:city", controller.csv);
 router.get("/json/:start?/:end?", controller.json);
+router.get("/measurements/:start/:end", controller.measurements);
 router.get("/:sensor/:start/:end", controller.sensor);
 
 export default router;

src/models/measurement.js

@@ -379,3 +379,22 @@ export async function getBySensor(sensor_id, start, end) {
     };
   });
 }
+
+export async function getMeasurements(start, end) {
+  const rows = await Measurement.find(
+    {
+      timestamp: {
+        $gt: start,
+        $lt: end,
+      },
+    },
+    { measurement: 1 }
+  ).lean();
+  let res = [];
+  for (const item of rows) {
+    if (item.measurement) {
+      res = [...new Set([...res, ...Object.keys(item.measurement)])];
+    }
+  }
+  return res;
+}