diff --git a/src/createClient.js b/src/createClient.js index 9833f33..3cd58e1 100644 --- a/src/createClient.js +++ b/src/createClient.js @@ -52,7 +52,7 @@ function createClient(options) { client.on('batch', function(packet) { var buf = zlib.inflateSync(packet.payload); var packets=batchProto.parsePacketBuffer("insideBatch",buf).data; - packets.forEach(packet => client.readEncapsulatedPacket(Buffer.concat([new Buffer([0x8e]),packet]))); + packets.forEach(packet => client.readEncapsulatedPacket(Buffer.concat([new Buffer([0xfe]),packet]))); }); return client; diff --git a/src/createServer.js b/src/createServer.js index 943f34f..557d088 100644 --- a/src/createServer.js +++ b/src/createServer.js @@ -39,7 +39,13 @@ function createServer(options) { client.writeMCPE("batch",{ payload:payload }); - } + }; + + client.on('batch', function(packet) { + var buf = zlib.inflateSync(packet.payload); + var packets=batchProto.parsePacketBuffer("insideBatch",buf).data; + packets.forEach(packet => client.readEncapsulatedPacket(Buffer.concat([new Buffer([0xfe]),packet]))); + }); }); return server; }