summary refs log tree commit diff
path: root/synapse/storage/data_stores
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-03-19 16:19:17 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2020-03-19 16:19:17 +0000
commit92d6b6caf85c4fa0cabc83433e95533234857e7b (patch)
treefb5567b484bfeaf6e891dd1ec79b7e58afafe8d8 /synapse/storage/data_stores
parentMerge pull request #6454 from matrix-org/erikj/clean_base_Store (diff)
parentget rid of (most of) have_events from _update_auth_events_and_context_for_aut... (diff)
downloadsynapse-92d6b6caf85c4fa0cabc83433e95533234857e7b.tar.xz
get rid of (most of) have_events from _update_auth_events_and_context_for_auth (#6468)
* commit 'e203874ca':
  get rid of (most of) have_events from _update_auth_events_and_context_for_auth (#6468)
Diffstat (limited to 'synapse/storage/data_stores')
-rw-r--r--synapse/storage/data_stores/main/events_worker.py34
1 files changed, 0 insertions, 34 deletions
diff --git a/synapse/storage/data_stores/main/events_worker.py b/synapse/storage/data_stores/main/events_worker.py

index e782e8f481..eaddca65b7 100644 --- a/synapse/storage/data_stores/main/events_worker.py +++ b/synapse/storage/data_stores/main/events_worker.py
@@ -783,40 +783,6 @@ class EventsWorkerStore(SQLBaseStore): yield self.runInteraction("have_seen_events", have_seen_events_txn, chunk) return results - def get_seen_events_with_rejections(self, event_ids): - """Given a list of event ids, check if we rejected them. - - Args: - event_ids (list[str]) - - Returns: - Deferred[dict[str, str|None): - Has an entry for each event id we already have seen. Maps to - the rejected reason string if we rejected the event, else maps - to None. - """ - if not event_ids: - return defer.succeed({}) - - def f(txn): - sql = ( - "SELECT e.event_id, reason FROM events as e " - "LEFT JOIN rejections as r ON e.event_id = r.event_id " - "WHERE e.event_id = ?" - ) - - res = {} - for event_id in event_ids: - txn.execute(sql, (event_id,)) - row = txn.fetchone() - if row: - _, rejected = row - res[event_id] = rejected - - return res - - return self.runInteraction("get_seen_events_with_rejections", f) - def _get_total_state_event_counts_txn(self, txn, room_id): """ See get_total_state_event_counts.