Merge pull request #1907 from ostcar/fix_reconnect

Reconnect at once. Do not wait 5 seconds. Add a connected flag to the…
This commit is contained in:
Norman Jäckel 2016-01-27 20:07:46 +01:00
commit 5044aaf7ed

View File

@ -36,7 +36,8 @@ angular.module('OpenSlidesApp.core', [
.factory('autoupdate', [ .factory('autoupdate', [
'DS', 'DS',
function (DS) { '$rootScope',
function (DS, $rootScope) {
var url = location.origin + "/sockjs"; var url = location.origin + "/sockjs";
var socket; var socket;
var Autoupdate = { var Autoupdate = {
@ -46,15 +47,20 @@ angular.module('OpenSlidesApp.core', [
var autoupdate = this; var autoupdate = this;
socket = this.socket = new SockJS(url); socket = this.socket = new SockJS(url);
this.socket.onmessage = function (event) { this.socket.onmessage = function (event) {
_.forEach(autoupdate.message_receivers, function (receiver) { _.forEach(autoupdate.message_receivers, function (receiver) {
receiver(event.data); receiver(event.data);
}); });
}; };
this.socket.onopen = function () {
$rootScope.connected = true;
};
this.socket.onclose = function () { this.socket.onclose = function () {
setTimeout(autoupdate.connect, 5000); $rootScope.connected = false;
autoupdate.connect()
}; };
}, },
on_message: function (receiver) { on_message: function (receiver) {
@ -65,6 +71,7 @@ angular.module('OpenSlidesApp.core', [
Autoupdate.connect(); Autoupdate.connect();
} }
}; };
$rootScope.connected = false;
Autoupdate.connect(); Autoupdate.connect();
return Autoupdate; return Autoupdate;
} }