max conns?

Dockers/xtream-proxy/src/config.js

@@ -77,7 +77,7 @@ function readConfigEntries() {
     }
 
     for (const url of validUrls) {
-      entries.push({ url, username, password });
+      entries.push({ url, username, password, entryId: index });
     }
   });
   return entries;
@@ -102,7 +102,12 @@ function reloadConfig() {
     seen.add(upstream.key);
 
     const existing = previous.get(upstream.key);
-    next.push(existing || upstream);
+    if (existing) {
+      existing.entryId = upstream.entryId;
+      next.push(existing);
+    } else {
+      next.push(upstream);
+    }
   }
 
   const removed = upstreams.filter((u) => !seen.has(u.key)).length;

Dockers/xtream-proxy/src/upstream-pool.js

@@ -26,13 +26,30 @@ function isBusy(upstream) {
 }
 
 function totalConnectionCapacity() {
-  let total = 0;
+  const perEntry = new Map();
 
   for (const upstream of getUpstreams()) {
+    const entryId = upstream.entryId ?? upstream.key;
     const maxCons = upstream.state.maxCons;
-    total += maxCons !== null && maxCons > 0 ? maxCons : 1;
+
+    if (!perEntry.has(entryId)) {
+      perEntry.set(entryId, maxCons);
+      continue;
     }
 
+    const current = perEntry.get(entryId);
+    if (maxCons !== null && maxCons > 0) {
+      perEntry.set(
+        entryId,
+        current !== null && current > 0 ? Math.max(current, maxCons) : maxCons
+      );
+    }
+  }
+
+  let total = 0;
+  for (const maxCons of perEntry.values()) {
+    total += maxCons !== null && maxCons > 0 ? maxCons : 1;
+  }
   return total;
 }
 

Dockers/xtream-proxy/src/upstream.js

@@ -19,7 +19,7 @@ function baseState() {
 }
 
 class Upstream {
-  constructor({ url, username, password }) {
+  constructor({ url, username, password, entryId }) {
     const parsed = new URL(url);
     parsed.hash = '';
     parsed.search = '';
@@ -27,6 +27,7 @@ class Upstream {
     this.basePath = parsed.pathname.replace(/\/+$/, '');
     this.username = username;
     this.password = password;
+    this.entryId = entryId;
     this.key = `${parsed.origin}${this.basePath}|${username}|${password}`;
     this.state = { ...baseState(), inFlight: 0 };
   }