-
-
Save jnstq/525333 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/* Ismael Celis 2010 | |
Simplified WebSocket events dispatcher (no channels, no users) | |
var socket = new ServerEventsDispatcher(); | |
// bind to server events | |
socket.bind('some_event', function(data){ | |
alert(data.name + ' says: ' + data.message) | |
}); | |
// broadcast events to all connected users | |
socket.trigger( 'some_event', {name: 'ismael', message : 'Hello world'} ); | |
*/ | |
var ServerEventsDispatcher = function(url){ | |
var conn = new WebSocket(url); | |
var callbacks = {}; | |
this.bind = function(event_name, callback){ | |
callbacks[event_name] = callbacks[event_name] || []; | |
callbacks[event_name].push(callback); | |
return this;// chainable | |
}; | |
this.send = function(event_name, event_data){ | |
var payload = JSON.stringify({event:event_name, data: event_data}); | |
conn.send( payload ); // <= send JSON data to socket server | |
return this; | |
}; | |
// dispatch to the right handlers | |
conn.onmessage = function(evt){ | |
var json = JSON.parse(evt.data) | |
dispatch(json.event, json.data) | |
}; | |
conn.onclose = function(){dispatch('close',null)} | |
conn.onopen = function(){dispatch('open',null)} | |
var dispatch = function(event_name, message){ | |
var chain = callbacks[event_name]; | |
if(typeof chain == 'undefined') return; // no callbacks for this event | |
for(var i = 0; i < chain.length; i++){ | |
chain[i]( message ) | |
} | |
} | |
}; |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment