@@ -22,86 +22,86 @@ WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ function Juggernaut(options) { - this.is_connected = false; - this.attempting_to_reconnect = false; - this.ever_been_connected = false; - this.hasLogger = "console" in window && "log" in window.console; - this.options = options; - this.bindToWindow(); - }; + this.is_connected = false; + this.attempting_to_reconnect = false; + this.ever_been_connected = false; + this.hasLogger = "console" in window && "log" in window.console; + this.options = options; + this.bindToWindow(); +}; Juggernaut.fn = Juggernaut.prototype; Juggernaut.fn.logger = function(msg) { - if (this.options.debug) { - msg = "Juggernaut: " + msg + " on " + this.options.host + ':' + this.options.port; - this.hasLogger ? console.log(msg) : alert(msg); - } - }; + if (this.options.debug) { + msg = "Juggernaut: " + msg + " on " + this.options.host + ':' + this.options.port; + this.hasLogger ? console.log(msg) : alert(msg); + } +}; Juggernaut.fn.initialized = function(){ - this.fire_event('initialized'); - this.connect(); - }; + this.fire_event('initialized'); + this.connect(); +}; Juggernaut.fn.broadcast = function(body, type, client_ids, channels){ - var msg = {command: 'broadcast', body: body, type: (type||'to_channels')}; - if(channels) msg['channels'] = channels; - if(client_ids) msg['client_ids'] = client_ids; - this.sendData(Juggernaut.toJSON(msg)); - }; + var msg = {command: 'broadcast', body: body, type: (type||'to_channels')}; + if(channels) msg['channels'] = channels; + if(client_ids) msg['client_ids'] = client_ids; + this.sendData(Juggernaut.toJSON(msg)); +}; Juggernaut.fn.sendData = function(data){ - this.swf().sendData(escape(data)); - }; - + this.swf().sendData(escape(data)); +}; + Juggernaut.fn.connect = function(){ - if(!this.is_connected){ - this.fire_event('connect'); - this.swf().connect(this.options.host, this.options.port); - } - }; + if(!this.is_connected){ + this.fire_event('connect'); + this.swf().connect(this.options.host, this.options.port); + } +}; Juggernaut.fn.disconnect = function(){ - if(this.is_connected) { - this.swf().disconnect(); - this.is_connected = false; - } - }; + if(this.is_connected) { + this.swf().disconnect(); + this.is_connected = false; + } +}; Juggernaut.fn.handshake = function() { - var handshake = {}; - handshake['command'] = 'subscribe'; - if(this.options.session_id) handshake['session_id'] = this.options.session_id; - if(this.options.client_id) handshake['client_id'] = this.options.client_id; - if(this.options.channels) handshake['channels'] = this.options.channels; - if(this.currentMsgId) { - handshake['last_msg_id'] = this.currentMsgId; - handshake['signature'] = this.currentSignature; - } - - return handshake; - }; + var handshake = {}; + handshake['command'] = 'subscribe'; + if(this.options.session_id) handshake['session_id'] = this.options.session_id; + if(this.options.client_id) handshake['client_id'] = this.options.client_id; + if(this.options.channels) handshake['channels'] = this.options.channels; + if(this.currentMsgId) { + handshake['last_msg_id'] = this.currentMsgId; + handshake['signature'] = this.currentSignature; + } + + return handshake; +}; Juggernaut.fn.connected = function(e) { - var json = Juggernaut.toJSON(this.handshake()); - this.sendData(json); - this.ever_been_connected = true; - this.is_connected = true; - var self = this; - setTimeout(function(){ - if(self.is_connected) self.attempting_to_reconnect = false; - }, 1 * 1000); - this.logger('Connected'); - this.fire_event('connected'); - }; + var json = Juggernaut.toJSON(this.handshake()); + this.sendData(json); + this.ever_been_connected = true; + this.is_connected = true; + var self = this; + setTimeout(function(){ + if(self.is_connected) self.attempting_to_reconnect = false; + }, 1 * 1000); + this.logger('Connected'); + this.fire_event('connected'); +}; Juggernaut.fn.receiveData = function(e) { - var msg = Juggernaut.parseJSON(unescape(e.toString())); - this.currentMsgId = msg.id; - this.currentSignature = msg.signature; - this.logger("Received data:\n" + msg.body + "\n"); - this.dispatchMessage(msg); + var msg = Juggernaut.parseJSON(unescape(e.toString())); + this.currentMsgId = msg.id; + this.currentSignature = msg.signature; + this.logger("Received data:\n" + msg.body + "\n"); + this.dispatchMessage(msg); }; Juggernaut.fn.dispatchMessage = function(msg) { @@ -112,95 +112,93 @@ var juggernaut; // Prototype specific - override for other frameworks Juggernaut.fn.fire_event = function(fx_name) { - $(document).fire("juggernaut:" + fx_name); - }; + $(document).fire("juggernaut:" + fx_name); +}; Juggernaut.fn.bindToWindow = function() { - - Event.observe(window, 'load', function() { - juggernaut = this; - this.appendFlashObject(); - }.bind(this)); - - }; + Event.observe(window, 'load', function() { + juggernaut = this; + this.appendFlashObject(); + }.bind(this)); +}; Juggernaut.toJSON = function(hash) { - return Object.toJSON(hash); - }; + return Object.toJSON(hash); +}; Juggernaut.parseJSON = function(string) { - return string.evalJSON(); - }; + return string.evalJSON(); +}; Juggernaut.fn.swf = function(){ - return $(this.options.swf_name); - }; + return $(this.options.swf_name); +}; Juggernaut.fn.appendElement = function() { - this.element = new Element('div', { id: 'juggernaut' }); - $(document.body).insert({ bottom: this.element }); - }; + this.element = new Element('div', { id: 'juggernaut' }); + $(document.body).insert({ bottom: this.element }); +}; /*** END PROTOTYPE SPECIFIC ***/ Juggernaut.fn.appendFlashObject = function(){ - if(this.swf()) { - throw("Juggernaut error. 'swf_name' must be unique per juggernaut instance."); - } - Juggernaut.fn.appendElement(); - swfobject.embedSWF( - this.options.swf_address, - 'juggernaut', - this.options.width, - this.options.height, - String(this.options.flash_version), - this.options.ei_swf_address, - {'bridgeName': this.options.bridge_name}, - {}, - {'id': this.options.swf_name, 'name': this.options.swf_name} - ); - }; + if(this.swf()) { + throw("Juggernaut error. 'swf_name' must be unique per juggernaut instance."); + } + Juggernaut.fn.appendElement(); + swfobject.embedSWF( + this.options.swf_address, + 'juggernaut', + this.options.width, + this.options.height, + String(this.options.flash_version), + this.options.ei_swf_address, + {'bridgeName': this.options.bridge_name}, + {}, + {'id': this.options.swf_name, 'name': this.options.swf_name} + ); +}; Juggernaut.fn.refreshFlashObject = function(){ - this.swf().remove(); - this.appendFlashObject(); - }; + this.swf().remove(); + this.appendFlashObject(); +}; Juggernaut.fn.errorConnecting = function(e) { - this.is_connected = false; - if(!this.attempting_to_reconnect) { - this.logger('There has been an error connecting'); - this.fire_event('errorConnecting'); - this.reconnect(); - } - }; + this.is_connected = false; + if(!this.attempting_to_reconnect) { + this.logger('There has been an error connecting'); + this.fire_event('errorConnecting'); + this.reconnect(); + } +}; Juggernaut.fn.disconnected = function(e) { - this.is_connected = false; - if(!this.attempting_to_reconnect) { - this.logger('Connection has been lost'); - this.fire_event('disconnected'); - this.reconnect(); - } - }; + this.is_connected = false; + if(!this.attempting_to_reconnect) { + this.logger('Connection has been lost'); + this.fire_event('disconnected'); + this.reconnect(); + } +}; Juggernaut.fn.reconnect = function(){ - if(this.options.reconnect_attempts){ - this.attempting_to_reconnect = true; - this.fire_event('reconnect'); - this.logger('Will attempt to reconnect ' + this.options.reconnect_attempts + ' times,\ + if(this.options.reconnect_attempts){ + this.attempting_to_reconnect = true; + this.fire_event('reconnect'); + this.logger('Will attempt to reconnect ' + this.options.reconnect_attempts + ' times,\ the first in ' + (this.options.reconnect_intervals || 3) + ' seconds'); - for(var i=0; i < this.options.reconnect_attempts; i++){ - setTimeout(function(){ - if(!this.is_connected){ - this.logger('Attempting reconnect'); - if(!this.ever_been_connected){ - this.refreshFlashObject(); - } else { - this.connect(); - } + for(var i=0; i < this.options.reconnect_attempts; i++){ + setTimeout(function(){ + if(!this.is_connected){ + this.logger('Attempting reconnect'); + if(!this.ever_been_connected){ + this.refreshFlashObject(); + } else { + this.connect(); } - }.bind(this), (this.options.reconnect_intervals || 3) * 1000 * (i + 1)); - } + } + }.bind(this), (this.options.reconnect_intervals || 3) * 1000 * (i + 1)); } - }; \ No newline at end of file + } +}; \ No newline at end of file media/juggernaut.js 46fa84c90081ffe14879190fde7e1a90b69d8098 Alex MacCaw maccman@gmail.com http://github.com/maccman/juggernaut_plugin/commit/147eeddfda33cf9feb760de74ad738a8536eaa18 147eeddfda33cf9feb760de74ad738a8536eaa18 2009-08-03T09:05:54-07:00 2009-08-03T09:05:54-07:00 format js properly 84b6d472893ccae43185f92f13c3c8d6ede77d4d Alex MacCaw maccman@gmail.com