Switch to using a delta file

changelog.d/6363.bugfix

@@ -0,0 +1 @@
+Fix `to_device` stream ID getting reset every time Synapse restarts, which had the potential to cause unable to decrypt errors.

changelog.d/6375.bugfix

@@ -0,0 +1 @@
+Fix `to_device` stream ID getting reset every time Synapse restarts, which had the potential to cause unable to decrypt errors.

synapse/rest/client/v1/room.py

@@ -845,32 +845,6 @@ class SearchRestServlet(RestServlet):
 
         return 200, results
 
-class JoinedManyRoomMemberListRestServlet(RestServlet):
-    PATTERNS = client_patterns("/joined_members$", v1=True)
-
-    def __init__(self, hs):
-        super(JoinedManyRoomMemberListRestServlet, self).__init__()
-        self.message_handler = hs.get_message_handler()
-        self.auth = hs.get_auth()
-
-    async def on_POST(self, request):
-        requester = await self.auth.get_user_by_req(request)
-
-        content = parse_json_object_from_request(request)
-
-        if content.get("rooms", None) is None:
-            raise SynapseError(400, "'rooms' not given in request body.", errcode=Codes.BAD_JSON)    
-
-        result = {}
-
-        for room_id in set(content["rooms"]):
-            if not isinstance(room_id, str):
-                raise SynapseError(400, "Invalid room_id given.", errcode=Codes.BAD_JSON)    
-            result[room_id] = await self.message_handler.get_joined_members(
-                requester, room_id
-            )
-
-        return 200, {"rooms": result}
 
 class JoinedRoomsRestServlet(RestServlet):
     PATTERNS = client_patterns("/joined_rooms$", v1=True)
@@ -926,7 +900,6 @@ def register_servlets(hs, http_server):
     RoomCreateRestServlet(hs).register(http_server)
     RoomMemberListRestServlet(hs).register(http_server)
     JoinedRoomMemberListRestServlet(hs).register(http_server)
-    JoinedManyRoomMemberListRestServlet(hs).register(http_server)
     RoomMessageListRestServlet(hs).register(http_server)
     JoinRoomAliasServlet(hs).register(http_server)
     RoomForgetRestServlet(hs).register(http_server)

synapse/storage/data_stores/main/schema/delta/56/device_stream_id.sql

@@ -0,0 +1,5 @@
+INSERT INTO device_max_stream_id (stream_id)
+SELECT 0
+WHERE NOT EXISTS (
+    SELECT 1 FROM device_max_stream_id
+);