Early work on IP KVM integration.

MeshCentralServer.njsproj

@@ -109,6 +109,7 @@
     <Compile Include="meshbot.js" />
     <Compile Include="meshctrl.js" />
     <Compile Include="meshdesktopmultiplex.js" />
+    <Compile Include="meshipkvm.js" />
     <Compile Include="meshmail.js" />
     <Compile Include="meshrelay.js" />
     <Compile Include="meshsms.js" />

meshcentral.js

@@ -59,6 +59,7 @@ function CreateMeshCentralServer(config, args) {
     obj.meshAgentBinaries = {};       // Mesh Agent Binaries, Architecture type --> { hash:(sha384 hash), size:(binary size), path:(binary path) }
     obj.meshAgentInstallScripts = {}; // Mesh Install Scripts, Script ID -- { hash:(sha384 hash), size:(binary size), path:(binary path) }
     obj.multiServer = null;
+    obj.ipKvmManager = null;
     obj.maintenanceTimer = null;
     obj.serverId = null;
     obj.serverKey = Buffer.from(obj.crypto.randomBytes(48), 'binary');
@@ -1566,7 +1567,7 @@ function CreateMeshCentralServer(config, args) {
                 if ((typeof obj.config.settings.mqtt == 'object') && (typeof obj.config.settings.mqtt.auth == 'object') && (typeof obj.config.settings.mqtt.auth.keyid == 'string') && (typeof obj.config.settings.mqtt.auth.key == 'string')) { obj.mqttbroker = require("./mqttbroker.js").CreateMQTTBroker(obj, obj.db, obj.args); }
 
                 // Start the web server and if needed, the redirection web server.
-                obj.webserver = require('./webserver.js').CreateWebServer(obj, obj.db, obj.args, obj.certificates);
+                obj.webserver = require('./webserver.js').CreateWebServer(obj, obj.db, obj.args, obj.certificates, obj.StartEx5);
                 if (obj.redirserver != null) { obj.redirserver.hookMainWebServer(obj.certificates); }
 
                 // Update proxy certificates
@@ -1815,6 +1816,14 @@ function CreateMeshCentralServer(config, args) {
         });
     };
 
+    // Called when the web server finished loading
+    obj.StartEx5 = function () {
+        // Setup the email server for each domain
+        var ipKvmSupport = false;
+        for (var i in obj.config.domains) { if (obj.config.domains[i].ipkvm == true) { ipKvmSupport = true; } }
+        if (ipKvmSupport) { obj.ipKvmManager = require('./meshipkvm').CreateIPKVMManager(obj); }
+    }
+
     // Refresh any certificate hashs from the reverse proxy
     obj.pendingProxyCertificatesRequests = 0;
     obj.lastProxyCertificatesRequest = null;

meshipkvm.js

@@ -0,0 +1,335 @@
+/**
+* @description MeshCentral IP KVM Management Module
+* @author Ylian Saint-Hilaire
+* @copyright Intel Corporation 2021
+* @license Apache-2.0
+* @version v0.0.1
+*/
+
+function CreateIPKVMManager(parent) {
+    const obj = {};
+    const managedGroups = {} // meshid --> Manager
+    
+    // Subscribe for mesh creation events
+    parent.AddEventDispatch(['server-createmesh', 'server-deletemesh'], obj);
+    obj.HandleEvent = function (source, event, ids, id) {
+        if ((event != null) && (event.action == 'createmesh') && (event.mtype == 4)) {
+            // Start managing this new device group
+            startManagement(parent.webserver.meshes[event.meshid]);
+        } else if ((event != null) && (event.action == 'deletemesh') && (event.mtype == 4)) {
+            // Stop managing this device group
+            stopManagement(event.meshid);
+        }
+    }
+    
+    // Run thru the list of device groups that require 
+    for (var i in parent.webserver.meshes) {
+        const mesh = parent.webserver.meshes[i];
+        if ((mesh.mtype == 4) && (mesh.deleted == null)) { startManagement(mesh); }
+    }
+    
+    // Start managing a IP KVM device
+    function startManagement(mesh) {
+        if ((mesh == null) || (mesh.mtype != 4) || (mesh.kvm == null) || (mesh.deleted != null) || (managedGroups[mesh._id] != null)) return;
+        var port = 443, hostSplit = mesh.kvm.host.split(':'), host = hostSplit[0];
+        if (hostSplit.length == 2) { port = parseInt(hostSplit[1]); }
+        if (mesh.kvm.model == 1) { // Raritan KX III
+            const manager = CreateRaritanKX3Manager(host, port, mesh.kvm.user, mesh.kvm.pass);
+            manager.meshid = mesh._id;
+            managedGroups[mesh._id] = manager;
+            manager.onStateChanged = onStateChanged;
+            manager.onPortsChanged = onPortsChanged;
+            manager.start();
+        }
+    }
+    
+    // Stop managing a IP KVM device
+    function stopManagement(meshid) {
+        const manager = managedGroups[meshid];
+        if (manager != null) { delete managedGroups[meshid]; manager.stop(); }
+    }
+    
+    // Called when a KVM device changes state
+    function onStateChanged(sender, state) {
+        console.log('State: ' + ['Disconnected', 'Connecting', 'Connected'][state]);
+        if (state == 2) {
+            console.log('DeviceModel:', sender.deviceModel);
+            console.log('FirmwareVersion:', sender.firmwareVersion);
+        }
+    }
+    
+    // Called when a KVM device changes state
+    function onPortsChanged(sender, updatedPorts) {
+        for (var i = 0; i < updatedPorts.length; i++) {
+            const port = sender.ports[updatedPorts[i]];
+            if ((port.Status == 1) && (port.Class == 'KVM')) {
+                console.log(port.PortNumber + ', ' + port.PortId + ', ' + port.Name + ', ' + port.Type + ', ' + ((port.StatAvailable == 0) ? 'Idle' : 'Connected'));
+            }
+        }
+    }
+
+    return obj;
+}
+
+function CreateRaritanKX3Manager(hostname, port, username, password) {
+    const https = require('https');
+    const obj = {};
+    var updateTimer = null;
+    var retryTimer = null;
+
+    obj.authCookie = null;
+    obj.state = 0; // 0 = Disconnected, 1 = Connecting, 2 = Connected
+    obj.ports = [];
+    obj.portCount = 0;
+    obj.portHash = null;
+    obj.deviceCount = 0;
+    obj.deviceHash = null;
+    obj.started = false;
+
+    // Events
+    obj.onStateChanged = null;
+    obj.onPortsChanged = null;
+
+    function onCheckServerIdentity(cert) {
+        console.log('TODO: Certificate Check');
+    }
+
+    obj.start = function () {
+        if (obj.started) return;
+        obj.started = true;
+        if (obj.state == 0) connect();
+    }
+
+    obj.stop = function () {
+        if (!obj.started) return;
+        obj.started = false;
+        if (retryTimer != null) { clearTimeout(retryTimer); retryTimer = null; }
+        setState(0);
+    }
+
+    function setState(newState) {
+        if (obj.state == newState) return;
+        obj.state = newState;
+        if (obj.onStateChanged != null) { obj.onStateChanged(obj, newState); }
+        if ((newState == 2) && (updateTimer == null)) { updateTimer = setInterval(obj.update, 10000); }
+        if ((newState != 2) && (updateTimer != null)) { clearInterval(updateTimer); updateTimer = null; }
+        if ((newState == 0) && (obj.started == true) && (retryTimer == null)) { retryTimer = setTimeout(connect, 20000); }
+    }
+
+    function connect() {
+        if (obj.state != 0) return;
+        setState(1); // 1 = Connecting
+        obj.authCookie = null;
+        if (retryTimer != null) { clearTimeout(retryTimer); retryTimer = null; }
+        const data = new TextEncoder().encode('is_dotnet=0&is_javafree=0&is_standalone_client=0&is_javascript_kvm_client=1&is_javascript_rsc_client=1&login=' + encodeURIComponent(username) + '&password=' + encodeURIComponent(password) + '&action_login=Login');
+        const options = {
+            hostname: hostname,
+            port: port,
+            rejectUnauthorized: false,
+            checkServerIdentity: onCheckServerIdentity,
+            path: '/auth.asp?client=javascript', // ?client=standalone
+            method: 'POST',
+            headers: {
+                'Content-Type': 'text/html; charset=UTF-8',
+                'Content-Length': data.length
+            }
+        }
+        const req = https.request(options, function (res) {
+            if (obj.state == 0) return;
+            if ((res.statusCode != 302) || (res.headers['set-cookie'] == null) || (res.headers['location'] == null)) { setState(0); return; }
+            for (var i in res.headers['set-cookie']) { if (res.headers['set-cookie'][i].startsWith('pp_session_id=')) { obj.authCookie = res.headers['set-cookie'][i].substring(14).split(';')[0]; } }
+            if (obj.authCookie == null) { setState(0); return; }
+            res.on('data', function (d) { })
+            fetchInitialInformation();
+        })
+        req.on('error', function (error) { setState(0); })
+        req.write(data);
+        req.end();
+    }
+
+    function checkCookie() {
+        if (obj.state != 2) return;
+        const options = {
+            hostname: hostname,
+            port: port,
+            rejectUnauthorized: false,
+            checkServerIdentity: onCheckServerIdentity,
+            path: '/cookiecheck.asp',
+            method: 'GET',
+            headers: {
+                'Content-Type': 'text/html; charset=UTF-8',
+                'Cookie': 'pp_session_id=' + obj.authCookie
+            }
+        }
+        const req = https.request(options, function (res) {
+            if (obj.state == 0) return;
+            if (res.statusCode != 302) { setState(0); return; }
+            if (res.headers['set-cookie'] != null) { for (var i in res.headers['set-cookie']) { if (res.headers['set-cookie'][i].startsWith('pp_session_id=')) { obj.authCookie = res.headers['set-cookie'][i].substring(14).split(';')[0]; } } }
+            res.on('data', function (d) { })
+        });
+        req.on('error', function (error) { setState(0); })
+        req.end();
+    }
+
+    function fetchInitialInformation() {
+        fetch('/webs_cron.asp?_portsstatushash=&_devicesstatushash=&webs_job=sidebarupdates', null, null, function (server, tag, data) {
+            const parsed = parseJsScript(data);
+            for (var i in parsed['updateSidebarPanel']) {
+                if (parsed['updateSidebarPanel'][i][0] == "cron_device") {
+                    obj.firmwareVersion = getSubString(parsed['updateSidebarPanel'][i][1], "Firmware:  ", "<");
+                    obj.deviceModel = getSubString(parsed['updateSidebarPanel'][i][1], "<div class=\"device-model\">", "<");
+                }
+            }
+            fetch('/sidebar.asp', null, null, function (server, tag, data) {
+                var dataBlock = getSubString(data, "updateKVMLinkHintOnContainer();", "devices.resetDevicesNew(1);");
+                if (dataBlock == null) { setState(0); return; }
+                const parsed = parseJsScript(dataBlock);
+                obj.portCount = parseInt(parsed['updatePortStatus'][0][0]) - 2;
+                obj.portHash = parsed['updatePortStatus'][0][1];
+                obj.deviceCount = parseInt(parsed['updateDeviceStatus'][0][0]);
+                obj.deviceHash = parsed['updateDeviceStatus'][0][1];
+                var updatedPorts = [];
+                for (var i = 0; i < parsed['addPortNew'].length; i++) {
+                    const portInfo = parsePortInfo(parsed['addPortNew'][i]);
+                    obj.ports[portInfo.hIndex] = portInfo;
+                    updatedPorts.push(portInfo.hIndex);
+                }
+                setState(2);
+                if (obj.onPortsChanged != null) { obj.onPortsChanged(obj, updatedPorts); }
+            });
+        });
+    }
+
+    obj.update = function () {
+        fetch('/webs_cron.asp?_portsstatushash=' + obj.portHash + '&_devicesstatushash=' + obj.deviceHash, null, null, function (server, tag, data) {
+            const parsed = parseJsScript(data);
+            if (parsed['updatePortStatus']) {
+                obj.portCount = parseInt(parsed['updatePortStatus'][0][0]) - 2;
+                obj.portHash = parsed['updatePortStatus'][0][1];
+            }
+            if (parsed['updateDeviceStatus']) {
+                obj.deviceCount = parseInt(parsed['updateDeviceStatus'][0][0]);
+                obj.deviceHash = parsed['updateDeviceStatus'][0][1];
+            }
+            if (parsed['updatePort']) {
+                var updatedPorts = [];
+                for (var i = 0; i < parsed['updatePort'].length; i++) {
+                    const portInfo = parsePortInfo(parsed['updatePort'][i]);
+                    obj.ports[portInfo.hIndex] = portInfo;
+                    updatedPorts.push(portInfo.hIndex);
+                }
+                if ((updatedPorts.length > 0) && (obj.onPortsChanged != null)) { obj.onPortsChanged(obj, updatedPorts); }
+            }
+        });
+    }
+
+    function parsePortInfo(args) {
+        var out = {};
+        for (var i = 0; i < args.length; i++) {
+            var parsed = parseJsScript(args[i]);
+            var v = parsed.J[0][1], vv = parseInt(v);
+            out[parsed.J[0][0]] = (v == vv)?vv:v;
+        }
+        return out;
+    }
+
+    function getSubString(str, start, end) {
+        var i = str.indexOf(start);
+        if (i < 0) return null;
+        str = str.substring(i + start.length);
+        i = str.indexOf(end);
+        if (i >= 0) { str = str.substring(0, i); }
+        return str;
+    }
+
+    // Parse JavaScript code calls
+    function parseJsScript(str) {
+        const out = {};
+        var functionName = '';
+        var args = [];
+        var arg = null;
+        var stack = [];
+        for (var i = 0; i < str.length; i++) {
+            if (stack.length == 0) {
+                if (str[i] != '(') {
+                    if (isAlphaNumeric(str[i])) { functionName += str[i]; } else { functionName = ''; }
+                } else {
+                    stack.push(')');
+                }
+            } else {
+                if (str[i] == stack[stack.length - 1]) {
+                    if (stack.length > 1) { if (arg == null) { arg = str[i]; } else { arg += str[i]; } }
+                    if (stack.length == 2) {
+                        if (arg != null) { args.push(trimQuotes(arg)); }
+                        arg = null;
+                    } else if (stack.length == 1) {
+                        if (arg != null) { args.push(trimQuotes(arg)); arg = null; }
+                        if (args.length > 0) {
+                            if (out[functionName] == null) {
+                                out[functionName] = [args];
+                            } else {
+                                out[functionName].push(args);
+                            }
+                        }
+                        args = [];
+                    }
+                    stack.pop();
+                } else if ((str[i] == '\'') || (str[i] == '"') || (str[i] == '(')) {
+                    if (str[i] == '(') { stack.push(')'); } else { stack.push(str[i]); }
+                    if (stack.length > 0) {
+                        if (arg == null) { arg = str[i]; } else { arg += str[i]; }
+                    }
+                } else {
+                    if ((stack.length == 1) && (str[i] == ',')) {
+                        if (arg != null) { args.push(trimQuotes(arg)); arg = null; }
+                    } else {
+                        if (stack.length > 0) { if (arg == null) { arg = str[i]; } else { arg += str[i]; } }
+                    }
+                }
+            }
+        }
+        return out;
+    }
+
+    function trimQuotes(str) {
+        if ((str == null) || (str.length < 2)) return str;
+        str = str.trim();
+        if ((str[0] == '\'') && (str[str.length - 1] == '\'')) { return str.substring(1, str.length - 1); }
+        if ((str[0] == '"') && (str[str.length - 1] == '"')) { return str.substring(1, str.length - 1); }
+        return str;
+    }
+
+    function isAlphaNumeric(char) {
+        return ((char >= 'A') && (char <= 'Z')) || ((char >= 'a') && (char <= 'z')) || ((char >= '0') && (char <= '9'));
+    }
+
+    function fetch(url, postdata, tag, func) {
+        if (obj.state == 0) return;
+        var data = '';
+        const options = {
+            hostname: hostname,
+            port: port,
+            rejectUnauthorized: false,
+            checkServerIdentity: onCheckServerIdentity,
+            path: url,
+            method: (postdata != null)?'POST':'GET',
+            headers: {
+                'Content-Type': 'text/html; charset=UTF-8',
+                'Cookie': 'pp_session_id=' + obj.authCookie
+            }
+        }
+        const req = https.request(options, function (res) {
+            if (obj.state == 0) return;
+            if (res.statusCode != 200) { setState(0); return; }
+            if (res.headers['set-cookie'] != null) { for (var i in res.headers['set-cookie']) { if (res.headers['set-cookie'][i].startsWith('pp_session_id=')) { obj.authCookie = res.headers['set-cookie'][i].substring(14).split(';')[0]; } } }
+            res.on('data', function (d) { data += d; });
+            res.on('end', function () { func(obj, tag, data); });
+        });
+        req.on('error', function (error) { setState(0); })
+        req.end();
+    }
+
+    return obj;
+}
+
+module.exports.CreateIPKVMManager = CreateIPKVMManager;

meshuser.js

@@ -2513,7 +2513,7 @@ module.exports.CreateMeshUser = function (parent, db, ws, req, args, domain, use
 
                         // Event the device group creation
                         var event = { etype: 'mesh', userid: user._id, username: user.name, meshid: meshid, name: command.meshname, mtype: command.meshtype, desc: command.desc, action: 'createmesh', links: links, msgid: 76, msgArgs: [command.meshname], msg: 'Device group created: ' + command.meshname, domain: domain.id, creation: mesh.creation, creatorid: mesh.creatorid, creatorname: mesh.creatorname, flags: mesh.flags, consent: mesh.consent };
-                        parent.parent.DispatchEvent(['*', meshid, user._id], obj, event); // Even if DB change stream is active, this event must be acted upon.
+                        parent.parent.DispatchEvent(['*', 'server-createmesh', meshid, user._id], obj, event); // Even if DB change stream is active, this event must be acted upon.
 
                         // Log in the auth log
                         if (parent.parent.authlog) { parent.parent.authLog('https', 'User ' + user.name + ' created device group ' + mesh.name); }
@@ -2559,8 +2559,8 @@ module.exports.CreateMeshUser = function (parent, db, ws, req, args, domain, use
                     if (err != null) { if (command.responseid != null) { try { ws.send(JSON.stringify({ action: 'deletemesh', responseid: command.responseid, result: err })); } catch (ex) { } } return; }
 
                     // Fire the removal event first, because after this, the event will not route
-                    var event = { etype: 'mesh', userid: user._id, username: user.name, meshid: command.meshid, name: command.meshname, action: 'deletemesh', msgid: 77, msgArgs: [command.meshname], msg: 'Device group deleted: ' + command.meshname, domain: domain.id };
-                    parent.parent.DispatchEvent(parent.CreateMeshDispatchTargets(command.meshid), obj, event); // Even if DB change stream is active, this event need to be acted on.
+                    var event = { etype: 'mesh', userid: user._id, username: user.name, mtype: mesh.mtype, meshid: command.meshid, name: command.meshname, action: 'deletemesh', msgid: 77, msgArgs: [command.meshname], msg: 'Device group deleted: ' + command.meshname, domain: domain.id };
+                    parent.parent.DispatchEvent(parent.CreateMeshDispatchTargets(command.meshid, ['server-deletemesh']), obj, event); // Even if DB change stream is active, this event need to be acted on.
 
                     // Remove all user links to this mesh
                     for (var j in mesh.links) {

webserver.js

@@ -31,7 +31,7 @@ if (!String.prototype.startsWith) { String.prototype.startsWith = function (sear
 if (!String.prototype.endsWith) { String.prototype.endsWith = function (searchString, position) { var subjectString = this.toString(); if (typeof position !== 'number' || !isFinite(position) || Math.floor(position) !== position || position > subjectString.length) { position = subjectString.length; } position -= searchString.length; var lastIndex = subjectString.lastIndexOf(searchString, position); return lastIndex !== -1 && lastIndex === position; }; }
 
 // Construct a HTTP server object
-module.exports.CreateWebServer = function (parent, db, args, certificates) {
+module.exports.CreateWebServer = function (parent, db, args, certificates, doneFunc) {
     var obj = {}, i = 0;
 
     // Modules
@@ -6307,6 +6307,9 @@ module.exports.CreateWebServer = function (parent, db, args, certificates) {
 
         // Start on a second agent-only alternative port if needed.
         if (obj.args.agentport) { CheckListenPort(obj.args.agentport, obj.args.agentportbind, StartAltWebServer); }
+
+        // We are done starting the web server.
+        if (doneFunc) doneFunc();
     }
 
     // Perform server inner authentication