AstralTransRocketries/node-minecraft-protocol
1
0
Fork 0
mirror of https://github.com/unmojang/node-minecraft-protocol.git synced 2025-09-30 06:30:39 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix createServer

Browse Source
This commit is contained in:
roblabla 2015-09-14 17:51:36 +00:00
parent eac198bdf3
commit cf4048d655
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/createServer.js
View File

@ -36,9 +36,9 @@ function createServer(options) {
server.playerCount = 0; server.playerCount = 0;
server.onlineModeExceptions = {}; server.onlineModeExceptions = {};
server.on("connection", function(client) { server.on("connection", function(client) {
client.once([states.HANDSHAKING, 0x00], onHandshake); client.once('set_protocol', onHandshake);
client.once([states.LOGIN, 0x00], onLogin); client.once('login_start', onLogin);
client.once([states.STATUS, 0x00], onPing); client.once('ping_start', onPing);
client.on('end', onEnd); client.on('end', onEnd);
var keepAlive = false; var keepAlive = false;
@ -104,11 +104,11 @@ function createServer(options) {
response = beforePing(response, client) || response; response = beforePing(response, client) || response;
} }
client.once([states.STATUS, 0x01], function(packet) { client.once('ping', function(packet) {
client.write(0x01, {time: packet.time}); client.write('ping', {time: packet.time});
client.end(); client.end();
}); });
client.write(0x00, {response: JSON.stringify(response)}); client.write('server_info', {response: JSON.stringify(response)});
} }
function onLogin(packet) { function onLogin(packet) {
@ -126,8 +126,8 @@ function createServer(options) {
client.publicKey = new Buffer(publicKeyStr, 'base64'); client.publicKey = new Buffer(publicKeyStr, 'base64');
hash = crypto.createHash("sha1"); hash = crypto.createHash("sha1");
hash.update(serverId); hash.update(serverId);
client.once([states.LOGIN, 0x01], onEncryptionKeyResponse); client.once('encryption_begin', onEncryptionKeyResponse);
client.write(0x01, { client.write('encryption_begin', {
serverId: serverId, serverId: serverId,
publicKey: client.publicKey, publicKey: client.publicKey,
verifyToken: client.verifyToken verifyToken: client.verifyToken
@ -193,7 +193,7 @@ function createServer(options) {
} }
//client.write('compress', { threshold: 256 }); // Default threshold is 256 //client.write('compress', { threshold: 256 }); // Default threshold is 256
//client.compressionThreshold = 256; //client.compressionThreshold = 256;
client.write(0x02, {uuid: client.uuid, username: client.username}); client.write('success', {uuid: client.uuid, username: client.username});
client.state = states.PLAY; client.state = states.PLAY;
loggedIn = true; loggedIn = true;
if(enableKeepAlive) startKeepAlive(); if(enableKeepAlive) startKeepAlive();