plugins/server-status.js

   1 (function() {
   2
   3 /*
   4  * We display untrusted stuff in html context... reject anything
   5  * that has HTML stuff in it
   6  */
   7
   8 function san(s)
   9 {
  10         if (s.search("<") !== -1)
  11                 return "invalid string";
  12
  13         return s;
  14 }
  15
  16 function humanize(s)
  17 {
  18         var i = parseInt(s, 10);
  19
  20         if (i >= (1024 * 1024 * 1024))
  21                 return (i / (1024 * 1024 * 1024)).toFixed(3) + "Gi";
  22
  23         if (i >= (1024 * 1024))
  24                 return (i / (1024 * 1024)).toFixed(3) + "Mi";
  25
  26         if (i > 1024)
  27                 return (i / 1024).toFixed(3) + "Ki";
  28
  29         return s;
  30 }
  31
  32         var pos = 0;
  33
  34 function get_appropriate_ws_url()
  35 {
  36         var pcol;
  37         var u = document.URL;
  38
  39         /*
  40          * We open the websocket encrypted if this page came on an
  41          * https:// url itself, otherwise unencrypted
  42          */
  43
  44         if (u.substring(0, 5) === "https") {
  45                 pcol = "wss://";
  46                 u = u.substr(8);
  47         } else {
  48                 pcol = "ws://";
  49                 if (u.substring(0, 4) === "http")
  50                         u = u.substr(7);
  51         }
  52
  53         u = u.split("/");
  54
  55         /* + "/xxx" bit is for IE10 workaround */
  56
  57         return pcol + u[0] + "/xxx";
  58 }
  59
  60
  61         var socket_status, jso, s;
  62
  63 function ws_open_server_status()
  64 {
  65         socket_status = new WebSocket(get_appropriate_ws_url(),
  66                                    "lws-server-status");
  67
  68         try {
  69                 socket_status.onopen = function() {
  70                         document.getElementById("title").innerHTML = "Server Status (Active)";
  71                         lws_gray_out(false);
  72                 };
  73
  74                 socket_status.onmessage =function got_packet(msg) {
  75                         var u, ci, n;
  76                         //document.getElementById("json").innerHTML = "<pre>"+msg.data+"</pre>";
  77                         if (msg.data.length < 100)
  78                                 return;
  79                         jso = JSON.parse(msg.data);
  80                         u = parseInt(san(jso.i.uptime), 10);
  81
  82                         if (parseInt(jso.i.contexts[0].deprecated, 10) === 0)
  83                                 s = "<table><tr><td></td><td class=\"c0\">";
  84                         else
  85                                 s = "<table><tr><td></td><td class=\"dc0\">";
  86                         s +=
  87                           "Server</td><td>" +
  88                           "<span class=\"sn\">Server Version:</span> <span class=\"v\">" +
  89                            san(jso.i.version) + "</span><br>" +
  90                           "<span class=\"sn\">Host Uptime:</span> <span class=\"v\">" +
  91                           ((u / (24 * 3600)) | 0) + "d " +
  92                           (((u % (24 * 3600)) / 3600) | 0) + "h " +
  93                           (((u % 3600) / 60) | 0) + "m</span>";
  94                         if (jso.i.l1)
  95                                 s = s + ", <span class=\"sn\">Host Load:</span> <span class=\"v\">" + san(jso.i.l1) + " ";
  96                         if (jso.i.l2)
  97                                 s = s + san(jso.i.l2) + " ";
  98                         if (jso.i.l3)
  99                                 s = s + san(jso.i.l3);
 100                         if (jso.i.l1)
 101                                 s =s + "</span>";
 102
 103                         if (jso.i.statm) {
 104                                 var sm = jso.i.statm.split(" ");
 105                                 s += ", <span class=\"sn\">Virt stack + heap Usage:</span> <span class=\"v\">" +
 106                                         humanize(parseInt(sm[5], 10) * 4096) + "B</span>";
 107                         }
 108                         s += ", <span class=\"sn\">lws heap usage:</span> <span class=\"v\">" +
 109                         humanize(jso.i.heap) + "B</span>";
 110
 111
 112                         for (n = 0; n < jso.files.length; n++) {
 113                                 s += "<br><span class=n>" + san(jso.files[n].path) + ":</span><br>    " + san(jso.files[n].val);
 114                         }
 115                         s += "</td></tr>";
 116
 117                         for (ci = 0; ci < jso.i.contexts.length; ci++) {
 118
 119                                 if (parseInt(jso.i.contexts[ci].deprecated, 10) === 0)
 120                                         s += "<tr><td></td><td class=\"c\">" +
 121                                           "Active Context</td><td>";
 122                                 else
 123                                         s += "<tr><td></td><td class=\"c1\">" +
 124                                           "Deprecated Context " + ci + "</td><td>";
 125
 126                                   u = parseInt(san(jso.i.contexts[ci].context_uptime), 10);
 127                                   s += "<span class=n>Server Uptime:</span> <span class=v>" +
 128                                   ((u / (24 * 3600)) | 0) + "d " +
 129                                   (((u % (24 * 3600)) / 3600) | 0) + "h " +
 130                                   (((u % 3600) / 60) | 0) + "m</span>";
 131
 132                                 s = s +
 133                                   "<br>" +
 134                                   "<span class=n>Listening wsi:</span> <span class=v>" + san(jso.i.contexts[ci].listen_wsi) + "</span>, " +
 135                                   "<span class=n>Current wsi alive:</span> <span class=v>" + (parseInt(san(jso.i.contexts[ci].wsi_alive), 10) -
 136                                                   parseInt(san(jso.i.contexts[ci].listen_wsi), 10)) + "</span><br>" +
 137                                   "<span class=n>Total Rx:</span> <span class=v>" + humanize(san(jso.i.contexts[ci].rx)) +"B</span>, " +
 138                                   "<span class=n>Total Tx:</span> <span class=v>" + humanize(san(jso.i.contexts[ci].tx)) +"B</span><br>" +
 139
 140                                   "<span class=n>CONNECTIONS: HTTP/1.x:</span> <span class=v>" + san(jso.i.contexts[ci].h1_conn) +"</span>, " +
 141                                   "<span class=n>Websocket:</span> <span class=v>" + san(jso.i.contexts[ci].ws_upg) +"</span>, " +
 142                                   "<span class=n>H2 upgrade:</span> <span class=v>" + san(jso.i.contexts[ci].h2_upg) +"</span>, " +
 143                                   "<span class=n>H2 ALPN:</span> <span class=v>" + san(jso.i.contexts[ci].h2_alpn) +"</span>, " +
 144                                   "<span class=n>Rejected:</span> <span class=v>" + san(jso.i.contexts[ci].rejected) +"</span><br>" +
 145
 146                                   "<span class=n>TRANSACTIONS: HTTP/1.x:</span> <span class=v>" + san(jso.i.contexts[ci].h1_trans) + "</span>, " +
 147                                   "<span class=n>H2:</span> <span class=v>" + san(jso.i.contexts[ci].h2_trans) +"</span>, " +
 148                                    "<span class=n>Total H2 substreams:</span> <span class=v>" + san(jso.i.contexts[ci].h2_subs) +"</span><br>" +
 149
 150                                   "<span class=n>CGI: alive:</span> <span class=v>" + san(jso.i.contexts[ci].cgi_alive) + "</span>, " +
 151                                   "<span class=n>spawned:</span> <span class=v>" + san(jso.i.contexts[ci].cgi_spawned) +
 152                                   "</span><table>";
 153
 154                                 for (n = 0; n < jso.i.contexts[ci].pt.length; n++) {
 155
 156                                         if (parseInt(jso.i.contexts[ci].deprecated, 10) === 0)
 157                                                 s += "<tr><td>&nbsp;&nbsp;</td><td class=\"l\">service thread " + (n + 1);
 158                                         else
 159                                                 s += "<tr><td>&nbsp;&nbsp;</td><td class=\"dl\">service thread " + (n + 1);
 160                                         s += "</td><td>" +
 161                                         "<span class=n>fds:</span> <span class=v>" + san(jso.i.contexts[ci].pt[n].fds_count) + " / " +
 162                                                   san(jso.i.contexts[ci].pt_fd_max) + "</span>, ";
 163                                         s = s + "<span class=n>ah pool:</span> <span class=v>" + san(jso.i.contexts[ci].pt[n].ah_pool_inuse) + " / " +
 164                                                       san(jso.i.contexts[ci].ah_pool_max) + "</span>, " +
 165                                         "<span class=n>ah waiting list:</span> <span class=v>" + san(jso.i.contexts[ci].pt[n].ah_wait_list);
 166
 167                                         s = s + "</span></td></tr>";
 168
 169                                 }
 170                                 for (n = 0; n < jso.i.contexts[ci].vhosts.length; n++) {
 171                                         if (parseInt(jso.i.contexts[ci].deprecated, 10) === 0)
 172                                                 s += "<tr><td>&nbsp;&nbsp;</td><td class=\"l\">vhost " + (n + 1);
 173                                         else
 174                                                 s += "<tr><td>&nbsp;&nbsp;</td><td class=\"dl\">vhost " + (n + 1);
 175                                         s += "</td><td><span class=\"mountname\">";
 176                                         if (jso.i.contexts[ci].vhosts[n].use_ssl === "1")
 177                                                 s = s + "https://";
 178                                         else
 179                                                 s = s + "http://";
 180                                         s = s + san(jso.i.contexts[ci].vhosts[n].name) + ":" +
 181                                                 san(jso.i.contexts[ci].vhosts[n].port) + "</span>";
 182                                         if (jso.i.contexts[ci].vhosts[n].sts === "1")
 183                                                 s = s + " (STS)";
 184                                         s = s +"<br>" +
 185
 186                                           "<span class=n>Total Rx:</span> <span class=v>" + humanize(san(jso.i.contexts[ci].vhosts[n].rx)) +"B</span>, " +
 187                                           "<span class=n>Total Tx:</span> <span class=v>" + humanize(san(jso.i.contexts[ci].vhosts[n].tx)) +"B</span><br>" +
 188
 189                                           "<span class=n>CONNECTIONS: HTTP/1.x:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].h1_conn) +"</span>, " +
 190                                           "<span class=n>Websocket:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].ws_upg) +"</span>, " +
 191                                           "<span class=n>H2 upgrade:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].h2_upg) +"</span>, " +
 192                                           "<span class=n>H2 ALPN:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].h2_alpn) +"</span>, " +
 193                                           "<span class=n>Rejected:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].rejected) +"</span><br>" +
 194
 195                                           "<span class=n>TRANSACTIONS: HTTP/1.x:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].h1_trans) + "</span>, " +
 196                                           "<span class=n>H2:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].h2_trans) +"</span>, " +
 197                                           "<span class=n>Total H2 substreams:</span> <span class=v>" + san(jso.i.contexts[ci].vhosts[n].h2_subs) +"</span><br>";
 198
 199                                         if (jso.i.contexts[ci].vhosts[n].mounts) {
 200                                                 s = s + "<table><tr><td class=t>Mountpoint</td><td class=t>Origin</td><td class=t>Cache Policy</td></tr>";
 201
 202                                                 var m;
 203                                                 for (m = 0; m < jso.i.contexts[ci].vhosts[n].mounts.length; m++) {
 204                                                         s = s + "<tr><td>";
 205                                                         s = s + "<span class=\"m1\">" + san(jso.i.contexts[ci].vhosts[n].mounts[m].mountpoint) +
 206                                                                 "</span></td><td><span class=\"m2\">" +
 207                                                                 san(jso.i.contexts[ci].vhosts[n].mounts[m].origin) +
 208                                                                 "</span></td><td>";
 209                                                         if (parseInt(san(jso.i.contexts[ci].vhosts[n].mounts[m].cache_max_age), 10))
 210                                                                 s = s + "<span class=n>max-age:</span> <span class=v>" +
 211                                                                 san(jso.i.contexts[ci].vhosts[n].mounts[m].cache_max_age) +
 212                                                                 "</span>, <span class=n>reuse:</span> <span class=v>" +
 213                                                                 san(jso.i.contexts[ci].vhosts[n].mounts[m].cache_reuse) +
 214                                                                 "</span>, <span class=n>reval:</span> <span class=v>" +
 215                                                                 san(jso.i.contexts[ci].vhosts[n].mounts[m].cache_revalidate) +
 216                                                                 "</span>, <span class=n>inter:</span> <span class=v>" +
 217                                                                 san(jso.i.contexts[ci].vhosts[n].mounts[m].cache_intermediaries);
 218                                                         s = s + "</span></td></tr>";
 219                                                 }
 220                                                 s = s + "</table>";
 221                                         }
 222                                         s = s + "</td></tr>";
 223                                 }
 224
 225                                 s += "</table></td></tr>";
 226
 227                         } // context
 228                         s = s + "</table>";
 229
 230                         document.getElementById("conninfo").innerHTML = s;
 231                 };
 232
 233                 socket_status.onclose = function(){
 234                         document.getElementById("title").innerHTML = "Server Status (Disconnected)";
 235                         lws_gray_out(true,{"zindex":"499"});
 236                 };
 237         } catch(exception) {
 238                 alert("<p>Error" + exception);
 239         }
 240 }
 241
 242 /* stuff that has to be delayed until all the page assets are loaded */
 243
 244 window.addEventListener("load", function() {
 245
 246         lws_gray_out(true,{"zindex":"499"});
 247
 248         ws_open_server_status();
 249
 250 }, false);
 251
 252 }());
 253