peppate
This commit is contained in:
parent
d4315bbf6b
commit
367cfab4e6
1 changed files with 2 additions and 3 deletions
|
@ -57,7 +57,7 @@ class ReceiptsStore(SQLBaseStore):
|
||||||
return txn.fetchall()
|
return txn.fetchall()
|
||||||
|
|
||||||
defer.returnValue(dict(
|
defer.returnValue(dict(
|
||||||
(yield self.runInteraction("get_receipts_for_user", f))
|
(yield self.runInteraction("get_receipts_for_user", f))
|
||||||
))
|
))
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
|
@ -212,7 +212,7 @@ class ReceiptsStore(SQLBaseStore):
|
||||||
def insert_linearized_receipt_txn(self, txn, room_id, receipt_type,
|
def insert_linearized_receipt_txn(self, txn, room_id, receipt_type,
|
||||||
user_id, event_id, data, stream_id):
|
user_id, event_id, data, stream_id):
|
||||||
txn.call_after(
|
txn.call_after(
|
||||||
self.get_receipts_for_room.invalidate, (room_id, receipt_type)
|
self.get_receipts_for_room.invalidate, (room_id, receipt_type)
|
||||||
)
|
)
|
||||||
txn.call_after(
|
txn.call_after(
|
||||||
self.get_receipts_for_user.invalidate, (user_id, receipt_type)
|
self.get_receipts_for_user.invalidate, (user_id, receipt_type)
|
||||||
|
@ -348,7 +348,6 @@ class ReceiptsStore(SQLBaseStore):
|
||||||
# FIXME: This shouldn't invalidate the whole cache
|
# FIXME: This shouldn't invalidate the whole cache
|
||||||
txn.call_after(self.get_linearized_receipts_for_room.invalidate_all)
|
txn.call_after(self.get_linearized_receipts_for_room.invalidate_all)
|
||||||
|
|
||||||
|
|
||||||
self._simple_delete_txn(
|
self._simple_delete_txn(
|
||||||
txn,
|
txn,
|
||||||
table="receipts_graph",
|
table="receipts_graph",
|
||||||
|
|
Loading…
Reference in a new issue