src/routes/index.js

   1 const {
   2   Router
   3 } = require('express');
   4 const router = new Router();
   5
   6
   7
   8 //renders de las paginas web
   9 router.get("/", (req, res) => {
  10   res.render("index")
  11 });
  12
  13 router.get("/access", (req, res) => {
  14   res.render("access")
  15 });
  16
  17 router.get("/starter", (req, res) => {
  18   res.render("starter")
  19 });
  20
  21 router.get("/stats", (req, res) => {
  22   res.render("stats")
  23 });
  24
  25 router.get("/topology", (req, res) => {
  26   res.render("topology")
  27 });
  28 let isVsorcUP = false;
  29 let isControllerUP = false;
  30 router.get("/topologyMaker", (req, res) => {
  31   res.render("topologyMaker")
  32 });
  33 //en lo adelante se encuentran las peticiones de datos
  34 router.get('/free', (req, res) => {
  35   var sys = require('sys')
  36   var exec = require('child_process').exec;
  37   var child;
  38   child = exec("free -b | grep Mem |  awk  '{print $3}'", function(error, stdout, stderr) {
  39     console.log("free");
  40     res.send(stdout);
  41   });
  42 });
  43
  44 router.post('/flowdel', (req, res) => {
  45   var sys = require('sys')
  46   var exec = require('child_process').exec;
  47   var child;
  48   var flow = JSON.stringify(req.body);
  49   child = exec("curl -X POST -d "+req.body+"localhost:8080/flowdel", function(error, stdout, stderr) {
  50     console.log(stdout);
  51     console.log(req.body);
  52     res.send(req.body);
  53   });
  54 });
  55
  56
  57 router.get('/mpstat', (req, res) => {
  58   var sys = require('sys')
  59   var exec = require('child_process').exec;
  60   var child;
  61   child = exec("mpstat 1 1| grep all | grep Average | awk '{print $12}'", function(error, stdout, stderr) {
  62     console.log("mpstat");
  63     res.send(stdout);
  64   });
  65 });
  66
  67 router.get('/ifstat', (req, res) => {
  68   var sys = require('sys')
  69   var exec = require('child_process').exec;
  70   var child;
  71   child = exec("ifstat -n -b -i eth0  0.3 1 | grep [0-9]$", function(error, stdout, stderr) {
  72     console.log("ifstat");
  73     res.send(stdout);
  74   });
  75 });
  76
  77 router.get('/showtemp', (req, res) => {
  78   var sys = require('sys')
  79   var exec = require('child_process').exec;
  80   var child;
  81   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) {
  82     console.log("show temp");//this was modified
  83     res.send(stdout);
  84   });
  85 });
  86 router.get('/gettopo', (req, res) => {
  87   var sys = require('sys')
  88   var exec = require('child_process').exec;
  89   var child;
  90   child = exec("curl localhost:8080/topology", function(error, stdout, stderr) {
  91     console.log("gettopo");
  92     res.send(stdout);
  93   });
  94 });
  95
  96 router.get('/net', (req, res) => {
  97   var sys = require('sys')
  98   var exec = require('child_process').exec;
  99   var child;
 100   child = exec("cd /home/pi/scripts && echo net > fifo", function(error, stdout, stderr) {
 101     console.log("net");
 102     res.send(stdout);
 103   });
 104 });
 105
 106 router.get('/rpiping', (req, res) => {
 107   var sys = require('sys')
 108   var exec = require('child_process').exec;
 109   var child;
 110   child = exec("cd /home/pi/scripts && ./rpiping.sh", function(error, stdout, stderr) {
 111     console.log("rpiping");
 112     res.send(stdout);
 113   });
 114 });
 115
 116 router.get('/nodes', (req, res) => {
 117   var sys = require('sys')
 118   var exec = require('child_process').exec;
 119   var child;
 120   child = exec("cd /home/pi/scripts && echo nodes > fifo", function(error, stdout, stderr) {
 121     console.log("nodes");
 122     res.send(stdout);
 123   });
 124 });
 125
 126 router.get('/statusnodes', (req, res) => {
 127   var sys = require('sys')
 128   var exec = require('child_process').exec;
 129   var child;
 130   child = exec("cd /home/pi/scripts && echo status > fifo", function(error, stdout, stderr) {
 131     console.log("status");
 132     res.send(stdout);
 133   });
 134 });
 135
 136 router.get('/intfs', (req, res) => {
 137   var sys = require('sys')
 138   var exec = require('child_process').exec;
 139   var child;
 140   child = exec("cd /home/pi/scripts && echo intfs > fifo", function(error, stdout, stderr) {
 141     console.log("interfaces");
 142     res.send(stdout);
 143   });
 144 });
 145
 146 router.get('/iperf', (req, res) => {
 147   var sys = require('sys')
 148   var exec = require('child_process').exec;
 149   var child;
 150   child = exec("cd /home/pi/scripts && echo iperf > fifo", function(error, stdout, stderr) {
 151     console.log("pingall");
 152     res.send(stdout);
 153   });
 154 });
 155
 156 router.get('/pingall', (req, res) => {
 157   var sys = require('sys')
 158   var exec = require('child_process').exec;
 159   var child;
 160   child = exec("cd /home/pi/scripts && echo pingall > fifo", function(error, stdout, stderr) {
 161     console.log("pingall");
 162     res.send(stdout);
 163   });
 164 });
 165 router.get('/placement', (req, res) => {
 166   var sys = require('sys')
 167   var exec = require('child_process').exec;
 168   var child;
 169   child = exec("cd /home/pi/scripts && echo placement > fifo", function(error, stdout, stderr) {
 170     console.log("placement");
 171     res.send(stdout);
 172   });
 173 });
 174
 175 router.get('/getvsorcdata', (req, res) => {
 176
 177   var sys = require('sys')
 178   var exec = require('child_process').exec;
 179   var child;
 180   var child2;
 181   child2 = exec("ps aux | grep GRE| grep sudo | grep -v tail| awk {'print $2'}", function(error, stdout, stderr) {
 182     console.log("view status vsorc");
 183     if (stdout === ""){
 184       isVsorcUP = false;
 185     }else {
 186       isVsorcUP = true;
 187     }
 188   });
 189   child = exec("cd /home/pi/scripts && cat aichivo 2>/dev/null", function(error, stdout, stderr) {
 190     console.log("getting vsorc data");
 191     res.send(stdout+"^"+isVsorcUP);
 192   });
 193 });
 194 router.get('/getcontrollerdata', (req, res) => {
 195   var sys = require('sys')
 196   var exec = require('child_process').exec;
 197   var child;
 198   var child2;
 199   child2 = exec("ps aux | grep python | grep ryu | grep -v grep |awk {'print $2'}", function(error, stdout, stderr) {
 200     console.log(stdout);
 201     console.log("view status controller");
 202     if (stdout === ""){
 203       isControllerUP = false;
 204     }else {
 205       isControllerUP = true;
 206     }
 207   });
 208   child = exec("cd /home/pi/scripts && cat controllerout 2>/dev/null", function(error, stdout, stderr) {
 209     console.log("getting controller data");
 210     res.send(stdout+"^"+isControllerUP);//Send controller data and UP or DOWN separate by ^
 211   });
 212
 213 });
 214 router.get('/listswitch', (req, res) => {
 215   var sys = require('sys')
 216   var exec = require('child_process').exec;
 217   var child;
 218   child = exec("curl localhost:8080/data?list=switches", function(error, stdout, stderr) {
 219     console.log("listswitch");
 220     console.log(stdout);
 221     let value = '';
 222     try {
 223       value = JSON.parse(stdout)
 224       res.send(value);
 225     }
 226     catch(error) {
 227       //console.error(error);
 228       console.log("no response from server");
 229       // expected output: ReferenceError: nonExistentFunction is not defined
 230       // Note - error messages will vary depending on browser
 231       res.send("No response from server");
 232     }
 233
 234
 235   });
 236 });
 237
 238 router.get('/status', (req, res) => {
 239   var sys = require('sys')
 240   var exec = require('child_process').exec;
 241   var child;
 242   console.log(req.query.status+req.query.dpid);
 243   child = exec("curl \"localhost:8080/status?status="+req.query.status+"&dpid="+req.query.dpid+"\"", function(error, stdout, stderr) {
 244     console.log("statusFlows");
 245     console.log(stdout);
 246     let value = JSON.parse(stdout)
 247
 248     res.send(value);
 249   });
 250 });
 251
 252 router.get('/tablestatus', (req, res) => {
 253   var sys = require('sys')
 254   var exec = require('child_process').exec;
 255   var child;
 256         console.log(req.query);
 257                 child = exec("curl \"localhost:8080/data?tablestat="+req.query.tablestat+"\"", function(error, stdout, stderr) {
 258                 console.log("table status");
 259                 console.log(stdout);
 260     let value = '';
 261     try {
 262       value = JSON.parse(stdout)
 263       res.send(value);
 264     }
 265     catch(error) {
 266       //console.error(error);
 267       console.log("no response from server");
 268       // expected output: ReferenceError: nonExistentFunction is not defined
 269       // Note - error messages will vary depending on browser
 270       let er = "No response from server";
 271       res.send(JSON.stringify(er));
 272     }
 273                         });
 274 });
 275
 276 router.get('/portsdesc', (req, res) => {
 277   var sys = require('sys')
 278   var exec = require('child_process').exec;
 279   var child;
 280         console.log(req.query);
 281                 child = exec("curl \"localhost:8080/data?portdesc="+req.query.portdesc+"\"", function(error, stdout, stderr) {
 282                 console.log("port desc");
 283                 let value = '';
 284                 try {
 285                   value = JSON.parse(stdout)
 286                   res.send(value);
 287                 }
 288                 catch(error) {
 289                   //console.error(error);
 290                   console.log("no response from server");
 291                   // expected output: ReferenceError: nonExistentFunction is not defined
 292                   // Note - error messages will vary depending on browser
 293                   let er = "No response from server";
 294                   res.send(JSON.stringify(er));
 295                 }
 296   });
 297 });
 298
 299 router.get('/portsstat', (req, res) => {
 300   var sys = require('sys')
 301   var exec = require('child_process').exec;
 302   var child;
 303         console.log(req.query);
 304                 child = exec("curl \"localhost:8080/data?portstat="+req.query.portstat+"\"", function(error, stdout, stderr) {
 305                 console.log("port status");
 306                 console.log(stdout);
 307                 let value = '';
 308                 try {
 309                   value = JSON.parse(stdout)
 310                   res.send(value);
 311                 }
 312                 catch(error) {
 313                   //console.error(error);
 314                   console.log("no response from server");
 315                   // expected output: ReferenceError: nonExistentFunction is not defined
 316                   // Note - error messages will vary depending on browser
 317                   let er = "No response from server";
 318                   res.send(JSON.stringify(er));
 319                 }
 320   });
 321 });
 322
 323 router.get('/startcontroller', (req, res) => {
 324   isControllerUP = true;
 325   var sys = require('sys')
 326   var exec = require('child_process').exec;
 327   var child;
 328   //cd /home/pi && setsid $(cat /home/pi/ejecutarcontroller.sh | grep sudo) >/dev/null 2>&1 < /dev/null &
 329   //cd /home/pi && ./ejecutarcontroller.sh > /dev/null 2>&1 < /dev/null &  //comando anterior
 330   child = exec("cd /home/pi/scripts && touch controllerout && ./ejecutarcontroller.sh > controllerout 2>&1 &", function(error, stdout, stderr) {
 331     console.log("controller started");
 332     res.send(stdout);
 333   });
 334 });
 335
 336 router.get('/startcontrollerrouter', (req, res) => {
 337   isControllerUP = true;
 338   var sys = require('sys')
 339   var exec = require('child_process').exec;
 340   var child;
 341   child = exec("cd /home/pi/scripts && touch controllerout && ./ryurouter.sh > controllerout 2>&1 &", function(error, stdout, stderr) {
 342     console.log("controller REST Router started");
 343     res.send(stdout);
 344   });
 345 });
 346
 347 router.get('/stopcontroller', (req, res) => {
 348   isControllerUP = false;
 349   var sys = require('sys')
 350   var exec = require('child_process').exec;
 351   var child;
 352   child = exec("cd /home/pi/scripts && rm controllerout && sudo kill $(ps aux | grep python | grep ryu | awk {'print $2'})", function(error, stdout, stderr) {
 353     console.log("controller stopped");
 354     res.send(stdout);
 355   });
 356 });
 357 router.get('/sendcommand', (req, res) => {
 358   var sys = require('sys')
 359   var exec = require('child_process').exec;
 360   var child;
 361   request = JSON.parse(req.query.cmd); //recibiendo el comando
 362   child = exec("cd /home/pi/scripts && echo \""+request+"\" > fifo", function(error, stdout, stderr) {
 363     console.log("command received \n" + request+"\n");
 364     res.send(stdout);
 365   });
 366 });
 367 router.get('/cancel', (req, res) => {
 368   var sys = require('sys')
 369   var exec = require('child_process').exec;
 370   var child;
 371   child = exec("sudo kill -2 $(ps aux | grep GRE| grep sudo|awk {'print $2'})", function(error, stdout, stderr) {
 372     console.log("cancelled");
 373     res.send(stdout);
 374   });
 375 });
 376 router.get('/startvsorc', (req, res) => {
 377
 378   var sys = require('sys')
 379   var exec = require('child_process').exec;
 380   var child0;//needs a mkfifo named fifo to exist
 381   var child1;
 382   var child2;
 383   var child3;
 384   var child4;
 385   var answer;
 386   request = JSON.parse(req.query.topology)
 387   console.log("Topology is : \n"+ request);
 388   //controlar que solo se haga un arranque por vez y agregar el exec 3>fifo
 389   child0 = exec("cd /home/pi/scripts && echo \""+request+"\" > data", function(error, stdout, stderr) {
 390     console.log(stdout + stderr);
 391     answer+=stdout;
 392   });
 393   child1 = exec("cd /home/pi/scripts && mkfifo fifo && rm aichivo && touch aichivo", function(error, stdout, stderr) {
 394     console.log(stdout + stderr);
 395     answer+=stdout;
 396   });
 397   child2 = exec("cd /home/pi/scripts && exec 3>fifo", function(error, stdout, stderr) {
 398     console.log(stdout + stderr);
 399     answer+=stdout;
 400   });
 401
 402
 403   //child3 uses tail so it can read from fifo even after a EOF
 404   child3 = exec("cd /home/pi/scripts && tail -n +1 -f fifo | sudo ./clusterGRE.py > aichivo 2>&1 &", function(error, stdout, stderr) {
 405     console.log(stdout + stderr);
 406     answer+=stdout;
 407   });
 408   res.send(answer);
 409 });
 410
 411 router.get('/stopvsorc', (req,res) =>{
 412
 413   var sys = require('sys')
 414   var exec = require('child_process').exec;
 415   var child1;
 416   var child2;
 417   var child3;
 418   var payload
 419   console.log("erasing...");
 420   child1 = exec("cd /home/pi/scripts && exec 3>&- ", function(error, stdout, stderr) {
 421     console.log(stdout);
 422
 423     payload+="rm done\n\n"+stdout;
 424   });//esto cierra el fifo, lo cual cierra el programa
 425
 426   //antes, en ves de echo exit > fifo, estaba sudo kill $(ps aux | grep GRE| grep sudo|awk {'print $2'})
 427   console.log("Exiting...");
 428   child2 = exec("cd /home/pi/scripts && echo exit > fifo && rm fifo && sudo killall tail", function(error, stdout, stderr) {
 429     console.log(stdout);
 430     payload+="killed\n\n"+stdout;
 431   });
 432   // console.log("Multisshing and cleaning...");
 433   // child3 = exec("cd /home/pi/scripts && ./multissh.sh sudo -E mn -c; sudo -E mn -c", function(error, stdout, stderr) {
 434   //   console.log(stdout);
 435   //   console.log("multisshed");
 436   //   payload+="Multisshed\n\n"+stdout;
 437   //
 438   // });
 439   res.send(payload);
 440 });
 441 module.exports = router;