From 1216ea99d374f034d3de62e095673ed0f119b099 Mon Sep 17 00:00:00 2001
From: Emanuel Schuetze <emanuel@intevation.de>
Date: Fri, 29 Jan 2016 16:28:17 +0100
Subject: [PATCH] Refactor reconnect function of autoupdate.

---
 openslides/core/static/js/core/base.js | 47 +++++++++++++-------------
 1 file changed, 24 insertions(+), 23 deletions(-)

diff --git a/openslides/core/static/js/core/base.js b/openslides/core/static/js/core/base.js
index b1328dc6c..7b32c531c 100644
--- a/openslides/core/static/js/core/base.js
+++ b/openslides/core/static/js/core/base.js
@@ -39,40 +39,41 @@ angular.module('OpenSlidesApp.core', [
     'DS',
     '$rootScope',
     function (DS, $rootScope) {
-        var url = location.origin + "/sockjs";
-        var socket;
-        var Autoupdate = {
-            socket: null,
-            message_receivers: [],
-            connect: function () {
-                var autoupdate = this;
-                socket = this.socket = new SockJS(url);
+        var socket = null;
+        var recInterval = null;
+        $rootScope.connected = true;
 
-                this.socket.onmessage = function (event) {
-                    _.forEach(autoupdate.message_receivers, function (receiver) {
+        var newConnect = function () {
+            socket = new SockJS(location.origin + "/sockjs");
+            clearInterval(recInterval);
+            socket.onopen = function () {
+                $rootScope.connected = true;
+            };
+            socket.onclose = function () {
+                $rootScope.connected = false;
+                socket = null;
+                recInterval = setInterval(function () {
+                    newConnect();
+                }, 1000);
+            };
+        };
+        var Autoupdate = {
+            messageReceivers: [],
+            connect: function () {
+                socket.onmessage = function (event) {
+                    _.forEach(Autoupdate.messageReceivers, function (receiver) {
                         receiver(event.data);
                     });
                 };
-
-                this.socket.onopen = function () {
-                    $rootScope.connected = true;
-                };
-
-                this.socket.onclose = function () {
-                    $rootScope.connected = false;
-                    autoupdate.connect()
-
-                };
             },
             on_message: function (receiver) {
-                this.message_receivers.push(receiver);
+                this.messageReceivers.push(receiver);
             },
             reconnect: function () {
                 socket.close();
-                Autoupdate.connect();
             }
         };
-        $rootScope.connected = false;
+        newConnect();
         Autoupdate.connect();
         return Autoupdate;
     }