diff --git a/js/key_worker.js b/js/key_worker.js
index e031a0c53..abff8c6d4 100644
--- a/js/key_worker.js
+++ b/js/key_worker.js
@@ -38415,91 +38415,89 @@ window.axolotl.sessions = {
  * You should have received a copy of the GNU Lesser General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-;(function(){
-    'use strict';
-
-    /*
-     * var socket = textsecure.websocket(url);
-     *
-     * Returns an adamantium-reinforced super socket, capable of sending
-     * app-level keep alives and automatically reconnecting.
-     *
-     */
-
-    window.textsecure.websocket = function (url) {
-        var keepAliveTimer;
-        var reconnectSemaphore = 0;
-        var reconnectTimeout = 1000;
-        var socket;
-        var socketWrapper = {
-            onmessage : function() {},
-            onclose   : function() {},
-            onerror   : function() {},
-            getStatus : function() { return socket.readyState; }
-        };
-        var error;
-
-        function resetKeepAliveTimer() {
-            clearTimeout(keepAliveTimer);
-            keepAliveTimer = setTimeout(function() {
-                if (socket.readyState === WebSocket.OPEN) {
-                    socket.send(
-                        new textsecure.protobuf.WebSocketMessage({
-                            type: textsecure.protobuf.WebSocketMessage.Type.REQUEST,
-                            request: { verb: 'GET', path: '/v1/keepalive' }
-                        }).encode().toArrayBuffer()
-                    );
-                }
 
-                resetKeepAliveTimer();
-            }, 55000);
-        };
+/*
+ * var socket = TextSecureWebSocket(url);
+ *
+ * Returns an adamantium-reinforced super socket, capable of sending
+ * app-level keep alives and automatically reconnecting.
+ *
+ */
 
-        function onclose(e) {
-            if (!error) {
-                reconnectSemaphore--;
-                setTimeout(connect, reconnectTimeout);
-            }
-            if (e !== 1000 ) { // CLOSE_NORMAL
-                console.log('websocket closed', e.code);
+TextSecureWebSocket = function (url) {
+    'use strict';
+    var keepAliveTimer;
+    var reconnectSemaphore = 0;
+    var reconnectTimeout = 1000;
+    var socket;
+    var socketWrapper = {
+        onmessage : function() {},
+        onclose   : function() {},
+        onerror   : function() {},
+        getStatus : function() { return socket.readyState; }
+    };
+    var error;
+
+    function resetKeepAliveTimer() {
+        clearTimeout(keepAliveTimer);
+        keepAliveTimer = setTimeout(function() {
+            if (socket.readyState === WebSocket.OPEN) {
+                socket.send(
+                    new textsecure.protobuf.WebSocketMessage({
+                        type: textsecure.protobuf.WebSocketMessage.Type.REQUEST,
+                        request: { verb: 'GET', path: '/v1/keepalive' }
+                    }).encode().toArrayBuffer()
+                );
             }
-            socketWrapper.onclose(e);
-        };
-
-        function onerror(e) {
-            error = e;
-            console.log('websocket error');
-            socketWrapper.onerror(e);
-        };
 
-        function onmessage(response) {
-            socketWrapper.onmessage(response);
             resetKeepAliveTimer();
-        };
+        }, 55000);
+    };
 
-        function send(msg) {
-            resetKeepAliveTimer();
-            socket.send(msg);
-        };
+    function onclose(e) {
+        if (!error) {
+            reconnectSemaphore--;
+            setTimeout(connect, reconnectTimeout);
+        }
+        if (e !== 1000 ) { // CLOSE_NORMAL
+            console.log('websocket closed', e.code);
+        }
+        socketWrapper.onclose(e);
+    };
 
-        function connect() {
-            clearTimeout(keepAliveTimer);
-            if (++reconnectSemaphore <= 0) { return; }
+    function onerror(e) {
+        error = e;
+        console.log('websocket error');
+        socketWrapper.onerror(e);
+    };
 
-            if (socket) { socket.close(); }
-            socket = new WebSocket(url);
+    function onmessage(response) {
+        socketWrapper.onmessage(response);
+        resetKeepAliveTimer();
+    };
 
-            socket.onopen      = resetKeepAliveTimer;
-            socket.onerror     = onerror
-            socket.onclose     = onclose;
-            socket.onmessage   = onmessage;
-            socketWrapper.send = send;
-        };
+    function send(msg) {
+        resetKeepAliveTimer();
+        socket.send(msg);
+    };
+
+    function connect() {
+        clearTimeout(keepAliveTimer);
+        if (++reconnectSemaphore <= 0) { return; }
 
-        connect();
-        return socketWrapper;
+        if (socket) { socket.close(); }
+        socket = new WebSocket(url);
+
+        socket.onopen      = resetKeepAliveTimer;
+        socket.onerror     = onerror
+        socket.onclose     = onclose;
+        socket.onmessage   = onmessage;
+        socketWrapper.send = send;
     };
-})();
+
+    connect();
+    return socketWrapper;
+};
 
 /* vim: ts=4:sw=4:expandtab
  *
@@ -39361,7 +39359,7 @@ window.textsecure.api = function () {
             var password = textsecure.storage.get("password");
             var params = 'login=%2B' + encodeURIComponent(user.substring(1)) + '&password=' + encodeURIComponent(password);
         }
-        return window.textsecure.websocket(URL+params)
+        return TextSecureWebSocket(URL+params)
     }
 
     self.getMessageWebsocket = function() {
diff --git a/js/libtextsecure.js b/js/libtextsecure.js
index ded9ce91f..bf818e33b 100644
--- a/js/libtextsecure.js
+++ b/js/libtextsecure.js
@@ -38414,91 +38414,89 @@ window.axolotl.sessions = {
  * You should have received a copy of the GNU Lesser General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-;(function(){
-    'use strict';
-
-    /*
-     * var socket = textsecure.websocket(url);
-     *
-     * Returns an adamantium-reinforced super socket, capable of sending
-     * app-level keep alives and automatically reconnecting.
-     *
-     */
-
-    window.textsecure.websocket = function (url) {
-        var keepAliveTimer;
-        var reconnectSemaphore = 0;
-        var reconnectTimeout = 1000;
-        var socket;
-        var socketWrapper = {
-            onmessage : function() {},
-            onclose   : function() {},
-            onerror   : function() {},
-            getStatus : function() { return socket.readyState; }
-        };
-        var error;
-
-        function resetKeepAliveTimer() {
-            clearTimeout(keepAliveTimer);
-            keepAliveTimer = setTimeout(function() {
-                if (socket.readyState === WebSocket.OPEN) {
-                    socket.send(
-                        new textsecure.protobuf.WebSocketMessage({
-                            type: textsecure.protobuf.WebSocketMessage.Type.REQUEST,
-                            request: { verb: 'GET', path: '/v1/keepalive' }
-                        }).encode().toArrayBuffer()
-                    );
-                }
 
-                resetKeepAliveTimer();
-            }, 55000);
-        };
+/*
+ * var socket = TextSecureWebSocket(url);
+ *
+ * Returns an adamantium-reinforced super socket, capable of sending
+ * app-level keep alives and automatically reconnecting.
+ *
+ */
 
-        function onclose(e) {
-            if (!error) {
-                reconnectSemaphore--;
-                setTimeout(connect, reconnectTimeout);
-            }
-            if (e !== 1000 ) { // CLOSE_NORMAL
-                console.log('websocket closed', e.code);
+TextSecureWebSocket = function (url) {
+    'use strict';
+    var keepAliveTimer;
+    var reconnectSemaphore = 0;
+    var reconnectTimeout = 1000;
+    var socket;
+    var socketWrapper = {
+        onmessage : function() {},
+        onclose   : function() {},
+        onerror   : function() {},
+        getStatus : function() { return socket.readyState; }
+    };
+    var error;
+
+    function resetKeepAliveTimer() {
+        clearTimeout(keepAliveTimer);
+        keepAliveTimer = setTimeout(function() {
+            if (socket.readyState === WebSocket.OPEN) {
+                socket.send(
+                    new textsecure.protobuf.WebSocketMessage({
+                        type: textsecure.protobuf.WebSocketMessage.Type.REQUEST,
+                        request: { verb: 'GET', path: '/v1/keepalive' }
+                    }).encode().toArrayBuffer()
+                );
             }
-            socketWrapper.onclose(e);
-        };
-
-        function onerror(e) {
-            error = e;
-            console.log('websocket error');
-            socketWrapper.onerror(e);
-        };
 
-        function onmessage(response) {
-            socketWrapper.onmessage(response);
             resetKeepAliveTimer();
-        };
+        }, 55000);
+    };
 
-        function send(msg) {
-            resetKeepAliveTimer();
-            socket.send(msg);
-        };
+    function onclose(e) {
+        if (!error) {
+            reconnectSemaphore--;
+            setTimeout(connect, reconnectTimeout);
+        }
+        if (e !== 1000 ) { // CLOSE_NORMAL
+            console.log('websocket closed', e.code);
+        }
+        socketWrapper.onclose(e);
+    };
 
-        function connect() {
-            clearTimeout(keepAliveTimer);
-            if (++reconnectSemaphore <= 0) { return; }
+    function onerror(e) {
+        error = e;
+        console.log('websocket error');
+        socketWrapper.onerror(e);
+    };
 
-            if (socket) { socket.close(); }
-            socket = new WebSocket(url);
+    function onmessage(response) {
+        socketWrapper.onmessage(response);
+        resetKeepAliveTimer();
+    };
 
-            socket.onopen      = resetKeepAliveTimer;
-            socket.onerror     = onerror
-            socket.onclose     = onclose;
-            socket.onmessage   = onmessage;
-            socketWrapper.send = send;
-        };
+    function send(msg) {
+        resetKeepAliveTimer();
+        socket.send(msg);
+    };
+
+    function connect() {
+        clearTimeout(keepAliveTimer);
+        if (++reconnectSemaphore <= 0) { return; }
 
-        connect();
-        return socketWrapper;
+        if (socket) { socket.close(); }
+        socket = new WebSocket(url);
+
+        socket.onopen      = resetKeepAliveTimer;
+        socket.onerror     = onerror
+        socket.onclose     = onclose;
+        socket.onmessage   = onmessage;
+        socketWrapper.send = send;
     };
-})();
+
+    connect();
+    return socketWrapper;
+};
 
 /* vim: ts=4:sw=4:expandtab
  *
@@ -39360,7 +39358,7 @@ window.textsecure.api = function () {
             var password = textsecure.storage.get("password");
             var params = 'login=%2B' + encodeURIComponent(user.substring(1)) + '&password=' + encodeURIComponent(password);
         }
-        return window.textsecure.websocket(URL+params)
+        return TextSecureWebSocket(URL+params)
     }
 
     self.getMessageWebsocket = function() {
diff --git a/libtextsecure/api.js b/libtextsecure/api.js
index 9584b785b..1487367d8 100644
--- a/libtextsecure/api.js
+++ b/libtextsecure/api.js
@@ -333,7 +333,7 @@ window.textsecure.api = function () {
             var password = textsecure.storage.get("password");
             var params = 'login=%2B' + encodeURIComponent(user.substring(1)) + '&password=' + encodeURIComponent(password);
         }
-        return window.textsecure.websocket(URL+params)
+        return TextSecureWebSocket(URL+params)
     }
 
     self.getMessageWebsocket = function() {
diff --git a/libtextsecure/websocket.js b/libtextsecure/websocket.js
index df134e9e1..c7421d064 100644
--- a/libtextsecure/websocket.js
+++ b/libtextsecure/websocket.js
@@ -13,88 +13,86 @@
  * You should have received a copy of the GNU Lesser General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-;(function(){
-    'use strict';
-
-    /*
-     * var socket = textsecure.websocket(url);
-     *
-     * Returns an adamantium-reinforced super socket, capable of sending
-     * app-level keep alives and automatically reconnecting.
-     *
-     */
-
-    window.textsecure.websocket = function (url) {
-        var keepAliveTimer;
-        var reconnectSemaphore = 0;
-        var reconnectTimeout = 1000;
-        var socket;
-        var socketWrapper = {
-            onmessage : function() {},
-            onclose   : function() {},
-            onerror   : function() {},
-            getStatus : function() { return socket.readyState; }
-        };
-        var error;
 
-        function resetKeepAliveTimer() {
-            clearTimeout(keepAliveTimer);
-            keepAliveTimer = setTimeout(function() {
-                if (socket.readyState === WebSocket.OPEN) {
-                    socket.send(
-                        new textsecure.protobuf.WebSocketMessage({
-                            type: textsecure.protobuf.WebSocketMessage.Type.REQUEST,
-                            request: { verb: 'GET', path: '/v1/keepalive' }
-                        }).encode().toArrayBuffer()
-                    );
-                }
+/*
+ * var socket = TextSecureWebSocket(url);
+ *
+ * Returns an adamantium-reinforced super socket, capable of sending
+ * app-level keep alives and automatically reconnecting.
+ *
+ */
 
-                resetKeepAliveTimer();
-            }, 55000);
-        };
+TextSecureWebSocket = function (url) {
+    'use strict';
+    var keepAliveTimer;
+    var reconnectSemaphore = 0;
+    var reconnectTimeout = 1000;
+    var socket;
+    var socketWrapper = {
+        onmessage : function() {},
+        onclose   : function() {},
+        onerror   : function() {},
+        getStatus : function() { return socket.readyState; }
+    };
+    var error;
 
-        function onclose(e) {
-            if (!error) {
-                reconnectSemaphore--;
-                setTimeout(connect, reconnectTimeout);
+    function resetKeepAliveTimer() {
+        clearTimeout(keepAliveTimer);
+        keepAliveTimer = setTimeout(function() {
+            if (socket.readyState === WebSocket.OPEN) {
+                socket.send(
+                    new textsecure.protobuf.WebSocketMessage({
+                        type: textsecure.protobuf.WebSocketMessage.Type.REQUEST,
+                        request: { verb: 'GET', path: '/v1/keepalive' }
+                    }).encode().toArrayBuffer()
+                );
             }
-            if (e !== 1000 ) { // CLOSE_NORMAL
-                console.log('websocket closed', e.code);
-            }
-            socketWrapper.onclose(e);
-        };
-
-        function onerror(e) {
-            error = e;
-            console.log('websocket error');
-            socketWrapper.onerror(e);
-        };
 
-        function onmessage(response) {
-            socketWrapper.onmessage(response);
             resetKeepAliveTimer();
-        };
+        }, 55000);
+    };
 
-        function send(msg) {
-            resetKeepAliveTimer();
-            socket.send(msg);
-        };
+    function onclose(e) {
+        if (!error) {
+            reconnectSemaphore--;
+            setTimeout(connect, reconnectTimeout);
+        }
+        if (e !== 1000 ) { // CLOSE_NORMAL
+            console.log('websocket closed', e.code);
+        }
+        socketWrapper.onclose(e);
+    };
 
-        function connect() {
-            clearTimeout(keepAliveTimer);
-            if (++reconnectSemaphore <= 0) { return; }
+    function onerror(e) {
+        error = e;
+        console.log('websocket error');
+        socketWrapper.onerror(e);
+    };
 
-            if (socket) { socket.close(); }
-            socket = new WebSocket(url);
+    function onmessage(response) {
+        socketWrapper.onmessage(response);
+        resetKeepAliveTimer();
+    };
 
-            socket.onopen      = resetKeepAliveTimer;
-            socket.onerror     = onerror
-            socket.onclose     = onclose;
-            socket.onmessage   = onmessage;
-            socketWrapper.send = send;
-        };
+    function send(msg) {
+        resetKeepAliveTimer();
+        socket.send(msg);
+    };
+
+    function connect() {
+        clearTimeout(keepAliveTimer);
+        if (++reconnectSemaphore <= 0) { return; }
 
-        connect();
-        return socketWrapper;
+        if (socket) { socket.close(); }
+        socket = new WebSocket(url);
+
+        socket.onopen      = resetKeepAliveTimer;
+        socket.onerror     = onerror
+        socket.onclose     = onclose;
+        socket.onmessage   = onmessage;
+        socketWrapper.send = send;
     };
-})();
+
+    connect();
+    return socketWrapper;
+};