X-Git-Url: https://git.josue.xyz/?a=blobdiff_plain;f=src%2Froutes%2Findex.js;h=0bff22eb68a95a1cfc9d41afb92ca62edd1e8855;hb=8bd25d906f766566ceee02d3d70e9890689a4c1a;hp=d4f9b59ffd41841e9b21b2da53cc349945a29955;hpb=777f2058e203bedb244f5a0ee779f6d5177a334f;p=VSoRC%2F.git diff --git a/src/routes/index.js b/src/routes/index.js index d4f9b59..0bff22e 100644 --- a/src/routes/index.js +++ b/src/routes/index.js @@ -4,6 +4,7 @@ const { const router = new Router(); + //renders de las paginas web router.get("/", (req, res) => { res.render("index") @@ -24,7 +25,8 @@ router.get("/stats", (req, res) => { router.get("/topology", (req, res) => { res.render("topology") }); - +let isVsorcUP = false; +let isControllerUP = false; router.get("/topologyMaker", (req, res) => { res.render("topologyMaker") }); @@ -39,6 +41,18 @@ router.get('/free', (req, res) => { }); }); +router.post('/flowdel', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + var flow = JSON.stringify(req.body); + child = exec("curl -X POST -d "+req.body+"localhost:8080/flowdel", function(error, stdout, stderr) { + console.log(stdout); + console.log(req.body); + res.send(req.body); + }); +}); + router.get('/mpstat', (req, res) => { var sys = require('sys') @@ -50,7 +64,6 @@ router.get('/mpstat', (req, res) => { }); }); - router.get('/ifstat', (req, res) => { var sys = require('sys') var exec = require('child_process').exec; @@ -65,8 +78,8 @@ router.get('/showtemp', (req, res) => { var sys = require('sys') var exec = require('child_process').exec; var child; - child = exec("cd /home/pi/scripts && ./gettemp.sh", function(error, stdout, stderr) { - console.log("show temp"); + child = exec("cd /home/pi/scripts && (./multissh.sh \"$(echo $(cat geteverything.sh))\" |grep -v rpi | sort -n -t . -k 1,1 -k 2,2 -k 3,3 -k 4,4)", function(error, stdout, stderr) { + console.log("show temp");//this was modified res.send(stdout); }); }); @@ -90,6 +103,16 @@ router.get('/net', (req, res) => { }); }); +router.get('/rpiping', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + child = exec("cd /home/pi/scripts && ./rpiping.sh", function(error, stdout, stderr) { + console.log("rpiping"); + res.send(stdout); + }); +}); + router.get('/nodes', (req, res) => { var sys = require('sys') var exec = require('child_process').exec; @@ -150,23 +173,80 @@ router.get('/placement', (req, res) => { }); router.get('/getvsorcdata', (req, res) => { + var sys = require('sys') var exec = require('child_process').exec; var child; - child = exec("cd /home/pi/scripts && cat aichivo 2>&1", function(error, stdout, stderr) { + var child2; + child2 = exec("ps aux | grep GRE| grep sudo | grep -v tail| awk {'print $2'}", function(error, stdout, stderr) { + console.log("view status vsorc"); + if (stdout === ""){ + isVsorcUP = false; + }else { + isVsorcUP = true; + } + }); + child = exec("cd /home/pi/scripts && cat aichivo 2>/dev/null", function(error, stdout, stderr) { console.log("getting vsorc data"); - res.send(stdout); + res.send(stdout+"^"+isVsorcUP); }); }); router.get('/getcontrollerdata', (req, res) => { var sys = require('sys') var exec = require('child_process').exec; var child; - child = exec("cd /home/pi/scripts && cat controllerout 2>&1", function(error, stdout, stderr) { + var child2; + child2 = exec("ps aux | grep python | grep ryu | grep -v grep |awk {'print $2'}", function(error, stdout, stderr) { + console.log(stdout); + console.log("view status controller"); + if (stdout === ""){ + isControllerUP = false; + }else { + isControllerUP = true; + } + }); + child = exec("cd /home/pi/scripts && cat controllerout 2>/dev/null", function(error, stdout, stderr) { console.log("getting controller data"); - res.send(stdout); + res.send(stdout+"^"+isControllerUP);//Send controller data and UP or DOWN separate by ^ }); + }); + + +router.get('/resetflows', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + var child2; +let salida; + child = exec("curl localhost:8080/data?list=switches", function(error, stdout, stderr) { + let value = ''; + try { + value = JSON.parse(stdout); + for (key in value){ + child2 = exec("cd /home/pi/scripts && ./resetflows.sh "+key, function(err, out, stder){ + console.log(out); + salida = out; +}); +} + +if (stdout === undifined){ +res.send("Switches not found"); +}else{ +res.send(salida); +} +} + catch(error) { + //console.error(error); + console.log("no response from server"); + // expected output: ReferenceError: nonExistentFunction is not def$ + // Note - error messages will vary depending on browser + res.send("No response from server"); + } + }); +}); + + router.get('/listswitch', (req, res) => { var sys = require('sys') var exec = require('child_process').exec; @@ -177,15 +257,15 @@ router.get('/listswitch', (req, res) => { let value = ''; try { value = JSON.parse(stdout) + res.send(value); } catch(error) { - console.error(error); - console.log("no response from server"); + //console.error(error); + console.log("no response from controller"); // expected output: ReferenceError: nonExistentFunction is not defined // Note - error messages will vary depending on browser + res.send(null); } - - res.send(value); }); }); @@ -203,8 +283,79 @@ router.get('/status', (req, res) => { }); }); +router.get('/tablestatus', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + console.log(req.query); + child = exec("curl \"localhost:8080/data?tablestat="+req.query.tablestat+"\"", function(error, stdout, stderr) { + console.log("table status"); + console.log(stdout); + let value = ''; + try { + value = JSON.parse(stdout) + res.send(value); + } + catch(error) { + //console.error(error); + console.log("no response from server"); + // expected output: ReferenceError: nonExistentFunction is not defined + // Note - error messages will vary depending on browser + let er = "No response from server"; + res.send(JSON.stringify(er)); + } + }); +}); + +router.get('/portsdesc', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + console.log(req.query); + child = exec("curl \"localhost:8080/data?portdesc="+req.query.portdesc+"\"", function(error, stdout, stderr) { + console.log("port desc"); + let value = ''; + try { + value = JSON.parse(stdout) + res.send(value); + } + catch(error) { + //console.error(error); + console.log("no response from server"); + // expected output: ReferenceError: nonExistentFunction is not defined + // Note - error messages will vary depending on browser + let er = "No response from server"; + res.send(JSON.stringify(er)); + } + }); +}); + +router.get('/portsstat', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + console.log(req.query); + child = exec("curl \"localhost:8080/data?portstat="+req.query.portstat+"\"", function(error, stdout, stderr) { + console.log("port status"); + console.log(stdout); + let value = ''; + try { + value = JSON.parse(stdout) + res.send(value); + } + catch(error) { + //console.error(error); + console.log("no response from server"); + // expected output: ReferenceError: nonExistentFunction is not defined + // Note - error messages will vary depending on browser + let er = "No response from server"; + res.send(JSON.stringify(er)); + } + }); +}); router.get('/startcontroller', (req, res) => { + isControllerUP = true; var sys = require('sys') var exec = require('child_process').exec; var child; @@ -216,7 +367,19 @@ router.get('/startcontroller', (req, res) => { }); }); +router.get('/startcontrollerrouter', (req, res) => { + isControllerUP = true; + var sys = require('sys') + var exec = require('child_process').exec; + var child; + child = exec("cd /home/pi/scripts && touch controllerout && ./ryurouter.sh > controllerout 2>&1 &", function(error, stdout, stderr) { + console.log("controller REST Router started"); + res.send(stdout); + }); +}); + router.get('/stopcontroller', (req, res) => { + isControllerUP = false; var sys = require('sys') var exec = require('child_process').exec; var child; @@ -225,14 +388,37 @@ router.get('/stopcontroller', (req, res) => { res.send(stdout); }); }); - +router.get('/sendcommand', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + console.log(req.query); + // request = JSON.parse(req.query.cmd); //recibiendo el comando + // + // console.log(request); + child = exec("cd /home/pi/scripts && echo "+req.query.cmd+" > fifo", function(error, stdout, stderr) { + console.log("command received \n" + req.query.cmd+"\n"); + res.send(stdout); + }); +}); +router.get('/cancel', (req, res) => { + var sys = require('sys') + var exec = require('child_process').exec; + var child; + child = exec("sudo kill -2 $(ps aux | grep GRE| grep sudo|awk {'print $2'})", function(error, stdout, stderr) { + console.log("cancelled"); + res.send(stdout); + }); +}); router.get('/startvsorc', (req, res) => { + var sys = require('sys') var exec = require('child_process').exec; var child0;//needs a mkfifo named fifo to exist var child1; var child2; var child3; + var child4; var answer; request = JSON.parse(req.query.topology) console.log("Topology is : \n"+ request); @@ -241,7 +427,7 @@ router.get('/startvsorc', (req, res) => { console.log(stdout + stderr); answer+=stdout; }); - child1 = exec("cd /home/pi/scripts && mkfifo fifo && touch aichivo", function(error, stdout, stderr) { + child1 = exec("cd /home/pi/scripts && mkfifo fifo && rm aichivo && touch aichivo", function(error, stdout, stderr) { console.log(stdout + stderr); answer+=stdout; }); @@ -249,6 +435,8 @@ router.get('/startvsorc', (req, res) => { console.log(stdout + stderr); answer+=stdout; }); + + //child3 uses tail so it can read from fifo even after a EOF child3 = exec("cd /home/pi/scripts && tail -n +1 -f fifo | sudo ./clusterGRE.py > aichivo 2>&1 &", function(error, stdout, stderr) { console.log(stdout + stderr); @@ -258,6 +446,7 @@ router.get('/startvsorc', (req, res) => { }); router.get('/stopvsorc', (req,res) =>{ + var sys = require('sys') var exec = require('child_process').exec; var child1; @@ -265,25 +454,25 @@ router.get('/stopvsorc', (req,res) =>{ var child3; var payload console.log("erasing..."); - child1 = exec("cd /home/pi/scripts && exec 3>&- && rm fifo && rm aichivo", function(error, stdout, stderr) { + child1 = exec("cd /home/pi/scripts && exec 3>&- ", function(error, stdout, stderr) { console.log(stdout); payload+="rm done\n\n"+stdout; });//esto cierra el fifo, lo cual cierra el programa - //sudo kill $(ps aux | grep GRE| grep sudo|awk {'print $2'}) && cd /home/pi && ./multissh.sh sudo -E mn -c; sudo -E mn -c - console.log("killing all..."); - child2 = exec("sudo kill $(ps aux | grep GRE| grep sudo|awk {'print $2'})", function(error, stdout, stderr) { + //antes, en ves de echo exit > fifo, estaba sudo kill $(ps aux | grep GRE| grep sudo|awk {'print $2'}) + console.log("Exiting..."); + child2 = exec("cd /home/pi/scripts && echo exit > fifo && rm fifo && sudo killall tail", function(error, stdout, stderr) { console.log(stdout); payload+="killed\n\n"+stdout; }); - console.log("Multisshing and cleaning..."); - child3 = exec("cd /home/pi/scripts && ./multissh.sh sudo -E mn -c; sudo -E mn -c", function(error, stdout, stderr) { - console.log(stdout); - console.log("multisshed"); - payload+="Multisshed\n\n"+stdout; - - }); + // console.log("Multisshing and cleaning..."); + // child3 = exec("cd /home/pi/scripts && ./multissh.sh sudo -E mn -c; sudo -E mn -c", function(error, stdout, stderr) { + // console.log(stdout); + // console.log("multisshed"); + // payload+="Multisshed\n\n"+stdout; + // + // }); res.send(payload); }); module.exports = router;