From 925c9f9008ac3e30b6a05df30fa710e07a2f430c Mon Sep 17 00:00:00 2001
From: arychagov <a.rychagov@sibsci.ru>
Date: Wed, 9 Jul 2025 15:44:46 +0700
Subject: [PATCH] error endpoint

---
 ToreksBackend/src/routes/main.route.ts | 39 +++++++++++++++++++++++---
 1 file changed, 35 insertions(+), 4 deletions(-)

diff --git a/ToreksBackend/src/routes/main.route.ts b/ToreksBackend/src/routes/main.route.ts
index dc88013..94530d9 100644
--- a/ToreksBackend/src/routes/main.route.ts
+++ b/ToreksBackend/src/routes/main.route.ts
@@ -5,19 +5,20 @@ const router = Router();
 
 router.post('/data', async (req, res) => {
     try {
-        const { timestamp, num_set, ch, data, block, dev_name } = req.body;
+        const { timestamp, num_set, channel, data, block, dev_name } = req.body;
 
-        if (!timestamp || !num_set || !ch || !Array.isArray(data) || !dev_name || !block) {
+        if (!timestamp || !num_set || !channel || !Array.isArray(data) || !dev_name || !block) {
+            // console.error(req.body);
             res.status(400).json({ error: 'Invalid payload' });
             return
         }
 
         const point = new Point('device_data')
             .tag('dev_name', dev_name)
-            .tag('ch', ch.toString())
+            .tag('channel', channel.toString())
             .tag('block', block.toString())
             .intField('num_set', num_set)
-            .timestamp(new Date(Date.now()));
+            .timestamp(new Date(timestamp));
 
         data.forEach((value, index) => {
             point.floatField(`data${index}`, value);
@@ -35,4 +36,34 @@ router.post('/data', async (req, res) => {
     }
 });
 
+router.post('/error', async (req, res) => {
+ try {
+     const { timestamp, num_set, channel, dev_name, sys_error, fiber_error } = req.body;
+
+     if (!timestamp || !num_set || !channel || !sys_error || !dev_name || !fiber_error) {
+         // console.error(req.body);
+         res.status(400).json({ error: 'Invalid payload' });
+         return
+     }
+
+     // console.log(req.body);
+
+     const point = new Point('device_error')
+            .tag('dev_name', dev_name)
+            .tag("channel", channel.toString())
+            .intField('num_set', num_set)
+            .stringField('sys_error', sys_error)
+            .stringField('fiber_error', fiber_error)
+            .timestamp(new Date(timestamp));
+
+     writeApi.writePoint(point);
+     await writeApi.flush();
+     res.status(200).json({ message: 'Error saved' });
+
+ } catch (err) {
+    console.error('Error writing to InfluxDB', err);
+    res.status(500).json({ error: 'Server error' });
+ }
+});
+
 export default router;