feat: move queryChannels events to LLC

Author: isekovanic

package/src/components/ChannelList/ChannelList.tsx

@@ -370,11 +370,11 @@ export const ChannelList = (props: ChannelListProps) => {
       return;
     }
 
-    upsertCidsForQuery({
-      cids: channels.map((c) => c.cid),
-      filters,
-      sort,
-    });
+    // upsertCidsForQuery({
+    //   cids: channels.map((c) => c.cid),
+    //   filters,
+    //   sort,
+    // });
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [channelIdsStr, staticChannelsActive]);
 

package/src/components/ChannelList/hooks/usePaginatedChannels.ts

@@ -234,35 +234,34 @@ export const usePaginatedChannels = ({
       // Any time DB is synced, we need to update the UI with local DB channels first,
       // and then call queryChannels to ensure any new channels are added to UI.
       listener = DBSyncManager.onSyncStatusChange(async (syncStatus) => {
-        if (syncStatus) {
-          const loadingChannelsSucceeded = await loadOfflineChannels();
-          if (loadingChannelsSucceeded) {
-            await reloadList();
-            setForceUpdate((u) => u + 1);
-          }
-        }
+        // if (syncStatus) {
+        //   const loadingChannelsSucceeded = await loadOfflineChannels();
+        //   if (loadingChannelsSucceeded) {
+        //     await reloadList();
+        //     setForceUpdate((u) => u + 1);
+        //   }
+        // }
       });
       // On start, load the channels from local db.
-      loadOfflineChannels().then((success) => {
-        // If db is already synced (sync api and pending api calls), then
-        // right away call queryChannels.
-        if (success) {
-          const dbSyncStatus = DBSyncManager.getSyncStatus();
-          if (dbSyncStatus) {
-            reloadList();
-          }
-        }
-      });
+      // loadOfflineChannels().then((success) => {
+      //   // If db is already synced (sync api and pending api calls), then
+      //   // right away call queryChannels.
+      //   if (success) {
+      //     const dbSyncStatus = DBSyncManager.getSyncStatus();
+      //     if (dbSyncStatus) {
+      //       reloadList();
+      //     }
+      //   }
+      // });
     } else {
       listener = client.on('connection.changed', async (event) => {
         if (event.online) {
           await refreshList();
           setForceUpdate((u) => u + 1);
         }
       });
-
-      reloadList();
     }
+    reloadList();
 
     return () => listener?.unsubscribe?.();
     // eslint-disable-next-line react-hooks/exhaustive-deps

package/src/components/Chat/Chat.tsx

@@ -24,6 +24,7 @@ import { useStreami18n } from '../../hooks/useStreami18n';
 import init from '../../init';
 
 import { NativeHandlers } from '../../native';
+import { OfflineDB } from '../../store/OfflineDB';
 import { SqliteClient } from '../../store/SqliteClient';
 
 import { DBSyncManager } from '../../utils/DBSyncManager';
@@ -213,6 +214,11 @@ const ChatWithContext = (props: PropsWithChildren<ChatProps>) => {
     }
 
     const initializeDatabase = () => {
+      // TODO: Rethink this, it looks ugly
+      console.log('TESTING2', client);
+      const offlineDBInstance = new OfflineDB({ client });
+      console.log(offlineDBInstance);
+      client.setOfflineDBApi(offlineDBInstance);
       // This acts as a lock for some very rare occurrences of concurrency
       // issues we've encountered before with the QuickSqliteClient being
       // uninitialized before it's being invoked.

package/src/components/Chat/hooks/handleEventToSyncDB.ts

@@ -227,15 +227,15 @@ export const handleEventToSyncDB = async (event: Event, client: StreamChat, flus
     }
   }
 
-  if (type === 'channels.queried') {
-    if (event.queriedChannels?.channels?.length) {
-      return upsertChannels({
-        channels: event.queriedChannels?.channels,
-        flush,
-        isLatestMessagesSet: event.queriedChannels?.isLatestMessageSet,
-      });
-    }
-  }
+  // if (type === 'channels.queried') {
+  //   if (event.queriedChannels?.channels?.length) {
+  //     return upsertChannels({
+  //       channels: event.queriedChannels?.channels,
+  //       flush,
+  //       isLatestMessagesSet: event.queriedChannels?.isLatestMessageSet,
+  //     });
+  //   }
+  // }
 
   if (type === 'member.added' || type === 'member.updated') {
     const member = event.member;

package/src/store/OfflineDB.ts

@@ -0,0 +1,14 @@
+import { AbstractOfflineDB, GetChannelsForQueryType, GetChannelsType } from 'stream-chat';
+
+import * as api from './apis';
+
+export class OfflineDB extends AbstractOfflineDB {
+  upsertCidsForQuery = api.upsertCidsForQuery;
+  upsertChannels = api.upsertChannels;
+  // FIXME
+  getChannels = ({ cids, userId }: GetChannelsType) =>
+    api.getChannels({ channelIds: cids, currentUserId: userId });
+  // FIXME
+  getChannelsForQuery = ({ userId, filters, sort }: GetChannelsForQueryType) =>
+    api.getChannelsForFilterSort({ currentUserId: userId, filters, sort });
+}