terminalManagerV2.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var vscode = require("vscode");
var TerminalManager = /** @class */ (function () {
    function TerminalManager(eventEmitter) {
        var _this = this;
        this.eventEmitter = eventEmitter;
        this.terminals = {};
        eventEmitter.on('terminal_process_created', function (pty) {
            _this.terminals[pty["id"]] = {
                "terminal": _this.lastCreatedTerminal,
                "pid": parseInt(pty["pid"]),
                "tid": _this.lastTid,
                "shared": _this.lastTerminalIsShared,
                "owner": _this.vfsid
            };
            _this.lastCreatedTerminal.onDidAcceptInput(function (data) {
                _this.eventEmitter.emit('send_ch4_message', ["write", pty["id"], data.toString()]);
            });
            _this.lastCreatedTerminal.terminal.show();
            _this.eventEmitter.emit('send_ch4_message', ["resize", pty["pid"], 159, 33]);
            _this.eventEmitter.emit('send_ch4_message', ["tmux", "", { "capturePane": { "start": -32768, "end": 1000, "pane": "cloud9_terminal_" + _this.lastTid + ":0.0" }, "encoding": "utf8", "name": "xterm-color", "command": "" }, { "$": pty["id"] }]);
            if (!_this.lastTerminalIsShared) {
                _this.eventEmitter.emit('send_ch4_message', // detach other clients if not shared
                ["write", pty["id"], ":detach -a\n"]);
            }
        });
        eventEmitter.on('ch4_data', function (data, environmentId) {
            if (Array.isArray(data)) {
                if (data.length > 2) {
                    if (data[0] == "onEnd") {
                        if (Object.keys(_this.terminals).map(Number).indexOf(data[1]) != -1) {
                            console.log("Terminating terminal");
                            _this.closeTerminal(_this.terminals[data[1]]);
                            delete _this.terminals[data[1]];
                        }
                    }
                    else if (data[0] == "onData") {
                        if (Object.keys(_this.terminals).map(Number).indexOf(data[1]) != -1) {
                            console.log("Emitting terminal data");
                            _this.emitTerminalData(_this.terminals[data[1]], data[2]);
                        }
                        try {
                            var xd = JSON.parse(data[2]);
                            if (xd['type'] == "GENERIC_BROADCAST" && xd['data']['sender'] != _this.vfsid) {
                                if (xd['data']['exttype'] == 'terminal_create') {
                                    var terminal = vscode.window.createTerminalRenderer("Shared Cloud9 Terminal");
                                    _this.terminals['shared_' + xd['data']['tid']] = {
                                        "terminal": terminal,
                                        "pid": null,
                                        "tid": xd['data']['tid'],
                                        "shared": true,
                                        "owner": xd['data']['sender']
                                    };
                                    terminal.terminal.show();
                                }
                                else if (xd['data']['exttype'] == 'terminal_data') {
                                    if ('shared_' + xd['data']['tid'] in _this.terminals) {
                                        _this.terminals['shared_' + xd['data']['tid']]['terminal'].write(xd['data']['data']);
                                    }
                                }
                                else if (xd['data']['exttype'] == 'terminal_destroy') {
                                    if ('shared_' + xd['data']['tid'] in _this.terminals) {
                                        _this.terminals['shared_' + xd['data']['tid']]['terminal'].terminal.dispose();
                                    }
                                }
                            }
                        }
                        catch (err) { }
                    }
                    else if (data[0] == 90) { // terminal creation channel
                        var contents = data[2];
                        console.log("Terminal Process Created");
                        eventEmitter.emit('terminal_process_created', contents["pty"]);
                    }
                }
            }
        });
        vscode.window.onDidCloseTerminal(function (closedTerminal) {
            //delete this.terminals[t];    TODO: Fix clean up of dict, if not shared
        });
    }
    TerminalManager.prototype.addTerminal = function (shared, vfsid) {
        this.vfsid = vfsid;
        this.lastTerminalIsShared = shared;
        var title = "Cloud9 Terminal";
        if (shared) {
            title = "Cloud9 Terminal (shared)";
        }
        this.lastCreatedTerminal = vscode.window.createTerminalRenderer(title);
        this.lastTid = Math.floor(900 * Math.random()) + 100;
        this.eventEmitter.emit('send_ch4_message', ["tmux", "", { "cwd": "/home/ec2-user/environment", "cols": 125, "rows": 33, "name": "xterm-color", "base": "/home/ec2-user/.c9", "attach": false, "session": "cloud9_terminal_" + this.lastTid, "output": false, "terminal": true, "detachOthers": true, "defaultEditor": false, "encoding": "utf8", "command": "bash -l" }, { "$": 90 }]);
        if (shared) {
            this.eventEmitter.emit('send_ch4_message', ["call", "collab", "send", [this.vfsid, { "type": "GENERIC_BROADCAST", "data": { "exttype": "terminal_create", "tid": this.lastTid, "sender": this.vfsid } }]]);
        }
        console.log("init'd remote terminal");
    };
    TerminalManager.prototype.closeTerminal = function (terminal) {
        terminal.terminal.dispose();
        if (terminal['shared']) {
            this.eventEmitter.emit('send_ch4_message', ["call", "collab", "send", [this.vfsid, { "type": "GENERIC_BROADCAST", "data": { "exttype": "terminal_destroy", "tid": terminal['tid'], "sender": this.vfsid } }]]);
        }
    };
    TerminalManager.prototype.closeAll = function () {
        var _this = this;
        Object.values(this.terminals).forEach(function (terminal) {
            _this.closeTerminal(terminal);
        });
    };
    TerminalManager.prototype.emitTerminalData = function (terminal, data) {
        if (typeof data == "string") {
            terminal['terminal'].write(data);
            if (terminal['shared']) {
                /// 4{"ack":20042,"seq":10051,"d":["onData",10,"{\"type\":\"MESSAGE\",\"data\":{\"source\":\"9c0r243bg2MEXXXX\",\"target\":\"9cmXSwNs63hEXXXX\",\"action\":\"listOpenFiles\",\"docId\":\"\"},\"command\":\"vfs-collab\"}"]}
                this.eventEmitter.emit('send_ch4_message', ["call", "collab", "send", [this.vfsid, { "type": "GENERIC_BROADCAST", "data": { "exttype": "terminal_data", "data": data, "tid": terminal['tid'], "sender": this.vfsid } }]]);
            }
        }
    };
    return TerminalManager;
}());
exports.TerminalManager = TerminalManager;