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

Fix readRaw, writeRaw

Browse Source
This commit is contained in:
roblabla 2015-03-03 12:35:51 +00:00
parent a2b06f70a2
commit e37a820709
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/client.js
View File

@ -93,10 +93,11 @@ Client.prototype.setSocket = function(socket) {
//incomingBuffer = incomingBuffer.slice(parsed.size); TODO: Already removed in prepare //incomingBuffer = incomingBuffer.slice(parsed.size); TODO: Already removed in prepare
var packetName = protocol.packetNames[self.state][self.isServer ? 'toServer' : 'toClient'][packet.id]; var packetName = protocol.packetNames[self.state][self.isServer ? 'toServer' : 'toClient'][packet.id];
var packetState = self.state;
self.emit(packetName, packet); self.emit(packetName, packet);
self.emit('packet', packet); self.emit('packet', packet);
self.emit('raw.' + packetName, parsed.buffer); self.emit('raw.' + packetName, parsed.buffer, packetState);
self.emit('raw', parsed.buffer); self.emit('raw', parsed.buffer, packetState);
prepareParse(); prepareParse();
} }
@ -214,9 +215,11 @@ Client.prototype.write = function(packetId, params) {
Client.prototype.writeRaw = function(buffer) { Client.prototype.writeRaw = function(buffer) {
var self = this; var self = this;
var finishWriting = function(buffer) { var finishWriting = function(error, buffer) {
if (error)
throw error; // TODO : How do we handle this error ?
var out = self.encryptionEnabled ? new Buffer(self.cipher.update(buffer), 'binary') : buffer; var out = self.encryptionEnabled ? new Buffer(self.cipher.update(buffer), 'binary') : buffer;
that.socket.write(out); self.socket.write(out);
}; };
if (this.compressionThreshold >= 0 && buffer.length >= this.compressionThreshold) { if (this.compressionThreshold >= 0 && buffer.length >= this.compressionThreshold) {
compressPacketBuffer(buffer, finishWriting); compressPacketBuffer(buffer, finishWriting);