mirror of
https://github.com/danbulant/flying-squid
synced 2026-06-10 18:14:13 +00:00
275 lines
7.4 KiB
JavaScript
275 lines
7.4 KiB
JavaScript
var mc = require('minecraft-protocol');
|
|
var states = mc.states;
|
|
var settings = require('./config/settings');
|
|
var World = require('prismarine-chunk');
|
|
var fs = require('fs');
|
|
var timeStarted = Math.floor(new Date() / 1000).toString();
|
|
var playersConnected = [];
|
|
var playerMoveData = [];
|
|
var playerLookData = [];
|
|
|
|
var options = {
|
|
motd: settings.motd,
|
|
'max-players': settings.maxPlayers,
|
|
port: settings.port,
|
|
'online-mode': settings.onlineMode,
|
|
reducedDebugInfo: false
|
|
};
|
|
|
|
var world = new World();
|
|
for (var x = 0; x < 16;x++) {
|
|
for (var z = 0; z < 16; z++) {
|
|
world.setBlockType(x, 50, z, 2);
|
|
for (var y = 0; y < 256; y++) {
|
|
world.setSkyLight(x, y, z, 15);
|
|
}
|
|
}
|
|
}
|
|
|
|
var server = mc.createServer(options);
|
|
|
|
if(settings.logging == true) {
|
|
createLog();
|
|
}
|
|
|
|
server.on('login', function(client) {
|
|
|
|
playersConnected.push(client);
|
|
|
|
playersConnected.forEach(function(entry) {
|
|
if(entry != client) {
|
|
client.write('named_entity_spawn', {
|
|
entityId: entry.id,
|
|
playerUUID: entry.uuid,
|
|
x: playerMoveData[entry.uuid].x,
|
|
y: playerMoveData[entry.uuid].y,
|
|
z: playerMoveData[entry.uuid].z,
|
|
yaw: playerLookData[entry.uuid],
|
|
pitch: playerLookData[entry.uuid],
|
|
currentItem: 0,
|
|
metadata: []
|
|
});
|
|
}
|
|
});
|
|
|
|
Object.keys(server.clients).forEach(function(clientKey) {
|
|
var otherClient=server.clients[clientKey]
|
|
otherClient.write('player_info', {
|
|
action: 0,
|
|
data: [{
|
|
UUID: client.uuid.split("-").map(function(item) { return parseInt(item, 16); }),
|
|
name: client.username,
|
|
properties: [],
|
|
gamemode: 0,
|
|
ping: 1,
|
|
hasDisplayName: true,
|
|
displayName: client.username
|
|
}]
|
|
});
|
|
});
|
|
|
|
playersConnected.forEach(function(entry) {
|
|
client.write('player_info', {
|
|
action: 0,
|
|
data: [{
|
|
UUID: entry.uuid.split("-").map(function(item) { return parseInt(item, 16); }),
|
|
name: entry.username,
|
|
properties: [],
|
|
gamemode: 0,
|
|
ping: 1,
|
|
hasDisplayName: true,
|
|
displayName: entry.username
|
|
}]
|
|
});
|
|
});
|
|
|
|
broadcast(client.username + ' joined the game.', "yellow");
|
|
var addr = client.socket.remoteAddress + ':' + client.socket.remotePort;
|
|
console.log("[INFO]: " + client.username + ' connected', '(' + addr + ')');
|
|
log("[INFO]: " + client.username + ' connected', '(' + addr + ')');
|
|
|
|
client.on('end', function() {
|
|
broadcast(client.username + ' joined the game.', "yellow");
|
|
console.log("[INFO]: " + client.username+' disconnected', '('+addr+')');
|
|
log("[INFO]: " + client.username+' disconnected', '('+addr+')');
|
|
});
|
|
|
|
client.on('position', function(packet) {
|
|
playerMoveData[client.uuid] = { x: packet.x, y: packet.y, z: packet.z, id: packet.id, onGround: packet.onGround};
|
|
client.write('rel_entity_move', {
|
|
entityId: playerMoveData[client.uuid].id,
|
|
dX: playerMoveData[client.uuid].x,
|
|
dY: playerMoveData[client.uuid].y,
|
|
dZ: playerMoveData[client.uuid].z,
|
|
onGround: playerMoveData[client.uuid].onGround
|
|
});
|
|
});
|
|
|
|
client.on('position_look', function(packet) {
|
|
playerLookData[client.uuid] = { x: packet.yaw, y: packet.pitch, id: packet.id, onGround: packet.onGround};
|
|
client.write('entity_look', {
|
|
entityId: playerLookData[client.uuid].id,
|
|
yaw: playerLookData[client.uuid].yaw,
|
|
pitch: playerLookData[client.uuid].pitch,
|
|
onGround: playerLookData[client.uuid].onGround
|
|
});
|
|
});
|
|
|
|
client.on('error', function(error) {
|
|
console.log('[ERR] ' + error.stack);
|
|
log('[ERR]: Client: ' + error.stack);
|
|
});
|
|
|
|
// send init data so client will start rendering world
|
|
client.write('login', {
|
|
entityId: client.id,
|
|
levelType: 'default',
|
|
gameMode: 0,
|
|
dimension: 0,
|
|
difficulty: 0,
|
|
reducedDebugInfo: false,
|
|
maxPlayers: server.maxPlayers
|
|
});
|
|
|
|
// client.write('player_info', {
|
|
// action: 0,
|
|
// data: [{
|
|
// UUID: client.uuid.split("-").map(function(item) { return parseInt(item, 16); }),
|
|
// name: client.username,
|
|
// properties: [],
|
|
// gamemode: 0,
|
|
// ping: 1,
|
|
// hasDisplayName: false,
|
|
// //displayName: client.username
|
|
// }]
|
|
// });
|
|
|
|
var packetData = {
|
|
x: 0,
|
|
z: 0,
|
|
groundUp: true,
|
|
bitMap: 0xffff,
|
|
chunkData: world.dump()
|
|
};
|
|
|
|
client.write('map_chunk', packetData);
|
|
|
|
//client.write('map_chunk', packetData);
|
|
|
|
client.write('position', {
|
|
x: 6,
|
|
y: 53,
|
|
z: 6,
|
|
yaw: 0,
|
|
pitch: 0,
|
|
flags: 0x00
|
|
});
|
|
|
|
console.log("[INFO]: position written, player spawning...");
|
|
log("[INFO]: position written, player spawning...");
|
|
|
|
client.write('update_time', {
|
|
age: [0,0],
|
|
time: [0,1]
|
|
});
|
|
|
|
client.write('game_state_change', {
|
|
reason: 3,
|
|
gameMode: 0
|
|
});
|
|
|
|
client.on('chat', function(data) {
|
|
var message = '<'+client.username+'>' + ' ' + data.message;
|
|
playerChat(message, client.username);
|
|
console.log("[INFO] " + message);
|
|
log("[INFO] " + message);
|
|
});
|
|
|
|
client.on('packet', function(packet) {
|
|
// we don't really need to see the server pass an object every 10nth of a second so I will just disable this
|
|
//console.log("[INFO] " + packet);
|
|
//log("[INFO] " + packet);
|
|
});
|
|
});
|
|
|
|
server.on('error', function(error) {
|
|
console.log('[ERR] ', error.stack);
|
|
log('[ERR]: Server:', error.stack);
|
|
});
|
|
|
|
server.on('listening', function() {
|
|
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) {
|
|
// var client, translate;
|
|
// translate = username ? 'chat.type.announcement' : 'chat.type.text';
|
|
// username = username || 'Server';
|
|
// for (var clientId in server.clients) {
|
|
// if (!server.clients.hasOwnProperty(clientId)) continue;
|
|
|
|
// client = server.clients[clientId];
|
|
// var msg = {
|
|
// translate: translate,
|
|
// "with": [
|
|
// username
|
|
// ]
|
|
// };
|
|
// if (typeof message === "string") {
|
|
// msg["with"].push(message);
|
|
// } else {
|
|
// Object.keys(message).forEach(function(key) {
|
|
// if (key === "text") {
|
|
// msg["with"].push(message[key]);
|
|
// } else {
|
|
// msg[key] = message[key];
|
|
// }
|
|
// });
|
|
// }
|
|
|
|
// 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) {
|
|
if(settings.logging == true) {
|
|
fs.appendFile("logs/" + timeStarted + ".log", message + "\n", function (err) { });
|
|
}
|
|
}
|
|
|
|
function playerChat(message, exclude, username) {
|
|
var client;
|
|
//translate = username ? 'chat.type.text' : 'chat.type.text';
|
|
username = username || '';
|
|
for(var clientId in server.clients) {
|
|
if(!server.clients.hasOwnProperty(clientId)) continue;
|
|
|
|
client = server.clients[clientId];
|
|
if(client !== exclude) {
|
|
var msg = {
|
|
"text": username + message
|
|
};
|
|
client.write('chat', { message: JSON.stringify(msg), position: 0 });
|
|
}
|
|
}
|
|
}
|
|
|
|
function broadcast(message, color) {
|
|
var client;
|
|
for(var clientId in server.clients) {
|
|
if(!server.clients.hasOwnProperty(clientId)) continue;
|
|
|
|
client = server.clients[clientId];
|
|
var msg = {
|
|
"text": message,
|
|
"color": color
|
|
};
|
|
client.write('chat', { message: JSON.stringify(msg), position: 0 });
|
|
}
|
|
}
|