feat: message deletes

Author: isekovanic

src/channel.ts

@@ -1752,6 +1752,8 @@ export class Channel {
           if (event.hard_delete) channelState.removeMessage(event.message);
           else channelState.addMessageSorted(event.message, false, false);
 
+          this.getClient().offlineDb?.handleDeleteMessage({ event });
+
           channelState.removeQuotedMessageReferences(event.message);
 
           if (event.message.pinned) {

src/offline_support_api.ts

@@ -237,7 +237,7 @@ export abstract class AbstractOfflineDB implements OfflineDBApi {
       if (channel && channel.data && channel.initialized && !channel.disconnected) {
         const channelQuery = await this.upsertChannelData({
           channel: channel.data as unknown as ChannelResponse,
-          flush,
+          flush: false,
         });
         if (channelQuery) {
           const createdQueries = await createQueries(false);
@@ -280,9 +280,9 @@ export abstract class AbstractOfflineDB implements OfflineDBApi {
 
     const finalQueries = await this.queriesWithChannelGuard(
       { event, flush },
-      async (flushOverride) => {
+      async () => {
         let queries = await this.upsertMessages({
-          flush: flushOverride,
+          flush: false,
           messages: [message],
         });
         if (cid && client.user && client.user.id !== user?.id) {
@@ -293,7 +293,7 @@ export abstract class AbstractOfflineDB implements OfflineDBApi {
             const unreadCount = channel.countUnread();
             const upsertReadsQueries = await this.upsertReads({
               cid,
-              flush: flushOverride,
+              flush: false,
               reads: [
                 {
                   last_read: ownReads.last_read.toString() as string,
@@ -317,6 +317,27 @@ export abstract class AbstractOfflineDB implements OfflineDBApi {
     return finalQueries;
   };
 
+  public handleDeleteMessage = async ({
+    event,
+    flush = true,
+  }: {
+    event: Event;
+    flush?: boolean;
+  }) => {
+    const { message, hard_delete = false } = event;
+
+    if (message) {
+      const deleteMethod = hard_delete ? this.hardDeleteMessage : this.softDeleteMessage;
+      return await this.queriesWithChannelGuard(
+        { event, flush },
+        async (flushOverride) =>
+          await deleteMethod({ id: message.id, flush: flushOverride }),
+      );
+    }
+
+    return [];
+  };
+
   public queueTask = async ({ task }: { task: PendingTask }) => {
     let response;
     try {
@@ -534,10 +555,8 @@ export class OfflineDBSyncManager {
   };
 
   private handleEventToSyncDB = async (event: Event, flush?: boolean) => {
-    const client = this.client;
-
     const { type } = event;
-    console.log('SYNCING REACTION EVENT1: ', event.type);
+    console.log('SYNCING EVENT: ', event.type);
 
     if (type.startsWith('reaction') && event.message && event.reaction) {
       const { message, reaction } = event;
@@ -575,6 +594,10 @@ export class OfflineDBSyncManager {
       }
     }
 
+    if (type === 'message.deleted') {
+      return await this.offlineDb.handleDeleteMessage({ event, flush });
+    }
+
     return [];
   };