Sha256: 2dd5530a6601165cbfb2806a3b5fa353e0d907bed39dadf3eea62f7a32ab5726
Contents?: true
Size: 1.58 KB
Versions: 7
Compression:
Stored size: 1.58 KB
Contents
var WebSocketIO = function(){
new EventEmitter().apply(this);
this.url = "<%= websocketio_url %>";
this.session = null;
this.websocket = null;
this.connecting = false;
var reconnect_timer_id = null;
var running = false;
var self = this;
self.on("__session_id", function(session_id){
self.session = session_id;
self.emit("connect", self.session);
});
this.connect = function(){
if(typeof WebSocket === "undefined"){
self.emit("error", "websocket not exists in this browser");
return null;
}
self.running = true;
var url = self.session ? self.url+"/session="+self.session : self.url;
self.websocket = new WebSocket(url);
self.websocket.onmessage = function(e){
try{
var data_ = JSON.parse(e.data);
self.emit(data_.type, data_.data);
}
catch(e){
self.emit("error", "WebSocketIO data parse error");
}
};
self.websocket.onclose = function(){
if(self.connecting){
self.connecting = false;
self.emit("disconnect");
}
if(self.running){
reconnect_timer_id = setTimeout(self.connect, 10000);
}
};
self.websocket.onopen = function(){
self.connecting = true;
};
return self;
};
this.close = function(){
clearTimeout(reconnect_timer_id);
self.running = false;
self.websocket.close();
};
this.push = function(type, data){
if(!self.connecting){
self.emit("error", "websocket not connected");
return;
}
self.websocket.send(JSON.stringify({type: type, data: data, session: self.session}));
};
};
Version data entries
7 entries across 7 versions & 1 rubygems