From 73d69e66d7590a0f7852a4fe6458c9f0b85dbd1c Mon Sep 17 00:00:00 2001
From: deathcap <deathcap@gmx.co.uk>
Date: Mon, 18 Jan 2016 01:41:08 -0800
Subject: [PATCH] Add noPacketFramer option to createClientStream()

---
 package.json              | 1 +
 src/createClientStream.js | 7 +++++++
 2 files changed, 8 insertions(+)

diff --git a/package.json b/package.json
index 9d23285..d02704f 100644
--- a/package.json
+++ b/package.json
@@ -51,6 +51,7 @@
     "protodef": "0.2.5",
     "readable-stream": "^1.1.0",
     "superagent": "~0.10.0",
+    "through": "^2.3.8",
     "ursa-purejs": "0.0.3",
     "uuid": "^2.0.1",
     "uuid-1345": "^0.99.6",
diff --git a/src/createClientStream.js b/src/createClientStream.js
index c5d047c..72dce01 100644
--- a/src/createClientStream.js
+++ b/src/createClientStream.js
@@ -1,6 +1,7 @@
 var Client = require('./client');
 var assert = require('assert');
 var states = require("./states");
+var EmptyTransformStream = require('through')();
 
 module.exports=createClientStream;
 
@@ -19,6 +20,12 @@ function createClientStream(options) {
 
   var client = new Client(false,version.majorVersion);
 
+  // Options to opt-out of MC protocol packet framing (useful since WS is alreay framed)
+  // TODO: refactor
+  if (options.noPacketFramer) {
+    client.framer = EmptyTransformStream;
+  }
+
   if(keepAlive) client.on('keep_alive', onKeepAlive);
   client.once('success', onLogin);
   client.once("compress", onCompressionRequest);