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

Merge pull request #371 from rom1504/dont_crash_after_an_error

Browse Source 
don't stop after an error
This commit is contained in:
Romain Beaumont 2016-02-20 17:48:16 +01:00
commit ba2d791d75
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@ -45,7 +45,7 @@
"buffer-equal": "1.0.0", "buffer-equal": "1.0.0",
"minecraft-data": "^1.0.3", "minecraft-data": "^1.0.3",
"prismarine-nbt": "0.2.1", "prismarine-nbt": "0.2.1",
"protodef": "^1.0.0", "protodef": "^1.0.1",
"readable-stream": "^2.0.5", "readable-stream": "^2.0.5",
"ursa-purejs": "0.0.3", "ursa-purejs": "0.0.3",
"uuid-1345": "^0.99.6", "uuid-1345": "^0.99.6",

8
src/client.js
View File

@ -59,6 +59,10 @@ class Client extends EventEmitter
const serializerDirection = !this.isServer ? 'toServer' : 'toClient'; const serializerDirection = !this.isServer ? 'toServer' : 'toClient';
e.field = [this.protocolState, serializerDirection].concat(parts).join("."); e.field = [this.protocolState, serializerDirection].concat(parts).join(".");
e.message = `Serialization error for ${e.field} : ${e.message}`; e.message = `Serialization error for ${e.field} : ${e.message}`;
if(!this.compressor)
this.serializer.pipe(this.framer);
else
this.serializer.pipe(this.compressor);
this.emit('error',e); this.emit('error',e);
}); });
@ -69,6 +73,10 @@ class Client extends EventEmitter
const deserializerDirection = this.isServer ? 'toServer' : 'toClient'; const deserializerDirection = this.isServer ? 'toServer' : 'toClient';
e.field = [this.protocolState, deserializerDirection].concat(parts).join("."); e.field = [this.protocolState, deserializerDirection].concat(parts).join(".");
e.message = `Deserialization error for ${e.field} : ${e.message}`; e.message = `Deserialization error for ${e.field} : ${e.message}`;
if(!this.compressor)
this.splitter.pipe(this.deserializer);
else
this.decompressor.pipe(this.deserializer);
this.emit('error',e); this.emit('error',e);
}); });