summary refs log tree commit diff
path: root/synapse/handlers/federation.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2014-11-07 16:03:31 +0000
committerErik Johnston <erik@matrix.org>2014-11-07 16:03:31 +0000
commit07286a73b179c7b3888f7cbf15dcf7c4f5a0c3a3 (patch)
treea9c62914ed34a232cdee3d25dcc83d8381d4057b /synapse/handlers/federation.py
parentAdd '/event_auth/' federation api (diff)
downloadsynapse-07286a73b179c7b3888f7cbf15dcf7c4f5a0c3a3.tar.xz
Use current state to get room hosts, rather than querying the database
Diffstat (limited to '')
-rw-r--r--synapse/handlers/federation.py21
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)