Fix and de-brittle remote result dict processing

synapse/handlers/e2e_keys.py

@@ -985,35 +985,49 @@ class E2eKeysHandler(object):
         Raises:
             NotFoundError: if the key is not found
         """
+        user = UserID.from_string(user_id)
         key = yield self.store.get_e2e_cross_signing_key(
             user_id, key_type, from_user_id
         )
-        if key is None:
+
+        if key is None and self.is_mine(user):
             # Attempt to fetch the missing key from the remote user's server
-            user = UserID.from_string(user_id)
             try:
                 remote_result = yield self.federation.query_client_keys(
                     user.domain, {"device_keys": {user_id: []}}, timeout=10 * 1000
                 )
 
-                # Save these keys to the database for subsequent queries
+                # Process the result
-                for key_type, remote_user_id in remote_result.items():
+                for remote_key_type, remote_user_dict in remote_result.items():
-                    if remote_user_id != user_id:
+                    # The key_type variable passed to this function is in the form
-                        continue
+                    # "self_signing","master" etc. whereas the results returned from
-                    key_contents = remote_result[key_type][remote_user_id]
+                    # the remote server use "self_signing_keys", "master_keys" etc.
-                    key_type = key_type[:-5]  # Remove the "_keys" from the key type
+                    # Remove the "_keys" from the key type
+                    if remote_key_type.endswith("_keys"):
+                        remote_key_type = remote_key_type[:-5]
 
-                    yield self.store.set_e2e_cross_signing_key(
+                    # remote_user_dict is a dictionary in the form of
-                        user_id, key_type, key_contents
+                    # {
-                    )
+                    #   "user_id": {
+                    #     "master_keys": ...
+                    #   },
+                    #   ...
+                    # }
 
-                # The key_type variable passed to this function is in the form
+                    # Only extract the keys that pertain to the requested user
-                # "self_signing","master" etc. Whereas the results returned from
+                    key_content_list = remote_user_dict.get(user_id, {}).values()
-                # the remote server use "self_signing_keys", "master_keys" etc.
-                # Translate that here.
-                remote_key_type = key_type + "_keys"
 
-                key = remote_result.get(remote_key_type, {}).get(user_id)
+                    for key_content in key_content_list:
+                        # If the key_type here matches the key we're requesting,
+                        # then this is the key we want to return
+                        if remote_key_type == key_type:
+                            key = key_content
+
+                        # At the same time, save the key to the database for subsequent
+                        # queries
+                        yield self.store.set_e2e_cross_signing_key(
+                            user_id, remote_key_type, key_content
+                        )
             except (
                 HttpResponseException,
                 NotRetryingDestination,