MeshCentral-Dokploy/agents/meshcore.js

/*
Copyright 2018-2022 Intel Corporation

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

process.on('uncaughtException', function (ex) {
    require('MeshAgent').SendCommand({ action: 'msg', type: 'console', value: "uncaughtException1: " + ex });
});
if (process.platform == 'win32' && require('user-sessions').getDomain == null) {
    require('user-sessions').getDomain = function getDomain(uid) {
        return (this.getSessionAttribute(uid, this.InfoClass.WTSDomainName));
    };
}

var promise = require('promise');

// Mesh Rights
var MNG_ERROR = 65;
var MESHRIGHT_EDITMESH = 1;
var MESHRIGHT_MANAGEUSERS = 2;
var MESHRIGHT_MANAGECOMPUTERS = 4;
var MESHRIGHT_REMOTECONTROL = 8;
var MESHRIGHT_AGENTCONSOLE = 16;
var MESHRIGHT_SERVERFILES = 32;
var MESHRIGHT_WAKEDEVICE = 64;
var MESHRIGHT_SETNOTES = 128;
var MESHRIGHT_REMOTEVIEW = 256; // Remote View Only
var MESHRIGHT_NOTERMINAL = 512;
var MESHRIGHT_NOFILES = 1024;
var MESHRIGHT_NOAMT = 2048;
var MESHRIGHT_LIMITEDINPUT = 4096;
var MESHRIGHT_LIMITEVENTS = 8192;
var MESHRIGHT_CHATNOTIFY = 16384;
var MESHRIGHT_UNINSTALL = 32768;
var MESHRIGHT_NODESKTOP = 65536;

var pendingSetClip = false; // This is a temporary hack to prevent multiple setclips at the same time to stop the agent from crashing.

//
// This is a helper function used by the 32 bit Windows Agent, when running on 64 bit windows. It will check if the agent is already patched for this
// and will use this helper if it is not. This helper will inject 'sysnative' into the results when calling readdirSync() on %windir%.
//
function __readdirSync_fix(path)
{
    var sysnative = false;
    pathstr = require('fs')._fixwinpath(path);
    if (pathstr.split('\\*').join('').toLowerCase() == process.env['windir'].toLowerCase()) { sysnative = true; }

    var ret = require('fs').__readdirSync_old(path);
    if (sysnative) { ret.push('sysnative'); }
    return (ret);
}

if (process.platform == 'win32' && require('_GenericMarshal').PointerSize == 4 && require('os').arch() == 'x64')
{
    if (require('fs').readdirSync.version == null)
    {
        //
        // 32 Bit Windows Agent on 64 bit Windows has not been patched for sysnative issue, so lets use our own solution
        //
        require('fs').__readdirSync_old = require('fs').readdirSync;
        require('fs').readdirSync = __readdirSync_fix;
    }
}

function bcdOK() {
    if (process.platform != 'win32') { return (false); }
    if (require('os').arch() == 'x64') {
        return (require('_GenericMarshal').PointerSize == 8);
    }
    return (true);
}
function getDomainInfo() {
    var hostname = require('os').hostname();
    var ret = { Name: hostname, Domain: "", PartOfDomain: false };

    switch (process.platform) {
        case 'win32':
            try {
                ret = require('win-wmi').query('ROOT\\CIMV2', 'SELECT * FROM Win32_ComputerSystem', ['Name', 'Domain', 'PartOfDomain'])[0];
            }
            catch (x) {
            }
            break;
        case 'linux':
            var hasrealm = false;

            try {
                hasrealm = require('lib-finder').hasBinary('realm');
            }
            catch (x) {
            }
            if (hasrealm) {
                var child = require('child_process').execFile('/bin/sh', ['sh']);
                child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
                child.stdin.write("realm list | grep domain-name: | tr '\\n' '`' | ");
                child.stdin.write("awk -F'`' '{ ");
                child.stdin.write('        printf("[");');
                child.stdin.write('        ST="";');
                child.stdin.write('        for(i=1;i<NF;++i)');
                child.stdin.write('        {');
                child.stdin.write('            match($i,/domain-name: /);');
                child.stdin.write('            printf("%s\\"%s\\"", ST, substr($i, RSTART+RLENGTH));');
                child.stdin.write('            ST=",";');
                child.stdin.write('        }');
                child.stdin.write('        printf("]");');
                child.stdin.write("     }'");
                child.stdin.write('\nexit\n');
                child.waitExit();
                var names = [];
                try {
                    names = JSON.parse(child.stdout.str);
                }
                catch (e) {
                }
                while (names.length > 0) {
                    if (hostname.endsWith('.' + names.peek())) {
                        ret = { Name: hostname.substring(0, hostname.length - names.peek().length - 1), Domain: names.peek(), PartOfDomain: true };
                        break;
                    }
                    names.pop();
                }
            }
            break;
    }
    return (ret);
}



try {
    Object.defineProperty(Array.prototype, 'findIndex', {
        value: function (func) {
            var i = 0;
            for (i = 0; i < this.length; ++i) {
                if (func(this[i], i, this)) {
                    return (i);
                }
            }
            return (-1);
        }
    });
} catch (ex) { }

if (require('MeshAgent').ARCHID == null) {
    var id = null;
    switch (process.platform) {
        case 'win32':
            id = require('_GenericMarshal').PointerSize == 4 ? 3 : 4;
            break;
        case 'freebsd':
            id = require('_GenericMarshal').PointerSize == 4 ? 31 : 30;
            break;
        case 'darwin':
            try {
                id = require('os').arch() == 'x64' ? 16 : 29;
            } catch (ex) { id = 16; }
            break;
    }
    if (id != null) { Object.defineProperty(require('MeshAgent'), 'ARCHID', { value: id }); }
}

function setDefaultCoreTranslation(obj, field, value) {
    if (obj[field] == null || obj[field] == '') { obj[field] = value; }
}

function getCoreTranslation() {
    var ret = {};
    if (global.coretranslations != null) {
        try {
            var lang = require('util-language').current;
            if (coretranslations[lang] == null) { lang = lang.split('-')[0]; }
            if (coretranslations[lang] == null) { lang = 'en'; }
            if (coretranslations[lang] != null) { ret = coretranslations[lang]; }
        }
        catch (ex) { }
    }

    setDefaultCoreTranslation(ret, 'allow', 'Allow');
    setDefaultCoreTranslation(ret, 'deny', 'Deny');
    setDefaultCoreTranslation(ret, 'autoAllowForFive', 'Auto accept all connections for next 5 minutes');
    setDefaultCoreTranslation(ret, 'terminalConsent', '{0} requesting remote terminal access. Grant access?');
    setDefaultCoreTranslation(ret, 'desktopConsent', '{0} requesting remote desktop access. Grant access?');
    setDefaultCoreTranslation(ret, 'fileConsent', '{0} requesting remote file Access. Grant access?');
    setDefaultCoreTranslation(ret, 'terminalNotify', '{0} started a remote terminal session.');
    setDefaultCoreTranslation(ret, 'desktopNotify', '{0} started a remote desktop session.');
    setDefaultCoreTranslation(ret, 'fileNotify', '{0} started a remote file session.');
    setDefaultCoreTranslation(ret, 'privacyBar', 'Sharing desktop with: {0}');

    return (ret);
}
var currentTranslation = getCoreTranslation();

try {
    require('kvm-helper');
}
catch (e) {
    var j =
        {
            users: function () {
                var r = {};
                require('user-sessions').Current(function (c) { r = c; });
                if (process.platform != 'win32') {
                    for (var i in r) {
                        r[i].SessionId = r[i].uid;
                    }
                }
                return (r);
            }
        };
    addModuleObject('kvm-helper', j);
}


function lockDesktop(uid) {
    switch (process.platform) {
        case 'linux':
            if (uid != null) {
                var name = require('user-sessions').getUsername(uid);
                var child = require('child_process').execFile('/bin/sh', ['sh']);
                child.stdout.str = ''; child.stdout.on('data', function (chunk) { this.str += chunk.toString(); });
                child.stderr.str = ''; child.stderr.on('data', function (chunk) { this.str += chunk.toString(); });
                child.stdin.write('loginctl show-user -p Sessions ' + name + " | awk '{");
                child.stdin.write('gsub(/^Sessions=/,"",$0);');
                child.stdin.write('cmd = sprintf("loginctl lock-session %s",$0);');
                child.stdin.write('system(cmd);');
                child.stdin.write("}'\nexit\n");
                child.waitExit();
            }
            else {
                var child = require('child_process').execFile('/bin/sh', ['sh']);
                child.stdout.str = ''; child.stdout.on('data', function (chunk) { this.str += chunk.toString(); });
                child.stderr.str = ''; child.stderr.on('data', function (chunk) { this.str += chunk.toString(); });
                child.stdin.write('loginctl lock-sessions\nexit\n');
                child.waitExit();
            }
            break;
        case 'win32':
            {
                var options = { type: 1, uid: uid };
                var child = require('child_process').execFile(process.env['windir'] + '\\system32\\cmd.exe', ['/c', 'RunDll32.exe user32.dll,LockWorkStation'], options);
                child.waitExit();
            }
            break;
        default:
            break;
    }
}
var writable = require('stream').Writable;
function destopLockHelper_pipe(httprequest) {
    if (process.platform != 'linux' && process.platform != 'freebsd') { return; }

    if (httprequest.unlockerHelper == null && httprequest.desktop != null && httprequest.desktop.kvm != null) {
        httprequest.unlockerHelper = new writable(
            {
                'write': function (chunk, flush) {
                    if (chunk.readUInt16BE(0) == 65) {
                        delete this.request.autolock;
                    }
                    flush();
                    return (true);
                },
                'final': function (flush) {
                    flush();
                }
            });
        httprequest.unlockerHelper.request = httprequest;
        httprequest.desktop.kvm.pipe(httprequest.unlockerHelper);
    }
}

var obj = { serverInfo: {} };
var agentFileHttpRequests = {}; // Currently active agent HTTPS GET requests from the server.
var agentFileHttpPendingRequests = []; // Pending HTTPS GET requests from the server.
var debugConsole = (global._MSH && (_MSH().debugConsole == 1));

var color_options =
    {
        background: (global._MSH != null) ? global._MSH().background : '0,54,105',
        foreground: (global._MSH != null) ? global._MSH().foreground : '255,255,255'
    };

if (process.platform == 'win32' && require('user-sessions').isRoot()) {
    // Check the Agent Uninstall MetaData for correctness, as the installer may have written an incorrect value
    try {
        var writtenSize = 0, actualSize = Math.floor(require('fs').statSync(process.execPath).size / 1024);
        var serviceName =  (_MSH().serviceName ?  _MSH().serviceName : (require('_agentNodeId').serviceName() ? require('_agentNodeId').serviceName() : 'Mesh Agent'));
        try { writtenSize = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Uninstall\\' + serviceName, 'EstimatedSize'); } catch (ex) { }
        if (writtenSize != actualSize) { try { require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Uninstall\\' + serviceName, 'EstimatedSize', actualSize); } catch (ex) { } }
    } catch (ex) { }

    // Check to see if we are the Installed Mesh Agent Service, if we are, make sure we can run in Safe Mode
    var svcname = process.platform == 'win32' ? 'Mesh Agent' : 'meshagent';
    try {
        svcname = require('MeshAgent').serviceName;
    } catch (ex) { }

    try {
        var meshCheck = false;
        try { meshCheck = require('service-manager').manager.getService(svcname).isMe(); } catch (ex) { }
        if (meshCheck && require('win-bcd').isSafeModeService && !require('win-bcd').isSafeModeService(svcname)) { require('win-bcd').enableSafeModeService(svcname); }
    } catch (ex) { }

    // Check the Agent Uninstall MetaData for DisplayVersion and update if not the same and only on windows
    if (process.platform == 'win32') {
        try {
            var writtenDisplayVersion = 0, actualDisplayVersion = process.versions.commitDate.toString();
            var serviceName =  (_MSH().serviceName ?  _MSH().serviceName : (require('_agentNodeId').serviceName() ? require('_agentNodeId').serviceName() : 'Mesh Agent'));
            try { writtenDisplayVersion = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Uninstall\\' + serviceName, 'DisplayVersion'); } catch (ex) { }
            if (writtenDisplayVersion != actualDisplayVersion) { try { require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Uninstall\\' + serviceName, 'DisplayVersion', actualDisplayVersion); } catch (ex) { } }
        } catch (ex) { }
    }
}

if (process.platform != 'win32') {
    var ch = require('child_process');
    ch._execFile = ch.execFile;
    ch.execFile = function execFile(path, args, options) {
        if (options && options.type && options.type == ch.SpawnTypes.TERM && options.env) {
            options.env['TERM'] = 'xterm-256color';
        }
        return (this._execFile(path, args, options));
    };
}


if (process.platform == 'darwin' && !process.versions) {
    // This is an older MacOS Agent, so we'll need to check the service definition so that Auto-Update will function correctly
    var child = require('child_process').execFile('/bin/sh', ['sh']);
    child.stdout.str = '';
    child.stdout.on('data', function (chunk) { this.str += chunk.toString(); });
    child.stdin.write("cat /Library/LaunchDaemons/meshagent_osx64_LaunchDaemon.plist | tr '\n' '\.' | awk '{split($0, a, \"<key>KeepAlive</key>\"); split(a[2], b, \"<\"); split(b[2], c, \">\"); ");
    child.stdin.write(" if(c[1]==\"dict\"){ split(a[2], d, \"</dict>\"); if(split(d[1], truval, \"<true/>\")>1) { split(truval[1], kn1, \"<key>\"); split(kn1[2], kn2, \"</key>\"); print kn2[1]; } }");
    child.stdin.write(" else { split(c[1], ka, \"/\"); if(ka[1]==\"true\") {print \"ALWAYS\";} } }'\nexit\n");
    child.waitExit();
    if (child.stdout.str.trim() == 'Crashed') {
        child = require('child_process').execFile('/bin/sh', ['sh']);
        child.stdout.str = '';
        child.stdout.on('data', function (chunk) { this.str += chunk.toString(); });
        child.stdin.write("launchctl list | grep 'meshagent' | awk '{ if($3==\"meshagent\"){print $1;}}'\nexit\n");
        child.waitExit();

        if (parseInt(child.stdout.str.trim()) == process.pid) {
            // The currently running MeshAgent is us, so we can continue with the update
            var plist = require('fs').readFileSync('/Library/LaunchDaemons/meshagent_osx64_LaunchDaemon.plist').toString();
            var tokens = plist.split('<key>KeepAlive</key>');
            if (tokens[1].split('>')[0].split('<')[1] == 'dict') {
                var tmp = tokens[1].split('</dict>');
                tmp.shift();
                tokens[1] = '\n    <true/>' + tmp.join('</dict>');
                tokens = tokens.join('<key>KeepAlive</key>');

                require('fs').writeFileSync('/Library/LaunchDaemons/meshagent_osx64_LaunchDaemon.plist', tokens);

                var fix = '';
                fix += ("function macosRepair()\n");
                fix += ("{\n");
                fix += ("    var child = require('child_process').execFile('/bin/sh', ['sh']);\n");
                fix += ("    child.stdout.str = '';\n");
                fix += ("    child.stdout.on('data', function (chunk) { this.str += chunk.toString(); });\n");
                fix += ("    child.stderr.on('data', function (chunk) { });\n");
                fix += ("    child.stdin.write('launchctl unload /Library/LaunchDaemons/meshagent_osx64_LaunchDaemon.plist\\n');\n");
                fix += ("    child.stdin.write('launchctl load /Library/LaunchDaemons/meshagent_osx64_LaunchDaemon.plist\\n');\n");
                fix += ("    child.stdin.write('rm /Library/LaunchDaemons/meshagentRepair.plist\\n');\n");
                fix += ("    child.stdin.write('rm " + process.cwd() + "/macosRepair.js\\n');\n");
                fix += ("    child.stdin.write('launchctl stop meshagentRepair\\nexit\\n');\n");
                fix += ("    child.waitExit();\n");
                fix += ("}\n");
                fix += ("macosRepair();\n");
                fix += ("process.exit();\n");
                require('fs').writeFileSync(process.cwd() + '/macosRepair.js', fix);

                var plist = '<?xml version="1.0" encoding="UTF-8"?>\n';
                plist += '<!DOCTYPE plist PUBLIC "-//Apple Computer//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">\n';
                plist += '<plist version="1.0">\n';
                plist += '  <dict>\n';
                plist += '      <key>Label</key>\n';
                plist += ('     <string>meshagentRepair</string>\n');
                plist += '      <key>ProgramArguments</key>\n';
                plist += '      <array>\n';
                plist += ('        <string>' + process.execPath + '</string>\n');
                plist += '        <string>macosRepair.js</string>\n';
                plist += '      </array>\n';
                plist += '      <key>WorkingDirectory</key>\n';
                plist += ('     <string>' + process.cwd() + '</string>\n');
                plist += '      <key>RunAtLoad</key>\n';
                plist += '      <true/>\n';
                plist += '  </dict>\n';
                plist += '</plist>';
                require('fs').writeFileSync('/Library/LaunchDaemons/meshagentRepair.plist', plist);

                child = require('child_process').execFile('/bin/sh', ['sh']);
                child.stdout.str = '';
                child.stdout.on('data', function (chunk) { this.str += chunk.toString(); });
                child.stdin.write("launchctl load /Library/LaunchDaemons/meshagentRepair.plist\nexit\n");
                child.waitExit();
            }
        }
    }
}

// Add an Intel AMT event to the log
function addAmtEvent(msg) {
    if (obj.amtevents == null) { obj.amtevents = []; }
    var d = new Date(), e = zeroPad(d.getHours(), 2) + ':' + zeroPad(d.getMinutes(), 2) + ':' + zeroPad(d.getSeconds(), 2) + ', ' + msg;
    obj.amtevents.push(e);
    if (obj.amtevents.length > 100) { obj.amtevents.splice(0, obj.amtevents.length - 100); }
    if (obj.showamtevent) { require('MeshAgent').SendCommand({ action: 'msg', type: 'console', value: e }); }
}
function zeroPad(num, size) { var s = '000000000' + num; return s.substr(s.length - size); }


// Create Secure IPC for Diagnostic Agent Communications
obj.DAIPC = require('net').createServer();
if (process.platform != 'win32') { try { require('fs').unlinkSync(process.cwd() + '/DAIPC'); } catch (ex) { } }
obj.DAIPC.IPCPATH = process.platform == 'win32' ? ('\\\\.\\pipe\\' + require('_agentNodeId')() + '-DAIPC') : (process.cwd() + '/DAIPC');
try { obj.DAIPC.listen({ path: obj.DAIPC.IPCPATH, writableAll: true, maxConnections: 5 }); } catch (ex) { }
obj.DAIPC._daipc = [];
obj.DAIPC.on('connection', function (c) {
    c._send = function (j) {
        var data = JSON.stringify(j);
        var packet = Buffer.alloc(data.length + 4);
        packet.writeUInt32LE(data.length + 4, 0);
        Buffer.from(data).copy(packet, 4);
        this.write(packet);
    };
    this._daipc.push(c);
    c.parent = this;
    c.on('end', function () { removeRegisteredApp(this); });
    c.on('data', function (chunk) {
        if (chunk.length < 4) { this.unshift(chunk); return; }
        var len = chunk.readUInt32LE(0);
        if (len > 8192) { removeRegisteredApp(this); this.end(); return; }
        if (chunk.length < len) { this.unshift(chunk); return; }

        var data = chunk.slice(4, len);
        try { data = JSON.parse(data.toString()); } catch (ex) { }
        if ((data == null) || (typeof data.cmd != 'string')) return;

        try {
            switch (data.cmd) {
                case 'requesthelp':
                    if (this._registered == null) return;
                    sendConsoleText('Request Help (' + this._registered + '): ' + data.value);
                    var help = {};
                    help[this._registered] = data.value;
                    try { mesh.SendCommand({ action: 'sessions', type: 'help', value: help }); } catch (ex) { }
                    MeshServerLogEx(98, [this._registered, data.value], "Help Requested, user: " + this._registered + ", details: " + data.value, null);
                    break;
                case 'cancelhelp':
                    if (this._registered == null) return;
                    sendConsoleText('Cancel Help (' + this._registered + ')');
                    try { mesh.SendCommand({ action: 'sessions', type: 'help', value: {} }); } catch (ex) { }
                    break;
                case 'register':
                    if (typeof data.value == 'string') {
                        this._registered = data.value;
                        var apps = {};
                        apps[data.value] = 1;
                        try { mesh.SendCommand({ action: 'sessions', type: 'app', value: apps }); } catch (ex) { }
                        this._send({ cmd: 'serverstate', value: meshServerConnectionState, url: require('MeshAgent').ConnectedServer, amt: (amt != null) });
                    }
                    break;
                case 'query':
                    switch (data.value) {
                        case 'connection':
                            data.result = require('MeshAgent').ConnectedServer;
                            this._send(data);
                            break;
                        case 'descriptors':
                            require('ChainViewer').getSnapshot().then(function (f) {
                                this.tag.payload.result = f;
                                this.tag.ipc._send(this.tag.payload);
                            }).parentPromise.tag = { ipc: this, payload: data };
                            break;
                        case 'timerinfo':
                            data.result = require('ChainViewer').getTimerInfo();
                            this._send(data);
                            break;
                    }
                    break;
                case 'amtstate':
                    if (amt == null) return;
                    var func = function amtStateFunc(state) { if (state != null) { amtStateFunc.pipe._send({ cmd: 'amtstate', value: state }); } }
                    func.pipe = this;
                    amt.getMeiState(11, func);
                    break;
                case 'sessions':
                    this._send({ cmd: 'sessions', sessions: tunnelUserCount });
                    break;
                case 'meshToolInfo':
                    try { mesh.SendCommand({ action: 'meshToolInfo', name: data.name, hash: data.hash, cookie: data.cookie ? true : false, pipe: true }); } catch (ex) { }
                    break;
                case 'getUserImage':
                    try { mesh.SendCommand({ action: 'getUserImage', userid: data.userid, pipe: true }); } catch (ex) { }
                    break;
                case 'console':
                    if (debugConsole) {
                        var args = splitArgs(data.value);
                        processConsoleCommand(args[0].toLowerCase(), parseArgs(args), 0, 'pipe');
                    }
                    break;
            }
        }
        catch (ex) { removeRegisteredApp(this); this.end(); return; }
    });
});

// Send current sessions to registered apps
function broadcastSessionsToRegisteredApps(x) {
    var p = {}, i;
    for (i = 0; sendAgentMessage.messages != null && i < sendAgentMessage.messages.length; ++i) {
        p[i] = sendAgentMessage.messages[i];
    }
    tunnelUserCount.msg = p;
    broadcastToRegisteredApps({ cmd: 'sessions', sessions: tunnelUserCount });
    tunnelUserCount.msg = {};
}

// Send this object to all registered local applications
function broadcastToRegisteredApps(x) {
    if ((obj.DAIPC == null) || (obj.DAIPC._daipc == null)) return;
    for (var i in obj.DAIPC._daipc) {
        if (obj.DAIPC._daipc[i]._registered != null) { obj.DAIPC._daipc[i]._send(x); }
    }
}

// Send this object to a specific registered local applications
function sendToRegisteredApp(appid, x) {
    if ((obj.DAIPC == null) || (obj.DAIPC._daipc == null)) return;
    for (var i in obj.DAIPC._daipc) { if (obj.DAIPC._daipc[i]._registered == appid) { obj.DAIPC._daipc[i]._send(x); } }
}

// Send list of registered apps to the server
function updateRegisteredAppsToServer() {
    if ((obj.DAIPC == null) || (obj.DAIPC._daipc == null)) return;
    var apps = {};
    for (var i in obj.DAIPC._daipc) { if (apps[obj.DAIPC._daipc[i]._registered] == null) { apps[obj.DAIPC._daipc[i]._registered] = 1; } else { apps[obj.DAIPC._daipc[i]._registered]++; } }
    try { mesh.SendCommand({ action: 'sessions', type: 'app', value: apps }); } catch (ex) { }
}

// Remove a registered app
function removeRegisteredApp(pipe) {
    for (var i = obj.DAIPC._daipc.length - 1; i >= 0; i--) { if (obj.DAIPC._daipc[i] === pipe) { obj.DAIPC._daipc.splice(i, 1); } }
    if (pipe._registered != null) updateRegisteredAppsToServer();
}

function diagnosticAgent_uninstall() {
    require('service-manager').manager.uninstallService('meshagentDiagnostic');
    require('task-scheduler').delete('meshagentDiagnostic/periodicStart'); // TODO: Using "delete" here breaks the minifier since this is a reserved keyword
}
function diagnosticAgent_installCheck(install) {
    try {
        var diag = require('service-manager').manager.getService('meshagentDiagnostic');
        return (diag);
    } catch (ex) { }
    if (!install) { return null; }

    var svc = null;
    try {
        require('service-manager').manager.installService(
            {
                name: 'meshagentDiagnostic',
                displayName: "Mesh Agent Diagnostic Service",
                description: "Mesh Agent Diagnostic Service",
                servicePath: process.execPath,
                parameters: ['-recovery']
                //files: [{ newName: 'diagnostic.js', _buffer: Buffer.from('LyoNCkNvcHlyaWdodCAyMDE5IEludGVsIENvcnBvcmF0aW9uDQoNCkxpY2Vuc2VkIHVuZGVyIHRoZSBBcGFjaGUgTGljZW5zZSwgVmVyc2lvbiAyLjAgKHRoZSAiTGljZW5zZSIpOw0KeW91IG1heSBub3QgdXNlIHRoaXMgZmlsZSBleGNlcHQgaW4gY29tcGxpYW5jZSB3aXRoIHRoZSBMaWNlbnNlLg0KWW91IG1heSBvYnRhaW4gYSBjb3B5IG9mIHRoZSBMaWNlbnNlIGF0DQoNCiAgICBodHRwOi8vd3d3LmFwYWNoZS5vcmcvbGljZW5zZXMvTElDRU5TRS0yLjANCg0KVW5sZXNzIHJlcXVpcmVkIGJ5IGFwcGxpY2FibGUgbGF3IG9yIGFncmVlZCB0byBpbiB3cml0aW5nLCBzb2Z0d2FyZQ0KZGlzdHJpYnV0ZWQgdW5kZXIgdGhlIExpY2Vuc2UgaXMgZGlzdHJpYnV0ZWQgb24gYW4gIkFTIElTIiBCQVNJUywNCldJVEhPVVQgV0FSUkFOVElFUyBPUiBDT05ESVRJT05TIE9GIEFOWSBLSU5ELCBlaXRoZXIgZXhwcmVzcyBvciBpbXBsaWVkLg0KU2VlIHRoZSBMaWNlbnNlIGZvciB0aGUgc3BlY2lmaWMgbGFuZ3VhZ2UgZ292ZXJuaW5nIHBlcm1pc3Npb25zIGFuZA0KbGltaXRhdGlvbnMgdW5kZXIgdGhlIExpY2Vuc2UuDQoqLw0KDQp2YXIgaG9zdCA9IHJlcXVpcmUoJ3NlcnZpY2UtaG9zdCcpLmNyZWF0ZSgnbWVzaGFnZW50RGlhZ25vc3RpYycpOw0KdmFyIFJlY292ZXJ5QWdlbnQgPSByZXF1aXJlKCdNZXNoQWdlbnQnKTsNCg0KaG9zdC5vbignc2VydmljZVN0YXJ0JywgZnVuY3Rpb24gKCkNCnsNCiAgICBjb25zb2xlLnNldERlc3RpbmF0aW9uKGNvbnNvbGUuRGVzdGluYXRpb25zLkxPR0ZJTEUpOw0KICAgIGhvc3Quc3RvcCA9IGZ1bmN0aW9uKCkNCiAgICB7DQogICAgICAgIHJlcXVpcmUoJ3NlcnZpY2UtbWFuYWdlcicpLm1hbmFnZXIuZ2V0U2VydmljZSgnbWVzaGFnZW50RGlhZ25vc3RpYycpLnN0b3AoKTsNCiAgICB9DQogICAgUmVjb3ZlcnlBZ2VudC5vbignQ29ubmVjdGVkJywgZnVuY3Rpb24gKHN0YXR1cykNCiAgICB7DQogICAgICAgIGlmIChzdGF0dXMgPT0gMCkNCiAgICAgICAgew0KICAgICAgICAgICAgY29uc29sZS5sb2coJ0RpYWdub3N0aWMgQWdlbnQ6IFNlcnZlciBjb25uZWN0aW9uIGxvc3QuLi4nKTsNCiAgICAgICAgICAgIHJldHVybjsNCiAgICAgICAgfQ0KICAgICAgICBjb25zb2xlLmxvZygnRGlhZ25vc3RpYyBBZ2VudDogQ29ubmVjdGlvbiBFc3RhYmxpc2hlZCB3aXRoIFNlcnZlcicpOw0KICAgICAgICBzdGFydCgpOw0KICAgIH0pOw0KfSk7DQpob3N0Lm9uKCdub3JtYWxTdGFydCcsIGZ1bmN0aW9uICgpDQp7DQogICAgaG9zdC5zdG9wID0gZnVuY3Rpb24gKCkNCiAgICB7DQogICAgICAgIHByb2Nlc3MuZXhpdCgpOw0KICAgIH0NCiAgICBjb25zb2xlLmxvZygnTm9uIFNlcnZpY2UgTW9kZScpOw0KICAgIFJlY292ZXJ5QWdlbnQub24oJ0Nvbm5lY3RlZCcsIGZ1bmN0aW9uIChzdGF0dXMpDQogICAgew0KICAgICAgICBpZiAoc3RhdHVzID09IDApDQogICAgICAgIHsNCiAgICAgICAgICAgIGNvbnNvbGUubG9nKCdEaWFnbm9zdGljIEFnZW50OiBTZXJ2ZXIgY29ubmVjdGlvbiBsb3N0Li4uJyk7DQogICAgICAgICAgICByZXR1cm47DQogICAgICAgIH0NCiAgICAgICAgY29uc29sZS5sb2coJ0RpYWdub3N0aWMgQWdlbnQ6IENvbm5lY3Rpb24gRXN0YWJsaXNoZWQgd2l0aCBTZXJ2ZXInKTsNCiAgICAgICAgc3RhcnQoKTsNCiAgICB9KTsNCn0pOw0KaG9zdC5vbignc2VydmljZVN0b3AnLCBmdW5jdGlvbiAoKSB7IHByb2Nlc3MuZXhpdCgpOyB9KTsNCmhvc3QucnVuKCk7DQoNCg0KZnVuY3Rpb24gc3RhcnQoKQ0Kew0KDQp9Ow0K', 'base64') }]
            });
        svc = require('service-manager').manager.getService('meshagentDiagnostic');
    }
    catch (ex) { return null; }
    var proxyConfig = require('global-tunnel').proxyConfig;
    var cert = require('MeshAgent').GenerateAgentCertificate('CN=MeshNodeDiagnosticCertificate');
    var nodeid = require('tls').loadCertificate(cert.root).getKeyHash().toString('base64');
    ddb = require('SimpleDataStore').Create(svc.appWorkingDirectory().replace('\\', '/') + '/meshagentDiagnostic.db');
    ddb.Put('disableUpdate', '1');
    ddb.Put('MeshID', Buffer.from(require('MeshAgent').ServerInfo.MeshID, 'hex'));
    ddb.Put('ServerID', require('MeshAgent').ServerInfo.ServerID);
    ddb.Put('MeshServer', require('MeshAgent').ServerInfo.ServerUri);
    if (cert.root.pfx) { ddb.Put('SelfNodeCert', cert.root.pfx); }
    if (cert.tls) { ddb.Put('SelfNodeTlsCert', cert.tls.pfx); }
    if (proxyConfig) {
        ddb.Put('WebProxy', proxyConfig.host + ':' + proxyConfig.port);
    } else {
        ddb.Put('ignoreProxyFile', '1');
    }

    require('MeshAgent').SendCommand({ action: 'diagnostic', value: { command: 'register', value: nodeid } });
    require('MeshAgent').SendCommand({ action: 'msg', type: 'console', value: "Diagnostic Agent Registered [" + nodeid.length + "/" + nodeid + "]" });

    delete ddb;

    // Set a recurrent task, to run the Diagnostic Agent every 2 days
    require('task-scheduler').create({ name: 'meshagentDiagnostic/periodicStart', daily: 2, time: require('tls').generateRandomInteger('0', '23') + ':' + require('tls').generateRandomInteger('0', '59').padStart(2, '0'), service: 'meshagentDiagnostic' });
    //require('task-scheduler').create({ name: 'meshagentDiagnostic/periodicStart', daily: '1', time: '17:16', service: 'meshagentDiagnostic' });

    return (svc);
}

// Monitor the file 'batterystate.txt' in the agent's folder and sends battery update when this file is changed.
if ((require('fs').existsSync(process.cwd() + 'batterystate.txt')) && (require('fs').watch != null)) {
    // Setup manual battery monitoring
    require('MeshAgent')._batteryFileWatcher = require('fs').watch(process.cwd(), function () {
        if (require('MeshAgent')._batteryFileTimer != null) return;
        require('MeshAgent')._batteryFileTimer = setTimeout(function () {
            try {
                require('MeshAgent')._batteryFileTimer = null;
                var data = null;
                try { data = require('fs').readFileSync(process.cwd() + 'batterystate.txt').toString(); } catch (ex) { }
                if ((data != null) && (data.length < 10)) {
                    data = data.split(',');
                    if ((data.length == 2) && ((data[0] == 'ac') || (data[0] == 'dc'))) {
                        var level = parseInt(data[1]);
                        if ((level >= 0) && (level <= 100)) { require('MeshAgent').SendCommand({ action: 'battery', state: data[0], level: level }); }
                    }
                }
            } catch (ex) { }
        }, 1000);
    });
}
else {
    try {
        // Setup normal battery monitoring
        if (require('computer-identifiers').isBatteryPowered && require('computer-identifiers').isBatteryPowered()) {
            require('MeshAgent')._battLevelChanged = function _battLevelChanged(val) {
                _battLevelChanged.self._currentBatteryLevel = val;
                _battLevelChanged.self.SendCommand({ action: 'battery', state: _battLevelChanged.self._currentPowerState, level: val });
            };
            require('MeshAgent')._battLevelChanged.self = require('MeshAgent');
            require('MeshAgent')._powerChanged = function _powerChanged(val) {
                _powerChanged.self._currentPowerState = (val == 'AC' ? 'ac' : 'dc');
                _powerChanged.self.SendCommand({ action: 'battery', state: (val == 'AC' ? 'ac' : 'dc'), level: _powerChanged.self._currentBatteryLevel });
            };
            require('MeshAgent')._powerChanged.self = require('MeshAgent');
            require('MeshAgent').on('Connected', function (status) {
                if (status == 0) {
                    require('power-monitor').removeListener('acdc', this._powerChanged);
                    require('power-monitor').removeListener('batteryLevel', this._battLevelChanged);
                } else {
                    require('power-monitor').on('acdc', this._powerChanged);
                    require('power-monitor').on('batteryLevel', this._battLevelChanged);
                }
            });
        }
    }
    catch (ex) { }
}


// MeshAgent JavaScript Core Module. This code is sent to and running on the mesh agent.
var meshCoreObj = { action: 'coreinfo', value: (require('MeshAgent').coreHash ? ((process.versions.compileTime ? process.versions.compileTime : '').split(', ')[1].replace('  ', ' ') + ', ' + crc32c(require('MeshAgent').coreHash)) : ('MeshCore v6')), caps: 14, root: require('user-sessions').isRoot() }; // Capability bitmask: 1 = Desktop, 2 = Terminal, 4 = Files, 8 = Console, 16 = JavaScript, 32 = Temporary Agent, 64 = Recovery Agent

// Get the operating system description string
try { require('os').name().then(function (v) { meshCoreObj.osdesc = v; meshCoreObjChanged(); }); } catch (ex) { }

// Setup logged in user monitoring (THIS IS BROKEN IN WIN7)
function onUserSessionChanged(user, locked) {
    userSession.enumerateUsers().then(function (users) {
        if (process.platform == 'linux') {
            if (userSession._startTime == null) {
                userSession._startTime = Date.now();
                userSession._count = users.length;
            }
            else if (Date.now() - userSession._startTime < 10000 && users.length == userSession._count) {
                userSession.removeAllListeners('changed');
                return;
            }
        }

        var u = [], a = users.Active;
        if(meshCoreObj.lusers == null) { meshCoreObj.lusers = []; }
        if(meshCoreObj.upnusers == null) { meshCoreObj.upnusers = []; }
        var ret = getDomainInfo();
        for (var i = 0; i < a.length; i++) {
            var un = a[i].Domain ? (a[i].Domain + '\\' + a[i].Username) : (a[i].Username);
            if (user && locked && (JSON.stringify(a[i]) === JSON.stringify(user))) { if (meshCoreObj.lusers.indexOf(un) == -1) { meshCoreObj.lusers.push(un); } }
            else if (user && !locked && (JSON.stringify(a[i]) === JSON.stringify(user))) { meshCoreObj.lusers.splice(meshCoreObj.lusers.indexOf(un), 1); }
            if (u.indexOf(un) == -1) { u.push(un); } // Only push users in the list once.
            if (a[i].Domain != null && a[i].Domain == 'AzureAD'){
                // AzureAD to-do
                // var userGUID = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'SYSTEM\\CurrentControlSet\\Control\\CloudDomainJoin\\JoinInfo');
                // if (userGUID != null){
                //     var user = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'SYSTEM\\CurrentControlSet\\Control\\CloudDomainJoin\\JoinInfo\\' + userGUID.subkeys[0], 'UserEmail');
                //     if (user != null) u[i].UPN = user;
                // }
            } else if (a[i].Domain != null) {
                if (ret != null && ret.PartOfDomain === true) {
                    meshCoreObj.upnusers.push(a[i].Username + '@' + ret.Domain);
                }
            }
        }
        meshCoreObj.lusers = meshCoreObj.lusers;
        meshCoreObj.users = u;
        meshCoreObjChanged();
    });
}

try {
    var userSession = require('user-sessions');
    userSession.on('changed', function () { onUserSessionChanged(null, false); });
    userSession.emit('changed');
    userSession.on('locked', function (user) { if(user != undefined && user != null) { onUserSessionChanged(user, true); } });
    userSession.on('unlocked', function (user) { if(user != undefined && user != null) { onUserSessionChanged(user, false); } });
} catch (ex) { }

var meshServerConnectionState = 0;
var tunnels = {};
var lastNetworkInfo = null;
var lastPublicLocationInfo = null;
var selfInfoUpdateTimer = null;
var http = require('http');
var net = require('net');
var fs = require('fs');
var rtc = require('ILibWebRTC');
var amt = null;
var processManager = require('process-manager');
var wifiScannerLib = null;
var wifiScanner = null;
var networkMonitor = null;
var nextTunnelIndex = 1;
var apftunnel = null;
var tunnelUserCount = { terminal: {}, files: {}, tcp: {}, udp: {}, msg: {} }; // List of userid->count sessions for terminal, files and TCP/UDP routing

// Add to the server event log
function MeshServerLog(msg, state) {
    if (typeof msg == 'string') { msg = { action: 'log', msg: msg }; } else { msg.action = 'log'; }
    if (state) {
        if (state.userid) { msg.userid = state.userid; }
        if (state.username) { msg.username = state.username; }
        if (state.sessionid) { msg.sessionid = state.sessionid; }
        if (state.remoteaddr) { msg.remoteaddr = state.remoteaddr; }
        if (state.guestname) { msg.guestname = state.guestname; }
    }
    mesh.SendCommand(msg);
}

// Add to the server event log, use internationalized events
function MeshServerLogEx(id, args, msg, state) {
    var msg = { action: 'log', msgid: id, msgArgs: args, msg: msg };
    if (state) {
        if (state.userid) { msg.userid = state.userid; }
        if (state.xuserid) { msg.xuserid = state.xuserid; }
        if (state.username) { msg.username = state.username; }
        if (state.sessionid) { msg.sessionid = state.sessionid; }
        if (state.remoteaddr) { msg.remoteaddr = state.remoteaddr; }
        if (state.guestname) { msg.guestname = state.guestname; }
    }
    mesh.SendCommand(msg);
}

// Import libraries
db = require('SimpleDataStore').Shared();
sha = require('SHA256Stream');
mesh = require('MeshAgent');
childProcess = require('child_process');

if (mesh.hasKVM == 1) {   // if the agent is compiled with KVM support
    // Check if this computer supports a desktop
    try {
        if ((process.platform == 'win32') || (process.platform == 'darwin') || (require('monitor-info').kvm_x11_support)) {
            meshCoreObj.caps |= 1; meshCoreObjChanged();
        } else if (process.platform == 'linux' || process.platform == 'freebsd') {
            require('monitor-info').on('kvmSupportDetected', function (value) { meshCoreObj.caps |= 1; meshCoreObjChanged(); });
        }
    } catch (ex) { }
}
mesh.DAIPC = obj.DAIPC;

/*
// Try to load up the network monitor
try {
    networkMonitor = require('NetworkMonitor');
    networkMonitor.on('change', function () { sendNetworkUpdateNagle(); });
    networkMonitor.on('add', function (addr) { sendNetworkUpdateNagle(); });
    networkMonitor.on('remove', function (addr) { sendNetworkUpdateNagle(); });
} catch (ex) { networkMonitor = null; }
*/

// Fetch the SMBios Tables
var SMBiosTables = null;
var SMBiosTablesRaw = null;
try {
    var SMBiosModule = null;
    try { SMBiosModule = require('smbios'); } catch (ex) { }
    if (SMBiosModule != null) {
        SMBiosModule.get(function (data) {
            if (data != null) {
                SMBiosTablesRaw = data;
                SMBiosTables = require('smbios').parse(data)
                if (mesh.isControlChannelConnected) { mesh.SendCommand({ action: 'smbios', value: SMBiosTablesRaw }); }

                // If SMBios tables say that Intel AMT is present, try to connect MEI
                if (SMBiosTables.amtInfo && (SMBiosTables.amtInfo.AMT == true)) {
                    var amtmodule = require('amt-manage');
                    amt = new amtmodule(mesh, db, false);
                    amt.on('portBinding_LMS', function (map) { mesh.SendCommand({ action: 'lmsinfo', value: { ports: map.keys() } }); });
                    amt.on('stateChange_LMS', function (v) { if (!meshCoreObj.intelamt) { meshCoreObj.intelamt = {}; } meshCoreObj.intelamt.microlms = v; meshCoreObjChanged(); }); // 0 = Disabled, 1 = Connecting, 2 = Connected
                    amt.onStateChange = function (state) { if (state == 2) { sendPeriodicServerUpdate(1); } } // MEI State
                    amt.reset();
                }
            }
        });
    }
} catch (ex) { sendConsoleText("ex1: " + ex); }

// Try to load up the WIFI scanner
try {
    var wifiScannerLib = require('wifi-scanner');
    wifiScanner = new wifiScannerLib();
    wifiScanner.on('accessPoint', function (data) { sendConsoleText("wifiScanner: " + data); });
} catch (ex) { wifiScannerLib = null; wifiScanner = null; }

// Get our location (lat/long) using our public IP address
var getIpLocationDataExInProgress = false;
var getIpLocationDataExCounts = [0, 0];
function getIpLocationDataEx(func) {
    if (getIpLocationDataExInProgress == true) { return false; }
    try {
        getIpLocationDataExInProgress = true;
        getIpLocationDataExCounts[0]++;
        var options = http.parseUri("http://ipinfo.io/json");
        options.method = 'GET';
        http.request(options, function (resp) {
            if (resp.statusCode == 200) {
                var geoData = '';
                resp.data = function (geoipdata) { geoData += geoipdata; };
                resp.end = function () {
                    var location = null;
                    try {
                        if (typeof geoData == 'string') {
                            var result = JSON.parse(geoData);
                            if (result.ip && result.loc) { location = result; }
                        }
                    } catch (ex) { }
                    if (func) { getIpLocationDataExCounts[1]++; func(location); }
                }
            } else
            { func(null); }
            getIpLocationDataExInProgress = false;
        }).end();
        return true;
    }
    catch (ex) { return false; }
}

// Remove all Gateway MAC addresses for interface list. This is useful because the gateway MAC is not always populated reliably.
function clearGatewayMac(str) {
    if (typeof str != 'string') return null;
    var x = JSON.parse(str);
    for (var i in x.netif) { try { if (x.netif[i].gatewaymac) { delete x.netif[i].gatewaymac } } catch (ex) { } }
    return JSON.stringify(x);
}

function getIpLocationData(func) {
    // Get the location information for the cache if possible
    var publicLocationInfo = db.Get('publicLocationInfo');
    if (publicLocationInfo != null) { publicLocationInfo = JSON.parse(publicLocationInfo); }
    if (publicLocationInfo == null) {
        // Nothing in the cache, fetch the data
        getIpLocationDataEx(function (locationData) {
            if (locationData != null) {
                publicLocationInfo = {};
                publicLocationInfo.netInfoStr = lastNetworkInfo;
                publicLocationInfo.locationData = locationData;
                var x = db.Put('publicLocationInfo', JSON.stringify(publicLocationInfo)); // Save to database
                if (func) func(locationData); // Report the new location
            }
            else {
                if (func) func(null); // Report no location
            }
        });
    }
    else {
        // Check the cache
        if (clearGatewayMac(publicLocationInfo.netInfoStr) == clearGatewayMac(lastNetworkInfo)) {
            // Cache match
            if (func) func(publicLocationInfo.locationData);
        }
        else {
            // Cache mismatch
            getIpLocationDataEx(function (locationData) {
                if (locationData != null) {
                    publicLocationInfo = {};
                    publicLocationInfo.netInfoStr = lastNetworkInfo;
                    publicLocationInfo.locationData = locationData;
                    var x = db.Put('publicLocationInfo', JSON.stringify(publicLocationInfo)); // Save to database
                    if (func) func(locationData); // Report the new location
                }
                else {
                    if (func) func(publicLocationInfo.locationData); // Can't get new location, report the old location
                }
            });
        }
    }
}

// Polyfill String.endsWith
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;
    };
}

// Polyfill path.join
obj.path =
    {
        join: function () {
            var x = [];
            for (var i in arguments) {
                var w = arguments[i];
                if (w != null) {
                    while (w.endsWith('/') || w.endsWith('\\')) { w = w.substring(0, w.length - 1); }
                    if (i != 0) {
                        while (w.startsWith('/') || w.startsWith('\\')) { w = w.substring(1); }
                    }
                    x.push(w);
                }
            }
            if (x.length == 0) return '/';
            return x.join('/');
        }
    };

// Replace a string with a number if the string is an exact number
function toNumberIfNumber(x) { if ((typeof x == 'string') && (+parseInt(x) === x)) { x = parseInt(x); } return x; }

// Convert decimal to hex
function char2hex(i) { return (i + 0x100).toString(16).substr(-2).toUpperCase(); }

// Convert a raw string to a hex string
function rstr2hex(input) { var r = '', i; for (i = 0; i < input.length; i++) { r += char2hex(input.charCodeAt(i)); } return r; }

// Convert a buffer into a string
function buf2rstr(buf) { var r = ''; for (var i = 0; i < buf.length; i++) { r += String.fromCharCode(buf[i]); } return r; }

// Convert a hex string to a raw string // TODO: Do this using Buffer(), will be MUCH faster
function hex2rstr(d) {
    if (typeof d != "string" || d.length == 0) return '';
    var r = '', m = ('' + d).match(/../g), t;
    while (t = m.shift()) r += String.fromCharCode('0x' + t);
    return r
}

// Convert an object to string with all functions
function objToString(x, p, pad, ret) {
    if (ret == undefined) ret = '';
    if (p == undefined) p = 0;
    if (x == null) { return '[null]'; }
    if (p > 8) { return '[...]'; }
    if (x == undefined) { return '[undefined]'; }
    if (typeof x == 'string') { if (p == 0) return x; return '"' + x + '"'; }
    if (typeof x == 'buffer') { return '[buffer]'; }
    if (typeof x != 'object') { return x; }
    var r = '{' + (ret ? '\r\n' : ' ');
    for (var i in x) { if (i != '_ObjectID') { r += (addPad(p + 2, pad) + i + ': ' + objToString(x[i], p + 2, pad, ret) + (ret ? '\r\n' : ' ')); } }
    return r + addPad(p, pad) + '}';
}

// Return p number of spaces 
function addPad(p, ret) { var r = ''; for (var i = 0; i < p; i++) { r += ret; } return r; }

// Split a string taking into account the quoats. Used for command line parsing
function splitArgs(str) {
    var myArray = [], myRegexp = /[^\s"]+|"([^"]*)"/gi;
    do { var match = myRegexp.exec(str); if (match != null) { myArray.push(match[1] ? match[1] : match[0]); } } while (match != null);
    return myArray;
}

// Parse arguments string array into an object
function parseArgs(argv) {
    var results = { '_': [] }, current = null;
    for (var i = 1, len = argv.length; i < len; i++) {
        var x = argv[i];
        if (x.length > 2 && x[0] == '-' && x[1] == '-') {
            if (current != null) { results[current] = true; }
            current = x.substring(2);
        } else {
            if (current != null) { results[current] = toNumberIfNumber(x); current = null; } else { results['_'].push(toNumberIfNumber(x)); }
        }
    }
    if (current != null) { results[current] = true; }
    return results;
}

// Get server target url with a custom path
function getServerTargetUrl(path) {
    var x = mesh.ServerUrl;
    //sendConsoleText("mesh.ServerUrl: " + mesh.ServerUrl);
    if (x == null) { return null; }
    if (path == null) { path = ''; }
    x = http.parseUri(x);
    if (x == null) return null;
    return x.protocol + '//' + x.host + ':' + x.port + '/' + path;
}

// Get server url. If the url starts with "*/..." change it, it not use the url as is.
function getServerTargetUrlEx(url) {
    if (url.substring(0, 2) == '*/') { return getServerTargetUrl(url.substring(2)); }
    return url;
}

function sendWakeOnLanEx_interval() {
    var t = require('MeshAgent').wakesockets;
    if (t.list.length == 0) {
        clearInterval(t);
        delete require('MeshAgent').wakesockets;
        return;
    }

    var mac = t.list.shift().split(':').join('')
    var magic = 'FFFFFFFFFFFF';
    for (var x = 1; x <= 16; ++x) { magic += mac; }
    var magicbin = Buffer.from(magic, 'hex');

    for (var i in t.sockets) {
        t.sockets[i].send(magicbin, 7, '255.255.255.255');
        //sendConsoleText('Sending wake packet on ' + JSON.stringify(t.sockets[i].address()));
    }
}
function sendWakeOnLanEx(hexMacList) {
    var ret = 0;

    if (require('MeshAgent').wakesockets == null) {
        // Create a new interval timer
        require('MeshAgent').wakesockets = setInterval(sendWakeOnLanEx_interval, 10);
        require('MeshAgent').wakesockets.sockets = [];
        require('MeshAgent').wakesockets.list = hexMacList;

        var interfaces = require('os').networkInterfaces();
        for (var adapter in interfaces) {
            if (interfaces.hasOwnProperty(adapter)) {
                for (var i = 0; i < interfaces[adapter].length; ++i) {
                    var addr = interfaces[adapter][i];
                    if ((addr.family == 'IPv4') && (addr.mac != '00:00:00:00:00:00')) {
                        try {
                            var socket = require('dgram').createSocket({ type: 'udp4' });
                            socket.bind({ address: addr.address });
                            socket.setBroadcast(true);
                            socket.setMulticastInterface(addr.address);
                            socket.setMulticastTTL(1);
                            socket.descriptorMetadata = 'WoL (' + addr.address + ')';
                            require('MeshAgent').wakesockets.sockets.push(socket);
                            ++ret;
                        }
                        catch (ex) { }
                    }
                }
            }
        }
    }
    else {
        // Append to an existing interval timer
        for (var i in hexMacList) {
            require('MeshAgent').wakesockets.list.push(hexMacList[i]);
        }
        ret = require('MeshAgent').wakesockets.sockets.length;
    }

    return ret;
}

function server_promise_default(res, rej) {
    this.resolve = res;
    this.reject = rej;
}
function server_getUserImage(userid) {
    var xpromise = require('promise');
    var ret = new xpromise(server_promise_default);

    if (require('MeshAgent')._promises == null) { require('MeshAgent')._promises = {}; }
    require('MeshAgent')._promises[ret._hashCode()] = ret;
    require('MeshAgent').SendCommand({ action: 'getUserImage', userid: userid, promise: ret._hashCode(), sentDefault: true });
    return ret;
}
require('MeshAgent')._consentTimers = {};
function server_set_consentTimer(id) {
    require('MeshAgent')._consentTimers[id] = new Date();
}
function server_check_consentTimer(id) {
    if (require('MeshAgent')._consentTimers[id] != null) {
        if ((new Date()) - require('MeshAgent')._consentTimers[id] < (60000 * 5)) return true;
        require('MeshAgent')._consentTimers[id] = null;
    }
    return false;
}

function tunnel_finalized()
{
    console.info1('Tunnel Request Finalized');
}
function tunnel_checkServerIdentity(certs)
{
    /*
    try { sendConsoleText("certs[0].digest: " + certs[0].digest); } catch (ex) { sendConsoleText(ex); }
    try { sendConsoleText("certs[0].fingerprint: " + certs[0].fingerprint); } catch (ex) { sendConsoleText(ex); }
    try { sendConsoleText("control-digest: " + require('MeshAgent').ServerInfo.ControlChannelCertificate.digest); } catch (ex) { sendConsoleText(ex); }
    try { sendConsoleText("control-fingerprint: " + require('MeshAgent').ServerInfo.ControlChannelCertificate.fingerprint); } catch (ex) { sendConsoleText(ex); }
    */

    // Check if this is an old agent, no certificate checks are possible in this situation. Display a warning.
    if ((require('MeshAgent').ServerInfo == null) || (require('MeshAgent').ServerInfo.ControlChannelCertificate == null) || (certs[0].digest == null)) { sendAgentMessage("This agent is using insecure tunnels, consider updating.", 3, 119, true); return; }

    // If the tunnel certificate matches the control channel certificate, accept the connection
    if (require('MeshAgent').ServerInfo.ControlChannelCertificate.digest == certs[0].digest) return; // Control channel certificate matches using full cert hash
    if ((certs[0].fingerprint != null) && (require('MeshAgent').ServerInfo.ControlChannelCertificate.fingerprint == certs[0].fingerprint)) return; // Control channel certificate matches using public key hash

    // Check that the certificate is the one expected by the server, fail if not.
    if ((tunnel_checkServerIdentity.servertlshash != null) && (tunnel_checkServerIdentity.servertlshash.toLowerCase() != certs[0].digest.split(':').join('').toLowerCase())) { throw new Error('BadCert') }
}

function tunnel_onError()
{
    sendConsoleText("ERROR: Unable to connect relay tunnel to: " + this.url + ", " + JSON.stringify(e));
}

// Handle a mesh agent command
function handleServerCommand(data) {
    if (typeof data == 'object') {
        // If this is a console command, parse it and call the console handler
        switch (data.action) {
            case 'agentupdate':
                agentUpdate_Start(data.url, { hash: data.hash, tlshash: data.servertlshash, sessionid: data.sessionid });
                break;
            case 'msg': {
                switch (data.type) {
                    case 'console': { // Process a console command
                        if ((typeof data.rights != 'number') || ((data.rights & 8) == 0) || ((data.rights & 16) == 0)) break; // Check console rights (Remote Control and Console)
                        if (data.value && data.sessionid) {
                            MeshServerLogEx(17, [data.value], "Processing console command: " + data.value, data);
                            var args = splitArgs(data.value);
                            processConsoleCommand(args[0].toLowerCase(), parseArgs(args), data.rights, data.sessionid);
                        }
                        break;
                    }
                    case 'tunnel':
                        {
                        if (data.value != null) { // Process a new tunnel connection request
                            // Create a new tunnel object
                            var xurl = getServerTargetUrlEx(data.value);
                            if (xurl != null) {
                                xurl = xurl.split('$').join('%24').split('@').join('%40'); // Escape the $ and @ characters
                                var woptions = http.parseUri(xurl);
                                woptions.perMessageDeflate = false;
                                if (typeof data.perMessageDeflate == 'boolean') { woptions.perMessageDeflate = data.perMessageDeflate; }

                                // Perform manual server TLS certificate checking based on the certificate hash given by the server.
                                woptions.rejectUnauthorized = 0;
                                woptions.checkServerIdentity = tunnel_checkServerIdentity;
                                woptions.checkServerIdentity.servertlshash = data.servertlshash;

                                //sendConsoleText(JSON.stringify(woptions));
                                //sendConsoleText('TUNNEL: ' + JSON.stringify(data, null, 2));

                                var tunnel = http.request(woptions);
                                tunnel.upgrade = onTunnelUpgrade;
                                tunnel.on('error', tunnel_onError);
                                tunnel.sessionid = data.sessionid;
                                tunnel.rights = data.rights;
                                tunnel.consent = data.consent;
                                if (global._MSH && _MSH().LocalConsent != null) { tunnel.consent |= parseInt(_MSH().LocalConsent); }
                                tunnel.privacybartext = data.privacybartext ? data.privacybartext : currentTranslation['privacyBar'];
                                tunnel.username = data.username + (data.guestname ? (' - ' + data.guestname) : '');
                                tunnel.realname = (data.realname ? data.realname : data.username) + (data.guestname ? (' - ' + data.guestname) : '');
                                tunnel.guestuserid = data.guestuserid;
                                tunnel.guestname = data.guestname;
                                tunnel.userid = data.userid;
                                if (server_check_consentTimer(tunnel.userid)) { tunnel.consent = (tunnel.consent & -57); } // Deleting Consent Requirement
                                tunnel.desktopviewonly = data.desktopviewonly;
                                tunnel.remoteaddr = data.remoteaddr;
                                tunnel.state = 0;
                                tunnel.url = xurl;
                                tunnel.protocol = 0;
                                tunnel.soptions = data.soptions;
                                tunnel.consentTimeout = (tunnel.soptions && tunnel.soptions.consentTimeout) ? tunnel.soptions.consentTimeout : 30;
                                tunnel.consentAutoAccept = (tunnel.soptions && (tunnel.soptions.consentAutoAccept === true));
                                tunnel.consentAutoAcceptIfNoUser = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfNoUser === true));
                                tunnel.consentAutoAcceptIfDesktopNoUser = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfDesktopNoUser === true));
                                tunnel.consentAutoAcceptIfTerminalNoUser = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfTerminalNoUser === true));
                                tunnel.consentAutoAcceptIfFileNoUser = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfFileNoUser === true));
                                tunnel.consentAutoAcceptIfLocked = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfLocked === true));
                                tunnel.consentAutoAcceptIfDesktopLocked = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfDesktopLocked === true));
                                tunnel.consentAutoAcceptIfTerminalLocked = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfTerminalLocked === true));
                                tunnel.consentAutoAcceptIfFileLocked = (tunnel.soptions && (tunnel.soptions.consentAutoAcceptIfFileLocked === true));
                                tunnel.oldStyle = (tunnel.soptions && tunnel.soptions.oldStyle) ? tunnel.soptions.oldStyle : false;
                                tunnel.tcpaddr = data.tcpaddr;
                                tunnel.tcpport = data.tcpport;
                                tunnel.udpaddr = data.udpaddr;
                                tunnel.udpport = data.udpport;

                                // Put the tunnel in the tunnels list
                                var index = nextTunnelIndex++;
                                tunnel.index = index;
                                tunnels[index] = tunnel;
                                tunnel.once('~', tunnel_finalized);
                                tunnel.end();

                                //sendConsoleText('New tunnel connection #' + index + ': ' + tunnel.url + ', rights: ' + tunnel.rights, data.sessionid);
                            }
                        }
                        break;
                    }
                    case 'endtunnel': {
                        // Terminate one or more tunnels
                        if ((data.rights != 4294967295) && (data.xuserid != data.userid)) return; // This command requires full admin rights on the device or user self-closes it's own sessions
                        for (var i in tunnels) {
                            if ((tunnels[i].userid == data.xuserid) && (tunnels[i].guestname == data.guestname)) {
                                var disconnect = false, msgid = 0;
                                if ((data.protocol == 'kvm') && (tunnels[i].protocol == 2)) { msgid = 134; disconnect = true; }
                                else if ((data.protocol == 'terminal') && (tunnels[i].protocol == 1)) { msgid = 135; disconnect = true; }
                                else if ((data.protocol == 'files') && (tunnels[i].protocol == 5)) { msgid = 136; disconnect = true; }
                                else if ((data.protocol == 'tcp') && (tunnels[i].tcpport != null)) { msgid = 137; disconnect = true; }
                                else if ((data.protocol == 'udp') && (tunnels[i].udpport != null)) { msgid = 137; disconnect = true; }
                                if (disconnect) {
                                    if (tunnels[i].s != null) { tunnels[i].s.end(); } else { tunnels[i].end(); }

                                    // Log tunnel disconnection
                                    var xusername = data.xuserid.split('/')[2];
                                    if (data.guestname != null) { xusername += '/' + guestname; }
                                    MeshServerLogEx(msgid, [xusername], "Forcibly disconnected session of user: " + xusername, data);
                                }
                            }
                        }
                        break;
                    }
                    case 'messagebox': {
                        // Display a message box
                        if (data.title && data.msg) {
                            MeshServerLogEx(18, [data.title, data.msg], "Displaying message box, title=" + data.title + ", message=" + data.msg, data);
                            if (process.platform == 'win32') {
                                if (global._clientmessage) {
                                    global._clientmessage.addMessage(data.msg);
                                }
                                else {
                                    try {
                                        require('win-dialog');
                                        var ipr = server_getUserImage(data.userid);
                                        ipr.title = data.title;
                                        ipr.message = data.msg;
                                        ipr.username = data.username;
                                        if (data.realname && (data.realname != '')) { ipr.username = data.realname; }
                                        ipr.timeout = (typeof data.timeout === 'number' ? data.timeout : 120000);
                                        global._clientmessage = ipr.then(function (img) {
                                            var options = { b64Image: img.split(',').pop(), background: color_options.background, foreground: color_options.foreground }
                                            if (this.timeout != 0) { options.timeout = this.timeout; }
                                            this.messagebox = require('win-dialog').create(this.title, this.message, this.username, options);
                                            this.__childPromise.addMessage = this.messagebox.addMessage.bind(this.messagebox);
                                            return (this.messagebox);
                                        });

                                        global._clientmessage.then(function () { global._clientmessage = null; });
                                    }
                                    catch (z) {
                                        try { require('message-box').create(data.title, data.msg, 120).then(function () { }).catch(function () { }); } catch (ex) { }
                                    }
                                }
                            }
                            else {
                                try { require('message-box').create(data.title, data.msg, 120).then(function () { }).catch(function () { }); } catch (ex) { }
                            }
                        }
                        break;
                    }
                    case 'ps': {
                        // Return the list of running processes
                        if (data.sessionid) {
                            processManager.getProcesses(function (plist) {
                                mesh.SendCommand({ action: 'msg', type: 'ps', value: JSON.stringify(plist), sessionid: data.sessionid });
                            });
                        }
                        break;
                    }
                    case 'psinfo': {
                        // Requestion details information about a process
                        if (data.pid) {
                            var info = {}; // TODO: Replace with real data. Feel free not to give all values if not available.
                            try {
                                info = processManager.getProcessInfo(data.pid);
                            }catch(e){ }
                            /*
                            info.processUser = "User"; // String
                            info.processDomain = "Domain"; // String
                            info.cmd = "abc"; // String
                            info.processName = "dummydata";
                            info.privateMemorySize = 123; // Bytes
                            info.virtualMemorySize = 123; // Bytes
                            info.workingSet = 123; // Bytes
                            info.totalProcessorTime = 123; // Seconds
                            info.userProcessorTime = 123; // Seconds
                            info.startTime = "2012-12-30T23:59:59.000Z"; // Time in UTC ISO format
                            info.sessionId = 123; // Number
                            info.privilegedProcessorTime = 123; // Seconds
                            info.PriorityBoostEnabled = true; // Boolean
                            info.peakWorkingSet = 123; // Bytes
                            info.peakVirtualMemorySize = 123; // Bytes
                            info.peakPagedMemorySize = 123; // Bytes
                            info.pagedSystemMemorySize = 123; // Bytes
                            info.pagedMemorySize = 123; // Bytes
                            info.nonpagedSystemMemorySize = 123; // Bytes
                            info.mainWindowTitle = "dummydata"; // String
                            info.machineName = "dummydata"; // Only set this if machine name is not "."
                            info.handleCount = 123; // Number
                            */
                            mesh.SendCommand({ action: 'msg', type: 'psinfo', pid: data.pid, sessionid: data.sessionid, value: info });
                        }
                        break;
                    }
                    case 'pskill': {
                        // Kill a process
                        if (data.value) {
                            var info = data.value.split('|'), pid = data.value, msg = " (Unknown)";
                            if (info.length > 1) { pid = info[0]; msg = " (" + info[1] + ")"; } else { info[1] = "Unknown"; }
                            MeshServerLogEx(19, info, "Killing process " + pid + msg, data);
                            try { process.kill(parseInt(pid)); } catch (ex) { sendConsoleText("pskill: " + JSON.stringify(ex)); }
                        }
                        break;
                    }
                    case 'service': {
                        // return information about the service
                        try {
                            var service = require('service-manager').manager.getService(data.serviceName);
                            if (service != null) {
                                var reply = {
                                    name: (service.name ? service.name : ''),
                                    status: (service.status ? service.status : ''),
                                    startType: (service.startType ? service.startType : ''),
                                    failureActions: (service.failureActions ? service.failureActions : ''),
                                    installedDate: (service.installedDate ? service.installedDate : ''),
                                    installedBy: (service.installedBy ? service.installedBy : '') ,
                                    user: (service.user ? service.user : '')
                                };
                                if(reply.installedBy.indexOf('S-1-5') != -1) {
                                    var cmd = "(Get-WmiObject -Class win32_userAccount -Filter \"SID='"+service.installedBy+"'\").Caption";
                                    var replydata = "";
                                    var pws = require('child_process').execFile(process.env['windir'] + '\\System32\\WindowsPowerShell\\v1.0\\powershell.exe', ['powershell', '-noprofile', '-nologo', '-command', '-'], {});
                                    pws.descriptorMetadata = 'UserSIDPowerShell';
                                    pws.stdout.on('data', function (c) { replydata += c.toString(); });
                                    pws.stderr.on('data', function (c) { replydata += c.toString(); });
                                    pws.stdin.write(cmd + '\r\nexit\r\n');
                                    pws.on('exit', function () { 
                                        if (replydata != "") reply.installedBy = replydata;
                                        mesh.SendCommand({ action: 'msg', type: 'service', value: JSON.stringify(reply), sessionid: data.sessionid });
                                        delete pws;
                                    });
                                } else {
                                    mesh.SendCommand({ action: 'msg', type: 'service', value: JSON.stringify(reply), sessionid: data.sessionid });
                                }
                            }
                        } catch (ex) { 
                            mesh.SendCommand({ action: 'msg', type: 'service', error: ex, sessionid: data.sessionid })
                        }
                    }
                    case 'services': {
                        // Return the list of installed services
                        var services = null;
                        try { services = require('service-manager').manager.enumerateService(); } catch (ex) { }
                        if (services != null) { mesh.SendCommand({ action: 'msg', type: 'services', value: JSON.stringify(services), sessionid: data.sessionid }); }
                        break;
                    }
                    case 'serviceStop': {
                        // Stop a service
                        try {
                            var service = require('service-manager').manager.getService(data.serviceName);
                            if (service != null) { service.stop(); }
                        } catch (ex) { }
                        break;
                    }
                    case 'serviceStart': {
                        // Start a service
                        try {
                            var service = require('service-manager').manager.getService(data.serviceName);
                            if (service != null) { service.start(); }
                        } catch (ex) { }
                        break;
                    }
                    case 'serviceRestart': {
                        // Restart a service
                        try {
                            var service = require('service-manager').manager.getService(data.serviceName);
                            if (service != null) { service.restart(); }
                        } catch (ex) { }
                        break;
                    }
                    case 'deskBackground':
                        {
                            // Toggle desktop background
                            try {
                                if (process.platform == 'win32') {
                                    var stype = require('user-sessions').getProcessOwnerName(process.pid).tsid == 0 ? 1 : 0;
                                    var sid = undefined;
                                    if (stype == 1) {
                                        if (require('MeshAgent')._tsid != null) {
                                            stype = 5;
                                            sid = require('MeshAgent')._tsid;
                                        }
                                    }
                                    var id = require('user-sessions').getProcessOwnerName(process.pid).tsid == 0 ? 1 : 0;
                                    var child = require('child_process').execFile(process.execPath, [process.execPath.split('\\').pop(), '-b64exec', 'dmFyIFNQSV9HRVRERVNLV0FMTFBBUEVSID0gMHgwMDczOwp2YXIgU1BJX1NFVERFU0tXQUxMUEFQRVIgPSAweDAwMTQ7CnZhciBHTSA9IHJlcXVpcmUoJ19HZW5lcmljTWFyc2hhbCcpOwp2YXIgdXNlcjMyID0gR00uQ3JlYXRlTmF0aXZlUHJveHkoJ3VzZXIzMi5kbGwnKTsKdXNlcjMyLkNyZWF0ZU1ldGhvZCgnU3lzdGVtUGFyYW1ldGVyc0luZm9BJyk7CgppZiAocHJvY2Vzcy5hcmd2Lmxlbmd0aCA9PSAzKQp7CiAgICB2YXIgdiA9IEdNLkNyZWF0ZVZhcmlhYmxlKDEwMjQpOwogICAgdXNlcjMyLlN5c3RlbVBhcmFtZXRlcnNJbmZvQShTUElfR0VUREVTS1dBTExQQVBFUiwgdi5fc2l6ZSwgdiwgMCk7CiAgICBjb25zb2xlLmxvZyh2LlN0cmluZyk7CiAgICBwcm9jZXNzLmV4aXQoKTsKfQplbHNlCnsKICAgIHZhciBuYiA9IEdNLkNyZWF0ZVZhcmlhYmxlKHByb2Nlc3MuYXJndlszXSk7CiAgICB1c2VyMzIuU3lzdGVtUGFyYW1ldGVyc0luZm9BKFNQSV9TRVRERVNLV0FMTFBBUEVSLCBuYi5fc2l6ZSwgbmIsIDApOwogICAgcHJvY2Vzcy5leGl0KCk7Cn0='], { type: stype, uid: sid });
                                    child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
                                    child.stderr.on('data', function () { });
                                    child.waitExit();
                                    var current = child.stdout.str.trim();
                                    if (current != '') { require('MeshAgent')._wallpaper = current; }
                                    child = require('child_process').execFile(process.execPath, [process.execPath.split('\\').pop(), '-b64exec', 'dmFyIFNQSV9HRVRERVNLV0FMTFBBUEVSID0gMHgwMDczOwp2YXIgU1BJX1NFVERFU0tXQUxMUEFQRVIgPSAweDAwMTQ7CnZhciBHTSA9IHJlcXVpcmUoJ19HZW5lcmljTWFyc2hhbCcpOwp2YXIgdXNlcjMyID0gR00uQ3JlYXRlTmF0aXZlUHJveHkoJ3VzZXIzMi5kbGwnKTsKdXNlcjMyLkNyZWF0ZU1ldGhvZCgnU3lzdGVtUGFyYW1ldGVyc0luZm9BJyk7CgppZiAocHJvY2Vzcy5hcmd2Lmxlbmd0aCA9PSAzKQp7CiAgICB2YXIgdiA9IEdNLkNyZWF0ZVZhcmlhYmxlKDEwMjQpOwogICAgdXNlcjMyLlN5c3RlbVBhcmFtZXRlcnNJbmZvQShTUElfR0VUREVTS1dBTExQQVBFUiwgdi5fc2l6ZSwgdiwgMCk7CiAgICBjb25zb2xlLmxvZyh2LlN0cmluZyk7CiAgICBwcm9jZXNzLmV4aXQoKTsKfQplbHNlCnsKICAgIHZhciBuYiA9IEdNLkNyZWF0ZVZhcmlhYmxlKHByb2Nlc3MuYXJndlszXSk7CiAgICB1c2VyMzIuU3lzdGVtUGFyYW1ldGVyc0luZm9BKFNQSV9TRVRERVNLV0FMTFBBUEVSLCBuYi5fc2l6ZSwgbmIsIDApOwogICAgcHJvY2Vzcy5leGl0KCk7Cn0=', current != '' ? '""' : require('MeshAgent')._wallpaper], { type: stype, uid: sid });
                                    child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
                                    child.stderr.on('data', function () { });
                                    child.waitExit();
                                    mesh.SendCommand({ action: 'msg', type: 'deskBackground', sessionid: data.sessionid, data: (current != '' ? "" : require('MeshAgent')._wallpaper), });
                                } else {
                                    var id = require('user-sessions').consoleUid();
                                    var current = require('linux-gnome-helpers').getDesktopWallpaper(id);
                                    if (current != '/dev/null') { require('MeshAgent')._wallpaper = current; }
                                    require('linux-gnome-helpers').setDesktopWallpaper(id, current != '/dev/null' ? undefined : require('MeshAgent')._wallpaper);
                                    mesh.SendCommand({ action: 'msg', type: 'deskBackground', sessionid: data.sessionid, data: (current != '/dev/null' ? "" : require('MeshAgent')._wallpaper), });
                                }
                            } catch (ex) {
                                sendConsoleText(ex);
                            }
                            break;
                        }
                    case 'openUrl': {
                        // Open a local web browser and return success/fail
                        MeshServerLogEx(20, [data.url], "Opening: " + data.url, data);
                        sendConsoleText("OpenURL: " + data.url);
                        if (data.url) { mesh.SendCommand({ action: 'msg', type: 'openUrl', url: data.url, sessionid: data.sessionid, success: (openUserDesktopUrl(data.url) != null) }); }
                        break;
                    }
                    case 'getclip': {
                        // Send the load clipboard back to the user
                        //sendConsoleText('getClip: ' + JSON.stringify(data));
                        if (require('MeshAgent').isService) {
                            require('clipboard').dispatchRead().then(function (str) {
                                if (str) {
                                    MeshServerLogEx(21, [str.length], "Getting clipboard content, " + str.length + " byte(s)", data);
                                    mesh.SendCommand({ action: 'msg', type: 'getclip', sessionid: data.sessionid, data: str, tag: data.tag });
                                }
                            });
                        } else {
                            require('clipboard').read().then(function (str) {
                                if (str) {
                                    MeshServerLogEx(21, [str.length], "Getting clipboard content, " + str.length + " byte(s)", data);
                                    mesh.SendCommand({ action: 'msg', type: 'getclip', sessionid: data.sessionid, data: str, tag: data.tag });
                                }
                            });
                        }
                        break;
                    }
                    case 'setclip': {
                        if (pendingSetClip) return;
                        // Set the load clipboard to a user value
                        if (typeof data.data == 'string') {
                            MeshServerLogEx(22, [data.data.length], "Setting clipboard content, " + data.data.length + " byte(s)", data);
                            if (require('MeshAgent').isService) {
                                if (process.platform != 'win32') {
                                    require('clipboard').dispatchWrite(data.data);
                                    mesh.SendCommand({ action: 'msg', type: 'setclip', sessionid: data.sessionid, success: true });
                                }
                                else {
                                    var clipargs = data.data;
                                    var uid = require('user-sessions').consoleUid();
                                    var user = require('user-sessions').getUsername(uid);
                                    var domain = require('user-sessions').getDomain(uid);
                                    user = (domain + '\\' + user);

                                    if (this._dispatcher) { this._dispatcher.close(); }
                                    this._dispatcher = require('win-dispatcher').dispatch({ user: user, modules: [{ name: 'clip-dispatch', script: "module.exports = { dispatch: function dispatch(val) { require('clipboard')(val); process.exit(); } };" }], launch: { module: 'clip-dispatch', method: 'dispatch', args: [clipargs] } });
                                    this._dispatcher.parent = this;
                                    //require('events').setFinalizerMetadata.call(this._dispatcher, 'clip-dispatch');
                                    pendingSetClip = true;
                                    this._dispatcher.on('connection', function (c) {
                                        this._c = c;
                                        this._c.root = this.parent;
                                        this._c.on('end', function ()
                                        {
                                            pendingSetClip = false;
                                            try { this.root._dispatcher.close(); } catch (ex) { }
                                            this.root._dispatcher = null;
                                            this.root = null;
                                            mesh.SendCommand({ action: 'msg', type: 'setclip', sessionid: data.sessionid, success: true });
                                        });
                                    });
                                }
                            }
                            else {
                                require('clipboard')(data.data);
                                mesh.SendCommand({ action: 'msg', type: 'setclip', sessionid: data.sessionid, success: true });
                            } // Set the clipboard
                        }
                        break;
                    }
                    case 'userSessions': {
                        mesh.SendCommand({ action: 'msg', type: 'userSessions', sessionid: data.sessionid, data: require('kvm-helper').users(), tag: data.tag });
                        break;
                    }
                    case 'cpuinfo':
                        // CPU & memory utilization
                        var cpuuse = require('sysinfo').cpuUtilization();
                        cpuuse.sessionid = data.sessionid;
                        cpuuse.tag = data.tag;
                        cpuuse.then(function (data) {
                            mesh.SendCommand(JSON.stringify(
                                {
                                    action: 'msg',
                                    type: 'cpuinfo',
                                    cpu: data,
                                    memory: require('sysinfo').memUtilization(),
                                    thermals: require('sysinfo').thermals == null ? [] : require('sysinfo').thermals(),
                                    sessionid: this.sessionid,
                                    tag: this.tag
                                }));
                        }, function (ex) { });
                        break;
                    case 'localapp':
                        // Send a message to a local application
                        sendConsoleText('localappMsg: ' + data.appid + ', ' + JSON.stringify(data.value));
                        if (data.appid != null) { sendToRegisteredApp(data.appid, data.value); } else { broadcastToRegisteredApps(data.value); }
                        break;
                    case 'alertbox': {
                        // Display an old style alert box
                        if (data.title && data.msg) {
                            MeshServerLogEx(158, [data.title, data.msg], "Displaying alert box, title=" + data.title + ", message=" + data.msg, data);
                            try { require('message-box').create(data.title, data.msg, 9999, 1).then(function () { }).catch(function () { }); } catch (ex) { }
                        }
                        break;
                    }
                    case 'sysinfo': {
                        // Send system information
                        getSystemInformation(function (results) {
                            if ((results != null) && (data.hash != results.hash)) { mesh.SendCommand({ action: 'sysinfo', sessionid: this.sessionid, data: results }); }
                        });
                        break;
                    }
                    default:
                        // Unknown action, ignore it.
                        break;
                }
                break;
            }
            case 'acmactivate': {
                if (amt != null) {
                    MeshServerLogEx(23, null, "Attempting Intel AMT ACM mode activation", data);
                    amt.setAcmResponse(data);
                }
                break;
            }
            case 'wakeonlan': {
                // Send wake-on-lan on all interfaces for all MAC addresses in data.macs array. The array is a list of HEX MAC addresses.
                //sendConsoleText("Server requesting wake-on-lan for: " + data.macs.join(', '));
                sendWakeOnLanEx(data.macs);
                sendWakeOnLanEx(data.macs);
                sendWakeOnLanEx(data.macs);
                break;
            }
            case 'runcommands': {
                if (mesh.cmdchild != null) { sendConsoleText("Run commands can't execute, already busy."); break; }
                if (!data.reply) sendConsoleText("Run commands (" + data.runAsUser + "): " + data.cmds);

                // data.runAsUser: 0=Agent,1=UserOrAgent,2=UserOnly
                var options = {};
                if (data.runAsUser > 0) {
                    try { options.uid = require('user-sessions').consoleUid(); } catch (ex) { }
                    options.type = require('child_process').SpawnTypes.TERM;
                }
                if (data.runAsUser == 2) {
                    if (options.uid == null) break;
                    if (((require('user-sessions').minUid != null) && (options.uid < require('user-sessions').minUid()))) break; // This command can only run as user.
                }
                var replydata = "";
                if (process.platform == 'win32') {
                    if (data.type == 1) {
                        // Windows command shell
                        mesh.cmdchild = require('child_process').execFile(process.env['windir'] + '\\system32\\cmd.exe', ['cmd'], options);
                        mesh.cmdchild.descriptorMetadata = 'UserCommandsShell';
                        mesh.cmdchild.stdout.on('data', function (c) { replydata += c.toString(); sendConsoleText(c.toString()); });
                        mesh.cmdchild.stderr.on('data', function (c) { replydata += c.toString(); sendConsoleText(c.toString()); });
                        mesh.cmdchild.stdin.write(data.cmds + '\r\nexit\r\n');
                        mesh.cmdchild.on('exit', function () {
                            if (data.reply) {
                                mesh.SendCommand({ action: 'msg', type: 'runcommands', result: replydata, sessionid: data.sessionid, responseid: data.responseid });
                            } else {
                                sendConsoleText("Run commands completed.");
                            }
                            delete mesh.cmdchild;
                        });
                    } else if (data.type == 2) {
                        // Windows Powershell
                        mesh.cmdchild = require('child_process').execFile(process.env['windir'] + '\\System32\\WindowsPowerShell\\v1.0\\powershell.exe', ['powershell', '-noprofile', '-nologo', '-command', '-'], options);
                        mesh.cmdchild.descriptorMetadata = 'UserCommandsPowerShell';
                        mesh.cmdchild.stdout.on('data', function (c) { replydata += c.toString(); sendConsoleText(c.toString()); });
                        mesh.cmdchild.stderr.on('data', function (c) { replydata += c.toString(); sendConsoleText(c.toString()); });
                        mesh.cmdchild.stdin.write(data.cmds + '\r\nexit\r\n');
                        mesh.cmdchild.on('exit', function () {
                            if (data.reply) {
                                mesh.SendCommand({ action: 'msg', type: 'runcommands', result: replydata, sessionid: data.sessionid, responseid: data.responseid });
                            } else {
                                sendConsoleText("Run commands completed.");
                            }
                            delete mesh.cmdchild;
                        });
                    }
                } else if (data.type == 3) {
                    // Linux shell
                    mesh.cmdchild = require('child_process').execFile('/bin/sh', ['sh'], options);
                    mesh.cmdchild.descriptorMetadata = 'UserCommandsShell';
                    mesh.cmdchild.stdout.on('data', function (c) { replydata += c.toString(); sendConsoleText(c.toString()); });
                    mesh.cmdchild.stderr.on('data', function (c) { replydata += c.toString(); sendConsoleText(c.toString()); });
                    mesh.cmdchild.stdin.write(data.cmds.split('\r').join('') + '\nexit\n');
                    mesh.cmdchild.on('exit', function () {
                        if (data.reply) {
                            mesh.SendCommand({ action: 'msg', type: 'runcommands', result: replydata, sessionid: data.sessionid, responseid: data.responseid });
                        } else {
                            sendConsoleText("Run commands completed.");
                        }
                        delete mesh.cmdchild;
                    });
                }
                break;
            }
            case 'uninstallagent':
                // Uninstall this agent
                var agentName = process.platform == 'win32' ? 'Mesh Agent' : 'meshagent';
                try {
                    agentName = require('MeshAgent').serviceName;
                } catch (ex) { }

                if (require('service-manager').manager.getService(agentName).isMe()) {
                    try { diagnosticAgent_uninstall(); } catch (ex) { }
                    var js = "require('service-manager').manager.getService('" + agentName + "').stop(); require('service-manager').manager.uninstallService('" + agentName + "'); process.exit();";
                    this.child = require('child_process').execFile(process.execPath, [process.platform == 'win32' ? (process.execPath.split('\\').pop()) : (process.execPath.split('/').pop()), '-b64exec', Buffer.from(js).toString('base64')], { type: 4, detached: true });
                }
                break;
            case 'poweraction': {
                // Server telling us to execute a power action
                if ((mesh.ExecPowerState != undefined) && (data.actiontype)) {
                    var forced = 0;
                    if (data.forced == 1) { forced = 1; }
                    data.actiontype = parseInt(data.actiontype);
                    MeshServerLogEx(25, [data.actiontype, forced], "Performing power action=" + data.actiontype + ", forced=" + forced, data);
                    sendConsoleText("Performing power action=" + data.actiontype + ", forced=" + forced + '.');
                    var r = mesh.ExecPowerState(data.actiontype, forced);
                    sendConsoleText("ExecPowerState returned code: " + r);
                }
                break;
            }
            case 'iplocation': {
                // Update the IP location information of this node. Only do this when requested by the server since we have a limited amount of time we can call this per day
                getIpLocationData(function (location) { mesh.SendCommand({ action: 'iplocation', type: 'publicip', value: location }); });
                break;
            }
            case 'toast': {
                // Display a toast message
                if (data.title && data.msg) {
                    MeshServerLogEx(26, [data.title, data.msg], "Displaying toast message, title=" + data.title + ", message=" + data.msg, data);
                    data.msg = data.msg.split('\r').join('\\r').split('\n').join('\\n');
                    try { require('toaster').Toast(data.title, data.msg); } catch (ex) { }
                }
                break;
            }
            case 'openUrl': {
                // Open a local web browser and return success/fail
                //sendConsoleText('OpenURL: ' + data.url);
                MeshServerLogEx(20, [data.url], "Opening: " + data.url, data);
                if (data.url) { mesh.SendCommand({ action: 'openUrl', url: data.url, sessionid: data.sessionid, success: (openUserDesktopUrl(data.url) != null) }); }
                break;
            }
            case 'amtconfig': {
                // Perform Intel AMT activation and/or configuration
                if ((apftunnel != null) || (amt == null) || (typeof data.user != 'string') || (typeof data.pass != 'string')) break;
                amt.getMeiState(15, function (state) {
                    if ((apftunnel != null) || (amt == null)) return;
                    if ((state == null) || (state.ProvisioningState == null)) return;
                    if ((state.UUID == null) || (state.UUID.length != 36)) return; // Bad UUID
                    getAmtOsDnsSuffix(state, function () {
                        var apfarg = {
                            mpsurl: mesh.ServerUrl.replace('/agent.ashx', '/apf.ashx'),
                            mpsuser: data.user, // Agent user name
                            mpspass: data.pass, // Encrypted login cookie
                            mpskeepalive: 60000,
                            clientname: state.OsHostname,
                            clientaddress: '127.0.0.1',
                            clientuuid: state.UUID,
                            conntype: 2, // 0 = CIRA, 1 = Relay, 2 = LMS. The correct value is 2 since we are performing an LMS relay, other values for testing.
                            meiState: state // MEI state will be passed to MPS server
                        };
                        addAmtEvent('LMS tunnel start.');
                        apftunnel = require('amt-apfclient')({ debug: false }, apfarg);
                        apftunnel.onJsonControl = handleApfJsonControl;
                        apftunnel.onChannelClosed = function () { addAmtEvent('LMS tunnel closed.'); apftunnel = null; }
                        try { apftunnel.connect(); } catch (ex) { }
                    });
                });
                break;
            }
            case 'getScript': {
                // Received a configuration script from the server
                sendConsoleText('getScript: ' + JSON.stringify(data));
                break;
            }
            case 'sysinfo': {
                // Fetch system information
                getSystemInformation(function (results) {
                    if ((results != null) && (data.hash != results.hash)) { mesh.SendCommand({ action: 'sysinfo', sessionid: this.sessionid, data: results }); }
                });
                break;
            }
            case 'ping': { mesh.SendCommand('{"action":"pong"}'); break; }
            case 'pong': { break; }
            case 'plugin': {
                try { require(data.plugin).consoleaction(data, data.rights, data.sessionid, this); } catch (ex) { throw ex; }
                break;
            }
            case 'coredump':
                // Set the current agent coredump situation.s
                if (data.value === true) {
                    if (process.platform == 'win32') {
                        // TODO: This replace() below is not ideal, would be better to remove the .exe at the end instead of replace.
                        process.coreDumpLocation = process.execPath.replace('.exe', '.dmp');
                    } else {
                        process.coreDumpLocation = (process.cwd() != '//') ? (process.cwd() + 'core') : null;
                    }
                } else if (data.value === false) {
                    process.coreDumpLocation = null;
                }
                break;
            case 'getcoredump':
                // Ask the agent if a core dump is currently available, if yes, also return the hash of the agent.
                var r = { action: 'getcoredump', value: (process.coreDumpLocation != null) };
                var coreDumpPath = null;
                if (process.platform == 'win32') { coreDumpPath = process.coreDumpLocation; } else { coreDumpPath = (process.cwd() != '//') ? fs.existsSync(process.cwd() + 'core') : null; }
                if ((coreDumpPath != null) && (fs.existsSync(coreDumpPath))) {
                    try {
                        var coredate = fs.statSync(coreDumpPath).mtime;
                        var coretime = new Date(coredate).getTime();
                        var agenttime = new Date(fs.statSync(process.execPath).mtime).getTime();
                        if (coretime > agenttime) { r.exists = (db.Get('CoreDumpTime') != coredate); }
                    } catch (ex) { }
                }
                if (r.exists == true) {
                    r.agenthashhex = getSHA384FileHash(process.execPath).toString('hex'); // Hash of current agent
                    r.corehashhex = getSHA384FileHash(coreDumpPath).toString('hex'); // Hash of core dump file
                }
                mesh.SendCommand(JSON.stringify(r));
                break;
            case 'meshToolInfo':
                if (data.pipe == true) { delete data.pipe; delete data.action; data.cmd = 'meshToolInfo'; broadcastToRegisteredApps(data); }
                if (data.tag == 'info') { sendConsoleText(JSON.stringify(data, null, 2)); }
                if (data.tag == 'install') {
                    data.func = function (options, success) {
                        sendConsoleText('Download of MeshCentral Assistant ' + (success ? 'succeed' : 'failed'));
                        if (success) {
                            // TODO: Install & Run
                        }
                    }
                    data.filename = 'MeshAssistant.exe';
                    downloadFile(data);
                }
                break;
            case 'getUserImage':
                if (data.pipe == true) { delete data.pipe; delete data.action; data.cmd = 'getUserImage'; broadcastToRegisteredApps(data); }
                if (data.tag == 'info') { sendConsoleText(JSON.stringify(data, null, 2)); }
                if (data.promise != null && require('MeshAgent')._promises[data.promise] != null) {
                    var p = require('MeshAgent')._promises[data.promise];
                    delete require('MeshAgent')._promises[data.promise];
                    p.resolve(data.image);
                }
                break;
            case 'wget': // Server uses this command to tell the agent to download a file using HTTPS/GET and place it in a given path. This is used for one-to-many file uploads.
                agentFileHttpPendingRequests.push(data);
                serverFetchFile();
                break;
            case 'serverInfo': // Server information
                obj.serverInfo = data;
                delete obj.serverInfo.action;
                break;
            case 'errorlog': // Return agent error log
                try { mesh.SendCommand(JSON.stringify({ action: 'errorlog', log: require('util-agentlog').read(data.startTime) })); } catch (ex) { }
                break;
            default:
                // Unknown action, ignore it.
                break;
        }
    }
}

// On non-Windows platforms, we need to query the DHCP server for the DNS suffix
function getAmtOsDnsSuffix(mestate, func) {
    if ((process.platform == 'win32') || (mestate.net0 == null) || (mestate.net0.mac == null)) { func(mestate); return; }
    try { require('linux-dhcp') } catch (ex) { func(mestate); return; }
    require('linux-dhcp').client.info(mestate.net0.mac).then(function (d) {
        if ((typeof d.options == 'object') && (typeof d.options.domainname == 'string')) { mestate.OsDnsSuffix = d.options.domainname; }
        func(mestate);
    }, function (e) {
        console.log('DHCP error', e);
        func(mestate);
    });
}

// Download a file from the server and check the hash.
// This download is similar to the one used for meshcore self-update.
var trustedDownloads = {};
function downloadFile(downloadoptions) {
    var options = require('http').parseUri(downloadoptions.url);
    options.rejectUnauthorized = false;
    options.checkServerIdentity = function checkServerIdentity(certs) {
        // If the tunnel certificate matches the control channel certificate, accept the connection
        try { if (require('MeshAgent').ServerInfo.ControlChannelCertificate.digest == certs[0].digest) return; } catch (ex) { }
        try { if (require('MeshAgent').ServerInfo.ControlChannelCertificate.fingerprint == certs[0].fingerprint) return; } catch (ex) { }
        // Check that the certificate is the one expected by the server, fail if not.
        if (checkServerIdentity.servertlshash == null) { if (require('MeshAgent').ServerInfo == null || require('MeshAgent').ServerInfo.ControlChannelCertificate == null) return; throw new Error('BadCert'); }
        if (certs[0].digest == null) return;
        if ((checkServerIdentity.servertlshash != null) && (checkServerIdentity.servertlshash.toLowerCase() != certs[0].digest.split(':').join('').toLowerCase())) { throw new Error('BadCert') }
    }
    //options.checkServerIdentity.servertlshash = downloadoptions.serverhash;
    trustedDownloads[downloadoptions.name] = downloadoptions;
    trustedDownloads[downloadoptions.name].dl = require('https').get(options);
    trustedDownloads[downloadoptions.name].dl.on('error', function (e) { downloadoptions.func(downloadoptions, false); delete trustedDownloads[downloadoptions.name]; });
    trustedDownloads[downloadoptions.name].dl.on('response', function (img) {
        this._file = require('fs').createWriteStream(trustedDownloads[downloadoptions.name].filename, { flags: 'wb' });
        this._filehash = require('SHA384Stream').create();
        this._filehash.on('hash', function (h) { if ((downloadoptions.hash != null) && (downloadoptions.hash.toLowerCase() != h.toString('hex').toLowerCase())) { downloadoptions.func(downloadoptions, false); delete trustedDownloads[downloadoptions.name]; return; } downloadoptions.func(downloadoptions, true); });
        img.pipe(this._file);
        img.pipe(this._filehash);
    });
}

// Handle APF JSON control commands
function handleApfJsonControl(data) {
    if (data.action == 'console') { addAmtEvent(data.msg); } // Add console message to AMT event log
    if (data.action == 'mestate') { amt.getMeiState(15, function (state) { apftunnel.updateMeiState(state); }); } // Update the MEI state
    if (data.action == 'close') { try { apftunnel.disconnect(); } catch (ex) { } apftunnel = null; } // Close the CIRA-LMS connection
    if (amt.amtMei != null) {
        if (data.action == 'deactivate') { // Request CCM deactivation
            amt.amtMei.unprovision(1, function (status) { if (apftunnel) apftunnel.sendMeiDeactivationState(status); }); // 0 = Success
        }
        if (data.action == 'startTlsHostConfig') { // Request start of host based TLS ACM activation
            amt.amtMei.startConfigurationHBased(Buffer.from(data.hash, 'hex'), data.hostVpn, data.dnsSuffixList, function (response) { apftunnel.sendStartTlsHostConfigResponse(response); });
        }
        if (data.action == 'stopConfiguration') { // Request Intel AMT stop configuration.
            amt.amtMei.stopConfiguration(function (status) { apftunnel.sendStopConfigurationResponse(status); });
        }
    }
}

// Agent just get a file from the server and save it locally.
function serverFetchFile() {
    if ((Object.keys(agentFileHttpRequests).length > 4) || (agentFileHttpPendingRequests.length == 0)) return; // No more than 4 active HTTPS requests to the server.
    var data = agentFileHttpPendingRequests.shift();
    if ((data.overwrite !== true) && fs.existsSync(data.path)) return; // Don't overwrite an existing file.
    if (data.createFolder) { try { fs.mkdirSync(data.folder); } catch (ex) { } } // If requested, create the local folder.
    data.url = 'http' + getServerTargetUrlEx('*/').substring(2);
    var agentFileHttpOptions = http.parseUri(data.url);
    agentFileHttpOptions.path = data.urlpath;

    // Perform manual server TLS certificate checking based on the certificate hash given by the server.
    agentFileHttpOptions.rejectUnauthorized = 0;
    agentFileHttpOptions.checkServerIdentity = function checkServerIdentity(certs) {
        // If the tunnel certificate matches the control channel certificate, accept the connection
        try { if (require('MeshAgent').ServerInfo.ControlChannelCertificate.digest == certs[0].digest) return; } catch (ex) { }
        try { if (require('MeshAgent').ServerInfo.ControlChannelCertificate.fingerprint == certs[0].fingerprint) return; } catch (ex) { }
        // Check that the certificate is the one expected by the server, fail if not.
        if ((checkServerIdentity.servertlshash != null) && (checkServerIdentity.servertlshash.toLowerCase() != certs[0].digest.split(':').join('').toLowerCase())) { throw new Error('BadCert') }
    }
    agentFileHttpOptions.checkServerIdentity.servertlshash = data.servertlshash;

    if (agentFileHttpOptions == null) return;
    var agentFileHttpRequest = http.request(agentFileHttpOptions,
        function (response) {
            response.xparent = this;
            try {
                response.xfile = fs.createWriteStream(this.xpath, { flags: 'wbN' })
                response.pipe(response.xfile);
                response.end = function () { delete agentFileHttpRequests[this.xparent.xurlpath]; delete this.xparent; serverFetchFile(); }
            } catch (ex) { delete agentFileHttpRequests[this.xurlpath]; delete response.xparent; serverFetchFile(); return; }
        }
    );
    agentFileHttpRequest.on('error', function (ex) { sendConsoleText(ex); delete agentFileHttpRequests[this.xurlpath]; serverFetchFile(); });
    agentFileHttpRequest.end();
    agentFileHttpRequest.xurlpath = data.urlpath;
    agentFileHttpRequest.xpath = data.path;
    agentFileHttpRequests[data.urlpath] = agentFileHttpRequest;
}

// Called when a file changed in the file system
/*
function onFileWatcher(a, b) {
    console.log('onFileWatcher', a, b, this.path);
    var response = getDirectoryInfo(this.path);
    if ((response != undefined) && (response != null)) { this.tunnel.s.write(JSON.stringify(response)); }
}
*/

// Replace all key name spaces with _ in an object recursively.
// This is a workaround since require('computer-identifiers').get() returns key names with spaces in them on Linux.
function replaceSpacesWithUnderscoresRec(o) {
    if (typeof o != 'object') return;
    for (var i in o) { if (i.indexOf(' ') >= 0) { o[i.split(' ').join('_')] = o[i]; delete o[i]; } replaceSpacesWithUnderscoresRec(o[i]); }
}

function getSystemInformation(func) {
    try {
        var results = { hardware: require('computer-identifiers').get() }; // Hardware info
        if (results.hardware && results.hardware.windows) {
            // Remove extra entries and things that change quickly
            var x = results.hardware.windows.osinfo;
            try { delete x.FreePhysicalMemory; } catch (ex) { }
            try { delete x.FreeSpaceInPagingFiles; } catch (ex) { }
            try { delete x.FreeVirtualMemory; } catch (ex) { }
            try { delete x.LocalDateTime; } catch (ex) { }
            try { delete x.MaxProcessMemorySize; } catch (ex) { }
            try { delete x.TotalVirtualMemorySize; } catch (ex) { }
            try { delete x.TotalVisibleMemorySize; } catch (ex) { }
            try {
                if (results.hardware.windows.memory) { for (var i in results.hardware.windows.memory) { delete results.hardware.windows.memory[i].Node; } }
                if (results.hardware.windows.osinfo) { 
                    delete results.hardware.windows.osinfo.Node;
                    results.hardware.windows.osinfo.Domain = getDomainInfo().Domain;
                    results.hardware.windows.osinfo.PartOfDomain = getDomainInfo().PartOfDomain;
                }
                if (results.hardware.windows.partitions) { for (var i in results.hardware.windows.partitions) { delete results.hardware.windows.partitions[i].Node; } }
            } catch (ex) { }
            if (x.LastBootUpTime) { // detect windows uptime
                var thedate = {
                    year: parseInt(x.LastBootUpTime.substring(0, 4)),
                    month: parseInt(x.LastBootUpTime.substring(4, 6)) - 1, // Months are 0-based in JavaScript (0 - January, 11 - December)
                    day: parseInt(x.LastBootUpTime.substring(6, 8)),
                    hours: parseInt(x.LastBootUpTime.substring(8, 10)),
                    minutes: parseInt(x.LastBootUpTime.substring(10, 12)),
                    seconds: parseInt(x.LastBootUpTime.substring(12, 14)),
                };
                var thelastbootuptime = new Date(thedate.year, thedate.month, thedate.day, thedate.hours, thedate.minutes, thedate.seconds);
                meshCoreObj.lastbootuptime = thelastbootuptime.getTime(); // store the last boot up time in coreinfo for columns
                meshCoreObjChanged();
                var nowtime = new Date();
                var differenceInMilliseconds = Math.abs(thelastbootuptime - nowtime);
                if (differenceInMilliseconds < 300000) { // computer uptime less than 5 minutes
                    MeshServerLogEx(159, [thelastbootuptime.toString()], "Device Powered On", null);
                }
            }
        }
        if(results.hardware && results.hardware.linux) {
            if(results.hardware.linux.LastBootUpTime) {
                var thelastbootuptime = new Date(results.hardware.linux.LastBootUpTime);
                meshCoreObj.lastbootuptime = thelastbootuptime.getTime(); // store the last boot up time in coreinfo for columns
                meshCoreObjChanged();
                var nowtime = new Date();
                var differenceInMilliseconds = Math.abs(thelastbootuptime - nowtime);
                if (differenceInMilliseconds < 300000) { // computer uptime less than 5 minutes
                    MeshServerLogEx(159, [thelastbootuptime.toString()], "Device Powered On", null);
                }
            }
        }
        if(results.hardware && results.hardware.darwin){
            if(results.hardware.darwin.LastBootUpTime) {
                var thelastbootuptime = new Date(results.hardware.darwin.LastBootUpTime * 1000); // must times by 1000 even tho timestamp is correct?
                meshCoreObj.lastbootuptime = thelastbootuptime.getTime(); // store the last boot up time in coreinfo for columns
                meshCoreObjChanged();
                var nowtime = new Date();
                var differenceInMilliseconds = Math.abs(thelastbootuptime - nowtime);
                if (differenceInMilliseconds < 300000) { // computer uptime less than 5 minutes
                    MeshServerLogEx(159, [thelastbootuptime.toString()], "Device Powered On", null);
                }
            }
        }    
        results.hardware.agentvers = process.versions;
        results.hardware.network = { dns: require('os').dns() }; 
        replaceSpacesWithUnderscoresRec(results);
        var hasher = require('SHA384Stream').create();

        // On Windows platforms, get volume information - Needs more testing.
        if (process.platform == 'win32')
        {
            results.pendingReboot = require('win-info').pendingReboot(); // Pending reboot
            if (require('win-volumes').volumes_promise != null)
            {
                var p = require('win-volumes').volumes_promise();
                p.then(function (res)
                {
                    results.hardware.windows.volumes = cleanGetBitLockerVolumeInfo(res);
                    results.hash = hasher.syncHash(JSON.stringify(results)).toString('hex');
                    func(results);
                });
            }
            else
            {
                results.hash = hasher.syncHash(JSON.stringify(results)).toString('hex');
                func(results);
            }
        }
        else
        {
            results.hash = hasher.syncHash(JSON.stringify(results)).toString('hex');
            func(results);
        }
        
    } catch (ex) { func(null, ex); }
}

// Get a formated response for a given directory path
function getDirectoryInfo(reqpath) {
    var response = { path: reqpath, dir: [] };
    if (((reqpath == undefined) || (reqpath == '')) && (process.platform == 'win32')) {
        // List all the drives in the root, or the root itself
        var results = null;
        try { results = fs.readDrivesSync(); } catch (ex) { }
        if (results != null) {
            for (var i = 0; i < results.length; ++i) {
                var drive = { n: results[i].name, t: 1, dt: results[i].type, s: (results[i].size ? results[i].size : 0), f: (results[i].free ? results[i].free : 0) };
                response.dir.push(drive);
            }
        }
    } else {
        // List all the files and folders in this path
        if (reqpath == '') { reqpath = '/'; }
        var results = null, xpath = obj.path.join(reqpath, '*');
        //if (process.platform == "win32") { xpath = xpath.split('/').join('\\'); }
        try { results = fs.readdirSync(xpath); } catch (ex) { }
        try { if ((results != null) && (results.length == 0) && (fs.existsSync(reqpath) == false)) { results = null; } } catch (ex) { }
        if (results != null) {
            for (var i = 0; i < results.length; ++i) {
                if ((results[i] != '.') && (results[i] != '..')) {
                    var stat = null, p = obj.path.join(reqpath, results[i]);
                    //if (process.platform == "win32") { p = p.split('/').join('\\'); }
                    try { stat = fs.statSync(p); } catch (ex) { } // TODO: Get file size/date
                    if ((stat != null) && (stat != undefined)) {
                        if (stat.isDirectory() == true) {
                            response.dir.push({ n: results[i], t: 2, d: stat.mtime });
                        } else {
                            response.dir.push({ n: results[i], t: 3, s: stat.size, d: stat.mtime });
                        }
                    }
                }
            }
        } else {
            response.dir = null;
        }
    }
    return response;
}

function tunnel_s_finalized()
{
    console.info1('Tunnel Socket Finalized');
}


function tunnel_onIdleTimeout()
{
    this.ping();
    this.setTimeout(require('MeshAgent').idleTimeout * 1000);
}

// Tunnel callback operations
function onTunnelUpgrade(response, s, head)
{

    this.s = s;
    s.once('~', tunnel_s_finalized);
    s.httprequest = this;
    s.end = onTunnelClosed;
    s.tunnel = this;
    s.descriptorMetadata = "MeshAgent_relayTunnel";


    if (require('MeshAgent').idleTimeout != null)
    {
        s.setTimeout(require('MeshAgent').idleTimeout * 1000);
        s.on('timeout', tunnel_onIdleTimeout);
    }

    //sendConsoleText('onTunnelUpgrade - ' + this.tcpport + ' - ' + this.udpport);

    if (this.tcpport != null) {
        // This is a TCP relay connection, pause now and try to connect to the target.
        s.pause();
        s.data = onTcpRelayServerTunnelData;
        var connectionOptions = { port: parseInt(this.tcpport) };
        if (this.tcpaddr != null) { connectionOptions.host = this.tcpaddr; } else { connectionOptions.host = '127.0.0.1'; }
        s.tcprelay = net.createConnection(connectionOptions, onTcpRelayTargetTunnelConnect);
        s.tcprelay.peerindex = this.index;

        // Add the TCP session to the count and update the server
        if (s.httprequest.userid != null) {
            var userid = getUserIdAndGuestNameFromHttpRequest(s.httprequest);
            if (tunnelUserCount.tcp[userid] == null) { tunnelUserCount.tcp[userid] = 1; } else { tunnelUserCount.tcp[userid]++; }
            try { mesh.SendCommand({ action: 'sessions', type: 'tcp', value: tunnelUserCount.tcp }); } catch (ex) { }
            broadcastSessionsToRegisteredApps();
        }
    }
    if (this.udpport != null) {
        // This is a UDP relay connection, get the UDP socket setup. // TODO: ***************
        s.data = onUdpRelayServerTunnelData;
        s.udprelay = require('dgram').createSocket({ type: 'udp4' });
        s.udprelay.bind({ port: 0 });
        s.udprelay.peerindex = this.index;
        s.udprelay.on('message', onUdpRelayTargetTunnelConnect);
        s.udprelay.udpport = this.udpport;
        s.udprelay.udpaddr = this.udpaddr;
        s.udprelay.first = true;

        // Add the UDP session to the count and update the server
        if (s.httprequest.userid != null) {
            var userid = getUserIdAndGuestNameFromHttpRequest(s.httprequest);
            if (tunnelUserCount.udp[userid] == null) { tunnelUserCount.udp[userid] = 1; } else { tunnelUserCount.udp[userid]++; }
            try { mesh.SendCommand({ action: 'sessions', type: 'udp', value: tunnelUserCount.tcp }); } catch (ex) { }
            broadcastSessionsToRegisteredApps();
        }
    }
    else {
        // This is a normal connect for KVM/Terminal/Files
        s.data = onTunnelData;
    }
}

// If the HTTP Request has a guest name, we need to form a userid that includes the guest name in hex.
// This is so we can tell the server that a session is for a given userid/guest sharing pair.
function getUserIdAndGuestNameFromHttpRequest(request) {
    if (request.guestname == null) return request.userid; else return request.guestuserid + '/guest:' + Buffer.from(request.guestname).toString('base64');
}

// Called when UDP relay data is received // TODO****
function onUdpRelayTargetTunnelConnect(data) {
    var peerTunnel = tunnels[this.peerindex];
    peerTunnel.s.write(data);
}

// Called when we get data from the server for a TCP relay (We have to skip the first received 'c' and pipe the rest)
function onUdpRelayServerTunnelData(data) {
    if (this.udprelay.first === true) {
        delete this.udprelay.first; // Skip the first 'c' that is received.
    } else {
        this.udprelay.send(data, parseInt(this.udprelay.udpport), this.udprelay.udpaddr ? this.udprelay.udpaddr : '127.0.0.1');
    }
}

// Called when the TCP relay target is connected
function onTcpRelayTargetTunnelConnect() {
    var peerTunnel = tunnels[this.peerindex];
    this.pipe(peerTunnel.s); // Pipe Target --> Server
    peerTunnel.s.first = true;
    peerTunnel.s.resume();
}

// Called when we get data from the server for a TCP relay (We have to skip the first received 'c' and pipe the rest)
function onTcpRelayServerTunnelData(data) {
    if (this.first == true) {
        this.first = false;
        this.pipe(this.tcprelay, { dataTypeSkip: 1 }); // Pipe Server --> Target (don't pipe text type websocket frames)
    }
}

function onTunnelClosed()
{
    if (this.httprequest._dispatcher != null && this.httprequest.term == null)
    {
        // Windows Dispatcher was created to spawn a child connection, but the child didn't connect yet, so we have to shutdown the dispatcher, otherwise the child may end up hanging
        if (this.httprequest._dispatcher.close) { this.httprequest._dispatcher.close(); }
        this.httprequest._dispatcher = null;
    }

    if (this.tunnel)
    {
        if (tunnels[this.httprequest.index] == null)
        {
            this.tunnel.s = null;
            this.tunnel = null;
            return;
        }
    }

    var tunnel = tunnels[this.httprequest.index];
    if (tunnel == null) return; // Stop duplicate calls.

    // Perform display locking on disconnect
    if ((this.httprequest.protocol == 2) && (this.httprequest.autolock === true)) {
        // Look for a TSID
        var tsid = null;
        if ((this.httprequest.xoptions != null) && (typeof this.httprequest.xoptions.tsid == 'number')) { tsid = this.httprequest.xoptions.tsid; }

        // Lock the current user out of the desktop
        MeshServerLogEx(53, null, "Locking remote user out of desktop", this.httprequest);
        lockDesktop(tsid);
    }

    // If this is a routing session, clean up and send the new session counts.
    if (this.httprequest.userid != null) {
        if (this.httprequest.tcpport != null) {
            var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest);
            if (tunnelUserCount.tcp[userid] != null) { tunnelUserCount.tcp[userid]--; if (tunnelUserCount.tcp[userid] <= 0) { delete tunnelUserCount.tcp[userid]; } }
            try { mesh.SendCommand({ action: 'sessions', type: 'tcp', value: tunnelUserCount.tcp }); } catch (ex) { }
            broadcastSessionsToRegisteredApps();
        } else if (this.httprequest.udpport != null) {
            var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest);
            if (tunnelUserCount.udp[userid] != null) { tunnelUserCount.udp[userid]--; if (tunnelUserCount.udp[userid] <= 0) { delete tunnelUserCount.udp[userid]; } }
            try { mesh.SendCommand({ action: 'sessions', type: 'udp', value: tunnelUserCount.udp }); } catch (ex) { }
            broadcastSessionsToRegisteredApps();
        }
    }

    try {
        // Sent tunnel statistics to the server, only send this if compression was used.
        if ((this.bytesSent_uncompressed) && (this.bytesSent_uncompressed.toString() != this.bytesSent_actual.toString())) {
            mesh.SendCommand({
                action: 'tunnelCloseStats',
                url: tunnel.url,
                userid: tunnel.userid,
                protocol: tunnel.protocol,
                sessionid: tunnel.sessionid,
                sent: this.bytesSent_uncompressed.toString(),
                sentActual: this.bytesSent_actual.toString(),
                sentRatio: this.bytesSent_ratio,
                received: this.bytesReceived_uncompressed.toString(),
                receivedActual: this.bytesReceived_actual.toString(),
                receivedRatio: this.bytesReceived_ratio
            });
        }
    } catch (ex) { }

    //sendConsoleText("Tunnel #" + this.httprequest.index + " closed. Sent -> " + this.bytesSent_uncompressed + ' bytes (uncompressed), ' + this.bytesSent_actual + ' bytes (actual), ' + this.bytesSent_ratio + '% compression', this.httprequest.sessionid);
    

    /*
    // Close the watcher if required
    if (this.httprequest.watcher != undefined) {
        //console.log('Closing watcher: ' + this.httprequest.watcher.path);
        //this.httprequest.watcher.close(); // TODO: This line causes the agent to crash!!!!
        delete this.httprequest.watcher;
    }
    */

    // If there is a upload or download active on this connection, close the file
    if (this.httprequest.uploadFile) { fs.closeSync(this.httprequest.uploadFile); delete this.httprequest.uploadFile; delete this.httprequest.uploadFileid; delete this.httprequest.uploadFilePath; delete this.httprequest.uploadFileSize; }
    if (this.httprequest.downloadFile) { delete this.httprequest.downloadFile; }

    // Clean up WebRTC
    if (this.webrtc != null) {
        if (this.webrtc.rtcchannel) { try { this.webrtc.rtcchannel.close(); } catch (ex) { } this.webrtc.rtcchannel.removeAllListeners('data'); this.webrtc.rtcchannel.removeAllListeners('end'); delete this.webrtc.rtcchannel; }
        if (this.webrtc.websocket) { delete this.webrtc.websocket; }
        try { this.webrtc.close(); } catch (ex) { }
        this.webrtc.removeAllListeners('connected');
        this.webrtc.removeAllListeners('disconnected');
        this.webrtc.removeAllListeners('dataChannel');
        delete this.webrtc;
    }

    // Clean up WebSocket
    delete tunnels[this.httprequest.index];
    tunnel = null;
    this.tunnel.s = null;
    this.tunnel = null;
    this.removeAllListeners('data');
}
function onTunnelSendOk() { /*sendConsoleText("Tunnel #" + this.index + " SendOK.", this.sessionid);*/ }

function terminal_onconnection (c)
{
    if (this.httprequest.connectionPromise.completed) 
    {
        c.end(); 
    }
    else
    {
        this.httprequest.connectionPromise._res(c);
    }
}
function terminal_user_onconnection(c)
{
    console.info1('completed-2: ' + this.connectionPromise.completed);

    if (this.connectionPromise.completed)
    {
        c.end();
    }
    else
    {
        this.connectionPromise._res(c);
    }
}
function terminal_stderr_ondata(c)
{
    this.stdout.write(c);
}
function terminal_onend()
{
    this.httprequest.process.kill();
}

function terminal_onexit()
{
    this.tunnel.end();
}
function terminal_onfinalized()
{
    this.httprequest = null;
    console.info1('Dispatcher Finalized');
}
function terminal_end()
{
    if (this.httprequest == null) { return; }
    if (this.httprequest.tpromise._consent) { this.httprequest.tpromise._consent.close(); }
    if (this.httprequest.connectionPromise) { this.httprequest.connectionPromise._rej('Closed'); }

    // Remove the terminal session to the count to update the server
    if (this.httprequest.userid != null)
    {
        var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest);
        if (tunnelUserCount.terminal[userid] != null) { tunnelUserCount.terminal[userid]--; if (tunnelUserCount.terminal[userid] <= 0) { delete tunnelUserCount.terminal[userid]; } }
        try { mesh.SendCommand({ action: 'sessions', type: 'terminal', value: tunnelUserCount.terminal }); } catch (ex) { }
        broadcastSessionsToRegisteredApps();
    }

    if (process.platform == 'win32')
    {
        // Unpipe the web socket
        this.unpipe(this.httprequest._term);
        if (this.httprequest._term) { this.httprequest._term.unpipe(this); }

        // Unpipe the WebRTC channel if needed (This will also be done when the WebRTC channel ends).
        if (this.rtcchannel)
        {
            this.rtcchannel.unpipe(this.httprequest._term);
            if (this.httprequest._term) { this.httprequest._term.unpipe(this.rtcchannel); }
        }

        // Clean up
        if (this.httprequest._term) { this.httprequest._term.end(); }
        this.httprequest._term = null;
        this.httprequest._dispatcher = null;
    }

    this.httprequest = null;

}

function terminal_consent_ask(ws) {
    ws.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: "Waiting for user to grant access...", msgid: 1 }));
    var consentMessage = currentTranslation['terminalConsent'].replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username);
    var consentTitle = 'MeshCentral';
    if (ws.httprequest.soptions != null) {
        if (ws.httprequest.soptions.consentTitle != null) { consentTitle = ws.httprequest.soptions.consentTitle; }
        if (ws.httprequest.soptions.consentMsgTerminal != null) { consentMessage = ws.httprequest.soptions.consentMsgTerminal.replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username); }
    }
    if (process.platform == 'win32') {
        var enhanced = false;
        if (ws.httprequest.oldStyle === false) {
            try { require('win-userconsent'); enhanced = true; } catch (ex) { }
        }
        if (enhanced) {
            var ipr = server_getUserImage(ws.httprequest.userid);
            ipr.consentTitle = consentTitle;
            ipr.consentMessage = consentMessage;
            ipr.consentTimeout = ws.httprequest.consentTimeout;
            ipr.consentAutoAccept = ws.httprequest.consentAutoAccept;
            ipr.username = ws.httprequest.realname;
            ipr.tsid = ws.tsid;
            ipr.translations = { Allow: currentTranslation['allow'], Deny: currentTranslation['deny'], Auto: currentTranslation['autoAllowForFive'], Caption: consentMessage };
            ws.httprequest.tpromise._consent = ipr.then(function (img) {
                this.consent = require('win-userconsent').create(this.consentTitle, this.consentMessage, this.username, { b64Image: img.split(',').pop(), uid: this.tsid, timeout: this.consentTimeout * 1000, timeoutAutoAccept: this.consentAutoAccept, translations: this.translations, background: color_options.background, foreground: color_options.foreground });
                this.__childPromise.close = this.consent.close.bind(this.consent);
                return (this.consent);
            });
        } else {
            ws.httprequest.tpromise._consent = require('message-box').create(consentTitle, consentMessage, ws.httprequest.consentTimeout);
        }
    } else {
        ws.httprequest.tpromise._consent = require('message-box').create(consentTitle, consentMessage, ws.httprequest.consentTimeout);
    }
    ws.httprequest.tpromise._consent.retPromise = ws.httprequest.tpromise;
    ws.httprequest.tpromise._consent.then(function (always) {
        if (always && process.platform == 'win32') { server_set_consentTimer(this.retPromise.httprequest.userid); }
        // Success
        MeshServerLogEx(27, null, "Local user accepted remote terminal request (" + this.retPromise.httprequest.remoteaddr + ")", this.retPromise.that.httprequest);
        this.retPromise.that.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: null, msgid: 0 }));
        this.retPromise._consent = null;
        this.retPromise._res();
    }, function (e) {
        if (this.retPromise.that) {
            if(this.retPromise.that.httprequest){ // User Consent Denied
                MeshServerLogEx(28, null, "Local user rejected remote terminal request (" + this.retPromise.that.httprequest.remoteaddr + ")", this.retPromise.that.httprequest);
            } else { } // Connection was closed server side, maybe log some messages somewhere?
            this.retPromise._consent = null;
            this.retPromise.that.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: e.toString(), msgid: 2 }));
        } else { } // no websocket, maybe log some messages somewhere?
        this.retPromise._rej(e.toString());
    });
}

function terminal_promise_connection_rejected(e)
{
    // FAILED to connect terminal
    this.ws.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: e.toString(), msgid: 2 }));
    this.ws.end();
}

function terminal_promise_connection_resolved(term)
{
    this._internal.completedArgs = [];

    // SUCCESS
    var stdoutstream;
    var stdinstream;
    if (process.platform == 'win32')
    {
        this.ws.httprequest._term = term;
        this.ws.httprequest._term.tunnel = this.ws;
        stdoutstream = stdinstream = term;
    }
    else
    {
        term.descriptorMetadata = 'Remote Terminal';
        this.ws.httprequest.process = term;
        this.ws.httprequest.process.tunnel = this.ws;
        term.stderr.stdout = term.stdout;
        term.stderr.on('data', terminal_stderr_ondata);
        stdoutstream = term.stdout;
        stdinstream = term.stdin;
        this.ws.prependListener('end', terminal_onend);
        term.prependListener('exit', terminal_onexit);
    }

    this.ws.removeAllListeners('data');
    this.ws.on('data', onTunnelControlData);

    stdoutstream.pipe(this.ws, { dataTypeSkip: 1 });            // 0 = Binary, 1 = Text.
    this.ws.pipe(stdinstream, { dataTypeSkip: 1, end: false }); // 0 = Binary, 1 = Text. 

    // Add the terminal session to the count to update the server
    if (this.ws.httprequest.userid != null)
    {
        var userid = getUserIdAndGuestNameFromHttpRequest(this.ws.httprequest);
        if (tunnelUserCount.terminal[userid] == null) { tunnelUserCount.terminal[userid] = 1; } else { tunnelUserCount.terminal[userid]++; }
        try { mesh.SendCommand({ action: 'sessions', type: 'terminal', value: tunnelUserCount.terminal }); } catch (ex) { }
        broadcastSessionsToRegisteredApps();
    }

    // Toast Notification, if required
    if (this.ws.httprequest.consent && (this.ws.httprequest.consent & 2))
    {
        // User Notifications is required
        var notifyMessage = currentTranslation['terminalNotify'].replace(/\{0\}/g, this.ws.httprequest.realname ? this.ws.httprequest.realname : this.ws.httprequest.username);
        var notifyTitle = "MeshCentral";
        if (this.ws.httprequest.soptions != null)
        {
            if (this.ws.httprequest.soptions.notifyTitle != null) { notifyTitle = this.ws.httprequest.soptions.notifyTitle; }
            if (this.ws.httprequest.soptions.notifyMsgTerminal != null) { notifyMessage = this.ws.httprequest.soptions.notifyMsgTerminal.replace(/\{0\}/g, this.ws.httprequest.realname).replace(/\{1\}/g, this.ws.httprequest.username); }
        }
        try { require('toaster').Toast(notifyTitle, notifyMessage); } catch (ex) { }
    }
    this.ws = null;
}
function terminal_promise_consent_rejected(e)
{
    // DO NOT start terminal
    if (this.that) {
        if(this.that.httprequest){ // User Consent Denied
            if ((this.that.httprequest.oldStyle === true) && (this.that.httprequest.consentAutoAccept === true) && (e.toString() != "7")) {
                terminal_promise_consent_resolved.call(this); // oldStyle prompt timed out and User Consent is not required so connect anyway
                return;
            }
        } else { } // Connection was closed server side, maybe log some messages somewhere?
        this.that.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: e.toString(), msgid: 2 }));
        this.that.end();
        
        this.that = null;
        this.httprequest = null;
    } else { } // no websocket, maybe log some messages somewhere?
}
function promise_init(res, rej) { this._res = res; this._rej = rej; }
function terminal_userpromise_resolved(u)
{

    var that = this.that;
    if (u.Active.length > 0)
    {
        var tmp;
        var username = '"' + u.Active[0].Domain + '\\' + u.Active[0].Username + '"';


        if (require('win-virtual-terminal').supported)
        {
            // ConPTY PseudoTerminal
            tmp = require('win-dispatcher').dispatch({ user: username, modules: [{ name: 'win-virtual-terminal', script: getJSModule('win-virtual-terminal') }], launch: { module: 'win-virtual-terminal', method: (that.httprequest.protocol == 9 ? 'StartPowerShell' : 'Start'), args: [this.cols, this.rows] } });
        }
        else
        {
            // Legacy Terminal
            tmp = require('win-dispatcher').dispatch({ user: username, modules: [{ name: 'win-terminal', script: getJSModule('win-terminal') }], launch: { module: 'win-terminal', method: (that.httprequest.protocol == 9 ? 'StartPowerShell' : 'Start'), args: [this.cols, this.rows] } });
        }
        that.httprequest._dispatcher = tmp;
        that.httprequest._dispatcher.connectionPromise = that.httprequest.connectionPromise;
        that.httprequest._dispatcher.on('connection', terminal_user_onconnection);
        that.httprequest._dispatcher.on('~', terminal_onfinalized);
    }
    this.that = null;
    that = null;
}

function terminal_promise_consent_resolved()
{
    this.httprequest.connectionPromise = new promise(promise_init);
    this.httprequest.connectionPromise.ws = this.that;

    // Start Terminal
    if (process.platform == 'win32')
    {
        try
        {
            var cols = 80, rows = 25;
            if (this.httprequest.xoptions)
            {
                if (this.httprequest.xoptions.rows) { rows = this.httprequest.xoptions.rows; }
                if (this.httprequest.xoptions.cols) { cols = this.httprequest.xoptions.cols; }
            }

            if ((this.httprequest.protocol == 1) || (this.httprequest.protocol == 6))
            {
                // Admin Terminal
                if (require('win-virtual-terminal').supported)
                {
                    // ConPTY PseudoTerminal
                    // this.httprequest._term = require('win-virtual-terminal')[this.httprequest.protocol == 6 ? 'StartPowerShell' : 'Start'](80, 25);

                    // The above line is commented out, because there is a bug with ClosePseudoConsole() API, so this is the workaround
                    this.httprequest._dispatcher = require('win-dispatcher').dispatch({ modules: [{ name: 'win-virtual-terminal', script: getJSModule('win-virtual-terminal') }], launch: { module: 'win-virtual-terminal', method: (this.httprequest.protocol == 6 ? 'StartPowerShell' : 'Start'), args: [cols, rows] } });
                    this.httprequest._dispatcher.httprequest = this.httprequest;
                    this.httprequest._dispatcher.on('connection', terminal_onconnection);
                    this.httprequest._dispatcher.on('~', terminal_onfinalized);
                }
                else
                {
                    // Legacy Terminal
                    this.httprequest.connectionPromise._res(require('win-terminal')[this.httprequest.protocol == 6 ? 'StartPowerShell' : 'Start'](cols, rows));
                }
            }
            else
            {
                // Logged in user
                var userPromise = require('user-sessions').enumerateUsers();
                userPromise.that = this;
                userPromise.cols = cols;
                userPromise.rows = rows;
                userPromise.then(terminal_userpromise_resolved);
            }
        } catch (ex)
        {
            this.httprequest.connectionPromise._rej('Failed to start remote terminal session, ' + ex.toString());
        }
    }
    else
    {
        try
        {
            var bash = fs.existsSync('/bin/bash') ? '/bin/bash' : false;
            var sh = fs.existsSync('/bin/sh') ? '/bin/sh' : false;
            var login = process.platform == 'linux' ? '/bin/login' : '/usr/bin/login';

            var env = { HISTCONTROL: 'ignoreboth' };
            if (process.env['LANG']) { env['LANG'] = process.env['LANG']; }
            if (process.env['PATH']) { env['PATH'] = process.env['PATH']; }
            if (this.httprequest.xoptions)
            {
                if (this.httprequest.xoptions.rows) { env.LINES = ('' + this.httprequest.xoptions.rows); }
                if (this.httprequest.xoptions.cols) { env.COLUMNS = ('' + this.httprequest.xoptions.cols); }
            }
            var options = { type: childProcess.SpawnTypes.TERM, uid: (this.httprequest.protocol == 8) ? require('user-sessions').consoleUid() : null, env: env };
            if (this.httprequest.xoptions && this.httprequest.xoptions.requireLogin)
            {
                if (!require('fs').existsSync(login)) { throw ('Unable to spawn login process'); }
                this.httprequest.connectionPromise._res(childProcess.execFile(login, ['login'], options)); // Start login shell
            }
            else if (bash)
            {
                var p = childProcess.execFile(bash, ['bash'], options); // Start bash
                // Spaces at the beginning of lines are needed to hide commands from the command history
                if ((obj.serverInfo.termlaunchcommand != null) && (typeof obj.serverInfo.termlaunchcommand[process.platform] == 'string'))
                {
                    if (obj.serverInfo.termlaunchcommand[process.platform] != '') { p.stdin.write(obj.serverInfo.termlaunchcommand[process.platform]); }
                } else if (process.platform == 'linux') { p.stdin.write(' alias ls=\'ls --color=auto\';clear\n'); }
                this.httprequest.connectionPromise._res(p);
            }
            else if (sh)
            {
                var p = childProcess.execFile(sh, ['sh'], options); // Start sh
                // Spaces at the beginning of lines are needed to hide commands from the command history
                if ((obj.serverInfo.termlaunchcommand != null) && (typeof obj.serverInfo.termlaunchcommand[process.platform] == 'string'))
                {
                    if (obj.serverInfo.termlaunchcommand[process.platform] != '') { p.stdin.write(obj.serverInfo.termlaunchcommand[process.platform]); }
                } else if (process.platform == 'linux') { p.stdin.write(' alias ls=\'ls --color=auto\';clear\n'); }
                this.httprequest.connectionPromise._res(p);
            }
            else
            {
                this.httprequest.connectionPromise._rej('Failed to start remote terminal session, no shell found');
            }
        } catch (ex)
        {
            this.httprequest.connectionPromise._rej('Failed to start remote terminal session, ' + ex.toString());
        }
    }

    this.httprequest.connectionPromise.then(terminal_promise_connection_resolved, terminal_promise_connection_rejected);
    this.that = null;
    this.httprequest = null;
}
function tunnel_kvm_end()
{
    --this.desktop.kvm.connectionCount;

    // Remove ourself from the list of remote desktop session
    var i = this.desktop.kvm.tunnels.indexOf(this);
    if (i >= 0) { this.desktop.kvm.tunnels.splice(i, 1); }

    // Send a metadata update to all desktop sessions
    var users = {};
    if (this.httprequest.desktop.kvm.tunnels != null)
    {
        for (var i in this.httprequest.desktop.kvm.tunnels)
        {
            try
            {
                var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest.desktop.kvm.tunnels[i].httprequest);
                if (users[userid] == null) { users[userid] = 1; } else { users[userid]++; }
            } catch (ex) { sendConsoleText(ex); }
        }
        for (var i in this.httprequest.desktop.kvm.tunnels)
        {
            try { this.httprequest.desktop.kvm.tunnels[i].write(JSON.stringify({ ctrlChannel: '102938', type: 'metadata', users: users })); } catch (ex) { }
        }
        tunnelUserCount.desktop = users;
        try { mesh.SendCommand({ action: 'sessions', type: 'kvm', value: users }); } catch (ex) { }
        broadcastSessionsToRegisteredApps();
    }

    // Unpipe the web socket
    try
    {
        this.unpipe(this.httprequest.desktop.kvm);
        this.httprequest.desktop.kvm.unpipe(this);
    } catch (ex) { }

    // Unpipe the WebRTC channel if needed (This will also be done when the WebRTC channel ends).
    if (this.rtcchannel)
    {
        try
        {
            this.rtcchannel.unpipe(this.httprequest.desktop.kvm);
            this.httprequest.desktop.kvm.unpipe(this.rtcchannel);
        }
        catch (ex) { }
    }

    // Place wallpaper back if needed
    // TODO

    if (this.desktop.kvm.connectionCount == 0)
    {
        // Display a toast message. This may not be supported on all platforms.
        // try { require('toaster').Toast('MeshCentral', 'Remote Desktop Control Ended.'); } catch (ex) { }

        this.httprequest.desktop.kvm.end();
        if (this.httprequest.desktop.kvm.connectionBar)
        {
            this.httprequest.desktop.kvm.connectionBar.removeAllListeners('close');
            this.httprequest.desktop.kvm.connectionBar.close();
            this.httprequest.desktop.kvm.connectionBar = null;
        }
    } else
    {
        for (var i in this.httprequest.desktop.kvm.users)
        {
            if ((this.httprequest.desktop.kvm.users[i] == this.httprequest.username) && this.httprequest.desktop.kvm.connectionBar)
            {
                for (var j in this.httprequest.desktop.kvm.rusers) { if (this.httprequest.desktop.kvm.rusers[j] == this.httprequest.realname) { this.httprequest.desktop.kvm.rusers.splice(j, 1); break; } }
                this.httprequest.desktop.kvm.users.splice(i, 1);
                this.httprequest.desktop.kvm.connectionBar.removeAllListeners('close');
                this.httprequest.desktop.kvm.connectionBar.close();
                this.httprequest.desktop.kvm.connectionBar = require('notifybar-desktop')(this.httprequest.privacybartext.replace(/\{0\}/g, this.httprequest.desktop.kvm.rusers.join(', ')).replace(/\{1\}/g, this.httprequest.desktop.kvm.users.join(', ')).replace(/'/g, "\\'\\"), require('MeshAgent')._tsid, color_options);
                this.httprequest.desktop.kvm.connectionBar.httprequest = this.httprequest;
                this.httprequest.desktop.kvm.connectionBar.on('close', function ()
                {
                    MeshServerLogEx(29, null, "Remote Desktop Connection forcefully closed by local user (" + this.httprequest.remoteaddr + ")", this.httprequest);
                    for (var i in this.httprequest.desktop.kvm._pipedStreams)
                    {
                        this.httprequest.desktop.kvm._pipedStreams[i].end();
                    }
                    this.httprequest.desktop.kvm.end();
                });
                break;
            }
        }
    }

    if(this.httprequest.desktop.kvm.connectionBar)
    {
        console.info1('Setting ConnectionBar request to NULL');
        this.httprequest.desktop.kvm.connectionBar.httprequest = null;
    }

    this.httprequest = null;
    this.desktop.tunnel = null;
}

function kvm_tunnel_consentpromise_closehandler()
{
    if (this._consentpromise && this._consentpromise.close) { this._consentpromise.close(); }
}

function kvm_consent_ok(ws) {
    // User Consent Prompt is not required because no user is present
    if (ws.httprequest.consent && (ws.httprequest.consent & 1)){
        // User Notifications is required
        MeshServerLogEx(35, null, "Started remote desktop with toast notification (" + ws.httprequest.remoteaddr + ")", ws.httprequest);
        var notifyMessage = currentTranslation['desktopNotify'].replace(/\{0\}/g, ws.httprequest.realname);
        var notifyTitle = "MeshCentral";
        if (ws.httprequest.soptions != null) {
            if (ws.httprequest.soptions.notifyTitle != null) { notifyTitle = ws.httprequest.soptions.notifyTitle; }
            if (ws.httprequest.soptions.notifyMsgDesktop != null) { notifyMessage = ws.httprequest.soptions.notifyMsgDesktop.replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username); }
        }
        try { require('toaster').Toast(notifyTitle, notifyMessage, ws.tsid); } catch (ex) { }
    } else {
        MeshServerLogEx(36, null, "Started remote desktop without notification (" + ws.httprequest.remoteaddr + ")", ws.httprequest);
    }
    if (ws.httprequest.consent && (ws.httprequest.consent & 0x40)) {
        // Connection Bar is required
        if (ws.httprequest.desktop.kvm.connectionBar) {
            ws.httprequest.desktop.kvm.connectionBar.removeAllListeners('close');
            ws.httprequest.desktop.kvm.connectionBar.close();
        }
        try {
            ws.httprequest.desktop.kvm.connectionBar = require('notifybar-desktop')(ws.httprequest.privacybartext.replace(/\{0\}/g, ws.httprequest.desktop.kvm.rusers.join(', ')).replace(/\{1\}/g, ws.httprequest.desktop.kvm.users.join(', ')).replace(/'/g, "\\'\\"), require('MeshAgent')._tsid, color_options);
            MeshServerLogEx(31, null, "Remote Desktop Connection Bar Activated/Updated (" + ws.httprequest.remoteaddr + ")", ws.httprequest);
        } catch (ex) {
            MeshServerLogEx(32, null, "Remote Desktop Connection Bar Failed or not Supported (" + ws.httprequest.remoteaddr + ")", ws.httprequest);
        }
        if (ws.httprequest.desktop.kvm.connectionBar) {
            ws.httprequest.desktop.kvm.connectionBar.state = {
                userid: ws.httprequest.userid,
                xuserid: ws.httprequest.xuserid,
                username: ws.httprequest.username,
                sessionid: ws.httprequest.sessionid,
                remoteaddr: ws.httprequest.remoteaddr,
                guestname: ws.httprequest.guestname,
                desktop: ws.httprequest.desktop
            };
            ws.httprequest.desktop.kvm.connectionBar.on('close', function () {
                console.info1('Connection Bar Forcefully closed');
                MeshServerLogEx(29, null, "Remote Desktop Connection forcefully closed by local user (" + this.state.remoteaddr + ")", this.state);
                for (var i in this.state.desktop.kvm._pipedStreams) {
                    this.state.desktop.kvm._pipedStreams[i].end();
                }
                this.state.desktop.kvm.end();
            });
        }
    }
    ws.httprequest.desktop.kvm.pipe(ws, { dataTypeSkip: 1 });
    if (ws.httprequest.autolock) {
        destopLockHelper_pipe(ws.httprequest);
    }
}

function kvm_consent_ask(ws){
    // Send a console message back using the console channel, "\n" is supported.
    ws.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: "Waiting for user to grant access...", msgid: 1 }));
    var consentMessage = currentTranslation['desktopConsent'].replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username);
    var consentTitle = 'MeshCentral';
    if (ws.httprequest.soptions != null) {
        if (ws.httprequest.soptions.consentTitle != null) { consentTitle = ws.httprequest.soptions.consentTitle; }
        if (ws.httprequest.soptions.consentMsgDesktop != null) { consentMessage = ws.httprequest.soptions.consentMsgDesktop.replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username); }
    }
    var pr;
    if (process.platform == 'win32') {
        var enhanced = false;
        if (ws.httprequest.oldStyle === false) {
            try { require('win-userconsent'); enhanced = true; } catch (ex) { }
        }
        if (enhanced) {
            var ipr = server_getUserImage(ws.httprequest.userid);
            ipr.consentTitle = consentTitle;
            ipr.consentMessage = consentMessage;
            ipr.consentTimeout = ws.httprequest.consentTimeout;
            ipr.consentAutoAccept = ws.httprequest.consentAutoAccept;
            ipr.tsid = ws.tsid;
            ipr.username = ws.httprequest.realname;
            ipr.translation = { Allow: currentTranslation['allow'], Deny: currentTranslation['deny'], Auto: currentTranslation['autoAllowForFive'], Caption: consentMessage };
            pr = ipr.then(function (img) {
                this.consent = require('win-userconsent').create(this.consentTitle, this.consentMessage, this.username, { b64Image: img.split(',').pop(), uid: this.tsid, timeout: this.consentTimeout * 1000, timeoutAutoAccept: this.consentAutoAccept, translations: this.translation, background: color_options.background, foreground: color_options.foreground });
                this.__childPromise.close = this.consent.close.bind(this.consent);
                return (this.consent);
            });
        } else {
            pr = require('message-box').create(consentTitle, consentMessage, ws.httprequest.consentTimeout, null, ws.tsid);
        }
    } else {
        pr = require('message-box').create(consentTitle, consentMessage, ws.httprequest.consentTimeout, null, ws.tsid);
    }
    pr.ws = ws;
    ws.pause();
    ws._consentpromise = pr;
    ws.prependOnceListener('end', kvm_tunnel_consentpromise_closehandler);
    pr.then(kvm_consentpromise_resolved, kvm_consentpromise_rejected);
}

function kvm_consentpromise_rejected(e)
{
    if (this.ws) {
        if(this.ws.httprequest){ // User Consent Denied
            if ((this.ws.httprequest.oldStyle === true) && (this.ws.httprequest.consentAutoAccept === true) && (e.toString() != "7")) {
                kvm_consentpromise_resolved.call(this); // oldStyle prompt timed out and User Consent is not required so connect anyway
                return;
            }
            MeshServerLogEx(34, null, "Failed to start remote desktop after local user rejected (" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
        } else { } // Connection was closed server side, maybe log some messages somewhere?
        this.ws._consentpromise = null;
        this.ws.end(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: e.toString(), msgid: 2 }));
        this.ws = null;
    } else { } // no websocket, maybe log some messages somewhere?
}
function kvm_consentpromise_resolved(always)
{
    if (always && process.platform=='win32') { server_set_consentTimer(this.ws.httprequest.userid); }

    // Success
    this.ws._consentpromise = null;
    MeshServerLogEx(30, null, "Starting remote desktop after local user accepted (" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
    this.ws.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: null, msgid: 0 }));
    if (this.ws.httprequest.consent && (this.ws.httprequest.consent & 1))
    {
        // User Notifications is required
        var notifyMessage = currentTranslation['desktopNotify'].replace(/\{0\}/g, this.ws.httprequest.realname);
        var notifyTitle = "MeshCentral";
        if (this.ws.httprequest.soptions != null)
        {
            if (this.ws.httprequest.soptions.notifyTitle != null) { notifyTitle = this.ws.httprequest.soptions.notifyTitle; }
            if (this.ws.httprequest.soptions.notifyMsgDesktop != null) { notifyMessage = this.ws.httprequest.soptions.notifyMsgDesktop.replace(/\{0\}/g, this.ws.httprequest.realname).replace(/\{1\}/g, this.ws.httprequest.username); }
        }
        try { require('toaster').Toast(notifyTitle, notifyMessage, tsid); } catch (ex) { }
    }
    if (this.ws.httprequest.consent && (this.ws.httprequest.consent & 0x40))
    {
        // Connection Bar is required
        if (this.ws.httprequest.desktop.kvm.connectionBar)
        {
            this.ws.httprequest.desktop.kvm.connectionBar.removeAllListeners('close');
            this.ws.httprequest.desktop.kvm.connectionBar.close();
        }
        try
        {
            this.ws.httprequest.desktop.kvm.connectionBar = require('notifybar-desktop')(this.ws.httprequest.privacybartext.replace(/\{0\}/g, this.ws.httprequest.desktop.kvm.rusers.join(', ')).replace(/\{1\}/g, this.ws.httprequest.desktop.kvm.users.join(', ')).replace(/'/g, "\\'\\"), require('MeshAgent')._tsid, color_options);
            MeshServerLogEx(31, null, "Remote Desktop Connection Bar Activated/Updated (" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
        } catch (ex)
        {
            if (process.platform != 'darwin')
            {
                MeshServerLogEx(32, null, "Remote Desktop Connection Bar Failed or Not Supported (" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
            }
        }
        try {
			if (this.ws.httprequest.desktop.kvm.connectionBar) {
				this.ws.httprequest.desktop.kvm.connectionBar.httprequest = this.ws.httprequest;
				this.ws.httprequest.desktop.kvm.connectionBar.on('close', function () {
					MeshServerLogEx(29, null, "Remote Desktop Connection forcefully closed by local user (" + this.httprequest.remoteaddr + ")", this.httprequest);
					for (var i in this.httprequest.desktop.kvm._pipedStreams) {
						this.httprequest.desktop.kvm._pipedStreams[i].end();
					}
					this.httprequest.desktop.kvm.end();
				});
			}
		}
		catch (ex)
        {
            if (process.platform != 'darwin')
            {
                MeshServerLogEx(32, null, "Failed2(" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
            }
        }
    }
    this.ws.httprequest.desktop.kvm.pipe(this.ws, { dataTypeSkip: 1 });
    if (this.ws.httprequest.autolock)
    {
        destopLockHelper_pipe(this.ws.httprequest);
    }
    this.ws.resume();
    this.ws = null;
}

function files_consent_ok(ws){
    // User Consent Prompt is not required
    if (ws.httprequest.consent && (ws.httprequest.consent & 4)) {
        // User Notifications is required
        MeshServerLogEx(42, null, "Started remote files with toast notification (" + ws.httprequest.remoteaddr + ")", ws.httprequest);
        var notifyMessage = currentTranslation['fileNotify'].replace(/\{0\}/g, ws.httprequest.realname);
        var notifyTitle = "MeshCentral";
        if (ws.httprequest.soptions != null) {
            if (ws.httprequest.soptions.notifyTitle != null) { notifyTitle = ws.httprequest.soptions.notifyTitle; }
            if (ws.httprequest.soptions.notifyMsgFiles != null) { notifyMessage = ws.httprequest.soptions.notifyMsgFiles.replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username); }
        }
        try { require('toaster').Toast(notifyTitle, notifyMessage); } catch (ex) { }
    } else {
        MeshServerLogEx(43, null, "Started remote files without notification (" + ws.httprequest.remoteaddr + ")", ws.httprequest);
    }
    ws.resume();
}

function files_consent_ask(ws){
    // Send a console message back using the console channel, "\n" is supported.
    ws.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: "Waiting for user to grant access...", msgid: 1 }));
    var consentMessage = currentTranslation['fileConsent'].replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username);
    var consentTitle = 'MeshCentral';

    if (ws.httprequest.soptions != null) {
        if (ws.httprequest.soptions.consentTitle != null) { consentTitle = ws.httprequest.soptions.consentTitle; }
        if (ws.httprequest.soptions.consentMsgFiles != null) { consentMessage = ws.httprequest.soptions.consentMsgFiles.replace(/\{0\}/g, ws.httprequest.realname).replace(/\{1\}/g, ws.httprequest.username); }
    }
    var pr;
    if (process.platform == 'win32') {
        var enhanced = false;
        if (ws.httprequest.oldStyle === false) {
            try { require('win-userconsent'); enhanced = true; } catch (ex) { }
        }
        if (enhanced) {
            var ipr = server_getUserImage(ws.httprequest.userid);
            ipr.consentTitle = consentTitle;
            ipr.consentMessage = consentMessage;
            ipr.consentTimeout = ws.httprequest.consentTimeout;
            ipr.consentAutoAccept = ws.httprequest.consentAutoAccept;
            ipr.username = ws.httprequest.realname;
            ipr.tsid = ws.tsid;
            ipr.translations = { Allow: currentTranslation['allow'], Deny: currentTranslation['deny'], Auto: currentTranslation['autoAllowForFive'], Caption: consentMessage };
            pr = ipr.then(function (img) {
                this.consent = require('win-userconsent').create(this.consentTitle, this.consentMessage, this.username, { b64Image: img.split(',').pop(), uid: this.tsid, timeout: this.consentTimeout * 1000, timeoutAutoAccept: this.consentAutoAccept, translations: this.translations, background: color_options.background, foreground: color_options.foreground });
                this.__childPromise.close = this.consent.close.bind(this.consent);
                return (this.consent);
            });
        } else {
            pr = require('message-box').create(consentTitle, consentMessage, ws.httprequest.consentTimeout, null);
        }
    } else {
        pr = require('message-box').create(consentTitle, consentMessage, ws.httprequest.consentTimeout, null);
    }
    pr.ws = ws;
    ws.pause();
    ws._consentpromise = pr;
    ws.prependOnceListener('end', files_tunnel_endhandler);
    pr.then(files_consentpromise_resolved, files_consentpromise_rejected);
}

function files_consentpromise_resolved(always)
{
    if (always && process.platform == 'win32') { server_set_consentTimer(this.ws.httprequest.userid); }

    // Success
    this.ws._consentpromise = null;
    MeshServerLogEx(40, null, "Starting remote files after local user accepted (" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
    this.ws.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: null }));
    if (this.ws.httprequest.consent && (this.ws.httprequest.consent & 4))
    {
        // User Notifications is required
        var notifyMessage = currentTranslation['fileNotify'].replace(/\{0\}/g, this.ws.httprequest.realname);
        var notifyTitle = "MeshCentral";
        if (this.ws.httprequest.soptions != null)
        {
            if (this.ws.httprequest.soptions.notifyTitle != null) { notifyTitle = this.ws.httprequest.soptions.notifyTitle; }
            if (this.ws.httprequest.soptions.notifyMsgFiles != null) { notifyMessage = this.ws.httprequest.soptions.notifyMsgFiles.replace(/\{0\}/g, this.ws.httprequest.realname).replace(/\{1\}/g, this.ws.httprequest.username); }
        }
        try { require('toaster').Toast(notifyTitle, notifyMessage); } catch (ex) { }
    }
    this.ws.resume();
    this.ws = null;
}
function files_consentpromise_rejected(e)
{
    if (this.ws) {
        if(this.ws.httprequest){ // User Consent Denied
            if ((this.ws.httprequest.oldStyle === true) && (this.ws.httprequest.consentAutoAccept === true) && (e.toString() != "7")) {
                files_consentpromise_resolved.call(this); // oldStyle prompt timed out and User Consent is not required so connect anyway
                return;
            }
            MeshServerLogEx(41, null, "Failed to start remote files after local user rejected (" + this.ws.httprequest.remoteaddr + ")", this.ws.httprequest);
        } else { } // Connection was closed server side, maybe log some messages somewhere?
        this.ws._consentpromise = null;
        this.ws.end(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: e.toString(), msgid: 2 }));
        this.ws = null;
    } else { } // no websocket, maybe log some messages somewhere?
}
function files_tunnel_endhandler()
{
    if (this._consentpromise && this._consentpromise.close) { this._consentpromise.close(); }
}

function onTunnelData(data)
{
    //sendConsoleText('OnTunnelData, ' + data.length + ', ' + typeof data + ', ' + data);

    // If this is upload data, save it to file
    if ((this.httprequest.uploadFile) && (typeof data == 'object') && (data[0] != 123)) {
        // Save the data to file being uploaded.
        if (data[0] == 0) {
            // If data starts with zero, skip the first byte. This is used to escape binary file data from JSON.
            this.httprequest.uploadFileSize += (data.length - 1);
            try { fs.writeSync(this.httprequest.uploadFile, data, 1, data.length - 1); } catch (ex) { sendConsoleText('FileUpload Error'); this.write(Buffer.from(JSON.stringify({ action: 'uploaderror' }))); return; } // Write to the file, if there is a problem, error out.
        } else {
            // If data does not start with zero, save as-is.
            this.httprequest.uploadFileSize += data.length;
            try { fs.writeSync(this.httprequest.uploadFile, data); } catch (ex) { sendConsoleText('FileUpload Error'); this.write(Buffer.from(JSON.stringify({ action: 'uploaderror' }))); return; } // Write to the file, if there is a problem, error out.
        }
        this.write(Buffer.from(JSON.stringify({ action: 'uploadack', reqid: this.httprequest.uploadFileid }))); // Ask for more data.
        return;
    }

    if (this.httprequest.state == 0) {
        // Check if this is a relay connection
        if ((data == 'c') || (data == 'cr')) {
            this.httprequest.state = 1;
            //sendConsoleText("Tunnel #" + this.httprequest.index + " now active", this.httprequest.sessionid);
        }
    }
    else {
        // Handle tunnel data
        if (this.httprequest.protocol == 0) { // 1 = Terminal (admin), 2 = Desktop, 5 = Files, 6 = PowerShell (admin), 7 = Plugin Data Exchange, 8 = Terminal (user), 9 = PowerShell (user), 10 = FileTransfer
            // Take a look at the protocol
            if ((data.length > 3) && (data[0] == '{')) { onTunnelControlData(data, this); return; }
            this.httprequest.protocol = parseInt(data);
            if (typeof this.httprequest.protocol != 'number') { this.httprequest.protocol = 0; }

            // See if this protocol request is allowed.
            if ((this.httprequest.soptions != null) && (this.httprequest.soptions.usages != null) && (this.httprequest.soptions.usages.indexOf(this.httprequest.protocol) == -1)) { this.httprequest.protocol = 0; }

            if (this.httprequest.protocol == 10) {
                //
                // Basic file transfer
                //
                var stats = null;
                if ((process.platform != 'win32') && (this.httprequest.xoptions.file.startsWith('/') == false)) { this.httprequest.xoptions.file = '/' + this.httprequest.xoptions.file; }
                try { stats = require('fs').statSync(this.httprequest.xoptions.file) } catch (ex) { }
                try { if (stats) { this.httprequest.downloadFile = fs.createReadStream(this.httprequest.xoptions.file, { flags: 'rbN' }); } } catch (ex) { }
                if (this.httprequest.downloadFile) {
                    MeshServerLogEx(106, [this.httprequest.xoptions.file, stats.size], 'Download: \"' + this.httprequest.xoptions.file + '\", Size: ' + stats.size, this.httprequest);
                    //sendConsoleText('BasicFileTransfer, ok, ' + this.httprequest.xoptions.file + ', ' + JSON.stringify(stats));
                    this.write(JSON.stringify({ op: 'ok', size: stats.size }));
                    this.httprequest.downloadFile.pipe(this);
                    this.httprequest.downloadFile.end = function () { }
                } else {
                    //sendConsoleText('BasicFileTransfer, cancel, ' + this.httprequest.xoptions.file);
                    this.write(JSON.stringify({ op: 'cancel' }));
                }
            }
            else if ((this.httprequest.protocol == 1) || (this.httprequest.protocol == 6) || (this.httprequest.protocol == 8) || (this.httprequest.protocol == 9)) {
                //
                // Remote Terminal
                //

                // Check user access rights for terminal
                if (((this.httprequest.rights & MESHRIGHT_REMOTECONTROL) == 0) || ((this.httprequest.rights != 0xFFFFFFFF) && ((this.httprequest.rights & MESHRIGHT_NOTERMINAL) != 0)))
                {
                    // Disengage this tunnel, user does not have the rights to do this!!
                    this.httprequest.protocol = 999999;
                    this.httprequest.s.end();
                    sendConsoleText("Error: No Terminal Control Rights.");
                    return;
                }

                this.descriptorMetadata = "Remote Terminal";

                // Look for a TSID
                var tsid = null;
                if ((this.httprequest.xoptions != null) && (typeof this.httprequest.xoptions.tsid == 'number')) { tsid = this.httprequest.xoptions.tsid; }
                require('MeshAgent')._tsid = tsid;
                this.tsid = tsid;

                if (process.platform == 'win32')
                {
                    if (!require('win-terminal').PowerShellCapable() && (this.httprequest.protocol == 6 || this.httprequest.protocol == 9)) {
                        this.httprequest.write(JSON.stringify({ ctrlChannel: '102938', type: 'console', msg: 'PowerShell is not supported on this version of windows', msgid: 1 }));
                        this.httprequest.s.end();
                        return;
                    }
                }

                var prom = require('promise');
                this.httprequest.tpromise = new prom(promise_init);
                this.httprequest.tpromise.that = this;
                this.httprequest.tpromise.httprequest = this.httprequest;
                this.end = terminal_end;

                // Perform User-Consent if needed. 
                if (this.httprequest.consent && (this.httprequest.consent & 16)) {
                    // User asked for consent so now we check if we can auto accept if no user is present/loggedin
                    if (this.httprequest.consentAutoAcceptIfNoUser || this.httprequest.consentAutoAcceptIfTerminalNoUser || this.httprequest.consentAutoAcceptIfLocked || this.httprequest.consentAutoAcceptIfTerminalLocked) {
                        var p = require('user-sessions').enumerateUsers();
                        p.sessionid = this.httprequest.sessionid;
                        p.ws = this;
                        p.then(function (u) {
                            var v = [];
                            for (var i in u) {
                                if (u[i].State == 'Active') { v.push({ tsid: i, type: u[i].StationName, user: u[i].Username, domain: u[i].Domain }); }
                            }
                            var autoAccept = false;
                            
                            // Check if we should auto-accept because no user is present
                            if ((this.ws.httprequest.consentAutoAcceptIfNoUser || this.ws.httprequest.consentAutoAcceptIfTerminalNoUser) && (v.length == 0)) {
                                autoAccept = true;
                            }
                            
                            // Check if we should auto-accept because all users are locked
                            if ((this.ws.httprequest.consentAutoAcceptIfLocked || this.ws.httprequest.consentAutoAcceptIfTerminalLocked) && (v.length > 0)) {
                                var allUsersLocked = true;
                                if (!meshCoreObj.lusers || meshCoreObj.lusers.length == 0) {
                                    // No locked users list available, assume users are not locked
                                    allUsersLocked = false;
                                } else {
                                    for (var i in v) {
                                        var username = v[i].domain ? (v[i].domain + '\\' + v[i].user) : v[i].user;
                                        if (meshCoreObj.lusers.indexOf(username) == -1) {
                                            allUsersLocked = false;
                                            break;
                                        }
                                    }
                                }
                                if (allUsersLocked) { autoAccept = true; }
                            }
                            
                            if (autoAccept) {
                                this.ws.httprequest.tpromise._res();
                            } else { 
                                // User is present and not all locked, so we still need consent
                                terminal_consent_ask(this.ws);
                            }
                        });
                    } else {
                        terminal_consent_ask(this);
                    }
                } else {
                    // User-Consent is not required, so just resolve this promise
                    this.httprequest.tpromise._res();
                }
                this.httprequest.tpromise.then(terminal_promise_consent_resolved, terminal_promise_consent_rejected);
            }
            else if (this.httprequest.protocol == 2)
            {
                //
                // Remote Desktop
                //

                // Check user access rights for desktop
                if ((((this.httprequest.rights & MESHRIGHT_REMOTECONTROL) == 0) && ((this.httprequest.rights & MESHRIGHT_REMOTEVIEW) == 0)) || ((this.httprequest.rights != 0xFFFFFFFF) && ((this.httprequest.rights & MESHRIGHT_NODESKTOP) != 0))) {
                    // Disengage this tunnel, user does not have the rights to do this!!
                    this.httprequest.protocol = 999999;
                    this.httprequest.s.end();
                    sendConsoleText("Error: No Desktop Control Rights.");
                    return;
                }

                this.descriptorMetadata = "Remote KVM";

                // Look for a TSID
                var tsid = null;
                if ((this.httprequest.xoptions != null) && (typeof this.httprequest.xoptions.tsid == 'number')) { tsid = this.httprequest.xoptions.tsid; }
                require('MeshAgent')._tsid = tsid;
                this.tsid = tsid;

                // If MacOS, Wake up device with caffeinate
                if(process.platform == 'darwin'){
                    try {
                        var options = {};
                        try { options.uid = require('user-sessions').consoleUid(); } catch (ex) { }
                        options.type = require('child_process').SpawnTypes.TERM;
                        var replydata = "";
                        var cmdchild = require('child_process').execFile('/usr/bin/caffeinate', ['caffeinate', '-u', '-t', '10'], options);
                        cmdchild.descriptorMetadata = 'UserCommandsShell';
                        cmdchild.stdout.on('data', function (c) { replydata += c.toString(); });
                        cmdchild.stderr.on('data', function (c) { replydata + c.toString(); });
                        cmdchild.on('exit', function () { delete cmdchild; });
                    } catch(err) { }
                }
                // Remote desktop using native pipes
                this.httprequest.desktop = { state: 0, kvm: mesh.getRemoteDesktopStream(tsid), tunnel: this };
                this.httprequest.desktop.kvm.parent = this.httprequest.desktop;
                this.desktop = this.httprequest.desktop;

                // Add ourself to the list of remote desktop sessions
                if (this.httprequest.desktop.kvm.tunnels == null) { this.httprequest.desktop.kvm.tunnels = []; }
                this.httprequest.desktop.kvm.tunnels.push(this);

                // Send a metadata update to all desktop sessions
                var users = {};
                if (this.httprequest.desktop.kvm.tunnels != null)
                {
                    for (var i in this.httprequest.desktop.kvm.tunnels)
                    {
                        try {
                            var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest.desktop.kvm.tunnels[i].httprequest);
                            if (users[userid] == null) { users[userid] = 1; } else { users[userid]++; }
                        } catch (ex) { sendConsoleText(ex); }
                    }
                    for (var i in this.httprequest.desktop.kvm.tunnels)
                    {
                        try { this.httprequest.desktop.kvm.tunnels[i].write(JSON.stringify({ ctrlChannel: '102938', type: 'metadata', users: users })); } catch (ex) { }
                    }
                    tunnelUserCount.desktop = users;
                    try { mesh.SendCommand({ action: 'sessions', type: 'kvm', value: users }); } catch (ex) { }
                    broadcastSessionsToRegisteredApps();
                }

                this.end = tunnel_kvm_end;

                if (this.httprequest.desktop.kvm.hasOwnProperty('connectionCount')) {
                    this.httprequest.desktop.kvm.connectionCount++;
                    this.httprequest.desktop.kvm.rusers.push(this.httprequest.realname);
                    this.httprequest.desktop.kvm.users.push(this.httprequest.username);
                    this.httprequest.desktop.kvm.rusers.sort();
                    this.httprequest.desktop.kvm.users.sort();
                } else {
                    this.httprequest.desktop.kvm.connectionCount = 1;
                    this.httprequest.desktop.kvm.rusers = [this.httprequest.realname];
                    this.httprequest.desktop.kvm.users = [this.httprequest.username];
                }

                if ((this.httprequest.desktopviewonly != true) && ((this.httprequest.rights == 0xFFFFFFFF) || (((this.httprequest.rights & MESHRIGHT_REMOTECONTROL) != 0) && ((this.httprequest.rights & MESHRIGHT_REMOTEVIEW) == 0))))
                {
                    // If we have remote control rights, pipe the KVM input
                    this.pipe(this.httprequest.desktop.kvm, { dataTypeSkip: 1, end: false }); // 0 = Binary, 1 = Text. Pipe the Browser --> KVM input.
                }
                else
                {
                    // We need to only pipe non-mouse & non-keyboard inputs.
                    // sendConsoleText('Warning: No Remote Desktop Input Rights.');
                    // TODO!!!
                }

                // Perform notification if needed. Toast messages may not be supported on all platforms.
                if (this.httprequest.consent && (this.httprequest.consent & 8)) {

                    // User asked for consent but now we check if can auto accept if no user is present
                    if (this.httprequest.consentAutoAcceptIfNoUser || this.httprequest.consentAutoAcceptIfDesktopNoUser || this.httprequest.consentAutoAcceptIfLocked || this.httprequest.consentAutoAcceptIfDesktopLocked) {
                        // Get list of users to check if we any actual users logged in, and if users logged in, we still need consent
                        var p = require('user-sessions').enumerateUsers();
                        p.sessionid = this.httprequest.sessionid;
                        p.ws = this;
                        p.then(function (u) {
                            var v = [];
                            for (var i in u) {
                                if (u[i].State == 'Active') { v.push({ tsid: i, type: u[i].StationName, user: u[i].Username, domain: u[i].Domain }); }
                            }
                            var autoAccept = false;
                            
                            // Check if we can auto-accept because no user is present
                            if ((this.ws.httprequest.consentAutoAcceptIfNoUser || this.ws.httprequest.consentAutoAcceptIfDesktopNoUser) && (v.length == 0)) {
                                // No user is present, auto accept
                                autoAccept = true;
                            }
                            
                            // Check if we can auto-accept because all users are locked
                            if ((this.ws.httprequest.consentAutoAcceptIfLocked || this.ws.httprequest.consentAutoAcceptIfDesktopLocked) && (v.length > 0)) {
                                var allUsersLocked = true;
                                if (!meshCoreObj.lusers || meshCoreObj.lusers.length == 0) {
                                    // No locked users list available, assume users are not locked
                                    allUsersLocked = false;
                                } else {
                                    for (var i in v) {
                                        var username = v[i].domain ? (v[i].domain + '\\' + v[i].user) : v[i].user;
                                        if (meshCoreObj.lusers.indexOf(username) == -1) {
                                            allUsersLocked = false;
                                            break;
                                        }
                                    }
                                }
                                if (allUsersLocked) { autoAccept = true; }
                            }
                            
                            if (autoAccept) {
                                kvm_consent_ok(this.ws);
                            } else { 
                                // User is present and not all locked, so we still need consent
                                kvm_consent_ask(this.ws);
                            }
                        });
                    } else {
                        // User Consent Prompt is required
                        kvm_consent_ask(this);
                    }
                } else {
                    // User Consent Prompt is not required
                    kvm_consent_ok(this);
                }

                this.removeAllListeners('data');
                this.on('data', onTunnelControlData);
                //this.write('MeshCore KVM Hello!1');
            } else if (this.httprequest.protocol == 5) {
                //
                // Remote Files
                //

                // Check user access rights for files
                if (((this.httprequest.rights & MESHRIGHT_REMOTECONTROL) == 0) || ((this.httprequest.rights != 0xFFFFFFFF) && ((this.httprequest.rights & MESHRIGHT_NOFILES) != 0))) {
                    // Disengage this tunnel, user does not have the rights to do this!!
                    this.httprequest.protocol = 999999;
                    this.httprequest.s.end();
                    sendConsoleText("Error: No files control rights.");
                    return;
                }

                this.descriptorMetadata = "Remote Files";

                // Look for a TSID
                var tsid = null;
                if ((this.httprequest.xoptions != null) && (typeof this.httprequest.xoptions.tsid == 'number')) { tsid = this.httprequest.xoptions.tsid; }
                require('MeshAgent')._tsid = tsid;
                this.tsid = tsid;

                // Add the files session to the count to update the server
                if (this.httprequest.userid != null) {
                    var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest);
                    if (tunnelUserCount.files[userid] == null) { tunnelUserCount.files[userid] = 1; } else { tunnelUserCount.files[userid]++; }
                    try { mesh.SendCommand({ action: 'sessions', type: 'files', value: tunnelUserCount.files }); } catch (ex) { }
                    broadcastSessionsToRegisteredApps();
                }

                this.end = function ()
                {
                    // Remove the files session from the count to update the server
                    if (this.httprequest.userid != null) {
                        var userid = getUserIdAndGuestNameFromHttpRequest(this.httprequest);
                        if (tunnelUserCount.files[userid] != null) { tunnelUserCount.files[userid]--; if (tunnelUserCount.files[userid] <= 0) { delete tunnelUserCount.files[userid]; } }
                        try { mesh.SendCommand({ action: 'sessions', type: 'files', value: tunnelUserCount.files }); } catch (ex) { }
                        broadcastSessionsToRegisteredApps();
                    }
                };

                // Perform notification if needed. Toast messages may not be supported on all platforms.
                if (this.httprequest.consent && (this.httprequest.consent & 32)) {
                    // User asked for consent so now we check if we can auto accept if no user is present/loggedin
                    if (this.httprequest.consentAutoAcceptIfNoUser || this.httprequest.consentAutoAcceptIfFileNoUser || this.httprequest.consentAutoAcceptIfLocked || this.httprequest.consentAutoAcceptIfFileLocked) {
                            var p = require('user-sessions').enumerateUsers();
                            p.sessionid = this.httprequest.sessionid;
                            p.ws = this;
                            p.then(function (u) {
                                var v = [];
                                for (var i in u) {
                                    if (u[i].State == 'Active') { v.push({ tsid: i, type: u[i].StationName, user: u[i].Username, domain: u[i].Domain }); }
                                }
                                var autoAccept = false;
                                
                                // Check if we should auto-accept because no user is present
                                if ((this.ws.httprequest.consentAutoAcceptIfNoUser || this.ws.httprequest.consentAutoAcceptIfFileNoUser) && (v.length == 0)) {
                                    autoAccept = true;
                                }
                                
                                // Check if we should auto-accept because all users are locked
                                if ((this.ws.httprequest.consentAutoAcceptIfLocked || this.ws.httprequest.consentAutoAcceptIfFileLocked) && (v.length > 0)) {
                                    var allUsersLocked = true;
                                    if (!meshCoreObj.lusers || meshCoreObj.lusers.length == 0) {
                                        // No locked users list available, assume users are not locked
                                        allUsersLocked = false;
                                    } else {
                                        for (var i in v) {
                                            var username = v[i].domain ? (v[i].domain + '\\' + v[i].user) : v[i].user;
                                            if (meshCoreObj.lusers.indexOf(username) == -1) {
                                                allUsersLocked = false;
                                                break;
                                            }
                                        }
                                    }
                                    if (allUsersLocked) { autoAccept = true; }
                                }
                                
                                if (autoAccept) {
                                    // User Consent Prompt is not required
                                    files_consent_ok(this.ws);
                                } else { 
                                    // User is present and not all locked, so we still need consent
                                    files_consent_ask(this.ws);
                                }
                            });
                    } else {
                         // User Consent Prompt is required
                        files_consent_ask(this);
                    }
                }  else {
                    // User Consent Prompt is not required
                    files_consent_ok(this);
                }

                // Setup files
                // NOP
            }
        } else if (this.httprequest.protocol == 1) {
            // Send data into terminal stdin
            //this.write(data); // Echo back the keys (Does not seem to be a good idea)
        } else if (this.httprequest.protocol == 2) {
            // Send data into remote desktop
            if (this.httprequest.desktop.state == 0) {
                this.write(Buffer.from(String.fromCharCode(0x11, 0xFE, 0x00, 0x00, 0x4D, 0x45, 0x53, 0x48, 0x00, 0x00, 0x00, 0x00, 0x02)));
                this.httprequest.desktop.state = 1;
            } else {
                this.httprequest.desktop.write(data);
            }
        } else if (this.httprequest.protocol == 5) {
            // Process files commands
            var cmd = null;
            try { cmd = JSON.parse(data); } catch (ex) { };
            if (cmd == null) { return; }
            if ((cmd.ctrlChannel == '102938') || ((cmd.type == 'offer') && (cmd.sdp != null))) { onTunnelControlData(cmd, this); return; } // If this is control data, handle it now.
            if (cmd.action == undefined) { return; }
            //sendConsoleText('CMD: ' + JSON.stringify(cmd));

            if ((cmd.path != null) && (process.platform != 'win32') && (cmd.path[0] != '/')) { cmd.path = '/' + cmd.path; } // Add '/' to paths on non-windows
            //console.log(objToString(cmd, 0, ' '));
            switch (cmd.action) {
                case 'ls': {
                    /*
                    // Close the watcher if required
                    var samepath = ((this.httprequest.watcher != undefined) && (cmd.path == this.httprequest.watcher.path));
                    if ((this.httprequest.watcher != undefined) && (samepath == false)) {
                        //console.log('Closing watcher: ' + this.httprequest.watcher.path);
                        //this.httprequest.watcher.close(); // TODO: This line causes the agent to crash!!!!
                        delete this.httprequest.watcher;
                    }
                    */

                    // Send the folder content to the browser
                    var response = getDirectoryInfo(cmd.path);
                    response.reqid = cmd.reqid;
                    this.write(Buffer.from(JSON.stringify(response)));

                    /*
                    // Start the directory watcher
                    if ((cmd.path != '') && (samepath == false)) {
                        var watcher = fs.watch(cmd.path, onFileWatcher);
                        watcher.tunnel = this.httprequest;
                        watcher.path = cmd.path;
                        this.httprequest.watcher = watcher;
                        //console.log('Starting watcher: ' + this.httprequest.watcher.path);
                    }
                    */
                    break;
                }
                case 'mkdir': {
                    // Create a new empty folder
                    fs.mkdirSync(cmd.path);
                    MeshServerLogEx(44, [cmd.path], "Create folder: \"" + cmd.path + "\"", this.httprequest);
                    break;
                }
                case 'mkfile': {
                    // Create a new empty file
                    fs.closeSync(fs.openSync(cmd.path, 'w'));
                    MeshServerLogEx(164, [cmd.path], "Create file: \"" + cmd.path + "\"", this.httprequest);
                    break;
                }
                case 'rm': {
                    // Delete, possibly recursive delete
                    for (var i in cmd.delfiles) {
                        var p = obj.path.join(cmd.path, cmd.delfiles[i]), delcount = 0;
                        try { delcount = deleteFolderRecursive(p, cmd.rec); } catch (ex) { }
                        if ((delcount == 1) && !cmd.rec) {
                            MeshServerLogEx(45, [p], "Delete: \"" + p + "\"", this.httprequest);
                        } else {
                            if (cmd.rec) {
                                MeshServerLogEx(46, [p, delcount], "Delete recursive: \"" + p + "\", " + delcount + " element(s) removed", this.httprequest);
                            } else {
                                MeshServerLogEx(47, [p, delcount], "Delete: \"" + p + "\", " + delcount + " element(s) removed", this.httprequest);
                            }
                        }
                    }
                    break;
                }
                case 'open': {
                    // Open the local file/folder on the users desktop
                    if (cmd.path) {
                        MeshServerLogEx(20, [cmd.path], "Opening: " + cmd.path, cmd);
                        openFileOnDesktop(cmd.path);
                    }
                }
                case 'markcoredump': {
                    // If we are asking for the coredump file, set the right path.
                    var coreDumpPath = null;
                    if (process.platform == 'win32') {
                        if (fs.existsSync(process.coreDumpLocation)) { coreDumpPath = process.coreDumpLocation; }
                    } else {
                        if ((process.cwd() != '//') && fs.existsSync(process.cwd() + 'core')) { coreDumpPath = process.cwd() + 'core'; }
                    }
                    if (coreDumpPath != null) { db.Put('CoreDumpTime', require('fs').statSync(coreDumpPath).mtime); }
                    break;
                }
                case 'rename':
                    {
                        // Rename a file or folder
                        var oldfullpath = obj.path.join(cmd.path, cmd.oldname);
                        var newfullpath = obj.path.join(cmd.path, cmd.newname);
                        MeshServerLogEx(48, [oldfullpath, cmd.newname], 'Rename: \"' + oldfullpath + '\" to \"' + cmd.newname + '\"', this.httprequest);
                        try { fs.renameSync(oldfullpath, newfullpath); } catch (ex) { console.log(ex); }
                        break;
                    }
                case 'findfile':
                    {
                        // Search for files
                        var r = require('file-search').find('"' + cmd.path + '"', cmd.filter);
                        if (!r.cancel) { r.cancel = function cancel() { this.child.kill(); }; }
                        this._search = r;
                        r.socket = this;
                        r.socket.reqid = cmd.reqid; // Search request id. This is used to send responses and cancel the request.
                        r.socket.path = cmd.path;   // Search path
                        r.on('result', function (str) { try { this.socket.write(Buffer.from(JSON.stringify({ action: 'findfile', r: str.substring(this.socket.path.length), reqid: this.socket.reqid }))); } catch (ex) { } });
                        r.then(function () { try { this.socket.write(Buffer.from(JSON.stringify({ action: 'findfile', r: null, reqid: this.socket.reqid }))); } catch (ex) { } });
                        break;
                    }
                case 'cancelfindfile':
                    {
                        if (this._search) { this._search.cancel(); this._search = null; }
                        break;
                    }
                case 'download':
                    {
                        // Download a file
                        var sendNextBlock = 0;
                        if (cmd.sub == 'start') { // Setup the download
                            if ((cmd.path == null) && (cmd.ask == 'coredump')) { // If we are asking for the coredump file, set the right path.
                                if (process.platform == 'win32') {
                                    if (fs.existsSync(process.coreDumpLocation)) { cmd.path = process.coreDumpLocation; }
                                } else {
                                    if ((process.cwd() != '//') && fs.existsSync(process.cwd() + 'core')) { cmd.path = process.cwd() + 'core'; }
                                }
                            }
                            MeshServerLogEx((cmd.ask == 'coredump') ? 104 : 49, [cmd.path], 'Download: \"' + cmd.path + '\"', this.httprequest);
                            if ((cmd.path == null) || (this.filedownload != null)) { this.write({ action: 'download', sub: 'cancel', id: this.filedownload.id }); delete this.filedownload; }
                            this.filedownload = { id: cmd.id, path: cmd.path, ptr: 0 }
                            try { this.filedownload.f = fs.openSync(this.filedownload.path, 'rbN'); } catch (ex) { this.write({ action: 'download', sub: 'cancel', id: this.filedownload.id }); delete this.filedownload; }
                            if (this.filedownload) { this.write({ action: 'download', sub: 'start', id: cmd.id }); }
                        } else if ((this.filedownload != null) && (cmd.id == this.filedownload.id)) { // Download commands
                            if (cmd.sub == 'startack') { sendNextBlock = ((typeof cmd.ack == 'number') ? cmd.ack : 8); } else if (cmd.sub == 'stop') { delete this.filedownload; } else if (cmd.sub == 'ack') { sendNextBlock = 1; }
                        }
                        // Send the next download block(s)
                        if (sendNextBlock > 0) {
                            sendNextBlock--;
                            var buf = Buffer.alloc(16384);
                            var len = fs.readSync(this.filedownload.f, buf, 4, 16380, null);
                            this.filedownload.ptr += len;
                            if (len < 16380) { buf.writeInt32BE(0x01000001, 0); fs.closeSync(this.filedownload.f); delete this.filedownload; sendNextBlock = 0; } else { buf.writeInt32BE(0x01000000, 0); }
                            this.write(buf.slice(0, len + 4)); // Write as binary
                        }
                        break;
                    }
                case 'upload':
                    {
                        // Upload a file, browser to agent
                        if (this.httprequest.uploadFile != null) { fs.closeSync(this.httprequest.uploadFile); delete this.httprequest.uploadFile; }
                        if (cmd.path == undefined) break;
                        var filepath = cmd.name ? obj.path.join(cmd.path, cmd.name) : cmd.path;
                        this.httprequest.uploadFilePath = filepath;
                        this.httprequest.uploadFileSize = 0;
                        try { this.httprequest.uploadFile = fs.openSync(filepath, cmd.append ? 'abN' : 'wbN'); } catch (ex) { this.write(Buffer.from(JSON.stringify({ action: 'uploaderror', reqid: cmd.reqid }))); break; }
                        this.httprequest.uploadFileid = cmd.reqid;
                        if (this.httprequest.uploadFile) { this.write(Buffer.from(JSON.stringify({ action: 'uploadstart', reqid: this.httprequest.uploadFileid }))); }
                        break;
                    }
                case 'uploaddone':
                    {
                        // Indicates that an upload is done
                        if (this.httprequest.uploadFile) {
                            MeshServerLogEx(105, [this.httprequest.uploadFilePath, this.httprequest.uploadFileSize], 'Upload: \"' + this.httprequest.uploadFilePath + '\", Size: ' + this.httprequest.uploadFileSize, this.httprequest);
                            fs.closeSync(this.httprequest.uploadFile);
                            this.write(Buffer.from(JSON.stringify({ action: 'uploaddone', reqid: this.httprequest.uploadFileid }))); // Indicate that we closed the file.
                            delete this.httprequest.uploadFile;
                            delete this.httprequest.uploadFileid;
                            delete this.httprequest.uploadFilePath;
                            delete this.httprequest.uploadFileSize;
                        }
                        break;
                    }
                case 'uploadcancel':
                    {
                        // Indicates that an upload is canceled
                        if (this.httprequest.uploadFile) {
                            fs.closeSync(this.httprequest.uploadFile);
                            fs.unlinkSync(this.httprequest.uploadFilePath);
                            this.write(Buffer.from(JSON.stringify({ action: 'uploadcancel', reqid: this.httprequest.uploadFileid }))); // Indicate that we closed the file.
                            delete this.httprequest.uploadFile;
                            delete this.httprequest.uploadFileid;
                            delete this.httprequest.uploadFilePath;
                            delete this.httprequest.uploadFileSize;
                        }
                        break;
                    }
                case 'uploadhash':
                    {
                        // Hash a file
                        var filepath = cmd.name ? obj.path.join(cmd.path, cmd.name) : cmd.path;
                        var h = null;
                        try { h = getSHA384FileHash(filepath); } catch (ex) { sendConsoleText(ex); }
                        this.write(Buffer.from(JSON.stringify({ action: 'uploadhash', reqid: cmd.reqid, path: cmd.path, name: cmd.name, tag: cmd.tag, hash: (h ? h.toString('hex') : null) })));
                        break
                    }
                case 'copy':
                    {
                        // Copy a bunch of files from scpath to dspath
                        for (var i in cmd.names) {
                            var sc = obj.path.join(cmd.scpath, cmd.names[i]), ds = obj.path.join(cmd.dspath, cmd.names[i]);
                            MeshServerLogEx(51, [sc, ds], 'Copy: \"' + sc + '\" to \"' + ds + '\"', this.httprequest);
                            if (sc != ds) { try { fs.copyFileSync(sc, ds); } catch (ex) { } }
                        }
                        break;
                    }
                case 'move':
                    {
                        // Move a bunch of files from scpath to dspath
                        for (var i in cmd.names) {
                            var sc = obj.path.join(cmd.scpath, cmd.names[i]), ds = obj.path.join(cmd.dspath, cmd.names[i]);
                            MeshServerLogEx(52, [sc, ds], 'Move: \"' + sc + '\" to \"' + ds + '\"', this.httprequest);
                            if (sc != ds) { try { fs.copyFileSync(sc, ds); fs.unlinkSync(sc); } catch (ex) { } }
                        }
                        break;
                    }
                case 'zip':
                    // Zip a bunch of files
                    if (this.zip != null) return; // Zip operating is currently running, exit now.

                    // Check that the specified files exist & build full paths
                    var fp, stat, p = [];
                    for (var i in cmd.files) { fp = cmd.path + '/' + cmd.files[i]; stat = null; try { stat = fs.statSync(fp); } catch (ex) { } if (stat != null) { p.push(fp); } }
                    if (p.length == 0) return; // No files, quit now.

                    // Setup file compression
                    var ofile = cmd.path + '/' + cmd.output;
                    this.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: 'zipping' })));
                    this.zipfile = ofile;
                    delete this.zipcancel;
                    var out = require('fs').createWriteStream(ofile, { flags: 'wb' });
                    out.xws = this;
                    out.on('close', function () {
                        this.xws.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: null })));
                        this.xws.write(Buffer.from(JSON.stringify({ action: 'refresh' })));
                        if (this.xws.zipcancel === true) { fs.unlinkSync(this.xws.zipfile); } // Delete the complete file.
                        delete this.xws.zipcancel;
                        delete this.xws.zipfile;
                        delete this.xws.zip;
                    });
                    this.zip = require('zip-writer').write({ files: p, basePath: cmd.path });
                    this.zip.xws = this;
                    this.zip.on('progress', require('events').moderated(function (name, p) { this.xws.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: 'zippingFile', file: ((process.platform == 'win32') ? (name.split('/').join('\\')) : name), progress: p }))); }, 1000));
                    this.zip.pipe(out);
                    break;
                case 'unzip':
                    if (this.unzip != null) return; // Unzip operating is currently running, exit now.
                    this.unzip = require('zip-reader').read(cmd.input);
                    this.unzip._dest = cmd.dest;
                    this.unzip.xws = this;
                    this.unzip.then(function (zipped) {
                        this.xws.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: 'unzipping' })));
                        zipped.xws = this.xws;
                        zipped.extractAll(this._dest).then(function () { // finished extracting
                            zipped.xws.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: null })));
                            zipped.xws.write(Buffer.from(JSON.stringify({ action: 'refresh' })));
                            delete zipped.xws.unzip;
                        }, function (e) { // error extracting
                            zipped.xws.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: 'unziperror', error: e })));
                            delete zipped.xws.unzip;
                        });
                    }, function (e) { this.xws.write(Buffer.from(JSON.stringify({ action: 'dialogmessage', msg: 'unziperror', error: e }))); delete this.xws.unzip });
                    break;
                case 'cancel':
                    // Cancel zip operation if present
                    try { this.zipcancel = true; this.zip.cancel(function () { }); } catch (ex) { }
                    this.zip = null;
                    break;
                default:
                    // Unknown action, ignore it.
                    break;
            }
        } else if (this.httprequest.protocol == 7) { // Plugin data exchange
            var cmd = null;
            try { cmd = JSON.parse(data); } catch (ex) { };
            if (cmd == null) { return; }
            if ((cmd.ctrlChannel == '102938') || ((cmd.type == 'offer') && (cmd.sdp != null))) { onTunnelControlData(cmd, this); return; } // If this is control data, handle it now.
            if (cmd.action == undefined) return;

            switch (cmd.action) {
                case 'plugin': {
                    try { require(cmd.plugin).consoleaction(cmd, null, null, this); } catch (ex) { throw ex; }
                    break;
                }
                default: {
                    // probably shouldn't happen, but just in case this feature is expanded
                }
            }

        }
        //sendConsoleText("Got tunnel #" + this.httprequest.index + " data: " + data, this.httprequest.sessionid);
    }
}

// Delete a directory with a files and directories within it
function deleteFolderRecursive(path, rec) {
    var count = 0;
    if (fs.existsSync(path)) {
        if (rec == true) {
            fs.readdirSync(obj.path.join(path, '*')).forEach(function (file, index) {
                var curPath = obj.path.join(path, file);
                if (fs.statSync(curPath).isDirectory()) { // recurse
                    count += deleteFolderRecursive(curPath, true);
                } else { // delete file
                    fs.unlinkSync(curPath);
                    count++;
                }
            });
        }
        fs.unlinkSync(path);
        count++;
    }
    return count;
}

// Called when receiving control data on WebRTC
function onTunnelWebRTCControlData(data) {
    if (typeof data != 'string') return;
    var obj;
    try { obj = JSON.parse(data); } catch (ex) { sendConsoleText('Invalid control JSON on WebRTC: ' + data); return; }
    if (obj.type == 'close') {
        //sendConsoleText('Tunnel #' + this.xrtc.websocket.tunnel.index + ' WebRTC control close');
        try { this.close(); } catch (ex) { }
        try { this.xrtc.close(); } catch (ex) { }
    }
}

function tunnel_webrtc_onEnd()
{
    // The WebRTC channel closed, unpipe the KVM now. This is also done when the web socket closes.
    //sendConsoleText('Tunnel #' + this.websocket.tunnel.index + ' WebRTC data channel closed');
    if (this.websocket.desktop && this.websocket.desktop.kvm)
    {
        try
        {
            this.unpipe(this.websocket.desktop.kvm);
            this.websocket.httprequest.desktop.kvm.unpipe(this);
        } catch (ex) { }
    }
    this.httprequest = null;
    this.websocket = null;
}
function tunnel_webrtc_DataChannel_OnFinalized()
{
    console.info1('WebRTC DataChannel Finalized');
}
function tunnel_webrtc_OnDataChannel(rtcchannel)
{
    //sendConsoleText('WebRTC Datachannel open, protocol: ' + this.websocket.httprequest.protocol);
    //rtcchannel.maxFragmentSize = 32768;
    rtcchannel.xrtc = this;
    rtcchannel.websocket = this.websocket;
    this.rtcchannel = rtcchannel;
    this.rtcchannel.once('~', tunnel_webrtc_DataChannel_OnFinalized);
    this.websocket.rtcchannel = rtcchannel;
    this.websocket.rtcchannel.on('data', onTunnelWebRTCControlData);
    this.websocket.rtcchannel.on('end', tunnel_webrtc_onEnd);
    this.websocket.write('{\"ctrlChannel\":\"102938\",\"type\":\"webrtc0\"}'); // Indicate we are ready for WebRTC switch-over.
}

function tunnel_webrtc_OnFinalized()
{
    console.info1('WebRTC Connection Finalized');
}

// Called when receiving control data on websocket
function onTunnelControlData(data, ws) {
    var obj;
    if (ws == null) { ws = this; }
    if (typeof data == 'string') { try { obj = JSON.parse(data); } catch (ex) { sendConsoleText('Invalid control JSON: ' + data); return; } }
    else if (typeof data == 'object') { obj = data; } else { return; }
    //sendConsoleText('onTunnelControlData(' + ws.httprequest.protocol + '): ' + JSON.stringify(data));
    //console.log('onTunnelControlData: ' + JSON.stringify(data));

    switch (obj.type) {
        case 'lock': {
            // Look for a TSID
            var tsid = null;
            if ((ws.httprequest.xoptions != null) && (typeof ws.httprequest.xoptions.tsid == 'number')) { tsid = ws.httprequest.xoptions.tsid; }

            // Lock the current user out of the desktop
            MeshServerLogEx(53, null, "Locking remote user out of desktop", ws.httprequest);
            lockDesktop(tsid);
            break;
        }
        case 'autolock': {
            // Set the session to auto lock on disconnect
            if (obj.value === true) {
                ws.httprequest.autolock = true;
                if (ws.httprequest.unlockerHelper == null) {
                    destopLockHelper_pipe(ws.httprequest);
                }
            }
            else {
                delete ws.httprequest.autolock;
            }
            break;
        }
        case 'options': {
            // These are additional connection options passed in the control channel.
            //sendConsoleText('options: ' + JSON.stringify(obj));
            delete obj.type;
            ws.httprequest.xoptions = obj;

            // Set additional user consent options if present
            if ((obj != null) && (typeof obj.consent == 'number')) { ws.httprequest.consent |= obj.consent; }

            // Set autolock
            if ((obj != null) && (obj.autolock === true)) {
                ws.httprequest.autolock = true;
                if (ws.httprequest.unlockerHelper == null) {
                    destopLockHelper_pipe(ws.httprequest);
                }
            }

            break;
        }
        case 'close': {
            // We received the close on the websocket
            //sendConsoleText('Tunnel #' + ws.tunnel.index + ' WebSocket control close');
            try { ws.close(); } catch (ex) { }
            break;
        }
        case 'termsize': {
            // Indicates a change in terminal size
            if (process.platform == 'win32') {
                if (ws.httprequest._dispatcher == null) return;
                //sendConsoleText('Win32-TermSize: ' + obj.cols + 'x' + obj.rows);
                if (ws.httprequest._dispatcher.invoke) { ws.httprequest._dispatcher.invoke('resizeTerminal', [obj.cols, obj.rows]); }
            } else {
                if (ws.httprequest.process == null || ws.httprequest.process.pty == 0) return;
                //sendConsoleText('Linux Resize: ' + obj.cols + 'x' + obj.rows);

                if (ws.httprequest.process.tcsetsize) { ws.httprequest.process.tcsetsize(obj.rows, obj.cols); }
            }
            break;
        }
        case 'webrtc0': { // Browser indicates we can start WebRTC switch-over.
            if (ws.httprequest.protocol == 1)
            { // Terminal
                // This is a terminal data stream, unpipe the terminal now and indicate to the other side that terminal data will no longer be received over WebSocket
                if (process.platform == 'win32') {
                    ws.httprequest._term.unpipe(ws);
                } else {
                    ws.httprequest.process.stdout.unpipe(ws);
                    ws.httprequest.process.stderr.unpipe(ws);
                }
            } else if (ws.httprequest.protocol == 2) { // Desktop
                // This is a KVM data stream, unpipe the KVM now and indicate to the other side that KVM data will no longer be received over WebSocket
                ws.httprequest.desktop.kvm.unpipe(ws);
            } else
            {
                // Switch things around so all WebRTC data goes to onTunnelData().
                ws.rtcchannel.httprequest = ws.httprequest;
                ws.rtcchannel.removeAllListeners('data');
                ws.rtcchannel.on('data', onTunnelData);
            }
            ws.write("{\"ctrlChannel\":\"102938\",\"type\":\"webrtc1\"}"); // End of data marker
            break;
        }
        case 'webrtc1':
            {
            if ((ws.httprequest.protocol == 1) || (ws.httprequest.protocol == 6))
            { // Terminal
                // Switch the user input from websocket to webrtc at this point.
                if (process.platform == 'win32') {
                    ws.unpipe(ws.httprequest._term);
                    ws.rtcchannel.pipe(ws.httprequest._term, { dataTypeSkip: 1 }); // 0 = Binary, 1 = Text.
                } else {
                    ws.unpipe(ws.httprequest.process.stdin);
                    ws.rtcchannel.pipe(ws.httprequest.process.stdin, { dataTypeSkip: 1 }); // 0 = Binary, 1 = Text.
                }
                ws.resume(); // Resume the websocket to keep receiving control data
            }
            else if (ws.httprequest.protocol == 2)
            { // Desktop
                // Switch the user input from websocket to webrtc at this point.
                ws.unpipe(ws.httprequest.desktop.kvm);
                if ((ws.httprequest.desktopviewonly != true) && ((ws.httprequest.rights == 0xFFFFFFFF) || (((ws.httprequest.rights & MESHRIGHT_REMOTECONTROL) != 0) && ((ws.httprequest.rights & MESHRIGHT_REMOTEVIEW) == 0)))) {
                    // If we have remote control rights, pipe the KVM input
                    try { ws.webrtc.rtcchannel.pipe(ws.httprequest.desktop.kvm, { dataTypeSkip: 1, end: false }); } catch (ex) { sendConsoleText('EX2'); } // 0 = Binary, 1 = Text.
                } else {
                    // We need to only pipe non-mouse & non-keyboard inputs.
                    // sendConsoleText('Warning: No Remote Desktop Input Rights.');
                    // TODO!!!
                }
                ws.resume(); // Resume the websocket to keep receiving control data
            }
            ws.write('{\"ctrlChannel\":\"102938\",\"type\":\"webrtc2\"}'); // Indicates we will no longer get any data on websocket, switching to WebRTC at this point.
            break;
        }
        case 'webrtc2': {
            // Other side received websocket end of data marker, start sending data on WebRTC channel
            if ((ws.httprequest.protocol == 1) || (ws.httprequest.protocol == 6)) { // Terminal
                if (process.platform == 'win32') {
                    ws.httprequest._term.pipe(ws.webrtc.rtcchannel, { dataTypeSkip: 1, end: false }); // 0 = Binary, 1 = Text.
                } else {
                    ws.httprequest.process.stdout.pipe(ws.webrtc.rtcchannel, { dataTypeSkip: 1, end: false }); // 0 = Binary, 1 = Text.
                    ws.httprequest.process.stderr.pipe(ws.webrtc.rtcchannel, { dataTypeSkip: 1, end: false }); // 0 = Binary, 1 = Text.
                }
            } else if (ws.httprequest.protocol == 2) { // Desktop
                ws.httprequest.desktop.kvm.pipe(ws.webrtc.rtcchannel, { dataTypeSkip: 1 }); // 0 = Binary, 1 = Text.
            }
            break;
        }
        case 'offer': {
            // This is a WebRTC offer.
            if ((ws.httprequest.protocol == 1) || (ws.httprequest.protocol == 6)) return; // TODO: Terminal is currently broken with WebRTC. Reject WebRTC upgrade for now.
            ws.webrtc = rtc.createConnection();
            ws.webrtc.once('~', tunnel_webrtc_OnFinalized);
            ws.webrtc.websocket = ws;
            //ws.webrtc.on('connected', function () { /*sendConsoleText('Tunnel #' + this.websocket.tunnel.index + ' WebRTC connected');*/ });
            //ws.webrtc.on('disconnected', function () { /*sendConsoleText('Tunnel #' + this.websocket.tunnel.index + ' WebRTC disconnected');*/ });
            ws.webrtc.on('dataChannel', tunnel_webrtc_OnDataChannel);

            var sdp = null;
            try { sdp = ws.webrtc.setOffer(obj.sdp); } catch (ex) { }
            if (sdp != null) { ws.write({ type: 'answer', ctrlChannel: '102938', sdp: sdp }); }
            break;
        }
        case 'ping': {
            ws.write("{\"ctrlChannel\":\"102938\",\"type\":\"pong\"}"); // Send pong response
            break;
        }
        case 'pong': { // NOP
            break;
        }
        case 'rtt': {
            ws.write({ type: 'rtt', ctrlChannel: '102938', time: obj.time });
            break;
        }
    }
}

// Console state
var consoleWebSockets = {};
var consoleHttpRequest = null;

// Console HTTP response
function consoleHttpResponse(response) {
    response.data = function (data) { sendConsoleText(rstr2hex(buf2rstr(data)), this.sessionid); consoleHttpRequest = null; }
    response.close = function () { sendConsoleText('httprequest.response.close', this.sessionid); consoleHttpRequest = null; }
}

// Open a local file on current user's desktop
function openFileOnDesktop(file) {
    var child = null;
    try {
        switch (process.platform) {
            case 'win32':
                var uid = require('user-sessions').consoleUid();
                var user = require('user-sessions').getUsername(uid);
                var domain = require('user-sessions').getDomain(uid);
                var task = { name: 'MeshChatTask', user: user, domain: domain, execPath: (require('fs').statSync(file).isDirectory() ? process.env['windir'] + '\\explorer.exe' : file) };
                if (require('fs').statSync(file).isDirectory()) task.arguments = [file];
                try {
                    require('win-tasks').addTask(task);
                    require('win-tasks').getTask({ name: 'MeshChatTask' }).run();
                    require('win-tasks').deleteTask('MeshChatTask');
                    return (true);
                }
                catch (ex) {
                    var taskoptions = { env: { _target: (require('fs').statSync(file).isDirectory() ? process.env['windir'] + '\\explorer.exe' : file), _user: '"' + domain + '\\' + user + '"' }, _args: "" };
                    if (require('fs').statSync(file).isDirectory()) taskoptions.env._args = file;
                    for (var c1e in process.env) {
                        taskoptions.env[c1e] = process.env[c1e];
                    }
                    var child = require('child_process').execFile(process.env['windir'] + '\\System32\\WindowsPowerShell\\v1.0\\powershell.exe', ['powershell', '-noprofile', '-nologo', '-command', '-'], taskoptions);
                    child.stderr.on('data', function (c) { });
                    child.stdout.on('data', function (c) { });
                    child.stdin.write('SCHTASKS /CREATE /F /TN MeshChatTask /SC ONCE /ST 00:00 ');
                    if (user) { child.stdin.write('/RU $env:_user '); }
                    child.stdin.write('/TR "$env:_target $env:_args"\r\n');
                    child.stdin.write('$ts = New-Object -ComObject Schedule.service\r\n');
                    child.stdin.write('$ts.connect()\r\n');
                    child.stdin.write('$tsfolder = $ts.getfolder("\\")\r\n');
                    child.stdin.write('$task = $tsfolder.GetTask("MeshChatTask")\r\n');
                    child.stdin.write('$taskdef = $task.Definition\r\n');
                    child.stdin.write('$taskdef.Settings.StopIfGoingOnBatteries = $false\r\n');
                    child.stdin.write('$taskdef.Settings.DisallowStartIfOnBatteries = $false\r\n');
                    child.stdin.write('$taskdef.Actions.Item(1).Path = $env:_target\r\n');
                    child.stdin.write('$taskdef.Actions.Item(1).Arguments = $env:_args\r\n');
                    child.stdin.write('$tsfolder.RegisterTaskDefinition($task.Name, $taskdef, 4, $null, $null, $null)\r\n');
                    child.stdin.write('SCHTASKS /RUN /TN MeshChatTask\r\n');
                    child.stdin.write('SCHTASKS /DELETE /F /TN MeshChatTask\r\nexit\r\n');
                    child.waitExit();
                }
                break;
            case 'linux':
                child = require('child_process').execFile('/usr/bin/xdg-open', ['xdg-open', file], { uid: require('user-sessions').consoleUid() });
                break;
            case 'darwin':
                child = require('child_process').execFile('/usr/bin/open', ['open', file]);
                break;
            default:
                // Unknown platform, ignore this command.
                break;
        }
    } catch (ex) { }
    return child;
}

// Open a web browser to a specified URL on current user's desktop
function openUserDesktopUrl(url) {
    if ((url.toLowerCase().startsWith('http://') == false) && (url.toLowerCase().startsWith('https://') == false)) { return null; }
    var child = null;
    try {
        switch (process.platform) {
            case 'win32':
                var uid = require('user-sessions').consoleUid();
                var user = require('user-sessions').getUsername(uid);
                var domain = require('user-sessions').getDomain(uid);
                var task = { name: 'MeshChatTask', user: user, domain: domain, execPath: process.env['windir'] + '\\system32\\cmd.exe', arguments: ['/C START ' + url.split('&').join('^&')] };

                try {
                    require('win-tasks').addTask(task);
                    require('win-tasks').getTask({ name: 'MeshChatTask' }).run();
                    require('win-tasks').deleteTask('MeshChatTask');
                    return (true);
                }
                catch (ex) {
                    var taskoptions = { env: { _target: process.env['windir'] + '\\system32\\cmd.exe', _args: '/C START ' + url.split('&').join('^&'), _user: '"' + domain + '\\' + user + '"' } };
                    for (var c1e in process.env) {
                        taskoptions.env[c1e] = process.env[c1e];
                    }
                    var child = require('child_process').execFile(process.env['windir'] + '\\System32\\WindowsPowerShell\\v1.0\\powershell.exe', ['powershell', '-noprofile', '-nologo', '-command', '-'], taskoptions);
                    child.stderr.on('data', function (c) { });
                    child.stdout.on('data', function (c) { });
                    child.stdin.write('SCHTASKS /CREATE /F /TN MeshChatTask /SC ONCE /ST 00:00 ');
                    if (user) { child.stdin.write('/RU $env:_user '); }
                    child.stdin.write('/TR "$env:_target $env:_args"\r\n');
                    child.stdin.write('$ts = New-Object -ComObject Schedule.service\r\n');
                    child.stdin.write('$ts.connect()\r\n');
                    child.stdin.write('$tsfolder = $ts.getfolder("\\")\r\n');
                    child.stdin.write('$task = $tsfolder.GetTask("MeshChatTask")\r\n');
                    child.stdin.write('$taskdef = $task.Definition\r\n');
                    child.stdin.write('$taskdef.Settings.StopIfGoingOnBatteries = $false\r\n');
                    child.stdin.write('$taskdef.Settings.DisallowStartIfOnBatteries = $false\r\n');
                    child.stdin.write('$taskdef.Actions.Item(1).Path = $env:_target\r\n');
                    child.stdin.write('$taskdef.Actions.Item(1).Arguments = $env:_args\r\n');
                    child.stdin.write('$tsfolder.RegisterTaskDefinition($task.Name, $taskdef, 4, $null, $null, $null)\r\n');

                    child.stdin.write('SCHTASKS /RUN /TN MeshChatTask\r\n');
                    child.stdin.write('SCHTASKS /DELETE /F /TN MeshChatTask\r\nexit\r\n');
                    child.waitExit();
                }
                break;
            case 'linux':
                child = require('child_process').execFile('/usr/bin/xdg-open', ['xdg-open', url], { uid: require('user-sessions').consoleUid() });
                break;
            case 'darwin':
                child = require('child_process').execFile('/usr/bin/open', ['open', url], { uid: require('user-sessions').consoleUid() });
                break;
            default:
                // Unknown platform, ignore this command.
                break;
        }
    } catch (ex) { }
    return child;
}

// Process a mesh agent console command
function processConsoleCommand(cmd, args, rights, sessionid) {
    try {
        var response = null;
        switch (cmd) {
            case 'help': { // Displays available commands
                var fin = '', f = '', availcommands = 'domain,translations,agentupdate,errorlog,msh,timerinfo,coreinfo,coreinfoupdate,coredump,service,fdsnapshot,fdcount,startupoptions,';
                availcommands += 'alert,agentsize,versions,help,info,osinfo,args,print,type,dbkeys,dbget,dbset,dbcompact,eval,parseuri,httpget,wslist,plugin,wsconnect,wssend,wsclose,notify,';
                availcommands += 'ls,ps,kill,netinfo,location,power,wakeonlan,setdebug,smbios,rawsmbios,toast,lock,users,openurl,getscript,getclip,setclip,log,cpuinfo,sysinfo';
                availcommands += 'apf,scanwifi,wallpaper,agentmsg,task,uninstallagent,display,openfile';
                if (require('os').dns != null) { availcommands += ',dnsinfo'; }
                try { require('linux-dhcp'); availcommands += ',dhcp'; } catch (ex) { }
                if (process.platform == 'win32') {
                    availcommands += ',bitlocker,cs,wpfhwacceleration,uac,volumes,rdpport,deskbackground,domaininfo';
                    if (bcdOK()) { availcommands += ',safemode'; }
                    if (require('notifybar-desktop').DefaultPinned != null) { availcommands += ',privacybar'; }
                    try { require('win-utils'); availcommands += ',taskbar'; } catch (ex) { }
                    try { require('win-info'); availcommands += ',installedapps,qfe,defender,av,installedstoreapps'; } catch (ex) { }
                }
                if (amt != null) { availcommands += ',amt,amtconfig,amtevents'; }
                if (process.platform != 'freebsd') { availcommands += ',vm'; }
                if (require('MeshAgent').maxKvmTileSize != null) { availcommands += ',kvmmode'; }
                try { require('zip-reader'); availcommands += ',zip,unzip'; } catch (ex) { }

                availcommands = availcommands.split(',').sort();
                while (availcommands.length > 0) {
                    if (f.length > 90) { fin += (f + ',\r\n'); f = ''; }
                    f += (((f != '') ? ', ' : ' ') + availcommands.shift());
                }
                if (f != '') { fin += f; }
                response = "Available commands: \r\n" + fin + ".";
                break;
            }
            case 'mousetrails':
                try { require('win-deskutils'); } catch (ex) { response = 'Unknown command "mousetrails", type "help" for list of available commands.'; break; }
                var id = require('user-sessions').getProcessOwnerName(process.pid).tsid == 0 ? 1 : null;
                switch (args['_'].length) 
                {
                    case 0:                    
                        var trails = require('win-deskutils').mouse.getTrails(id);
                        response = trails == 0 ? 'MouseTrails Disabled' : ('MouseTrails enabled (' + trails + ')');
                        response += '\nTo change setting, specify a positive integer, where 0 is disable: mousetrails [n]';
                        break;
                    case 1:
                        var trails = parseInt(args['_'][0]);
                        require('win-deskutils').mouse.setTrails(trails, id);
                        trails = require('win-deskutils').mouse.getTrails(id);
                        response = trails == 0 ? 'MouseTrails Disabled' : ('MouseTrails enabled (' + trails + ')');
                        break;
                    default:
                        response = 'Proper usage: mousetrails [n]';
                        break;
                }
                break;
            case 'deskbackground':
                try { require('win-deskutils'); } catch (ex) { response = 'Unknown command "deskbackground", type "help" for list of available commands.'; break; }
                var id = require('user-sessions').getProcessOwnerName(process.pid).tsid == 0 ? 1 : null;
                switch (args['_'].length)
                {
                    case 0:
                        response = 'Desktop Background: ' + require('win-deskutils').background.get(id);
                        break;
                    case 1:
                        require('win-deskutils').background.set(args['_'][0], id);
                        response = 'Desktop Background: ' + require('win-deskutils').background.get(id);
                        break;
                    default:
                        response = 'Proper usage: deskbackground [path]';
                        break;
                }
                break;
            case 'taskbar':
                try { require('win-utils'); } catch (ex) { response = 'Unknown command "taskbar", type "help" for list of available commands.'; break; }
                switch (args['_'].length) {
                    case 1:
                    case 2:
                        {
                            var tsid = parseInt(args['_'][1]);
                            if (isNaN(tsid)) { tsid = require('user-sessions').consoleUid(); }
                            sendConsoleText('Changing TaskBar AutoHide status. Please wait...', sessionid);
                            try {
                                var result = require('win-utils').taskBar.autoHide(tsid, args['_'][0].toLowerCase() == 'hide');
                                response = 'Current Status of TaskBar AutoHide: ' + result;
                            } catch (ex) { response = 'Unable to change TaskBar settings'; }
                        }
                        break;
                    default:
                        {
                            response = 'Proper usage: taskbar HIDE|SHOW [TSID]';
                            break;
                        }
                }
                break;
            case 'privacybar':
                if (process.platform != 'win32' || require('notifybar-desktop').DefaultPinned == null) {
                    response = 'Unknown command "privacybar", type "help" for list of available commands.';
                }
                else {
                    switch (args['_'].length) {
                        default:
                            // Show Help
                            response = "Current Default Pinned State: " + (require('notifybar-desktop').DefaultPinned ? "PINNED" : "UNPINNED") + '\r\n';
                            response += "To set default pinned state:\r\n  privacybar [PINNED|UNPINNED]\r\n";
                            break;
                        case 1:
                            switch (args['_'][0].toUpperCase()) {
                                case 'PINNED':
                                    require('notifybar-desktop').DefaultPinned = true;
                                    response = "privacybar default pinned state is: PINNED";
                                    break;
                                case 'UNPINNED':
                                    require('notifybar-desktop').DefaultPinned = false;
                                    response = "privacybar default pinned state is: UNPINNED";
                                    break;
                                default:
                                    response = "INVALID parameter: " + args['_'][0].toUpperCase();
                                    break;
                            }
                            break;
                    }
                }
                break;
            case 'domain':
                response = getDomainInfo();
                break;
            case 'domaininfo':
                {
                    if (process.platform != 'win32') {
                        response = 'Unknown command "domaininfo", type "help" for list of available commands.';
                        break;
                    }
                    if (global._domainQuery != null) {
                        response = "There is already an outstanding Domain Controller Query... Please try again later...";
                        break;
                    }

                    sendConsoleText('Querying Domain Controller... This can take up to 60 seconds. Please wait...', sessionid);
                    global._domainQuery = require('win-wmi').queryAsync('ROOT\\CIMV2', 'SELECT * FROM Win32_NTDomain');
                    global._domainQuery.session = sessionid;
                    global._domainQuery.then(function (v) {
                        var results = [];
                        if (Array.isArray(v)) {
                            var i;
                            var r;
                            for (i = 0; i < v.length; ++i) {
                                r = {};
                                if (v[i].DomainControllerAddress != null) { r.DomainControllerAddress = v[i].DomainControllerAddress.split('\\').pop(); }
                                if (r.DomainControllerName != null) { r.DomainControllerName = v[i].DomainControllerName.split('\\').pop(); }
                                r.DomainGuid = v[i].DomainGuid;
                                r.DomainName = v[i].DomainName;
                                if (r.DomainGuid != null) {
                                    results.push(r);
                                }
                            }
                        }
                        if (results.length > 0) {
                            sendConsoleText('Domain Controller Results:', this.session);
                            sendConsoleText(JSON.stringify(results, null, 1), this.session);
                            sendConsoleText('End of results...', this.session);
                        }
                        else {
                            sendConsoleText('Domain Controller: No results returned. Is the domain controller reachable?', this.session);
                        }
                        global._domainQuery = null;
                    });
                    break;
                }
            case 'translations': {
                response = JSON.stringify(coretranslations, null, 2);
                break;
            }
            case 'volumes':
                response = JSON.stringify(require('win-volumes').getVolumes(), null, 1);
                break;
            case 'bitlocker':
                if (process.platform == 'win32') {
                    if (require('win-volumes').volumes_promise != null) {
                        var p = require('win-volumes').volumes_promise();
                        p.then(function (res) { sendConsoleText(JSON.stringify(cleanGetBitLockerVolumeInfo(res), null, 1), this.session); });
                    }
                }
                break;
            case 'dhcp': // This command is only supported on Linux, this is because Linux does not give us the DNS suffix for each network adapter independently so we have to ask the DHCP server.
                {
                    try { require('linux-dhcp'); } catch (ex) { response = 'Unknown command "dhcp", type "help" for list of available commands.'; break; }
                    if (args['_'].length == 0) {
                        var j = require('os').networkInterfaces();
                        var ifcs = [];
                        for (var i in j) {
                            for (var z in j[i]) {
                                if (j[i][z].status == 'up' && j[i][z].type != 'loopback' && j[i][z].address != null) {
                                    ifcs.push('"' + i + '"');
                                    break;
                                }
                            }
                        }
                        response = 'Proper usage: dhcp [' + ifcs.join(' | ') + ']';
                    }
                    else {
                        require('linux-dhcp').client.info(args['_'][0]).
                            then(function (d) {
                                sendConsoleText(JSON.stringify(d, null, 1), sessionid);
                            },
                            function (e) {
                                sendConsoleText(e, sessionid);
                            });
                    }
                    break;
                }
            case 'cs':
                if (process.platform != 'win32') {
                    response = 'Unknown command "cs", type "help" for list of available commands.';
                    break;
                }
                switch (args['_'].length) {
                    case 0:
                        try {
                            var cs = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Power', 'CsEnabled');
                            response = "Connected Standby: " + (cs == 1 ? "ENABLED" : "DISABLED");
                        } catch (ex) {
                            response = "This machine does not support Connected Standby";
                        }
                        break;
                    case 1:
                        if ((args['_'][0].toUpperCase() != 'ENABLE' && args['_'][0].toUpperCase() != 'DISABLE')) {
                            response = "Proper usage:\r\n  cs [ENABLE|DISABLE]";
                        }
                        else {
                            try {
                                var cs = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Power', 'CsEnabled');
                                require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Power', 'CsEnabled', args['_'][0].toUpperCase() == 'ENABLE' ? 1 : 0);

                                cs = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Power', 'CsEnabled');
                                response = "Connected Standby: " + (cs == 1 ? "ENABLED" : "DISABLED");
                            } catch (ex) {
                                response = "This machine does not support Connected Standby";
                            }
                        }
                        break;
                    default:
                        response = "Proper usage:\r\n  cs [ENABLE|DISABLE]";
                        break;
                }
                break;
            case 'assistant':
                if (process.platform == 'win32') {
                    // Install MeshCentral Assistant on this device
                    response = "Usage: Assistant [info|install|uninstall]";
                    if (args['_'].length == 1) {
                        if ((args['_'][0] == 'install') || (args['_'][0] == 'info')) { response = ''; require('MeshAgent').SendCommand({ action: 'meshToolInfo', sessionid: sessionid, name: 'MeshCentralAssistant', cookie: true, tag: args['_'][0] }); }
                        // TODO: Uninstall
                    }
                } else {
                    response = "MeshCentral Assistant is not supported on this platform.";
                }
                break;
            case 'userimage':
                require('MeshAgent').SendCommand({ action: 'getUserImage', sessionid: sessionid, userid: args['_'][0], tag: 'info' });
                response = 'ok';
                break;
            case 'agentupdate':
                require('MeshAgent').SendCommand({ action: 'agentupdate', sessionid: sessionid });
                break;
            case 'agentupdateex':
                // Perform an direct agent update without requesting any information from the server, this should not typically be used.
                if (args['_'].length == 1) {
                    if (args['_'][0].startsWith('https://')) { agentUpdate_Start(args['_'][0], { sessionid: sessionid }); } else { response = "Usage: agentupdateex https://server/path"; }
                } else {
                    agentUpdate_Start(null, { sessionid: sessionid });
                }
                break;
            case 'errorlog':
                switch (args['_'].length) {
                    case 0:
                        // All Error Logs
                        response = JSON.stringify(require('util-agentlog').read(), null, 1);
                        break;
                    case 1:
                        // Error Logs, by either count or timestamp
                        response = JSON.stringify(require('util-agentlog').read(parseInt(args['_'][0])), null, 1);
                        break;
                    default:
                        response = "Proper usage:\r\n  errorlog [lastCount|linuxEpoch]";
                        break;
                }
                break;
            case 'msh':
                if (args['_'].length == 0) {
                    response = JSON.stringify(_MSH(), null, 2);
                } else if (args['_'].length > 3) {
                    response = 'Proper usage: msh [get|set|delete]\r\nmsh get MeshServer\r\nmsh set abc "xyz"\r\nmsh delete abc';
                } else {
                    var mshFileName = process.execPath.replace('.exe','') + '.msh';
                    switch (args['_'][0].toLocaleLowerCase()) {
                        case 'get':
                            if (typeof args['_'][1] != 'string' || args['_'].length > 2) {
                                response = 'Proper usage: msh get MeshServer';
                            } else if(_MSH()[args['_'][1]]) {
                                response = _MSH()[args['_'][1]];
                            } else {
                                response = "Unknown Value: " + args['_'][1];
                            }
                            break;
                        case 'set': 
                            if (typeof args['_'][1] != 'string' || typeof args['_'][2] != 'string') {
                                response = 'Proper usage: msh set abc "xyz"';
                            } else {
                                var jsonToSave = _MSH();
                                jsonToSave[args['_'][1]] = args['_'][2];
                                var updatedContent = '';
                                for (var key in jsonToSave) {
                                    if (jsonToSave.hasOwnProperty(key)) {
                                        updatedContent += key + '=' + jsonToSave[key] + '\n';
                                    }
                                }
                                try {
                                    require('fs').writeFileSync(mshFileName, updatedContent);
                                    response = "msh set " + args['_'][1] + " successful"
                                } catch (ex) {
                                    response = "msh set " + args['_'][1] + " unsuccessful";
                                }
                            }
                            break;
                        case 'delete':
                            if (typeof args['_'][1] != 'string') {
                                response = 'Proper usage: msh delete abc';
                            } else {
                                var jsonToSave = _MSH();
                                delete jsonToSave[args['_'][1]];
                                var updatedContent = '';
                                for (var key in jsonToSave) {
                                    if (jsonToSave.hasOwnProperty(key)) {
                                        updatedContent += key + '=' + jsonToSave[key] + '\n';
                                    }
                                }
                                try {
                                    require('fs').writeFileSync(mshFileName, updatedContent);
                                    response = "msh delete " + args['_'][1] + " successful"
                                } catch (ex) {
                                    response = "msh delete " + args['_'][1] + " unsuccessful";
                                }
                            }
                            break;
                        default:
                            response = 'Proper usage: msh [get|set|delete]\r\nmsh get MeshServer\r\nmsh set abc "xyz"\r\nmsh delete abc';
                            break;
                    }
                }
                break;
            case 'dnsinfo':
                if (require('os').dns == null) {
                    response = "Unknown command \"" + cmd + "\", type \"help\" for list of available commands.";
                }
                else {
                    response = 'DNS Servers: ';
                    var dns = require('os').dns();
                    for (var i = 0; i < dns.length; ++i) {
                        if (i > 0) { response += ', '; }
                        response += dns[i];
                    }
                }
                break;
            case 'timerinfo':
                response = require('ChainViewer').getTimerInfo();
                break;
            case 'rdpport':
                if (process.platform != 'win32') {
                    response = 'Unknown command "rdpport", type "help" for list of available commands.';
                    return;
                }
                if (args['_'].length == 0) {
                    response = 'Proper usage: rdpport [get|default|PORTNUMBER]';
                } else {
                    switch (args['_'][0].toLocaleLowerCase()) {
                        case 'get':
                            var rdpport = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Terminal Server\\WinStations\\RDP-Tcp', 'PortNumber');
                            response = "Current RDP Port Set To: " + rdpport + '\r\n';
                            break;
                        case 'default':
                            try {
                                require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Terminal Server\\WinStations\\RDP-Tcp', 'PortNumber', 3389);
                                response = 'RDP Port Set To 3389, Please Dont Forget To Restart Your Computer To Fully Apply';
                            } catch (ex) {
                                response = 'Unable to Set RDP Port To: 3389';
                            }
                            break;
                        default:
                            if (isNaN(parseFloat(args['_'][0]))){
                                response = 'Proper usage: rdpport [get|default|PORTNUMBER]';
                            } else if(parseFloat(args['_'][0]) < 0 || args['_'][0] > 65535) {
                                response = 'RDP Port Must Be More Than 0 And Less Than 65535';
                            } else {
                                try {
                                    require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'System\\CurrentControlSet\\Control\\Terminal Server\\WinStations\\RDP-Tcp', 'PortNumber', parseFloat(args['_'][0]));
                                    response = 'RDP Port Set To ' + args['_'][0] + ', Please Dont Forget To Restart Your Computer To Fully Apply';
                                } catch (ex) {
                                    response = 'Unable to Set RDP Port To: '+args['_'][0];
                                }
                            }
                            break;
                    }
                }
                break;
            case 'find':
                if (args['_'].length <= 1) {
                    response = "Proper usage:\r\n  find root criteria [criteria2] [criteria n...]";
                }
                else {
                    var root = args['_'][0];
                    var p = args['_'].slice(1);
                    var r = require('file-search').find(root, p);
                    r.sid = sessionid;
                    r.on('result', function (str) { sendConsoleText(str, this.sid); });
                    r.then(function () { sendConsoleText('*** End Results ***', this.sid); });
                    response = "Find: [" + root + "] " + JSON.stringify(p);
                }
                break;
            case 'coreinfo': {
                response = JSON.stringify(meshCoreObj, null, 2);
                break;
            }
            case 'coreinfoupdate': {
                sendPeriodicServerUpdate(null, true);
                response = "Core Info Update Requested"
                break;
            }
            case 'agentmsg': {
                if (args['_'].length == 0) {
                    response = "Proper usage:\r\n  agentmsg add \"[message]\" [iconIndex]\r\n  agentmsg remove [id]\r\n  agentmsg list"; // Display usage
                } else {
                    if ((args['_'][0] == 'add') && (args['_'].length > 1)) {
                        var msgID, iconIndex = 0;
                        if (args['_'].length >= 3) { try { iconIndex = parseInt(args['_'][2]); } catch (ex) { } }
                        if (typeof iconIndex != 'number') { iconIndex = 0; }
                        msgID = sendAgentMessage(args['_'][1], iconIndex);
                        response = 'Agent message: ' + msgID + ' added.';
                    } else if ((args['_'][0] == 'remove') && (args['_'].length > 1)) {
                        var r = removeAgentMessage(args['_'][1]);
                        response = 'Message ' + (r ? 'removed' : 'NOT FOUND');
                    } else if (args['_'][0] == 'list') {
                        response = JSON.stringify(sendAgentMessage(), null, 2);
                    }
                    broadcastSessionsToRegisteredApps();
                }
                break;
            }
            case 'clearagentmsg': {
                removeAgentMessage();
                broadcastSessionsToRegisteredApps();
                break;
            }
            case 'coredump':
                if (args['_'].length != 1) {
                    response = "Proper usage: coredump on|off|status|clear"; // Display usage
                } else {
                    switch (args['_'][0].toLowerCase()) {
                        case 'on':
                            process.coreDumpLocation = (process.platform == 'win32') ? (process.execPath.replace('.exe', '.dmp')) : (process.execPath + '.dmp');
                            response = 'coredump is now on';
                            break;
                        case 'off':
                            process.coreDumpLocation = null;
                            response = 'coredump is now off';
                            break;
                        case 'status':
                            response = 'coredump is: ' + ((process.coreDumpLocation == null) ? 'off' : 'on');
                            if (process.coreDumpLocation != null) {
                                if (process.platform == 'win32') {
                                    if (fs.existsSync(process.coreDumpLocation)) {
                                        response += '\r\n  CoreDump present at: ' + process.coreDumpLocation;
                                        response += '\r\n  CoreDump Time: ' + new Date(fs.statSync(process.coreDumpLocation).mtime).getTime();
                                        response += '\r\n  Agent Time   : ' + new Date(fs.statSync(process.execPath).mtime).getTime();
                                    }
                                } else {
                                    if ((process.cwd() != '//') && fs.existsSync(process.cwd() + 'core')) {
                                        response += '\r\n  CoreDump present at: ' + process.cwd() + 'core';
                                        response += '\r\n  CoreDump Time: ' + new Date(fs.statSync(process.cwd() + 'core').mtime).getTime();
                                        response += '\r\n  Agent Time   : ' + new Date(fs.statSync(process.execPath).mtime).getTime();
                                    }
                                }
                            }
                            break;
                        case 'clear':
                            db.Put('CoreDumpTime', null);
                            response = 'coredump db cleared';
                            break;
                        default:
                            response = "Proper usage: coredump on|off|status"; // Display usage
                            break;
                    }
                }
                break;
            case 'service':
                if (args['_'].length != 1) {
                    response = "Proper usage: service status|restart"; // Display usage
                } else {
                    var svcname = process.platform == 'win32' ? 'Mesh Agent' : 'meshagent';
                    try {
                        svcname = require('MeshAgent').serviceName;
                    } catch (ex) { }
                    var s = require('service-manager').manager.getService(svcname);
                    switch (args['_'][0].toLowerCase()) {
                        case 'status':
                            response = 'Service ' + (s.isRunning() ? (s.isMe() ? '[SELF]' : '[RUNNING]') : ('[NOT RUNNING]'));
                            break;
                        case 'restart':
                            if (s.isMe()) {
                                s.restart();
                            } else {
                                response = 'Restarting another agent instance is not allowed';
                            }
                            break;
                        default:
                            response = "Proper usage: service status|restart"; // Display usage
                            break;
                    }
                    if (process.platform == 'win32') { s.close(); }
                }
                break;
            case 'zip':
                if (args['_'].length == 0) {
                    response = "Proper usage: zip (output file name), input1 [, input n]"; // Display usage
                } else {
                    var p = args['_'].join(' ').split(',');
                    var ofile = p.shift();
                    sendConsoleText('Writing ' + ofile + '...');
                    var out = require('fs').createWriteStream(ofile, { flags: 'wb' });
                    out.fname = ofile;
                    out.sessionid = sessionid;
                    out.on('close', function () { sendConsoleText('DONE writing ' + this.fname, this.sessionid); });
                    var zip = require('zip-writer').write({ files: p });
                    zip.pipe(out);
                }
                break;
            case 'unzip':
                if (args['_'].length == 0) {
                    response = "Proper usage: unzip input,destination"; // Display usage
                } else {
                    var p = args['_'].join(' ').split(',');
                    if (p.length != 2) { response = "Proper usage: unzip input,destination"; break; } // Display usage
                    var prom = require('zip-reader').read(p[0].trim());
                    prom._dest = p[1].trim();
                    prom.self = this;
                    prom.sessionid = sessionid;
                    prom.then(function (zipped) {
                        sendConsoleText('Extracting to ' + this._dest + '...', this.sessionid);
                        zipped.extractAll(this._dest).then(function () { sendConsoleText('finished unzipping', this.sessionid); }, function (e) { sendConsoleText('Error unzipping: ' + e, this.sessionid); }).parentPromise.sessionid = this.sessionid;
                    }, function (e) { sendConsoleText('Error unzipping: ' + e, this.sessionid); });
                }
                break;
            case 'setbattery':
                // require('MeshAgent').SendCommand({ action: 'battery', state: 'dc', level: 55 });
                if ((args['_'].length > 0) && ((args['_'][0] == 'ac') || (args['_'][0] == 'dc'))) {
                    var b = { action: 'battery', state: args['_'][0] };
                    if (args['_'].length == 2) { b.level = parseInt(args['_'][1]); }
                    require('MeshAgent').SendCommand(b);
                } else {
                    require('MeshAgent').SendCommand({ action: 'battery' });
                }
                break;
            case 'fdsnapshot':
                require('ChainViewer').getSnapshot().then(function (c) { sendConsoleText(c, this.sessionid); }).parentPromise.sessionid = sessionid;
                break;
            case 'fdcount':
                require('DescriptorEvents').getDescriptorCount().then(
                    function (c) {
                        sendConsoleText('Descriptor Count: ' + c, this.sessionid);
                    }, function (e) {
                        sendConsoleText('Error fetching descriptor count: ' + e, this.sessionid);
                    }).parentPromise.sessionid = sessionid;
                break;
            case 'uac':
                if (process.platform != 'win32') {
                    response = 'Unknown command "uac", type "help" for list of available commands.';
                    break;
                }
                if (args['_'].length != 1) {
                    response = 'Proper usage: uac [get|interactive|secure]';
                }
                else {
                    switch (args['_'][0].toUpperCase()) {
                        case 'GET':
                            var secd = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Policies\\System', 'PromptOnSecureDesktop');
                            response = "UAC mode: " + (secd == 0 ? "Interactive Desktop" : "Secure Desktop");
                            break;
                        case 'INTERACTIVE':
                            try {
                                require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Policies\\System', 'PromptOnSecureDesktop', 0);
                                response = 'UAC mode changed to: Interactive Desktop';
                            } catch (ex) {
                                response = "Unable to change UAC Mode";
                            }
                            break;
                        case 'SECURE':
                            try {
                                require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Policies\\System', 'PromptOnSecureDesktop', 1);
                                response = 'UAC mode changed to: Secure Desktop';
                            } catch (ex) {
                                response = "Unable to change UAC Mode";
                            }
                            break;
                        default:
                            response = 'Proper usage: uac [get|interactive|secure]';
                            break;
                    }
                }
                break;
            case 'vm':
                response = 'Virtual Machine = ' + require('computer-identifiers').isVM();
                break;
            case 'startupoptions':
                response = JSON.stringify(require('MeshAgent').getStartupOptions());
                break;
            case 'kvmmode':
                if (require('MeshAgent').maxKvmTileSize == null) {
                    response = "Unknown command \"kvmmode\", type \"help\" for list of available commands.";
                }
                else {
                    if (require('MeshAgent').maxKvmTileSize == 0) {
                        response = 'KVM Mode: Full JUMBO';
                    }
                    else {
                        response = 'KVM Mode: ' + (require('MeshAgent').maxKvmTileSize <= 65500 ? 'NO JUMBO' : 'Partial JUMBO');
                        response += (', TileLimit: ' + (require('MeshAgent').maxKvmTileSize < 1024 ? (require('MeshAgent').maxKvmTileSize + ' bytes') : (Math.round(require('MeshAgent').maxKvmTileSize / 1024) + ' Kbytes')));
                    }
                }
                break;
            case 'alert':
                if (args['_'].length == 0) {
                    response = "Proper usage: alert TITLE, CAPTION [, TIMEOUT]"; // Display usage
                }
                else {
                    var p = args['_'].join(' ').split(',');
                    if (p.length < 2) {
                        response = "Proper usage: alert TITLE, CAPTION [, TIMEOUT]"; // Display usage
                    }
                    else {
                        this._alert = require('message-box').create(p[0], p[1], p.length == 3 ? parseInt(p[2]) : 9999, 1);
                    }
                }
                break;
            case 'agentsize':
                var actualSize = Math.floor(require('fs').statSync(process.execPath).size / 1024);
                if (process.platform == 'win32') {
                    // Check the Agent Uninstall MetaData for correctness, as the installer may have written an incorrect value
                    var writtenSize = 0;
                    var serviceName =  (_MSH().serviceName ?  _MSH().serviceName : (require('_agentNodeId').serviceName() ? require('_agentNodeId').serviceName() : 'Mesh Agent'));
                    try { writtenSize = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Uninstall\\' + serviceName, 'EstimatedSize'); } catch (ex) { response = ex; }
                    if (writtenSize != actualSize) {
                        response = "Size updated from: " + writtenSize + " to: " + actualSize;
                        try { require('win-registry').WriteKey(require('win-registry').HKEY.LocalMachine, 'Software\\Microsoft\\Windows\\CurrentVersion\\Uninstall\\' + serviceName, 'EstimatedSize', actualSize); } catch (ex) { response = ex; }
                    } else
                    { response = "Agent Size: " + actualSize + " kb"; }
                } else
                { response = "Agent Size: " + actualSize + " kb"; }
                break;
            case 'versions':
                response = JSON.stringify(process.versions, null, '  ');
                break;
            case 'wpfhwacceleration':
                if (process.platform != 'win32') { throw ("wpfhwacceleration setting is only supported on Windows"); }
                if (args['_'].length != 1) {
                    response = "Proper usage: wpfhwacceleration (ON|OFF|STATUS)"; // Display usage
                }
                else {
                    var reg = require('win-registry');
                    var uname = require('user-sessions').getUsername(require('user-sessions').consoleUid());
                    var key = reg.usernameToUserKey(uname);

                    switch (args['_'][0].toUpperCase()) {
                        default:
                            response = "Proper usage: wpfhwacceleration (ON|OFF|STATUS|DEFAULT)"; // Display usage
                            break;
                        case 'ON':
                            try {
                                reg.WriteKey(reg.HKEY.Users, key + '\\SOFTWARE\\Microsoft\\Avalon.Graphics', 'DisableHWAcceleration', 0);
                                response = "OK";
                            } catch (ex) { response = "FAILED"; }
                            break;
                        case 'OFF':
                            try {
                                reg.WriteKey(reg.HKEY.Users, key + '\\SOFTWARE\\Microsoft\\Avalon.Graphics', 'DisableHWAcceleration', 1);
                                response = 'OK';
                            } catch (ex) { response = 'FAILED'; }
                            break;
                        case 'STATUS':
                            var s;
                            try { s = reg.QueryKey(reg.HKEY.Users, key + '\\SOFTWARE\\Microsoft\\Avalon.Graphics', 'DisableHWAcceleration') == 1 ? 'DISABLED' : 'ENABLED'; } catch (ex) { s = 'DEFAULT'; }
                            response = "WPF Hardware Acceleration: " + s;
                            break;
                        case 'DEFAULT':
                            try { reg.DeleteKey(reg.HKEY.Users, key + '\\SOFTWARE\\Microsoft\\Avalon.Graphics', 'DisableHWAcceleration'); } catch (ex) { }
                            response = 'OK';
                            break;
                    }
                }
                break;
            case 'tsid':
                if (process.platform == 'win32') {
                    if (args['_'].length != 1) {
                        response = "TSID: " + (require('MeshAgent')._tsid == null ? "console" : require('MeshAgent')._tsid);
                    } else {
                        var i = parseInt(args['_'][0]);
                        require('MeshAgent')._tsid = (isNaN(i) ? null : i);
                        response = "TSID set to: " + (require('MeshAgent')._tsid == null ? "console" : require('MeshAgent')._tsid);
                    }
                } else
                { response = "TSID command only supported on Windows"; }
                break;
            case 'activeusers':
                if (process.platform == 'win32') {
                    var p = require('user-sessions').enumerateUsers();
                    p.sessionid = sessionid;
                    p.then(function (u) {
                        var v = [];
                        var ret = getDomainInfo();
                        for (var i in u) {
                            if (u[i].State == 'Active') {
                               if (u[i].Domain != null && u[i].Domain == 'AzureAD'){
                                    // AzureAD to-do
                                    // var userGUID = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'SYSTEM\\CurrentControlSet\\Control\\CloudDomainJoin\\JoinInfo');
                                    // if (userGUID != null){
                                    //     var user = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'SYSTEM\\CurrentControlSet\\Control\\CloudDomainJoin\\JoinInfo\\' + userGUID.subkeys[0], 'UserEmail');
                                    //     if (user != null) u[i].UPN = user;
                                    // }
                                } else if (u[i].Domain != null) {
                                    if (ret != null && ret.PartOfDomain === true) {
                                        u[i].UPN = u[i].Username + '@' + ret.Domain;
                                    }
                                }
                                v.push({ tsid: i, type: u[i].StationName, user: u[i].Username, domain: u[i].Domain, upn: u[i].UPN });
                            }
                        }
                        sendConsoleText(JSON.stringify(v, null, 1), this.sessionid);
                    });
                } else
                { response = "activeusers command only supported on Windows"; }
                break;
            case 'wallpaper':
                if (process.platform != 'win32' && !(process.platform == 'linux' && require('linux-gnome-helpers').available)) {
                    response = "wallpaper command not supported on this platform";
                }
                else {
                    if (args['_'].length != 1) {
                        response = 'Proper usage: wallpaper (GET|TOGGLE)'; // Display usage
                    }
                    else {
                        switch (args['_'][0].toUpperCase()) {
                            default:
                                response = 'Proper usage: wallpaper (GET|TOGGLE)'; // Display usage
                                break;
                            case 'GET':
                            case 'TOGGLE':
                                if (process.platform == 'win32') {
                                    var id = require('user-sessions').getProcessOwnerName(process.pid).tsid == 0 ? 1 : 0;
                                    var child = require('child_process').execFile(process.execPath, [process.execPath.split('\\').pop(), '-b64exec', 'dmFyIFNQSV9HRVRERVNLV0FMTFBBUEVSID0gMHgwMDczOwp2YXIgU1BJX1NFVERFU0tXQUxMUEFQRVIgPSAweDAwMTQ7CnZhciBHTSA9IHJlcXVpcmUoJ19HZW5lcmljTWFyc2hhbCcpOwp2YXIgdXNlcjMyID0gR00uQ3JlYXRlTmF0aXZlUHJveHkoJ3VzZXIzMi5kbGwnKTsKdXNlcjMyLkNyZWF0ZU1ldGhvZCgnU3lzdGVtUGFyYW1ldGVyc0luZm9BJyk7CgppZiAocHJvY2Vzcy5hcmd2Lmxlbmd0aCA9PSAzKQp7CiAgICB2YXIgdiA9IEdNLkNyZWF0ZVZhcmlhYmxlKDEwMjQpOwogICAgdXNlcjMyLlN5c3RlbVBhcmFtZXRlcnNJbmZvQShTUElfR0VUREVTS1dBTExQQVBFUiwgdi5fc2l6ZSwgdiwgMCk7CiAgICBjb25zb2xlLmxvZyh2LlN0cmluZyk7CiAgICBwcm9jZXNzLmV4aXQoKTsKfQplbHNlCnsKICAgIHZhciBuYiA9IEdNLkNyZWF0ZVZhcmlhYmxlKHByb2Nlc3MuYXJndlszXSk7CiAgICB1c2VyMzIuU3lzdGVtUGFyYW1ldGVyc0luZm9BKFNQSV9TRVRERVNLV0FMTFBBUEVSLCBuYi5fc2l6ZSwgbmIsIDApOwogICAgcHJvY2Vzcy5leGl0KCk7Cn0='], { type: id });
                                    child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
                                    child.stderr.on('data', function () { });
                                    child.waitExit();
                                    var current = child.stdout.str.trim();
                                    if (args['_'][0].toUpperCase() == 'GET') {
                                        response = current;
                                        break;
                                    }
                                    if (current != '') {
                                        require('MeshAgent')._wallpaper = current;
                                        response = 'Wallpaper cleared';
                                    } else {
                                        response = 'Wallpaper restored';
                                    }
                                    child = require('child_process').execFile(process.execPath, [process.execPath.split('\\').pop(), '-b64exec', 'dmFyIFNQSV9HRVRERVNLV0FMTFBBUEVSID0gMHgwMDczOwp2YXIgU1BJX1NFVERFU0tXQUxMUEFQRVIgPSAweDAwMTQ7CnZhciBHTSA9IHJlcXVpcmUoJ19HZW5lcmljTWFyc2hhbCcpOwp2YXIgdXNlcjMyID0gR00uQ3JlYXRlTmF0aXZlUHJveHkoJ3VzZXIzMi5kbGwnKTsKdXNlcjMyLkNyZWF0ZU1ldGhvZCgnU3lzdGVtUGFyYW1ldGVyc0luZm9BJyk7CgppZiAocHJvY2Vzcy5hcmd2Lmxlbmd0aCA9PSAzKQp7CiAgICB2YXIgdiA9IEdNLkNyZWF0ZVZhcmlhYmxlKDEwMjQpOwogICAgdXNlcjMyLlN5c3RlbVBhcmFtZXRlcnNJbmZvQShTUElfR0VUREVTS1dBTExQQVBFUiwgdi5fc2l6ZSwgdiwgMCk7CiAgICBjb25zb2xlLmxvZyh2LlN0cmluZyk7CiAgICBwcm9jZXNzLmV4aXQoKTsKfQplbHNlCnsKICAgIHZhciBuYiA9IEdNLkNyZWF0ZVZhcmlhYmxlKHByb2Nlc3MuYXJndlszXSk7CiAgICB1c2VyMzIuU3lzdGVtUGFyYW1ldGVyc0luZm9BKFNQSV9TRVRERVNLV0FMTFBBUEVSLCBuYi5fc2l6ZSwgbmIsIDApOwogICAgcHJvY2Vzcy5leGl0KCk7Cn0=', current != '' ? '""' : require('MeshAgent')._wallpaper], { type: id });
                                    child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
                                    child.stderr.on('data', function () { });
                                    child.waitExit();
                                }
                                else {
                                    var id = require('user-sessions').consoleUid();
                                    var current = require('linux-gnome-helpers').getDesktopWallpaper(id);
                                    if (args['_'][0].toUpperCase() == 'GET') {
                                        response = current;
                                        break;
                                    }
                                    if (current != '/dev/null') {
                                        require('MeshAgent')._wallpaper = current;
                                        response = 'Wallpaper cleared';
                                    } else {
                                        response = 'Wallpaper restored';
                                    }
                                    require('linux-gnome-helpers').setDesktopWallpaper(id, current != '/dev/null' ? undefined : require('MeshAgent')._wallpaper);
                                }
                                break;
                        }
                    }
                }
                break;
            case 'safemode':
                if (process.platform != 'win32') {
                    response = 'safemode only supported on Windows Platforms'
                }
                else {
                    if (!bcdOK()) {
                        response = 'safemode not supported on 64 bit Windows from a 32 bit process'
                        break;
                    }
                    if (args['_'].length != 1) {
                        response = 'Proper usage: safemode (ON|OFF|STATUS)'; // Display usage
                    }
                    else {
                        var svcname = process.platform == 'win32' ? 'Mesh Agent' : 'meshagent';
                        try {
                            svcname = require('MeshAgent').serviceName;
                        } catch (ex) { }

                        switch (args['_'][0].toUpperCase()) {
                            default:
                                response = 'Proper usage: safemode (ON|OFF|STATUS)'; // Display usage
                                break;
                            case 'ON':
                                require('win-bcd').setKey('safeboot', 'Network');
                                require('win-bcd').enableSafeModeService(svcname);
                                break;
                            case 'OFF':
                                require('win-bcd').deleteKey('safeboot');
                                break;
                            case 'STATUS':
                                var nextboot = require('win-bcd').getKey('safeboot');
                                if (nextboot) {
                                    switch (nextboot) {
                                        case 'Network':
                                        case 'network':
                                            nextboot = 'SAFE_MODE_NETWORK';
                                            break;
                                        default:
                                            nextboot = 'SAFE_MODE';
                                            break;
                                    }
                                }
                                response = 'Current: ' + require('win-bcd').bootMode + ', NextBoot: ' + (nextboot ? nextboot : 'NORMAL');
                                break;
                        }
                    }
                }
                break;
            /*
            case 'border':
                {
                    if ((args['_'].length == 1) && (args['_'][0] == 'on')) {
                        if (meshCoreObj.users.length > 0) {
                            obj.borderManager.Start(meshCoreObj.users[0]);
                            response = 'Border blinking is on.';
                        } else {
                            response = 'Cannot turn on border blinking, no logged in users.';
                        }
                    } else if ((args['_'].length == 1) && (args['_'][0] == 'off')) {
                        obj.borderManager.Stop();
                        response = 'Border blinking is off.';
                    } else {
                        response = 'Proper usage: border "on|off"'; // Display correct command usage
                    }
                }
                break;
            */
            case 'av':
                if (process.platform == 'win32') {
                    // Windows Command: "wmic /Namespace:\\root\SecurityCenter2 Path AntiVirusProduct get /FORMAT:CSV"
                    response = JSON.stringify(require('win-info').av(), null, 1);
                } else {
                    response = 'Not supported on the platform';
                }
                break;
            case 'defender':
                 if (process.platform == 'win32') {
                    // Windows Command: "wmic /Namespace:\\root\SecurityCenter2 Path AntiVirusProduct get /FORMAT:CSV"
                    response = JSON.stringify(require('win-info').defender(), null, 1);
                } else {
                    response = 'Not supported on the platform';
                }
                break;
            case 'log':
                if (args['_'].length != 1) { response = 'Proper usage: log "sample text"'; } else { MeshServerLog(args['_'][0]); response = 'ok'; }
                break;
            case 'getclip':
                if (require('MeshAgent').isService) {
                    require('clipboard').dispatchRead().then(function (str) { sendConsoleText(str, sessionid); });
                } else {
                    require('clipboard').read().then(function (str) { sendConsoleText(str, sessionid); });
                }
                break;
            case 'setclip': {
                if (pendingSetClip) {
                    response = 'Busy';
                } else if (args['_'].length != 1) {
                    response = 'Proper usage: setclip "sample text"';
                } else {
                    if (require('MeshAgent').isService) {
                        if (process.platform != 'win32') {
                            require('clipboard').dispatchWrite(args['_'][0]);
                        }
                        else {
                            var clipargs = args['_'][0];
                            var uid = require('user-sessions').consoleUid();
                            var user = require('user-sessions').getUsername(uid);
                            var domain = require('user-sessions').getDomain(uid);
                            user = (domain + '\\' + user);

                            if (this._dispatcher) { this._dispatcher.close(); }
                            this._dispatcher = require('win-dispatcher').dispatch({ user: user, modules: [{ name: 'clip-dispatch', script: "module.exports = { dispatch: function dispatch(val) { require('clipboard')(val); process.exit(); } };" }], launch: { module: 'clip-dispatch', method: 'dispatch', args: [clipargs] } });
                            this._dispatcher.parent = this;
                            //require('events').setFinalizerMetadata.call(this._dispatcher, 'clip-dispatch');
                            pendingSetClip = true;
                            this._dispatcher.on('connection', function (c) {
                                this._c = c;
                                this._c.root = this.parent;
                                this._c.on('end', function ()
                                {
                                    pendingSetClip = false;
                                    try { this.root._dispatcher.close(); } catch (ex) { }
                                    this.root._dispatcher = null;
                                    this.root = null;
                                });
                            });
                        }
                        response = 'Setting clipboard to: "' + args['_'][0] + '"';
                    }
                    else {
                        require('clipboard')(args['_'][0]); response = 'Setting clipboard to: "' + args['_'][0] + '"';
                    }
                }
                break;
            }
            case 'openurl': {
                if (args['_'].length != 1) { response = 'Proper usage: openurl (url)'; } // Display usage
                else { if (openUserDesktopUrl(args['_'][0]) == null) { response = 'Failed.'; } else { response = 'Success.'; } }
                break;
            }
            case 'openfile': {
                if (args['_'].length != 1) { response = 'Proper usage: openfile (filepath)'; } // Display usage
                else { if (openFileOnDesktop(args['_'][0]) == null) { response = 'Failed.'; } else { response = 'Success.'; } }
                break;
            }
            case 'users': {
                if (meshCoreObj.users == null) { response = 'Active users are unknown.'; } else { response = 'Active Users: ' + meshCoreObj.users.join(', ') + '.'; }
                require('user-sessions').enumerateUsers().then(function (u) { 
                    var ret = getDomainInfo();
                    for (var i in u) { 
                        if (u[i].Domain != null && u[i].Domain == 'AzureAD'){
                            // AzureAD to-do
                            // var userGUID = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'SYSTEM\\CurrentControlSet\\Control\\CloudDomainJoin\\JoinInfo');
                            // if (userGUID != null){
                            //     var user = require('win-registry').QueryKey(require('win-registry').HKEY.LocalMachine, 'SYSTEM\\CurrentControlSet\\Control\\CloudDomainJoin\\JoinInfo\\' + userGUID.subkeys[0], 'UserEmail');
                            //     if (user != null) u[i].UPN = user;
                            // }
                        } else if (u[i].Domain != null) {
                            if (ret != null && ret.PartOfDomain === true) {
                                u[i].UPN = u[i].Username + '@' + ret.Domain;
                            }
                        }
                        sendConsoleText(u[i]);
                    }
                });
                break;
            }
            case 'kvmusers':
                response = JSON.stringify(require('kvm-helper').users(), null, 1);
                break;
            case 'toast': {
                if (args['_'].length < 1) { response = 'Proper usage: toast "message"'; } else {
                    if (require('MeshAgent')._tsid == null) {
                        require('toaster').Toast('MeshCentral', args['_'][0]).then(sendConsoleText, sendConsoleText);
                    }
                    else {
                        require('toaster').Toast('MeshCentral', args['_'][0], require('MeshAgent')._tsid).then(sendConsoleText, sendConsoleText);
                    }
                }
                break;
            }
            case 'setdebug': {
                if (args['_'].length < 1) { response = 'Proper usage: setdebug (target), 0 = Disabled, 1 = StdOut, 2 = This Console, * = All Consoles, 4 = WebLog, 8 = Logfile'; } // Display usage
                else { if (args['_'][0] == '*') { console.setDestination(2); } else { console.setDestination(parseInt(args['_'][0]), sessionid); } }
                break;
            }
            case 'ps': {
                processManager.getProcesses(function (plist) {
                    var x = '';
                    for (var i in plist) { x += i + ((plist[i].user) ? (', ' + plist[i].user) : '') + ', ' + plist[i].cmd + '\r\n'; }
                    sendConsoleText(x, sessionid);
                });
                break;
            }
            case 'kill': {
                if ((args['_'].length < 1)) {
                    response = 'Proper usage: kill [pid]'; // Display correct command usage
                } else {
                    process.kill(parseInt(args['_'][0]));
                    response = 'Killed process ' + args['_'][0] + '.';
                }
                break;
            }
            case 'smbios': {
                if (SMBiosTables == null) { response = 'SMBios tables not available.'; } else { response = objToString(SMBiosTables, 0, ' ', true); }
                break;
            }
            case 'rawsmbios': {
                if (SMBiosTablesRaw == null) { response = 'SMBios tables not available.'; } else {
                    response = '';
                    for (var i in SMBiosTablesRaw) {
                        var header = false;
                        for (var j in SMBiosTablesRaw[i]) {
                            if (SMBiosTablesRaw[i][j].length > 0) {
                                if (header == false) { response += ('Table type #' + i + ((require('smbios').smTableTypes[i] == null) ? '' : (', ' + require('smbios').smTableTypes[i]))) + '\r\n'; header = true; }
                                response += ('  ' + SMBiosTablesRaw[i][j].toString('hex')) + '\r\n';
                            }
                        }
                    }
                }
                break;
            }
            case 'eval': { // Eval JavaScript
                if (args['_'].length < 1) {
                    response = 'Proper usage: eval "JavaScript code"'; // Display correct command usage
                } else {
                    response = JSON.stringify(mesh.eval(args['_'][0])); // This can only be run by trusted administrator.
                }
                break;
            }
            case 'uninstallagent': // Uninstall this agent
                var agentName = process.platform == 'win32' ? 'Mesh Agent' : 'meshagent';
                try {
                    agentName = require('MeshAgent').serviceName;
                } catch (ex) { }

                if (!require('service-manager').manager.getService(agentName).isMe()) {
                    response = 'Uininstall failed, this instance is not the service instance';
                } else {
                    try { diagnosticAgent_uninstall(); } catch (ex) { }
                    var js = "require('service-manager').manager.getService('" + agentName + "').stop(); require('service-manager').manager.uninstallService('" + agentName + "'); process.exit();";
                    this.child = require('child_process').execFile(process.execPath, [process.platform == 'win32' ? (process.execPath.split('\\').pop()) : (process.execPath.split('/').pop()), '-b64exec', Buffer.from(js).toString('base64')], { type: 4, detached: true });
                }
                break;
            case 'notify': { // Send a notification message to the mesh
                if (args['_'].length != 1) {
                    response = 'Proper usage: notify "message" [--session]'; // Display correct command usage
                } else {
                    var notification = { action: 'msg', type: 'notify', value: args['_'][0], tag: 'console' };
                    if (args.session) { notification.sessionid = sessionid; } // If "--session" is specified, notify only this session, if not, the server will notify the mesh
                    mesh.SendCommand(notification); // no sessionid or userid specified, notification will go to the entire mesh
                    response = "ok";
                }
                break;
            }
            case 'cpuinfo': { // Return system information
                // CPU & memory utilization
                pr = require('sysinfo').cpuUtilization();
                pr.sessionid = sessionid;
                pr.then(function (data) {
                    sendConsoleText(JSON.stringify(
                        {
                            cpu: data,
                            memory: require('sysinfo').memUtilization(),
                            thermals: require('sysinfo').thermals == null ? [] : require('sysinfo').thermals()
                        }, null, 1), this.sessionid);
                }, function (e) {
                    sendConsoleText(e);
                });
                break;
            }
            case 'sysinfo': { // Return system information
                getSystemInformation(function (results, err) {
                    if (results == null) {
                        sendConsoleText(err, this.sessionid);
                    } else {
                        sendConsoleText(JSON.stringify(results, null, 1), this.sessionid);
                        mesh.SendCommand({ action: 'sysinfo', sessionid: this.sessionid, data: results });
                    }
                });
                break;
            }
            case 'info': { // Return information about the agent and agent core module
                response = 'Current Core: ' + meshCoreObj.value + '\r\nAgent Time: ' + Date() + '.\r\nUser Rights: 0x' + rights.toString(16) + '.\r\nPlatform: ' + process.platform + '.\r\nCapabilities: ' + meshCoreObj.caps + '.\r\nServer URL: ' + mesh.ServerUrl + '.';
                if (amt != null) { response += '\r\nBuilt-in LMS: ' + ['Disabled', 'Connecting..', 'Connected'][amt.lmsstate] + '.'; }
                if (meshCoreObj.osdesc) { response += '\r\nOS: ' + meshCoreObj.osdesc + '.'; }
                response += '\r\nModules: ' + addedModules.join(', ') + '.';
                response += '\r\nServer Connection: ' + mesh.isControlChannelConnected + ', State: ' + meshServerConnectionState + '.';
                var oldNodeId = db.Get('OldNodeId');
                if (oldNodeId != null) { response += '\r\nOldNodeID: ' + oldNodeId + '.'; }
                response += '\r\nNode ID: ' + Buffer.from(require('_agentNodeId')(), 'hex').toString('base64').replace(/\+/g, '@').replace(/\//g, '$');
                if (process.platform == 'linux' || process.platform == 'freebsd') { response += '\r\nX11 support: ' + require('monitor-info').kvm_x11_support + '.'; }
                response += '\r\nApplication Location: ' + process.cwd();
                //response += '\r\Debug Console: ' + debugConsole + '.';
                break;
            }
            case 'osinfo': { // Return the operating system information
                var i = 1;
                if (args['_'].length > 0) { i = parseInt(args['_'][0]); if (i > 8) { i = 8; } response = 'Calling ' + i + ' times.'; }
                for (var j = 0; j < i; j++) {
                    var pr = require('os').name();
                    pr.sessionid = sessionid;
                    pr.then(function (v) {
                        sendConsoleText("OS: " + v + (process.platform == 'win32' ? (require('win-virtual-terminal').supported ? ' [ConPTY: YES]' : ' [ConPTY: NO]') : ''), this.sessionid);
                    });
                }
                break;
            }
            case 'args': { // Displays parsed command arguments
                response = 'args ' + objToString(args, 0, ' ', true);
                break;
            }
            case 'print': { // Print a message on the mesh agent console, does nothing when running in the background
                var r = [];
                for (var i in args['_']) { r.push(args['_'][i]); }
                console.log(r.join(' '));
                response = 'Message printed on agent console.';
                break;
            }
            case 'type': { // Returns the content of a file
                if (args['_'].length == 0) {
                    response = 'Proper usage: type (filepath) [maxlength]'; // Display correct command usage
                } else {
                    var max = 4096;
                    if ((args['_'].length > 1) && (typeof args['_'][1] == 'number')) { max = args['_'][1]; }
                    if (max > 4096) max = 4096;
                    var buf = Buffer.alloc(max), fd = fs.openSync(args['_'][0], "r"), r = fs.readSync(fd, buf, 0, max); // Read the file content
                    response = buf.toString();
                    var i = response.indexOf('\n');
                    if ((i > 0) && (response[i - 1] != '\r')) { response = response.split('\n').join('\r\n'); }
                    if (r == max) response += '...';
                    fs.closeSync(fd);
                }
                break;
            }
            case 'dbkeys': { // Return all data store keys
                response = JSON.stringify(db.Keys);
                break;
            }
            case 'dbget': { // Return the data store value for a given key
                if (db == null) { response = 'Database not accessible.'; break; }
                if (args['_'].length != 1) {
                    response = 'Proper usage: dbget (key)'; // Display the value for a given database key
                } else {
                    response = db.Get(args['_'][0]);
                }
                break;
            }
            case 'dbset': { // Set a data store key and value pair
                if (db == null) { response = 'Database not accessible.'; break; }
                if (args['_'].length != 2) {
                    response = 'Proper usage: dbset (key) (value)'; // Set a database key
                } else {
                    var r = db.Put(args['_'][0], args['_'][1]);
                    response = 'Key set: ' + r;
                }
                break;
            }
            case 'dbcompact': { // Compact the data store
                if (db == null) { response = 'Database not accessible.'; break; }
                var r = db.Compact();
                response = 'Database compacted: ' + r;
                break;
            }
            case 'httpget': {
                if (consoleHttpRequest != null) {
                    response = 'HTTP operation already in progress.';
                } else {
                    if (args['_'].length != 1) {
                        response = 'Proper usage: httpget (url)';
                    } else {
                        var options = http.parseUri(args['_'][0]);
                        options.method = 'GET';
                        if (options == null) {
                            response = 'Invalid url.';
                        } else {
                            try { consoleHttpRequest = http.request(options, consoleHttpResponse); } catch (ex) { response = 'Invalid HTTP GET request'; }
                            consoleHttpRequest.sessionid = sessionid;
                            if (consoleHttpRequest != null) {
                                consoleHttpRequest.end();
                                response = 'HTTPGET ' + options.protocol + '//' + options.host + ':' + options.port + options.path;
                            }
                        }
                    }
                }
                break;
            }
            case 'wslist': { // List all web sockets
                response = '';
                for (var i in consoleWebSockets) {
                    var httprequest = consoleWebSockets[i];
                    response += 'Websocket #' + i + ', ' + httprequest.url + '\r\n';
                }
                if (response == '') { response = 'no websocket sessions.'; }
                break;
            }
            case 'wsconnect': { // Setup a web socket
                if (args['_'].length == 0) {
                    response = 'Proper usage: wsconnect (url)\r\nFor example: wsconnect wss://localhost:443/meshrelay.ashx?id=abc'; // Display correct command usage
                } else {
                    var httprequest = null;
                    try {
                        var options = http.parseUri(args['_'][0].split('$').join('%24').split('@').join('%40')); // Escape the $ and @ characters in the URL
                        options.rejectUnauthorized = 0;
                        httprequest = http.request(options);
                    } catch (ex) { response = 'Invalid HTTP websocket request'; }
                    if (httprequest != null) {
                        httprequest.upgrade = onWebSocketUpgrade;
                        httprequest.on('error', function (e) { sendConsoleText("ERROR: Unable to connect to: " + this.url + ", " + JSON.stringify(e)); });

                        var index = 1;
                        while (consoleWebSockets[index]) { index++; }
                        httprequest.sessionid = sessionid;
                        httprequest.index = index;
                        httprequest.url = args['_'][0];
                        consoleWebSockets[index] = httprequest;
                        response = 'New websocket session #' + index;
                    }
                }
                break;
            }
            case 'wssend': { // Send data on a web socket
                if (args['_'].length == 0) {
                    response = 'Proper usage: wssend (socketnumber)\r\n'; // Display correct command usage
                    for (var i in consoleWebSockets) {
                        var httprequest = consoleWebSockets[i];
                        response += 'Websocket #' + i + ', ' + httprequest.url + '\r\n';
                    }
                } else {
                    var i = parseInt(args['_'][0]);
                    var httprequest = consoleWebSockets[i];
                    if (httprequest != undefined) {
                        httprequest.s.write(args['_'][1]);
                        response = 'ok';
                    } else {
                        response = 'Invalid web socket number';
                    }
                }
                break;
            }
            case 'wsclose': { // Close a websocket
                if (args['_'].length == 0) {
                    response = 'Proper usage: wsclose (socketnumber)'; // Display correct command usage
                } else {
                    var i = parseInt(args['_'][0]);
                    var httprequest = consoleWebSockets[i];
                    if (httprequest != undefined) {
                        if (httprequest.s != null) { httprequest.s.end(); } else { httprequest.end(); }
                        response = 'ok';
                    } else {
                        response = 'Invalid web socket number';
                    }
                }
                break;
            }
            case 'tunnels': { // Show the list of current tunnels
                response = '';
                for (var i in tunnels) {
                    response += 'Tunnel #' + i + ', ' + tunnels[i].protocol; //tunnels[i].url
                    if (tunnels[i].userid) { response += ', ' + tunnels[i].userid; }
                    if (tunnels[i].guestname) { response += '/' + tunnels[i].guestname; }
                    response += '\r\n'
                }
                if (response == '') { response = 'No websocket sessions.'; }
                break;
            }
            case 'ls': { // Show list of files and folders
                response = '';
                var xpath = '*';
                if (args['_'].length > 0) { xpath = obj.path.join(args['_'][0], '*'); }
                response = 'List of ' + xpath + '\r\n';
                var results = fs.readdirSync(xpath);
                for (var i = 0; i < results.length; ++i) {
                    var stat = null, p = obj.path.join(args['_'][0], results[i]);
                    try { stat = fs.statSync(p); } catch (ex) { }
                    if ((stat == null) || (stat == undefined)) {
                        response += (results[i] + "\r\n");
                    } else {
                        response += (results[i] + " " + ((stat.isDirectory()) ? "(Folder)" : "(File)") + "\r\n");
                    }
                }
                break;
            }
            case 'lsx': { // Show list of files and folders
                response = objToString(getDirectoryInfo(args['_'][0]), 0, ' ', true);
                break;
            }
            case 'lock': { // Lock the current user out of the desktop
                lockDesktop();
                break;
            }
            case 'amt': { // Show Intel AMT status
                if (amt != null) {
                    amt.getMeiState(9, function (state) {
                        var resp = "Intel AMT not detected.";
                        if (state != null) { resp = objToString(state, 0, ' ', true); }
                        sendConsoleText(resp, sessionid);
                    });
                } else {
                    response = "Intel AMT not detected.";
                }
                break;
            }
            case 'netinfo': { // Show network interface information
                var interfaces = require('os').networkInterfaces();
                if (process.platform == 'win32') {
                    try {
                        var ret = require('win-wmi').query('ROOT\\CIMV2', 'SELECT InterfaceIndex,NetConnectionID,Speed FROM Win32_NetworkAdapter', ['InterfaceIndex','NetConnectionID','Speed']);
                        if (ret[0]) {
                            var speedMap = {};
                            for (var i = 0; i < ret.length; i++) speedMap[ret[i].InterfaceIndex] = ret[i].Speed;
                            var adapterNames = Object.keys(interfaces);
                            for (var j = 0; j < adapterNames.length; j++) {
                                var theinterfaces = interfaces[adapterNames[j]];
                                for (var k = 0; k < theinterfaces.length; k++) {
                                    var iface = theinterfaces[k], speed = speedMap[iface.index] || 0;
                                    iface.speed = parseInt(speed); // bits per seconds
                                }
                            }
                        }
                    } catch(ex) { }
                } else if (process.platform == 'linux') {
                    var adapterNames = Object.keys(interfaces);
                    for (var i = 0; i < adapterNames.length; i++) {
                        var ifaceName = adapterNames[i];
                        try {
                            var speedStr = require('fs').readFileSync('/sys/class/net/' + ifaceName + '/speed').toString();
                            if ((speedStr.trim() != "") && (speedStr.trim() != "-1")) {
                                var theinterfaces = interfaces[ifaceName];
                                for (var k = 0; k < theinterfaces.length; k++) {
                                    var iface = theinterfaces[k];
                                    iface.speed = parseInt(speedStr) * 1000000; // bits per seconds
                                }
                            }
                        } catch(ex) { }
                    }
                }
                response = objToString(interfaces, 0, ' ', true);
                break;
            }
            case 'wakeonlan': { // Send wake-on-lan
                if ((args['_'].length != 1) || (args['_'][0].length != 12)) {
                    response = 'Proper usage: wakeonlan [mac], for example "wakeonlan 010203040506".';
                } else {
                    var count = sendWakeOnLanEx([args['_'][0]]);
                    sendWakeOnLanEx([args['_'][0]]);
                    sendWakeOnLanEx([args['_'][0]]);
                    response = 'Sending wake-on-lan on ' + count + ' interface(s).';
                }
                break;
            }
            case 'display': {
                 if (args['_'].length != 1) {
                    response = 'Proper usage: display (sleep | awake)';
                } else {
                    var sleepawake = [args['_'][0]];
                    if(sleepawake=='sleep'){
                        require('power-monitor').sleepDisplay()
                    }else if(sleepawake=='awake'){
                        require('power-monitor').wakeDisplay()

                    }
                    response = 'Setting Display To ' + sleepawake;
                }
                break;
            }
            case 'sendall': { // Send a message to all consoles on this mesh
                sendConsoleText(args['_'].join(' '));
                break;
            }
            case 'power': { // Execute a power action on this computer
                if (mesh.ExecPowerState == undefined) {
                    response = 'Power command not supported on this agent.';
                } else {
                    if ((args['_'].length == 0) || isNaN(Number(args['_'][0]))) {
                        response = 'Proper usage: power (actionNumber), where actionNumber is:\r\n  LOGOFF = 1\r\n  SHUTDOWN = 2\r\n  REBOOT = 3\r\n  SLEEP = 4\r\n  HIBERNATE = 5\r\n  DISPLAYON = 6\r\n  KEEPAWAKE = 7\r\n  BEEP = 8\r\n  CTRLALTDEL = 9\r\n  VIBRATE = 13\r\n  FLASH = 14'; // Display correct command usage
                    } else {
                        var r = mesh.ExecPowerState(Number(args['_'][0]), Number(args['_'][1]));
                        response = 'Power action executed with return code: ' + r + '.';
                    }
                }
                break;
            }
            case 'location': {
                getIpLocationData(function (location) {
                    sendConsoleText(objToString({ action: 'iplocation', type: 'publicip', value: location }, 0, ' '));
                });
                break;
            }
            case 'parseuri': {
                response = JSON.stringify(http.parseUri(args['_'][0]));
                break;
            }
            case 'scanwifi': {
                if (wifiScanner != null) {
                    var wifiPresent = wifiScanner.hasWireless;
                    if (wifiPresent) { response = "Perfoming Wifi scan..."; wifiScanner.Scan(); } else { response = "Wifi absent."; }
                } else
                { response = "Wifi module not present."; }
                break;
            }
            case 'modules': {
                response = JSON.stringify(addedModules);
                break;
            }
            case 'listservices': {
                var services = require('service-manager').manager.enumerateService();
                response = JSON.stringify(services, null, 1);
                break;
            }
            case 'getscript': {
                if (args['_'].length != 1) {
                    response = "Proper usage: getscript [scriptNumber].";
                } else {
                    mesh.SendCommand({ action: 'getScript', type: args['_'][0] });
                }
                break;
            }
            case 'diagnostic':
                {
                    if (!mesh.DAIPC.listening) {
                        response = 'Unable to bind to Diagnostic IPC, most likely because the path (' + process.cwd() + ') is not on a local file system';
                        break;
                    }
                    var diag = diagnosticAgent_installCheck();
                    if (diag) {
                        if (args['_'].length == 1 && args['_'][0] == 'uninstall') {
                            diagnosticAgent_uninstall();
                            response = 'Diagnostic Agent uninstalled';
                        }
                        else {
                            response = 'Diagnostic Agent installed at: ' + diag.appLocation();
                        }
                    }
                    else {
                        if (args['_'].length == 1 && args['_'][0] == 'install') {
                            diag = diagnosticAgent_installCheck(true);
                            if (diag) {
                                response = 'Diagnostic agent was installed at: ' + diag.appLocation();
                            }
                            else {
                                response = 'Diagnostic agent installation failed';
                            }
                        }
                        else {
                            response = 'Diagnostic Agent Not installed. To install: diagnostic install';
                        }
                    }
                    if (diag) { diag.close(); diag = null; }
                    break;
                }
            case 'amtevents': {
                if ((args['_'].length == 1) && (args['_'][0] == 'on')) { obj.showamtevent = true; response = 'Intel AMT configuration events live view enabled.'; }
                else if ((args['_'].length == 1) && (args['_'][0] == 'off')) { delete obj.showamtevent; response = 'Intel AMT configuration events live view disabled.'; }
                else if (obj.amtevents == null) { response = 'No events.'; } else { response = obj.amtevents.join('\r\n'); }
                break;
            }
            case 'amtconfig': {
                if (amt == null) { response = 'Intel AMT not detected.'; break; }
                if (!obj.showamtevent) { obj.showamtevent = true; require('MeshAgent').SendCommand({ action: 'msg', type: 'console', value: 'Enabled live view of Intel AMT configuration events, \"amtevents off\" to disable.' }); }
                if (apftunnel != null) { response = 'Intel AMT server tunnel already active'; break; }
                require('MeshAgent').SendCommand({ action: 'amtconfig' }); // Request that the server give us a server authentication cookie to start the APF session.
                break;
            }
            case 'apf': {
                if (meshCoreObj.intelamt !== null) {
                    if (args['_'].length == 1) {
                        var connType = -1, connTypeStr = args['_'][0].toLowerCase();
                        if (connTypeStr == 'lms') { connType = 2; }
                        if (connTypeStr == 'relay') { connType = 1; }
                        if (connTypeStr == 'cira') { connType = 0; }
                        if (connTypeStr == 'off') { connType = -2; }
                        if (connType >= 0) { // Connect
                            var apfarg = {
                                mpsurl: mesh.ServerUrl.replace('agent.ashx', 'apf.ashx'),
                                mpsuser: Buffer.from(mesh.ServerInfo.MeshID, 'hex').toString('base64').substring(0, 16).replace(/\+/g, '@').replace(/\//g, '$'),
                                mpspass: Buffer.from(mesh.ServerInfo.MeshID, 'hex').toString('base64').substring(0, 16).replace(/\+/g, '@').replace(/\//g, '$'),
                                mpskeepalive: 60000,
                                clientname: require('os').hostname(),
                                clientaddress: '127.0.0.1',
                                clientuuid: meshCoreObj.intelamt.UUID,
                                conntype: connType // 0 = CIRA, 1 = Relay, 2 = LMS. The correct value is 2 since we are performing an LMS relay, other values for testing.
                            };
                            if ((apfarg.clientuuid == null) || (apfarg.clientuuid.length != 36)) {
                                response = "Unable to get Intel AMT UUID: " + apfarg.clientuuid;
                            } else {
                                apftunnel = require('amt-apfclient')({ debug: false }, apfarg);
                                apftunnel.onJsonControl = handleApfJsonControl;
                                apftunnel.onChannelClosed = function () { apftunnel = null; }
                                try {
                                    apftunnel.connect();
                                    response = "Started APF tunnel";
                                } catch (ex) {
                                    response = JSON.stringify(ex);
                                }
                            }
                        } else if (connType == -2) { // Disconnect
                            try {
                                apftunnel.disconnect();
                                response = "Stopped APF tunnel";
                            } catch (ex) {
                                response = JSON.stringify(ex);
                            }
                            apftunnel = null;
                        } else {
                            response = "Invalid command.\r\nUse: apf lms|relay|cira|off";
                        }
                    } else {
                        response = "APF tunnel is " + (apftunnel == null ? "off" : "on") + "\r\nUse: apf lms|relay|cira|off";
                    }
                } else {
                    response = "APF tunnel requires Intel AMT";
                }
                break;
            }
            case 'plugin': {
                if (typeof args['_'][0] == 'string') {
                    try {
                        // Pass off the action to the plugin
                        // for plugin creators, you'll want to have a plugindir/modules_meshcore/plugin.js
                        // to control the output / actions here.
                        response = require(args['_'][0]).consoleaction(args, rights, sessionid, mesh);
                    } catch (ex) {
                        response = "There was an error in the plugin (" + ex + ")";
                    }
                } else {
                    response = "Proper usage: plugin [pluginName] [args].";
                }
                break;
            }
            case 'installedapps': {
                if(process.platform == 'win32'){
                    require('win-info').installedApps().then(function (apps){ sendConsoleText(JSON.stringify(apps,null,1)); });
                }
                break;
            }
            case 'installedstoreapps': {
                if(process.platform == 'win32'){
                    var apps = require('win-info').installedStoreApps();
                    if (apps[0]) {
                        sendConsoleText(JSON.stringify(apps,null,1));
                    };
                }
                break;
            }
            case 'qfe': {
                if(process.platform == 'win32'){
                    var qfe = require('win-info').qfe();
                    sendConsoleText(JSON.stringify(qfe,null,1));
                }
                break;
            }
            default: { // This is an unknown command, return an error message
                response = "Unknown command \"" + cmd + "\", type \"help\" for list of available commands.";
                break;
            }
        }
    } catch (ex) { response = "Command returned an exception error: " + ex; console.log(ex); }
    if (response != null) { sendConsoleText(response, sessionid); }
}

// Send a mesh agent console command
function sendConsoleText(text, sessionid) {
    if (typeof text == 'object') { text = JSON.stringify(text); }
    if (debugConsole && ((sessionid == null) || (sessionid == 'pipe'))) { broadcastToRegisteredApps({ cmd: 'console', value: text }); }
    if (sessionid != 'pipe') { require('MeshAgent').SendCommand({ action: 'msg', type: 'console', value: text, sessionid: sessionid }); }
}

function removeAgentMessage(msgid) {
    var ret = false;
    if (msgid == null) {
        // Delete all messages
        sendAgentMessage.messages = [];
        ret = true;
    }
    else {
        var i = sendAgentMessage.messages.findIndex(function (v) { return (v.id == msgid); });
        if (i >= 0) {
            sendAgentMessage.messages.splice(i, 1);
            ret = true;
        }
    }
    if (ret) { sendAgentMessage(); }
    return (ret);
}

// Send a mesh agent message to server, placing a bubble/badge on the agent device
function sendAgentMessage(msg, icon, serverid, first) {
    if (sendAgentMessage.messages == null) {
        sendAgentMessage.messages = [];
    }

    if (arguments.length > 0) {
        if (first == null || (serverid && first && sendAgentMessage.messages.findIndex(function (v) { return (v.msgid == serverid); }) < 0)) {
            sendAgentMessage.messages.push({ msg: msg, icon: icon, msgid: serverid });
            sendAgentMessage.messages.peek().id = sendAgentMessage.messages.peek()._hashCode();
        }
    }

    var p = {}, i;
    for (i = 0; i < sendAgentMessage.messages.length; ++i) {
        p[i] = sendAgentMessage.messages[i];
    }
    try {
        require('MeshAgent').SendCommand({ action: 'sessions', type: 'msg', value: p });
    } catch (ex) { }
    return (arguments.length > 0 ? sendAgentMessage.messages.peek().id : sendAgentMessage.messages);
}
function getOpenDescriptors() {
    var r = [];
    switch (process.platform) {
        case "freebsd": {
            var child = require('child_process').execFile('/bin/sh', ['sh']);
            child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
            child.stderr.on('data', function (c) { });

            child.stdin.write("procstat -f " + process.pid + " | tr '\\n' '`' | awk -F'`' '");
            child.stdin.write('{');
            child.stdin.write('   DEL="";');
            child.stdin.write('   printf "[";');
            child.stdin.write('   for(i=1;i<NF;++i)');
            child.stdin.write('   {');
            child.stdin.write('      A=split($i,B," ");');
            child.stdin.write('      if(B[3] ~ /^[0-9]/)');
            child.stdin.write('      {');
            child.stdin.write('         printf "%s%s", DEL, B[3];');
            child.stdin.write('         DEL=",";');
            child.stdin.write('      }');
            child.stdin.write('   }');
            child.stdin.write('   printf "]";');
            child.stdin.write("}'");

            child.stdin.write('\nexit\n');
            child.waitExit();

            try { r = JSON.parse(child.stdout.str.trim()); } catch (ex) { }
            break;
        }
        case "linux": {
            var child = require('child_process').execFile('/bin/sh', ['sh']);
            child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
            child.stderr.on('data', function (c) { });

            child.stdin.write("ls /proc/" + process.pid + "/fd | tr '\\n' '`' | awk -F'`' '");
            child.stdin.write('{');
            child.stdin.write('   printf "[";');
            child.stdin.write('   DEL="";');
            child.stdin.write('   for(i=1;i<NF;++i)');
            child.stdin.write('   {');
            child.stdin.write('      printf "%s%s",DEL,$i;');
            child.stdin.write('      DEL=",";');
            child.stdin.write('   }');
            child.stdin.write('   printf "]";');
            child.stdin.write("}'");
            child.stdin.write('\nexit\n');
            child.waitExit();

            try { r = JSON.parse(child.stdout.str.trim()); } catch (ex) { }
            break;
        }
    }
    return r;
}
function closeDescriptors(libc, descriptors) {
    var fd = null;
    while (descriptors.length > 0) {
        fd = descriptors.pop();
        if (fd > 2) {
            libc.close(fd);
        }
    }
}
function linux_execv(name, agentfilename, sessionid) {
    var libs = require('monitor-info').getLibInfo('libc');
    var libc = null;

    if ((libs.length == 0 || libs.length == null) && require('MeshAgent').ARCHID == 33) {
        var child = require('child_process').execFile('/bin/sh', ['sh']);
        child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
        child.stderr.str = ''; child.stderr.on('data', function (c) { this.str += c.toString(); });
        child.stdin.write("ls /lib/libc.* | tr '\\n' '`' | awk -F'`' '{ " + ' printf "["; DEL=""; for(i=1;i<NF;++i) { printf "%s{\\"path\\":\\"%s\\"}",DEL,$i; DEL=""; } printf "]"; }\'\nexit\n');
        child.waitExit();

        try {
            libs = JSON.parse(child.stdout.str.trim());
        } catch (ex) { }
    }

    while (libs.length > 0) {
        try {
            libc = require('_GenericMarshal').CreateNativeProxy(libs.pop().path);
            break;
        } catch (ex) {
            libc = null;
            continue;
        }
    }
    if (libc != null) {
        try {
            libc.CreateMethod('execv');
            libc.CreateMethod('close');
        } catch (ex) {
            libc = null;
        }
    }

    if (libc == null) {
        // Couldn't find libc.so, fallback to using service manager to restart agent
        if (sessionid != null) { sendConsoleText('Restarting service via service-manager...', sessionid) }
        try {
            // restart service
            var s = require('service-manager').manager.getService(name);
            s.restart();
        } catch (ex) {
            sendConsoleText('Self Update encountered an error trying to restart service', sessionid);
            sendAgentMessage('Self Update encountered an error trying to restart service', 3);
        }
        return;
    }

    if (sessionid != null) { sendConsoleText('Restarting service via execv()...', sessionid) }

    var i;
    var args;
    var argarr = [process.execPath];
    var argtmp = [];
    var path = require('_GenericMarshal').CreateVariable(process.execPath);

    if (require('MeshAgent').getStartupOptions != null) {
        var options = require('MeshAgent').getStartupOptions();
        for (i in options) {
            argarr.push('--' + i + '="' + options[i] + '"');
        }
    }

    args = require('_GenericMarshal').CreateVariable((1 + argarr.length) * require('_GenericMarshal').PointerSize);
    for (i = 0; i < argarr.length; ++i) {
        var arg = require('_GenericMarshal').CreateVariable(argarr[i]);
        argtmp.push(arg);
        arg.pointerBuffer().copy(args.toBuffer(), i * require('_GenericMarshal').PointerSize);
    }

    var descriptors = getOpenDescriptors();
    closeDescriptors(libc, descriptors);

    libc.execv(path, args);
    if (sessionid != null) { sendConsoleText('Self Update failed because execv() failed', sessionid) }
    sendAgentMessage('Self Update failed because execv() failed', 3);
}

function bsd_execv(name, agentfilename, sessionid) {
    var child = require('child_process').execFile('/bin/sh', ['sh']);
    child.stdout.str = ''; child.stdout.on('data', function (c) { this.str += c.toString(); });
    child.stderr.str = ''; child.stderr.on('data', function (c) { this.str += c.toString(); });
    child.stdin.write("cat /usr/lib/libc.so | awk '");
    child.stdin.write('{');
    child.stdin.write(' a=split($0, tok, "(");');
    child.stdin.write(' if(a>1)');
    child.stdin.write(' {');
    child.stdin.write('     split(tok[2], b, ")");');
    child.stdin.write('     split(b[1], c, " ");');
    child.stdin.write('     print c[1];');
    child.stdin.write(' }');
    child.stdin.write("}'\nexit\n");
    child.waitExit();
    if (child.stdout.str.trim() == '') {
        if (sessionid != null) { sendConsoleText('Self Update failed because cannot find libc.so', sessionid) }
        sendAgentMessage('Self Update failed because cannot find libc.so', 3);
        return;
    }

    var libc = null;
    try {
        libc = require('_GenericMarshal').CreateNativeProxy(child.stdout.str.trim());
        libc.CreateMethod('execv');
        libc.CreateMethod('close');
    } catch (ex) {
        if (sessionid != null) { sendConsoleText('Self Update failed: ' + ex.toString(), sessionid) }
        sendAgentMessage('Self Update failed: ' + ex.toString(), 3);
        return;
    }

    var path = require('_GenericMarshal').CreateVariable(process.execPath);
    var argarr = [process.execPath];
    var args, i, argtmp = [];
    var options = require('MeshAgent').getStartupOptions();
    for (i in options) {
        argarr.push('--' + i + '="' + options[i] + '"');
    }
    args = require('_GenericMarshal').CreateVariable((1 + argarr.length) * require('_GenericMarshal').PointerSize);
    for (i = 0; i < argarr.length; ++i) {
        var arg = require('_GenericMarshal').CreateVariable(argarr[i]);
        argtmp.push(arg);
        arg.pointerBuffer().copy(args.toBuffer(), i * require('_GenericMarshal').PointerSize);
    }

    if (sessionid != null) { sendConsoleText('Restarting service via execv()', sessionid) }

    var descriptors = getOpenDescriptors();
    closeDescriptors(libc, descriptors);

    libc.execv(path, args);
    if (sessionid != null) { sendConsoleText('Self Update failed because execv() failed', sessionid) }
    sendAgentMessage('Self Update failed because execv() failed', 3);
}

function windows_execve(name, agentfilename, sessionid) {
    var libc;
    try {
        libc = require('_GenericMarshal').CreateNativeProxy('msvcrt.dll');
        libc.CreateMethod('_wexecve');
    } catch (ex) {
        sendConsoleText('Self Update failed because msvcrt.dll is missing', sessionid);
        sendAgentMessage('Self Update failed because msvcrt.dll is missing', 3);
        return;
    }
    
    var cmd = require('_GenericMarshal').CreateVariable(process.env['windir'] + '\\system32\\cmd.exe', { wide: true });
    var args = require('_GenericMarshal').CreateVariable(3 * require('_GenericMarshal').PointerSize);
    var arg1 = require('_GenericMarshal').CreateVariable('cmd.exe', { wide: true });
    var arg2 = require('_GenericMarshal').CreateVariable('/C net stop "' + name + '" & "' + process.cwd() + agentfilename + '.update.exe" -b64exec ' + 'dHJ5CnsKICAgIHZhciBzZXJ2aWNlTG9jYXRpb24gPSBwcm9jZXNzLmFyZ3YucG9wKCkudG9Mb3dlckNhc2UoKTsKICAgIHJlcXVpcmUoJ3Byb2Nlc3MtbWFuYWdlcicpLmVudW1lcmF0ZVByb2Nlc3NlcygpLnRoZW4oZnVuY3Rpb24gKHByb2MpCiAgICB7CiAgICAgICAgZm9yICh2YXIgcCBpbiBwcm9jKQogICAgICAgIHsKICAgICAgICAgICAgaWYgKHByb2NbcF0ucGF0aCAmJiAocHJvY1twXS5wYXRoLnRvTG93ZXJDYXNlKCkgPT0gc2VydmljZUxvY2F0aW9uKSkKICAgICAgICAgICAgewogICAgICAgICAgICAgICAgcHJvY2Vzcy5raWxsKHByb2NbcF0ucGlkKTsKICAgICAgICAgICAgfQogICAgICAgIH0KICAgICAgICBwcm9jZXNzLmV4aXQoKTsKICAgIH0pOwp9CmNhdGNoIChlKQp7CiAgICBwcm9jZXNzLmV4aXQoKTsKfQ==' +
        ' "' + process.execPath + '" & copy "' + process.cwd() + agentfilename + '.update.exe" "' + process.execPath + '" & net start "' + name + '" & erase "' + process.cwd() + agentfilename + '.update.exe"', { wide: true });

    arg1.pointerBuffer().copy(args.toBuffer());
    arg2.pointerBuffer().copy(args.toBuffer(), require('_GenericMarshal').PointerSize);

    libc._wexecve(cmd, args, 0);
}

// Start a JavaScript based Agent Self-Update
function agentUpdate_Start(updateurl, updateoptions) {
    // If this value is null
    var sessionid = (updateoptions != null) ? updateoptions.sessionid : null; // If this is null, messages will be broadcast. Otherwise they will be unicasted

    // If the url starts with *, switch it to use the same protoco, host and port as the control channel.
    if (updateurl != null) {
        updateurl = getServerTargetUrlEx(updateurl);
        if (updateurl.startsWith("wss://")) { updateurl = "https://" + updateurl.substring(6); }
    }

    if (agentUpdate_Start._selfupdate != null) {
        // We were already called, so we will ignore this duplicate request
        if (sessionid != null) { sendConsoleText('Self update already in progress...', sessionid); }
    }
    else {
        if (agentUpdate_Start._retryCount == null) { agentUpdate_Start._retryCount = 0; }
        if (require('MeshAgent').ARCHID == null && updateurl == null) {
            // This agent doesn't have the ability to tell us which ARCHID it is, so we don't know which agent to pull
            sendConsoleText('Unable to initiate update, agent ARCHID is not defined', sessionid);
        }
        else {
            var agentfilename = process.execPath.split(process.platform == 'win32' ? '\\' : '/').pop(); // Local File Name, ie: MeshAgent.exe
            var name = require('MeshAgent').serviceName;
            if (name == null) { name = (process.platform == 'win32' ? 'Mesh Agent' : 'meshagent'); } // This is an older agent that doesn't expose the service name, so use the default
            try {
                var s = require('service-manager').manager.getService(name);
                if (!s.isMe()) {
                    if (process.platform == 'win32') { s.close(); }
                    sendConsoleText('Self Update cannot continue, this agent is not an instance of (' + name + ')', sessionid);
                    return;
                }
                if (process.platform == 'win32') { s.close(); }
            }
            catch (ex) {
                sendConsoleText('Self Update Failed because this agent is not an instance of (' + name + ')', sessionid);
                sendAgentMessage('Self Update Failed because this agent is not an instance of (' + name + ')', 3);
                return;
            }

            if ((sessionid != null) && (updateurl != null)) { sendConsoleText('Downloading update from: ' + updateurl, sessionid); }
            var options = require('http').parseUri(updateurl != null ? updateurl : require('MeshAgent').ServerUrl);
            options.protocol = 'https:';
            if (updateurl == null) { options.path = ('/meshagents?id=' + require('MeshAgent').ARCHID); sendConsoleText('Downloading update from: ' + options.path, sessionid); }
            options.rejectUnauthorized = false;
            options.checkServerIdentity = function checkServerIdentity(certs) {
                // If the tunnel certificate matches the control channel certificate, accept the connection
                try { if (require('MeshAgent').ServerInfo.ControlChannelCertificate.digest == certs[0].digest) return; } catch (ex) { }
                try { if (require('MeshAgent').ServerInfo.ControlChannelCertificate.fingerprint == certs[0].fingerprint) return; } catch (ex) { }

                // Check that the certificate is the one expected by the server, fail if not.
                if (checkServerIdentity.servertlshash == null) {
                    if (require('MeshAgent').ServerInfo == null || require('MeshAgent').ServerInfo.ControlChannelCertificate == null) { return; }
                    sendConsoleText('Self Update failed, because the url cannot be verified: ' + updateurl, sessionid);
                    sendAgentMessage('Self Update failed, because the url cannot be verified: ' + updateurl, 3);
                    throw new Error('BadCert');
                }
                if (certs[0].digest == null) { return; }
                if ((checkServerIdentity.servertlshash != null) && (checkServerIdentity.servertlshash.toLowerCase() != certs[0].digest.split(':').join('').toLowerCase())) {
                    sendConsoleText('Self Update failed, because the supplied certificate does not match', sessionid);
                    sendAgentMessage('Self Update failed, because the supplied certificate does not match', 3);
                    throw new Error('BadCert')
                }
            }
            options.checkServerIdentity.servertlshash = (updateoptions != null ? updateoptions.tlshash : null);
            agentUpdate_Start._selfupdate = require('https').get(options);
            agentUpdate_Start._selfupdate.on('error', function (e) {
                sendConsoleText('Self Update failed, because there was a problem trying to download the update from ' + updateurl, sessionid);
                sendAgentMessage('Self Update failed, because there was a problem trying to download the update from ' + updateurl, 3);
                agentUpdate_Start._selfupdate = null;
            });
            agentUpdate_Start._selfupdate.on('response', function (img) {
                this._file = require('fs').createWriteStream(agentfilename + (process.platform == 'win32' ? '.update.exe' : '.update'), { flags: 'wb' });
                this._filehash = require('SHA384Stream').create();
                this._filehash.on('hash', function (h) {
                    if (updateoptions != null && updateoptions.hash != null) {
                        if (updateoptions.hash.toLowerCase() == h.toString('hex').toLowerCase()) {
                            if (sessionid != null) { sendConsoleText('Download complete. HASH verified.', sessionid); }
                        } else {
                            agentUpdate_Start._retryCount++;
                            sendConsoleText('Self Update FAILED because the downloaded agent FAILED hash check (' + agentUpdate_Start._retryCount + '), URL: ' + updateurl, sessionid);
                            sendConsoleText(updateoptions.hash + " != " + h.toString('hex'));
                            sendAgentMessage('Self Update FAILED because the downloaded agent FAILED hash check (' + agentUpdate_Start._retryCount + '), URL: ' + updateurl, 3);
                            agentUpdate_Start._selfupdate = null;

                            if (agentUpdate_Start._retryCount < 4) {
                                // Retry the download again
                                sendConsoleText('Self Update will try again in 60 seconds...', sessionid);
                                agentUpdate_Start._timeout = setTimeout(agentUpdate_Start, 60000, updateurl, updateoptions);
                            }
                            else {
                                sendConsoleText('Self Update giving up, too many failures...', sessionid);
                                sendAgentMessage('Self Update giving up, too many failures...', 3);
                            }
                            return;
                        }
                    }
                    else {
                        sendConsoleText('Download complete. HASH=' + h.toString('hex'), sessionid);
                    }

                    // Send an indication to the server that we got the update download correctly.
                    try { require('MeshAgent').SendCommand({ action: 'agentupdatedownloaded' }); } catch (ex) { }

                    if (sessionid != null) { sendConsoleText('Updating and restarting agent...', sessionid); }
                    if (process.platform == 'win32') {
                        // Use _wexecve() equivalent to perform the update
                        windows_execve(name, agentfilename, sessionid);
                    }
                    else {
                        var m = require('fs').statSync(process.execPath).mode;
                        require('fs').chmodSync(process.cwd() + agentfilename + '.update', m);

                        // remove binary
                        require('fs').unlinkSync(process.execPath);

                        // copy update
                        require('fs').copyFileSync(process.cwd() + agentfilename + '.update', process.execPath);
                        require('fs').chmodSync(process.execPath, m);

                        // erase update
                        require('fs').unlinkSync(process.cwd() + agentfilename + '.update');

                        switch (process.platform) {
                            case 'freebsd':
                                bsd_execv(name, agentfilename, sessionid);
                                break;
                            case 'linux':
                                linux_execv(name, agentfilename, sessionid);
                                break;
                            default:
                                try {
                                    // restart service
                                    var s = require('service-manager').manager.getService(name);
                                    s.restart();
                                }
                                catch (ex) {
                                    sendConsoleText('Self Update encountered an error trying to restart service', sessionid);
                                    sendAgentMessage('Self Update encountered an error trying to restart service', 3);
                                }
                                break;
                        }
                    }
                });
                img.pipe(this._file);
                img.pipe(this._filehash);
            });
        }
    }
}




// Called before the process exits
//process.exit = function (code) { console.log("Exit with code: " + code.toString()); }

// Called when the server connection state changes
function handleServerConnection(state) {
    meshServerConnectionState = state;
    if (meshServerConnectionState == 0) {
        // Server disconnected
        if (selfInfoUpdateTimer != null) { clearInterval(selfInfoUpdateTimer); selfInfoUpdateTimer = null; }
        lastSelfInfo = null;
    } else {
        // Server connected, send mesh core information
        if (require('MeshAgent').ServerInfo == null || require('MeshAgent').ServerInfo.ControlChannelCertificate == null) {
            // Outdated Agent, will have insecure tunnels
            sendAgentMessage("This agent has an outdated certificate validation mechanism, consider updating.", 3, 118);
        }
        else if (global._MSH == null) {
            sendAgentMessage("This is an old agent version, consider updating.", 3, 117);
        }

        var oldNodeId = db.Get('OldNodeId');
        if (oldNodeId != null) { mesh.SendCommand({ action: 'mc1migration', oldnodeid: oldNodeId }); }

        // Send SMBios tables if present
        if (SMBiosTablesRaw != null) { mesh.SendCommand({ action: 'smbios', value: SMBiosTablesRaw }); }

        // Update the server on with basic info, logged in users and more advanced stuff, like Intel ME and Network Settings
        meInfoStr = null;
        LastPeriodicServerUpdate = null;
        sendPeriodicServerUpdate(null, true);
        if (selfInfoUpdateTimer == null) {
            selfInfoUpdateTimer = setInterval(sendPeriodicServerUpdate, 1200000); // 20 minutes
            selfInfoUpdateTimer.metadata = 'meshcore (InfoUpdate Timer)';
        }

        // Send any state messages
        if (Object.keys(tunnelUserCount.msg).length > 0) {
            sendAgentMessage();
            broadcastSessionsToRegisteredApps();
        }

        // Send update of registered applications to the server
        updateRegisteredAppsToServer();
    }

    // Send server state update to registered applications
    broadcastToRegisteredApps({ cmd: 'serverstate', value: meshServerConnectionState, url: require('MeshAgent').ConnectedServer });
}

// Update the server with the latest network interface information
var sendNetworkUpdateNagleTimer = null;
function sendNetworkUpdateNagle() { if (sendNetworkUpdateNagleTimer != null) { clearTimeout(sendNetworkUpdateNagleTimer); sendNetworkUpdateNagleTimer = null; } sendNetworkUpdateNagleTimer = setTimeout(sendNetworkUpdate, 5000); }
function sendNetworkUpdate(force) {
    sendNetworkUpdateNagleTimer = null;

    try {
        // Update the network interfaces information data
        var netInfo = { netif2: require('os').networkInterfaces() };
        if (process.platform == 'win32') {
            try {
                var ret = require('win-wmi').query('ROOT\\CIMV2', 'SELECT InterfaceIndex,NetConnectionID,Speed FROM Win32_NetworkAdapter', ['InterfaceIndex','NetConnectionID','Speed']);
                if (ret[0]) {
                    var speedMap = {};
                    for (var i = 0; i < ret.length; i++) speedMap[ret[i].InterfaceIndex] = ret[i].Speed;
                    var adapterNames = Object.keys(netInfo.netif2);
                    for (var j = 0; j < adapterNames.length; j++) {
                        var interfaces = netInfo.netif2[adapterNames[j]];
                        for (var k = 0; k < interfaces.length; k++) {
                            var iface = interfaces[k], speed = speedMap[iface.index] || 0;
                            iface.speed = parseInt(speed); // bits per seconds
                        }
                    }
                }
            } catch(ex) { }
        } else if (process.platform == 'linux') {
            var adapterNames = Object.keys(netInfo.netif2);
            for (var i = 0; i < adapterNames.length; i++) {
                var ifaceName = adapterNames[i];
                try {
                    var speedStr = require('fs').readFileSync('/sys/class/net/' + ifaceName + '/speed').toString();
                    if ((speedStr.trim() != "") && (speedStr.trim() != "-1")) {
                        var theinterfaces = netInfo.netif2[ifaceName];
                        for (var k = 0; k < theinterfaces.length; k++) {
                            var iface = theinterfaces[k];
                            iface.speed = parseInt(speedStr) * 1000000; // bits per seconds
                        }
                    }
                } catch(ex) { }
            }
        }
        if (netInfo.netif2) {
            netInfo.action = 'netinfo';
            var netInfoStr = JSON.stringify(netInfo);
            if ((force == true) || (clearGatewayMac(netInfoStr) != clearGatewayMac(lastNetworkInfo))) { mesh.SendCommand(netInfo); lastNetworkInfo = netInfoStr; }
        }
    } catch (ex) { }
}

// Called periodically to check if we need to send updates to the server
function sendPeriodicServerUpdate(flags, force) {
    if (meshServerConnectionState == 0) return; // Not connected to server, do nothing.
    if (!flags) { flags = 0xFFFFFFFF; }
    if (!force) { force = false; }

    // If we have a connected MEI, get Intel ME information
    if ((flags & 1) && (amt != null) && (amt.state == 2)) {
        delete meshCoreObj.intelamt;
        amt.getMeiState(9, function (meinfo) {
            meshCoreObj.intelamt = meinfo;
            meshCoreObj.intelamt.microlms = amt.lmsstate;
            meshCoreObjChanged();
        });
    }

    // Update network information
    if (flags & 2) { sendNetworkUpdateNagle(false); }

    // Update anti-virus information
    if ((flags & 4) && (process.platform == 'win32')) {
        // Windows Command: "wmic /Namespace:\\root\SecurityCenter2 Path AntiVirusProduct get /FORMAT:CSV"
        try { meshCoreObj.av = require('win-info').av(); meshCoreObjChanged(); } catch (ex) { av = null; } // Antivirus
        //if (process.platform == 'win32') { try { meshCoreObj.pr = require('win-info').pendingReboot(); meshCoreObjChanged(); } catch (ex) { meshCoreObj.pr = null; } } // Pending reboot
    }
    if (process.platform == 'win32') {
        if (require('MeshAgent')._securitycenter == null) {
            try {
                require('MeshAgent')._securitycenter = require('win-securitycenter').status();
                meshCoreObj['wsc'] = require('MeshAgent')._securitycenter; // Windows Security Central (WSC)
                require('win-securitycenter').on('changed', function () {
                    require('MeshAgent')._securitycenter = require('win-securitycenter').status();
                    meshCoreObj['wsc'] = require('MeshAgent')._securitycenter; // Windows Security Central (WSC)
                    require('MeshAgent').SendCommand({ action: 'coreinfo', wsc: require('MeshAgent')._securitycenter });
                });
            } catch (ex) { }
        }

        // Get Defender Information
        try {
            meshCoreObj.defender = require('win-info').defender();
            meshCoreObjChanged();
        } catch (ex) { }
    }

    // Send available data right now
    if (force) {
        meshCoreObj = sortObjRec(meshCoreObj);
        var x = JSON.stringify(meshCoreObj);
        if (x != LastPeriodicServerUpdate) {
            LastPeriodicServerUpdate = x;
            mesh.SendCommand(meshCoreObj);
        }
    }
}

// Sort the names in an object
function sortObject(obj) { return Object.keys(obj).sort().reduce(function(a, v) { a[v] = obj[v]; return a; }, {}); }

// Fix the incoming data and cut down how much data we use
function cleanGetBitLockerVolumeInfo(volumes) {
    for (var i in volumes) {
        const v = volumes[i];
        if (typeof v.size == 'string') { v.size = parseInt(v.size); }
        if (typeof v.sizeremaining == 'string') { v.sizeremaining = parseInt(v.sizeremaining); }
        if (v.identifier == '') { delete v.identifier; }
        if (v.name == '') { delete v.name; }
        if (v.removable != true) { delete v.removable; }
        if (v.cdrom != true) { delete v.cdrom; }
        if (v.protectionStatus == 'On') { v.protectionStatus = true; } else { delete v.protectionStatus; }
        if (v.volumeStatus == 'FullyDecrypted') { delete v.volumeStatus; }
        if (v.recoveryPassword == '') { delete v.recoveryPassword; }
    }
    return sortObject(volumes);
}

// Once we are done collecting all the data, send to server if needed
var LastPeriodicServerUpdate = null;
var PeriodicServerUpdateNagleTimer = null;
function meshCoreObjChanged() {
    if (PeriodicServerUpdateNagleTimer == null) {
        PeriodicServerUpdateNagleTimer = setTimeout(meshCoreObjChangedEx, 500);
    }
}
function meshCoreObjChangedEx() {
    PeriodicServerUpdateNagleTimer = null;
    meshCoreObj = sortObjRec(meshCoreObj);
    var x = JSON.stringify(meshCoreObj);
    if (x != LastPeriodicServerUpdate) {
        try { LastPeriodicServerUpdate = x; mesh.SendCommand(meshCoreObj); } catch (ex) { }
    }
}

function sortObjRec(o) { if ((typeof o != 'object') || (Array.isArray(o))) return o; for (var i in o) { if (typeof o[i] == 'object') { o[i] = sortObjRec(o[i]); } } return sortObj(o); }
function sortObj(o) { return Object.keys(o).sort().reduce(function (result, key) { result[key] = o[key]; return result; }, {}); }

function onWebSocketClosed() { sendConsoleText("WebSocket #" + this.httprequest.index + " closed.", this.httprequest.sessionid); delete consoleWebSockets[this.httprequest.index]; }
function onWebSocketData(data) { sendConsoleText("Got WebSocket #" + this.httprequest.index + " data: " + data, this.httprequest.sessionid); }
function onWebSocketSendOk() { sendConsoleText("WebSocket #" + this.index + " SendOK.", this.sessionid); }

function onWebSocketUpgrade(response, s, head) {
    sendConsoleText("WebSocket #" + this.index + " connected.", this.sessionid);
    this.s = s;
    s.httprequest = this;
    s.end = onWebSocketClosed;
    s.data = onWebSocketData;
}

mesh.AddCommandHandler(handleServerCommand);
mesh.AddConnectHandler(handleServerConnection);