ServerState: filter out inactive proxies properly

picoHz · Sep 13, 2023 · df773d5 · df773d5
1 parent ee26332
commit df773d5
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/taxy/src/server/state.rs b/taxy/src/server/state.rs
@@ -224,7 +224,9 @@ impl ServerState {
             let proxies = self
                 .proxies
                 .entries()
-                .filter(|entry: &&ProxyEntry| entry.proxy.ports.contains(&ctx.entry.id))
+                .filter(|entry: &&ProxyEntry| {
+                    entry.proxy.active && entry.proxy.ports.contains(&ctx.entry.id)
+                })
                 .cloned()
                 .collect();
             let _ = ctx.setup(&self.certs, proxies).await;
@@ -242,7 +244,9 @@ impl ServerState {
         let proxies = self
             .proxies
             .entries()
-            .filter(|entry: &&ProxyEntry| entry.proxy.ports.contains(&ctx.entry.id))
+            .filter(|entry: &&ProxyEntry| {
+                entry.proxy.active && entry.proxy.ports.contains(&ctx.entry.id)
+            })
             .cloned()
             .collect();
         let span = span!(Level::INFO, "port", resource_id = ctx.entry.id.to_string());
@@ -284,7 +288,9 @@ impl ServerState {
             let proxies = self
                 .proxies
                 .entries()
-                .filter(|entry: &&ProxyEntry| entry.proxy.ports.contains(&ctx.entry.id))
+                .filter(|entry: &&ProxyEntry| {
+                    entry.proxy.active && entry.proxy.ports.contains(&ctx.entry.id)
+                })
                 .cloned()
                 .collect();
             let span = span!(Level::INFO, "port", resource_id = ctx.entry.id.to_string());