Upload 3 files

app.py

@@ -2599,6 +2599,48 @@ def api_admin_payment_slip(payment_id):
         return jsonify(ok=False, msg=str(e))
 
 
+@app.route('/api/admin/broadcast', methods=['POST'])
+def api_admin_broadcast():
+    """Send broadcast message to all users via Telegram bot."""
+    try:
+        data = request.get_json(force=True)
+        caller = data.get('caller', '')
+        if caller != ADMIN_U:
+            return jsonify(ok=False, msg='❌ Admin only'), 403
+        message = data.get('message', '').strip()
+        if not message:
+            return jsonify(ok=False, msg='❌ Message မထည့်ရသေးပါ')
+        db = load_db()
+        token = os.getenv('TELEGRAM_BOT_TOKEN', '')
+        if not token:
+            return jsonify(ok=False, msg='❌ BOT_TOKEN မသတ်မှတ်ရသေးပါ')
+        import urllib.request as _ur, json as _json, threading as _th
+        sent = 0; fail = 0
+        for uname, udata in db.get('users', {}).items():
+            tg_id = udata.get('tg_chat_id')
+            if not tg_id:
+                continue
+            try:
+                payload = _json.dumps({
+                    'chat_id': tg_id,
+                    'text': f'📢 *ကြေငြာချက်*\n\n{message}',
+                    'parse_mode': 'Markdown',
+                }).encode()
+                req = _ur.Request(
+                    f'https://api.telegram.org/bot{token}/sendMessage',
+                    data=payload,
+                    headers={'Content-Type': 'application/json'})
+                _ur.urlopen(req, timeout=8)
+                sent += 1
+            except Exception as e:
+                logger.warning(f'[broadcast] {uname}: {e}')
+                fail += 1
+        return jsonify(ok=True, sent=sent, fail=fail,
+                       msg=f'✅ {sent} ယောက် ပို့ပြီး — {fail} ကျ')
+    except Exception as e:
+        return jsonify(ok=False, msg=str(e))
+
+
 @app.route('/api/payment/kbz_qr')
 def api_kbz_qr():
     """

bot.py

@@ -876,6 +876,41 @@ async def on_callback(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
 # ── TEXT HANDLER ──
 
 
+async def error_handler(update: object, ctx: ContextTypes.DEFAULT_TYPE) -> None:
+    """Handle all telegram errors gracefully without crashing."""
+    import traceback
+    err = ctx.error
+    tb = ''.join(traceback.format_exception(type(err), err, err.__traceback__))
+    logger.warning(f'[ErrorHandler] {err}\n{tb[:400]}')
+
+async def cmd_broadcast(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    """Admin: /broadcast <message> — send to all users with tg_chat_id."""
+    cid = update.effective_chat.id
+    s = sess(cid)
+    if not s.get('is_admin'):
+        await update.message.reply_text("❌ Admin only"); return
+    text = ' '.join(ctx.args) if ctx.args else ''
+    if not text:
+        await update.message.reply_text(
+            "📢 *Broadcast*\\n\\nUsage: `/broadcast <message>`",
+            parse_mode=ParseMode.MARKDOWN); return
+    db = load_db()
+    sent = 0; fail = 0
+    for uname, udata in db.get('users', {}).items():
+        tg_id = udata.get('tg_chat_id')
+        if not tg_id: continue
+        try:
+            await ctx.bot.send_message(
+                chat_id=tg_id,
+                text=f"📢 *ကြေငြာချက်*\\n\\n{text}",
+                parse_mode=ParseMode.MARKDOWN)
+            sent += 1
+        except Exception as e:
+            logger.warning(f'[broadcast] {uname}: {e}')
+            fail += 1
+    await update.message.reply_text(
+        f"✅ Broadcast ပြီးပါပြီ\\n📨 ပေးပို့: {sent} ယောက်\\n❌ မအောင်မြင်: {fail} ယောက်")
+
 async def cmd_pending(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
     """Admin: list pending payments."""
     cid = update.effective_chat.id
@@ -1119,8 +1154,10 @@ def main():
     )
     application.add_handler(conv)
     application.add_handler(CommandHandler('pending', cmd_pending))
+    application.add_handler(CommandHandler('broadcast', cmd_broadcast))
     # Global handler for adm_pay callbacks — works even outside conversation state
     application.add_handler(CallbackQueryHandler(on_callback, pattern='^adm_pay[|]'))
+    application.add_error_handler(error_handler)
     logger.info('🤖 Recap Studio Bot အသင့်ဖြစ်ပြီ!')
     application.run_polling(
         drop_pending_updates=True,

index.html

@@ -1003,6 +1003,17 @@ body{background:var(--bg);color:var(--text);font-family:var(--F);min-height:100v
       <div style="display:flex;gap:8px;margin-top:8px;flex-wrap:wrap">
         <button class="adm-act-btn" onclick="loadUsers()"><i class="fas fa-users"></i> Users</button>
         <button class="adm-act-btn" style="background:rgba(239,68,68,.1);border-color:rgba(239,68,68,.3);color:#ef4444" onclick="loadPendingPayments()"><i class="fas fa-clock"></i> Pending Payments <span id="adm-pending-count" style="background:#ef4444;color:#fff;border-radius:20px;padding:1px 7px;font-size:.62rem;margin-left:4px;display:none">0</span></button>
+        <button class="adm-act-btn" style="background:rgba(99,102,241,.1);border-color:rgba(99,102,241,.3);color:#6366f1" onclick="document.getElementById('adm-bc-wrap').style.display=document.getElementById('adm-bc-wrap').style.display==='none'?'block':'none'"><i class="fas fa-bullhorn"></i> Broadcast</button>
+      </div>
+      <!-- Broadcast Section -->
+      <div id="adm-bc-wrap" style="display:none;margin-top:10px;background:rgba(99,102,241,.06);border:1px solid rgba(99,102,241,.2);border-radius:12px;padding:12px">
+        <div style="font-size:.72rem;font-weight:700;text-transform:uppercase;letter-spacing:.08em;color:#6366f1;margin-bottom:8px"><i class="fas fa-bullhorn"></i> Broadcast Message</div>
+        <textarea id="bc-msg" placeholder="ကြေငြာချက် ရေးပါ…" style="width:100%;box-sizing:border-box;background:rgba(255,255,255,.05);border:1px solid rgba(255,255,255,.1);border-radius:8px;color:#fff;padding:10px;font-size:.82rem;font-family:var(--F);resize:vertical;min-height:80px;outline:none" rows="3"></textarea>
+        <div style="display:flex;gap:8px;margin-top:8px;align-items:center">
+          <button class="abtn ab-g" onclick="sendBroadcast()" style="flex:1"><i class="fas fa-paper-plane"></i> ပို့မည်</button>
+          <button class="abtn" onclick="document.getElementById('bc-msg').value=''" style="background:rgba(255,255,255,.07);border:1px solid rgba(255,255,255,.1);color:rgba(255,255,255,.6)"><i class="fas fa-times"></i></button>
+        </div>
+        <div id="bc-res" style="font-size:.72rem;margin-top:6px;color:var(--green);font-weight:600"></div>
       </div>
       <div id="utw" style="overflow-x:auto;margin-top:8px"></div>
       <!-- Pending Payments -->
@@ -1821,6 +1832,18 @@ async function qDel(u){if(!confirm('Delete '+u+'?'))return;const r=await fetch('
 async function qBan(u,ban){const label=ban?'Ban':'Unban';if(!confirm(label+' '+u+'?'))return;const r=await fetch('/api/admin/ban_user',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({caller:U,username:u,ban})});const d=await r.json();toast(d.msg);if(d.ok)loadUsers();}
 
 /* ══ PENDING PAYMENTS ══ */
+async function sendBroadcast(){
+  const msg=document.getElementById('bc-msg').value.trim();
+  const res=document.getElementById('bc-res');
+  if(!msg){res.style.color='#ef4444';res.textContent='❌ Message ထည့်ပါ';return;}
+  res.style.color='rgba(255,255,255,.5)';res.textContent='📨 ပို့နေသည်…';
+  try{
+    const r=await fetch('/api/admin/broadcast',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({caller:U,message:msg})});
+    const d=await r.json();
+    if(d.ok){res.style.color='var(--green)';res.textContent=d.msg;document.getElementById('bc-msg').value='';}
+    else{res.style.color='#ef4444';res.textContent=d.msg||'❌ Error';}
+  }catch(e){res.style.color='#ef4444';res.textContent='❌ Network error';}
+}
 async function loadPendingPayments(){
   const wrap=document.getElementById('adm-pending-wrap');
   const list=document.getElementById('adm-pending-list');