src/routes/index.js

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