diff options
author | Mark Haines <mark.haines@matrix.org> | 2016-07-26 11:05:39 +0100 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2016-07-26 11:05:39 +0100 |
commit | a6f06ce3e280cfa18f51748a7d4327001658db40 (patch) | |
tree | f1db3785548fa00e6f23134c43fba7a7a39e60c9 /synapse | |
parent | Don't add rejected events if we've seen them befrore. Add some comments to ex... (diff) | |
download | synapse-a6f06ce3e280cfa18f51748a7d4327001658db40.tar.xz |
Fix how push_actions are redacted.
Diffstat (limited to 'synapse')
-rw-r--r-- | synapse/storage/events.py | 18 |
1 files changed, 10 insertions, 8 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index 25a2be2795..c63ca36df6 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -522,6 +522,8 @@ class EventsStore(SQLBaseStore): ] if not events_and_contexts: + # Make sure we don't pass an empty list to functions that expect to + # be storing at least one element. return # From this point onwards the events are only events that we haven't @@ -608,6 +610,13 @@ class EventsStore(SQLBaseStore): txn, event, context.push_actions ) + if event.type == EventTypes.Redaction and event.redacts is not None: + # Remove the entries in the event_push_actions table for the + # redacted event. + self._remove_push_actions_for_event_id_txn( + txn, event.room_id, event.redacts + ) + self._simple_insert_many_txn( txn, table="event_auth", @@ -622,13 +631,6 @@ class EventsStore(SQLBaseStore): ], ) - if event.type == EventTypes.Redaction and event.redacts is not None: - # Remove the entries in the event_push_actions table for the - # redacted event. - self._remove_push_actions_for_event_id_txn( - txn, event.room_id, event.redacts - ) - # Insert into the state_groups, state_groups_state, and # event_to_state_groups tables. self._store_mult_state_groups_txn(txn, events_and_contexts) @@ -716,7 +718,7 @@ class EventsStore(SQLBaseStore): ], ) - # Prefil the event cache + # Prefill the event cache self._add_to_cache(txn, events_and_contexts) if backfilled: |