const Core = require('./core');

/** Unsupported -- use at your own risk!! */

class Tribes1Master extends Core {
    constructor() {
        super();
        this.encoding = 'latin1';
    }

    async run(state) {
        const queryBuffer = Buffer.from([
            0x10, // standard header
            0x03, // dump servers
            0xff, // ask for all packets
            0x00, // junk
            0x01, 0x02, // challenge
        ]);

        let parts = new Map();
        let total = 0;
        const full = await this.udpSend(queryBuffer,(buffer) => {
            const reader = this.reader(buffer);
            const header = reader.uint(2);
            if (header !== 0x0610) {
                this.debugLog('Header response does not match: ' + header.toString(16));
                return;
            }
            const num = reader.uint(1);
            const t = reader.uint(1);
            if (t <= 0 || (total > 0 && t !== total)) {
                throw new Error('Conflicting packet total: ' + t);
            }
            total = t;

            if (num < 1 || num > total) {
                this.debugLog('Invalid packet number: ' + num + ' ' + total);
                return;
            }
            if (parts.has(num)) {
                this.debugLog('Duplicate part: ' + num);
                return;
            }

            reader.skip(2); // challenge (0x0201)
            reader.skip(2); // always 0x6600
            parts.set(num, reader.rest());

            if (parts.size === total) {
                const ordered = [];
                for (let i = 1; i <= total; i++) ordered.push(parts.get(i));
                return Buffer.concat(ordered);
            }
        });

        const fullReader = this.reader(full);
        state.raw.name = this.readString(fullReader);
        state.raw.motd = this.readString(fullReader);

        state.raw.servers = [];
        while (!fullReader.done()) {
            fullReader.skip(1); // junk ?
            const count = fullReader.uint(1);
            for (let i = 0; i < count; i++) {
                const six = fullReader.uint(1);
                if (six !== 6) {
                    throw new Error('Expecting 6');
                }
                const ip = fullReader.uint(4);
                const port = fullReader.uint(2);
                const ipStr = (ip & 255) + '.' + (ip >> 8 & 255) + '.' + (ip >> 16 & 255) + '.' + (ip >>> 24);
                state.raw.servers.push(ipStr+":"+port);
            }
        }
    }
    readString(reader) {
        return reader.pascalString(1);
    }
}

module.exports = Tribes1Master;