yunkong2.socketio/main.js

/* jshint -W097 */// jshint strict:false
/*jslint node: true */
'use strict';

const utils     = require(__dirname + '/lib/utils'); // Get common adapter utils
const IOSocket  = require(__dirname + '/lib/socket.js');
const LE        = require(utils.controllerDir + '/lib/letsencrypt.js');

let webServer = null;
let store     = null;
let secret    = 'Zgfr56gFe87jJOM'; // Will be generated by first start

const adapter   = new utils.Adapter('socketio');

adapter.on('objectChange', (id, obj) => {
    if (webServer && webServer.io) {
        webServer.io.publishAll('objectChange', id, obj);
    }
});

adapter.on('stateChange', (id, state) => {
    if (webServer && webServer.io) {
        webServer.io.publishAll('stateChange', id, state);
    }
});

adapter.on('unload', callback => {
    try {
        adapter.log.info('terminating http' + (webServer.settings.secure ? 's' : '') + ' server on port ' + webServer.settings.port);
        webServer.io.close();

        callback();
    } catch (e) {
        callback();
    }
});

adapter.on('ready', () => {
    if (adapter.config.auth) {
        // Generate secret for session manager
        adapter.getForeignObject('system.config', (err, obj) => {
            if (!err && obj) {
                if (!obj.native || !obj.native.secret) {
                    obj.native = obj.native || {};
                    require('crypto').randomBytes(24, (ex, buf) => {
                        secret = buf.toString('hex');
                        adapter.extendForeignObject('system.config', {native: {secret: secret}});
                        main();
                    });
                } else {
                    secret = obj.native.secret;
                    main();
                }
            } else {
                adapter.logger.error('Cannot find object system.config');
            }
        });
    } else {
        main();
    }

});

adapter.on('log', obj => {
    if (webServer && webServer.io) {
        webServer.io.sendLog(obj);
    }
});

function main() {
    if (adapter.config.secure) {
        // Load certificates
        adapter.getCertificates(function (err, certificates, leConfig) {
            adapter.config.certificates = certificates;
            adapter.config.leConfig     = leConfig;
            webServer = initWebServer(adapter.config);
        });
    } else {
        webServer = initWebServer(adapter.config);
    }
}

//settings: {
//    "port":   8080,
//    "auth":   false,
//    "secure": false,
//    "bind":   "0.0.0.0", // "::"
//}
function initWebServer(settings) {

    const server = {
        app:       null,
        server:    null,
        io:        null,
        settings:  settings
    };

    settings.port = parseInt(settings.port, 10) || 0;

    if (settings.port) {
        if (settings.secure) {
            if (!settings.certificates) return null;
        }
        if (settings.auth) {
            const session =          require('express-session');
            const AdapterStore =     require(utils.controllerDir + '/lib/session.js')(session, settings.ttl);
            // Authentication checked by server itself
            store = new AdapterStore({adapter: adapter});
            settings.secret           = secret;
            settings.store            = store;
            settings.ttl              = settings.ttl || 3600;
            settings.forceWebSockets  = settings.forceWebSockets || false;
        }

        adapter.getPort(settings.port, port => {
            if (parseInt(port, 10) !== settings.port && !adapter.config.findNextPort) {
                adapter.log.error('port ' + settings.port + ' already in use');
                process.exit(1);
            }
            settings.port = port;

            server.server = LE.createServer((req, res) => {
                res.writeHead(501);
                res.end('Not Implemented');
            }, settings, adapter.config.certificates, adapter.config.leConfig, adapter.log);

            server.server.listen(settings.port, (settings.bind && settings.bind !== '0.0.0.0') ? settings.bind : undefined);

            settings.crossDomain     = true;
            settings.ttl             = settings.ttl || 3600;
            settings.forceWebSockets = settings.forceWebSockets || false;

            server.io = new IOSocket(server.server, settings, adapter);
        });
    } else {
        adapter.log.error('port missing');
        process.exit(1);
    }

    return server;
}