Update app.py

app.py

@@ -4,8 +4,9 @@ import os
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
 import traceback
+import time
 
-# টোকেন এবং ডিটেইলস
+# ডিটেইলস
 BOT_TOKEN = "8628213901:AAFvfHBpZ6tok40ZQuhIDLAVIMrHeiheMNY"
 SUPABASE_URL = "https://yctirvnryrzygoxbpvoy.supabase.co"
 SUPABASE_KEY = "sb_publishable_aBcD-atruskWwoCiLr0lWw_inT8GLoN"
@@ -13,6 +14,7 @@ WEB_APP_URL = "https://rony90790.github.io/Forward-bot/index.html"
 HF_SPACE_URL = "https://pmrony-forwardbot.hf.space" 
 
 bot = telebot.TeleBot(BOT_TOKEN)
+# ক্লায়েন্ট ইনিশিয়ালাইজেশন
 supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 app = Flask(__name__)
 
@@ -23,8 +25,6 @@ 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)
-        # লগ প্রিন্ট হবে যাতে বোঝা যায় মেসেজ এসেছে
-        print(f"[LOG] New Update Received: {update.update_id}")
         bot.process_new_updates([update])
         return "OK", 200
     return "Forbidden", 403
@@ -46,39 +46,43 @@ def index():
 
 @bot.message_handler(commands=['start'])
 def start(message):
-    print(f"[LOG] /start command received from {message.chat.id}")
+    user_id = message.from_user.id
+    print(f"[LOG] Start command from {user_id}")
+    
     try:
-        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
 
-        # ডাটাবেজ চেক
-        user_check = supabase.table('referrals').select('*').eq('user_id', user_id).execute()
-        if not user_check.data:
-            supabase.table('referrals').insert({
-                'user_id': user_id, 
-                'referral_count': 0, 
-                'referrer_id': referrer_id if referrer_id != user_id else None
-            }).execute()
+        # ডাটাবেজ অপারেশন (Try-Except এর ভেতরে রাখা হয়েছে যাতে এরর হলে বট না থামে)
+        try:
+            user_check = supabase.table('referrals').select('*').eq('user_id', user_id).execute()
+            if not user_check.data:
+                supabase.table('referrals').insert({
+                    'user_id': user_id, 
+                    'referral_count': 0, 
+                    'referrer_id': referrer_id if referrer_id != user_id else None
+                }).execute()
 
-            if referrer_id and referrer_id != user_id:
-                ref_data = supabase.table('referrals').select('referral_count').eq('user_id', referrer_id).execute()
-                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, "🎉 কেউ আপনার রেফারে জয়েন করেছে!")
+                if referrer_id and referrer_id != user_id:
+                    ref_data = supabase.table('referrals').select('referral_count').eq('user_id', referrer_id).execute()
+                    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, "🎉 কেউ আপনার রেফারে জয়েন করেছে!")
+        except Exception as db_err:
+            print(f"[DB ERROR] {db_err}")
+            # ডাটাবেজে এরর হলেও আমরা বটকে রিপ্লাই দিতে দিব
         
         markup = InlineKeyboardMarkup()
         markup.add(InlineKeyboardButton("Play video 🔞", web_app=WebAppInfo(url=WEB_APP_URL)))
         bot.reply_to(message, "ভাইরাল ভিডিও দেখতে নিচের বাটনে ক্লিক করো 👇", reply_markup=markup)
-        print("[LOG] Reply sent for /start")
+        
     except Exception as e:
-        print(f"[ERROR] In /start: {e}")
+        print(f"[CRITICAL ERROR] {e}")
         traceback.print_exc()
 
 @bot.message_handler(commands=['png'])
 def add_png(message):
-    print(f"[LOG] /png command received: {message.text}")
     try:
         parts = message.text.split(maxsplit=1)
         if len(parts) > 1:
@@ -86,17 +90,17 @@ def add_png(message):
             admin_states[message.chat.id] = {"step": 1, "thumbnail_url": img_url}
             bot.reply_to(message, "✅ ছবি সেট হয়েছে। এখন এই ছবির জন্য **Google Drive ভিডিও লিংক** দিন।")
         else:
-            bot.reply_to(message, "সঠিক নিয়ম: `/png https://i.postimg.cc/image.jpg`")
+            bot.reply_to(message, "সঠিক নিয়ম: `/png https://link-to-image.jpg`")
     except Exception as e:
-        print(f"[ERROR] In /png: {e}")
+        print(f"[ERROR] /png: {e}")
 
 @bot.message_handler(func=lambda m: admin_states.get(m.chat.id, {}).get("step") == 1)
 def add_video_step(message):
-    print(f"[LOG] Video link received: {message.text}")
     try:
         video_url = message.text.strip()
         thumbnail_url = admin_states[message.chat.id]["thumbnail_url"]
         
+        # ডাটাবেজে ভিডিও সেভ
         supabase.table('videos').insert({
             "video_url": video_url,
             "thumbnail_url": thumbnail_url
@@ -105,16 +109,15 @@ def add_video_step(message):
         bot.reply_to(message, "🎉 অভিনন্দন! ভিডিওটি সফলভাবে অ্যাপে অ্যাড হয়েছে।")
         admin_states[message.chat.id] = {}
     except Exception as e:
-        print(f"[ERROR] In add_video_step: {e}")
-        bot.reply_to(message, "❌ সেভ করতে সমস্যা হয়েছে।")
+        print(f"[DB ERROR] Video Insert: {e}")
+        bot.reply_to(message, "❌ ডাটাবেজে সেভ করতে সমস্যা হয়েছে। আবার চেষ্টা করুন।")
 
 @app.route('/api/videos')
 def api_videos():
     try:
         res = supabase.table('videos').select('*').order('id', desc=True).execute()
         return jsonify(res.data)
-    except Exception as e:
-        print(f"[ERROR] API: {e}")
+    except:
         return jsonify([])
 
 if __name__ == "__main__":