mirror of https://github.com/portainer/portainer
117 lines
3.2 KiB
JavaScript
117 lines
3.2 KiB
JavaScript
import angular from 'angular';
|
|
import { Terminal } from 'xterm';
|
|
import { baseHref } from '@/portainer/helpers/pathHelper';
|
|
|
|
class KubernetesApplicationConsoleController {
|
|
/* @ngInject */
|
|
constructor($async, $state, Notifications, KubernetesApplicationService, LocalStorage) {
|
|
this.$async = $async;
|
|
this.$state = $state;
|
|
this.Notifications = Notifications;
|
|
this.KubernetesApplicationService = KubernetesApplicationService;
|
|
this.LocalStorage = LocalStorage;
|
|
|
|
this.onInit = this.onInit.bind(this);
|
|
}
|
|
|
|
disconnect() {
|
|
this.state.socket.close();
|
|
this.state.term.dispose();
|
|
this.state.connected = false;
|
|
}
|
|
|
|
configureSocketAndTerminal(socket, term) {
|
|
socket.onopen = function () {
|
|
const terminal_container = document.getElementById('terminal-container');
|
|
term.open(terminal_container);
|
|
term.setOption('cursorBlink', true);
|
|
term.focus();
|
|
};
|
|
|
|
term.on('data', function (data) {
|
|
socket.send(data);
|
|
});
|
|
|
|
socket.onmessage = function (msg) {
|
|
term.write(msg.data);
|
|
};
|
|
|
|
socket.onerror = function (err) {
|
|
this.disconnect();
|
|
this.Notifications.error('Failure', err, 'Websocket connection error');
|
|
}.bind(this);
|
|
|
|
this.state.socket.onclose = function () {
|
|
this.disconnect();
|
|
}.bind(this);
|
|
|
|
this.state.connected = true;
|
|
}
|
|
|
|
connectConsole() {
|
|
const params = {
|
|
token: this.LocalStorage.getJWT(),
|
|
endpointId: this.endpoint.Id,
|
|
namespace: this.application.ResourcePool,
|
|
podName: this.podName,
|
|
containerName: this.containerName,
|
|
command: this.state.command,
|
|
};
|
|
|
|
let url =
|
|
window.location.origin +
|
|
baseHref() +
|
|
'api/websocket/pod?' +
|
|
Object.keys(params)
|
|
.map((k) => k + '=' + params[k])
|
|
.join('&');
|
|
if (url.indexOf('https') > -1) {
|
|
url = url.replace('https://', 'wss://');
|
|
} else {
|
|
url = url.replace('http://', 'ws://');
|
|
}
|
|
|
|
this.state.socket = new WebSocket(url);
|
|
this.state.term = new Terminal();
|
|
|
|
this.configureSocketAndTerminal(this.state.socket, this.state.term);
|
|
}
|
|
|
|
async onInit() {
|
|
const availableCommands = ['/bin/bash', '/bin/sh'];
|
|
|
|
this.state = {
|
|
actionInProgress: false,
|
|
availableCommands: availableCommands,
|
|
command: availableCommands[1],
|
|
connected: false,
|
|
socket: null,
|
|
term: null,
|
|
viewReady: false,
|
|
};
|
|
|
|
const podName = this.$transition$.params().pod;
|
|
const applicationName = this.$transition$.params().name;
|
|
const namespace = this.$transition$.params().namespace;
|
|
const containerName = this.$transition$.params().container;
|
|
|
|
this.podName = podName;
|
|
this.containerName = containerName;
|
|
|
|
try {
|
|
this.application = await this.KubernetesApplicationService.get(namespace, applicationName);
|
|
} catch (err) {
|
|
this.Notifications.error('Failure', err, 'Unable to retrieve application logs');
|
|
} finally {
|
|
this.state.viewReady = true;
|
|
}
|
|
}
|
|
|
|
$onInit() {
|
|
return this.$async(this.onInit);
|
|
}
|
|
}
|
|
|
|
export default KubernetesApplicationConsoleController;
|
|
angular.module('portainer.kubernetes').controller('KubernetesApplicationConsoleController', KubernetesApplicationConsoleController);
|