From 8c06ca5a38d1a55aba4881937b3342090ed9c01d Mon Sep 17 00:00:00 2001
From: Romain Beaumont <romain.rom1@gmail.com>
Date: Wed, 15 Jun 2016 00:44:38 +0200
Subject: [PATCH] parse server bound batches

---
 src/createClient.js | 2 +-
 src/createServer.js | 8 +++++++-
 2 files changed, 8 insertions(+), 2 deletions(-)

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;
 }