From fc80d771e8321e871543eaa584a3fcda0bd6228e Mon Sep 17 00:00:00 2001
From: Tilen Komel <me@komelt.dev>
Date: Sun, 4 Aug 2024 16:44:01 +0200
Subject: [PATCH] Added /position-history api endpint

---
 src/index.js | 79 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 79 insertions(+)

diff --git a/src/index.js b/src/index.js
index deefe20..6f8245d 100644
--- a/src/index.js
+++ b/src/index.js
@@ -428,6 +428,85 @@ app.get('/api/v1/nodes/:nodeId/traceroutes', async (req, res) => {
     }
 });
 
+app.get('/api/v1/nodes/:nodeId/position-history', async (req, res) => {
+    try {
+
+        const nodeId = parseInt(req.params.nodeId);
+        const timeFrom = req.query.time_from ? parseInt(req.query.time_from) : new Date().getTime() - 3600 * 1000;
+        const timeTo = req.query.time_to ? parseInt(req.query.time_to) : new Date().getTime();
+
+        const node = await prisma.node.findFirst({
+            where: {
+                node_id: nodeId,
+            },
+        });
+
+        // make sure node exists
+        if(!node){
+            res.status(404).json({
+                message: "Not Found",
+            });
+            return;
+        }
+
+        const positions = await prisma.position.findMany({
+            where: {
+                node_id: nodeId,
+                created_at: {
+                    gte: new Date(timeFrom),
+                    lte: new Date(timeTo),
+                },
+            }
+        });
+
+        const mapReports = await prisma.mapReport.findMany({
+            where: {
+                node_id: nodeId,
+                created_at: {
+                    gte: new Date(timeFrom),
+                    lte: new Date(timeTo),
+                },
+            }
+        });
+        
+        const positionHistory = []
+
+        positions.forEach((position) => {
+            positionHistory.push({
+                node_id: position.node_id,
+                latitude: position.latitude,
+                longitude: position.longitude,
+                altitude: position.altitude,
+                accuracy: position.accuracy,
+                time: position.created_at,
+            });
+        });
+
+        mapReports.forEach((mapReport) => {
+            positionHistory.push({
+                node_id: mapReport.node_id,
+                latitude: mapReport.latitude,
+                longitude: mapReport.longitude,
+                altitude: mapReport.altitude,
+                accuracy: mapReport.accuracy,
+                time: mapReport.created_at,
+            });
+        });
+
+        positionHistory.sort((a, b) => a.time - b.time);
+
+        res.json({
+            position_history: positionHistory,
+        });
+
+    } catch(err) {
+        console.error(err);
+        res.status(500).json({
+            message: "Something went wrong, try again later.",
+        });
+    }
+});
+
 app.get('/api/v1/stats/hardware-models', async (req, res) => {
     try {