From 321580e3bb5a478a0d3ef6f72a49f2b8c2f190ed Mon Sep 17 00:00:00 2001
From: Michael Morrison <mmorrison@pon4.net>
Date: Sun, 2 Feb 2014 06:25:50 -0600
Subject: [PATCH] Add Teamspeak2 support

---
 games/teamspeak2.js | 86 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 86 insertions(+)
 create mode 100644 games/teamspeak2.js

diff --git a/games/teamspeak2.js b/games/teamspeak2.js
new file mode 100644
index 0000000..6f53766
--- /dev/null
+++ b/games/teamspeak2.js
@@ -0,0 +1,86 @@
+var async = require('async');
+
+module.exports = require('./protocols/core').extend({
+	init: function() {
+		this._super();
+		this.pretty = 'Teamspeak 2';
+		this.options.port = 8767;
+		this.options.master_port = 51234;
+	},
+	run: function(state) {
+		var self = this;
+		
+		var port = this.options.port;
+		this.options.port = this.options.master_port;
+		
+		async.series([
+			function(c) {
+				self.sendCommand('sel '+port, function(data) {
+					if(data != '[TS]') self.fatal('Invalid header');
+					c();
+				});
+			},
+			function(c) {
+				self.sendCommand('si', function(data) {
+					var split = data.split('\r\n');
+					split.forEach(function(line) {
+						var equals = line.indexOf('=');
+						var key = line.substr(0,equals);
+						var value = line.substr(equals+1);
+						state.raw[key] = value;
+					});
+					c();
+				});
+			},
+			function(c) {
+				self.sendCommand('pl', function(data) {
+					var split = data.split('\r\n');
+					var fields = split.shift().split('\t');
+					split.forEach(function(line) {
+						var split2 = line.split('\t');
+						var player = {};
+						split2.forEach(function(value,i) {
+							var key = fields[i];
+							if(!key) return;
+							if(key == 'nick') key = 'name';
+							if(m = value.match(/^"(.*)"$/)) value = m[1];
+							player[key] = value;
+						});
+						state.players.push(player);
+					});
+					c();
+				});
+			},
+			function(c) {
+				self.sendCommand('cl', function(data) {
+					var split = data.split('\r\n');
+					var fields = split.shift().split('\t');
+					state.raw.channels = [];
+					split.forEach(function(line) {
+						var split2 = line.split('\t');
+						var channel = {};
+						split2.forEach(function(value,i) {
+							var key = fields[i];
+							if(!key) return;
+							if(m = value.match(/^"(.*)"$/)) value = m[1];
+							channel[key] = value;
+						});
+						state.raw.channels.push(channel);
+					});
+					c();
+				});
+			},
+			function(c) {
+				self.finish(state);
+			}
+		]);
+	},
+	sendCommand: function(cmd,c) {
+		this.tcpSend(cmd+'\x0A', function(buffer) {
+			if(buffer.length < 6) return;
+			if(buffer.slice(-6).toString() != '\r\nOK\r\n') return;
+			c(buffer.slice(0,-6).toString());
+			return true;
+		});
+	}
+});