12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082 |
- /**
- * @description MeshCentral IP KVM Management Module
- * @author Ylian Saint-Hilaire
- * @copyright Intel Corporation 2021-2022
- * @license Apache-2.0
- * @version v0.0.1
- */
- function CreateIPKVMManager(parent) {
- const obj = {};
- obj.parent = parent;
- obj.managedGroups = {} // meshid --> Manager
- obj.managedPorts = {} // nodeid --> PortInfo
- // Mesh Rights
- const MESHRIGHT_EDITMESH = 0x00000001; // 1
- const MESHRIGHT_MANAGEUSERS = 0x00000002; // 2
- const MESHRIGHT_MANAGECOMPUTERS = 0x00000004; // 4
- const MESHRIGHT_REMOTECONTROL = 0x00000008; // 8
- const MESHRIGHT_AGENTCONSOLE = 0x00000010; // 16
- const MESHRIGHT_SERVERFILES = 0x00000020; // 32
- const MESHRIGHT_WAKEDEVICE = 0x00000040; // 64
- const MESHRIGHT_SETNOTES = 0x00000080; // 128
- const MESHRIGHT_REMOTEVIEWONLY = 0x00000100; // 256
- const MESHRIGHT_NOTERMINAL = 0x00000200; // 512
- const MESHRIGHT_NOFILES = 0x00000400; // 1024
- const MESHRIGHT_NOAMT = 0x00000800; // 2048
- const MESHRIGHT_DESKLIMITEDINPUT = 0x00001000; // 4096
- const MESHRIGHT_LIMITEVENTS = 0x00002000; // 8192
- const MESHRIGHT_CHATNOTIFY = 0x00004000; // 16384
- const MESHRIGHT_UNINSTALL = 0x00008000; // 32768
- const MESHRIGHT_NODESKTOP = 0x00010000; // 65536
- const MESHRIGHT_REMOTECOMMAND = 0x00020000; // 131072
- const MESHRIGHT_RESETOFF = 0x00040000; // 262144
- const MESHRIGHT_GUESTSHARING = 0x00080000; // 524288
- const MESHRIGHT_DEVICEDETAILS = 0x00100000; // ?1048576?
- const MESHRIGHT_ADMIN = 0xFFFFFFFF;
- // Subscribe for mesh creation events
- parent.AddEventDispatch(['server-createmesh', 'server-deletemesh', 'server-editmesh', 'devport-operation'], obj);
- obj.HandleEvent = function (source, event, ids, id) {
- if ((event == null) || (event.mtype != 4)) return;
- if (event.action == 'createmesh') {
- // Start managing this new device group
- startManagement(parent.webserver.meshes[event.meshid]);
- } else if (event.action == 'deletemesh') {
- // Stop managing this device group
- stopManagement(event.meshid);
- } else if ((event.action == 'meshchange') && (event.relayid != null)) {
- // See if the relayid changed
- changeManagementRelayId(event.meshid, event.relayid);
- } else if ((event.action == 'turnon') || (event.action == 'turnoff')) {
- // Perform power operation
- const manager = obj.managedGroups[event.meshid];
- if ((manager) && (manager.powerOperation)) { manager.powerOperation(event); }
- }
- }
- // Run thru the list of device groups that require
- for (var i in parent.webserver.meshes) {
- const mesh = parent.webserver.meshes[i];
- if ((mesh.mtype == 4) && (mesh.deleted == null)) { startManagement(mesh); }
- }
- // Start managing a IP KVM device
- function startManagement(mesh) {
- if ((mesh == null) || (mesh.mtype != 4) || (mesh.kvm == null) || (mesh.deleted != null) || (obj.managedGroups[mesh._id] != null)) return;
- var port = 443, hostSplit = mesh.kvm.host.split(':'), host = hostSplit[0];
- if (hostSplit.length == 2) { port = parseInt(hostSplit[1]); }
- if (mesh.kvm.model == 1) { // Raritan KX III
- const manager = CreateRaritanKX3Manager(obj, host, port, mesh.kvm.user, mesh.kvm.pass);
- manager.meshid = mesh._id;
- manager.relayid = mesh.relayid;
- manager.domainid = mesh._id.split('/')[1];
- obj.managedGroups[mesh._id] = manager;
- manager.onStateChanged = onStateChanged;
- manager.onPortsChanged = onPortsChanged;
- manager.start();
- } else if (mesh.kvm.model == 2) { // WebPowerSwitch 7
- const manager = CreateWebPowerSwitch(obj, host, port, mesh.kvm.user, mesh.kvm.pass);
- manager.meshid = mesh._id;
- manager.relayid = mesh.relayid;
- manager.domainid = mesh._id.split('/')[1];
- obj.managedGroups[mesh._id] = manager;
- manager.onStateChanged = onStateChanged;
- manager.onPortsChanged = onPortsChanged;
- manager.start();
- }
- }
- // Stop managing a IP KVM device
- function stopManagement(meshid) {
- const manager = obj.managedGroups[meshid];
- if (manager != null) {
- // Remove all managed ports
- for (var i = 0; i < manager.ports.length; i++) {
- const port = manager.ports[i];
- const nodeid = generateIpKvmNodeId(manager.meshid, port.PortId, manager.domainid);
- delete obj.managedPorts[nodeid]; // Remove the managed port
- }
- // Remove the manager
- delete obj.managedGroups[meshid];
- manager.stop();
- }
- }
- // Change the relayid of a managed device if needed
- function changeManagementRelayId(meshid, relayid) {
- const manager = obj.managedGroups[meshid];
- if ((manager != null) && (manager.relayid != null) && (manager.relayid != relayid)) { manager.updateRelayId(relayid); }
- }
- // Called when a KVM device changes state
- function onStateChanged(sender, state) {
- /*
- console.log('State: ' + ['Disconnected', 'Connecting', 'Connected'][state]);
- if (state == 2) {
- if (sender.deviceModel) { console.log('DeviceModel:', sender.deviceModel); }
- if (sender.firmwareVersion) { console.log('FirmwareVersion:', sender.firmwareVersion); }
- }
- */
- if (state == 0) {
- // Disconnect all nodes for this device group
- for (var i in sender.ports) {
- const port = sender.ports[i];
- const nodeid = generateIpKvmNodeId(sender.meshid, port.PortId, sender.domainid);
- if (obj.managedPorts[nodeid] != null) {
- parent.ClearConnectivityState(sender.meshid, nodeid, 1, null, null);
- delete obj.managedPorts[nodeid];
- }
- }
- }
- }
- // Called when a KVM device changes state
- function onPortsChanged(sender, updatedPorts) {
- for (var i = 0; i < updatedPorts.length; i++) {
- const port = sender.ports[updatedPorts[i]];
- const nodeid = generateIpKvmNodeId(sender.meshid, port.PortId, sender.domainid);
- if ((port.Status == 1) && (port.Class == 'PDU')) {
- //console.log(port.PortNumber + ', ' + port.PortId + ', ' + port.Name + ', ' + port.State);
- if ((obj.managedPorts[nodeid] == null) || (obj.managedPorts[nodeid].name != port.Name)) {
- parent.db.Get(nodeid, function (err, nodes) {
- if ((err != null) || (nodes == null)) return;
- const mesh = parent.webserver.meshes[sender.meshid];
- if (nodes.length == 0) {
- // The device does not exist, create it
- const device = { type: 'node', mtype: 4, _id: nodeid, icon: 4, meshid: sender.meshid, name: port.Name, rname: port.Name, domain: sender.domainid, portid: port.PortId, portnum: port.PortNumber, porttype: 'PDU' };
- parent.db.Set(device);
- // Event the new node
- parent.DispatchEvent(parent.webserver.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, { etype: 'node', action: 'addnode', nodeid: nodeid, node: device, msgid: 57, msgArgs: [port.Name, mesh.name], msg: ('Added device ' + port.Name + ' to device group ' + mesh.name), domain: sender.domainid });
- } else {
- // The device exists, update it
- var changed = false;
- const device = nodes[0];
- if (device.rname != port.Name) { device.rname = port.Name; changed = true; } // Update the device port name
- if ((mesh.flags) && (mesh.flags & 2) && (device.name != port.Name)) { device.name = port.Name; changed = true; } // Sync device name to port name
- if (changed) {
- // Update the database and event the node change
- parent.db.Set(device);
- parent.DispatchEvent(parent.webserver.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, { etype: 'node', action: 'changenode', nodeid: nodeid, node: device, domain: sender.domainid, nolog: 1 });
- }
- }
- // Set the connectivity state if needed
- if (obj.managedPorts[nodeid] == null) {
- parent.SetConnectivityState(sender.meshid, nodeid, Date.now(), 1, port.State ? 1 : 8, null, null);
- obj.managedPorts[nodeid] = { name: port.Name, meshid: sender.meshid, portid: port.PortId, portType: port.PortType, portNo: port.PortIndex };
- }
- });
- } else {
- // Update connectivity state
- parent.SetConnectivityState(sender.meshid, nodeid, Date.now(), 1, port.State ? 1 : 8, null, null);
- }
- } else if ((port.Status == 1) && (port.Class == 'KVM')) {
- //console.log(port.PortNumber + ', ' + port.PortId + ', ' + port.Name + ', ' + port.Type + ', ' + ((port.StatAvailable == 0) ? 'Idle' : 'Connected'));
- if ((obj.managedPorts[nodeid] == null) || (obj.managedPorts[nodeid].name != port.Name)) {
- parent.db.Get(nodeid, function (err, nodes) {
- if ((err != null) || (nodes == null)) return;
- const mesh = parent.webserver.meshes[sender.meshid];
- if (nodes.length == 0) {
- // The device does not exist, create it
- const device = { type: 'node', mtype: 4, _id: nodeid, icon: 1, meshid: sender.meshid, name: port.Name, rname: port.Name, domain: sender.domainid, porttype: port.Type, portid: port.PortId, portnum: port.PortNumber };
- parent.db.Set(device);
- // Event the new node
- parent.DispatchEvent(parent.webserver.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, { etype: 'node', action: 'addnode', nodeid: nodeid, node: device, msgid: 57, msgArgs: [port.Name, mesh.name], msg: ('Added device ' + port.Name + ' to device group ' + mesh.name), domain: sender.domainid });
- } else {
- // The device exists, update it
- var changed = false;
- const device = nodes[0];
- if (device.rname != port.Name) { device.rname = port.Name; changed = true; } // Update the device port name
- if ((mesh.flags) && (mesh.flags & 2) && (device.name != port.Name)) { device.name = port.Name; changed = true; } // Sync device name to port name
- if (changed) {
- // Update the database and event the node change
- parent.db.Set(device);
- parent.DispatchEvent(parent.webserver.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, { etype: 'node', action: 'changenode', nodeid: nodeid, node: device, domain: sender.domainid, nolog: 1 });
- }
- }
- // Set the connectivity state if needed
- if (obj.managedPorts[nodeid] == null) {
- parent.SetConnectivityState(sender.meshid, nodeid, Date.now(), 1, 1, null, null);
- obj.managedPorts[nodeid] = { name: port.Name, meshid: sender.meshid, portid: port.PortId, portType: port.PortType, portNo: port.PortIndex };
- }
- // Update busy state
- const portInfo = obj.managedPorts[nodeid];
- if ((portInfo.sessions != null) != (port.StatAvailable != 0)) {
- if (port.StatAvailable != 0) { portInfo.sessions = { kvm: { 'busy': 1 } } } else { delete portInfo.sessions; }
- // Event the new sessions, this will notify everyone that agent sessions have changed
- var event = { etype: 'node', action: 'devicesessions', nodeid: nodeid, domain: sender.domainid, sessions: portInfo.sessions, nolog: 1 };
- parent.DispatchEvent(parent.webserver.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, event);
- }
- });
- } else {
- // Update busy state
- const portInfo = obj.managedPorts[nodeid];
- if ((portInfo.sessions != null) != (port.StatAvailable != 0)) {
- if (port.StatAvailable != 0) { portInfo.sessions = { kvm: { 'busy': 1 } } } else { delete portInfo.sessions; }
- // Event the new sessions, this will notify everyone that agent sessions have changed
- var event = { etype: 'node', action: 'devicesessions', nodeid: nodeid, domain: sender.domainid, sessions: portInfo.sessions, nolog: 1 };
- parent.DispatchEvent(parent.webserver.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, event);
- }
- }
- } else {
- if (obj.managedPorts[nodeid] != null) {
- // This port is no longer connected
- parent.ClearConnectivityState(sender.meshid, nodeid, 1, null, null);
- const mesh = parent.webserver.meshes[sender.meshid];
- // If the device group policy is set to auto-remove devices, remove it now
- if ((mesh != null) && (mesh.flags) && (mesh.flags & 1)) { // Auto-remove devices
- parent.db.Remove(nodeid); // Remove node with that id
- parent.db.Remove('nt' + nodeid); // Remove notes
- parent.db.Remove('lc' + nodeid); // Remove last connect time
- parent.db.Remove('al' + nodeid); // Remove error log last time
- parent.db.RemoveAllNodeEvents(nodeid); // Remove all events for this node
- parent.db.removeAllPowerEventsForNode(nodeid); // Remove all power events for this node
- // Event node deletion
- parent.parent.DispatchEvent(parent.CreateMeshDispatchTargets(sender.meshid, [nodeid]), obj, { etype: 'node', action: 'removenode', nodeid: nodeid, domain: domain.id, nolog: 1 });
- }
- // Remove the managed port
- delete obj.managedPorts[nodeid];
- }
- }
- }
- }
- // Generate the nodeid from the device group and device identifier
- function generateIpKvmNodeId(meshid, portid, domainid) {
- return 'node/' + domainid + '/' + parent.crypto.createHash('sha384').update(Buffer.from(meshid + '/' + portid)).digest().toString('base64').replace(/\+/g, '@').replace(/\//g, '$');
- }
- // Parse an incoming HTTP request URL
- function parseIpKvmUrl(domain, url) {
- const q = require('url').parse(url, true);
- const i = q.path.indexOf('/ipkvm.ashx/');
- if (i == -1) return null;
- const urlargs = q.path.substring(i + 12).split('/');
- if (urlargs[0].length != 64) return null;
- const nodeid = 'node/' + domain.id + '/' + urlargs[0];
- const nid = urlargs[0];
- const kvmport = obj.managedPorts[nodeid];
- if (kvmport == null) return null;
- const kvmmanager = obj.managedGroups[kvmport.meshid];
- if (kvmmanager == null) return null;
- urlargs.shift();
- var relurl = '/' + urlargs.join('/');
- if (relurl.endsWith('/.websocket')) { relurl = relurl.substring(0, relurl.length - 11); }
- return { domain: domain.id, relurl: relurl, preurl: q.path.substring(0, i + 76), nodeid: nodeid, nid: nid, kvmmanager: kvmmanager, kvmport: kvmport };
- }
- // Handle a IP-KVM HTTP get request
- obj.handleIpKvmGet = function (domain, req, res, next) {
- // Parse the URL and get information about this KVM port
- const reqinfo = parseIpKvmUrl(domain, req.url);
- if (reqinfo == null) { next(); return; }
- // Check node rights
- if ((req.session == null) || (req.session.userid == null)) { next(); return; }
- const user = parent.webserver.users[req.session.userid];
- if (user == null) { next(); return; }
- const rights = parent.webserver.GetNodeRights(user, reqinfo.kvmmanager.meshid, reqinfo.nodeid);
- if ((rights & MESHRIGHT_REMOTECONTROL) == 0) { next(); return; }
- // Process the request
- reqinfo.kvmmanager.handleIpKvmGet(domain, reqinfo, req, res, next);
- }
- // Handle a IP-KVM HTTP websocket request
- obj.handleIpKvmWebSocket = function (domain, ws, req) {
- // Parse the URL and get information about this KVM port
- const reqinfo = parseIpKvmUrl(domain, req.url);
- if (reqinfo == null) { try { ws.close(); } catch (ex) { } return; }
- // Check node rights
- if ((req.session == null) || (req.session.userid == null)) { try { ws.close(); } catch (ex) { } return; }
- const user = parent.webserver.users[req.session.userid];
- if (user == null) { try { ws.close(); } catch (ex) { } return; }
- const rights = parent.webserver.GetNodeRights(user, reqinfo.kvmmanager.meshid, reqinfo.nodeid);
- if ((rights & MESHRIGHT_REMOTECONTROL) == 0) { try { ws.close(); } catch (ex) { } return; }
- // Add more logging data to the request information
- reqinfo.clientIp = req.clientIp;
- reqinfo.userid = req.session.userid;
- reqinfo.username = user.name;
- // Process the request
- reqinfo.kvmmanager.handleIpKvmWebSocket(domain, reqinfo, ws, req);
- }
- return obj;
- }
- // Create Raritan Dominion KX III Manager
- function CreateRaritanKX3Manager(parent, hostname, port, username, password) {
- const https = require('https');
- const obj = {};
- var updateTimer = null;
- var retryTimer = null;
- obj.authCookie = null;
- obj.state = 0; // 0 = Disconnected, 1 = Connecting, 2 = Connected
- obj.ports = [];
- obj.portCount = 0;
- obj.portHash = null;
- obj.deviceCount = 0;
- obj.deviceHash = null;
- obj.started = false;
- // Events
- obj.onStateChanged = null;
- obj.onPortsChanged = null;
- function onCheckServerIdentity(cert) {
- console.log('TODO: Certificate Check');
- }
- obj.start = function () {
- if (obj.started) return;
- obj.started = true;
- if (obj.relayid) {
- obj.router = CreateMiniRouter(parent, obj.relayid, hostname, port);
- obj.router.start(function () { connect(); });
- } else {
- connect();
- }
- }
- obj.stop = function () {
- if (!obj.started) return;
- obj.started = false;
- if (retryTimer != null) { clearTimeout(retryTimer); retryTimer = null; }
- setState(0);
- if (obj.router) { obj.router.stop(); delete obj.router; }
- }
- // If the relay device has changed, update our router
- obj.updateRelayId = function (relayid) {
- obj.relayid = relayid;
- if (obj.router != null) { obj.router.nodeid = relayid; }
- }
- function setState(newState) {
- if (obj.state == newState) return;
- obj.state = newState;
- if (obj.onStateChanged != null) { obj.onStateChanged(obj, newState); }
- if ((newState == 2) && (updateTimer == null)) { updateTimer = setInterval(obj.update, 10000); }
- if ((newState != 2) && (updateTimer != null)) { clearInterval(updateTimer); updateTimer = null; }
- if ((newState == 0) && (obj.started == true) && (retryTimer == null)) { retryTimer = setTimeout(connect, 20000); }
- if (newState == 0) { obj.ports = []; obj.portCount = 0; obj.deviceCount = 0; }
- }
- function connect() {
- if (obj.state != 0) return;
- setState(1); // 1 = Connecting
- obj.authCookie = null;
- if (retryTimer != null) { clearTimeout(retryTimer); retryTimer = null; }
- const data = Buffer.from('is_dotnet=0&is_javafree=0&is_standalone_client=0&is_javascript_kvm_client=1&is_javascript_rsc_client=1&login=' + encodeURIComponent(username) + '&password=' + encodeURIComponent(password) + '&action_login=Login');
- const options = {
- hostname: hostname,
- port: port,
- rejectUnauthorized: false,
- checkServerIdentity: onCheckServerIdentity,
- path: '/auth.asp?client=javascript', // ?client=standalone
- method: 'POST',
- headers: {
- 'Content-Type': 'text/html; charset=UTF-8',
- 'Content-Length': data.length
- }
- }
- const req = https.request(options, function (res) {
- if (obj.state == 0) return;
- if ((res.statusCode != 302) || (res.headers['set-cookie'] == null) || (res.headers['location'] == null)) { setState(0); return; }
- for (var i in res.headers['set-cookie']) { if (res.headers['set-cookie'][i].startsWith('pp_session_id=')) { obj.authCookie = res.headers['set-cookie'][i].substring(14).split(';')[0]; } }
- if (obj.authCookie == null) { setState(0); return; }
- res.on('data', function (d) { })
- fetchInitialInformation();
- })
- req.on('error', function (error) { setState(0); });
- req.on('timeout', function () { setState(0); });
- req.write(data);
- req.end();
- }
- function checkCookie() {
- if (obj.state != 2) return;
- const options = {
- hostname: hostname,
- port: port,
- rejectUnauthorized: false,
- checkServerIdentity: onCheckServerIdentity,
- path: '/cookiecheck.asp',
- method: 'GET',
- headers: {
- 'Content-Type': 'text/html; charset=UTF-8',
- 'Cookie': 'pp_session_id=' + obj.authCookie
- }
- }
- const req = https.request(options, function (res) {
- if (obj.state == 0) return;
- if (res.statusCode != 302) { setState(0); return; }
- if (res.headers['set-cookie'] != null) { for (var i in res.headers['set-cookie']) { if (res.headers['set-cookie'][i].startsWith('pp_session_id=')) { obj.authCookie = res.headers['set-cookie'][i].substring(14).split(';')[0]; } } }
- res.on('data', function (d) { })
- });
- req.on('error', function (error) { setState(0); });
- req.on('timeout', function () { setState(0); });
- req.end();
- }
- function fetchInitialInformation() {
- obj.fetch('/webs_cron.asp?_portsstatushash=&_devicesstatushash=&webs_job=sidebarupdates', null, null, function (server, tag, data) {
- data = data.toString();
- const parsed = parseJsScript(data);
- for (var i in parsed['updateSidebarPanel']) {
- if (parsed['updateSidebarPanel'][i][0] == "cron_device") {
- obj.firmwareVersion = getSubString(parsed['updateSidebarPanel'][i][1], "Firmware: ", "<");
- obj.deviceModel = getSubString(parsed['updateSidebarPanel'][i][1], "<div class=\"device-model\">", "<");
- }
- }
- obj.fetch('/sidebar.asp', null, null, function (server, tag, data) {
- data = data.toString();
- var dataBlock = getSubString(data, "updateKVMLinkHintOnContainer();", "devices.resetDevicesNew(1);");
- if (dataBlock == null) { setState(0); return; }
- const parsed = parseJsScript(dataBlock);
- obj.portCount = parseInt(parsed['updatePortStatus'][0][0]) - 2;
- obj.portHash = parsed['updatePortStatus'][0][1];
- obj.deviceCount = parseInt(parsed['updateDeviceStatus'][0][0]);
- obj.deviceHash = parsed['updateDeviceStatus'][0][1];
- var updatedPorts = [];
- for (var i = 0; i < parsed['addPortNew'].length; i++) {
- const portInfo = parsePortInfo(parsed['addPortNew'][i]);
- obj.ports[portInfo.hIndex] = portInfo;
- updatedPorts.push(portInfo.hIndex);
- }
- setState(2);
- if (obj.onPortsChanged != null) { obj.onPortsChanged(obj, updatedPorts); }
- });
- });
- }
- obj.update = function () {
- obj.fetch('/webs_cron.asp?_portsstatushash=' + obj.portHash + '&_devicesstatushash=' + obj.deviceHash, null, null, function (server, tag, data) {
- data = data.toString();
- const parsed = parseJsScript(data);
- if (parsed['updatePortStatus']) {
- obj.portCount = parseInt(parsed['updatePortStatus'][0][0]) - 2;
- obj.portHash = parsed['updatePortStatus'][0][1];
- }
- if (parsed['updateDeviceStatus']) {
- obj.deviceCount = parseInt(parsed['updateDeviceStatus'][0][0]);
- obj.deviceHash = parsed['updateDeviceStatus'][0][1];
- }
- if (parsed['updatePort']) {
- var updatedPorts = [];
- for (var i = 0; i < parsed['updatePort'].length; i++) {
- const portInfo = parsePortInfo(parsed['updatePort'][i]);
- obj.ports[portInfo.hIndex] = portInfo;
- updatedPorts.push(portInfo.hIndex);
- }
- if ((updatedPorts.length > 0) && (obj.onPortsChanged != null)) { obj.onPortsChanged(obj, updatedPorts); }
- }
- });
- }
- function parsePortInfo(args) {
- var out = {};
- for (var i = 0; i < args.length; i++) {
- var parsed = parseJsScript(args[i]);
- var v = parsed.J[0][1], vv = parseInt(v);
- out[parsed.J[0][0]] = (v == vv) ? vv : v;
- }
- return out;
- }
- function getSubString(str, start, end) {
- var i = str.indexOf(start);
- if (i < 0) return null;
- str = str.substring(i + start.length);
- i = str.indexOf(end);
- if (i >= 0) { str = str.substring(0, i); }
- return str;
- }
- // Parse JavaScript code calls
- function parseJsScript(str) {
- const out = {};
- var functionName = '';
- var args = [];
- var arg = null;
- var stack = [];
- for (var i = 0; i < str.length; i++) {
- if (stack.length == 0) {
- if (str[i] != '(') {
- if (isAlphaNumeric(str[i])) { functionName += str[i]; } else { functionName = ''; }
- } else {
- stack.push(')');
- }
- } else {
- if (str[i] == stack[stack.length - 1]) {
- if (stack.length > 1) { if (arg == null) { arg = str[i]; } else { arg += str[i]; } }
- if (stack.length == 2) {
- if (arg != null) { args.push(trimQuotes(arg)); }
- arg = null;
- } else if (stack.length == 1) {
- if (arg != null) { args.push(trimQuotes(arg)); arg = null; }
- if (args.length > 0) {
- if (out[functionName] == null) {
- out[functionName] = [args];
- } else {
- out[functionName].push(args);
- }
- }
- args = [];
- }
- stack.pop();
- } else if ((str[i] == '\'') || (str[i] == '"') || (str[i] == '(')) {
- if (str[i] == '(') { stack.push(')'); } else { stack.push(str[i]); }
- if (stack.length > 0) {
- if (arg == null) { arg = str[i]; } else { arg += str[i]; }
- }
- } else {
- if ((stack.length == 1) && (str[i] == ',')) {
- if (arg != null) { args.push(trimQuotes(arg)); arg = null; }
- } else {
- if (stack.length > 0) { if (arg == null) { arg = str[i]; } else { arg += str[i]; } }
- }
- }
- }
- }
- return out;
- }
- function trimQuotes(str) {
- if ((str == null) || (str.length < 2)) return str;
- str = str.trim();
- if ((str[0] == '\'') && (str[str.length - 1] == '\'')) { return str.substring(1, str.length - 1); }
- if ((str[0] == '"') && (str[str.length - 1] == '"')) { return str.substring(1, str.length - 1); }
- return str;
- }
- function isAlphaNumeric(char) {
- return ((char >= 'A') && (char <= 'Z')) || ((char >= 'a') && (char <= 'z')) || ((char >= '0') && (char <= '9'));
- }
- obj.fetch = function (url, postdata, tag, func) {
- if (obj.state == 0) return;
- var data = [];
- const options = {
- hostname: obj.router ? 'localhost' : hostname,
- port: obj.router ? obj.router.tcpServerPort : port,
- rejectUnauthorized: false,
- checkServerIdentity: onCheckServerIdentity,
- path: url,
- method: (postdata != null) ? 'POST' : 'GET',
- headers: {
- 'Content-Type': 'text/html; charset=UTF-8',
- 'Cookie': 'pp_session_id=' + obj.authCookie
- }
- }
- const req = https.request(options, function (res) {
- if (obj.state == 0) return;
- if (res.statusCode != 200) { setState(0); return; }
- if (res.headers['set-cookie'] != null) { for (var i in res.headers['set-cookie']) { if (res.headers['set-cookie'][i].startsWith('pp_session_id=')) { obj.authCookie = res.headers['set-cookie'][i].substring(14).split(';')[0]; } } }
- res.on('data', function (d) { data.push(d); });
- res.on('end', function () {
- // This line is used for debugging only, used to swap a file.
- //if (url.endsWith('js_kvm_client.1604062083669.min.js')) { data = [ parent.parent.fs.readFileSync('c:\\tmp\\js_kvm_client.1604062083669.min.js') ] ; }
- func(obj, tag, Buffer.concat(data), res);
- });
- });
- req.on('error', function (error) { setState(0); });
- req.on('timeout', function () { setState(0); });
- req.end();
- }
- // Handle a IP-KVM HTTP get request
- obj.handleIpKvmGet = function (domain, reqinfo, req, res, next) {
- if (reqinfo.relurl == '/') { res.redirect(reqinfo.preurl + '/jsclient/Client.asp'); return; }
- // Example: /jsclient/Client.asp#portId=P_000d5d20f64c_1
- obj.fetch(reqinfo.relurl, null, [res, reqinfo], function (server, args, data, rres) {
- const resx = args[0], xreqinfo = args[1];
- if (rres.headers['content-type']) { resx.set('content-type', rres.headers['content-type']); }
- if (xreqinfo.relurl.startsWith('/js/js_kvm_client.')) {
- data = data.toString();
- // Since our cookies can't be read from the html page for security, we embed a dummy cookie into the page.
- data = data.replace('module$js$helper$Extensions.Utils.getCookieValue("pp_session_id")', '"DUMMCOOKIEY"');
- // Add the connection information directly into the file.
- data = data.replace('\'use strict\';', '\'use strict\';sessionStorage.setItem("portPermission","CCC");sessionStorage.setItem("appId","1638838693725_3965868704642470");sessionStorage.setItem("portId","' + xreqinfo.kvmport.portid + '");sessionStorage.setItem("channelName","' + xreqinfo.kvmport.name + '");sessionStorage.setItem("portType","' + xreqinfo.kvmport.portType + '");sessionStorage.setItem("portNo","' + xreqinfo.kvmport.portNo + '");');
- // Replace the WebSocket code in one of the files to make it work with our server.
- data = data.replace('b=new WebSocket(e+"//"+c+"/"+g);', 'b=new WebSocket(e+"//"+c+"/ipkvm.ashx/' + xreqinfo.nid + '/"+g);');
- }
- resx.end(data);
- });
- }
- function logConnection(wsClient) {
- const kvmport = wsClient.kvmport
- const reqinfo = wsClient.reqinfo;
- var event = { etype: 'relay', action: 'relaylog', domain: reqinfo.domain, userid: reqinfo.userid, username: reqinfo.username, msgid: 15, msgArgs: [kvmport.portid, reqinfo.clientIp, kvmport.portNo], msg: 'Started desktop session' + ' \"' + kvmport.portid + '\" from ' + reqinfo.clientIp + ' to ' + kvmport.portNo, protocol: 2, nodeid: reqinfo.nodeid };
- parent.parent.DispatchEvent(['*', reqinfo.userid, reqinfo.nodeid, kvmport.meshid], obj, event);
- }
- function logDisconnection(wsClient) {
- const kvmport = wsClient.kvmport
- const reqinfo = wsClient.reqinfo;
- var event = { etype: 'relay', action: 'relaylog', domain: reqinfo.domain, userid: reqinfo.userid, username: reqinfo.username, msgid: 11, msgArgs: [kvmport.portid, reqinfo.clientIp, kvmport.portNo, Math.floor((Date.now() - kvmport.connectionStart) / 1000)], msg: 'Ended desktop session' + ' \"' + kvmport.portid + '\" from ' + reqinfo.clientIp + ' to ' + kvmport.portNo + ', ' + Math.floor((Date.now() - kvmport.connectionStart) / 1000) + ' second(s)', protocol: 2, nodeid: reqinfo.nodeid, bytesin: kvmport.bytesIn, bytesout: kvmport.bytesOut };
- parent.parent.DispatchEvent(['*', reqinfo.userid, reqinfo.nodeid, kvmport.meshid], obj, event);
- delete kvmport.bytesIn;
- delete kvmport.bytesOut;
- delete kvmport.connectionStart;
- delete wsClient.reqinfo;
- }
- // Handle a IP-KVM HTTP websocket request
- obj.handleIpKvmWebSocket = function (domain, reqinfo, ws, req) {
- ws._socket.pause();
- //console.log('handleIpKvmWebSocket', reqinfo.preurl);
- if (reqinfo.kvmport.wsClient != null) {
- // Relay already open
- //console.log('IPKVM Relay already present');
- try { ws.close(); } catch (ex) { }
- } else {
- // Setup a websocket-to-websocket relay
- try {
- const options = {
- rejectUnauthorized: false,
- servername: 'raritan', // We set this to remove the IP address warning from NodeJS.
- headers: { Cookie: 'pp_session_id=' + obj.authCookie + '; view_length=32' }
- };
- parent.parent.debug('relay', 'IPKVM: Relay connecting to: wss://' + hostname + ':' + port + '/rfb');
- const WebSocket = require('ws');
- reqinfo.kvmport.wsClient = new WebSocket('wss://' + hostname + ':' + port + '/rfb', options);
- reqinfo.kvmport.wsClient.wsBrowser = ws;
- ws.wsClient = reqinfo.kvmport.wsClient;
- reqinfo.kvmport.wsClient.kvmport = reqinfo.kvmport;
- reqinfo.kvmport.wsClient.reqinfo = reqinfo;
- reqinfo.kvmport.connectionStart = Date.now();
- reqinfo.kvmport.bytesIn = 0;
- reqinfo.kvmport.bytesOut = 0;
- logConnection(reqinfo.kvmport.wsClient);
- reqinfo.kvmport.wsClient.on('open', function () {
- parent.parent.debug('relay', 'IPKVM: Relay websocket open');
- this.wsBrowser.on('message', function (data) {
- //console.log('KVM browser data', data.toString('hex'), data.toString('utf8'));
- // Replace the authentication command that used the dummy cookie with a command that has the correct hash
- if ((this.xAuthNonce != null) && (this.xAuthNonce != 1) && (data.length == 67) && (data[0] == 0x21) && (data[1] == 0x41)) {
- const hash = Buffer.from(require('crypto').createHash('sha256').update(this.xAuthNonce + obj.authCookie).digest().toString('hex'));
- data = Buffer.alloc(67);
- data[0] = 0x21; // Auth Command
- data[1] = 0x41; // Length
- hash.copy(data, 2); // Hash
- this.xAuthNonce = 1;
- }
- // Check the port name
- if ((data[0] == 0x89) && (data.length > 4)) {
- const portNameLen = (data[2] << 8) + data[3];
- if (data.length == (4 + portNameLen)) {
- const portName = data.slice(4).toString('utf8');
- if (reqinfo.kvmport.portid != portName) {
- // The browser required an unexpected port for remote control, disconnect not.
- try { this._socket.close(); } catch (ex) { }
- return;
- }
- }
- }
- try { this.wsClient.kvmport.bytesOut += data.length; } catch (ex) { }
- this._socket.pause();
- try { this.wsClient.send(data); } catch (ex) { }
- this._socket.resume();
- });
- this.wsBrowser.on('close', function () {
- parent.parent.debug('relay', 'IPKVM: Relay browser websocket closed');
- // Clean up
- if (this.wsClient) {
- logDisconnection(this.wsClient);
- try { this.wsClient.close(); } catch (ex) { }
- try {
- if (this.wsClient.kvmport) {
- delete this.wsClient.kvmport.wsClient;
- delete this.wsClient.kvmport;
- }
- delete this.wsClient.wsBrowser;
- delete this.wsClient;
- } catch (ex) { console.log(ex); }
- }
- });
- this.wsBrowser.on('error', function (err) {
- parent.parent.debug('relay', 'IPKVM: Relay browser websocket error: ' + err);
- });
- this.wsBrowser._socket.resume();
- });
- reqinfo.kvmport.wsClient.on('message', function (data) { // Make sure to handle flow control.
- //console.log('KVM switch data', data, data.length, data.toString('hex'));
- // If the data start with 0x21 and 0x41 followed by {SHA256}, store the authenticate nonce
- if ((this.wsBrowser.xAuthNonce == null) && (data.length == 67) && (data[0] == 0x21) && (data[1] == 0x41) && (data[2] == 0x7b) && (data[3] == 0x53) && (data[4] == 0x48)) {
- this.wsBrowser.xAuthNonce = data.slice(2).toString().substring(0, 64);
- }
- try { this.wsBrowser.wsClient.kvmport.bytesIn += data.length; } catch (ex) { }
- this._socket.pause();
- try { this.wsBrowser.send(data); } catch (ex) { }
- this._socket.resume();
- });
- reqinfo.kvmport.wsClient.on('close', function () {
- parent.parent.debug('relay', 'IPKVM: Relay websocket closed');
- // Clean up
- try {
- if (this.wsBrowser) {
- logDisconnection(this.wsBrowser.wsClient);
- try { this.wsBrowser.close(); } catch (ex) { }
- delete this.wsBrowser.wsClient; delete this.wsBrowser;
- }
- if (this.kvmport) { delete this.kvmport.wsClient; delete this.kvmport; }
- } catch (ex) { console.log(ex); }
- });
- reqinfo.kvmport.wsClient.on('error', function (err) {
- parent.parent.debug('relay', 'IPKVM: Relay websocket error: ' + err);
- });
- } catch (ex) { console.log(ex); }
- }
- }
- return obj;
- }
- // Create WebPowerSwitch Manager
- function CreateWebPowerSwitch(parent, hostname, port, username, password) {
- port = 80;
- const https = require('http');
- const crypto = require('crypto');
- const obj = {};
- var updateTimer = null;
- var retryTimer = null;
- var challenge = null;
- var challengeRetry = 0;
- var nonceCounter = 1;
- obj.state = 0; // 0 = Disconnected, 1 = Connecting, 2 = Connected
- obj.ports = [];
- obj.portCount = 0;
- obj.started = false;
- obj.onStateChanged = null;
- obj.onPortsChanged = null;
- function onCheckServerIdentity(cert) {
- console.log('TODO: Certificate Check');
- }
- obj.start = function () {
- if (obj.started) return;
- obj.started = true;
- if (obj.state == 0) {
- if (obj.relayid) {
- obj.router = CreateMiniRouter(parent, obj.relayid, hostname, port);
- obj.router.start(function () { connect(); });
- } else {
- connect();
- }
- }
- }
- obj.stop = function () {
- if (!obj.started) return;
- obj.started = false;
- if (retryTimer != null) { clearTimeout(retryTimer); retryTimer = null; }
- setState(0);
- obj.ports = [];
- if (obj.router) { obj.router.stop(); delete obj.router; }
- }
- // If the relay device has changed, update our router
- obj.updateRelayId = function (relayid) {
- obj.relayid = relayid;
- if (obj.router != null) { obj.router.nodeid = relayid; }
- }
- function setState(newState) {
- if (obj.state == newState) return;
- obj.state = newState;
- if (obj.onStateChanged != null) { obj.onStateChanged(obj, newState); }
- if ((newState == 2) && (updateTimer == null)) { updateTimer = setInterval(obj.update, 10000); }
- if ((newState != 2) && (updateTimer != null)) { clearInterval(updateTimer); updateTimer = null; }
- if ((newState == 0) && (obj.started == true) && (retryTimer == null)) { retryTimer = setTimeout(connect, 20000); }
- if (newState == 0) { obj.ports = []; obj.portCount = 0; }
- }
- function connect() {
- if (obj.state != 0) return;
- if (retryTimer != null) { clearTimeout(retryTimer); retryTimer = null; }
- setState(1); // 1 = Connecting
- obj.update();
- }
- obj.update = function () {
- obj.fetch('/restapi/relay/outlets/all;/=name,physical_state/', 'GET', null, null, function (sender, tag, rdata, res) {
- if (res.statusCode == 207) {
- var rdata2 = null;
- if (rdata != null) { try { rdata2 = JSON.parse(rdata); } catch (ex) { } }
- if (Array.isArray(rdata2)) {
- obj.portCount = (rdata2.length / 2);
- setState(2); // 2 = Connected
- const updatedPorts = [];
- for (var i = 0; i < (rdata2.length / 2); i++) {
- const portname = rdata2[i * 2];
- const portstate = rdata2[(i * 2) + 1];
- var portchanged = false;
- if (obj.ports[i] == null) {
- // Add the port
- obj.ports[i] = { PortNumber: i + 1, PortId: 'p' + i, Name: portname, Status: 1, State: portstate, Class: 'PDU' };
- portchanged = true;
- } else {
- // Update the port
- const port = obj.ports[i];
- if (port.Name != portname) { port.Name = portname; portchanged = true; }
- if (port.State != portstate) { port.State = portstate; portchanged = true; }
- }
- if (portchanged) { updatedPorts.push(i); }
- }
- if ((updatedPorts.length > 0) && (obj.onPortsChanged != null)) { obj.onPortsChanged(obj, updatedPorts); }
- } else {
- setState(0); // 0 = Disconnected
- }
- } else {
- setState(0); // 0 = Disconnected
- }
- });
- }
- obj.powerOperation = function (event) {
- if (typeof event.portnum != 'number') return;
- if (event.action == 'turnon') { setPowerState(event.portnum - 1, true); }
- else if (event.action == 'turnoff') { setPowerState(event.portnum - 1, false); }
- }
- function setPowerState(port, state, func) {
- obj.fetch('/restapi/relay/outlets/' + port + '/state/', 'PUT', 'value=' + state, null, function (sender, tag, rdata, res) {
- if (res.statusCode == 204) { obj.update(); }
- });
- }
- obj.fetch = function (url, method, data, tag, func) {
- if (obj.state == 0) return;
- if (typeof data == 'string') { data = Buffer.from(data); }
- var rdata = [];
- const options = {
- hostname: obj.router ? 'localhost' : hostname,
- port: obj.router ? obj.router.tcpServerPort : port,
- rejectUnauthorized: false,
- checkServerIdentity: onCheckServerIdentity,
- path: url,
- method: method,
- headers: {
- 'Content-Type': 'application/x-www-form-urlencoded',
- 'accept': 'application/json',
- 'X-CSRF': 'x'
- }
- }
- if (data != null) { options.headers['Content-Length'] = data.length; }
- if (challenge != null) {
- const buf = Buffer.alloc(10);
- challenge.cnonce = crypto.randomFillSync(buf).toString('hex');
- challenge.nc = nonceCounter++;
- const ha1 = crypto.createHash('md5');
- ha1.update([username, challenge.realm, password].join(':'));
- var xha1 = ha1.digest('hex')
- const ha2 = crypto.createHash('md5');
- ha2.update([options.method, options.path].join(':'));
- var xha2 = ha2.digest('hex');
- const response = crypto.createHash('md5');
- response.update([xha1, challenge.nonce, challenge.nc, challenge.cnonce, challenge.qop, xha2].join(':'));
- var requestParams = {
- "username": username,
- "realm": challenge.realm,
- "nonce": challenge.nonce,
- "uri": options.path,
- "response": response.digest('hex'),
- "cnonce": challenge.cnonce,
- "opaque": challenge.opaque
- };
- options.headers = options.headers || {};
- options.headers.Authorization = renderDigest(requestParams) + ', algorithm=MD5, nc=' + challenge.nc + ', qop=' + challenge.qop;
- }
- const req = https.request(options, function (res) {
- if (obj.state == 0) return;
- //console.log('res.statusCode', res.statusCode);
- //if (res.statusCode != 200) { console.log(res.statusCode, res.headers, Buffer.concat(data).toString()); setState(0); return; }
- challengeRetry = 0;
- res.on('data', function (d) { rdata.push(d); });
- res.on('end', function () {
- if (res.statusCode == 401) {
- challengeRetry++;
- if (challengeRetry > 4) { setState(0); return; }
- challenge = parseChallenge(res.headers['www-authenticate']);
- obj.fetch(url, method, data, tag, func);
- return;
- } else {
- // This line is used for debugging only, used to swap a file.
- func(obj, tag, Buffer.concat(rdata), res);
- }
- });
- });
- req.on('error', function (error) { setState(0); });
- req.on('timeout', function () { setState(0); });
- if (data) { req.write(data); }
- req.end();
- }
- function parseChallenge(header) {
- header = header.replace('qop="auth,auth-int"', 'qop="auth"'); // We don't support auth-int yet, easiest way to get rid of it.
- const prefix = 'Digest ';
- const challenge = header.substr(header.indexOf(prefix) + prefix.length);
- const parts = challenge.split(',');
- const length = parts.length;
- const params = {};
- for (var i = 0; i < length; i++) {
- var part = parts[i].match(/^\s*?([a-zA-Z0-0]+)="(.*)"\s*?$/);
- if (part && part.length > 2) { params[part[1]] = part[2]; }
- }
- return params;
- }
- function renderDigest(params) {
- const parts = [];
- for (var i in params) { parts.push(i + '="' + params[i] + '"'); }
- return 'Digest ' + parts.join(', ');
- }
- return obj;
- }
- // Mini TCP port router
- function CreateMiniRouter(parent, nodeid, targetHost, targetPort) {
- const Net = require('net');
- const WebSocket = require('ws');
- const obj = {};
- const tcpSockets = {}
- obj.tcpServerPort = 0;
- obj.nodeid = nodeid;
- obj.targetHost = targetHost;
- obj.targetPort = targetPort;
- parent.parent.debug('relay', 'MiniRouter: Request relay for ' + obj.targetHost + ':' + obj.targetPort + ' thru ' + nodeid + '.');
- // Close a TCP socket and the coresponding web socket.
- function closeTcpSocket(tcpSocket) {
- if (tcpSockets[tcpSocket]) {
- delete tcpSockets[tcpSocket];
- try { tcpSocket.end(); } catch (ex) { console.log(ex); }
- if (tcpSocket.relaySocket) { try { tcpSocket.relaySocket.close(); } catch (ex) { console.log(ex); } }
- try { delete tcpSocket.relaySocket.tcpSocket; } catch (ex) { }
- try { delete tcpSocket.relaySocket; } catch (ex) { }
- }
- }
- // Close a web socket and the coresponding TCP socket.
- function closeWebSocket(webSocket) {
- const tcpSocket = webSocket.tcpSocket;
- if (tcpSocket) { closeTcpSocket(tcpSocket); }
- }
- // Start the looppback server
- obj.start = function(onReadyFunc) {
- obj.tcpServer = new Net.Server();
- obj.tcpServer.listen(0, 'localhost', function () {
- obj.tcpServerPort = obj.tcpServer.address().port;
- parent.parent.debug('relay', 'MiniRouter: Request for relay ' + obj.targetHost + ':' + obj.targetPort + ' started on port ' + obj.tcpServerPort);
- onReadyFunc(obj.tcpServerPort, obj);
- });
- obj.tcpServer.on('connection', function (socket) {
- tcpSockets[socket] = 1;
- socket.pause();
- socket.on('data', function (chunk) { // Make sure to handle flow control.
- const f = function sendDone() { sendDone.tcpSocket.resume(); }
- f.tcpSocket = this;
- if (this.relaySocket && this.relaySocket.active) { this.pause(); this.relaySocket.send(chunk, f); }
- });
- socket.on('end', function () { closeTcpSocket(this); });
- socket.on('close', function () { closeTcpSocket(this); });
- socket.on('error', function (err) { closeTcpSocket(this); });
- // Encode the device relay cookie. Note that there is no userid in this cookie.
- const domainid = obj.nodeid.split('/')[1];
- const cookie = parent.parent.encodeCookie({ nouser: 1, domainid: domainid, nodeid: obj.nodeid, tcpaddr: obj.targetHost, tcpport: obj.targetPort }, parent.parent.loginCookieEncryptionKey);
- const domain = parent.parent.config.domains[domainid];
- // Setup the correct URL with domain and use TLS only if needed.
- const options = { rejectUnauthorized: false };
- const protocol = (parent.parent.args.tlsoffload) ? 'ws' : 'wss';
- var domainadd = '';
- if ((domain.dns == null) && (domain.id != '')) { domainadd = domain.id + '/' }
- const url = protocol + '://localhost:' + parent.parent.args.port + '/' + domainadd + 'meshrelay.ashx?noping=1&hd=1&auth=' + cookie; // TODO: &p=10, Protocol 10 is Web-RDP, Specify TCP routing protocol?
- parent.parent.debug('relay', 'MiniRouter: Connection websocket to ' + url);
- socket.relaySocket = new WebSocket(url, options);
- socket.relaySocket.tcpSocket = socket;
- socket.relaySocket.on('open', function () { parent.parent.debug('relay', 'MiniRouter: Relay websocket open'); });
- socket.relaySocket.on('message', function (data) { // Make sure to handle flow control.
- if (!this.active) {
- if (data == 'c') {
- // Relay Web socket is connected, start data relay
- this.active = true;
- this.tcpSocket.resume();
- } else {
- // Could not connect web socket, close it
- closeWebSocket(this);
- }
- } else {
- // Relay more data
- this._socket.pause();
- const f = function sendDone() { sendDone.webSocket._socket.resume(); }
- f.webSocket = this;
- this.tcpSocket.write(data, f);
- }
- });
- socket.relaySocket.on('close', function (reasonCode, description) { parent.parent.debug('relay', 'MiniRouter: Relay websocket closed'); closeWebSocket(this); });
- socket.relaySocket.on('error', function (err) { parent.parent.debug('relay', 'MiniRouter: Relay websocket error: ' + err); closeWebSocket(this); });
- });
- }
- // Stop the looppback server and all relay sockets
- obj.stop = function () {
- for (var tcpSocket in tcpSockets) { closeTcpSocket(tcpSocket); }
- obj.tcpServer.close();
- obj.tcpServer = null;
- }
- return obj;
- }
- module.exports.CreateIPKVMManager = CreateIPKVMManager;
|