129 lines
3.7 KiB
JavaScript
129 lines
3.7 KiB
JavaScript
var server = require('./lib/server');
|
|
var ping = require('./lib/ping');
|
|
var logger = require('./lib/logger');
|
|
var mojang = require('./lib/mojang_services');
|
|
var util = require('./lib/util');
|
|
|
|
var config = require('./config.json');
|
|
|
|
var networkHistory = [];
|
|
var connectedClients = 0;
|
|
|
|
function pingAll() {
|
|
var servers = config.servers;
|
|
|
|
for (var i = 0; i < servers.length; i++) {
|
|
// Make sure we lock our scope.
|
|
(function(network) {
|
|
ping.ping(network.ip, network.port, network.type, config.rates.connectTimeout, function(err, res) {
|
|
// Handle our ping results, if it succeeded.
|
|
if (err) {
|
|
logger.log('error', 'Failed to ping ' + network.ip + ': ' + JSON.stringify(err));
|
|
}
|
|
|
|
// If we have favicon override specified, use it.
|
|
if (res && config.faviconOverride && config.faviconOverride[network.name]) {
|
|
res.favicon = config.faviconOverride[network.name];
|
|
}
|
|
|
|
var networkSnapshot = {
|
|
info: {
|
|
name: network.name,
|
|
timestamp: util.getCurrentTimeMs()
|
|
}
|
|
};
|
|
|
|
if (res) {
|
|
networkSnapshot.result = res;
|
|
} else if (err) {
|
|
networkSnapshot.error = err;
|
|
}
|
|
|
|
server.io.sockets.emit('update', networkSnapshot);
|
|
|
|
// Log our response.
|
|
if (!networkHistory[network.ip]) {
|
|
networkHistory[network.ip] = [];
|
|
}
|
|
|
|
var _networkHistory = networkHistory[network.ip];
|
|
|
|
// Remove our previous data that we don't need anymore.
|
|
for (var i = 0; i < _networkHistory.length; i++) {
|
|
delete _networkHistory[i].info;
|
|
|
|
if (_networkHistory[i].result) {
|
|
delete _networkHistory[i].result.favicon;
|
|
}
|
|
}
|
|
|
|
_networkHistory.push({
|
|
error: err,
|
|
result: res,
|
|
timestamp: util.getCurrentTimeMs(),
|
|
info: {
|
|
ip: network.ip,
|
|
port: network.port,
|
|
type: network.type,
|
|
name: network.name
|
|
}
|
|
});
|
|
|
|
// Make sure we never log too much.
|
|
if (_networkHistory.length > 72) { // 60/2.5 = 24, so 24 is one minute
|
|
_networkHistory.shift();
|
|
}
|
|
});
|
|
})(servers[i]);
|
|
}
|
|
}
|
|
|
|
// Start our main loop that does everything.
|
|
function startMainLoop() {
|
|
util.setIntervalNoDelay(pingAll, config.rates.pingAll);
|
|
|
|
util.setIntervalNoDelay(function() {
|
|
mojang.update(config.rates.mojangStatusTimeout);
|
|
|
|
server.io.sockets.emit('updateMojangServices', mojang.toMessage());
|
|
}, config.rates.upateMojangStatus);
|
|
}
|
|
|
|
server.start(function() {
|
|
// Track how many people are currently connected.
|
|
server.io.on('connect', function(client) {
|
|
// If we haven't sent out at least one round of pings, disconnect them for now.
|
|
if (Object.keys(networkHistory).length < config.servers.length) {
|
|
client.disconnect();
|
|
|
|
return;
|
|
}
|
|
|
|
// We're good to connect them!
|
|
connectedClients += 1;
|
|
|
|
logger.log('info', 'Accepted connection: %s, total clients: %d', client.request.connection.remoteAddress, connectedClients);
|
|
|
|
setTimeout(function() {
|
|
// Send them our previous data, so they have somewhere to start.
|
|
client.emit('updateMojangServices', mojang.toMessage());
|
|
|
|
// Remap our associative array into just an array.
|
|
var networkHistoryKeys = Object.keys(networkHistory);
|
|
|
|
// Send each individually, this should look cleaner than waiting for one big array to transfer.
|
|
for (var i = 0; i < networkHistoryKeys.length; i++) {
|
|
client.emit('add', [networkHistory[networkHistoryKeys[i]]]);
|
|
}
|
|
}, 1);
|
|
|
|
// Attach our listeners.
|
|
client.on('disconnect', function(client) {
|
|
connectedClients -= 1;
|
|
|
|
logger.log('info', 'Client disconnected, total clients: %d', connectedClients);
|
|
});
|
|
});
|
|
|
|
startMainLoop();
|
|
}); |