Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2025-05-02 05:56:01 -04:00
Code Issues Projects Releases Packages Wiki Activity

Fix creating batch sent member events on worker

Browse source 
Signed-off-by: Tulir Asokan <tulir@beeper.com>
This commit is contained in:
Tulir Asokan 2021-11-02 12:18:39 +02:00 • committed by Tulir Asokan
parent d2ad447a5a
commit 1cc7f9060b
1 changed files with 15 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

28
synapse/handlers/message.py
View file

@ -1385,13 +1385,14 @@ class EventCreationHandler:
if event.type == EventTypes.Member: if event.type == EventTypes.Member:
if event.content["membership"] == Membership.INVITE: if event.content["membership"] == Membership.INVITE:
event.unsigned[ if not event.internal_metadata.outlier:
"invite_room_state" event.unsigned[
] = await self.store.get_stripped_room_state_from_event_context( "invite_room_state"
context, ] = await self.store.get_stripped_room_state_from_event_context(
self.room_prejoin_state_types, context,
membership_user_id=event.sender, self.room_prejoin_state_types,
) membership_user_id=event.sender,
)
invitee = UserID.from_string(event.state_key) invitee = UserID.from_string(event.state_key)
if not self.hs.is_mine(invitee): if not self.hs.is_mine(invitee):
@ -1408,12 +1409,13 @@ class EventCreationHandler:
event.signatures.update(returned_invite.signatures) event.signatures.update(returned_invite.signatures)
if event.content["membership"] == Membership.KNOCK: if event.content["membership"] == Membership.KNOCK:
event.unsigned[ if not event.internal_metadata.outlier:
"knock_room_state" event.unsigned[
] = await self.store.get_stripped_room_state_from_event_context( "knock_room_state"
context, ] = await self.store.get_stripped_room_state_from_event_context(
self.room_prejoin_state_types, context,
) self.room_prejoin_state_types,
)
if event.type == EventTypes.Redaction: if event.type == EventTypes.Redaction:
original_event = await self.store.get_event( original_event = await self.store.get_event(