infoscreen3/modules/websocket.js

let meta = require("../data/meta.json");
let display = require("./display.js");
let admin = require("./admin.js");
let cli = require('./cli.js');
let bundleManager = require('./bundleManager.js');
let chalk = require('chalk');
let fs = require('fs');

/**
 *
 * @type {module:infoscreen3/display[]}
 */
let screenView = [];

/**
 * @exports infoscreen3/websocket
 */
module.exports = function (server, app, io, dispatcher) {
    console.log(chalk.green(">> ") + "InfoScreen3" + chalk.green("<<"));
    cli.log("Checking for write permissions...");

    try {
        fs.accessSync("./data", fs.W_OK);
        cli.success("data directory (./data) is writable");
    } catch (err) {
        cli.error("data directory (./data) is not writable", err);
        process.exit(1);
    }

    try {
        fs.accessSync("./tmp", fs.W_OK);
        cli.success("temp directory (./tmp) is writable ");
        let tempFiles = fs.readdirSync("./tmp/", {
            dotfiles: false
        });
        cli.info("removing temp-files...");
        for (let file of tempFiles) {
            if (file !== ".gitkeep") {
                fs.unlinkSync("./tmp/" + file);
            }
        }
        cli.info("done.");

    } catch (err) {
        cli.error("temp directory (./tmp) is not writable", err);
        process.exit(1);
    }

    cli.info("Starting bundle manager...");

    let bundler = new bundleManager();

    cli.info("Starting websocket backends...");

    let screenId = 0;
    for (let metadata of meta.displays) {
        screenView.push(new display(io, dispatcher, metadata, screenId, bundler));
        screenId += 1;
    }

    let adminView = new admin(io, dispatcher, screenView, bundler);

    io.of("/lobby").on("connection", function (socket) {
        cli.info("WS/" + socket.conn.remoteAddress + " connect");

        socket.on('error', function (error) {
            cli.error(error, "WS/ error");
        });

        socket.on('disconnect', function (reason) {
            cli.info("WS/ " + reason + " " + socket.conn.remoteAddress);
        });

        socket.on('displays', function () {
            let previewImages = [];
            for (let display of screenView) {
                previewImages.push("/render/" + display.serverOptions.currentBundle + "/" + display.serverOptions.currentFile + ".png");
            }
            socket.emit("callback.displays", {displays: meta.displays, previewImages: previewImages});
        });
    });

    return screenView;
};