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

class Teamspeak2 extends Core {
    async run(state) {
        const queryPort = this.options.teamspeakQueryPort || 51234;

        await this.withTcp(async socket => {
            {
                const data = await this.sendCommand(socket, 'sel '+this.options.port);
                if(data !== '[TS]') throw new Error('Invalid header');
            }

            {
                const data = await this.sendCommand(socket, 'si');
                for (const line of data.split('\r\n')) {
                    const equals = line.indexOf('=');
                    const key = equals === -1 ? line : line.substr(0,equals);
                    const value = equals === -1 ? '' : line.substr(equals+1);
                    state.raw[key] = value;
                }
            }

            {
                const data = await this.sendCommand(socket, 'pl');
                const split = data.split('\r\n');
                const fields = split.shift().split('\t');
                for (const line of split) {
                    const split2 = line.split('\t');
                    const player = {};
                    split2.forEach((value,i) => {
                        let key = fields[i];
                        if(!key) return;
                        if(key === 'nick') key = 'name';
                        const m = value.match(/^"(.*)"$/);
                        if(m) value = m[1];
                        player[key] = value;
                    });
                    state.players.push(player);
                }
            }

            {
                const data = await this.sendCommand(socket, 'cl');
                const split = data.split('\r\n');
                const fields = split.shift().split('\t');
                state.raw.channels = [];
                for (const line of split) {
                    const split2 = line.split('\t');
                    const channel = {};
                    split2.forEach((value,i) => {
                        const key = fields[i];
                        if(!key) return;
                        const m = value.match(/^"(.*)"$/);
                        if(m) value = m[1];
                        channel[key] = value;
                    });
                    state.raw.channels.push(channel);
                }
            }
        }, queryPort);
    }

    async sendCommand(socket,cmd) {
        return await this.tcpSend(socket, cmd+'\x0A', buffer => {
            if(buffer.length < 6) return;
            if(buffer.slice(-6).toString() !== '\r\nOK\r\n') return;
            return buffer.slice(0,-6).toString();
        });
    }
}

module.exports = Teamspeak2;