summary refs log tree commit diff
path: root/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix
diff options
context:
space:
mode:
Diffstat (limited to 'host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix')
-rw-r--r--host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix50
1 files changed, 0 insertions, 50 deletions
diff --git a/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix b/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix
deleted file mode 100644
index 6b0d2c2..0000000
--- a/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix
+++ /dev/null
@@ -1,50 +0,0 @@
-{ 
-  count,
-  separateEventWriters ? 1,
-  separateTypingWriters ? 1, 
-  separateToDeviceWriters ? 1, 
-  separateAccountDataWriters ? 1,
-  separateReceiptsWriters ? 1,
-  separatePresenceWriters ? 1,
-  separatePusherWriters ? 1,
-}:
-{ config, pkgs, lib, ... }:
-let 
-  eventWriters = lib.range 0 (count - 1);
-  typingWriters = lib.range 0 (count - 1);
-  deviceWriters = lib.range 0 (count - 1);
-  accountDataWriters = lib.range 0 (count - 1);
-  receiptsWriters = lib.range 0 (count - 1);
-  presenceWriters = lib.range 0 (count - 1);
-  pusherWriters = lib.range 0 (count - 1);
-in
-{
-  services.matrix-synapse = {
-    settings = {
-      instance_map = lib.listToAttrs (lib.map (port: {
-        name = "stream-writer-${toString port}";
-        value = {
-          path = "/run/matrix-synapse/stream-writer-${toString port}.sock";
-        };
-      }) federationSenders);
-
-      stream_writers = {
-        events = lib.map (port: "stream-writer-events-${toString port}") federationSenders;
-        typing = lib.map (port: "stream-writer-typing-${toString port}") typingWriters;
-        to_device = lib.map (port: "stream-writer-to_device-${toString port}") deviceWriters;
-        account_data = lib.map (port: "stream-writer-account_data-${toString port}") accountDataWriters;
-        receipts = lib.map (port: "stream-writer-receipts-${toString port}") receiptsWriters;
-        presence = lib.map (port: "stream-writer-presence-${toString port}") presenceWriters;
-        push_rules = lib.map (port: "stream-writer-push_rules-${toString port}") pusherWriters;
-      };
-    };
-
-    workers = lib.listToAttrs (lib.map (port: {
-      name = "stream-writerr-${toString port}";
-      value = {
-        worker_app = "synapse.app.generic_worker";
-        worker_listeners = [ ];
-      };
-    }) federationSenders);
-  };
-}
\ No newline at end of file