dynamically show infrastructure

Author: HaoyL666

app/containers/Inspect.jsx

@@ -48,7 +48,7 @@ const Inspect = () => {
 
 
 
-        fetch('http://localhost:1111/api/data')
+        fetch('http://localhost:1111/api/kuberData')
             .then(r => r.text())
             .then(d3.csvParse)
             .then(data => {

chronos_npm_package/server/fileControllers.js

@@ -0,0 +1,35 @@
+const { Parser } = require('@json2csv/plainjs');
+const fs = require('fs');
+const { convertArrayToCSV } = require('convert-array-to-csv');
+const converter = require('convert-array-to-csv');
+
+const fileControllers = {};
+
+fileControllers.saveCSV = (req, res, next) => {
+    console.log('saveCSV endpoint hit');
+    const data = res.locals.data;
+
+    try {
+        // const parser = new Parser();
+        // const csv = parser.parse(data);
+        const csv = convertArrayToCSV(data);
+        console.log(csv);
+
+        fs.writeFile('./output.csv', csv, (err) => {
+            if (err) {
+                console.log('error: ', err);
+                return res.status(500).send('Error');
+            }
+            console.log('data saved');
+            next();
+
+        })
+    } catch (err) {
+        console.log('error: ', err);
+        return next(err);
+    };
+}
+
+
+
+module.exports = fileControllers;

chronos_npm_package/server/kuberControllers.js

@@ -112,28 +112,34 @@ kuberControllers.getResources = async (req, res, next) => {
                 }
 
             }
-
-            // const podRes = await coreV1Api.listNamespacedPod('default');
-            // //console.log('Pods: ', podRes.body.items[0]);
-            // for (let pod of podRes.body.items) {
-            //     //console.log('Pod: ', pod);
-            //     for (let d of deployments) {
-            //         if (pod.metadata.labels.app === d.app) {
-            //             d.services[service.metadata.name].push(pod.metadata.name);
-            //         }
-            //     }
-            // }
-
-            // }
-            // }
-
-
         }
         console.log('final deployments: ', deployments);
         for (let d of deployments) {
             console.log('pods: ', d.services);
         }
 
+        const data = [];
+        data.push({ size: '', path: 'default' })
+        for (let d of deployments) {
+            const obj = {};
+            for (let s in d.services) {
+                let path = 'default/' + 'service: ' + s
+                for (let p of d.services[s]) {
+                    let path = 'default/' + 'service: ' + s
+                    path += '/pod: ' + p;
+                    data.push({ size: '', path: path })
+                }
+                path = 'default/' + 'service: ' + s
+                data.push({ size: '', path: path })
+            }
+
+
+        }
+
+        console.log('data: ', data);
+        res.locals.data = data;
+        next();
+
 
     } catch (err) {
         console.log('Error: ', err)

chronos_npm_package/server/output.csv

@@ -0,0 +1,11 @@
+size,path
+"",default
+"",default/service: grafana/pod: grafana-85d768d55b-jkr84
+"",default/service: grafana
+"",default/service: frontend/pod: nginx-frontend-55b44fbc7-q4glh
+"",default/service: frontend/pod: nginx-frontend-55b44fbc7-s47v4
+"",default/service: frontend
+"",default/service: backend/pod: node-backend-d597768c-rtwwx
+"",default/service: backend
+"",default/service: prometheus-service/pod: prometheus-deployment-96898bbc9-km5cf
+"",default/service: prometheus-service

chronos_npm_package/server/package-lock.json

@@ -10,8 +10,10 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
+    "@json2csv/plainjs": "^7.0.2",
     "@kubernetes/client-node": "^0.18.1",
+    "convert-array-to-csv": "^2.0.0",
     "cors": "^2.8.5",
     "express": "^4.18.2"
   }
-}
+}

chronos_npm_package/server/package.json

@@ -5,6 +5,7 @@ const port = 1111;
 const utilities = require('../controllers/utilities');
 const fs = require('fs');
 const kuberControllers = require('./kuberControllers');
+const fileControllers = require('./fileControllers');
 
 
 app.use(cors());
@@ -45,9 +46,17 @@ app.get('/api/data', async (req, res) => {
 });
 
 
-app.get('/api/getData', kuberControllers.getResources, (req, res) => {
-    console.log('getData endpoint hit');
-    return res.status(200).send('getData endpoint hit');
+app.get('/api/kuberData', kuberControllers.getResources, fileControllers.saveCSV, (req, res) => {
+    console.log('kuberData endpoint hit');
+    fs.readFile('./output.csv', 'utf8', (err, data) => {
+        if (err) {
+            console.log('error: ', err);
+            return res.status(500).send('Error');
+
+        }
+        console.log('data: ', data);
+        return res.status(200).send(data);
+    });
 });