Add support for login & logout while keeping the same shared worker

www/common/cryptpad-common.js

@@ -932,9 +932,12 @@ define([
                     document.location.reload();
                 } else if (o && !n) {
                     LocalStore.logout();
-                    postMessage("DISCONNECT");
                 }
             });
+            LocalStore.onLogout(function () {
+                console.log('onLogout: disconnect');
+                postMessage("DISCONNECT");
+            });
 
             if (PINNING_ENABLED && LocalStore.isLoggedIn()) {
                 console.log("logged in. pads will be pinned");

www/common/outer/async-store.js

@@ -23,6 +23,7 @@ define([
              Crypto, ChainPad, Listmap, nThen, Saferphore) {
     var Store = {};
 
+    var create = function () {
         var postMessage = function () {};
         var broadcast = function () {};
         var sendDriveEvent = function () {};
@@ -1454,4 +1455,9 @@ define([
             store.network.disconnect();
         };
         return Store;
+    };
+
+    return {
+        create: create
+    };
 });

www/common/outer/serviceworker.js

@@ -27,10 +27,15 @@ var init = function (client, cb) {
             '/common/common-util.js',
             '/common/outer/worker-channel.js',
             '/common/outer/store-rpc.js'
-        ], function (Util, Channel, Rpc) {
+        ], function (Util, Channel, SRpc) {
             debug('SW Required ressources loaded');
             var msgEv = Util.mkEvent();
 
+            if (!self.Rpc) {
+                self.Rpc = SRpc();
+            }
+            var Rpc = self.Rpc;
+
             var postToClient = function (data) {
                 postMsg(client, data);
             };
@@ -51,11 +56,17 @@ var init = function (client, cb) {
                             console.error(e);
                             console.log(data);
                         }
+                        if (q === "DISCONNECT") {
+                            console.log('Deleting existing store!');
+                            delete self.Rpc;
+                            delete self.store;
+                        }
                     });
                 });
                 chan.on('CONNECT', function (cfg, cb) {
                     debug('SW Connect callback');
                     if (self.store) {
+                        debug('Store already exists!');
                         if (cfg.driveEvents) {
                             Rpc._subscribeToDrive(clientId);
                         }

www/common/outer/sharedworker.js

@@ -27,10 +27,15 @@ var init = function (client, cb) {
             '/common/common-util.js',
             '/common/outer/worker-channel.js',
             '/common/outer/store-rpc.js'
-        ], function (Util, Channel, Rpc) {
+        ], function (Util, Channel, SRpc) {
             debug('SharedW Required ressources loaded');
             var msgEv = Util.mkEvent();
 
+            if (!self.Rpc) {
+                self.Rpc = SRpc();
+            }
+            var Rpc = self.Rpc;
+
             var postToClient = function (data) {
                 postMsg(client, data);
             };
@@ -51,6 +56,11 @@ var init = function (client, cb) {
                             console.error(e);
                             console.log(data);
                         }
+                        if (q === "DISCONNECT") {
+                            console.log('Deleting existing store!');
+                            delete self.Rpc;
+                            delete self.store;
+                        }
                     });
                 });
                 chan.on('CONNECT', function (cfg, cb) {

www/common/outer/store-rpc.js

@@ -1,6 +1,10 @@
 define([
     '/common/outer/async-store.js'
-], function (Store) {
+], function (AStore) {
+
+    var create = function () {
+        var Store = AStore.create();
+
         var Rpc = {};
 
         var queries = Rpc.queries = {
@@ -85,5 +89,8 @@ define([
         Rpc._subscribeToMessenger = Store._subscribeToMessenger;
 
         return Rpc;
+    };
+
+    return create;
 });
 

www/common/outer/webworker.js

@@ -15,9 +15,11 @@ require([
         '/common/common-util.js',
         '/common/outer/worker-channel.js',
         '/common/outer/store-rpc.js'
-    ], function (Util, Channel, Rpc) {
+    ], function (Util, Channel, SRpc) {
         var msgEv = Util.mkEvent();
 
+        var Rpc = SRpc();
+
         Channel.create(msgEv, postMessage, function (chan) {
             var clientId = '1';
             Object.keys(Rpc.queries).forEach(function (q) {