|
|
|
@ -1118,11 +1118,9 @@ class FederationHandler(BaseHandler): |
|
|
|
|
""" |
|
|
|
|
events_to_context = {} |
|
|
|
|
for e in itertools.chain(auth_events, state): |
|
|
|
|
ctx = yield self.state_handler.compute_event_context( |
|
|
|
|
e, outlier=True, |
|
|
|
|
) |
|
|
|
|
events_to_context[e.event_id] = ctx |
|
|
|
|
e.internal_metadata.outlier = True |
|
|
|
|
ctx = yield self.state_handler.compute_event_context(e) |
|
|
|
|
events_to_context[e.event_id] = ctx |
|
|
|
|
|
|
|
|
|
event_map = { |
|
|
|
|
e.event_id: e |
|
|
|
@ -1169,7 +1167,7 @@ class FederationHandler(BaseHandler): |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
new_event_context = yield self.state_handler.compute_event_context( |
|
|
|
|
event, old_state=state, outlier=False, |
|
|
|
|
event, old_state=state |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
event_stream_id, max_stream_id = yield self.store.persist_event( |
|
|
|
@ -1181,10 +1179,9 @@ class FederationHandler(BaseHandler): |
|
|
|
|
|
|
|
|
|
@defer.inlineCallbacks |
|
|
|
|
def _prep_event(self, origin, event, state=None, auth_events=None): |
|
|
|
|
outlier = event.internal_metadata.is_outlier() |
|
|
|
|
|
|
|
|
|
context = yield self.state_handler.compute_event_context( |
|
|
|
|
event, old_state=state, outlier=outlier, |
|
|
|
|
event, old_state=state, |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
if not auth_events: |
|
|
|
|