--- /dev/null
+console.log('xtermjs: starting');
+
+var states = {
+ start: 1,
+ connecting: 2,
+ connected: 3,
+ disconnecting: 4,
+ disconnected: 5,
+ reconnecting: 6,
+};
+
+var term,
+ protocol,
+ socketURL,
+ socket,
+ ticket,
+ resize,
+ ping,
+ state = states.start,
+ starttime = new Date();
+
+var type = getQueryParameter('console');
+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, code) {
+ var timeout, severity, message;
+ switch (newState) {
+ case states.connecting:
+ message = "Connecting...";
+ timeout = 0;
+ 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:
+ case states.reconnecting:
+ message = "Connection failed";
+ timeout = 0;
+ severity = severities.error;
+ break;
+ case states.connected:
+ case states.disconnecting:
+ var time_since_started = new Date() - starttime;
+ timeout = 5000;
+ if (time_since_started > 5*1000 || type === 'shell') {
+ message = "Connection closed";
+ } else {
+ message = "Connection failed";
+ severity = severities.error;
+ }
+ break;
+ case states.disconnected:
+ // no state change
+ break;
+ default:
+ throw "unknown state";
+ }
+ break;
+ default:
+ throw "unknown state";
+ }
+ let msgArr = [];
+ if (msg) {
+ msgArr.push(msg);
+ }
+ if (code !== undefined) {
+ msgArr.push(`Code: ${code}`);
+ }
+ if (msgArr.length > 0) {
+ message += ` (${msgArr.join(', ')})`;
+ }
+ state = newState;
+ showMsg(message, timeout, severity);
+}
+
+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();
+const webglAddon = new WebglAddon.WebglAddon();
+
+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);
+
+ 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.open(terminalContainer);
+ term.loadAddon(fitAddon);
+ try {
+ term.loadAddon(webglAddon);
+ } catch (_e) {
+ console.warn("webgl-addon loading failed, falling back to regular dom renderer");
+ }
+
+ term.onResize(function (size) {
+ if (state === states.connected) {
+ socket.send("1:" + size.cols + ":" + size.rows + ":");
+ }
+ });
+
+ protocol = (location.protocol === 'https:') ? 'wss://' : 'ws://';
+
+ var params = {};
+ var url = '/nodes/' + nodename;
+ switch (type) {
+ case 'kvm':
+ url += '/qemu/' + vmid;
+ break;
+ case 'lxc':
+ url += '/lxc/' + vmid;
+ break;
+ case 'upgrade':
+ params.cmd = 'upgrade';
+ break;
+ case 'cmd':
+ params.cmd = decodeURI(cmd);
+ if (cmdOpts !== undefined && cmdOpts !== null && cmdOpts !== "") {
+ params['cmd-opts'] = decodeURI(cmdOpts);
+ }
+ break;
+ }
+ 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 = new Uint8Array(event.data);
+ if (state === states.connected) {
+ term.write(answer);
+ } else if(state === states.connecting) {
+ if (answer[0] === 79 && answer[1] === 75) { // "OK"
+ updateState(states.connected);
+ term.write(answer.slice(2));
+ } else {
+ socket.close();
+ }
+ }
+ };
+
+ term.onData(function(data) {
+ if (state === states.connected) {
+ socket.send("0:" + unescape(encodeURIComponent(data)).length.toString() + ":" + data);
+ }
+ });
+
+ ping = setInterval(function() {
+ socket.send("2");
+ }, 30*1000);
+
+ window.addEventListener('resize', function() {
+ clearTimeout(resize);
+ resize = setTimeout(function() {
+ // done resizing
+ fitAddon.fit();
+ }, 250);
+ });
+
+ socket.send(PVE.UserName + ':' + ticket + "\n");
+
+ // initial focus and resize
+ setTimeout(function() {
+ term.focus();
+ fitAddon.fit();
+ }, 250);
+}
+
+function getLxcStatus(callback) {
+ API2Request({
+ method: 'GET',
+ url: '/nodes/' + nodename + '/lxc/' + vmid + '/status/current',
+ success: function(result) {
+ if (typeof callback === 'function') {
+ callback(true, result);
+ }
+ },
+ failure: function(msg) {
+ if (typeof callback === 'function') {
+ callback(false, msg);
+ }
+ }
+ });
+}
+
+function checkMigration() {
+ var apitype = type;
+ if (apitype === 'kvm') {
+ apitype = 'qemu';
+ }
+ API2Request({
+ method: 'GET',
+ params: {
+ type: 'vm'
+ },
+ url: '/cluster/resources',
+ success: function(result) {
+ // if not yet migrated , wait and try again
+ // if not migrating and stopped, cancel
+ // if started, connect
+ result.data.forEach(function(entity) {
+ if (entity.id === (apitype + '/' + vmid)) {
+ var started = entity.status === 'running';
+ var migrated = entity.node !== nodename;
+ if (migrated) {
+ if (started) {
+ // goto different node
+ location.href = '?console=' + type +
+ '&xtermjs=1&vmid=' + vmid + '&vmname=' +
+ vmname + '&node=' + entity.node;
+ } else {
+ // wait again
+ updateState(states.reconnecting, 'waiting for migration to finish...');
+ setTimeout(checkMigration, 5000);
+ }
+ } else {
+ if (type === 'lxc') {
+ // we have to check the status of the
+ // container to know if it has the
+ // migration lock
+ getLxcStatus(function(success, result) {
+ if (success) {
+ if (result.data.lock === 'migrate') {
+ // still waiting
+ updateState(states.reconnecting, 'waiting for migration to finish...');
+ setTimeout(checkMigration, 5000);
+ } else if (started) {
+ // container was rebooted
+ location.reload();
+ } else {
+ stopTerminal();
+ }
+ } else {
+ // probably the status call failed because
+ // the ct is already somewhere else, so retry
+ setTimeout(checkMigration, 1000);
+ }
+ });
+ } else if (started) {
+ // this happens if we have old data in
+ // /cluster/resources, or the connection
+ // disconnected, so simply try to reload here
+ location.reload();
+ } else if (type === 'kvm') {
+ // it seems the guest simply stopped
+ stopTerminal();
+ }
+ }
+
+ return;
+ }
+ });
+ },
+ failure: function(msg) {
+ errorTerminal({msg: msg});
+ }
+ });
+}
+
+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(event);
+ return;
+ }
+
+ updateState(states.disconnecting, 'Detecting migration...');
+ setTimeout(checkMigration, 5000);
+}
+
+function clearEvents() {
+ term.onResize(() => {});
+ 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.reason, event.code);
+}
+
+function errorTerminal(event) {
+ event = event || {};
+ clearEvents();
+ clearInterval(ping);
+ socket.close();
+ term.dispose();
+ updateState(states.disconnected, event.msg, event.code);
+}
projects / pve-xtermjs.git / blobdiff