From b2321a7268da7cfa61cc6e6e538239fb9f000be9 Mon Sep 17 00:00:00 2001
From: liamcottle <liam@liamcottle.com>
Date: Fri, 7 Jun 2024 00:02:57 +1200
Subject: [PATCH] add power metrics api

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

diff --git a/src/index.js b/src/index.js
index 72d23a9..1070294 100644
--- a/src/index.js
+++ b/src/index.js
@@ -251,6 +251,50 @@ app.get('/api/v1/nodes/:nodeId/environment-metrics', async (req, res) => {
     }
 });
 
+app.get('/api/v1/nodes/:nodeId/power-metrics', async (req, res) => {
+    try {
+
+        const nodeId = parseInt(req.params.nodeId);
+        const count = req.query.count ? parseInt(req.query.count) : undefined;
+
+        // find node
+        const node = await prisma.node.findFirst({
+            where: {
+                node_id: nodeId,
+            },
+        });
+
+        // make sure node exists
+        if(!node){
+            res.status(404).json({
+                message: "Not Found",
+            });
+            return;
+        }
+
+        // get latest power metrics
+        const powerMetrics = await prisma.powerMetric.findMany({
+            where: {
+                node_id: node.node_id,
+            },
+            orderBy: {
+                id: 'desc',
+            },
+            take: count,
+        });
+
+        res.json({
+            power_metrics: powerMetrics,
+        });
+
+    } catch(err) {
+        console.error(err);
+        res.status(500).json({
+            message: "Something went wrong, try again later.",
+        });
+    }
+});
+
 app.get('/api/v1/nodes/:nodeId/mqtt-metrics', async (req, res) => {
     try {