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

Fix crash when trying to write to socket

Browse Source
This commit is contained in:
Will Franzen 2014-12-31 12:26:59 -06:00
parent 52078273fe
commit 00241c4044
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/client.js
View File

@ -155,13 +155,15 @@ Client.prototype.write = function(packetId, params) {
packetId = packetId[1]; packetId = packetId[1];
} }
var that = this;
// TODO: Which comes first, encryption or compression? // TODO: Which comes first, encryption or compression?
var finishWriting = function(buffer) { var finishWriting = function(buffer) {
debug("writing packetId " + packetId + " (0x" + packetId.toString(16) + ")"); debug("writing packetId " + packetId + " (0x" + packetId.toString(16) + ")");
debug(params); debug(params);
var out = this.encryptionEnabled ? new Buffer(this.cipher.update(buffer), 'binary') : buffer; var out = this.encryptionEnabled ? new Buffer(this.cipher.update(buffer), 'binary') : buffer;
this.socket.write(out); that.socket.write(out);
return true; return true;
} }
@ -179,9 +181,11 @@ Client.prototype.writeRaw = function(buffer, shouldEncrypt) {
shouldEncrypt = true; shouldEncrypt = true;
} }
var that = this;
var finishWriting = function(buffer) { var finishWriting = function(buffer) {
var out = (shouldEncrypt && this.encryptionEnabled) ? new Buffer(this.cipher.update(buffer), 'binary') : buffer; var out = (shouldEncrypt && this.encryptionEnabled) ? new Buffer(this.cipher.update(buffer), 'binary') : buffer;
this.socket.write(out); that.socket.write(out);
}; };
if(this.compressionThreshold != -1 && buffer.length > this.compressionThreshold) { if(this.compressionThreshold != -1 && buffer.length > this.compressionThreshold) {