Skip to content
Snippets Groups Projects
Unverified Commit a8f7ed28 authored by Erik Johnston's avatar Erik Johnston Committed by GitHub
Browse files

Typing worker needs to handle stream update requests (#7967)

IIRC this doesn't break tests because its only hit on reconnection, or something.

Basically, when a process needs to fetch missing updates for the `typing` stream it needs to query the writer instance via HTTP (as we don't write typing notifications to the DB), the problem was that the endpoint (`streams`) was only registered on master and specifically not on the typing writer worker. 
parent f57b99af
No related branches found
No related tags found
No related merge requests found
Fix experimental support for moving typing off master when worker is restarted, which is broken in v1.18.0-rc1.
...@@ -39,10 +39,10 @@ class ReplicationRestResource(JsonResource): ...@@ -39,10 +39,10 @@ class ReplicationRestResource(JsonResource):
federation.register_servlets(hs, self) federation.register_servlets(hs, self)
presence.register_servlets(hs, self) presence.register_servlets(hs, self)
membership.register_servlets(hs, self) membership.register_servlets(hs, self)
streams.register_servlets(hs, self)
# The following can't currently be instantiated on workers. # The following can't currently be instantiated on workers.
if hs.config.worker.worker_app is None: if hs.config.worker.worker_app is None:
login.register_servlets(hs, self) login.register_servlets(hs, self)
register.register_servlets(hs, self) register.register_servlets(hs, self)
devices.register_servlets(hs, self) devices.register_servlets(hs, self)
streams.register_servlets(hs, self)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment