54 lines
1.2 KiB
JavaScript
54 lines
1.2 KiB
JavaScript
/* exported WebSocketChannel */
|
|
|
|
function WebSocketChannel(){
|
|
this.wsUrl = window.location.protocol.replace("http", "ws") +
|
|
"//" + window.location.host +
|
|
window.location.pathname.substring(0, window.location.pathname.lastIndexOf("/")) +
|
|
"/api/ws";
|
|
|
|
this.listenerMap = {/* type -> [listeners] */};
|
|
}
|
|
|
|
WebSocketChannel.prototype.addListener = function(type, listener){
|
|
var list = this.listenerMap[type];
|
|
if (!list){
|
|
list = [];
|
|
this.listenerMap[type] = list;
|
|
}
|
|
|
|
list.push(listener);
|
|
};
|
|
|
|
WebSocketChannel.prototype.removeListener = function(type, listener){
|
|
var list = this.listenerMap[type];
|
|
if (!list){
|
|
return;
|
|
}
|
|
|
|
this.listenerMap[type] = list.filter(function(l){
|
|
return l != listener;
|
|
});
|
|
};
|
|
|
|
WebSocketChannel.prototype.connect = function(){
|
|
var ws = new WebSocket(this.wsUrl);
|
|
var self = this;
|
|
|
|
ws.onmessage = function(e){
|
|
var event = JSON.parse(e.data);
|
|
//rendered-tile, mapobject-created, mapobjects-cleared
|
|
|
|
var listeners = self.listenerMap[event.type];
|
|
if (listeners){
|
|
listeners.forEach(function(listener){
|
|
listener(event.data);
|
|
});
|
|
}
|
|
};
|
|
|
|
ws.onerror = function(){
|
|
//reconnect after some time
|
|
setTimeout(self.connect.bind(self), 1000);
|
|
};
|
|
};
|