diff options
author | Paul "LeoNerd" Evans <paul@matrix.org> | 2014-08-15 15:44:53 +0100 |
---|---|---|
committer | Paul "LeoNerd" Evans <paul@matrix.org> | 2014-08-15 15:44:53 +0100 |
commit | 3c532314ecec31c0fed718dbff80d8dc417f9fd2 (patch) | |
tree | b4403634c60457909e8834a6da773caacc808484 | |
parent | Create a room-nuking script as it's useful for emergency debugging (diff) | |
download | synapse-3c532314ecec31c0fed718dbff80d8dc417f9fd2.tar.xz |
Fix imsync's SELECT query to only find the rooms I'm actually joined in, not every room I have ever joined
Diffstat (limited to '')
-rw-r--r-- | synapse/storage/roommember.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/synapse/storage/roommember.py b/synapse/storage/roommember.py index ef73be4af4..c45d128f1b 100644 --- a/synapse/storage/roommember.py +++ b/synapse/storage/roommember.py @@ -111,9 +111,12 @@ class RoomMemberStore(SQLBaseStore): for membership in membership_list: args.append(membership) + # sub-select finds the row ID for the most recent (i.e. current) + # state change of this user per room, then the outer select finds those query = ("SELECT room_id, membership FROM room_memberships" - + " WHERE user_id=? AND " + where_membership - + " GROUP BY room_id ORDER BY id DESC") + + " WHERE id IN (SELECT MAX(id) FROM room_memberships" + + " WHERE user_id=? GROUP BY room_id)" + + " AND " + where_membership) return self._execute( self.cursor_to_dict, query, *args ) |