pusher.js

/*!
 * Pusher JavaScript Library v1.11.2
 * http://pusherapp.com/
 *
 * Copyright 2011, Pusher
 * Released under the MIT licence.
 */

if(Function.prototype.scopedTo===void 0)Function.prototype.scopedTo=function(a,d){var b=this;return function(){return b.apply(a,Array.prototype.slice.call(d||[]).concat(Array.prototype.slice.call(arguments)))}};
var Pusher=function(a,d){this.options=d||{};this.key=a;this.channels=new Pusher.Channels;this.global_emitter=new Pusher.EventsDispatcher;var b=this;this.checkAppKey();this.connection=new Pusher.Connection(this.key,this.options);this.connection.bind("connected",function(){b.subscribeAll()}).bind("message",function(a){var d=a.event.indexOf("pusher_internal:")===0;if(a.channel){var g;(g=b.channel(a.channel))&&g.emit(a.event,a.data)}d||b.global_emitter.emit(a.event,a.data)}).bind("disconnected",function(){b.channels.disconnect()}).bind("error",
function(a){Pusher.warn("Error",a)});Pusher.instances.push(this);Pusher.isReady&&b.connect()};Pusher.instances=[];
Pusher.prototype={channel:function(a){return this.channels.find(a)},connect:function(){this.connection.connect()},disconnect:function(){this.connection.disconnect()},bind:function(a,d){this.global_emitter.bind(a,d);return this},bind_all:function(a){this.global_emitter.bind_all(a);return this},subscribeAll:function(){for(var a in this.channels.channels)this.channels.channels.hasOwnProperty(a)&&this.subscribe(a)},subscribe:function(a){var d=this,b=this.channels.add(a,this);this.connection.state==="connected"&&
b.authorize(this,function(e,f){e?b.emit("pusher:subscription_error",f):d.send_event("pusher:subscribe",{channel:a,auth:f.auth,channel_data:f.channel_data})});return b},unsubscribe:function(a){this.channels.remove(a);this.connection.state==="connected"&&this.send_event("pusher:unsubscribe",{channel:a})},send_event:function(a,d,b){return this.connection.send_event(a,d,b)},checkAppKey:function(){(this.key===null||this.key===void 0)&&Pusher.warn("Warning","You must pass your app key when you instantiate Pusher.")}};
Pusher.Util={extend:function extend(d,b){for(var e in b)d[e]=b[e]&&b[e].constructor&&b[e].constructor===Object?extend(d[e]||{},b[e]):b[e];return d},stringify:function(){for(var a=["Pusher"],d=0;d<arguments.length;d++)typeof arguments[d]==="string"?a.push(arguments[d]):window.JSON==void 0?a.push(arguments[d].toString()):a.push(JSON.stringify(arguments[d]));return a.join(" : ")},arrayIndexOf:function(a,d){var b=Array.prototype.indexOf;if(a==null)return-1;if(b&&a.indexOf===b)return a.indexOf(d);for(i=
0,l=a.length;i<l;i++)if(a[i]===d)return i;return-1}};Pusher.debug=function(){Pusher.log&&Pusher.log(Pusher.Util.stringify.apply(this,arguments))};Pusher.warn=function(){window.console&&window.console.warn?window.console.warn(Pusher.Util.stringify.apply(this,arguments)):Pusher.log&&Pusher.log(Pusher.Util.stringify.apply(this,arguments))};Pusher.VERSION="1.11.2";Pusher.host="ws.pusherapp.com";Pusher.ws_port=80;Pusher.wss_port=443;Pusher.channel_auth_endpoint="/pusher/auth";Pusher.cdn_http="http://js.pusher.com/";
Pusher.cdn_https="https://d3dy5gmtp8yhk7.cloudfront.net/";Pusher.dependency_suffix=".min";Pusher.channel_auth_transport="ajax";Pusher.activity_timeout=12E4;Pusher.pong_timeout=3E4;Pusher.isReady=!1;Pusher.ready=function(){Pusher.isReady=!0;for(var a=0,d=Pusher.instances.length;a<d;a++)Pusher.instances[a].connect()};
(function(){function a(a){this.callbacks={};this.global_callbacks=[];this.failThrough=a}a.prototype.bind=function(a,b){this.callbacks[a]=this.callbacks[a]||[];this.callbacks[a].push(b);return this};a.prototype.unbind=function(a,b){if(this.callbacks[a]){var e=Pusher.Util.arrayIndexOf(this.callbacks[a],b);this.callbacks[a].splice(e,1)}return this};a.prototype.emit=function(a,b){for(var e=0;e<this.global_callbacks.length;e++)this.global_callbacks[e](a,b);var f=this.callbacks[a];if(f)for(e=0;e<f.length;e++)f[e](b);
else this.failThrough&&this.failThrough(a,b);return this};a.prototype.bind_all=function(a){this.global_callbacks.push(a);return this};this.Pusher.EventsDispatcher=a}).call(this);
(function(){function a(a,b,d){if(b[a]!==void 0)b[a](d)}function d(a,d,g){b.EventsDispatcher.call(this);this.state=void 0;this.errors=[];this.stateActions=g;this.transitions=d;this.transition(a)}var b=this.Pusher;d.prototype.transition=function(d,f){var g=this.state,h=this.stateActions;if(g&&b.Util.arrayIndexOf(this.transitions[g],d)==-1)throw this.emit("invalid_transition_attempt",{oldState:g,newState:d}),Error("Invalid transition ["+g+" to "+d+"]");a(g+"Exit",h,f);a(g+"To"+(d.substr(0,1).toUpperCase()+
d.substr(1)),h,f);a(d+"Pre",h,f);this.state=d;this.emit("state_change",{oldState:g,newState:d});a(d+"Post",h,f)};d.prototype.is=function(a){return this.state===a};d.prototype.isNot=function(a){return this.state!==a};b.Util.extend(d.prototype,b.EventsDispatcher.prototype);this.Pusher.Machine=d}).call(this);
(function(){var a=function(){var a=this;Pusher.EventsDispatcher.call(this);window.addEventListener!==void 0&&(window.addEventListener("online",function(){a.emit("online",null)},!1),window.addEventListener("offline",function(){a.emit("offline",null)},!1))};a.prototype.isOnLine=function(){return window.navigator.onLine===void 0?!0:window.navigator.onLine};Pusher.Util.extend(a.prototype,Pusher.EventsDispatcher.prototype);this.Pusher.NetInfo=a}).call(this);
(function(){function a(a){a.connectionWait=0;a.openTimeout=b.TransportType==="flash"?5E3:2E3;a.connectedTimeout=2E3;a.connectionSecure=a.compulsorySecure;a.connectionAttempts=0}function d(d,r){function k(){c.connectionWait<s&&(c.connectionWait+=f);c.openTimeout<t&&(c.openTimeout+=g);c.connectedTimeout<u&&(c.connectedTimeout+=h);if(c.compulsorySecure!==!0)c.connectionSecure=!c.connectionSecure;c.connectionAttempts++}function o(){c._machine.transition("impermanentlyClosing")}function p(){c._activityTimer&&
clearTimeout(c._activityTimer);c._activityTimer=setTimeout(function(){c.send_event("pusher:ping",{});c._activityTimer=setTimeout(function(){c.socket.close()},c.options.pong_timeout||b.pong_timeout)},c.options.activity_timeout||b.activity_timeout)}function v(){var a=c.connectionWait;if(a===0&&c.connectedAt){var b=(new Date).getTime()-c.connectedAt;b<1E3&&(a=1E3-b)}return a}function w(){c._machine.transition("open")}function x(a){a=q(a);if(a!==void 0)if(a.event==="pusher:connection_established")c._machine.transition("connected",
a.data.socket_id);else if(a.event==="pusher:error"){var b=a.data.code;c.emit("error",{type:"PusherError",data:{code:b,message:a.data.message}});b===4E3?(c.compulsorySecure=!0,c.connectionSecure=!0,c.options.encrypted=!0,c._machine.transition("impermanentlyClosing")):b<4100?c._machine.transition("permanentlyClosing"):b<4200?(c.connectionWait=1E3,c._machine.transition("waiting")):b<4300?c._machine.transition("impermanentlyClosing"):c._machine.transition("permanentlyClosing")}}function y(a){p();a=q(a);
if(a!==void 0){b.debug("Event recd",a);switch(a.event){case "pusher:error":c.emit("error",{type:"PusherError",data:a.data});break;case "pusher:ping":c.send_event("pusher:pong",{})}c.emit("message",a)}}function q(a){try{var b=JSON.parse(a.data);if(typeof b.data==="string")try{b.data=JSON.parse(b.data)}catch(d){if(!(d instanceof SyntaxError))throw d;}return b}catch(e){c.emit("error",{type:"MessageParseError",error:e,data:a.data})}}function m(){c._machine.transition("waiting")}function n(){c.emit("error",
{type:"WebSocketError"});c.socket.close();c._machine.transition("impermanentlyClosing")}function j(a,d){var e=c.state;c.state=a;e!==a&&(b.debug("State changed",e+" -> "+a),c.emit("state_change",{previous:e,current:a}),c.emit(a,d))}var c=this;b.EventsDispatcher.call(this);this.options=b.Util.extend({encrypted:!1},r);this.netInfo=new b.NetInfo;this.netInfo.bind("online",function(){c._machine.is("waiting")&&(c._machine.transition("connecting"),j("connecting"))});this.netInfo.bind("offline",function(){if(c._machine.is("connected"))c.socket.onclose=
void 0,c.socket.onmessage=void 0,c.socket.onerror=void 0,c.socket.onopen=void 0,c.socket.close(),c.socket=void 0,c._machine.transition("waiting")});this._machine=new b.Machine("initialized",e,{initializedPre:function(){c.compulsorySecure=c.options.encrypted;c.key=d;c.socket=null;c.socket_id=null;c.state="initialized"},waitingPre:function(){c.connectionWait>0&&c.emit("connecting_in",c.connectionWait);c.netInfo.isOnLine()&&c.connectionAttempts<=4?j("connecting"):j("unavailable");if(c.netInfo.isOnLine())c._waitingTimer=
setTimeout(function(){c._machine.transition("connecting")},v())},waitingExit:function(){clearTimeout(c._waitingTimer)},connectingPre:function(){if(c.netInfo.isOnLine()===!1)c._machine.transition("waiting"),j("unavailable");else{var a;a=b.ws_port;var d="ws://";if(c.connectionSecure||document.location.protocol==="https:")a=b.wss_port,d="wss://";a=d+b.host+":"+a+"/app/"+c.key+"?protocol=5&client=js&version="+b.VERSION+"&flash="+(b.TransportType==="flash"?"true":"false");b.debug("Connecting",a);c.socket=
new b.Transport(a);c.socket.onopen=w;c.socket.onclose=m;c.socket.onerror=n;c._connectingTimer=setTimeout(o,c.openTimeout)}},connectingExit:function(){clearTimeout(c._connectingTimer)},connectingToWaiting:function(){k()},connectingToImpermanentlyClosing:function(){k()},openPre:function(){c.socket.onmessage=x;c.socket.onerror=n;c.socket.onclose=m;c._openTimer=setTimeout(o,c.connectedTimeout)},openExit:function(){clearTimeout(c._openTimer)},openToWaiting:function(){k()},openToImpermanentlyClosing:function(){c.socket.onmessage=
void 0;k()},connectedPre:function(b){c.socket_id=b;c.socket.onmessage=y;c.socket.onerror=n;c.socket.onclose=m;a(c);c.connectedAt=(new Date).getTime();p()},connectedPost:function(){j("connected")},connectedExit:function(){c._activityTimer&&clearTimeout(c._activityTimer);j("disconnected")},impermanentlyClosingPost:function(){if(c.socket)c.socket.onclose=m,c.socket.close()},permanentlyClosingPost:function(){c.socket?(c.socket.onclose=function(){a(c);c._machine.transition("permanentlyClosed")},c.socket.close()):
(a(c),c._machine.transition("permanentlyClosed"))},failedPre:function(){j("failed");b.debug("WebSockets are not available in this browser.")},permanentlyClosedPost:function(){j("disconnected")}})}var b=this.Pusher,e={initialized:["waiting","failed"],waiting:["connecting","permanentlyClosed"],connecting:["open","permanentlyClosing","impermanentlyClosing","waiting"],open:["connected","permanentlyClosing","impermanentlyClosing","waiting"],connected:["permanentlyClosing","impermanentlyClosing","waiting"],
impermanentlyClosing:["waiting","permanentlyClosing"],permanentlyClosing:["permanentlyClosed"],permanentlyClosed:["waiting"],failed:["permanentlyClosing"]},f=2E3,g=2E3,h=2E3,s=5*f,t=5*g,u=5*h;d.prototype.connect=function(){b.Transport===null||b.Transport===void 0?this._machine.transition("failed"):this._machine.is("initialized")?(a(this),this._machine.transition("waiting")):this._machine.is("waiting")&&this.netInfo.isOnLine()===!0?this._machine.transition("connecting"):this._machine.is("permanentlyClosed")&&
(a(this),this._machine.transition("waiting"))};d.prototype.send=function(a){if(this._machine.is("connected")){var b=this;setTimeout(function(){b.socket.send(a)},0);return!0}else return!1};d.prototype.send_event=function(a,d,e){a={event:a,data:d};e&&(a.channel=e);b.debug("Event sent",a);return this.send(JSON.stringify(a))};d.prototype.disconnect=function(){this._machine.is("permanentlyClosed")||(this._machine.is("waiting")?this._machine.transition("permanentlyClosed"):this._machine.transition("permanentlyClosing"))};
b.Util.extend(d.prototype,b.EventsDispatcher.prototype);this.Pusher.Connection=d}).call(this);Pusher.Channels=function(){this.channels={}};Pusher.Channels.prototype={add:function(a,d){var b=this.find(a);b||(b=Pusher.Channel.factory(a,d),this.channels[a]=b);return b},find:function(a){return this.channels[a]},remove:function(a){delete this.channels[a]},disconnect:function(){for(var a in this.channels)this.channels[a].disconnect()}};
Pusher.Channel=function(a,d){var b=this;Pusher.EventsDispatcher.call(this,function(b){Pusher.debug("No callbacks on "+a+" for "+b)});this.pusher=d;this.name=a;this.subscribed=!1;this.bind("pusher_internal:subscription_succeeded",function(a){b.onSubscriptionSucceeded(a)})};
Pusher.Channel.prototype={init:function(){},disconnect:function(){},onSubscriptionSucceeded:function(){this.subscribed=!0;this.emit("pusher:subscription_succeeded")},authorize:function(a,d){d(!1,{})},trigger:function(a,d){return this.pusher.send_event(a,d,this.name)}};Pusher.Util.extend(Pusher.Channel.prototype,Pusher.EventsDispatcher.prototype);Pusher.auth_callbacks={};
Pusher.authorizers={ajax:function(a,d){var b;b=Pusher.XHR?new Pusher.XHR:window.XMLHttpRequest?new window.XMLHttpRequest:new ActiveXObject("Microsoft.XMLHTTP");b.open("POST",Pusher.channel_auth_endpoint,!0);b.setRequestHeader("Content-Type","application/x-www-form-urlencoded");b.onreadystatechange=function(){if(b.readyState==4)if(b.status==200){var a,f=!1;try{a=JSON.parse(b.responseText),f=!0}catch(g){d(!0,"JSON returned from webapp was invalid, yet status code was 200. Data was: "+b.responseText)}f&&
d(!1,a)}else Pusher.warn("Couldn't get auth info from your webapp",status),d(!0,b.status)};b.send("socket_id="+encodeURIComponent(a.connection.socket_id)+"&channel_name="+encodeURIComponent(this.name))},jsonp:function(a,d){var b="socket_id="+encodeURIComponent(a.connection.socket_id)+"&channel_name="+encodeURIComponent(this.name),e=document.createElement("script");Pusher.auth_callbacks[this.name]=function(a){d(!1,a)};e.src=Pusher.channel_auth_endpoint+"?callback="+encodeURIComponent("Pusher.auth_callbacks['"+
this.name+"']")+"&"+b;b=document.getElementsByTagName("head")[0]||document.documentElement;b.insertBefore(e,b.firstChild)}};Pusher.Channel.PrivateChannel={authorize:function(a,d){Pusher.authorizers[Pusher.channel_auth_transport].scopedTo(this)(a,d)}};
Pusher.Channel.PresenceChannel={init:function(){this.bind("pusher_internal:member_added",function(a){this.emit("pusher:member_added",this.members.add(a.user_id,a.user_info))}.scopedTo(this));this.bind("pusher_internal:member_removed",function(a){(a=this.members.remove(a.user_id))&&this.emit("pusher:member_removed",a)}.scopedTo(this))},disconnect:function(){this.members.clear()},onSubscriptionSucceeded:function(a){this.members._members_map=a.presence.hash;this.members.count=a.presence.count;this.subscribed=
!0;this.emit("pusher:subscription_succeeded",this.members)},members:{_members_map:{},count:0,each:function(a){for(var d in this._members_map)a({id:d,info:this._members_map[d]})},add:function(a,d){this._members_map[a]=d;this.count++;return this.get(a)},remove:function(a){var d=this.get(a);d&&(delete this._members_map[a],this.count--);return d},get:function(a){return this._members_map.hasOwnProperty(a)?{id:a,info:this._members_map[a]}:null},clear:function(){this._members_map={};this.count=0}}};
Pusher.Channel.factory=function(a,d){var b=new Pusher.Channel(a,d);a.indexOf("private-")===0?Pusher.Util.extend(b,Pusher.Channel.PrivateChannel):a.indexOf("presence-")===0&&(Pusher.Util.extend(b,Pusher.Channel.PrivateChannel),Pusher.Util.extend(b,Pusher.Channel.PresenceChannel));b.init();return b};
var _require=function(){var a;a=document.addEventListener?function(a,b){a.addEventListener("load",b,!1)}:function(a,b){a.attachEvent("onreadystatechange",function(){(a.readyState=="loaded"||a.readyState=="complete")&&b()})};return function(d,b){function e(b,d){var d=d||function(){},e=document.getElementsByTagName("head")[0],h=document.createElement("script");h.setAttribute("src",b);h.setAttribute("type","text/javascript");h.setAttribute("async",!0);a(h,function(){var a=d;f++;g==f&&setTimeout(a,0)});
e.appendChild(h)}for(var f=0,g=d.length,h=0;h<g;h++)e(d[h],b)}}();
(function(){var a=(document.location.protocol=="http:"?Pusher.cdn_http:Pusher.cdn_https)+Pusher.VERSION,d=[];window.JSON===void 0&&d.push(a+"/json2"+Pusher.dependency_suffix+".js");if(window.WebSocket===void 0&&window.MozWebSocket===void 0)window.WEB_SOCKET_DISABLE_AUTO_INITIALIZATION=!0,d.push(a+"/flashfallback"+Pusher.dependency_suffix+".js");var b=function(){return window.WebSocket===void 0&&window.MozWebSocket===void 0?function(){window.WebSocket!==void 0&&window.MozWebSocket===void 0?(Pusher.Transport=
window.WebSocket,Pusher.TransportType="flash",window.WEB_SOCKET_SWF_LOCATION=a+"/WebSocketMain.swf",WebSocket.__addTask(function(){Pusher.ready()}),WebSocket.__initialize()):(Pusher.Transport=null,Pusher.TransportType="none",Pusher.ready())}:function(){Pusher.Transport=window.MozWebSocket!==void 0?window.MozWebSocket:window.WebSocket;Pusher.TransportType="native";Pusher.ready()}}(),e=function(a){var b=function(){document.body?a():setTimeout(b,0)};b()},f=function(){e(b)};d.length>0?_require(d,f):f()})();