MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-11-14 14:01:59 +01:00
Code Issues Projects Releases Wiki Activity

Fixup comment

Browse source
This commit is contained in:
Erik Johnston 2019-09-09 13:31:00 +01:00
parent fffe17b77d
commit 916c697228
1 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
synapse/storage/events.py
View file

@ -269,7 +269,7 @@ class EventsStore(
) )
if self.hs.config.redaction_retention_period is not None: if self.hs.config.redaction_retention_period is not None:
hs.get_clock().looping_call(_censor_redactions, 10 * 60 * 1000) hs.get_clock().looping_call(_censor_redactions, 5 * 60 * 1000)
@defer.inlineCallbacks @defer.inlineCallbacks
def _read_forward_extremities(self): def _read_forward_extremities(self):
@ -1574,9 +1574,17 @@ class EventsStore(
self._clock.time_msec() - self.hs.config.redaction_retention_period self._clock.time_msec() - self.hs.config.redaction_retention_period
) )
# We fetch all redactions that point to an event that we have that has # We fetch all redactions that:
# a stream ordering from over a month ago, that we haven't yet censored # 1. point to an event we have that has,
# in the DB. # 2. has a stream ordering from before the cut off, and
# 3. we haven't yet censored.
#
# This is limited to 100 events to ensure that we don't try and do too
# much at once. We'll get called again so this should eventually catch
# up.
#
# We use the range [-max_pos, max_pos] to handle backfilled events,
# which are given negative stream ordering.
sql = """ sql = """
SELECT er.event_id, redacts FROM redactions SELECT er.event_id, redacts FROM redactions
INNER JOIN events AS er USING (event_id) INNER JOIN events AS er USING (event_id)