Merge pull request #5505 from matrix-org/erikj/messages_worker

Support pagination API in client_reader worker
code_spécifique_watcha
Erik Johnston 6 years ago committed by GitHub
commit 5f8a612af1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      changelog.d/5505.feature
  2. 7
      docs/workers.rst
  3. 2
      synapse/app/client_reader.py

@ -0,0 +1 @@
Add support for handling pagination APIs on client reader worker.

@ -239,6 +239,13 @@ be routed to the same instance::
^/_matrix/client/(r0|unstable)/register$ ^/_matrix/client/(r0|unstable)/register$
Pagination requests can also be handled, but all requests with the same path
room must be routed to the same instance. Additionally, care must be taken to
ensure that the purge history admin API is not used while pagination requests
for the room are in flight::
^/_matrix/client/(api/v1|r0|unstable)/rooms/.*/messages$
``synapse.app.user_dir`` ``synapse.app.user_dir``
~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~

@ -52,6 +52,7 @@ from synapse.rest.client.v1.room import (
PublicRoomListRestServlet, PublicRoomListRestServlet,
RoomEventContextServlet, RoomEventContextServlet,
RoomMemberListRestServlet, RoomMemberListRestServlet,
RoomMessageListRestServlet,
RoomStateRestServlet, RoomStateRestServlet,
) )
from synapse.rest.client.v1.voip import VoipRestServlet from synapse.rest.client.v1.voip import VoipRestServlet
@ -109,6 +110,7 @@ class ClientReaderServer(HomeServer):
JoinedRoomMemberListRestServlet(self).register(resource) JoinedRoomMemberListRestServlet(self).register(resource)
RoomStateRestServlet(self).register(resource) RoomStateRestServlet(self).register(resource)
RoomEventContextServlet(self).register(resource) RoomEventContextServlet(self).register(resource)
RoomMessageListRestServlet(self).register(resource)
RegisterRestServlet(self).register(resource) RegisterRestServlet(self).register(resource)
LoginRestServlet(self).register(resource) LoginRestServlet(self).register(resource)
ThreepidRestServlet(self).register(resource) ThreepidRestServlet(self).register(resource)

Loading…
Cancel
Save