mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-24 18:45:52 +03:00
Code Issues Projects Releases Packages Wiki Activity

Add fastpath optimisation

Browse source
This commit is contained in:
David Baker 2017-10-05 13:20:22 +01:00
parent e433393c4f
commit ed80c6b6cc
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
synapse/push/bulk_push_rule_evaluator.py
View file

@ -112,9 +112,15 @@ class BulkPushRuleEvaluator(object):
@defer.inlineCallbacks @defer.inlineCallbacks
def _get_sender_power_level(self, event, context): def _get_sender_power_level(self, event, context):
auth_events_ids = yield self.auth.compute_auth_events( pl_event_key = (EventTypes.PowerLevels, "", )
event, context.prev_state_ids, for_verification=False, if pl_event_key in context.prev_state_ids:
) # fastpath: if there's a power level event, that's all we need, and
# not having a power level event is an extreme edge case
auth_events_ids = [context.prev_state_ids[pl_event_key]]
else:
auth_events_ids = yield self.auth.compute_auth_events(
event, context.prev_state_ids, for_verification=False,
)
auth_events = yield self.store.get_events(auth_events_ids) auth_events = yield self.store.get_events(auth_events_ids)
auth_events = { auth_events = {
(e.type, e.state_key): e for e in auth_events.values() (e.type, e.state_key): e for e in auth_events.values()