From 760469c81238f86a4ae6dbb485c9c2f4930a3483 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Tue, 1 Nov 2016 11:42:08 +0000 Subject: [PATCH] Continue to clean up received_transactions --- synapse/storage/transactions.py | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/synapse/storage/transactions.py b/synapse/storage/transactions.py index 59ece7b81..adab520c7 100644 --- a/synapse/storage/transactions.py +++ b/synapse/storage/transactions.py @@ -46,6 +46,11 @@ class TransactionStore(SQLBaseStore): """A collection of queries for handling PDUs. """ + def __init__(self, hs): + super(TransactionStore, self).__init__(hs) + + self._clock.looping_call(self._cleanup_transactions, 30 * 60 * 1000) + def get_received_txn_response(self, transaction_id, origin): """For an incoming transaction from a given origin, check if we have already responded to it. If so, return the response code and response @@ -234,3 +239,12 @@ class TransactionStore(SQLBaseStore): txn.execute(query, (self._clock.time_msec(),)) return self.cursor_to_dict(txn) + + def _cleanup_transactions(self): + now = self._clock.time_msec() + month_ago = now - 30 * 24 * 60 * 60 * 1000 + + def _cleanup_transactions_txn(txn): + txn.execute("DELETE FROM received_transactions WHERE ts < ?", (month_ago,)) + + return self.runInteraction("_cleanup_transactions", _cleanup_transactions_txn)