diff options
author | Erik Johnston <erik@matrix.org> | 2014-11-07 16:03:31 +0000 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2014-11-07 16:03:31 +0000 |
commit | 07286a73b179c7b3888f7cbf15dcf7c4f5a0c3a3 (patch) | |
tree | a9c62914ed34a232cdee3d25dcc83d8381d4057b /synapse/handlers/federation.py | |
parent | Add '/event_auth/' federation api (diff) | |
download | synapse-07286a73b179c7b3888f7cbf15dcf7c4f5a0c3a3.tar.xz |
Use current state to get room hosts, rather than querying the database
Diffstat (limited to '')
-rw-r--r-- | synapse/handlers/federation.py | 21 |
1 files changed, 17 insertions, 4 deletions
diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py index ce65bbcd62..7e10583902 100644 --- a/synapse/handlers/federation.py +++ b/synapse/handlers/federation.py @@ -376,10 +376,23 @@ class FederationHandler(BaseHandler): "user_joined_room", user=user, room_id=event.room_id ) - new_pdu = self.pdu_codec.pdu_from_event(event); - new_pdu.destinations = yield self.store.get_joined_hosts_for_room( - event.room_id - ) + new_pdu = self.pdu_codec.pdu_from_event(event) + + destinations = set() + + for k, s in event.state_events.items(): + try: + if k[0] == RoomMemberEvent.TYPE: + if s.content["membership"] == Membership.JOIN: + destinations.add( + self.hs.parse_userid(s.state_key).domain + ) + except: + logger.warn( + "Failed to get destination from event %s", s.event_id + ) + + new_pdu.destinations = list(destinations) yield self.replication_layer.send_pdu(new_pdu) |