JJ2 Bot for Node.js

'use strict';

// created by djazz

var BOT_NAME = '[bot]';

var info = {
    ip: '127.0.0.1',
    port: 10052
}

var net = require('net');
var dgram = require('dgram');

// Zero fill
function zfs(v, width) {
    v = v+'';
    if (typeof width !== 'number') width = v.length+1;
    return new Array(width-v.length+1).join("0")+v;
}

function Server (config) {
    if(!config) config = {};
    this.ip = config.ip;
    this.port = parseInt(config.port, 10) || 0;
    this.address = this.ip+":"+this.port;
    this['private'] = !!(config['private'] || false);
    this.gametype = parseInt(config.gametype, 10) || 0;
    this.version = new Buffer(4);
    if(Buffer.isBuffer(config.version)) {
        config.version.copy(this.version, 0, 0, 4);
    }
    else if(typeof config.version === 'string') {
        this.version.write(config.version, 0, 4, 'binary');
    }
    if(!config.capacity) config.capacity = [0, 0];
    this.capacity = [+config.capacity[0] || 0, +config.capacity[1] || 0];
    this.servername = config.servername || '';
};
Server.prototype.toJSON = function () {
    return {
        ip: this.ip,
        port: this.port,
        address: this.address,
        'private': this['private'],
        gametype: this.gametype,
        version: this.version.toString('binary'),
        capacity: this.capacity,
        servername: this.servername
    };
};

function udpchecksum (buf) {
    var x = 1, y = 1, size = buf.length;
    for(var i = 2; i < size; i+=1) {
        x += buf[i];
        y += x;
    }
    buf[0] = x % 251;
    buf[1] = y % 251;
    return buf;
};

var disconnectMessages = {
    1: "Server is full",
    2: "Version different",
    3: "Server is full",
    4: "Error during handshaking",
    5: "Feature not supported in shareware",
    6: "Error downloading level",
    7: "Connection lost",
    8: "Winsock error",
    9: "Connection timed out",
    10:"Server stopped",
    11:"Kicked off",
    12:"Banned",

    17:"Unauthorized file request",
    18:"No splitscreeners allowed"
};
var actionSizes = {
    0x01: 3,
    0x02: 3,
    0x03: 3,
    0x04: 3,
    0x05: 1,
    0x06: 2,
    0x07: 11,
    0x08: 12,
    0x09: 1,
    0x0A: 3,
    0x0B: 4,
    0x0C: 4,
    0x0D: 1,
    0x0E: 10,
    0x0F: 2,

    0x15: 3,

    0x19: 4,

    0x1A: 3,

    0x1D: 3,

    0x1E: 21
};

var server = {
    info: new Server(info),
    client: {},
    isConnected: false
};

var udpPort = 0;
var udpCounter = 0;
var udpTimers = [];
var currentPlayerId = 3;

function connectFailed () {
    //console.log('CONNECT FAILED');
    server.isConnected = false;
    udpTimers.forEach(clearInterval);
    udp._handle && udp.close();
};

function udpSend (data) {
    data[3] = (udpCounter++) % 256;
    data = udpchecksum(data);

    udp._handle && udp.send(data, 0, data.length, server.info.port, server.info.ip);
};

function joinServer () {
    /*if (server.info.address !== "80.78.215.117:10052") {
        connectFailed();
        return;
    }*/

    //connectFailed();
    //return;

    server.client.socketId = 0;
    server.client.playerId = 0;
    server.client.levelName = "";
    server.client.isPlus = false;
    server.client.players = [];

    server.client.game = {
        gamemode: 0,
        maxscore: 0,
        customMode: 0,
        ctf: {
            teams: [
                {score: 0, holder: -1},
                {score: 0, holder: -1}
            ]
        },
        time: {
            started: false,
            inPregame: false,
            inOvertime: false,
            timeLeft: 0,
            time: 0,
            autoCycle: false
        },
        isIdleserver: false,

    };
    var game = server.client.game;

    server.client.lastTimeUpdate = Date.now();

    var password = "";

    var toSend = udpchecksum(new Buffer("yy"+"\x0A"+String.fromCharCode(password.length)+password));
    udp.send(toSend, 0, toSend.length, server.info.port, server.info.ip);

    udp.on('message', function (data, rinfo) {
        var olddata = data;
        var packetId = data[2];
        if (packetId === 0x02) {
            var playercount = data[4];
            var ids = [];

            for (var i = 0; i < playercount; i++) {
                var offset = 12*i;
                var playerId = data[offset+6] & 31;
                var health = data[offset+6] >> 5;
                ids.push(playerId);

                var player = server.client.players[playerId];
                if (player) {
                    player.xpos = (data[offset+10]+data[offset+11]*256)/32 % 1024;
                    player.ypos = (data[offset+12]+data[offset+13]*256)/32 % 1024;
                    player.health = health;

                } else {
                    console.log("no player "+playerId);
                }
            }
            //console.log(playercount, ids);


        } else if (packetId === 0x07) { // Subpacket/action
            var i = 4;
            var packets = [];
            var ids = [];
            //console.log(olddata.slice(4));

            while (i < data.length) {
                var id = data[i];
                //console.log(id);
                if (!actionSizes[id] || i+actionSizes[id]+1 > data.length) break;
                packets.push(data.slice(i, i+actionSizes[id]+1));
                i += actionSizes[id] + 1;
                ids.push(id);
            }
            /*if (Array.prototype.indexOf.call(data.slice(4), 0x0E) > -1) {
                console.log("UDP ACTION: ", Array.prototype.indexOf.call(data.slice(4), 0x0E), data.slice(4));
                console.log(ids);
            }*/
            //console.log(packets);

            for (var key = 0; key < packets.length; key++) {

                var data = packets[key];

                //console.log(data);
                var subPacketId = data[0];

                //console.log(subPacketId);
                if (subPacketId === 0x03) { // Object destroyed/despawn

                } else if (subPacketId === 0x04) { // Collision

                    //sendChat("unknown packet");

                } else if (subPacketId === 0x07) { // Bullet
                    var gunman = ~~(data[6] / 4);
                    var direction = (data[7] / 32) & 3;
                    var weapon = data[7] % 16;
                    var powered = Math.floor(data[7] / 128);
                    var xpos = data.readUInt16LE(8) / 32;
                    var ypos = data.readUInt16LE(10) / 32;
                    //console.log('bullet', server.client.players[gunman].name, direction, zfs(data[7].toString(2), 8), data[7]);
                    //sendChat("Bullet fired by "+server.client.players[gunman].name+" "+(weapon+1)+" "+(powered?'PU':''));

                } else if (subPacketId === 0x0C) { // Hurt
                    var playerId = data[3] & 31;
                    var health = data[3] >> 5;
                    var player = server.client.players[playerId];
                    if (player) {
                        player.health = health;
                    }

                } else if (subPacketId === 0x0E) { // Roast/kill/suicide
                    //console.log("ROAST");
                    var i = 1;
                    var victimId = data[i++];
                    var victimPoints = data.readUInt32LE(i); i+=4;
                    var killerId = data[i++];
                    var killerPoints = data.readUInt32LE(i); i+=4;

                    var victim = server.client.players[victimId];
                    var killer = server.client.players[killerId];

                    if (victim && killer) {
                        //sendChat(killerPoints+", "+victimPoints);

                        if (victimId !== killerId) {
                            killer.points = killerPoints;
                            victim.points = victimPoints;

                            //sendChat(killer.name+" roasted "+victim.name);
                            //sendChat(killer.name+' got '+killer.points+' points');
                            //sendChat(victim.name+' got '+victim.points+' points');
                        } else {
                            killer.points = killerPoints;
                            //sendChat(killer.name+" ate it");
                            //sendChat(killer.name+' got '+killer.points+' points');
                        }

                    } else {
                        //sendChat("Unknown killer/victim player.", killerId, victimId);
                    }

                } else if (subPacketId === 0x0F) { // Streetfightad
                    var victimId = data[1] & 31;
                    var victimHealth = data[1] >> 5;
                    var killerId = data[2];

                    var victim = server.client.players[victimId];
                    var killer = server.client.players[killerId];

                    if (victim && killer) {
                        //sendChat(killer.name+" streetfighted "+victim.name);
                    } else {
                        //sendChat(killerId+" streetfighted "+victimId);
                    }
                    if (victim) {
                        victim.health = health;
                    }
                    /*var toSend = new Buffer(11);
                    toSend[2] = 0x07;
                    toSend[4] = 0x0F;
                    toSend[5] = killerId;
                    toSend[6] = victimId;
                    //console.log(olddata);
                    //udpSend(toSend);
                    console.log(toSend);*/


                } else if (subPacketId === 0x15) {

                } else if (subPacketId === 0x1E) {
                    //console.log(data);
                    var bluescore = data[5];
                    var redscore = data[10];
                    var blueHolder = data[20] > 0 ? data[21] : -1;
                    var redHolder = data[17] > 0 ? data[18] : -1;

                    game.ctf.teams[0].score = bluescore;
                    game.ctf.teams[1].score = redscore;
                    game.ctf.teams[0].holder = blueHolder;
                    game.ctf.teams[1].holder = redHolder;

                    //console.log('score: ', bluescore, redscore, 'holder: ', blueHolder, redHolder);
                } else {
                    //console.log("GOT ACTION UDP", "0x"+subPacketId.toString(16), data);
                }

            }


        } else if (packetId === 0x09) { // Keep alive (JJ2+)
            var toSend = data;
            udpSend(toSend);

        } else if (packetId === 0x0B) {
            if (data[3] > 0) {
                startTCP();
            } else if (password) {
                //console.log("Wrong password '"+password+"' for "+server.info.servername);
            }
        } else {
            //console.log("UDP", data)
        }


    });

    var extraPlusData = new Buffer(0);

    var sendChat = function (msg) {
        if(server.client.socketId) {
            var toSend = "\x1B"+String.fromCharCode(server.client.socketId)+"\x20"+msg;
            toSend = String.fromCharCode(toSend.length+1)+toSend;
            if(conn.client._handle) {
                conn.client.write(new Buffer(toSend, "binary"));
                return true;
            }
        }
        return false;
    };

    var getPlayerId = function (sock) {
        var result = [];
        for(var i=0; i < server.client.players.length; i+=1) {
            if(server.client.players[i] !== undefined && server.client.players[i].socketId === sock) {
                result.push(i);
            }
        }
        return result;
    };

    function sendUpdateRequest() {
        // update request
        toSend = new Buffer(6);
        toSend[0] = 6;
        toSend[1] = 0x1A;
        extraPlusData.copy(toSend, 2, 0, 4);
        conn.client.write(toSend);
        console.log("Sent update request");
    }

    function startGame() {
        // udp handshake
        var toSend = new Buffer(8);
        toSend[2] = 0x09;
        toSend[3] = server.client.socketId;
        extraPlusData.copy(toSend, 4, 4, 8);
        udpSend(toSend);

        //client.write("\x03\x42\x21", 'binary'); // Make bot spectate

        server.isConnected = true; // Important

        var startTime = Date.now();

        udpTimers.push(setInterval(function () {
            var myPlayer = server.client.players[server.client.playerId];
            var followPlayer = server.client.players[currentPlayerId] || server.client.players[0];

            if (myPlayer.health === 0) {
                myPlayer.xpos = 0;
                myPlayer.ypos = 0;
                myPlayer.health = 5;
            }

            var time = (Date.now()/1000)*2;

            var x = followPlayer.xpos+3*Math.cos(time);
            var y = followPlayer.ypos+3*Math.sin(time*0.6);

            var dx = myPlayer.xpos-x;
            var dy = myPlayer.ypos-y;

            var distance = Math.min(Math.sqrt(dx*dx+dy*dy)/10, 1.5);

            //console.log(dx, dy, distance);
            var angle = Math.atan2(dy, dx);
            //console.log(~~(angle*57.2957795), ~~(dx/32), ~~(dy/32), 10*Math.cos(angle), 10*Math.sin(angle), ~~distance);

            var velx = -distance*Math.cos(angle);
            var vely = -distance*Math.sin(angle);

            myPlayer.xpos += velx;
            myPlayer.ypos += vely;
            myPlayer.xpos = Math.max(0, Math.min(myPlayer.xpos, 1024));
            myPlayer.ypos = Math.max(0, Math.min(myPlayer.ypos, 1024));

            //console.log(~~velx*32, ~~vely*32);

            myPlayer.direction = velx > 0;

            var xpos = new Buffer(new Uint8Array(new Uint16Array([myPlayer.xpos*32]).buffer));
            var ypos = new Buffer(new Uint8Array(new Uint16Array([myPlayer.ypos*32]).buffer));

            var toSend = new Buffer([0, 0, 0x01, 0, 0x01, Math.floor(Date.now()/70)%256, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00]);

            toSend[2+7] = xpos[0];
            toSend[3+7] = (xpos[1] & 0x7F) | (myPlayer.direction*0x80);
            toSend[4+7] = ypos[0];
            toSend[5+7] = ypos[1];
            toSend[6+7] = 67;//Math.floor(Date.now()/500) % 128; // 67, 77
            toSend[7+7] = Math.floor(Date.now()/70) % 12;

            if (vely < -0.25) {
                toSend[6+7] = 70; // swim up
            } else if (vely > 0.4) {
                toSend[6+7] = 66; // swim down
            }


            udpSend(toSend);


        }, 1000/20));

        udpTimers.push(setInterval(function () {

            var myPlayer = server.client.players[server.client.playerId];

            //var xpos = new Buffer(new Uint8Array(new Uint16Array([myPlayer.xpos*32]).buffer));
            //var ypos = new Buffer(new Uint8Array(new Uint16Array([myPlayer.ypos*32]).buffer));

            var weapon = 0; // zero based
            var direction = myPlayer.direction ? 1 : 0;
            var powered = false;

            var toSend = new Buffer(5+11);
            toSend.fill(0);
            toSend[2] = 0x08;
            toSend[4] = 0x07;
            toSend[8] = 0x07;
            toSend[9] = server.client.playerId;
            toSend[10] = server.client.playerId*4;
            toSend[11] = (powered << 7) | (direction << 5) | weapon;
            toSend.writeUInt16LE(myPlayer.xpos*32|0, 12);
            toSend.writeUInt16LE(myPlayer.ypos*32|0, 14);
            //udpSend(toSend);
        }, 500));
    }

    function downloadFiles(cb) {
        console.log("Downloading "+server.client.levelName);

        //var toSend = chr(levelFileName.length+3)+"\x15"+chr(levelFileName.length)+levelFileName;
        var toSend = new Buffer(server.client.levelName.length+3);
        toSend[0] = toSend.length;
        toSend[1] = 0x15;
        toSend[2] = server.client.levelName.length;
        toSend.write(server.client.levelName, 3, server.client.levelName.length, 'binary');
        console.log(toSend, toSend.toString('binary'));
        //conn.client.write(toSend);

        // When finished downloading
        sendUpdateRequest();
        if (typeof cb === 'function') cb();

    }

    function startTCP () {
        var client = net.connect(server.info.port, server.info.ip);
        conn.client = client;

        client.on('connect', function () {
            clearTimeout(clientTimer);
            console.log('connected to '+server.info.address);

            var buf = new Buffer(9);
            buf.write("\x09\x0F", 0, 'binary');
            buf.writeUInt16LE(udpPort, 2);
            server.info.version.copy(buf, 4);
            buf.write("\x01", 8, 'binary');
            client.write(buf);

        });
        client.on('data', function (res) {


            // TODO: Clean up the code!
            var p = 0, j = res.length, res_a = [], l = 0;
            var special = false;
            while (p < j) {

                l = res[p];

                if (res[p] === 0 && ++p < j) {
                    l = res.readUInt16LE(p);
                    p += 2;
                    var buf = new Buffer(l+1);
                    buf[0] = 0;
                    res.copy(buf, 1, p, p+l);
                    res_a.push(buf);

                } else {
                    if (p+l > j) {
                        //console.log('oob', p, l, j, res);
                        break;
                    }
                    res_a.push(res.slice(p, p+l));
                }
                p += l;
            }

            for (var key = 0; key < res_a.length; key++) { // Loops through packet array
                var data = res_a[key];

                var packetId = data[1];

                if (packetId === 0x0D) { // Disconnect
                    //console.log(data);

                    var type = data[2];
                    var message = disconnectMessages[type] || ("Unknown error |"+type);

                    var playerid = getPlayerId(data[3]);
                    var reason = data.length > 10 ? data.slice(10).toString('binary') : "";
                    //console.log("Disconnected:", data[3], type, message, reason && "("+reason+")");
                    for(var i = 0; i < playerid.length; i++) {
                        if(type !== 7) {
                            sendChat("§1"+server.client.players[playerid[i]].name+" left: |"+message +" |"+(reason && "("+reason+")"));
                        }
                        if (playerid[i] === server.client.playerId) {
                            console.log("The bot was disconnected from", server.info.address, server.info.servername, message, reason && "("+reason+")");
                        }
                        delete server.client.players[playerid[i]];
                    }


                } else if (packetId === 0x10) { // Server info

                    var i = 2;
                    server.client.socketId = data[i++];
                    server.client.playerId = data[i++];
                    var l = data[i++];
                    server.client.levelName = data.slice(i, i + l).toString('binary');
                    i += l;

                    i+=8; // Skip CRC stuff
                    server.client.game.gamemode = data[i++];
                    server.client.game.maxscore = data[i++];

                    if (data.length > i) {
                        extraPlusData = data.slice(i);
                    } else {
                        client.destroy();
                        connectFailed();
                        return;
                    }
                    //console.log(extraPlusData);

                    client.write("\x08\x3F\x20\x01\x00\x00\x04\x01"); // JJ2+ New


                    //console.log("info?!1+", data.slice(i));

                    var toSend = "\x0E\x01"+String.fromCharCode(server.client.playerId)+"\x02\x00"+"\x18\x10\x28\x20"+BOT_NAME+"\x00";
                    toSend = String.fromCharCode(toSend.length+1)+toSend;
                    client.write(toSend, 'binary');
                } else if(packetId === 0x11) { // Someone joins...
                    var packetLength = data.length;
                    var i=4; // Skip player amount
                    var sockID = data[2];
                    var playerid;
                    var pname = "";
                    var fur;
                    var charTeam;
                    while(packetLength>i) {
                        playerid = data[i++];
                        charTeam = data[i++];
                        i++;
                        fur = [data[i++], data[i++], data[i++], data[i++]];
                        pname = "";
                        while(data[i] != undefined) {pname+=String.fromCharCode(data[i++]);if(data[i]==0) break;}
                        i+=1;
                        server.client.players[playerid] = {
                            charTeam: charTeam,
                            fur: fur,
                            name: pname,
                            socketId: sockID,
                            spectating: false,
                            points: 0,
                            deaths: 0,
                            ping: -1,
                            xpos: 0,
                            ypos: 0,
                            direction: true,
                            health: 5
                        };
                    }
                } else if(packetId === 0x12) { // Playerlist
                    var packetLength = data.length;
                    var totalplayers = 0;
                    var i = 3;
                    while (packetLength>i) {
                        var psock = data[i++];
                        var pplayer = data[i++];
                        var pcharTeam = data[i++];
                        i++;

                        var fur = [data[i++], data[i++], data[i++], data[i++]];
                        var pname = "";
                        while(data[i] != undefined) {pname+=String.fromCharCode(data[i++]);if(data[i]==0) break;}
                        i += 1;
                        totalplayers += 1;
                        if (!server.client.players[pplayer]) {
                            server.client.players[pplayer] = {
                                spectating: false,
                                points: 0,
                                deaths: 0,
                                ping: -1
                            };
                        }

                        var player = server.client.players[pplayer];
                        player.name = pname;
                        player.fur = fur;
                        player.charTeam = pcharTeam;
                        player.socketId = psock;
                        player.xpos = 0;
                        player.ypos = 0;
                        player.direction = true;
                        player.health = 5;


                        //roomBroadcast(JSON.stringify({'console': [(pplayer+1)+". "+pname, 1]}), roomId);

                    }
                    //console.log(server.client.players);
                    //roomBroadcast(JSON.stringify({'console': [Array.prototype.slice.call(data, 2).join(" "), 1]}), roomId);

                } else if (packetId === 0x13) { // Game init

                    if (server.isConnected) {
                        continue;
                    }

                    downloadFiles(startGame);

                    // ??
                    //udp.send(new Buffer([0x0A, 0x15, 0x09, 0x00 ]), 0, 4, server.info.port, server.info.ip);

                } else if (packetId === 0x14) {
                    var index = 2;
                    var currPieceID = data.readUInt32LE(index); // LATEST PLUS ONLY!
                    index += 4;
                    if (currPieceID === 0) {
                        var expectedDownloadFileSize = data.readUInt32LE(index); // filesize
                    }


                } else if(packetId === 0x16) { // Level cycle
                    var i = 2;
                    i+=8; // Skip CRC stuff
                    var l = data[i++];
                    server.client.levelName = data.slice(i, i + l - 1).toString('binary');
                    i += l;


                    extraPlusData = data.slice(i);

                    downloadFiles();


                    // udp
                    /*var toSend = new Buffer(4);
                    toSend[2] = 0x09;
                    udpSend(toSend);*/

                    for (var i = 0; i < server.client.players.length; i++) {
                        var player = server.client.players[i];
                        if (player) {
                            player.points = 0;
                            player.deaths = 0;
                            //console.log("Reset points/deaths for "+player.name);

                        }
                    }

                } else if (packetId === 0x17) { // End of level

                } else if (packetId === 0x18) { // Events update

                } else if (packetId === 0x1B) { // Chat
                    var message = data.slice(4).toString('binary');
                    var playerId = getPlayerId(data[2])[0];
                    var player = server.client.players[playerId];
                    if (message === "!follow") {
                        if (player) {
                            currentPlayerId = playerId;
                            sendChat("Now following "+player.name);
                        } else {
                            sendChat("Player "+(playerId+1)+" not found");
                        }
                    }

                } else if (packetId === 0x3F) { // Plus packet
                    game.customMode = data[6];
                } else if (packetId === 0x40) { // Console message
                    //console.log("Console: "+data.slice(3).toString('binary'));
                } else if (packetId === 0x41) {
                    //console.log("SPECTATE", data.slice(2));
                    //sendChat('got spectate packet: '+data[2].toString(2)+' ['+Array.prototype.slice.call(data, 2).join(", ")+']');
                    var i = 2;
                    var spectatePacketType = data[i++];
                    if (spectatePacketType === 0) {
                        //sendChat("zepectate: "+data[i++].toString(2)+" "+data[i++].toString(2)+" ["+Array.prototype.slice.call(data, 2).join(", ")+']');
                        var unknown = data[i++];
                        var binary = data[i++];
                        for (var i = 0; i < server.client.players.length; i++) {
                            var player = server.client.players[i];
                            if (player) {
                                var isSpec = ((binary >> player.socketId) & 1) === 1;
                                if (isSpec !== player.spectating) {
                                    if (isSpec) {
                                        //sendChat(player.name+" is now spectating");
                                        player.points = 0;
                                        player.deaths = 0;
                                        //console.log("Reset points/deaths for "+player.name);

                                    } else {
                                        //sendChat(player.name+" is no longer spectating");
                                    }
                                    player.spectating = isSpec;
                                }
                            }

                        }

                    } else if (spectatePacketType === 1) {
                        var spectateType = data[i++];
                        var clientId = data[i++];
                        var spectateId = data[i++];
                        var playerIds = getPlayerId(clientId);

                        //console.log("someone changed spec", data);
                        var isSpec = spectateId !== 0xFE;
                        for (var i = 0; i < playerIds.length; i++) {
                            var player = server.client.players[playerIds[i]];

                            if (player && isSpec !== player.spectating) {
                                if (isSpec) {
                                    //sendChat(player.name+" is spectating");
                                    player.points = 0;
                                    player.deaths = 0;
                                } else {
                                    //sendChat(player.name+" is no longer spectating");
                                }
                                player.spectating = isSpec;
                            }

                        }
                    }
                    /*if(data[0] === 5) {
                        console.log("got spec list: "+data[2].toString(2), data.slice(3));
                        //sendChat('got spec list: '+data[2].toString(2)+' ['+Array.prototype.slice.call(data, 2)+']');
                        var binary = data[2];
                        for (var i = 0; i < server.client.players.length; i++) {
                            var player = server.client.players[i];
                            if (player) {
                                var isSpec = ((binary >> player.socketId) & 1) === 1;
                                console.log(isSpec, player.spectating)
                                if (isSpec !== player.spectating) {
                                    if (isSpec) {
                                        sendChat(player.name+" is spectating");
                                    } else {
                                        sendChat(player.name+" is no longer spectating");
                                    }
                                    player.spectating = isSpec;
                                }
                            }

                        }
                    }
                    else {
                        var playerIds = getPlayerId(data[2]);

                        //console.log("someone changed spec", data);
                        var isSpec = data[3] !== 0xFE;
                        for (var i = 0; i < playerIds.length; i++) {
                            var player = server.client.players[playerIds[i]];

                            if (player && isSpec !== player.spectating) {
                                if (isSpec) {
                                    sendChat(player.name+" is spectating");
                                } else {
                                    sendChat(player.name+" is no longer spectating");
                                }
                                player.spectating = isSpec;
                            }

                        }

                    }*/
                } else if (packetId === 0x45) { // Time
                    var gameState = data[2];
                    var gameStarted = !!(gameState & 1);
                    var inPregame = !((gameState >> 1) & 1) && ((gameState >> 2) & 1);
                    var inOvertime = !!(((gameState >> 1) & 1) && ((gameState >> 2) & 1));
                    var timeLeft = data.readUInt32LE(3)/1000;
                    var mins = Math.floor(timeLeft / 60);
                    var secs = Math.floor(timeLeft) % 60;

                    game.time.started = gameStarted;
                    game.time.autoCycle =  !!((gameState >> 1) & 1);
                    game.time.inPregame = inPregame;
                    game.time.inOvertime = inOvertime;
                    game.time.timeLeft = timeLeft;

                    server.client.lastTimeUpdate = Date.now();
                    //console.log(timeLeft);
                    //sendChat("§0|"+(gameStarted?(inPregame?"|||":"")+(inOvertime?"||":""):"|")+zfs(mins)+":"+zfs(secs)+" left");

                } else if (packetId === 0x49) { // Pings
                    //sendChat("Pings: "+Array.prototype.slice.call(data, 2).join(", "));
                    var i = 2;
                    while (i < data.length) {
                        var playerId = data[i++];
                        var ping = data.readUInt16LE(i); i+=2;
                        var player = server.client.players[playerId];
                        if (player) {
                            player.ping = ping;
                        }
                    }

                } else if (packetId === 0x4A) { // Gamemode and maxscore
                    var gamemode = data[2];
                    var customGamemode = data[3];
                    var maxscore = data[4];
                    game.gamemode = gamemode;
                    game.maxscore = maxscore;
                    game.customMode = customGamemode;
                    //console.log(customGamemode > 0 ? "Custom gamemode: "+customGamemode : "Gamemode: "+gamemode, "maxscore: "+maxscore)
                } else if (packetId === 0x4C) { // Player stats

                    var i = 2, len = data.length;
                    while (i < len) {
                        var playerId = data[i++];
                        var points = data.readUInt32LE(i); i += 4;
                        var deaths = data.readUInt32LE(i); i += 4;
                        var player = server.client.players[playerId];
                        if (player) {
                            player.points = points;
                            player.deaths = deaths;
                            //sendChat(player.name+' got '+player.points+' points and '+player.deaths+' deaths');
                        } else {
                            sendChat("Unknown player "+playerId);
                        }
                    }

                } else if (packetId === 0x4D) { // Deaths
                    //sendChat(Array.prototype.slice.call(data, 2).join(", "));
                    var i = 2, len = data.length;
                    while (i < len) {
                        var playerId = data[i++];
                        var deaths = data.readUInt32LE(i); i += 4;
                        var player = server.client.players[playerId];
                        if (player) {
                            player.deaths = deaths;
                            //sendChat(player.name+' got '+player.deaths+' deaths');
                        } else {
                            sendChat("Unknown player "+playerId);
                        }
                    }
                } else if (packetId === 0x50) { // TCP_SC_MISC

                } else if (packetId === 0x52) { // Idleserver
                    game.isIdleserver = !!data[2];
                    //sendChat("IDLESERVER IS "+(isIdleserver? "|ENABLED" : "||DISABLED"));

                } else {
                    //console.log("TCP: 0x"+packetId.toString(16), data.slice(2));
                }

                //console.log("0x"+packetId.toString(16));

            }
        });
        client.on('error', function (err) {
            console.log("client "+err);
        });
        client.on('close', function () {
            console.log('Disconnected from', server.info.address, server.info.servername);
            connectFailed();
        });
        var clientTimer = setTimeout(function () {
            client.destroy();
        }, 3000);

    }
};

var conn = {};

var query = udpchecksum(new Buffer("yy\x05\x00"));
conn.udp = dgram.createSocket("udp4");
var udp = conn.udp;

var isFirst = true;
udp.on('listening', function () {
    var rinfo = udp.address();
    //console.log("Listening on "+rinfo.address+":"+rinfo.port);

    udpPort = rinfo.port;
    udp.send(query, 0, query.length, server.info.port, server.info.ip);
});
udp.on('message', function (data, rinfo) {

    if (rinfo.address === server.info.ip && rinfo.port === server.info.port && isFirst) {
        isFirst = false;
        clearTimeout(queryTimer);

        server.info.version = data.slice(8, 8+4);
        server.info.capacity = [data[12], data[15]];
        server.info.gametype = data[14];
        server.info.servername = data.slice(17, 17+data[16]).toString('binary');

        joinServer();
    }
});
udp.on('error', function (err) {
    console.log('UDP '+err)
});
udp.bind();
var queryTimer = setTimeout(function () {
    conn.udp.close();
    connectFailed();
}, 3000);