Temporarily disable worker mode [REVERT ME LATER]

This is a workaround various not yet solved inconsistencies in the 
presence hook implementation inside Synapse.

This commit needs to be reverted once we make a release with Synapse >= 1.34.0

Author: fredo

build/synapse/Dockerfile

@@ -24,6 +24,10 @@ RUN /synapse-venv/bin/pip install \
     docker-py \
     raiden-synapse-modules==${RAIDEN_SYNAPSE_MODULES}
 
+# XXX Temporary hot-patch while https://github.com/matrix-org/synapse/pull/9820 is not released yet -- note: this should
+# be run in  in workerless setup
+RUN sed -i 's/\(\s*\)if self.worker_type/\1if True or self.worker_type/' /synapse-venv/lib/python3.9/site-packages/raiden_synapse_modules/pfs_presence_router.py
+
 COPY eth_auth_provider.py /synapse-venv/lib/python3.9/site-packages/
 COPY admin_user_auth_provider.py /synapse-venv/lib/python3.9/site-packages/
 COPY synapse-entrypoint.sh /bin/

build/synapse/synapse-entrypoint.sh

@@ -10,6 +10,8 @@ TYPE="$1"
 shift
 
 if [[ $TYPE == 'worker' ]]; then
+  echo "WORKERS ARE DISABLED!"
+  exit 1
   WORKER="$1"
   shift
   CONFIG_PATH=$(/synapse-venv/bin/python /bin/render_config_template.py "$TYPE" --type "$WORKER")
@@ -19,7 +21,7 @@ elif [[ $TYPE == 'synapse' ]]; then
   /synapse-venv/bin/python /bin/render_config_template.py "$TYPE"
   /synapse-venv/bin/python -m synapse.app.homeserver --config-path /config/synapse.yaml --generate-keys
 
-  /synapse-venv/bin/python -m synapse.app.homeserver --config-path /config/synapse.yaml --config-path /config/workers/homeserver.yaml
+  /synapse-venv/bin/python -m synapse.app.homeserver --config-path /config/synapse.yaml
 else
   echo "Unknown run type: $TYPE"
   exit 1

config/synapse/synapse.template.yaml

@@ -44,9 +44,9 @@ log_config: "/config/synapse.log.config"
 ## Split worker specific settings
 
 # Handled by the federation_sender worker
-send_federation: False
+send_federation: true
 # Handled by the user_directory worker
-update_user_directory: False
+update_user_directory: true
 
 
 ## Ratelimiting

docker-compose.yml

@@ -164,78 +164,6 @@ services:
       - "traefik.http.middlewares.metrics-access-control.ipwhitelist.sourcerange=${CIDR_ALLOW_METRICS}"
       - "purge_restart_container=true"
 
-  generic_worker:
-    << : *IMAGE_SYNAPSE_VERSION
-    restart: always
-    volumes:
-      - ./config/synapse:/config
-      - ${DATA_DIR:-./data}/synapse:/data
-      - /var/run/docker.sock:/var/run/docker.sock
-    environment:
-      - SERVER_NAME=transport.${SERVER_NAME}
-      - SERVICE_REGISTRY
-      - ETH_RPC
-    depends_on:
-      synapse:
-        condition: service_healthy
-    command: ["worker", "generic_worker"]
-    scale: ${WORKER_COUNT:-4}
-    <<: *log-config
-    labels:
-      - "traefik.enable=true"
-      - "traefik.http.routers.generic_worker.rule=Host(`transport.${SERVER_NAME}`) && (PathPrefix(`/_matrix/client/versions`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0)}/initialSync`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0)}/rooms/{room:[^/]+}/initialSync`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/account/3pid`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/join/`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/joined_groups`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/keys/changes`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/keys/query`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/login`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/profile/`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/publicised_groups`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/publicRooms`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/rooms/{room:.*}/context/{context:.*}`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/rooms/{room:.*}/joined_members`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/rooms/{room:.*}/members`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/rooms/{room:.*}/send`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/rooms/{room:.*}/state`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/rooms/{room:.*}/{action:(join|invite|leave|ban|unban|kick)}`) || PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/voip/turnServer`) || PathPrefix(`/_matrix/client/{version:(api/v1|v2_alpha|r0)}/events`) || PathPrefix(`/_matrix/client/{version:(v2_alpha|r0)}/sync`) || PathPrefix(`/_matrix/federation/v1/{type:(backfill|event|event_auth|exchange_third_party_invite|get_groups_publicised|get_missing_events|invite|make_join|make_leave|publicRoom|query|query_auth|send|send_join|send_leave|state|state_ids|user/devices)}`) || PathPrefix(`/_matrix/federation/v2/{type:(invite|send_join|send_leave)}`) || PathPrefix(`/_matrix/key/v2/query`))"
-      - "traefik.http.routers.generic_worker.tls=true"
-      - "traefik.http.routers.generic_worker.tls.certresolver=le"
-      - "traefik.http.routers.generic_worker.service=generic_worker"
-      - "traefik.http.services.generic_worker.loadbalancer.server.port=8008"
-      - "traefik.http.services.generic_worker.loadbalancer.sticky=true"
-
-  federation_sender:
-    << : *IMAGE_SYNAPSE_VERSION
-    restart: always
-    volumes:
-      - ./config/synapse:/config
-      - ${DATA_DIR:-./data}/synapse:/data
-      - /var/run/docker.sock:/var/run/docker.sock
-    environment:
-      - SERVER_NAME=transport.${SERVER_NAME}
-      - SERVICE_REGISTRY
-      - ETH_RPC
-    depends_on:
-      synapse:
-        condition: service_healthy
-    command: ["worker", "federation_sender"]
-    healthcheck:
-      disable: true
-    << : *log-config
-    labels:
-      - "purge_restart_container=true"
-
-  user_dir:
-    << : *IMAGE_SYNAPSE_VERSION
-    restart: always
-    volumes:
-      - ./config/synapse:/config
-      - ${DATA_DIR:-./data}/synapse:/data
-      - /var/run/docker.sock:/var/run/docker.sock
-    environment:
-      - SERVER_NAME=transport.${SERVER_NAME}
-      - SERVICE_REGISTRY
-      - ETH_RPC
-    depends_on:
-      synapse:
-        condition: service_healthy
-    command: ["worker", "user_dir"]
-    scale: ${WORKER_COUNT:-4}
-    << : *log-config
-    labels:
-      - "traefik.enable=true"
-      - "traefik.http.routers.user_dir.rule=Host(`transport.${SERVER_NAME}`) && PathPrefix(`/_matrix/client/{version:(api/v1|r0|unstable)}/user_directory/search`)"
-      - "traefik.http.routers.user_dir.tls=true"
-      - "traefik.http.routers.user_dir.tls.certresolver=le"
-      - "traefik.http.routers.user_dir.service=user_dir"
-      - "traefik.http.services.user_dir.loadbalancer.server.port=8008"
-      - "traefik.http.services.user_dir.loadbalancer.sticky=true"
 
   db:
     << : *IMAGE_DB_VERSION