detect not running guests and add start button

[pve-xtermjs.git] / src / www / main.js

diff --git a/src/www/main.js b/src/www/main.js
index 6d7ee69bcb5b252ab0ecb0bda05c2297373de4a8..2c81e7fcd778c025cc5d8a9e1794bf9d3625c12e 100644 (file)
--- a/src/www/main.js
+++ b/src/www/main.js
@@ -24,8 +24,9 @@ var vmid = getQueryParameter('vmid');
 var vmname = getQueryParameter('vmname');
 var nodename = getQueryParameter('node');
 var cmd = getQueryParameter('cmd');
+var cmdOpts = getQueryParameter('cmd-opts');
 
-function updateState(newState, msg) {
+function updateState(newState, msg, code) {
     var timeout, severity, message;
     switch (newState) {
        case states.connecting:
@@ -34,19 +35,23 @@ function updateState(newState, msg) {
            severity = severities.warning;
            break;
        case states.connected:
+           window.onbeforeunload = windowUnload;
            message = "Connected";
            break;
        case states.disconnecting:
+           window.onbeforeunload = undefined;
            message = "Disconnecting...";
            timeout = 0;
            severity = severities.warning;
            break;
        case states.reconnecting:
+           window.onbeforeunload = undefined;
            message = "Reconnecting...";
            timeout = 0;
            severity = severities.warning;
            break;
        case states.disconnected:
+           window.onbeforeunload = undefined;
            switch (state) {
                case states.start:
                case states.connecting:
@@ -76,8 +81,15 @@ function updateState(newState, msg) {
        default:
            throw "unknown state";
     }
+    let msgArr = [];
     if (msg) {
-       message += " (" + msg + ")";
+       msgArr.push(msg);
+    }
+    if (code !== undefined) {
+       msgArr.push(`Code: ${code}`);
+    }
+    if (msgArr.length > 0) {
+       message += ` (${msgArr.join(', ')})`;
     }
     state = newState;
     showMsg(message, timeout, severity);
@@ -85,10 +97,59 @@ function updateState(newState, msg) {
 
 var terminalContainer = document.getElementById('terminal-container');
 document.getElementById('status_bar').addEventListener('click', hideMsg);
+document.getElementById('connect_btn').addEventListener('click', startGuest);
 const fitAddon = new FitAddon.FitAddon();
 
 createTerminal();
 
+function startConnection(url, params, term) {
+    API2Request({
+       method: 'POST',
+       params: params,
+       url: url + '/termproxy',
+       success: function(result) {
+           var port = encodeURIComponent(result.data.port);
+           ticket = result.data.ticket;
+           socketURL = protocol + location.hostname + ((location.port) ? (':' + location.port) : '') + '/api2/json' + url + '/vncwebsocket?port=' + port + '&vncticket=' + encodeURIComponent(ticket);
+
+           term.open(terminalContainer, true);
+           socket = new WebSocket(socketURL, 'binary');
+           socket.binaryType = 'arraybuffer';
+           socket.onopen = runTerminal;
+           socket.onclose = tryReconnect;
+           socket.onerror = tryReconnect;
+           updateState(states.connecting);
+       },
+       failure: function(msg) {
+           updateState(states.disconnected,msg);
+       }
+    });
+}
+
+function startGuest() {
+    let api_type = type === 'kvm' ? 'qemu' : 'lxc';
+    API2Request({
+       method: 'POST',
+       url: `/nodes/${nodename}/${api_type}/${vmid}/status/start`,
+       success: function(result) {
+           showMsg('Guest started successfully', 0);
+           setTimeout(function() {
+               location.reload();
+           }, 1000);
+       },
+       failure: function(msg) {
+           if (msg.match(/already running/)) {
+               showMsg('Guest started successfully', 0);
+               setTimeout(function() {
+                   location.reload();
+               }, 1000);
+           } else {
+               updateState(states.disconnected,msg);
+           }
+       }
+    });
+}
+
 function createTerminal() {
     term = new Terminal(getTerminalSettings());
     term.loadAddon(fitAddon);
@@ -111,44 +172,42 @@ function createTerminal() {
            url += '/lxc/' + vmid;
            break;
        case 'upgrade':
-           params.upgrade = 1;
+           params.cmd = 'upgrade';
            break;
        case 'cmd':
            params.cmd = decodeURI(cmd);
+           if (cmdOpts !== undefined && cmdOpts !== null && cmdOpts !== "") {
+               params['cmd-opts'] = decodeURI(cmdOpts);
+           }
            break;
     }
-    API2Request({
-       method: 'POST',
-       params: params,
-       url: url + '/termproxy',
-       success: function(result) {
-           var port = encodeURIComponent(result.data.port);
-           ticket = result.data.ticket;
-           socketURL = protocol + location.hostname + ((location.port) ? (':' + location.port) : '') + '/api2/json' + url + '/vncwebsocket?port=' + port + '&vncticket=' + encodeURIComponent(ticket);
-
-           term.open(terminalContainer, true);
-           socket = new WebSocket(socketURL, 'binary');
-           socket.binaryType = 'arraybuffer';
-           socket.onopen = runTerminal;
-           socket.onclose = tryReconnect;
-           socket.onerror = tryReconnect;
-           window.onbeforeunload = stopTerminal;
-           updateState(states.connecting);
-       },
-       failure: function(msg) {
-           updateState(states.disconnected,msg);
-       }
-    });
-
+    if (type === 'kvm' || type === 'lxc') {
+       API2Request({
+           method: 'GET',
+           url: `${url}/status/current`,
+           success: function(result) {
+               if (result.data.status === 'running') {
+                   startConnection(url, params, term);
+               } else {
+                   document.getElementById('connect_dlg').classList.add('pve_open');
+               }
+           },
+           failure: function(msg) {
+               updateState(states.disconnected, msg);
+           },
+       });
+    } else {
+       startConnection(url, params, term);
+    }
 }
 
 function runTerminal() {
     socket.onmessage = function(event) {
-       var answer = Utf8ArrayToStr(event.data);
+       var answer = new Uint8Array(event.data);
        if (state === states.connected) {
            term.write(answer);
        } else if(state === states.connecting) {
-           if (answer.slice(0,2) === "OK") {
+           if (answer[0] === 79 && answer[1] === 75) { // "OK"
                updateState(states.connected);
                term.write(answer.slice(2));
            } else {
@@ -275,11 +334,11 @@ function checkMigration() {
     });
 }
 
-function tryReconnect() {
+function tryReconnect(event) {
     var time_since_started = new Date() - starttime;
     var type = getQueryParameter('console');
     if (time_since_started < 5*1000 || type === 'shell' || type === 'cmd') { // 5 seconds
-       stopTerminal();
+       stopTerminal(event);
        return;
     }
 
@@ -292,12 +351,23 @@ function clearEvents() {
     term.onData(() => {});
 }
 
+function windowUnload(e) {
+    let message = "Are you sure you want to leave this page?";
+
+    e = e || window.event;
+    if (e) {
+       e.returnValue = message;
+    }
+
+    return message;
+}
+
 function stopTerminal(event) {
     event = event || {};
     clearEvents();
     clearInterval(ping);
     socket.close();
-    updateState(states.disconnected, event.msg + event.code);
+    updateState(states.disconnected, event.reason, event.code);
 }
 
 function errorTerminal(event) {
@@ -306,5 +376,5 @@ function errorTerminal(event) {
     clearInterval(ping);
     socket.close();
     term.dispose();
-    updateState(states.disconnected, event.msg + event.code);
+    updateState(states.disconnected, event.msg, event.code);
 }