codePugHacKEr/bedrock-protocol
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add writePacket and writeData.

Browse source
This commit is contained in:
Filiph Sandström 2017-01-18 09:26:56 +01:00
commit e48f146528
1 changed files with 32 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

40
src/createServer.js
View file

@ -44,7 +44,7 @@ function createServer(options, encryption) {
server.on('connection', function(client) {
client.receiveCounter = 0;
client.sendCounter = 0;
client.encryptionEnabled = encryption ? encryption : false;
client.encryptionEnabled = encryption ? true : false;
let proto = new ProtoDef();
proto.addTypes(require('./datatypes/minecraft'));
@ -60,22 +60,45 @@ function createServer(options, encryption) {
packets.forEach(packet => client.readEncapsulatedPacket(Buffer.concat([new Buffer([0xfe]), packet])));
});
client.writeMCPE = (name, params) => {
if (client.encryptionEnabled)
// client.writePacket (string, object)
// Send data to the client
//
// string: packet name
// object: packet data
client.writeMCPE = function (name, params) {
if (client.encryptionEnabled) {
client.mcpePacketSerializer.write({ name, params });
else
} else {
client.writeEncapsulated('mcpe', { name, params });
}
};
client.writeBatch = function(packets) {
client.writePacket = client.writeMCPE;
// client.writeData (array)
// Send data to the client
//
// array: packets to send
client.writeBatch = function (packets) {
const payload = zlib.deflateSync(batchProto.createPacketBuffer('insideBatch',
packets.map(packet => client.mcpePacketSerializer.createPacketBuffer(packet))));
client.writeMCPE('batch', {
client.writePacket('batch', {
payload: payload
});
};
client.writeData = client.writeBatch;
client.on('game_login', (packet) => {
// client.writeAll (string, object)
// Send data to the client
//
// string: packet name
// object: packet data
client.writeAll = function (name, data) {
return; //TODO
server._writeAll(name, data);
};
client.on('game_login', function (packet) {
try {
let dataProto = new ProtoDef();
dataProto.addType('data_chain', ['container', [{
@ -91,6 +114,7 @@ function createServer(options, encryption) {
}]]);
//FIXME: Xbox & Non-Xbox support
console.log(packet);
let body = dataProto.parsePacketBuffer('data_chain', zlib.inflateSync(packet.body)),
chain = null,
decode = null,
@ -120,4 +144,4 @@ function createServer(options, encryption) {
return server;
}
module.exports = createServer;
module.exports = createServer;