Ylianst/MeshCentral
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshCentral.git synced 2024-11-22 22:17:31 +03:00
Code Issues Packages Projects Releases Wiki Activity
ace4046415
MeshCentral/meshagent.js

576 lines
34 KiB
JavaScript
Raw Normal View History

Initial main commit
2017-08-28 19:27:45 +03:00
/**
* @description Meshcentral MeshAgent
* @author Ylian Saint-Hilaire & Bryan Roe
* @version v0.0.1
*/
// Construct a MeshAgent object, called upon connection
module.exports.CreateMeshAgent = function (parent, db, ws, req, args, domain) {
var obj = {};
obj.parent = parent;
obj.db = db;
obj.ws = ws;
obj.fs = parent.fs;
obj.args = args;
obj.nodeid = null;
obj.meshid = null;
obj.dbNodeKey = null;
obj.dbMeshKey = null;
obj.forge = parent.parent.certificateOperations.forge;
obj.common = parent.parent.common;
obj.authenticated = 0;
obj.domain = domain;
obj.receivedCommands = 0;
obj.connectTime = null;
obj.agentCoreCheck = 0;
obj.agentInfo;
obj.agentUpdate = null;
var agentUpdateBlockSize = 65520;
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
obj.remoteaddr = obj.ws._socket.remoteAddress;
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
obj.useSHA386 = false;
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
if (obj.remoteaddr.startsWith('::ffff:')) { obj.remoteaddr = obj.remoteaddr.substring(7); }
Much improved MeshAgent and javascript module support.
2017-10-05 06:35:52 +03:00
ws._socket.setKeepAlive(true, 0); // Set TCP keep alive
Initial main commit
2017-08-28 19:27:45 +03:00
// Send a message to the mesh agent
Added a lot of the load-balancing support
2017-09-13 21:25:57 +03:00
obj.send = function (data) { try { if (typeof data == 'string') { obj.ws.send(new Buffer(data, 'binary')); } else { obj.ws.send(data); } } catch (e) { } }
Initial main commit
2017-08-28 19:27:45 +03:00
// Disconnect this agent
obj.close = function (arg) {
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
if ((arg == 1) || (arg == null)) { try { obj.ws.close(); obj.parent.parent.debug(1, 'Soft disconnect ' + obj.nodeid + ' (' + obj.remoteaddr + ')'); } catch (e) { console.log(e); } } // Soft close, close the websocket
if (arg == 2) { try { obj.ws._socket._parent.end(); obj.parent.parent.debug(1, 'Hard disconnect ' + obj.nodeid + ' (' + obj.remoteaddr + ')'); } catch (e) { console.log(e); } } // Hard close, close the TCP socket
Initial main commit
2017-08-28 19:27:45 +03:00
if (obj.parent.wsagents[obj.dbNodeKey] == obj) {
delete obj.parent.wsagents[obj.dbNodeKey];
obj.parent.parent.ClearConnectivityState(obj.dbMeshKey, obj.dbNodeKey, 1);
}
// Other clean up may be needed here
if (obj.unauth) { delete obj.unauth; }
if (obj.agentUpdate != null) { obj.fs.close(obj.agentUpdate.fd); obj.agentUpdate = null; }
}
// When data is received from the mesh agent web socket
ws.on('message', function (msg) {
if (msg.length < 2) return;
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if (typeof msg == 'object') { msg = msg.toString('binary'); } // TODO: Could change this entire method to use Buffer instead of binary string
Initial main commit
2017-08-28 19:27:45 +03:00
if (obj.authenticated == 2) { // We are authenticated
if (msg.charCodeAt(0) == 123) { processAgentData(msg); }
if (msg.length < 2) return;
var cmdid = obj.common.ReadShort(msg, 0);
if (cmdid == 11) { // MeshCommand_CoreModuleHash
if (msg.length == 4) { ChangeAgentCoreInfo({ caps: 0 }); } // If the agent indicated that no core is running, clear the core information string.
// Mesh core hash, sent by agent with the hash of the current mesh core.
if (obj.agentCoreCheck == 1000) return; // If we are using a custom core, don't try to update it.
// We need to check if the core is current.
// TODO: Check if we have a mesh specific core. If so, use that.
var agentMeshCoreHash = null;
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if (msg.length == 52) { agentMeshCoreHash = msg.substring(4, 52); }
Initial main commit
2017-08-28 19:27:45 +03:00
if (agentMeshCoreHash != obj.parent.parent.defaultMeshCoreHash) {
if (obj.agentCoreCheck < 5) { // This check is in place to avoid a looping core update.
if (obj.parent.parent.defaultMeshCoreHash == null) {
// Update no core
obj.send(obj.common.ShortToStr(10) + obj.common.ShortToStr(0)); // Command 10, ask mesh agent to clear the core
} else {
// Update new core
obj.send(obj.common.ShortToStr(10) + obj.common.ShortToStr(0) + obj.parent.parent.defaultMeshCoreHash + obj.parent.parent.defaultMeshCore); // Command 10, ask mesh agent to set the core
}
obj.agentCoreCheck++;
}
} else {
obj.agentCoreCheck = 0;
}
}
else if (cmdid == 12) { // MeshCommand_AgentHash
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if ((msg.length == 52) && (obj.agentExeInfo != null) && (obj.agentExeInfo.update == true)) {
Initial main commit
2017-08-28 19:27:45 +03:00
var agenthash = obj.common.rstr2hex(msg.substring(4)).toLowerCase();
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if (agenthash != obj.agentExeInfo.hash) {
Initial main commit
2017-08-28 19:27:45 +03:00
// Mesh agent update required
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
console.log('Agent update required, NodeID=0x' + obj.nodeid.substring(0, 16) + ', ' + obj.agentExeInfo.desc);
obj.fs.open(obj.agentExeInfo.path, 'r', function (err, fd) {
Initial main commit
2017-08-28 19:27:45 +03:00
if (err) { return console.error(err); }
obj.agentUpdate = { oldHash: agenthash, ptr: 0, buf: new Buffer(agentUpdateBlockSize + 4), fd: fd };
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
// We got the agent file open on the server side, tell the agent we are sending an update starting with the SHA384 hash of the result
Initial main commit
2017-08-28 19:27:45 +03:00
//console.log("Agent update file open.");
obj.send(obj.common.ShortToStr(13) + obj.common.ShortToStr(0)); // Command 13, start mesh agent download
// Send the first mesh agent update data block
obj.agentUpdate.buf[0] = 0;
obj.agentUpdate.buf[1] = 14;
obj.agentUpdate.buf[2] = 0;
obj.agentUpdate.buf[3] = 1;
var len = -1;
try { len = obj.fs.readSync(obj.agentUpdate.fd, obj.agentUpdate.buf, 4, agentUpdateBlockSize, obj.agentUpdate.ptr); } catch (e) { }
if (len == -1) {
// Error reading the agent file, stop here.
obj.fs.close(obj.agentUpdate.fd);
obj.agentUpdate = null;
} else {
// Send the first block to the agent
obj.agentUpdate.ptr += len;
//console.log("Agent update send first block: " + len);
obj.send(obj.agentUpdate.buf); // Command 14, mesh agent first data block
}
});
}
}
}
else if (cmdid == 14) { // MeshCommand_AgentBinaryBlock
if ((msg.length == 4) && (obj.agentUpdate != null)) {
var status = obj.common.ReadShort(msg, 2);
if (status == 1) {
var len = -1;
try { len = obj.fs.readSync(obj.agentUpdate.fd, obj.agentUpdate.buf, 4, agentUpdateBlockSize, obj.agentUpdate.ptr); } catch (e) { }
if (len == -1) {
// Error reading the agent file, stop here.
obj.fs.close(obj.agentUpdate.fd);
obj.agentUpdate = null;
} else {
// Send the next block to the agent
obj.agentUpdate.ptr += len;
//console.log("Agent update send next block: " + len);
if (len == agentUpdateBlockSize) { obj.ws.send(obj.agentUpdate.buf); } else { obj.ws.send(obj.agentUpdate.buf.slice(0, len + 4)); } // Command 14, mesh agent next data block
if (len < agentUpdateBlockSize) {
//console.log("Agent update sent");
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
obj.send(obj.common.ShortToStr(13) + obj.common.ShortToStr(0) + obj.common.hex2rstr(obj.agentInfo.hash)); // Command 13, end mesh agent download, send agent SHA384 hash
Initial main commit
2017-08-28 19:27:45 +03:00
obj.fs.close(obj.agentUpdate.fd);
obj.agentUpdate = null;
}
}
}
}
}
else if (cmdid == 15) { // MeshCommand_AgentTag
ChangeAgentTag(msg.substring(2));
}
}
else if (obj.authenticated < 2) { // We are not authenticated
var cmd = obj.common.ReadShort(msg, 0);
if (cmd == 1) {
// Agent authentication request
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if ((msg.length != 98) || ((obj.receivedCommands & 1) != 0)) return;
Initial main commit
2017-08-28 19:27:45 +03:00
obj.receivedCommands += 1; // Agent can't send the same command twice on the same connection ever. Block DOS attack path.
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
// Check that the server hash matches out own web certificate hash (SHA386)
if (obj.parent.webCertificatHash != msg.substring(2, 50)) { obj.close(); return; }
Initial main commit
2017-08-28 19:27:45 +03:00
// Use our server private key to sign the ServerHash + AgentNonce + ServerNonce
var privateKey = obj.forge.pki.privateKeyFromPem(obj.parent.certificates.agent.key);
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
var md = obj.forge.md.sha384.create();
Initial main commit
2017-08-28 19:27:45 +03:00
md.update(msg.substring(2), 'binary');
md.update(obj.nonce, 'binary');
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
obj.agentnonce = msg.substring(50);
Initial main commit
2017-08-28 19:27:45 +03:00
// Send back our certificate + signature
obj.send(obj.common.ShortToStr(2) + obj.common.ShortToStr(parent.agentCertificatAsn1.length) + parent.agentCertificatAsn1 + privateKey.sign(md)); // Command 2, certificate + signature
// Check the agent signature if we can
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (obj.unauthsign != null) {
Initial main commit
2017-08-28 19:27:45 +03:00
if (processAgentSignature(obj.unauthsign) == false) { disonnect(); return; } else { completeAgentConnection(); }
}
}
else if (cmd == 2) {
// Agent certificate
if ((msg.length < 4) || ((obj.receivedCommands & 2) != 0)) return;
obj.receivedCommands += 2; // Agent can't send the same command twice on the same connection ever. Block DOS attack path.
// Decode the certificate
var certlen = obj.common.ReadShort(msg, 2);
obj.unauth = {};
obj.unauth.nodeCert = null;
try { obj.unauth.nodeCert = obj.forge.pki.certificateFromAsn1(obj.forge.asn1.fromDer(msg.substring(4, 4 + certlen))); } catch (e) { return; }
Base64 encoding of meshid/nodeid in the database.
2017-10-16 03:36:06 +03:00
obj.unauth.nodeid = new Buffer(obj.forge.pki.getPublicKeyFingerprint(obj.unauth.nodeCert.publicKey, { md: obj.forge.md.sha384.create() }).data, 'binary').toString('base64').replace(/\+/g, '@').replace(/\//g, '$');
Initial main commit
2017-08-28 19:27:45 +03:00
// Check the agent signature if we can
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if (obj.agentnonce == null) { obj.unauthsign = msg.substring(4 + certlen); } else { if (processAgentSignature(msg.substring(4 + certlen)) == false) { console.log('Bad Agent Signature'); obj.close(); return; } }
Initial main commit
2017-08-28 19:27:45 +03:00
completeAgentConnection();
}
else if (cmd == 3) {
// Agent meshid
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if ((msg.length < 72) || ((obj.receivedCommands & 4) != 0)) return;
Initial main commit
2017-08-28 19:27:45 +03:00
obj.receivedCommands += 4; // Agent can't send the same command twice on the same connection ever. Block DOS attack path.
// Set the meshid
obj.agentInfo = {};
obj.agentInfo.infoVersion = obj.common.ReadInt(msg, 2);
obj.agentInfo.agentId = obj.common.ReadInt(msg, 6);
obj.agentInfo.agentVersion = obj.common.ReadInt(msg, 10);
obj.agentInfo.platformType = obj.common.ReadInt(msg, 14);
Base64 encoding of meshid/nodeid in the database.
2017-10-16 03:36:06 +03:00
obj.meshid = new Buffer(msg.substring(18, 66), 'binary').toString('base64').replace(/\+/g, '@').replace(/\//g, '$');;
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
obj.agentInfo.capabilities = obj.common.ReadInt(msg, 66);
var computerNameLen = obj.common.ReadShort(msg, 70);
obj.agentInfo.computerName = msg.substring(72, 72 + computerNameLen);
Initial main commit
2017-08-28 19:27:45 +03:00
obj.dbMeshKey = 'mesh/' + obj.domain.id + '/' + obj.meshid;
completeAgentConnection();
}
}
});
// If error, do nothing
ws.on('error', function (err) { console.log(err); });
// If the mesh agent web socket is closed, clean up.
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
ws.on('close', function (req) { obj.parent.parent.debug(1, 'Agent disconnect ' + obj.nodeid + ' (' + obj.remoteaddr + ')'); obj.close(0); });
// obj.ws._socket._parent.on('close', function (req) { obj.parent.parent.debug(1, 'Agent TCP disconnect ' + obj.nodeid + ' (' + obj.remoteaddr + ')'); });
Initial main commit
2017-08-28 19:27:45 +03:00
// Start authenticate the mesh agent by sending a auth nonce & server TLS cert hash.
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
// Send 384 bits SHA384 hash of TLS cert public key + 384 bits nonce
obj.nonce = obj.forge.random.getBytesSync(48);
Initial main commit
2017-08-28 19:27:45 +03:00
obj.send(obj.common.ShortToStr(1) + parent.webCertificatHash + obj.nonce); // Command 1, hash + nonce
// Once we get all the information about an agent, run this to hook everything up to the server
function completeAgentConnection() {
if (obj.authenticated =! 1 || obj.meshid == null) return;
// Check that the mesh exists
obj.db.Get(obj.dbMeshKey, function (err, meshes) {
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
if (meshes.length == 0) { console.log('Agent connected with invalid domain/mesh, holding connection (' + obj.remoteaddr + ').'); return; } // If we disconnect, the agnet will just reconnect. We need to log this or tell agent to connect in a few hours.
Initial main commit
2017-08-28 19:27:45 +03:00
var mesh = meshes[0];
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
if (mesh.mtype != 2) { console.log('Agent connected with invalid mesh type, holding connection (' + obj.remoteaddr + ').'); return; } // If we disconnect, the agnet will just reconnect. We need to log this or tell agent to connect in a few hours.
Initial main commit
2017-08-28 19:27:45 +03:00
// Check that the node exists
obj.db.Get(obj.dbNodeKey, function (err, nodes) {
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
var device;
Initial main commit
2017-08-28 19:27:45 +03:00
// Mark when we connected to this agent
obj.connectTime = Date.now();
if (nodes.length == 0) {
// This node does not exist, create it.
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
device = { type: 'node', mtype: mesh.mtype, _id: obj.dbNodeKey, icon: obj.agentInfo.platformType, meshid: obj.dbMeshKey, name: obj.agentInfo.computerName, domain: domain.id, agent: { ver: obj.agentInfo.agentVersion, id: obj.agentInfo.agentId, caps: obj.agentInfo.capabilities }, host: null };
Initial main commit
2017-08-28 19:27:45 +03:00
obj.db.Set(device);
// Event the new node
var change = 'Added device ' + obj.agentInfo.computerName + ' to mesh ' + mesh.name;
obj.parent.parent.DispatchEvent(['*', obj.dbMeshKey], obj, { etype: 'node', action: 'addnode', node: device, msg: change, domain: domain.id })
} else {
// Device already exists, look if changes has occured
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
device = nodes[0];
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (device.agent == null) {
Initial main commit
2017-08-28 19:27:45 +03:00
device.agent = { ver: obj.agentInfo.agentVersion, id: obj.agentInfo.agentId, caps: obj.agentInfo.capabilities }; change = 1;
} else {
var changes = [], change = 0;
if (device.agent.ver != obj.agentInfo.agentVersion) { device.agent.ver = obj.agentInfo.agentVersion; change = 1; changes.push('agent version'); }
if (device.agent.id != obj.agentInfo.agentId) { device.agent.id = obj.agentInfo.agentId; change = 1; changes.push('agent type'); }
if ((device.agent.caps & 24) != (obj.agentInfo.capabilities & 24)) { device.agent.caps = obj.agentInfo.capabilities; change = 1; changes.push('agent capabilities'); } // If agent console or javascript support changes, update capabilities
if (device.meshid != obj.dbMeshKey) { device.meshid = obj.dbMeshKey; change = 1; changes.push('agent meshid'); } // TODO: If the meshid changes, we need to event a device add/remove on both meshes
if (change == 1) {
obj.db.Set(device);
// Event the node change
var event = { etype: 'node', action: 'changenode', nodeid: obj.dbNodeKey, domain: domain.id, msg: 'Changed device ' + device.name + ' from mesh ' + mesh.name + ': ' + changes.join(', ') };
var device2 = obj.common.Clone(device);
if (device2.intelamt && device2.intelamt.pass) delete device2.intelamt.pass; // Remove the Intel AMT password before eventing this.
event.node = device;
obj.parent.parent.DispatchEvent(['*', device.meshid], obj, event);
}
}
}
// Check if this agent is already connected
var dupAgent = obj.parent.wsagents[obj.dbNodeKey];
obj.parent.wsagents[obj.dbNodeKey] = obj;
if (dupAgent) {
// Close the duplicate agent
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
obj.parent.parent.debug(1, 'Duplicate agent ' + obj.nodeid + ' (' + obj.remoteaddr + ')');
Initial main commit
2017-08-28 19:27:45 +03:00
dupAgent.close();
} else {
// Indicate the agent is connected
obj.parent.parent.SetConnectivityState(obj.dbMeshKey, obj.dbNodeKey, obj.connectTime, 1, 1);
}
// We are done, ready to communicate with this agent
obj.authenticated = 2;
// Command 4, inform mesh agent that it's authenticated.
obj.send(obj.common.ShortToStr(4));
// Check the mesh core, if the agent is capable of running one
if ((obj.agentInfo.capabilities & 16) != 0) { obj.send(obj.common.ShortToStr(11) + obj.common.ShortToStr(0)); } // Command 11, ask for mesh core hash.
// Check if we need to make an native update check
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
obj.agentExeInfo = obj.parent.parent.meshAgentBinaries[obj.agentInfo.agentId];
if ((obj.agentExeInfo != null) && (obj.agentExeInfo.update == true)) { obj.send(obj.common.ShortToStr(12) + obj.common.ShortToStr(0)); } // Ask the agent for it's executable binary hash
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
Fixed agent desktop/terminal pipes + added IP location info store in the server
2017-09-06 20:08:01 +03:00
// Check if we already have IP location information for this node
obj.db.Get('iploc_' + obj.remoteaddr, function (err, iplocs) {
if (iplocs.length == 1) {
// We have a location in the database for this remote IP
var iploc = nodes[0], x = {};
x.publicip = iploc.ip;
Added server self-update support along with many fixes.
2017-09-07 04:10:24 +03:00
x.iploc = iploc.loc + ',' + (Math.floor((new Date(iploc.date)) / 1000));
Fixed agent desktop/terminal pipes + added IP location info store in the server
2017-09-06 20:08:01 +03:00
ChangeAgentLocationInfo(x);
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
} else {
Fixed agent desktop/terminal pipes + added IP location info store in the server
2017-09-06 20:08:01 +03:00
// Check if we need to ask for the IP location
var doIpLocation = 0;
if (device.iploc == null) {
doIpLocation = 1;
} else {
var loc = device.iploc.split(',');
if (loc.length < 3) {
doIpLocation = 2;
} else {
var t = new Date((parseFloat(loc[2]) * 1000)), now = Date.now();
t.setDate(t.getDate() + 20);
if (t < now) { doIpLocation = 3; }
}
}
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
Fixed agent desktop/terminal pipes + added IP location info store in the server
2017-09-06 20:08:01 +03:00
// If we need to ask for IP location, see if we have the quota to do it.
if (doIpLocation > 0) {
obj.db.getValueOfTheDay('ipLocationRequestLimitor', 10, function (ipLocationLimitor) {
if (ipLocationLimitor.value > 0) {
ipLocationLimitor.value--;
obj.db.Set(ipLocationLimitor);
obj.send(JSON.stringify({ action: 'iplocation' }));
}
});
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
}
Fixed agent desktop/terminal pipes + added IP location info store in the server
2017-09-06 20:08:01 +03:00
}
});
Initial main commit
2017-08-28 19:27:45 +03:00
});
});
}
// Verify the agent signature
function processAgentSignature(msg) {
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
var md = obj.forge.md.sha384.create(); // TODO: Switch this to SHA384 on node instead of forge.
Initial main commit
2017-08-28 19:27:45 +03:00
md.update(obj.parent.webCertificatHash, 'binary');
md.update(obj.nonce, 'binary');
md.update(obj.agentnonce, 'binary');
Improved crypto and removed dependency on WebSocket library, using ws instead.
2017-10-15 09:22:19 +03:00
if (obj.unauth.nodeCert.publicKey.verify(md.digest().bytes(), msg) == false) { return false; }
Initial main commit
2017-08-28 19:27:45 +03:00
// Connection is a success, clean up
Base64 encoding of meshid/nodeid in the database.
2017-10-16 03:36:06 +03:00
obj.nodeid = obj.unauth.nodeid;
Initial main commit
2017-08-28 19:27:45 +03:00
obj.dbNodeKey = 'node/' + domain.id + '/' + obj.nodeid;
delete obj.nonce;
delete obj.agentnonce;
delete obj.unauth;
if (obj.unauthsign) delete obj.unauthsign;
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
obj.parent.parent.debug(1, 'Verified agent connection to ' + obj.nodeid + ' (' + obj.remoteaddr + ').');
Initial main commit
2017-08-28 19:27:45 +03:00
obj.authenticated = 1;
return true;
}
// Process incoming agent JSON data
function processAgentData(msg) {
var str = msg.toString('utf8');
if (str[0] == '{') {
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
try { command = JSON.parse(str) } catch (e) { console.log('Unable to parse JSON (' + obj.remoteaddr + ').'); return; } // If the command can't be parsed, ignore it.
Initial main commit
2017-08-28 19:27:45 +03:00
switch (command.action) {
case 'msg':
{
// Route a message.
// If this command has a sessionid, that is the target.
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (command.sessionid != null) {
Initial main commit
2017-08-28 19:27:45 +03:00
var splitsessionid = command.sessionid.split('/');
// Check that we are in the same domain and the user has rights over this node.
if ((splitsessionid[0] == 'user') && (splitsessionid[1] == domain.id)) {
// Check if this user has rights to get this message
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
//if (mesh.links[user._id] == null || ((mesh.links[user._id].rights & 16) == 0)) return; // TODO!!!!!!!!!!!!!!!!!!!!!
Initial main commit
2017-08-28 19:27:45 +03:00
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
// See if the session is connected. If so, go ahead and send this message to the target node
Initial main commit
2017-08-28 19:27:45 +03:00
var ws = obj.parent.wssessions2[command.sessionid];
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (ws != null) {
Initial main commit
2017-08-28 19:27:45 +03:00
command.nodeid = obj.dbNodeKey; // Set the nodeid, required for responses.
delete command.sessionid; // Remove the sessionid, since we are sending to that sessionid, so it's implyed.
ws.send(JSON.stringify(command));
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
} else if (obj.parent.parent.multiServer != null) {
Completed server load-balancing support
2017-09-21 00:44:22 +03:00
// See if we can send this to a peer server
var serverid = obj.parent.wsPeerSessions2[command.sessionid];
if (serverid != null) {
command.fromNodeid = obj.dbNodeKey;
obj.parent.parent.multiServer.DispatchMessageSingleServer(command, serverid);
}
Initial main commit
2017-08-28 19:27:45 +03:00
}
}
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
} else if (command.userid != null) { // If this command has a userid, that is the target.
Initial main commit
2017-08-28 19:27:45 +03:00
var splituserid = command.userid.split('/');
// Check that we are in the same domain and the user has rights over this node.
if ((splituserid[0] == 'user') && (splituserid[1] == domain.id)) {
// Check if this user has rights to get this message
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
//if (mesh.links[user._id] == null || ((mesh.links[user._id].rights & 16) == 0)) return; // TODO!!!!!!!!!!!!!!!!!!!!!
Initial main commit
2017-08-28 19:27:45 +03:00
// See if the session is connected
var sessions = obj.parent.wssessions[command.userid];
// Go ahead and send this message to the target node
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (sessions != null) {
Initial main commit
2017-08-28 19:27:45 +03:00
command.nodeid = obj.dbNodeKey; // Set the nodeid, required for responses.
delete command.userid; // Remove the userid, since we are sending to that userid, so it's implyed.
for (var i in sessions) { sessions[i].send(JSON.stringify(command)); }
}
}
} else { // Route this command to the mesh
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
command.nodeid = obj.dbNodeKey;
var cmdstr = JSON.stringify(command);
Initial main commit
2017-08-28 19:27:45 +03:00
for (var userid in obj.parent.wssessions) { // Find all connected users for this mesh and send the message
var user = obj.parent.users[userid];
if (user) {
var rights = user.links[obj.dbMeshKey];
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (rights != null) { // TODO: Look at what rights are needed for message routing
Initial main commit
2017-08-28 19:27:45 +03:00
var sessions = obj.parent.wssessions[userid];
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
// Send the message to all users on this server
for (var i in sessions) { sessions[i].send(cmdstr); }
Initial main commit
2017-08-28 19:27:45 +03:00
}
}
}
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
// Send the message to all users of other servers
if (obj.parent.parent.multiServer != null) {
delete command.nodeid;
command.fromNodeid = obj.dbNodeKey;
command.meshid = obj.dbMeshKey;
obj.parent.parent.multiServer.DispatchMessage(command);
}
Initial main commit
2017-08-28 19:27:45 +03:00
}
break;
}
case 'coreinfo':
{
// Sent by the agent to update agent information
ChangeAgentCoreInfo(command);
break;
}
case 'netinfo':
{
// Sent by the agent to update agent network interface information
delete command.action;
command.updateTime = Date.now();
command._id = 'if' + obj.dbNodeKey;
command.type = 'ifinfo';
obj.db.Set(command);
// Event the node interface information change
obj.parent.parent.DispatchEvent(['*', obj.meshid], obj, { action: 'ifchange', nodeid: obj.dbNodeKey, domain: domain.id, nolog: 1 });
Added public IP location information to the mesh agent
2017-08-28 22:48:53 +03:00
break;
}
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
case 'iplocation':
Added public IP location information to the mesh agent
2017-08-28 22:48:53 +03:00
{
// Sent by the agent to update location information
Fixed location issue
2017-08-30 23:52:56 +03:00
if ((command.type == 'publicip') && (command.value != null) && (typeof command.value == 'object') && (command.value.ip) && (command.value.loc)) {
Added device location
2017-08-29 01:06:29 +03:00
var x = {};
x.publicip = command.value.ip;
Added IP location server rate limit
2017-09-06 03:19:28 +03:00
x.iploc = command.value.loc + ',' + (Math.floor(Date.now() / 1000) );
Added device location
2017-08-29 01:06:29 +03:00
ChangeAgentLocationInfo(x);
Fixed agent desktop/terminal pipes + added IP location info store in the server
2017-09-06 20:08:01 +03:00
command.value._id = 'iploc_' + command.value.ip;
command.value.type = 'iploc';
command.value.date = Date.now();
obj.db.Set(command.value); // Store the IP to location data in the database
// Sample Value: { ip: '192.55.64.246', city: 'Hillsboro', region: 'Oregon', country: 'US', loc: '45.4443,-122.9663', org: 'AS4983 Intel Corporation', postal: '97123' }
Added device location
2017-08-29 01:06:29 +03:00
}
Initial main commit
2017-08-28 19:27:45 +03:00
break;
}
}
}
}
// Change the current core information string and event it
function ChangeAgentCoreInfo(command) {
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if ((command == null) || (command == null)) return; // Safety, should never happen.
Initial main commit
2017-08-28 19:27:45 +03:00
// Check capabilities value
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (command.caps == null || command.caps == null) { command.caps = 0; } else { if (typeof command.caps != 'number') command.caps = 0; }
Initial main commit
2017-08-28 19:27:45 +03:00
// Check that the mesh exists
obj.db.Get(obj.dbMeshKey, function (err, meshes) {
if (meshes.length != 1) return;
var mesh = meshes[0];
// Get the node and change it if needed
obj.db.Get(obj.dbNodeKey, function (err, nodes) {
if (nodes.length != 1) return;
var device = nodes[0];
if (device.agent) {
var changes = [], change = 0;
// Check if anything changes
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (device.agent.core != command.value) { if ((command.value == null) && (device.agent.core != null)) { delete device.agent.core; } else { device.agent.core = command.value; } change = 1; changes.push('agent core'); }
Initial main commit
2017-08-28 19:27:45 +03:00
if ((device.agent.caps & 0xFFFFFFE7) != (command.caps & 0xFFFFFFE7)) { device.agent.caps = ((device.agent.caps & 24) + (command.caps & 0xFFFFFFE7)); change = 1; changes.push('agent capabilities'); } // Allow Javascript on the agent to change all capabilities except console and javascript support
if (command.intelamt) {
if (!device.intelamt) { device.intelamt = {}; }
if (device.intelamt.ver != command.intelamt.ver) { device.intelamt.ver = command.intelamt.ver; change = 1; changes.push('AMT version'); }
if (device.intelamt.state != command.intelamt.state) { device.intelamt.state = command.intelamt.state; change = 1; changes.push('AMT state'); }
if (device.intelamt.flags != command.intelamt.flags) { device.intelamt.flags = command.intelamt.flags; change = 1; changes.push('AMT flags'); }
if (device.intelamt.host != command.intelamt.host) { device.intelamt.host = command.intelamt.host; change = 1; changes.push('AMT host'); }
}
if (mesh.mtype == 2) {
Added MeshAgent power actions
2017-09-01 21:23:22 +03:00
if (device.host != obj.remoteaddr) { device.host = obj.remoteaddr; change = 1; changes.push('host'); }
Initial main commit
2017-08-28 19:27:45 +03:00
// TODO: Check that the agent has an interface that is the same as the one we got this websocket connection on. Only set if we have a match.
}
// If there are changes, save and event
if (change == 1) {
obj.db.Set(device);
// Event the node change
var event = { etype: 'node', action: 'changenode', nodeid: obj.dbNodeKey, domain: domain.id, msg: 'Changed device ' + device.name + ' from mesh ' + mesh.name + ': ' + changes.join(', ') };
var device2 = obj.common.Clone(device);
if (device2.intelamt && device2.intelamt.pass) delete device2.intelamt.pass; // Remove the Intel AMT password before eventing this.
event.node = device;
obj.parent.parent.DispatchEvent(['*', device.meshid], obj, event);
}
}
});
});
}
Added device location
2017-08-29 01:06:29 +03:00
// Change the current core information string and event it
function ChangeAgentLocationInfo(command) {
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if ((command == null) || (command == null)) return; // Safety, should never happen.
Added device location
2017-08-29 01:06:29 +03:00
// Check that the mesh exists
obj.db.Get(obj.dbMeshKey, function (err, meshes) {
if (meshes.length != 1) return;
var mesh = meshes[0];
// Get the node and change it if needed
obj.db.Get(obj.dbNodeKey, function (err, nodes) {
if (nodes.length != 1) return;
var device = nodes[0];
if (device.agent) {
var changes = [], change = 0;
// Check if anything changes
if ((command.publicip) && (device.publicip != command.publicip)) { device.publicip = command.publicip; change = 1; changes.push('public ip'); }
if ((command.iploc) && (device.iploc != command.iploc)) { device.iploc = command.iploc; change = 1; changes.push('ip location'); }
// If there are changes, save and event
if (change == 1) {
obj.db.Set(device);
// Event the node change
var event = { etype: 'node', action: 'changenode', nodeid: obj.dbNodeKey, domain: domain.id, msg: 'Changed device ' + device.name + ' from mesh ' + mesh.name + ': ' + changes.join(', ') };
var device2 = obj.common.Clone(device);
if (device2.intelamt && device2.intelamt.pass) delete device2.intelamt.pass; // Remove the Intel AMT password before eventing this.
event.node = device;
obj.parent.parent.DispatchEvent(['*', device.meshid], obj, event);
}
}
});
});
}
Initial main commit
2017-08-28 19:27:45 +03:00
// Update the mesh agent tab in the database
function ChangeAgentTag(tag) {
Added new account creation and server peering flow control
2017-09-15 21:45:06 +03:00
if (tag.length == 0) { tag = null; }
Initial main commit
2017-08-28 19:27:45 +03:00
// Get the node and change it if needed
obj.db.Get(obj.dbNodeKey, function (err, nodes) {
if (nodes.length != 1) return;
var device = nodes[0];
if (device.agent) {
if (device.agent.tag != tag) {
device.agent.tag = tag;
obj.db.Set(device);
// Event the node change
var event = { etype: 'node', action: 'changenode', nodeid: obj.dbNodeKey, domain: domain.id, nolog: 1 };
var device2 = obj.common.Clone(device);
if (device2.intelamt && device2.intelamt.pass) delete device2.intelamt.pass; // Remove the Intel AMT password before eventing this.
event.node = device;
obj.parent.parent.DispatchEvent(['*', device.meshid], obj, event);
}
}
});
}
return obj;
}
Reference in New Issue Copy Permalink