getMessageQueue() rather than .messageQueue to avoid startup issue

js/background.js

@@ -1408,9 +1408,11 @@
       await window.lokiFileServerAPI.updateOurDeviceMapping();
       // TODO: we should ensure the message was sent and retry automatically if not
       const device = new libsession.Types.PubKey(pubKey);
-      const unlinkMessage = new libsession.Messages.Outgoing.DeviceUnlinkMessage(pubKey);
+      const unlinkMessage = new libsession.Messages.Outgoing.DeviceUnlinkMessage(
+        pubKey
+      );
 
-      await libsession.messageQueue.send(device, unlinkMessage);
+      await libsession.getMessageQueue().send(device, unlinkMessage);
       // Remove all traces of the device
       setTimeout(() => {
         ConversationController.deleteContact(pubKey);

libloki/api.js

@@ -60,7 +60,7 @@
     const sessionEstablished = new window.libsession.Messages.Outgoing.SessionEstablished(
       { timestamp: Date.now() }
     );
-    await libsession.messageQueue.send(user, sessionEstablished);
+    await libsession.getMessageQueue().send(user, sessionEstablished);
   }
 
   async function sendBackgroundMessage(pubKey, debugMessageType) {

libtextsecure/account_manager.js

@@ -556,7 +556,9 @@
           requestSignature,
         }
       );
-      await libsession.messageQueue.send(primaryDevice, requestPairingMessage);
+      await window.libsession
+        .getMessageQueue()
+        .send(primaryDevice, requestPairingMessage);
     },
     async authoriseSecondaryDevice(secondaryDeviceStr) {
       const ourPubKey = textsecure.storage.user.getNumber();
@@ -633,10 +635,9 @@
             lokiProfile,
           }
         );
-        await libsession.messageQueue.send(
+        await libsession
-          secondaryDevicePubKey,
+          .getMessageQueue()
-          requestPairingMessage
+          .send(secondaryDevicePubKey, requestPairingMessage);
-        );
       } catch (e) {
         log.error(
           'Failed to authorise secondary device: ',

preload.js

@@ -160,6 +160,7 @@ window.setPassword = (passPhrase, oldPhrase) =>
 
 window.passwordUtil = require('./app/password_util');
 window.libsession = require('./ts/session');
+window.libsession.getMessageQueue = require('./ts/session/sending/instance').getMessageQueue;
 
 // We never do these in our code, so we'll prevent it everywhere
 window.open = () => null;

ts/session/index.ts

@@ -1,8 +1,5 @@
 import * as Messages from './messages';
 import * as Protocols from './protocols';
 import * as Types from './types';
-import { MessageQueue } from './sending';
 
-const messageQueue = new MessageQueue();
+export { Messages, Protocols, Types };
-
-export { Messages, Protocols, Types, messageQueue };

ts/session/sending/instance.ts

@@ -0,0 +1,12 @@
+import { MessageQueue } from './MessageQueue';
+
+let messageQueue: MessageQueue;
+
+function getMessageQueue() {
+  if (!messageQueue) {
+    messageQueue = new MessageQueue();
+  }
+  return messageQueue;
+}
+
+export { getMessageQueue };