summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-02-21 15:19:54 +0000
committerErik Johnston <erik@matrix.org>2018-02-21 15:19:54 +0000
commitfaeb369f158a3ca6ba8f48ca1d551b2b53f4c53a (patch)
treed311bc0f5dda76560c21e19094165ac4a1e91891 /synapse/storage
parentMerge pull request #2893 from matrix-org/erikj/delete_from_staging_fed (diff)
downloadsynapse-faeb369f158a3ca6ba8f48ca1d551b2b53f4c53a.tar.xz
Fix missing invalidations for receipt storage
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/receipts.py28
1 files changed, 14 insertions, 14 deletions
diff --git a/synapse/storage/receipts.py b/synapse/storage/receipts.py
index 40530632c6..eac8694e0f 100644
--- a/synapse/storage/receipts.py
+++ b/synapse/storage/receipts.py
@@ -292,20 +292,6 @@ class ReceiptsWorkerStore(SQLBaseStore):
             "get_all_updated_receipts", get_all_updated_receipts_txn
         )
 
-
-class ReceiptsStore(ReceiptsWorkerStore):
-    def __init__(self, db_conn, hs):
-        # We instantiate this first as the ReceiptsWorkerStore constructor
-        # needs to be able to call get_max_receipt_stream_id
-        self._receipts_id_gen = StreamIdGenerator(
-            db_conn, "receipts_linearized", "stream_id"
-        )
-
-        super(ReceiptsStore, self).__init__(db_conn, hs)
-
-    def get_max_receipt_stream_id(self):
-        return self._receipts_id_gen.get_current_token()
-
     def _invalidate_get_users_with_receipts_in_room(self, room_id, receipt_type,
                                                     user_id):
         if receipt_type != "m.read":
@@ -326,6 +312,20 @@ class ReceiptsStore(ReceiptsWorkerStore):
 
         self.get_users_with_read_receipts_in_room.invalidate((room_id,))
 
+
+class ReceiptsStore(ReceiptsWorkerStore):
+    def __init__(self, db_conn, hs):
+        # We instantiate this first as the ReceiptsWorkerStore constructor
+        # needs to be able to call get_max_receipt_stream_id
+        self._receipts_id_gen = StreamIdGenerator(
+            db_conn, "receipts_linearized", "stream_id"
+        )
+
+        super(ReceiptsStore, self).__init__(db_conn, hs)
+
+    def get_max_receipt_stream_id(self):
+        return self._receipts_id_gen.get_current_token()
+
     def insert_linearized_receipt_txn(self, txn, room_id, receipt_type,
                                       user_id, event_id, data, stream_id):
         txn.call_after(