Update app.py

app.py

@@ -1,28 +1,40 @@
-import telebot
-from telebot import apihelper
-from telebot.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInfo
 import os
+import requests
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
 import threading
 
-# টোকেন ও ডিটেইলস
+# ডিটেইলস
 BOT_TOKEN = "8628213901:AAFvfHBpZ6tok40ZQuhIDLAVIMrHeiheMNY"
 SUPABASE_URL = "https://yctirvnryrzygoxbpvoy.supabase.co"
 SUPABASE_KEY = "sb_publishable_aBcD-atruskWwoCiLr0lWw_inT8GLoN"
 WEB_APP_URL = "https://rony90790.github.io/Forward-bot/index.html" 
 HF_SPACE_URL = "https://pmrony-forwardbot.hf.space" 
 
-# কানেকশন টাইমআউট সর্বোচ্চ করা হলো
-apihelper.CONNECT_TIMEOUT = 100
-apihelper.READ_TIMEOUT = 100
-
-bot = telebot.TeleBot(BOT_TOKEN, threaded=False)
 supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 app = Flask(__name__)
 
-# --- ডাটাবেজ কাজ আলাদা থ্রেডে করার ফাংশন ---
-def save_referral_bg(user_id, referrer_id):
+# --- সরাসরি মেসেজ পাঠানোর ফাংশন (SSL সমস্যা এড়াতে) ---
+def send_telegram_message(chat_id, text, reply_markup=None):
+    url = f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
+    payload = {
+        "chat_id": chat_id,
+        "text": text,
+        "parse_mode": "HTML"
+    }
+    if reply_markup:
+        payload["reply_markup"] = reply_markup
+    
+    try:
+        # ৫ সেকেন্ডের মধ্যে মেসেজ না গেলে হাল ছেড়ে দিবে না, চেষ্টা করবে
+        r = requests.post(url, json=payload, timeout=15)
+        return r.json()
+    except Exception as e:
+        print(f"Send Error: {e}")
+        return None
+
+# --- ডাটাবেজ কাজ ব্যাকগ্রাউন্ডে ---
+def handle_db_stuff(user_id, referrer_id):
     try:
         user_check = supabase.table('referrals').select('*').eq('user_id', user_id).execute()
         if not user_check.data:
@@ -35,67 +47,50 @@ def save_referral_bg(user_id, referrer_id):
                 if ref_data.data:
                     new_count = ref_data.data[0]['referral_count'] + 1
                     supabase.table('referrals').update({'referral_count': new_count}).eq('user_id', referrer_id).execute()
-                    bot.send_message(referrer_id, "🎉 কেউ আপনার রেফারে জয়েন করেছে!")
+                    send_telegram_message(referrer_id, "🎉 কেউ আপনার রেফারে জয়েন করেছে!")
     except:
         pass
 
 @app.route(f'/{BOT_TOKEN}', methods=['POST'])
 def webhook():
-    if request.headers.get('content-type') == 'application/json':
-        json_string = request.get_data().decode('utf-8')
-        update = telebot.types.Update.de_json(json_string)
-        bot.process_new_updates([update])
+    data = request.get_json()
+    if not data or "message" not in data:
         return "OK", 200
-    return "Forbidden", 403
-
-@app.route('/set_webhook')
-def set_webhook():
-    bot.remove_webhook()
-    # ওয়েব হুক সেট করার সময় ১০ সেকেন্ড ওয়েট করবে
-    success = bot.set_webhook(url=f"{HF_SPACE_URL}/{BOT_TOKEN}", timeout=60)
-    if success:
-        return "<h1>✅ Webhook Set Success!</h1>"
-    else:
-        return "<h1>❌ Webhook Set Failed!</h1>"
-
-@app.route('/')
-def index():
-    return "Bot is Running Perfectly!"
+    
+    message = data["message"]
+    chat_id = message["chat"]["id"]
+    text = message.get("text", "")
 
-# ================= COMMANDS =================
+    if text.startswith("/start"):
+        # রেফারেল আইডি বের করা
+        args = text.split()
+        referrer_id = int(args[1]) if len(args) > 1 and args[1].isdigit() else None
+        
+        # ব্যাকগ্রাউন্ডে ডাটাবেজ আপডেট
+        threading.Thread(target=handle_db_stuff, args=(chat_id, referrer_id)).start()
 
-@bot.message_handler(commands=['start'])
-def start(message):
-    user_id = message.from_user.id
-    args = message.text.split()
-    referrer_id = int(args[1]) if len(args) > 1 and args[1].isdigit() else None
-    
-    # ডাটাবেজের কাজ হবে ব্যাকগ্রাউন্ডে, যাতে বট স্লো না হয়
-    threading.Thread(target=save_referral_bg, args=(user_id, referrer_id)).start()
+        # রিপ্লাই কিবোর্ড তৈরি
+        reply_markup = {
+            "inline_keyboard": [[
+                {"text": "Play video 🔞", "web_app": {"url": WEB_APP_URL}}
+            ]]
+        }
+        send_telegram_message(chat_id, "ভাইরাল ভিডিও দেখতে নিচের বাটনে ক্লিক করো 👇", reply_markup)
 
-    # ইউজারকে সাথে ��াথে রিপ্লাই দিবে
-    markup = InlineKeyboardMarkup()
-    markup.add(InlineKeyboardButton("Play video 🔞", web_app=WebAppInfo(url=WEB_APP_URL)))
-    bot.send_message(message.chat.id, "ভাইরাল ভিডিও দেখতে নিচের বাটনে ক্লিক করো 👇", reply_markup=markup)
+    elif text.startswith("/png"):
+        parts = text.split(maxsplit=1)
+        if len(parts) > 1:
+            send_telegram_message(chat_id, "✅ ছবি সেট হয়েছে। এখন এই ছবির জন্য ভিডিওর <b>Google Drive লিংক</b> পাঠান। (এটি বর্তমানে ম্যানুয়ালি Supabase-এ অ্যাড করুন)")
+        else:
+            send_telegram_message(chat_id, "সঠিক নিয়ম: /png [লিংক]")
 
-@bot.message_handler(commands=['png'])
-def add_png(message):
-    parts = message.text.split(maxsplit=1)
-    if len(parts) > 1:
-        img_url = parts[1].strip()
-        bot.send_message(message.chat.id, f"✅ ছবি সেট হয়েছে। এখন এই ছবির জন্য ভিডিওর **Google Drive লিংক** পাঠান।")
-        # ভিডিও অ্যাড করার লজিক এখানে সিম্পল রাখা হয়েছে
-        bot.register_next_step_handler(message, save_video_final, img_url)
-    else:
-        bot.send_message(message.chat.id, "সঠিক নিয়ম: `/png https://link.jpg`")
+    return "OK", 200
 
-def save_video_final(message, img_url):
-    video_url = message.text.strip()
-    try:
-        supabase.table('videos').insert({"video_url": video_url, "thumbnail_url": img_url}).execute()
-        bot.send_message(message.chat.id, "🎉 সফলভাবে ভিডিও অ্যাড হয়েছে!")
-    except:
-        bot.send_message(message.chat.id, "❌ ডাটাবেজ এরর!")
+@app.route('/set_webhook')
+def set_webhook():
+    webhook_url = f"{HF_SPACE_URL}/{BOT_TOKEN}"
+    r = requests.get(f"https://api.telegram.org/bot{BOT_TOKEN}/setWebhook?url={webhook_url}")
+    return jsonify(r.json())
 
 @app.route('/api/videos')
 def api_videos():
@@ -107,5 +102,9 @@ def api_videos():
     except:
         return jsonify([])
 
+@app.route('/')
+def index():
+    return "Bot System is Active!"
+
 if __name__ == "__main__":
     app.run(host="0.0.0.0", port=7860)