Update app.py

app.py

@@ -1,30 +1,24 @@
 import os
-import threading
-import time
 import telebot
 import requests
-from http.server import HTTPServer, BaseHTTPRequestHandler
+from flask import Flask, request, Response
 
 # --- Bot Setup ---
-TOKEN = os.environ.get('8354363462:AAGR1MyBo6mX69DPUdCaemR8-XcOcOoKEmg')
-if not TOKEN:
-    print("❌ TELEGRAM_BOT_TOKEN chưa được cấu hình!")
-    raise ValueError("❌ Chưa cấu hình TELEGRAM_BOT_TOKEN!")
-
-print(f"✅ Token đã load: {TOKEN[:10]}...")
+TOKEN = '8354363462:AAGR1MyBo6mX69DPUdCaemR8-XcOcOoKEmg'
+print("✅ Token loaded")
 bot = telebot.TeleBot(TOKEN)
 
 # --- Bot Handlers ---
 
 @bot.message_handler(commands=['start'])
 def send_welcome(message):
-    print(f"📩 Nhận lệnh /start từ {message.from_user.first_name}")
+    print(f"📩 /start từ {message.from_user.first_name}")
     bot.reply_to(message, "🎬 Chào bạn! Nhập tên phim muốn xem, mình sẽ lấy link trực tiếp cho nhé.")
 
 @bot.message_handler(func=lambda message: True)
 def search_and_get_link(message):
     query = message.text
-    print(f"🔍 Tìm kiếm: {query}")
+    print(f"🔍 Tìm: {query}")
     search_url = f"https://ophim1.com/v1/api/tim-kiem?keyword={query}"
 
     try:
@@ -36,7 +30,6 @@ def search_and_get_link(message):
             return
 
         movie_slug = items[0]['slug']
-
         detail_url = f"https://ophim1.com/phim/{movie_slug}"
         detail_res = requests.get(detail_url, timeout=10).json()
         movie_info = detail_res.get('movie', {})
@@ -47,7 +40,6 @@ def search_and_get_link(message):
             if server_data:
                 latest_ep = server_data[-1]
                 watch_link = latest_ep.get('link_embed', '')
-
                 response_msg = (
                     f"✅ **Đã tìm thấy: {movie_info.get('name')}**\n"
                     f"🎭 Tên gốc: {movie_info.get('origin_name')}\n"
@@ -56,7 +48,6 @@ def search_and_get_link(message):
                     f"📺 **[NHẤN VÀO ĐÂY ĐỂ XEM PHIM NGAY]({watch_link})**"
                 )
                 bot.send_message(message.chat.id, response_msg, parse_mode="Markdown")
-                print(f"✅ Đã gửi link phim: {movie_info.get('name')}")
             else:
                 bot.reply_to(message, "Hic, phim này hiện chưa có link xem.")
         else:
@@ -66,35 +57,30 @@ def search_and_get_link(message):
         print(f"❌ Lỗi: {e}")
         bot.reply_to(message, "⚠️ Có lỗi khi lấy dữ liệu từ máy chủ phim!")
 
-# --- Run bot in background thread with auto-restart ---
-def run_bot():
-    while True:
-        try:
-            print("🤖 Bot Telegram đang khởi động (polling mode)...")
-            bot.remove_webhook()
-            time.sleep(1)
-            bot.infinity_polling(timeout=60, long_polling_timeout=60)
-        except Exception as e:
-            print(f"❌ Bot lỗi: {e}")
-            print("🔄 Tự khởi động lại sau 5 giây...")
-            time.sleep(5)
-
-bot_thread = threading.Thread(target=run_bot, daemon=True)
-bot_thread.start()
-print("🤖 Bot thread đã khởi động!")
-
-# --- Simple web server for HF Spaces health check (port 7860) ---
-class HealthHandler(BaseHTTPRequestHandler):
-    def do_GET(self):
-        self.send_response(200)
-        self.send_header('Content-type', 'text/html; charset=utf-8')
-        self.end_headers()
-        html = '<h2>🎬 Bot Telegram Xem Phim đang hoạt động!</h2><p>Bot thread: running</p>'
-        self.wfile.write(html.encode('utf-8'))
-
-    def log_message(self, format, *args):
-        pass
-
-print("🌐 Web server chạy trên port 7860...")
-server = HTTPServer(('0.0.0.0', 7860), HealthHandler)
-server.serve_forever()
+# --- Flask Server ---
+app = Flask(__name__)
+
+@app.route('/', methods=['GET'])
+def index():
+    return '<h2>🎬 Bot Telegram Xem Phim đang hoạt động!</h2>'
+
+@app.route('/webhook', methods=['POST'])
+def webhook():
+    if request.headers.get('content-type') == 'application/json':
+        json_data = request.get_json()
+        update = telebot.types.Update.de_json(json_data)
+        bot.process_new_updates([update])
+        return Response('OK', status=200)
+    return Response('Bad Request', status=400)
+
+@app.route('/set_webhook', methods=['GET'])
+def set_webhook():
+    webhook_host = request.url_root.rstrip('/')
+    webhook_url = f"{webhook_host}/webhook"
+    bot.remove_webhook()
+    result = bot.set_webhook(url=webhook_url)
+    return f'Webhook URL: {webhook_url}<br>Kết quả: {result}'
+
+if __name__ == '__main__':
+    print("🌐 Server chạy trên port 7860...")
+    app.run(host='0.0.0.0', port=7860)