`update_membership` declaration: now always returns an event id. (#7809)

code_spécifique_watcha
Richard van der Hoff 4 years ago committed by GitHub
parent 8ca39bd2c3
commit 53ee214f2f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      changelog.d/7809.bugfix
  2. 8
      synapse/handlers/room_member.py
  3. 2
      synapse/handlers/room_member_worker.py
  4. 2
      synapse/rest/client/v1/room.py

@ -0,0 +1 @@
Fix 'stuck invites' which happen when we are unable to reject a room invite received over federation.

@ -109,7 +109,7 @@ class RoomMemberHandler(object):
txn_id: Optional[str], txn_id: Optional[str],
requester: Requester, requester: Requester,
content: JsonDict, content: JsonDict,
) -> Tuple[Optional[str], int]: ) -> Tuple[str, int]:
""" """
Rejects an out-of-band invite we have received from a remote server Rejects an out-of-band invite we have received from a remote server
@ -268,7 +268,7 @@ class RoomMemberHandler(object):
ratelimit: bool = True, ratelimit: bool = True,
content: Optional[dict] = None, content: Optional[dict] = None,
require_consent: bool = True, require_consent: bool = True,
) -> Tuple[Optional[str], int]: ) -> Tuple[str, int]:
key = (room_id,) key = (room_id,)
with (await self.member_linearizer.queue(key)): with (await self.member_linearizer.queue(key)):
@ -299,7 +299,7 @@ class RoomMemberHandler(object):
ratelimit: bool = True, ratelimit: bool = True,
content: Optional[dict] = None, content: Optional[dict] = None,
require_consent: bool = True, require_consent: bool = True,
) -> Tuple[Optional[str], int]: ) -> Tuple[str, int]:
content_specified = bool(content) content_specified = bool(content)
if content is None: if content is None:
content = {} content = {}
@ -1006,7 +1006,7 @@ class RoomMemberMasterHandler(RoomMemberHandler):
txn_id: Optional[str], txn_id: Optional[str],
requester: Requester, requester: Requester,
content: JsonDict, content: JsonDict,
) -> Tuple[Optional[str], int]: ) -> Tuple[str, int]:
""" """
Rejects an out-of-band invite received from a remote user Rejects an out-of-band invite received from a remote user

@ -67,7 +67,7 @@ class RoomMemberWorkerHandler(RoomMemberHandler):
txn_id: Optional[str], txn_id: Optional[str],
requester: Requester, requester: Requester,
content: dict, content: dict,
) -> Tuple[Optional[str], int]: ) -> Tuple[str, int]:
""" """
Rejects an out-of-band invite received from a remote user Rejects an out-of-band invite received from a remote user

@ -217,8 +217,6 @@ class RoomStateEventRestServlet(TransactionRestServlet):
) )
event_id = event.event_id event_id = event.event_id
ret = {} # type: dict
if event_id:
set_tag("event_id", event_id) set_tag("event_id", event_id)
ret = {"event_id": event_id} ret = {"event_id": event_id}
return 200, ret return 200, ret

Loading…
Cancel
Save