dan/flying-squid
1
0
Fork 0
mirror of https://github.com/danbulant/flying-squid synced 2026-09-20 14:44:11 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Added logging

Browse source
This commit is contained in:
mhsjlw 2015-08-24 09:02:36 -04:00
parent 0c4fc34e57
commit 95234325f0
1 changed files with 36 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
app.js
View file

@ -1,12 +1,14 @@
var mc = require('minecraft-protocol'); var mc = require('minecraft-protocol');
var states = mc.states; var states = mc.states;
var World = require('./world'); var World = require('./world');
var fs = require('fs');
var timeStarted = Math.floor(new Date() / 1000).toString();
var options = { var options = {
motd: 'Minecraft Server', motd: 'Minecraft Server',
'max-players': 20, 'max-players': 20,
port: 25565, port: 25565,
'online-mode': false, 'online-mode': true,
reducedDebugInfo: false reducedDebugInfo: false
}; };
@ -19,15 +21,24 @@ for (var x = 0; x < 16;x++) {
var server = mc.createServer(options); var server = mc.createServer(options);
createLog();
server.on('login', function(client) { server.on('login', function(client) {
broadcast({ text: client.username + ' joined the game.', color: "yellow" }); broadcast({ text: client.username + ' joined the game.', color: "yellow" });
var addr = client.socket.remoteAddress + ':' + client.socket.remotePort; var addr = client.socket.remoteAddress + ':' + client.socket.remotePort;
console.log(client.username + ' connected', '(' + addr + ')'); console.log("[INFO]: " + client.username + ' connected', '(' + addr + ')');
log("[INFO]: " + client.username + ' connected', '(' + addr + ')');
client.on('end', function() { client.on('end', function() {
broadcast({ text: client.username+' left the game.', color: "yellow" }); broadcast({ text: client.username+' left the game.', color: "yellow" });
console.log(client.username+' disconnected', '('+addr+')'); console.log("[INFO]: " + client.username+' disconnected', '('+addr+')');
log("[INFO]: " + client.username+' disconnected', '('+addr+')');
});
client.on('error', function(error) {
console.log('[ERR] ' + error.stack);
log('[ERR]: Client: ' + error.stack);
}); });
// send init data so client will start rendering world // send init data so client will start rendering world
@ -44,7 +55,7 @@ server.on('login', function(client) {
var chunkBulk = world.packMapChunkBulk([0,0], function(err, packetData) { var chunkBulk = world.packMapChunkBulk([0,0], function(err, packetData) {
if (err) { if (err) {
console.log(err); console.log(err.stack);
return; return;
} }
client.write('map_chunk_bulk', packetData); client.write('map_chunk_bulk', packetData);
@ -57,8 +68,8 @@ server.on('login', function(client) {
pitch: 0, pitch: 0,
flags: 0x00 flags: 0x00
}); });
console.log("[INFO]: position written, player spawning...");
console.log("Written position, player should spawn"); log("[INFO]: position written, player spawning...");
client.write('update_time', { client.write('update_time', {
age: [0,0], age: [0,0],
@ -74,20 +85,24 @@ server.on('login', function(client) {
client.on([states.PLAY, 'chat'], function(data) { client.on([states.PLAY, 'chat'], function(data) {
var message = '<'+client.username+'>' + ' ' + data.message; var message = '<'+client.username+'>' + ' ' + data.message;
broadcast(message, client.username); broadcast(message, client.username);
console.log(message); console.log("[INFO] " + message);
log("[INFO] " + message);
}); });
client.on('packet', function(packet) { client.on('packet', function(packet) {
console.log(packet); console.log("[INFO] " + packet);
log("[INFO] " + message);
}) })
}); });
server.on('error', function(error) { server.on('error', function(error) {
console.log('Error:', error.stack); console.log('[ERR] ', error.stack);
log('[ERR]: Server:', error.stack);
}); });
server.on('listening', function() { server.on('listening', function() {
console.log('Server listening on port', server.socketServer.address().port); console.log('[INFO]: Server listening on port', server.socketServer.address().port);
log('[INFO]: Server listening on port', server.socketServer.address().port);
}); });
// function broadcast(message, username) { // function broadcast(message, username) {
@ -119,6 +134,17 @@ server.on('listening', function() {
// client.write('success', { message: JSON.stringify(msg) }); // client.write('success', { message: JSON.stringify(msg) });
// } // }
function createLog() {
fs.writeFile("logs/" + timeStarted + ".log", "[INFO]: Started logging...\n", function(err, data) {
if (err) return console.log(err);
});
}
function log(message) {
fs.appendFile("logs/" + timeStarted + ".log", message + "\n", function (err) {
});
}
function broadcast(message, exclude, username) { function broadcast(message, exclude, username) {
var client, translate; var client, translate;
translate = username ? 'chat.type.announcement' : 'chat.type.text'; translate = username ? 'chat.type.announcement' : 'chat.type.text';