node-gamedig/protocols/minecraftvanilla.js

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 str = reader.rest().toString('utf8');
        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 (str.length > strLen) {
            const bccStr = str.substring(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;