Prayer: 0be4ca6 engine; no concurrent cap (MAX=0)

ingest.py

@@ -35,12 +35,15 @@ def max_concurrent_relays():
     not a pass. Operators may raise MAX_CONCURRENT_RELAYS; health reports the
     value actually in force. Ceiling 8 is only a fork-bomb guard.
     """
-    raw = os.getenv('MAX_CONCURRENT_RELAYS') or os.getenv('YOUTUBE_MAX_EVENTS') or '2'
+    raw = os.getenv('MAX_CONCURRENT_RELAYS')
+    if raw is None or str(raw).strip() == '':
+        raw = os.getenv('YOUTUBE_MAX_EVENTS') or '0'
     try:
         n = int(str(raw).strip())
     except (TypeError, ValueError):
-        n = 2
-    return max(1, min(n, 8))
+        n = 0
+    # 0 = every LIVE account may copy (one FFmpeg per user). No hidden ceiling.
+    return n if n > 0 else 0
 
 
 def format_session_title(broadcaster, when=None):
@@ -147,7 +150,10 @@ class RelayHub:
         with self.lock:
             n = sum(1 for u, v in self.slots.items()
                     if u != except_user and self._ffmpeg_alive(v))
-            return n >= max_concurrent_relays()
+            cap = max_concurrent_relays()
+            if cap <= 0:
+                return False
+            return n >= cap
 
     def env_key_busy(self, except_user=None):
         """A single env stream key can only accept one publisher (any owner)."""

youtube_manager.py

@@ -45,7 +45,12 @@ class ManagedYouTube:
         # إيقاع إعادة المحاولة عندما تكون تيك توك «مباشرة» بلا مرشّحات (لحظات انتقال جولات PK):
         # كان الحدث ينتظر دورة المشغّل كاملة (30ث) مع كاش رصد قديم، فبدا «معلّقًا على يوتيوب».
         self.source_retry=max(5,int(os.getenv('YOUTUBE_SOURCE_RETRY',str(min(15,self.scan)))))
-        self.max_events=max(1,int(os.getenv('YOUTUBE_MAX_EVENTS') or max_concurrent_relays()))
+        try:
+            self.max_events=int(os.getenv('YOUTUBE_MAX_EVENTS') or 0)
+        except (TypeError, ValueError):
+            self.max_events=0
+        if self.max_events<=0:
+            self.max_events=int(max_concurrent_relays() or 0)
         self.last_logged=None;self.status_text='متوقف'
         # Written in _select_source / _skip_note; declared here so a fresh manager never has to
         # rely on getattr() defaults (and so the reason survives the first skip).
@@ -1233,7 +1238,7 @@ class ManagedYouTube:
                 return False
             if any(e.get('username')==user for e in d['events'].values()):
                 return False
-            if len(d['events'])>=self.max_events:
+            if self.max_events>0 and len(d['events'])>=self.max_events:
                 return False
             key=user+':'+str(obs['room_id'])
             entry=next((h for h in d['history'] if h.get('session_key')==key),None)
@@ -1328,7 +1333,7 @@ class ManagedYouTube:
         # 2) Discover new live sessions, one event per account, up to the concurrency cap.
         cap=self.max_events;active=len(d['events']);capped=False
         for user in accounts:
-            if active>=cap:capped=True;break
+            if cap>0 and active>=cap:capped=True;break
             if any(e['username']==user for e in d['events'].values()):continue
             # رفض الهوية (توكن منتهٍ) لا يُعالَج بوتيرة الرصد: كل دورة كانت تضرب تيك توك
             # برفض مؤكد (~10/د على خمسة حسابات) وتُغرق السجل حتى وهو مكبوت. إيقاف لكل