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

Cleanup create server.

Browse source
This commit is contained in:
Filiph Sandström 2016-12-12 08:44:19 +01:00 • committed by GitHub
commit 0094941fd5
1 changed files with 105 additions and 152 deletions
Download patch file Download diff file Expand all files Collapse all files

257
src/createServer.js
View file

@ -1,173 +1,126 @@
'use strict';
const raknet = require('raknet');
const zlib = require('zlib');
const ProtoDef = require('protodef').ProtoDef;
const Parser = require('protodef').Parser;
const Serializer = require('protodef').Serializer;
const jwt = require('jwt-simple');
const crypto = require('crypto');
const Ber = require('asn1').Ber;
const merge=require("lodash.merge");
const assert=require("assert");
var debug = require('debug')("raknet");
// const BN = require('bn.js');
let raknet = require('raknet'),
zlib = require('zlib'),
ProtoDef = require('protodef').ProtoDef,
Parser = require('protodef').Parser,
Serializer = require('protodef').Serializer,
jwt = require('jwt-simple'),
crypto = require('crypto'),
Ber = require('asn1').Ber,
merge = require('lodash.merge'),
assert = require('assert');
var debug = require('debug')('raknet');
const batchProto = new ProtoDef();
batchProto.addTypes(require("./datatypes/minecraft"));
batchProto.addType("insideBatch", ["endOfArray", {
"type": ["buffer", {
"countType": "i32"
}]
batchProto.addTypes(require('./datatypes/minecraft'));
batchProto.addType('insideBatch', ['endOfArray', {
'type': ['buffer', {
'countType': 'varint'
}]
}]);
const dataProto = new ProtoDef();
dataProto.addType("data_chain", ["container", [{
"name": "chain",
"type": ["pstring", {
"countType": "li32"
}]
}, {
"name": "clientData",
"type": ["pstring", {
"countType": "li32"
}]
}]]);
function writeLI64(value, buffer, offset) {
buffer.writeInt32LE(value[0], offset+4);
buffer.writeInt32LE(value[1], offset);
return offset + 8;
}
function computeCheckSum(packetPlaintext,sendCounter,secretKeyBytes) {
let digest = crypto.createHash('sha256');
let counter=new Buffer(8);
writeLI64(sendCounter,counter,0);
digest.update(counter);
digest.update(packetPlaintext);
digest.update(secretKeyBytes);
let hash = digest.digest();
return hash.slice(0,8);
}
function readX509PublicKey(key) {
var reader = new Ber.Reader(new Buffer(key, "base64"));
reader.readSequence();
reader.readSequence();
reader.readOID();
reader.readOID();
return new Buffer(reader.readString(Ber.BitString, true)).slice(1);
}
function writeX509PublicKey(key) {
var writer = new Ber.Writer();
writer.startSequence();
writer.startSequence();
writer.writeOID("1.2.840.10045.2.1");
writer.writeOID("1.3.132.0.34");
writer.endSequence();
writer.writeBuffer(Buffer.concat([new Buffer([0x00]),key]),Ber.BitString);
writer.endSequence();
return writer.buffer.toString("base64");
}
const Transform = require('stream').Transform;
const PUBLIC_KEY = 'MHYwEAYHKoZIzj0CAQYFK4EEACIDYgAE8ELkixyLcwlZryUQcu1TvPOmI2B7vX83ndnWRUaXm74wFfa5f/lwQNTfrLVHa2PmenpGI6JhIMUJaWZrjmMj90NoKNFSNBuKdm8rYiXsfaz3K36x/1U26HpG0ZxK/V1V';
function createServer(options) {
options = options || {};
var port = options.port != null ?
options.port :
options['server-port'] != null ?
options['server-port'] :
19132;
var host = options.host || '0.0.0.0';
options = options || {};
var port = options.port != null ?
options.port :
options['server-port'] != null ?
options['server-port'] :
19132;
var host = options.host || '0.0.0.0';
options.customPackets = require("../data/protocol");
options.customTypes = require("./datatypes/minecraft");
var server = raknet.createServer(options);
options.customPackets = require('../data/protocol');
options.customTypes = require('./datatypes/minecraft');
var server = raknet.createServer(options);
server.name = options.name || "Minecraft Server";
server.motd = options.motd || "A Minecraft server";
server.maxPlayers = options['max-players'] || 20;
server.playerCount = 0;
server.name = options.name || 'Minecraft Server';
server.motd = options.motd || 'A Minecraft server';
server.maxPlayers = options['max-players'] || 20;
server.playerCount = 0;
server.on("connection", function(client) {
server.on('connection', function(client) {
client.receiveCounter=0;
client.sendCounter=0;
client.receiveCounter=0;
client.sendCounter=0;
client.encryptionEnabled = false;
client.encryptionEnabled = false;
let proto = new ProtoDef();
proto.addTypes(require("./datatypes/minecraft"));
proto.addTypes(require("../data/protocol").types);
client.mcpePacketSerializer = new Serializer(proto, 'mcpe_packet');
let proto = new ProtoDef();
proto.addTypes(require('./datatypes/minecraft'));
proto.addTypes(require('../data/protocol').types);
client.mcpePacketSerializer = new Serializer(proto, 'mcpe_packet');
client.on("mcpe", packet => {
client.emit(packet.name, packet.params)
});
client.writeMCPE = (name, params) => {
if(client.encryptionEnabled) {
debug("write mcpe", name, params);
client.mcpePacketSerializer.write({ name, params });
}
else {
client.writeEncapsulated("mcpe", { name, params });
}
};
client.writeBatch = function(packets) {
const payload = zlib.deflateSync(batchProto.createPacketBuffer("insideBatch",
packets.map(packet =>
client.mcpePacketSerializer.createPacketBuffer(packet))));
client.writeMCPE("batch", {
payload: payload
client.on('mcpe', packet => {
client.emit(packet.name, packet.params)
});
};
client.writeMCPE = (name, params) => {
if (client.encryptionEnabled) {
client.mcpePacketSerializer.write({ name, params });
}
else {
client.writeEncapsulated('mcpe', { name, params });
}
};
client.on('batch', function(packet) {
var buf = zlib.inflateSync(packet.payload);
var packets = batchProto.parsePacketBuffer("insideBatch", buf).data;
packets.forEach(packet => client.readEncapsulatedPacket(Buffer.concat([new Buffer([0xfe]), packet])));
client.writeBatch = function(packets) {
const payload = zlib.deflateSync(batchProto.createPacketBuffer('insideBatch',
packets.map(packet =>
client.mcpePacketSerializer.createPacketBuffer(packet))));
client.writeMCPE('batch', {
payload: payload
});
};
client.on('batch', function(packet) {
var buf = zlib.inflateSync(packet.payload);
var packets = batchProto.parsePacketBuffer('insideBatch', buf).data;
packets.forEach(packet => client.readEncapsulatedPacket(Buffer.concat([new Buffer([0xfe]), packet])));
});
client.on('game_login', (packet) => {
try {
const dataProto = new ProtoDef();
dataProto.addType('data_chain', ['container', [{
'name': 'chain',
'type': ['pstring', {
'countType': 'li32'
}]
}, {
'name': 'clientData',
'type': ['pstring', {
'countType': 'li32'
}]
}]]);
let body = dataProto.parsePacketBuffer('data_chain', zlib.inflateSync(packet.body)),
chain = null,
decode = null,
data = null;
body.data.chain = JSON.parse(body.data.chain);
chain = body.data.chain.chain[0];
decode = jwt.decode(chain, 'MHYwEAYHKoZIzj0CAQYFK4EEACIDYgAE8ELkixyLcwlZryUQcu1TvPOmI2B7vX83ndnWRUaXm74wFfa5f/lwQNTfrLVHa2PmenpGI6JhIMUJaWZrjmMj90NoKNFSNBuKdm8rYiXsfaz3K36x/1U26HpG0ZxK/V1V', 'ES384');
data = jwt.decode(body.data.clientData, decode.identityPublicKey, 'ES384');
data.SkinData = null;
client.emit('mcpe_login', {
protocol: packet.protocol,
uuid: (decode.extraData != null) ? decode.extraData.identity : null,
id: (decode.extraData != null) ? decode.extraData.identityPublicKey : null,
username: (decode.extraData != null) ? decode.extraData.displayName : null,
skinData: data.SkinData,
skinId: data.SkinId
})
} catch(err) {
console.log(err);
}
});
});
client.on('client_to_server_handshake',() => {
client.emit('login_mcpe', {
displayName: client.displayName,
randomId: client.randomId,
skinData: client.skinData,
skinId: client.skinId,
identity: client.identity,
XUID: client.XUID
});
});
client.on('batch_non_encrypted', function(packet) {
var buf = zlib.inflateSync(packet.payload);
var packets = batchProto.parsePacketBuffer("insideBatch", buf).data;
packets.forEach(packet => {
try {
debug("handle mcpe",packet);
var r = client.mcpePacketParser.parsePacketBuffer(packet);
client.emitPacket(r);
}
catch(err) {
client.emit("error",err);
}
});
});
});
return server;
return server;
}
module.exports = createServer;