Skip to content

Commit d2d9b9c

Browse files
committed
feat(store): also delete thread subscriptions when deleting a room in db
1 parent a2cc39c commit d2d9b9c

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

crates/matrix-sdk-base/src/store/memory_store.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -754,6 +754,7 @@ impl StateStore for MemoryStore {
754754
inner.room_event_receipts.remove(room_id);
755755
inner.send_queue_events.remove(room_id);
756756
inner.dependent_send_queue_events.remove(room_id);
757+
inner.thread_subscriptions.remove(room_id);
757758

758759
Ok(())
759760
}

crates/matrix-sdk-sqlite/src/state_store.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1766,6 +1766,13 @@ impl StateStore for SqliteStateStore {
17661766
this.encode_key(keys::DEPENDENTS_SEND_QUEUE, &room_id);
17671767
txn.remove_room_dependent_send_queue(&dependent_send_queue_room_id)?;
17681768

1769+
let thread_subscriptions_room_id =
1770+
this.encode_key(keys::THREAD_SUBSCRIPTIONS, &room_id);
1771+
txn.execute(
1772+
"DELETE FROM thread_subscriptions WHERE room_id = ?",
1773+
(thread_subscriptions_room_id,),
1774+
)?;
1775+
17691776
Ok(())
17701777
})
17711778
.await?;

0 commit comments

Comments
 (0)