summary refs log tree commit diff
path: root/synapse/handlers
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-02-01 10:30:03 +0000
committerErik Johnston <erik@matrix.org>2017-02-01 10:30:03 +0000
commit97479d0c5442f3a644b356c5dbc920bf2ca2c925 (patch)
treefa0e7ce4f192c10604a3c3256a8299b26cb30d85 /synapse/handlers
parentMerge pull request #1866 from matrix-org/erikj/device_list_fixes (diff)
downloadsynapse-97479d0c5442f3a644b356c5dbc920bf2ca2c925.tar.xz
Implement /keys/changes
Diffstat (limited to 'synapse/handlers')
-rw-r--r--synapse/handlers/device.py16
1 files changed, 16 insertions, 0 deletions
diff --git a/synapse/handlers/device.py b/synapse/handlers/device.py
index 7245d14fab..4a28d95967 100644
--- a/synapse/handlers/device.py
+++ b/synapse/handlers/device.py
@@ -221,6 +221,22 @@ class DeviceHandler(BaseHandler):
                 self.federation_sender.send_device_messages(host)
 
     @defer.inlineCallbacks
+    def get_user_ids_changed(self, user_id, from_device_key):
+        rooms = yield self.store.get_rooms_for_user(user_id)
+        room_ids = set(r.room_id for r in rooms)
+
+        user_ids_changed = set()
+        changed = yield self.store.get_user_whose_devices_changed(
+            from_device_key
+        )
+        for other_user_id in changed:
+            other_rooms = yield self.store.get_rooms_for_user(other_user_id)
+            if room_ids.intersection(e.room_id for e in other_rooms):
+                user_ids_changed.add(other_user_id)
+
+        defer.returnValue(user_ids_changed)
+
+    @defer.inlineCallbacks
     def _incoming_device_list_update(self, origin, edu_content):
         user_id = edu_content["user_id"]
         device_id = edu_content["device_id"]