تنبيه بدء البثّ المباشر إلى تيليغرام + حذف الحسابين غير الموجودين

- telegram_api: notify_live_start()/notify_targets()/live_start_text() — رسالة باسم
المذيع والتاريخ والوقت إلى القناة والحساب الشخصي، مرة لكل بثّ (منع التكرار بـroom_id
في السجلّ الدائم)، وأي فشل يُسجَّل ولا يرمي استثناءً.
- app.py: خطّاف في حلقة المراقبة قبل أول اتصال بالمصدر + POST /api/telegram/notify-test.
- index.html: زرّ تجربة التنبيه وسطر حالة 🔔 في لوحة تيليغرام.
- Dockerfile/variables.env: LIVE_NOTIFY=on, LIVE_NOTIFY_TARGETS=both, LIVE_NOTIFY_TEXT.
- اختبارات §18 (33) ⇒ 159/159.

Dockerfile

@@ -98,6 +98,12 @@ ENV TIKTOK_TT_TARGET_IDC=useast1a
 # مع سبب واضح في الطابور، فلا تضيع رفعة غيغابايت لتُرفض في النهاية.
 # ARCHIVE_PART_MB=0 ⇒ تلقائي: أي ملف يتجاوز 95% من سقف الرفع الحالي يُقسَّم
 # بـ ffmpeg -c copy (بلا إعادة ترميز) وتُرسل أجزاؤه ألبومًا واحدًا (sendMediaGroup).
+# تنبيه بدء البثّ: حين يكتشف المراقب أنّ مذيعًا صار مباشرًا تصل رسالة إلى تيليغرام
+# باسم المذيع وتاريخ اليوم ووقته (منطقة TZ). تُبعث **مرة واحدة لكل بثّ** لا لكل
+# مقطع، ولا تكرار بعد إعادة الإقلاع (معرّف الغرفة محفوظ في السجلّ الدائم).
+# LIVE_NOTIFY_TARGETS: both = القناة والحساب الشخصي | channel | backup.
+# LIVE_NOTIFY_TEXT: قالب اختياري بالمفاتيح {name} {username} {nickname} {live_title}
+# {date} {time} {room_id} — فارغ ⇒ النصّ الافتراضي.
 ENV ARCHIVE_ENABLED=on \
     ARCHIVE_DELETE_AFTER_UPLOAD=on \
     ARCHIVE_PROTECT_QUEUE=on \
@@ -112,6 +118,9 @@ ENV ARCHIVE_ENABLED=on \
     TELEGRAM_REQUIRE_BACKUP=on \
     TELEGRAM_SILENT=off \
     TELEGRAM_MIN_CHAT_INTERVAL=4 \
+    LIVE_NOTIFY=on \
+    LIVE_NOTIFY_TARGETS=both \
+    LIVE_NOTIFY_TEXT= \
     TELEGRAM_LOCAL_PORT=8081 \
     TELEGRAM_LOCAL_URL=http://127.0.0.1:8081 \
     TZ=Asia/Baghdad

README.md

@@ -52,6 +52,34 @@ pinned: false
 * ملاحظة تقنية مُثبتة بالتجربة: حقل الملف داخل `InputMedia` يجب أن يكون `media` لا `video`،
   وإلا ردّ الخادم `can't parse InputMedia: media not found`.
 
+## تنبيه بدء البثّ المباشر
+
+حين يكتشف المراقب أنّ أحد المذيعين صار **مباشرًا** تصل رسالة إلى تيليغرام فورًا،
+قبل أول محاولة اتصال بمصدر الفيديو:
+
+```
+🔴 أحمد (@ahmedbarbooka2) بدأ بثًّا مباشرًا
+📅 10-10-2026 · ⏰ 20:30
+📝 سهرة الليلة
+```
+
+* **الوجهة:** القناة **و** الحساب الشخصي معًا (`LIVE_NOTIFY_TARGETS=both` الافتراضي؛
+  `channel` أو `backup` لوجهة واحدة).
+* **المحتوى:** لقب المذيع كما يظهر في تيك توك (وإلا اسم المستخدم)، ‏`@username`،
+  تاريخ اليوم ووقته بمنطقة `TZ=Asia/Baghdad`، وعنوان البثّ إن وُجد.
+* **مرة واحدة لكل بثّ:** لا لكل مقطع (البثّ يتجزّأ عند انقطاع المصدر)، ولا بعد إعادة
+  الإقلاع (معرّف الغرفة محفوظ في `telegram-api-state.json`). حين يعود المذيع إلى
+  «البث منتهٍ» ثم يبدأ بثًّا جديدًا يُعلَن من جديد.
+* **بلا مخاطرة:** التنبيه خدمة إضافية — أي فشل إرسال يُسجَّل في سجلّ التطبيق ولا
+  يوقف التسجيل ولا الأرشفة، ولا تُعاد المحاولة (حتى لا تتكرّر الرسالة).
+* **بلا رسالة انتهاء:** المطلوب كان إعلان البدء فقط، فلا رسالة عند انتهاء البثّ ولا
+  عند جهوز الأرشيف (الأرشيف يصل كالمعتاد بملفه أو ألبومه).
+* **القالب:** `LIVE_NOTIFY_TEXT` بمفاتيح `{name} {nickname} {username} {live_title}
+  {title} {date} {time} {room_id}`، و`LIVE_NOTIFY=off` يطفئ التنبيه.
+* **التجربة:** زرّ **تجربة تنبيه بدء البثّ** في لوحة تيليغرام (أو
+  `POST /api/telegram/notify-test`) يرسل نموذجًا مُعلَّمًا كرسالة تجريبية إلى الوجهات
+  المضبوطة، ولا يلوّث مانع التكرار.
+
 ## V15: اعتماد وجهة جديدة دون ضياع الأرشيف
 
 1. اضغط **فحص الوجهة والبوت** لعرض الوجهة الموجودة في Secrets والوجهة المعتمدة السابقة. الفحص للقراءة فقط ولا يغيّر الربط.
@@ -220,6 +248,9 @@ ffmpeg -i in.flv -map 0:v:0 -map 0:a:0? -c copy -tag:v avc3 -movflags +faststart
 | `TELEGRAM_SEND_AS` | `auto` | `auto` فيديو ثم ملف · `video` · `document` |
 | `TELEGRAM_SILENT` | `off` | `on` = إرسال بلا إشعار للمشتركين |
 | `TELEGRAM_MIN_CHAT_INTERVAL` | `4` | ثوانٍ بين إرسالين للمحادثة نفسها |
+| `LIVE_NOTIFY` | `on` | تنبيه «بدأ بثًّا مباشرًا» بالاسم والتاريخ والوقت |
+| `LIVE_NOTIFY_TARGETS` | `both` | `both` = القناة والحساب الشخصي / `channel` / `backup` |
+| `LIVE_NOTIFY_TEXT` | _(فارغ)_ | قالب رسالة التنبيه (`{name} {username} {date} {time} …`) |
 | `ARCHIVE_PROTECT_QUEUE` | `on` | منع التنظيف من حذف ملف لم يُرسل |
 | `ARCHIVE_MIN_MB` | `5` | أصغر حجم يستحق الإرسال |
 | `ARCHIVE_MAX_ATTEMPTS` | `6` | عدد المحاولات قبل التوقف مع إبقاء الملف |

VARIABLES.md

@@ -51,6 +51,11 @@
 | `TELEGRAM_SEND_AS` | `auto` | `auto`: `sendVideo` أولًا (مشغّل داخل القناة) ثم `sendDocument` عند الرفض. `video` أو `document` لإجبار أحدهما. |
 | `TELEGRAM_SILENT` | `off` | `on` = إرسال بلا إشعار للمشتركين (`disable_notification`). |
 | `TELEGRAM_MIN_CHAT_INTERVAL` | `4` | أقل فاصلة بالثواني بين إرسالين للمحادثة نفسها. حارس معدل يمنع 429 عند جهوزية عدة ملفات معًا. |
+| `LIVE_NOTIFY` | `on` | تنبيه «بدأ بثًّا مباشرًا» إلى تيليغرام باسم المذيع وتاريخ اليوم ووقته. ‏`off` يوقفه **بلا أي أثر على التسجيل أو الأرشفة**. |
+| `LIVE_NOTIFY_TARGETS` | `both` | وجهة التنبيه: `both` = القناة **و** الحساب الشخصي (`TELEGRAM_CHAT_ID` + `TELEGRAM_BACKUP_CHAT_ID`)، أو `channel`، أو `backup`. |
+| `LIVE_NOTIFY_TEXT` | _(فارغ)_ | قالب اختياري بمفاتيح `{name}` `{nickname}` `{username}` `{live_title}` `{title}` `{date}` `{time}` `{room_id}`. فارغ ⇒ النصّ الافتراضي: «🔴 الاسم (@المستخدم) بدأ بثًّا مباشرًا / 📅 التاريخ · ⏰ الوقت» ويُضاف سطر العنوان إن وُجد. مفتاح غير معروف يبقى كما هو ولا يُسقط الرسالة. |
+
+**كيف لا يتكرّر التنبيه:** يُبعث **مرة واحدة لكل بثّ** لا لكل مقطع — البثّ الواحد يتجزّأ إلى عدة ملفات عند انقطاع المصدر ثم عودته، وإعادة الإعلان إزعاج. المنع على طبقتين: في ذاكرة المراقب (يُمسح حين يعود المذيع إلى «البث منتهٍ» فيُعلَن بثّه القادم)، وفي السجلّ الدائم `telegram-api-state.json` بمعرّف الغرفة `room_id` (فلا تكرار بعد إعادة إقلاع أثناء بثّ قائم). ومفتاح غير معروف في القالب لا يُسقط الرسالة، وأي فشل إرسال يُسجَّل في سجلّ التطبيق ولا يوقف التسجيل أبدًا. للتجربة من اللوحة: زرّ **تجربة تنبيه بدء البثّ** (أو `POST /api/telegram/notify-test`) يرسل نموذجًا مُعلَّمًا كرسالة تجريبية.
 | `TELEGRAM_LOCAL_URL` | `http://127.0.0.1:8081` | عنوان خادم Bot API المحلي. التطبيق يفحصه كل 60 ثانية ويستعمله إن أجاب. |
 | `TELEGRAM_LOCAL_PORT` | `8081` | المنفذ الذي يشغّل عليه `entrypoint.sh` الخادم المحلي. |
 | `TELEGRAM_UPLOAD_TIMEOUT` | *(محسوب)* | مهلة الإرسال بالثواني. تُحسب تلقائيًا من الحجم (~4 دقائق/غيغابايت + هامش). |

app.py

@@ -347,6 +347,9 @@ PROTECT_QUEUE=os.getenv('ARCHIVE_PROTECT_QUEUE','on').strip().lower() in ('1','o
 # 0 يُعطّل الضمّ ويرفع كل ملف فور جهوزه.
 JOIN_WINDOW=max(0,int(os.getenv('ARCHIVE_JOIN_WINDOW','300') or 0))
 _live_meta={}
+# تنبيه «بدأ بثًّا مباشرًا»: مرة واحدة لكل بثّ. المفتاح اسم المذيع والقيمة معرّف
+# الغرفة (أو True إن لم يُعرف بعد)؛ يُمسح حين ينتهي البثّ فيُعلَن البثّ القادم.
+_live_seen={}
 _NICKS=ROOT/'nicknames.json'
 
 def load_nicknames():
@@ -1426,7 +1429,18 @@ def worker(user,stop):
                 remember_nickname(user,known.get('nickname'))
             except Exception:pass
             if not urls:
+                _live_seen.pop(user,None)
                 update(user,status='البث منتهٍ');stop.wait(INTERVAL);continue
+            # تنبيه بدء البثّ قبل أول محاولة اتصال: مرة لكل بثّ لا لكل مقطع (البثّ
+            # الواحد يتجزّأ عند انقطاع المصدر)، ومنع التكرار قائم أيضًا في
+            # telegram_api بمعرّف الغرفة حتى لو أُعيد إقلاع البرنامج أثناء البثّ.
+            # أي فشل هنا لا يوقف التسجيل: التنبيه خدمة إضافية لا شرط.
+            if not _live_seen.get(user):
+                meta=_live_meta.get(user) or {}
+                room=str(meta.get('room_id') or '')
+                _live_seen[user]=room or True
+                try:telegram.notify_live_start(user,meta,room)
+                except Exception:log(user,'تعذّر إرسال تنبيه بدء البثّ')
             update(user,status='جاري الاتصال بمصدر الفيديو');ok=False
             for url in urls:
                 if stop.is_set():break
@@ -1475,6 +1489,17 @@ def telegram_check():
         msg=str(e) if isinstance(e,(APIError,RuntimeError,ValueError)) else 'تعذر فحص وجهة تيليغرام'
         raise HTTPException(400,msg)
 
+@app.post('/api/telegram/notify-test')
+def telegram_notify_test():
+    """زرّ تجربة: يرسل نموذج تنبيه بدء البثّ إلى الوجهات المضبوطة (بلا بثّ فعلي)."""
+    try:
+        ok=telegram.notify_live_start('example',{'nickname':'مثال','live_title':'تجربة تنبيه بدء البثّ'},test=True)
+        return {'ok':bool(ok),'targets':telegram.notify_targets()}
+    except Exception as e:
+        from telegram_api import APIError
+        msg=str(e) if isinstance(e,(APIError,RuntimeError,ValueError)) else 'تعذر إرسال تنبيه تجريبي'
+        raise HTTPException(400,msg)
+
 class TelegramChannelConfirmation(BaseModel):
     channel_id:str
 @app.post('/api/telegram/channel')

index.html

@@ -30,7 +30,7 @@ textarea,select{font:inherit;background:#0c1220;color:#e4eaf7;border:1px solid #
 </section>
 <section class="panel"><h2>ربط قناة تيليغرام</h2>
 <p>يوتيوب أُلغي من هذا المشروع نهائيًا. الوجهة الآن <b>تيليغرام</b>: تُقرأ من السرّين <code dir="ltr">TELEGRAM_CHAT_ID</code> (القناة) و<code dir="ltr">TELEGRAM_BACKUP_CHAT_ID</code> (حسابك الشخصي). الفحص يقرأ الوجهة من تيليغرام نفسه ولا يغيّر الربط.</p>
-<div class="row"><button id="tgcheck" class="secondary" type="button">فحص الوجهة والبوت</button><button id="tgadopt" type="button" hidden>اعتماد الوجهة الجديدة فقط</button></div>
+<div class="row"><button id="tgcheck" class="secondary" type="button">فحص الوجهة والبوت</button><button id="tgnotify" class="secondary" type="button">تجربة تنبيه بدء البثّ</button><button id="tgadopt" type="button" hidden>اعتماد الوجهة الجديدة فقط</button></div>
 <p id="tgchannelnotice" class="notice" role="status" aria-live="polite" hidden></p>
 <p id="channel">لم يتم فحص الوجهة بعد.</p><p id="tgstate">تحميل الحالة…</p>
 <small id="budget"></small>
@@ -61,7 +61,7 @@ function error(text){$('error').textContent=text;$('error').hidden=!text}
 function channelSwitchPending(){return !!(checkedChannel?.previous&&checkedChannel.previous.id!==checkedChannel.id)}
 function renderCheckedChannel(){
   const pending=channelSwitchPending(),needsAdoption=!!(checkedChannel&&String(checkedChannel.id)!==String(lastT?.channel?.id));
-  $('tgadopt').hidden=!needsAdoption;$('tgadopt').disabled=tgBusy;$('tgcheck').disabled=tgBusy;
+  $('tgadopt').hidden=!needsAdoption;$('tgadopt').disabled=tgBusy;$('tgcheck').disabled=tgBusy;$('tgnotify').disabled=tgBusy;
   $('tgchannelnotice').hidden=!checkedChannel;
   $('tgchannelnotice').textContent=!checkedChannel?'':pending
     ? 'الوجهة المتاحة في الأسرار: «'+checkedChannel.title+'» ('+checkedChannel.id+') بدل «'+checkedChannel.previous.title+'». الفحص لم يبدّل الربط. اعتمد الجديدة بتأكيدك؛ يُحفظ طابور الوجهة السابقة وتُوقف الأرشفة حتى تفعيلها من جديد.'
@@ -79,6 +79,7 @@ $('capacity').textContent=`${s.version} • حد الحسابات: ${s.max_accou
 $('channel').textContent=y.channel?`الوجهة المعتمدة: ${y.channel.title} · ${y.channel.id}${y.channel.username?' · @'+y.channel.username:''}`:'اضبط TELEGRAM_CHAT_ID ثم اضغط فحص الوجهة.';
 renderCheckedChannel();
 $('tgstate').textContent=channelSwitchPending()?'الوجهة في الأسرار مختلفة؛ اعتمد الجديدة قبل تفعيل الأرشفة.':y.configured?`البوت ${y.bot_username||'مضبوط'} — سقف الرفع ${y.max_upload_mb}MB عبر ${y.local_server?'خادم Bot API المحلي':'الواجهة العامة (50MB فقط؛ أضف TELEGRAM_API_ID/HASH لرفعه)'}. النسخة الاحتياطية: ${y.backup_configured?'مضبوطة ✓':'غير مضبوطة'}.${y.local_server||!y.local_error||y.local_error.indexOf('TELEGRAM_API_ID')===0?'':'\n⚠ الخادم المحلي لا يستجيب: '+y.local_error}`:'TELEGRAM_BOT_TOKEN أو TELEGRAM_CHAT_ID ناقص — لن يُرسل أي تسجيل.';
+if(y.configured)$('tgstate').textContent+='\n'+(y.live_notify?'🔔 تنبيه بدء البثّ مفعّل → '+((y.live_notify_targets||[]).length>1?'القناة والحساب الشخصي':((y.live_notify_targets||[]).length===1?'وجهة واحدة':'لا وجهة مضبوطة')):'🔕 تنبيه بدء البثّ مُطفأ (LIVE_NOTIFY=off)');
 $('budget').textContent=`أُرسل اليوم: ${y.budget?.sent||0} ملف · ${Math.round((y.budget?.bytes||0)/1048576)}MB`;
 $('tasks').innerHTML=s.tasks.length?s.tasks.map(t=>`<article class="card"><h3>@${esc(t.username)}</h3><p>${esc(t.status)}</p><small>${esc(t.quality||'الجودة لم تحدد بعد')} · ${t.received_mb||0} MB · ${Math.floor((t.elapsed_seconds||0)/60)} دقيقة</small><p>${t.enabled?'المراقبة مفعّلة':'المراقبة معطّلة'} · توكن الجلسة: ${t.has_token?'موجود ✓':'غير مضاف'}</p><div class="row"><button data-user="${esc(t.username)}" data-action="start">تشغيل</button><button class="secondary" data-user="${esc(t.username)}" data-action="stop">إيقاف</button><button class="secondary" data-user="${esc(t.username)}" data-action="token">توكن</button><button class="danger" data-user="${esc(t.username)}" data-action="delete">حذف</button></div></article>`).join(''):'<p>أضف حسابات المذيع المطلوبة فقط.</p>';
 $('files').innerHTML=s.files.length?s.files.map(f=>`<div class="file"><div><code>${esc(f.name)}</code><br><small>${f.mb} MB</small></div><div class="row"><a href="/api/files/${encodeURIComponent(f.name)}">تنزيل</a><button class="danger" data-file="${esc(f.name)}">حذف الملف</button></div></div>`).join(''):'<p>لا توجد ملفات مكتملة بعد.</p>';
@@ -127,6 +128,12 @@ $('tgcheck').onclick=async()=>{
     alert('الوجهة المتاحة في الأسرار: «'+channel.title+'» ('+channel.id+').'+(channelSwitchPending()?' تحتاج تأكيد اعتمادها؛ الفحص لم يغيّر الربط.':' الفحص للقراءة فقط.'));
   }catch(e){error(e.message)}finally{tgBusy=false;renderCheckedChannel()}
 };
+$('tgnotify').onclick=async()=>{
+  if(tgBusy)return;tgBusy=true;renderCheckedChannel();
+  try{error('');const r=await api('/api/telegram/notify-test','POST');
+    alert(r.ok?('أُرسل نموذج التنبيه إلى '+((r.targets||[]).length)+' وجهة — تفقّد القناة ورسائل البوت الخاصة.'):'لم يُرسل التنبيه: تحقّق من LIVE_NOTIFY ومن ضبط القناة والنسخة الاحتياطية.');
+  }catch(e){error(e.message)}finally{tgBusy=false;renderCheckedChannel()}
+};
 $('tgadopt').onclick=async()=>{
   if(tgBusy)return;tgBusy=true;renderCheckedChannel();
   try{

telegram_api.py

@@ -36,6 +36,17 @@ ABSOLUTE_MAX_MB = 2000
 
 # حاشية الوسائط في تيليغرام: 1024 حرفًا (لا 4900 كوصف يوتيوب).
 CAPTION_LIMIT = 1024
+# حدّ تيليغرام لنصّ الرسالة (الحاشية 1024، النصّ 4096).
+MESSAGE_LIMIT = 4096
+DEFAULT_LIVE_TEXT = ('\U0001f534 {name} (@{username}) بدأ بثًّا مباشرًا\n'
+                     '\U0001f4c5 {date} · \u23f0 {time}')
+
+
+class _Safe(dict):
+    '''قالب لا يسقط بمفتاح ناقص: يترك {المفتاح} كما هو.'''
+
+    def __missing__(self, key):
+        return '{' + key + '}'
 # حدّ تيليغرام لعناصر الألبوم الواحد في sendMediaGroup.
 MAX_ALBUM_ITEMS = 100
 
@@ -564,10 +575,98 @@ class TelegramCore:
             'local_error': self.api.local_error(),
             'max_upload_mb': self.api.max_upload_mb(),
             'budget': budget,
+            'live_notify': str(os.getenv('LIVE_NOTIFY', 'on')).strip().lower()
+                           in ('1', 'on', 'true', 'yes'),
+            'live_notify_targets': self.notify_targets(),
             'live_relay': 'removed',
             'youtube': 'removed',
         }
 
+    # ---------- تنبيه بدء البثّ ----------
+    def notify_targets(self, which=None):
+        """إلى أين يذهب تنبيه بدء البثّ: `both` (افتراضي) أو `channel` أو `backup`."""
+        mode = str(which or os.getenv('LIVE_NOTIFY_TARGETS', 'both') or 'both').strip().lower()
+        out = []
+        if mode in ('both', 'channel') and self.api.chat_id():
+            out.append(self.api.chat_id())
+        if mode in ('both', 'backup') and self.api.backup_chat_id():
+            out.append(self.api.backup_chat_id())
+        return out
+
+    def live_start_text(self, user, meta=None, when=None):
+        """نصّ التنبيه: اسم المذيع وتاريخ اليوم ووقته (منطقة `TZ`)."""
+        from datetime import datetime
+        tz = None
+        try:
+            from zoneinfo import ZoneInfo
+            tz = ZoneInfo(os.getenv('TZ', 'Asia/Baghdad') or 'UTC')
+        except Exception:
+            tz = None
+        now = when or (datetime.now(tz) if tz else datetime.now())
+        meta = dict(meta or {})
+        nickname = str(meta.get('nickname') or '').strip()
+        title = str(meta.get('live_title') or '').strip()
+        template = str(os.getenv('LIVE_NOTIFY_TEXT', '') or DEFAULT_LIVE_TEXT)
+        values = _Safe({'name': nickname or user, 'nickname': nickname or user,
+                        'username': user, 'title': title or (nickname or user),
+                        'live_title': title, 'date': now.strftime('%d-%m-%Y'),
+                        'time': now.strftime('%H:%M'),
+                        'room_id': str(meta.get('room_id') or '')})
+        try:
+            text = template.format_map(values)
+        except Exception:
+            text = DEFAULT_LIVE_TEXT.format_map(values)
+        if title and '{live_title}' not in template:
+            text = f'{text}\n\U0001f4dd {title}'
+        return text.strip()[:MESSAGE_LIMIT]
+
+    def notify_live_start(self, user, meta=None, room_id='', when=None, test=False):
+        """رسالة «بدأ بثًّا مباشرًا». ← هل وصلت إلى وجهة واحدة على الأقل.
+
+        * مرة واحدة لكل بثّ: `app.py` يمنع التكرار بين مقاطع البثّ الواحد، والسجلّ
+          الدائم يمنعه بعد إعادة التشغيل (بمعرّف الغرفة).
+        * **لا يعطّل التسجيل أبدًا**: أي فشل يُسجَّل ويعيد `False`.
+        """
+        if str(os.getenv('LIVE_NOTIFY', 'on')).strip().lower() not in ('1', 'on', 'true', 'yes'):
+            return False
+        if not self.api.token():
+            return False
+        targets = self.notify_targets()
+        if not targets:
+            return False
+        meta = dict(meta or {})
+        key = str(user or '').lower()
+        room = str(room_id or meta.get('room_id') or '').strip()
+        if room and not test:
+            seen = self.journal.read().get('notified') or {}
+            if str(seen.get(key) or '') == room:
+                return False           # هذا البثّ أُعلن من قبل، حتى لو أُعيد الإقلاع
+        text = self.live_start_text(user, meta, when)
+        if test:
+            text = ('\U0001f9ea ' + text +
+                    '\n\n(رسالة تجريبية من اللوحة — لا يوجد بثّ فعلي)')[:MESSAGE_LIMIT]
+        sent = []
+        for chat in targets:
+            try:
+                self.api.call('sendMessage', {'chat_id': str(chat), 'text': text,
+                                              'disable_web_page_preview': True})
+                sent.append(str(chat))
+            except Exception as exc:
+                self.log('system', f'تعذّر تنبيه بدء بثّ {user} إلى {chat} '
+                                   f'({type(exc).__name__})')
+        if not sent:
+            return False
+        if room and not test:
+            def mutate(d):
+                seen = d.setdefault('notified', {})
+                seen[key] = room
+                if len(seen) > 200:                 # لا يكبر السجلّ بلا حدّ
+                    d['notified'] = dict(list(seen.items())[-200:])
+            self.journal.change(mutate)
+        self.log(user, f'أُرسل تنبيه «بدأ بثًّا مباشرًا» إلى {len(sent)} وجهة'
+                       + (' (تجربة)' if test else ''))
+        return True
+
     # ---------- دورة حياة ----------
     def restore(self):
         """إقلاع: ينبّه على بقايا يوتيوب وعلى نقص الأسرار، ولا يرسل شيئًا."""

test_telegram_archive.py

@@ -40,6 +40,7 @@ class FakeBot:
         self._mid = 100
         self.albums = []              # (chat_id, file_ids, caption)
         self.fail_album = None        # APIError تُرمى عند أول ألبوم
+        self.fail_send = None         # APIError تُرمى عند أي sendMessage
 
     # --- أسرار/إعداد ---
     def token(self): return os.environ.get('TELEGRAM_BOT_TOKEN', '')
@@ -91,8 +92,13 @@ class FakeBot:
                           'width': 1080, 'height': 1920, 'duration': 60,
                           'file_size': Path(path).stat().st_size}}
 
-    def call(self, method, data=None, timeout=60):
+    def call(self, method, data=None, timeout=60, retries=0):
         self.calls.append((method, dict(data or {})))
+        if method == 'sendMessage':
+            if self.fail_send:
+                raise self.fail_send
+            self._mid += 1
+            return {'message_id': self._mid}
         if method == 'sendVideo' or method == 'sendDocument':
             if self.fail_backup:
                 raise self.fail_backup        # يبقى قائمًا: يفشل video وdocument معًا
@@ -693,6 +699,129 @@ try:
 finally:
     TA.shutil.which, TA.subprocess.run = real_w2, real_r2
 
+print('\n=== 18) تنبيه «بدأ بثًّا مباشرًا» إلى تيليغرام ===')
+# المطلوب: اسم المذيع + التاريخ + الوقت، إلى القناة والحساب الشخصي معًا، مرة واحدة
+# لكل بثّ (لا لكل مقطع، ولا بعد إعادة الإقلاع)، وبلا تعطيل التسجيل عند الفشل.
+from datetime import datetime
+
+with tempfile.TemporaryDirectory() as tmp:
+    arc, core, files = make_archive(tmp, LIVE_NOTIFY='on', LIVE_NOTIFY_TARGETS='both',
+                                    LIVE_NOTIFY_TEXT='')
+    bot = core.api
+    texts = lambda api: [d['text'] for m, d in api.calls if m == 'sendMessage']
+    chats = lambda api: [str(d['chat_id']) for m, d in api.calls if m == 'sendMessage']
+
+    # 1) بدء البثّ: رسالة إلى الوجهتين تحمل الاسم والتاريخ والوقت
+    ok = core.notify_live_start('ahmedbarbooka2', {'nickname': 'أحمد', 'live_title': 'سهرة',
+                                                   'room_id': '74'},
+                                when=datetime(2026, 10, 10, 8, 5))
+    check('التنبيه نجح', ok is True)
+    check('إلى القناة والحساب الشخصي معًا',
+          chats(bot) == ['-1001234567890', '8482164917'], str(chats(bot)))
+    t1 = texts(bot)[0]
+    check('يحمل اسم المذيع', 'أحمد' in t1, t1)
+    check('يحمل اسم المستخدم', '@ahmedbarbooka2' in t1, t1)
+    check('يحمل التاريخ', '10-10-2026' in t1, t1)
+    check('يحمل الوقت', '08:05' in t1, t1)
+    check('يحمل عنوان البثّ', 'سهرة' in t1, t1)
+    check('يقول إنّه بدأ بثًّا مباشرًا', 'بثًّا مباشرًا' in t1, t1)
+    check('بلا معاينة رابط (لا بطاقة مزعجة)',
+          all(d.get('disable_web_page_preview') is True for m, d in bot.calls
+              if m == 'sendMessage'))
+
+    # 2) مقطع ثانٍ من البثّ نفسه (انقطاع مصدر ثم عودة): لا تكرار
+    n0 = len(bot.calls)
+    check('المقطع الثاني من البثّ نفسه لا يُعلن مرتين',
+          core.notify_live_start('ahmedbarbooka2', {'nickname': 'أحمد', 'room_id': '74'}) is False
+          and len(bot.calls) == n0, str(len(bot.calls) - n0))
+
+    # 3) إعادة إقلاع أثناء البثّ: السجلّ الدائم يمنع التكرار
+    jpath = Path(tmp) / 'telegram-api-state.json'
+    core2 = TelegramCore(lambda *a, **k: None, jpath)
+    core2.api = FakeBot(core2.journal)
+    check('مانع التكرار محفوظ في السجلّ',
+          (core2.journal.read().get('notified') or {}).get('ahmedbarbooka2') == '74',
+          str(core2.journal.read().get('notified')))
+    check('بعد إعادة الإقلاع لا يُعلن البثّ نفسه مرّة أخرى',
+          core2.notify_live_start('ahmedbarbooka2', {'nickname': 'أحمد', 'room_id': '74'}) is False
+          and not chats(core2.api))
+
+    # 4) بثّ جديد (غرفة جديدة) ⇒ تنبيه جديد بتاريخه ووقته
+    check('بثّ جديد بغرفة جديدة يُعلن',
+          core2.notify_live_start('ahmedbarbooka2', {'nickname': 'أحمد', 'room_id': '99'},
+                                  when=datetime(2026, 10, 11, 20, 30)) is True)
+    t2 = texts(core2.api)[-1]
+    check('التنبيه الجديد يحمل تاريخه ووقته', '11-10-2026' in t2 and '20:30' in t2, t2)
+
+    # 5) بلا لقب ⇒ يُذكر اسم المستخدم؛ بلا عنوان ⇒ لا سطر عنوان
+    core2.notify_live_start('strongarmor', {}, when=datetime(2026, 10, 10, 9, 0))
+    t3 = texts(core2.api)[-1]
+    check('بلا لقب يُذكر اسم المستخدم', '@strongarmor' in t3 and 'strongarmor (' in t3, t3)
+    check('بلا عنوان لا يُضاف سطر العنوان', '\U0001f4dd' not in t3, t3)
+    check('لا يبقى قوس قالب غير مُعبَّأ', '{' not in t3, t3)
+
+    # 6) الإطفاء
+    os.environ['LIVE_NOTIFY'] = 'off'
+    n1 = len(core2.api.calls)
+    check('LIVE_NOTIFY=off يوقف التنبيه',
+          core2.notify_live_start('ahmedbarbooka2', {'room_id': '500'}) is False
+          and len(core2.api.calls) == n1)
+    os.environ['LIVE_NOTIFY'] = 'on'
+
+    # 7) اختيار الوجهة
+    os.environ['LIVE_NOTIFY_TARGETS'] = 'channel'
+    check('targets=channel ⇒ القناة فقط', core2.notify_targets() == ['-1001234567890'],
+          str(core2.notify_targets()))
+    os.environ['LIVE_NOTIFY_TARGETS'] = 'backup'
+    check('targets=backup ⇒ الحساب الشخصي فقط', core2.notify_targets() == ['8482164917'],
+          str(core2.notify_targets()))
+    os.environ['LIVE_NOTIFY_TARGETS'] = 'both'
+    check('targets=both ⇒ الوجهتان', len(core2.notify_targets()) == 2)
+
+    # 8) فشل الإرسال: لا استثناء، لا تعطيل للتسجيل، ويُبلَّغ
+    # make_archive يعطي النواة مسجِّلًا صامتًا؛ هنا نلتقط سجلّها كما تفعل app.py.
+    CORE_LOG = []
+    core.log = lambda user, msg: CORE_LOG.append((user, msg))
+    bot.fail_send = APIError('networkOrInvalidResponse', 'انقطاع الاتصال')
+    check('فشل الإرسال يعيد False بلا استثناء',
+          core.notify_live_start('ahmadbarbooka.cinderella', {'nickname': 'سندريلا',
+                                                              'room_id': '1'}) is False)
+    check('الفشل سُجّل في سجلّ التطبيق',
+          any('تنبيه بدء بثّ' in m for _, m in CORE_LOG), str(CORE_LOG[:2]))
+    check('الفشل لم يُسجَّل في مانع التكرار (يُحاول في بثّ لاحق)',
+          (core.journal.read().get('notified') or {}).get('ahmadbarbooka.cinderella') is None)
+    bot.fail_send = None
+
+    # 9) زرّ التجربة من اللوحة: يُرسل دائمًا ولا يلوّث مانع التكرار
+    check('زرّ التجربة يُرسل بلا بثّ فعلي',
+          core.notify_live_start('example', {'nickname': 'مثال'}, test=True) is True)
+    tt = texts(bot)[-1]
+    check('رسالة التجربة مُعلَّمة كتجربة', 'تجريبية' in tt, tt)
+    check('التجربة لا تُسجَّل في مانع التكرار',
+          'example' not in (core.journal.read().get('notified') or {}))
+
+    # 10) قالب مخصّص + مفتاح غير معروف يبقى كما هو
+    os.environ['LIVE_NOTIFY_TEXT'] = '{name} مباشر {date} {time} {unknown_key}'
+    t4 = core.live_start_text('u', {'nickname': 'ن'}, when=datetime(2026, 1, 2, 3, 4))
+    check('القالب المخصّص مستعمل', t4.startswith('ن مباشر 02-01-2026 03:04'), t4)
+    check('مفتاح غير معروف لا يُسقط الرسالة', '{unknown_key}' in t4, t4)
+    os.environ['LIVE_NOTIFY_TEXT'] = ''
+
+    # 11) مانع التكرار لا يكبر بلا حدّ
+    core.journal.change(lambda d: d.update(notified={('k%d' % i): str(i) for i in range(250)}))
+    core.notify_live_start('capuser', {'room_id': 'R'})
+    check('مانع التكرار يبقى تحت 200 غرفة',
+          len(core.journal.read().get('notified') or {}) <= 200,
+          str(len(core.journal.read().get('notified') or {})))
+    check('أحدث الغرف محفوظة بعد التقليم',
+          (core.journal.read().get('notified') or {}).get('capuser') == 'R')
+
+    # 12) لقطة اللوحة تُظهر حالة التنبيه
+    snap = core.snapshot()
+    check('اللقطة تُظهر التنبيه مفعّلًا', snap.get('live_notify') is True)
+    check('اللقطة تُظهر وجهتي التنبيه', len(snap.get('live_notify_targets') or []) == 2,
+          str(snap.get('live_notify_targets')))
+
 # --------------------------------------------------------------------------- #
 failed = [r for r in RESULTS if not r[1]]
 print('\n' + '=' * 62)

variables.env

@@ -46,6 +46,13 @@ TELEGRAM_REQUIRE_BACKUP=on
 TELEGRAM_SILENT=off
 # حارس المعدل: أقل فاصلة بين إرسالين للمحادثة نفسها (ثوانٍ)
 TELEGRAM_MIN_CHAT_INTERVAL=4
+# تنبيه «بدأ بثًّا مباشرًا» باسم المذيع والتاريخ والوقت — مرة لكل بثّ
+# on/off. الإيقاف لا يمسّ التسجيل ولا الأرشفة.
+LIVE_NOTIFY=on
+# إلى أين: both = القناة + الحساب الشخصي | channel | backup
+LIVE_NOTIFY_TARGETS=both
+# قالب اختياري: {name} {username} {nickname} {live_title} {date} {time} {room_id}
+LIVE_NOTIFY_TEXT=
 TELEGRAM_LOCAL_PORT=8081
 
 # ---------- المراقبة والتسجيل والتخزين ----------