Update app.py

app.py

@@ -11,7 +11,6 @@ SUPABASE_URL = "https://yctirvnryrzygoxbpvoy.supabase.co"
 SUPABASE_KEY = "sb_publishable_aBcD-atruskWwoCiLr0lWw_inT8GLoN"
 WEB_APP_URL = "https://rony90790.github.io/Forward-bot/index.html" 
 
-# আপনার Hugging Face এর লিংক
 HF_SPACE_URL = "https://pmrony-forwardbot.hf.space" 
 
 CHANNEL_USERNAME = "xmlcpg"   
@@ -22,24 +21,26 @@ bot = telebot.TeleBot(BOT_TOKEN)
 supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 app = Flask(__name__)
 
+# ইন-মেমরি ক্যাশে (যাতে বারবার টেলিগ্রাম পেজ স্ক্র্যাপ করে স্পেস স্লো না হয়)
+thumbnail_cache = {}
+
 # ==========================================
-#          WEBHOOK SETUP (NO TIMEOUT)
+#          WEBHOOK SETUP
 # ==========================================
 
-# টেলিগ্রাম থেকে ডাটা রিসিভ করার রুট
 @app.route(f'/{BOT_TOKEN}', methods=['POST'])
 def webhook():
-    if request.headers.get('content-type') == 'application/json':
+    # Content-type একটু ফ্লেক্সিবল করা হলো টেলিগ্রামের জন্য
+    if 'application/json' in request.headers.get('content-type', ''):
         json_string = request.get_data().decode('utf-8')
         update = telebot.types.Update.de_json(json_string)
         bot.process_new_updates([update])
         return "OK", 200
     return "Forbidden", 403
 
-# Webhook সেট করার রুট (আপনার ব্রাউজার থেকে হিট করতে হবে)
 @app.route('/set_webhook')
 def set_webhook():
-    bot.remove_webhook() # আগের পোলিং ডিলিট করবে
+    bot.remove_webhook()
     success = bot.set_webhook(url=f"{HF_SPACE_URL}/{BOT_TOKEN}")
     if success:
         return f"<h1>✅ Webhook Successfully Set to Hugging Face!</h1><p>আপনার বট এখন আর টাইম-আউট হবে না।</p>"
@@ -55,6 +56,12 @@ def index():
 # ==========================================
 
 def get_telegram_thumbnail(channel, msg_id):
+    cache_key = f"{channel}_{msg_id}"
+    
+    # ক্যাশে থাকলে দ্রুত রিটার্ন করবে (API ফাস্ট হবে)
+    if cache_key in thumbnail_cache:
+        return thumbnail_cache[cache_key]
+        
     try:
         url = f"https://t.me/{channel}/{msg_id}?embed=1"
         req = urllib.request.Request(url, headers={'User-Agent': 'Mozilla/5.0'})
@@ -63,10 +70,15 @@ def get_telegram_thumbnail(channel, msg_id):
         if match:
             img_url = match.group(1)
             if "telegram_logo" not in img_url:
+                thumbnail_cache[cache_key] = img_url
                 return img_url
     except Exception:
         pass
-    return f"https://via.placeholder.com/150/222222/FF9900?text=Video+{msg_id}"
+        
+    # কোনো ছবি না পেলে ডামি ছবি
+    fallback = f"https://via.placeholder.com/150/222222/FF9900?text=Video+{msg_id}"
+    thumbnail_cache[cache_key] = fallback
+    return fallback
 
 @app.route('/api/videos')
 def api_videos():
@@ -88,27 +100,33 @@ def start(message):
 
     referrer_id = None
     if len(text) > 1:
-        referrer_id = text[1] 
+        try:
+            # Type error এড়াতে int এ কনভার্ট
+            referrer_id = int(text[1])
+        except ValueError:
+            referrer_id = None 
 
     try:
         user_check = supabase.table('referrals').select('*').eq('user_id', user_id).execute()
 
-        if len(user_check.data) == 0:
+        # যদি ডাটাবেজে ইউজার না থাকে
+        if not user_check.data:
             supabase.table('referrals').insert({
                 'user_id': user_id,
                 'referral_count': 0,
-                'referrer_id': referrer_id if referrer_id != str(user_id) else None
+                'referrer_id': referrer_id if referrer_id != user_id else None
             }).execute()
 
-            if referrer_id and referrer_id != str(user_id):
+            # যদি নতুন ইউজার কোনো রেফারের মাধ্যমে জয়েন করে
+            if referrer_id and referrer_id != user_id:
                 referrer_data = supabase.table('referrals').select('referral_count').eq('user_id', referrer_id).execute()
-                if len(referrer_data.data) > 0:
+                if referrer_data.data:
                     new_count = referrer_data.data[0]['referral_count'] + 1
                     supabase.table('referrals').update({'referral_count': new_count}).eq('user_id', referrer_id).execute()
                     
                     try:
                         bot.send_message(referrer_id, "🎉 একজন আপনার লিংকে জয়েন করেছে! আপনার রেফারেল কাউন্ট বাড়লো।")
-                    except Exception as e:
+                    except Exception:
                         pass
     except Exception as e:
         print("Database Error:", e)
@@ -118,5 +136,5 @@ def start(message):
     bot.reply_to(message, "ভাইরাল ভিডিও দেখতে নিচের বাটনে ক্লিক করো 👇", reply_markup=markup)
 
 if __name__ == "__main__":
-    # এখানে আর infinity_polling() নেই, পুরোটাই এখন Webhook এ চলবে!
-    app.run(host="0.0.0.0", port=7860)
+    # Threaded=True দিলে একই সাথে একাধিক ইউজার ওয়েবঅ্যাপ এবং বট ব্যবহার করতে পারবে
+    app.run(host="0.0.0.0", port=7860, threaded=True)