{ config, pkgs, lib, ... }: let cfg = config.services.matrix-synapse; workers = lib.range 0 (cfg.mediaRepoWorkers - 1); routes = [ "~ ^/_matrix/media/" "~ ^/_matrix/client/v1/media/" "~ ^/_matrix/federation/v1/media/" "~ ^/_synapse/admin/v1/purge_media_cache$" "~ ^/_synapse/admin/v1/room/.*/media.*$" "~ ^/_synapse/admin/v1/user/.*/media.*$" "~ ^/_synapse/admin/v1/media/.*$" "~ ^/_synapse/admin/v1/quarantine_media/.*$" ]; in { config = lib.mkIf (cfg.mediaRepoWorkers > 0) { services.matrix-synapse = { settings = { instance_map = lib.listToAttrs ( lib.map (index: { name = "media_repo-${toString index}"; value = { path = "/run/matrix-synapse/media_repo-${toString index}.sock"; }; }) workers ); media_instance_running_background_jobs = "media_repo-0"; enable_media_repo = false; }; workers = lib.listToAttrs ( lib.map (index: { name = "media_repo-${toString index}"; value = { worker_app = "synapse.app.generic_worker"; worker_listeners = [ { type = "http"; path = "/run/matrix-synapse/media_repo-${toString index}.sock"; resources = [ { names = [ "replication" ]; compress = false; } ]; } { type = "http"; path = "/run/matrix-synapse/media_repo-media-${toString index}.sock"; mode = "666"; resources = [ { names = [ "media" ]; compress = false; } ]; } ]; database = ( import ../db.nix { workerName = "media_repo-${toString index}"; dbGroup = "solo"; } ); enable_media_repo = true; }; }) workers ); }; services.nginx.upstreams."media_repo" = { extraConfig = '' keepalive 32; ''; servers = lib.listToAttrs ( lib.map (index: { name = "unix:/run/matrix-synapse/media_repo-media-${toString index}.sock"; value = { max_fails = 0; }; }) workers ); }; services.nginx.virtualHosts."${cfg.nginxVirtualHostName}".locations = lib.listToAttrs ( lib.map (route: { name = route; value = { proxyPass = "http://media_repo"; extraConfig = '' client_max_body_size 500M; ''; }; }) routes ); }; }