var varint = require('varint'), async = require('async'); function varIntBuffer(num) { return new Buffer(varint.encode(num)); } function buildPacket(id,data) { if(!data) data = new Buffer(0); var idBuffer = varIntBuffer(id); return Buffer.concat([ varIntBuffer(data.length+idBuffer.length), idBuffer, data ]); } module.exports = require('./core').extend({ run: function(state) { var self = this; var receivedData; async.series([ function(c) { // build and send handshake and status TCP packet var portBuf = new Buffer(2); portBuf.writeUInt16BE(self.options.port_query,0); var addressBuf = new Buffer(self.options.address,'utf8'); var bufs = [ varIntBuffer(4), varIntBuffer(addressBuf.length), addressBuf, portBuf, varIntBuffer(1) ]; var outBuffer = Buffer.concat([ buildPacket(0,Buffer.concat(bufs)), buildPacket(0) ]); self.tcpSend(outBuffer, function(data) { if(data.length < 10) return false; var expected = varint.decode(data); data = data.slice(varint.decode.bytes); if(data.length < expected) return false; receivedData = data; c(); return true; }); }, function(c) { // parse response var data = receivedData; var packetId = varint.decode(data); if(self.debug) console.log("Packet ID: "+packetId); data = data.slice(varint.decode.bytes); var strLen = varint.decode(data); if(self.debug) console.log("String Length: "+strLen); data = data.slice(varint.decode.bytes); var str = data.toString('utf8'); if(self.debug) { console.log(str); } var json; try { json = JSON.parse(str); delete json.favicon; } catch(e) { return self.fatal('Invalid JSON'); } state.raw.version = json.version.name; state.maxplayers = json.players.max; state.raw.description = json.description.text; if(json.players.sample) { for(var i = 0; i < json.players.sample.length; i++) { state.players.push({ id: json.players.sample[i].id, name: json.players.sample[i].name }); } } while(state.players.length < json.players.online) { state.players.push({}); } self.finish(state); } ]); } });