mirror of
https://github.com/danbulant/flying-squid
synced 2026-06-10 10:01:48 +00:00
302 lines
7.9 KiB
JavaScript
302 lines
7.9 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 uuidToPlayer = {};
|
|
var vec3 = require("vec3");
|
|
|
|
var options = {
|
|
motd: settings.motd,
|
|
'max-players': settings.maxPlayers,
|
|
port: settings.port,
|
|
'online-mode': settings.onlineMode
|
|
};
|
|
|
|
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 entityMaxId=0;
|
|
|
|
var server = mc.createServer(options);
|
|
|
|
if(settings.logging == true) {
|
|
createLog();
|
|
}
|
|
|
|
function transformUuid(s)
|
|
{
|
|
return s.split("-").map(function(item) { return parseInt(item, 16); });
|
|
}
|
|
|
|
server.on('login', function(client) {
|
|
if(uuidToPlayer[client.uuid])
|
|
{
|
|
client.end("You are already connected");
|
|
return;
|
|
}
|
|
entityMaxId++;
|
|
client.id=entityMaxId;
|
|
playersConnected.push(client);
|
|
uuidToPlayer[client.uuid]=client;
|
|
|
|
|
|
// 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
|
|
});
|
|
|
|
var packetData = {
|
|
x: 0,
|
|
z: 0,
|
|
groundUp: true,
|
|
bitMap: 0xffff,
|
|
chunkData: world.dump()
|
|
};
|
|
|
|
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);
|
|
});
|
|
|
|
function getOtherClients()
|
|
{
|
|
return playersConnected.filter(function(otherClient){return otherClient!=client});
|
|
}
|
|
|
|
var otherClients=getOtherClients();
|
|
|
|
otherClients.forEach(function(otherClient) {
|
|
otherClient.write('player_info', {
|
|
action: 0,
|
|
data: [{
|
|
UUID: transformUuid(client.uuid),
|
|
name: client.username,
|
|
properties: [],
|
|
gamemode: 0,
|
|
ping: 1,
|
|
hasDisplayName: true,
|
|
displayName: client.username
|
|
}]
|
|
});
|
|
});
|
|
|
|
client.write('player_info', {
|
|
action: 0,
|
|
data: playersConnected
|
|
.map(function(otherClient) {
|
|
return {
|
|
UUID: transformUuid(otherClient.uuid),
|
|
name: otherClient.username,
|
|
properties: [],
|
|
gamemode: 0,
|
|
ping: 1,
|
|
hasDisplayName: true,
|
|
displayName: otherClient.username
|
|
};
|
|
})
|
|
});
|
|
|
|
|
|
otherClients.forEach(function(otherClient) {
|
|
var pos=uuidToPlayer[otherClient.uuid].position;
|
|
client.write('named_entity_spawn', {
|
|
entityId: otherClient.id,
|
|
playerUUID: transformUuid(otherClient.uuid),
|
|
x: pos ? Math.floor(pos.x*32) : 6*32,
|
|
y: pos ? Math.floor(pos.y*32) : 53*32,
|
|
z: pos ? Math.floor(pos.z*32) : 6*32,
|
|
yaw: 0,
|
|
pitch: 0,
|
|
currentItem: 0,
|
|
metadata: []
|
|
});
|
|
otherClient.write('named_entity_spawn', {
|
|
entityId: client.id,
|
|
playerUUID: transformUuid(client.uuid),
|
|
x: 6*32,
|
|
y: 53*32,
|
|
z: 6*32,
|
|
yaw: 0,
|
|
pitch: 0,
|
|
currentItem: 0,
|
|
metadata: []
|
|
});
|
|
});
|
|
|
|
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) {
|
|
var position = new vec3(packet.x,packet.y,packet.z);
|
|
var onGround=packet.onGround;
|
|
sendRelativePositionChange(client,position,onGround);
|
|
});
|
|
|
|
client.on('position_look', function(packet) {
|
|
var position = new vec3(packet.x,packet.y,packet.z);
|
|
var onGround=packet.onGround;
|
|
sendRelativePositionChange(client,position,onGround);
|
|
});
|
|
|
|
function sendRelativePositionChange(client,newPosition,onGround) {
|
|
if (uuidToPlayer[client.uuid].position) {
|
|
var diff = newPosition.minus(uuidToPlayer[client.uuid].position);
|
|
if(diff.distanceTo(new vec3(0,0,0))>0.1)
|
|
getOtherClients().forEach(function (otherClient) {
|
|
otherClient.write('rel_entity_move', {
|
|
entityId: uuidToPlayer[client.uuid].id,
|
|
dX: Math.floor(diff.x*32),
|
|
dY: Math.floor(diff.y*32),
|
|
dZ: Math.floor(diff.z*32),
|
|
onGround: onGround
|
|
});
|
|
});
|
|
}
|
|
uuidToPlayer[client.uuid].position = newPosition;
|
|
uuidToPlayer[client.uuid].onGround=onGround;
|
|
}
|
|
|
|
client.on('error', function(error) {
|
|
console.log('[ERR] ' + error.stack);
|
|
log('[ERR]: Client: ' + error.stack);
|
|
});
|
|
|
|
});
|
|
|
|
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 });
|
|
}
|
|
}
|