feat: move truncated event to llc

Author: isekovanic

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

@@ -1,8 +1,8 @@
-import type { Event, StreamChat } from 'stream-chat';
+// import type { Event, StreamChat } from 'stream-chat';
 
 // import { deleteChannel } from '../../../store/apis/deleteChannel';
 // import { deleteMember } from '../../../store/apis/deleteMember';
-import { deleteMessagesForChannel } from '../../../store/apis/deleteMessagesForChannel';
+// import { deleteMessagesForChannel } from '../../../store/apis/deleteMessagesForChannel';
 // import { updateMessage } from '../../../store/apis/updateMessage';
 // import { upsertChannelData } from '../../../store/apis/upsertChannelData';
 // import { upsertChannelDataFromChannel } from '../../../store/apis/upsertChannelDataFromChannel';
@@ -13,9 +13,9 @@ import { deleteMessagesForChannel } from '../../../store/apis/deleteMessagesForC
 // import { PreparedQueries } from '../../../store/types';
 
 // eslint-disable-next-line require-await
-export const handleEventToSyncDB = async (event: Event, client: StreamChat, flush?: boolean) => {
-  const { type } = event;
-  console.log('client', !!client);
+export const handleEventToSyncDB = async () => {
+  // const { type } = event;
+  // console.log('client', !!client);
 
   // This function is used to guard the queries that require channel to be present in the db first
   // If channel is not present in the db, we first fetch the channel data from the channel object
@@ -217,14 +217,16 @@ export const handleEventToSyncDB = async (event: Event, client: StreamChat, flus
   //   }
   // }
 
-  if (type === 'channel.truncated') {
-    if (event.channel) {
-      return deleteMessagesForChannel({
-        cid: event.channel.cid,
-        flush,
-      });
-    }
-  }
+  // if (type === 'channel.truncated') {
+  //   console.log('TRUNCATINO: ', event);
+  //   if (event.channel) {
+  //     return deleteMessagesForChannel({
+  //       cid: event.channel.cid,
+  //       flush,
+  //       truncated_at: event.channel.truncated_at,
+  //     });
+  //   }
+  // }
 
   // if (type === 'member.added' || type === 'member.updated') {
   //   const member = event.member;

package/src/store/OfflineDB.ts

@@ -68,6 +68,8 @@ export class OfflineDB extends AbstractOfflineDB {
 
   deleteChannel = api.deleteChannel;
 
+  deleteMessagesForChannel = api.deleteMessagesForChannel;
+
   hardDeleteMessage = api.deleteMessage;
 
   softDeleteMessage = api.softDeleteMessage;

package/src/store/apis/deleteMessagesForChannel.ts

@@ -1,20 +1,24 @@
-import { createDeleteQuery } from '../sqlite-utils/createDeleteQuery';
 import { SqliteClient } from '../SqliteClient';
 
 export const deleteMessagesForChannel = async ({
   cid,
+  truncated_at,
   flush = true,
 }: {
   cid: string;
+  truncated_at?: string;
   flush?: boolean;
 }) => {
-  const query = createDeleteQuery('messages', {
-    cid,
-  });
+  const timestamp = truncated_at ? new Date(truncated_at).toISOString() : new Date().toISOString();
+  const query: [string, (string | number)[]] = [
+    `DELETE FROM messages WHERE cid = ? AND createdAt <= ?`,
+    [cid, timestamp],
+  ];
 
   SqliteClient.logger?.('info', 'deleteMessagesForChannel', {
     cid,
     flush,
+    truncated_at,
   });
 
   if (flush) {

package/src/store/apis/queries/selectMessagesForChannels.ts

@@ -30,7 +30,7 @@ export const selectMessagesForChannels = async (
         *,
         ROW_NUMBER() OVER (
           PARTITION BY cid
-          ORDER BY cast(strftime('%s', createdAt) AS INTEGER) DESC
+          ORDER BY createdAt DESC
         ) RowNum
       FROM messages
       WHERE cid in (${questionMarks})
@@ -39,7 +39,7 @@ export const selectMessagesForChannels = async (
       users b
     ON b.id = a.userId
     WHERE RowNum < 200
-    ORDER BY cast(strftime('%s', a.createdAt) AS INTEGER) ASC`,
+    ORDER BY a.createdAt ASC`,
     cids,
   );