feat: add appSettings to database

Author: vishalnarkhede

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

@@ -1,8 +1,9 @@
 import { useEffect, useRef, useState } from 'react';
 
 import type { AppSettingsAPIResponse, StreamChat } from 'stream-chat';
-import type { DefaultStreamChatGenerics } from 'stream-chat-react-native';
 
+import * as dbApi from '../../../store/apis';
+import type { DefaultStreamChatGenerics } from '../../../types/types';
 export const useAppSettings = <
   StreamChatGenerics extends DefaultStreamChatGenerics = DefaultStreamChatGenerics,
 >(
@@ -13,11 +14,23 @@ export const useAppSettings = <
   const isMounted = useRef(true);
 
   useEffect(() => {
-    async function getAppSettings() {
+    async function enforeAppSettings() {
+      if (!client.userID) return;
+
+      if (!isOnline) {
+        const appSettings = dbApi.getAppSettings({ currentUserId: client.userID });
+        setAppSettings(appSettings);
+        return;
+      }
+
       try {
         const appSettings = await client.getAppSettings();
         if (isMounted.current) {
           setAppSettings(appSettings);
+          dbApi.upsertAppSettings({
+            appSettings,
+            currentUserId: client.userID as string,
+          });
         }
       } catch (error: unknown) {
         if (error instanceof Error) {
@@ -26,9 +39,7 @@ export const useAppSettings = <
       }
     }
 
-    if (isOnline && client.userID) {
-      getAppSettings();
-    }
+    enforeAppSettings();
 
     return () => {
       isMounted.current = false;

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

@@ -22,7 +22,7 @@ export const useIsOnline = <
   client: StreamChat<StreamChatGenerics>,
   closeConnectionOnBackground = true,
 ) => {
-  const [isOnline, setIsOnline] = useState(true);
+  const [isOnline, setIsOnline] = useState<boolean | null>(null);
   const [connectionRecovering, setConnectionRecovering] = useState(false);
   const isMounted = useIsMountedRef();
   const clientExists = !!client;

package/src/store/apis/getAppSettings.ts

@@ -0,0 +1,19 @@
+import type { AppSettingsAPIResponse } from 'stream-chat';
+
+import { QuickSqliteClient } from '../QuickSqliteClient';
+import { createSelectQuery } from '../sqlite-utils/createSelectQuery';
+
+export const getAppSettings = ({
+  currentUserId,
+}: {
+  currentUserId: string;
+}): AppSettingsAPIResponse => {
+  const result = QuickSqliteClient.executeSql.apply(
+    null,
+    createSelectQuery('userSyncStatus', ['*'], {
+      userId: currentUserId,
+    }),
+  );
+
+  return result[0]?.appSettings ? JSON.parse(result[0].appSettings) : null;
+};

package/src/store/apis/index.ts

@@ -4,6 +4,7 @@ export * from './deleteMessage';
 export * from './deleteMessagesForChannel';
 export * from './deleteReactions';
 export * from './getAllChannelIds';
+export * from './getAppSettings';
 export * from './getChannelMessages';
 export * from './getChannels';
 export * from './getChannelsForFilterSort';
@@ -12,6 +13,7 @@ export * from './getMembers';
 export * from './getReads';
 export * from './updateMessage';
 export * from './updateReaction';
+export * from './upsertAppSettings';
 export * from './upsertChannelData';
 export * from './upsertChannels';
 export * from './upsertCidsForQuery';

package/src/store/apis/upsertAppSettings.ts

@@ -0,0 +1,23 @@
+import type { AppSettingsAPIResponse } from 'stream-chat';
+
+import { QuickSqliteClient } from '../QuickSqliteClient';
+import { createUpsertQuery } from '../sqlite-utils/createUpsertQuery';
+
+export const upsertAppSettings = ({
+  appSettings,
+  currentUserId,
+  flush = true,
+}: {
+  appSettings: AppSettingsAPIResponse;
+  currentUserId: string;
+  flush?: boolean;
+}) => {
+  const query = createUpsertQuery('userSyncStatus', {
+    appSettings: JSON.stringify(appSettings),
+    userId: currentUserId,
+  });
+
+  if (flush) {
+    QuickSqliteClient.executeSql.apply(null, query);
+  }
+};

package/src/store/schema.ts

@@ -201,6 +201,7 @@ export const tables: Tables = {
   },
   userSyncStatus: {
     columns: {
+      appSettings: 'TEXT',
       lastSyncedAt: 'TEXT',
       userId: 'TEXT',
     },
@@ -302,6 +303,7 @@ export type Schema = {
     updatedAt?: string;
   };
   userSyncStatus: {
+    appSettings: string;
     lastSyncedAt: string;
     userId: string;
   };