fix: debug on prod

src/modules/main/chat/persistence/message-storage.ts

@@ -17,7 +17,6 @@ export function createMessageObjectStore(db: IDBPDatabase) {
 export function createMessageStorage(db: IDBPDatabase): MessageStorage {
   return {
     async lastMessage({ url, queueId }): Promise<ChatMessage | undefined> {
-      console.log("TEST", url, queueId);
       const cursor = await db.transaction("message-v2")
         .store.index("queueId")
         .openCursor(IDBKeyRange.only([url, queueId]), "prev");

src/modules/umbrella/logic/logic.ts

@@ -72,11 +72,11 @@ function createSeedClient() {
     },
   });
   client.setForeground(true);
-  window.onfocus = function() {
+  window.onoffline = function() {
     console.log(">> foreground(true)");
     client.setForeground(true);
   };
-  window.onblur = function() {
+  window.ononline = function() {
     console.log("<< foreground(false)");
     client.setForeground(false);
   };

src/modules/umbrella/persistence/seed-persistence.ts

@@ -1,3 +1,5 @@
+/* eslint-disable @typescript-eslint/no-unsafe-member-access */
+/* eslint-disable @typescript-eslint/no-unsafe-assignment */
 import {
   createMessageObjectStore,
   createMessageStorage,
@@ -77,10 +79,10 @@ export async function createPersistence(): Promise<SeedPersistence> {
         const messageV2Store = transaction.objectStore("message-v2");
 
         const cursor = await messageStore.openCursor() ?? [];
-        for await (const { value } of cursor) {
-          // eslint-disable-next-line
-          value.queueId = value.chatId;
-          await messageV2Store.put(value);
+        for await (const { value: message } of cursor) {
+          message.queueId = message.chatId;
+          message.url = "wss://meetacy.app/seed-go";
+          await messageV2Store.put(message);
         }
 
         db.deleteObjectStore("message");

src/sdk-v2/seed-client.ts

@@ -99,17 +99,27 @@ export function createSeedClient(
   const events: Observable<SeedClientEvent> = createObservable();
 
   const engine = createSeedEngine(engineOptions.mainUrl);
-  const subscribeQueueIds: Set<string> = new Set();
-  const waitingQueues: Map<string, Set<string>> = new Map();
+  const subscribeQueues: Map<string, Set<string>> = new Map();
 
-  setInterval(() => {
-    void engine.executeOrThrow(
-      engineOptions.mainUrl,
-      {
-        "type": "ping",
-      },
-    );
-  }, 15_000);
+  function setSubscribeQueue(
+    url: string,
+    queueId: string,
+    subscribed: boolean,
+  ) {
+    const urlQueues = subscribeQueues.get(url) ?? new Set();
+    subscribeQueues.set(url, urlQueues);
+    if (subscribed) {
+      urlQueues.add(queueId);
+    } else {
+      urlQueues.delete(queueId);
+    }
+  }
+  function getSubscribeQueue(url: string, queueId: string) {
+    const urlQueues = subscribeQueues.get(url);
+    return urlQueues !== undefined && urlQueues.has(queueId);
+  }
+
+  const waitingQueues: Map<string, Set<string>> = new Map();
 
   function setWaitingQueue(url: string, queueId: string, waiting: boolean) {
     const urlQueues = waitingQueues.get(url) ?? new Set();
@@ -130,6 +140,16 @@ export function createSeedClient(
     return urlQueues !== undefined && urlQueues.has(queueId);
   }
 
+  setInterval(() => {
+    ensureServer(engineOptions.mainUrl);
+    void engine.executeOrThrow(
+      engineOptions.mainUrl,
+      {
+        "type": "ping",
+      },
+    );
+  }, 15_000);
+
   engine.events.subscribe(event => {
     switch (event.type) {
       case "ready":
@@ -188,11 +208,11 @@ export function createSeedClient(
   }
 
   function subscribe(url: string, { queueId, nonce }: SeedClientSubscribeOptions) {
-    if (subscribeQueueIds.has(url)) {
+    if (getSubscribeQueue(url, queueId)) {
       throw new Error(`Already subscribed to this chat id ${queueId}`);
     }
     ensureServer(url);
-    subscribeQueueIds.add(url);
+    setSubscribeQueue(url, queueId, true);
     const request: SubscribeRequest = {
       type: "subscribe",
       queueId, nonce,

src/sdk-v2/seed-engine.ts

@@ -186,9 +186,9 @@ export function createSeedEngine(mainUrl: string): SeedEngine {
   ) {
     console.log(`>> execute\nServer: ${url}\nRequest:`, payload);
     return new Promise((resolve, reject) => {
-      if (!ready) throw new SeedEngineDisconnected();
+      if (!ready) reject(new SeedEngineDisconnected());
       if (checkConnection && !connectedUrls.has(url)) {
-        throw new SeedEngineDisconnected();
+        reject(new SeedEngineDisconnected());
       }
 
       requests.push({