comms.js

var Comms = (function() {
	var self = {};
	var sock;
	var fmt = d3.format("0,000");

	$('#loading-indicator').show();

	var redditRequester = new XMLHttpRequest();

	redditRequester.onreadystatechange = function () {
		if (redditRequester.readyState !== 4) {
			return;
		}
		var websocketURL;
		if (redditRequester.status === 200) {
			var regex = /"(wss:\/\/wss\.redditmedia\.com\/thebutton\?h=[^"]*)"/g;
			websocketURL = regex.exec(redditRequester.responseText)[1];
		}

		websocketURL = websocketURL || "wss://wss.redditmedia.com/thebutton?h=7f66bf82878e6151f7688ead7085eb63a0baff0b&e=1428621271";
		
		console.log("Connecting to: " + websocketURL);
		sock = new WebSocket(websocketURL);
		sock.onmessage = tick;
	};
	// Use CORS proxy by lezed1 to get the Reddit homepage!
	redditRequester.open("get", "//cors-unblocker.herokuapp.com/get?url=https%3A%2F%2Fwww.reddit.com%2Fr%2Fthebutton", true);
	redditRequester.send();

	function tick(evt) {
		$('#loading-indicator').hide();
		$('#stats').show();
		Stats.start = Stats.start || moment();

		// {"type": "ticking", "payload": {"participants_text": "585,177", "tick_mac": "362a88a8ae0a89c909395f587e329992c656b4d8", "seconds_left": 59.0, "now_str": "2015-04-04-23-44-42"}}
		var packet = JSON.parse(evt.data);
		if (packet.type != "ticking") {
			return;
		}

		packet.payload.now = moment(packet.payload.now_str + " 0000", "YYYY-MM-DD-HH-mm-ss Z");
		Stats.lag = d3.format("0,000")(packet.payload.now - moment());
		packet.payload.participants = parseInt(packet.payload.participants_text.replace(/[^0-9]/g, ''))

		var last = _.last(data);
		if (data.length > 0 && packet.payload.seconds_left >= last.seconds_left) {
			last.is_click = true;
			last.clicks = packet.payload.participants - last.participants;
			Stats.clicks += last.clicks;

			var total_resets = _.filter(data, 'is_click').length;
			var last_time = last.seconds_left;
			// Update color stats
			if (last_time <= 11) {
				Stats.total_reds += last.clicks;
			}
			else if (last_time <= 21) {
				Stats.total_oranges += last.clicks;
			}
			else if (last_time <= 31) {
				Stats.total_yellows += last.clicks;
			}
			else if (last_time <= 41) {
				Stats.total_greens += last.clicks;
			}
			else if (last_time <= 51) {
				Stats.total_blues += last.clicks;
			}
			else if (last_time <= 60) {
				Stats.total_purples += last.clicks;
			}

			// Update percentages
			Stats.purple_percentage = "(" + (100.0 * Stats.total_purples / Stats.clicks).toFixed(3) + "%)";
			Stats.blue_percentage = "(" + (100.0 * Stats.total_blues / Stats.clicks).toFixed(3) + "%)";
			Stats.green_percentage = "(" + (100.0 * Stats.total_greens / Stats.clicks).toFixed(3) + "%)";
			Stats.yellow_percentage = "(" + (100.0 * Stats.total_yellows / Stats.clicks).toFixed(3) + "%)";
			Stats.orange_percentage = "(" + (100.0 * Stats.total_oranges / Stats.clicks).toFixed(3) + "%)";
			Stats.red_percentage = "(" + (100.0 * Stats.total_reds / Stats.clicks).toFixed(3) + "%)";

			// Update lowest time if needed
			if (Stats.lowest_time > last_time) {
				Stats.lowest_time = last_time;
			}

			// Update average time
			Stats.sum_of_times += last_time;
			Stats.average_time = (1.0 * Stats.sum_of_times / total_resets).toFixed(3);

			// Resets per minute
			Stats.resets_per_minute = (60.0 * total_resets / data.length).toFixed(3);
		}
		data.push(packet.payload);
		Stats.ticks = fmt(data.length);
		Stats.participants = packet.payload.participants_text;
		Chart.render(data);
		Timer.sync(packet.payload.seconds_left);
		Stats.render();
	}

	self.resize = function() {
		$('#loading-indicator')
			.css('left', ($(window).width() - $('#loading-indicator').width()) / 2)
			.css('top', ($(window).height() - $('#loading-indicator').height()) * (1/3));
	}

	return self;
}())