1 files changed, 19 insertions, 33 deletions
diff --git a/web/src/js/connection.js b/web/src/js/connection.js
index d511270d..6ca353b3 100644
--- a/web/src/js/connection.js
+++ b/web/src/js/connection.js
@@ -1,38 +1,24 @@
 function Connection(url) {
-    if (url[0] != "/") {
-        this.url = url;
-    } else {
-        this.url = location.origin.replace("http", "ws") + url;
+
+    if (url[0] === "/") {
+        url = location.origin.replace("http", "ws") + url;
     }
-    var ws = new WebSocket(this.url);
+
+    var ws = new WebSocket(url);
     ws.onopen = function () {
-        this.onopen.apply(this, arguments);
-    }.bind(this);
-    ws.onmessage = function () {
-        this.onmessage.apply(this, arguments);
-    }.bind(this);
+        ConnectionActions.open();
+    };
+    ws.onmessage = function (message) {
+        var m = JSON.parse(message.data);
+        AppDispatcher.dispatchServerAction(m);
+    };
     ws.onerror = function () {
-        this.onerror.apply(this, arguments);
-    }.bind(this);
+        ConnectionActions.error();
+        EventLogActions.add_event("WebSocket connection error.");
+    };
     ws.onclose = function () {
-        this.onclose.apply(this, arguments);
-    }.bind(this);
-    this.ws = ws;
-}
-Connection.prototype.onopen = function (open) {
-    console.debug("onopen", this, arguments);
-};
-Connection.prototype.onmessage = function (message) {
-    console.warn("onmessage (not implemented)", this, message.data);
-};
-Connection.prototype.onerror = function (error) {
-    EventLogActions.add_event("WebSocket Connection Error.");
-    console.debug("onerror", this, arguments);
-};
-Connection.prototype.onclose = function (close) {
-    EventLogActions.add_event("WebSocket Connection closed.");
-    console.debug("onclose", this, arguments);
-};
-Connection.prototype.close = function () {
-    this.ws.close();
-};
-\ No newline at end of file
+        ConnectionActions.close();
+        EventLogActions.add_event("WebSocket connection closed.");
+    };
+    return ws;
+}
+\ No newline at end of file