{ config, pkgs, lib, ... }: let cfg = config.services.matrix-synapse; workers = lib.range 0 (cfg.federationReaders - 1); routes = [ "~ ^/_matrix/federation/(v1|v2)/event/" "~ ^/_matrix/federation/(v1|v2)/state/" "~ ^/_matrix/federation/(v1|v2)/state_ids/" "~ ^/_matrix/federation/(v1|v2)/backfill/" "~ ^/_matrix/federation/(v1|v2)/get_missing_events/" "~ ^/_matrix/federation/(v1|v2)/publicRooms" "~ ^/_matrix/federation/(v1|v2)/query/" "~ ^/_matrix/federation/(v1|v2)/make_join/" "~ ^/_matrix/federation/(v1|v2)/make_leave/" "~ ^/_matrix/federation/(v1|v2)/send_join/" "~ ^/_matrix/federation/(v1|v2)/send_leave/" "~ ^/_matrix/federation/v1/make_knock/" "~ ^/_matrix/federation/v1/send_knock/" "~ ^/_matrix/federation/(v1|v2)/invite/" "~ ^/_matrix/federation/(v1|v2)/query_auth/" "~ ^/_matrix/federation/(v1|v2)/event_auth/" "~ ^/_matrix/federation/v1/timestamp_to_event/" "~ ^/_matrix/federation/(v1|v2)/exchange_third_party_invite/" "~ ^/_matrix/federation/(v1|v2)/user/devices/" "~ ^/_matrix/federation/(v1|v2)/get_groups_publicised$" "~ ^/_matrix/key/v2/query" ]; in { config = lib.mkIf (cfg.federationReaders > 0) { services.matrix-synapse = { settings = { instance_map = lib.listToAttrs ( lib.map (index: { name = "federation_reader-${toString index}"; value = { path = "/run/matrix-synapse/federation_reader-${toString index}.sock"; }; }) workers ); }; workers = lib.listToAttrs ( lib.map (index: { name = "federation_reader-${toString index}"; value = { worker_app = "synapse.app.generic_worker"; worker_listeners = [ { type = "http"; path = "/run/matrix-synapse/federation_reader-${toString index}.sock"; resources = [ { names = [ "replication" ]; compress = false; } ]; } { type = "http"; path = "/run/matrix-synapse/federation_reader-federation-${toString index}.sock"; mode = "666"; resources = [ { names = [ "federation" ]; compress = false; } ]; } ]; database = ( import ../db.nix { workerName = "federation_reader-${toString index}"; dbGroup = "medium"; } ); }; }) workers ); }; services.nginx.upstreams."federation_reader" = { extraConfig = '' keepalive 32; ip_hash; ''; servers = lib.listToAttrs ( lib.map (index: { name = "unix:/run/matrix-synapse/federation_reader-federation-${toString index}.sock"; value = { max_fails = 0; }; }) workers ); }; services.nginx.virtualHosts."${cfg.nginxVirtualHostName}".locations = lib.listToAttrs ( lib.map (route: { name = route; value = { proxyPass = "http://federation_reader"; }; }) routes ); }; }