95 lines
2.8 KiB
JavaScript
95 lines
2.8 KiB
JavaScript
const Core = require('./core'),
|
|
Varint = require('varint');
|
|
|
|
class MinecraftVanilla extends Core {
|
|
async run(state) {
|
|
const portBuf = Buffer.alloc(2);
|
|
portBuf.writeUInt16BE(this.options.port,0);
|
|
|
|
const addressBuf = Buffer.from(this.options.host,'utf8');
|
|
|
|
const bufs = [
|
|
this.varIntBuffer(47),
|
|
this.varIntBuffer(addressBuf.length),
|
|
addressBuf,
|
|
portBuf,
|
|
this.varIntBuffer(1)
|
|
];
|
|
|
|
const outBuffer = Buffer.concat([
|
|
this.buildPacket(0,Buffer.concat(bufs)),
|
|
this.buildPacket(0)
|
|
]);
|
|
|
|
const data = await this.withTcp(async socket => {
|
|
return await this.tcpSend(socket, outBuffer, data => {
|
|
if(data.length < 10) return;
|
|
const reader = this.reader(data);
|
|
const length = reader.varint();
|
|
if(data.length < length) return;
|
|
return reader.rest();
|
|
});
|
|
});
|
|
|
|
const reader = this.reader(data);
|
|
|
|
const packetId = reader.varint();
|
|
this.debugLog("Packet ID: "+packetId);
|
|
|
|
const strLen = reader.varint();
|
|
this.debugLog("String Length: "+strLen);
|
|
|
|
const rest = reader.rest()
|
|
|
|
const str = rest.toString('utf8', 0, strLen)
|
|
this.debugLog(str);
|
|
|
|
const json = JSON.parse(str.substring(0, strLen));
|
|
delete json.favicon;
|
|
|
|
state.raw = json;
|
|
state.maxplayers = json.players.max;
|
|
|
|
if(json.players.sample) {
|
|
for(const player of json.players.sample) {
|
|
state.players.push({
|
|
id: player.id,
|
|
name: player.name
|
|
});
|
|
}
|
|
}
|
|
|
|
// players.sample may not contain all players or no players at all, depending on how many players are online.
|
|
// Insert a dummy player object for every online player that is not listed in players.sample.
|
|
// Limit player amount to 10.000 players for performance reasons.
|
|
for (let i = state.players.length; i < Math.min(json.players.online, 10000); i++) {
|
|
state.players.push({});
|
|
}
|
|
|
|
// Better Compatibility Checker mod support
|
|
let bccJson = {}
|
|
|
|
if (rest.length > strLen) {
|
|
const bccStr = rest.toString('utf8', strLen + 1);
|
|
bccJson = JSON.parse(bccStr);
|
|
}
|
|
|
|
state.raw.bcc = bccJson;
|
|
}
|
|
|
|
varIntBuffer(num) {
|
|
return Buffer.from(Varint.encode(num));
|
|
}
|
|
buildPacket(id,data) {
|
|
if(!data) data = Buffer.from([]);
|
|
const idBuffer = this.varIntBuffer(id);
|
|
return Buffer.concat([
|
|
this.varIntBuffer(data.length+idBuffer.length),
|
|
idBuffer,
|
|
data
|
|
]);
|
|
}
|
|
}
|
|
|
|
module.exports = MinecraftVanilla;
|