make FederationHandler.on_send_leave_request async
This commit is contained in:
parent
98681f90cb
commit
d184cbc031
|
@ -1641,9 +1641,7 @@ class FederationHandler(BaseHandler):
|
||||||
|
|
||||||
return event
|
return event
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
async def on_send_leave_request(self, origin, pdu):
|
||||||
@log_function
|
|
||||||
def on_send_leave_request(self, origin, pdu):
|
|
||||||
""" We have received a leave event for a room. Fully process it."""
|
""" We have received a leave event for a room. Fully process it."""
|
||||||
event = pdu
|
event = pdu
|
||||||
|
|
||||||
|
@ -1663,9 +1661,9 @@ class FederationHandler(BaseHandler):
|
||||||
|
|
||||||
event.internal_metadata.outlier = False
|
event.internal_metadata.outlier = False
|
||||||
|
|
||||||
context = yield self._handle_new_event(origin, event)
|
context = await self._handle_new_event(origin, event)
|
||||||
|
|
||||||
event_allowed = yield self.third_party_event_rules.check_event_allowed(
|
event_allowed = await self.third_party_event_rules.check_event_allowed(
|
||||||
event, context
|
event, context
|
||||||
)
|
)
|
||||||
if not event_allowed:
|
if not event_allowed:
|
||||||
|
|
Loading…
Reference in New Issue