Real YouTube loading fix: never delay copy reconnect once the event is live; dump_extra on H264 copy IDR

relay.py

@@ -341,6 +341,10 @@ class Sender:
         enhanced=self.enhanced_advertisement(mode,candidate) if network else []
         if mode=='copy':
             video=['-c:v','copy']
+            # Repeat SPS/PPS on every IDR so a YouTube viewer who hits loading can
+            # resync without leaving the app. Video remains copy (no re-encode).
+            if not self.hevc_payload(candidate):
+                video += ['-bsf:v','dump_extra=freq=keyframe']
         else:
             width,height,bitrate=(1080,1920,'6000k') if mode=='fixed1080' else (720,1280,'4000k')
             # VIDEO_BITRATE was documented in the README but never read anywhere; it now caps the

youtube_manager.py

@@ -698,11 +698,25 @@ class ManagedYouTube:
             self.log(user or 'system', '[WATCHDOG] أُلغي تأجيل إعادة الاتصال (%d حدث) — %s' % (dropped, why))
         return dropped
 
+
+    def _yt_public(self, ev):
+        """Viewers can already open the watch URL — any delay is a YouTube loading spinner."""
+        if not ev:
+            return False
+        if ev.get('was_live'):
+            return True
+        return str(ev.get('youtube_status') or '') in ('live', 'testing', 'liveStarting')
     def start_sender(self,key):
-        # عقاب الوتيرة يجب أن يصمد أمام نقرات tick(): أي أن إعادة الاتصال المؤجّلة بسبب رفض
-        # الوجهة (187) لا تُبطلها دورة رصد جاءت بعد 15 ث. بدون هذا القفل يبقى التأجيل شكليًا
-        # لأن tick/drive_event يستدعيان start_sender كل دورة.
+        ev=self.journal.read()['events'].get(key)
+        public=self._yt_public(ev)
+        # عقاب الوتيرة يجب أن يصمد أمام نقرات tick() قبل أن يصبح الحدث علنيًا.
+        # بعد live أي تأخير = دائرة تحميل أمام المشاهد — نلغي القفل ونعيد copy فورًا.
         until=self.retry_at.get(key)
+        if public:
+            if until:
+                self.retry_at.pop(key, None)
+                self._gate_note_at.pop(key, None)
+            until=None
         if until and time.monotonic()<until:
             left=int(round(until-time.monotonic()))
             # الصمت هنا هو بالضبط «بالانتظار بلا سبب» الذي شكا منه المستخدم: القفل صحيح لكن يجب
@@ -766,7 +780,7 @@ class ManagedYouTube:
             return
         if hub.busy(ev['username']):
             return
-        if time.monotonic()-float(self._spawn_at.get(ev['username']) or 0)<8:
+        if (not public) and time.monotonic()-float(self._spawn_at.get(ev['username']) or 0)<8:
             return
         # لا نلمس entry هنا: بعد موت خيط الإرسال تُبقي tick() القيد الميت في self.senders،
         # و`entry['candidate']=None` على قيد ميت كان يرمي TypeError عند كل دورة مشغّل
@@ -812,7 +826,8 @@ class ManagedYouTube:
                 if not since:
                     entry['idle_since']=time.monotonic()
                     continue
-                if time.monotonic()-since<20:
+                grace=2.0 if self._yt_public(ev) else 20.0
+                if time.monotonic()-since<grace:
                     continue
                 self.log(ev.get('username') or key,
                          '[RELAY] @%s sender thread without FFmpeg; recycle'%ev.get('username'))
@@ -959,7 +974,11 @@ class ManagedYouTube:
             # Skip the idle wait right after a resolution change; otherwise keep polling.
             if restart_at and time.monotonic()-restart_at<30:restart_at=0.0;continue
             gap=float(getattr(sender,'last_source_gap',0) or 0)
-            wait=0.5 if gap>=8 else self._backoff(user)
+            ev_now=(self.journal.read()['events'].get(key) or {})
+            if self._yt_public(ev_now):
+                wait=0.5
+            else:
+                wait=0.5 if gap>=8 else self._backoff(user)
             if stop.wait(wait):return
     def mark_stream_stable(self, user):
         """الحافة تقبل التدفق: تُرمى نافذة العقاب وملاحظتها وعدّادها. تُستدعى من المرسل عند أول
@@ -1054,15 +1073,21 @@ class ManagedYouTube:
                 except Exception as e:
                     self.log(user, '[WATCHDOG] تعذر تجديد عنوان الاستقبال: ' + self.safe_error(e)[:120])
         if n >= 3:
-            # أرضية 20 ث × تصاعد هندسي: retry_min=1 في الصورة كان يجعل الطلعة الثالثة «2 ث»
-            # (لا شيء يتغيّر فعليًا)، لذا الحدّ الأدنى 20 ث ثم 40 و80 حتى 120.
-            wait = min(120.0, max(20.0, self.retry_min) * (2 ** (n - 3)))
-            self.retry[user] = max(self.retry.get(user, 0) or 0, wait)
-            for k in [k for k, ev in self.journal.read()['events'].items() if ev.get('username') == user]:
-                self.retry_at[k] = time.monotonic() + wait        # يقفل start_sender من tick() نفسه
-            self.log(user, '[WATCHDOG] الوجهة أغلقت الاتصال بعد %.0f ث (رمز %s) — المرة %d: تأجيل إعادة الاتصال إلى %d ث بدل النقر على حافة ترفض%s'
-                     % (lasted, code, n, int(self._backoff(user)),
-                        '؛ السبب المعلوم: الحدث لم يُشغَّل بعد' if not_started else ''))
+            public=any(self._yt_public(ev) for ev in _evs)
+            if public:
+                # الحدث أمام المشاهد: أي تأجيل = دائرة تحميل. نعيد copy على نفس المفتاح فورًا.
+                for k in [k for k, ev in self.journal.read()['events'].items() if ev.get('username') == user]:
+                    self.retry_at.pop(k, None)
+                self.retry[user] = self.retry_min
+                self.log(user, '[WATCHDOG] يوتيوب أغلق RTMPS والحدث ما زال live — إعادة copy فورًا على نفس المفتاح (بلا تأجيل %d×)'%n)
+            else:
+                wait = min(120.0, max(20.0, self.retry_min) * (2 ** (n - 3)))
+                self.retry[user] = max(self.retry.get(user, 0) or 0, wait)
+                for k in [k for k, ev in self.journal.read()['events'].items() if ev.get('username') == user]:
+                    self.retry_at[k] = time.monotonic() + wait
+                self.log(user, '[WATCHDOG] الوجهة أغلقت الاتصال بعد %.0f ث (رمز %s) — المرة %d: تأجيل إعادة الاتصال إلى %d ث بدل النقر على حافة ترفض%s'
+                         % (lasted, code, n, int(self._backoff(user)),
+                            '؛ السبب المعلوم: الحدث لم يُشغَّل بعد' if not_started else ''))
         return
 
     def _backoff(self,user):