xterm.js

// @flow
/*jshint esversion: 6 */
/*jslint node: true */
"use strict";

const express = require("express");
const getUserDataDir = require("./main.js").getUserDataDir();
const app = express();
const expressWs = require("express-ws")(app);
const os = require("os");
const auth = require("http-auth");
let basic = auth.basic({
    realm: "eleos",
    file: (getUserDataDir + "/eleos.htpasswd")
});

let terminals = {},
    logs = {};

app.use(auth.connect(basic));

app.use("/resources/", express.static(__dirname + "/resources"));

app.use("/xterm/", express.static(__dirname + "/node_modules/xterm/dist"));

app.get("/", function (req, res) {
    res.sendFile(__dirname + "/console.html");
});

app.get("/console.html", function (req, res) {
    res.sendFile(__dirname + "/console.html");
});

app.get("/style.css", function (req, res) {
    res.sendFile(__dirname + "/resources/xtermjs.css");
});

app.get("/main.js", function (req, res) {
    res.sendFile(__dirname + "/resources/xtermjs.js");
});

app.get("/fetch.min.js", function (req, res) {
    res.sendFile(__dirname + "/resources/fetch.min.js");
});

app.post("/terminals", function (req, res) {
    const pty = require("node-pty");
    let cols = parseInt(req.query.cols);
    let rows = parseInt(req.query.rows);
    let shell = process.platform === "win32" ? "cmd.exe" : "bash";
    let command = process.platform === "win32" ? ["/k", "cd " + __dirname] : ["-c", "cd " + __dirname + " && bash"];
    let term = pty.spawn(shell, command, {
        name: "xterm-color",
        cols: cols || 80,
        rows: rows || 24,
        cwd: process.env.HOME,
        env: process.env
    });

    console.log("Created terminal with PID: " + term.pid);
    terminals[term.pid] = term;
    logs[term.pid] = "";
    term.on("data", function (data) {
        logs[term.pid] += data;
    });
    res.send(term.pid.toString());
    res.end();
});

app.post("/terminals/:pid/size", function (req, res) {
    let pid = parseInt(req.params.pid);
    let cols = parseInt(req.query.cols);
    let rows = parseInt(req.query.rows);
    let term = terminals[pid];

    term.resize(cols, rows);
    console.log("Resized terminal " + pid + " to " + cols + " cols and " + rows + " rows.");
    res.end();
});

app.ws("/terminals/:pid", function (ws, req) {
    let term = terminals[parseInt(req.params.pid)];
    console.log("Connected to terminal " + term.pid);
    ws.send(logs[term.pid]);

    term.on("data", function (data) {
        try {
            ws.send(data);
        } catch (ex) {
            // The WebSocket is not open, ignore
        }
    });
    ws.on("message", function (msg) {
        term.write(msg);
    });
    ws.on("close", function () {
        term.kill();
        console.log("Closed terminal " + term.pid);
        // Clean things up
        delete terminals[term.pid];
        delete logs[term.pid];
    });
});

let port = process.env.PORT || 3000;
let host = os.platform() === "win32" ? "127.0.0.1" : "0.0.0.0";

app.listen(port, host);