fix(threads): restore reply soft-deletion

src/thread.ts

@@ -291,8 +291,13 @@ export class Thread<SCG extends ExtendableGenerics = DefaultGenerics> {
 
   private subscribeReplyDeleted = () =>
     this.client.on('message.deleted', (event) => {
-      if (event.message?.parent_id === this.id && event.hard_delete) {
-        return this.deleteReplyLocally({ message: event.message });
+      if (event.message?.parent_id !== this.id) return;
+
+      if (event.hard_delete) {
+        this.deleteReplyLocally({ message: event.message });
+      } else {
+        // Handle soft delete (updates deleted_at timestamp)
+        this.upsertReplyLocally({ message: event.message });
       }
     }).unsubscribe;
 

test/unit/threads.test.ts

@@ -795,7 +795,7 @@ describe('Threads 2.0', () => {
       });
 
       describe('Event: message.deleted', () => {
-        it('deletes reply if the message was hard-deleted', () => {
+        it('deletes reply from local store if it was hard-deleted', () => {
           const createdAt = new Date().getTime();
           // five messages "created" second apart
           const messages = Array.from(
@@ -823,6 +823,41 @@ describe('Threads 2.0', () => {
 
           thread.unregisterSubscriptions();
         });
+
+        it('updates deleted_at property of the reply if it was soft deleted', () => {
+          const createdAt = new Date().getTime();
+          // five messages "created" second apart
+          const messages = Array.from(
+            { length: 5 },
+            (_, i) =>
+              generateMsg({
+                parent_id: parentMessageResponse.id,
+                created_at: new Date(createdAt + 1000 * i).toISOString(),
+              }) as MessageResponse,
+          );
+          const thread = createTestThread({ latest_replies: messages });
+          thread.registerSubscriptions();
+
+          const messageToDelete = messages[2];
+
+          expect(messageToDelete.deleted_at).to.be.undefined;
+
+          const deletedAt = new Date();
+          client.dispatchEvent({
+            type: 'message.deleted',
+            message: { ...messageToDelete, type: 'deleted', deleted_at: deletedAt.toISOString() },
+          });
+
+          const stateAfter = thread.state.getLatestValue();
+          expect(stateAfter.replies).to.have.lengthOf(5);
+          expect(stateAfter.replies[2].id).to.equal(messageToDelete.id);
+          expect(stateAfter.replies[2]).to.not.equal(messageToDelete);
+          expect(stateAfter.replies[2].deleted_at).to.be.a('date');
+          expect(stateAfter.replies[2].deleted_at!.toISOString()).to.equal(deletedAt.toISOString());
+          expect(stateAfter.replies[2].type).to.equal('deleted');
+
+          thread.unregisterSubscriptions();
+        });
       });
 
       describe('Events: message.updated, reaction.new, reaction.deleted', () => {