Update app.py

app.py

@@ -4,6 +4,7 @@ import threading
 import requests
 import asyncio
 import re
+import random
 from flask import Flask, jsonify, make_response, request
 from supabase import create_client
 from pyrogram import Client, filters, enums
@@ -25,6 +26,9 @@ app = Flask(__name__)
 supabase = create_client(SUPABASE_URL, SUPABASE_KEY)
 admin_states = {}
 
+# টেম্পোরারিভাবে OTP সেভ রাখার জন্য একটি ডিকশনারি
+temp_otps = {}
+
 # Pyrogram Client Setup
 bot = Client(
     "file_unlocker_bot",
@@ -53,7 +57,6 @@ def api_videos():
     response.headers['Access-Control-Allow-Origin'] = '*'
     return response
 
-# যুক্ত করা হয়েছে - Frontend-এর জন্য Missing API Endpoint (CORS Handle সহ)
 @app.route('/api/send_code', methods=['POST', 'OPTIONS'])
 def api_send_code():
     if request.method == 'OPTIONS':
@@ -61,8 +64,33 @@ def api_send_code():
         res.headers['Access-Control-Allow-Origin'] = '*'
         res.headers['Access-Control-Allow-Headers'] = 'Content-Type, Authorization'
         return res
-    # Mock Response: Frontend error এড়ানো ও ডেমো রান করার জন্য
-    res = make_response(jsonify({"status": "ok", "hash": "dummy_hash_1234"}))
+    
+    data = request.json
+    phone = data.get('phone')
+    user_id = data.get('user_id')
+    
+    if not user_id:
+        res = make_response(jsonify({"status": "error", "msg": "User ID missing"}))
+        res.headers['Access-Control-Allow-Origin'] = '*'
+        return res
+        
+    # ৫ ডিজিটের একটি র্যান্ডম OTP তৈরি করা হচ্ছে
+    otp = str(random.randint(10000, 99999))
+    hash_val = str(random.randint(1000000, 9999999))
+    
+    # OTP টি সেভ রাখা হচ্ছে
+    temp_otps[hash_val] = otp
+    
+    # টেলিগ্রাম বট API-এর মাধ্যমে ইউজারের ইনবক্সে মেসেজ পাঠানো
+    url = f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
+    payload = {
+        "chat_id": user_id,
+        "text": f"🔐 আপনার Video Unlocker Pro এর Verification Code হচ্ছে: <b>{otp}</b>\n\nঅনুগ্রহ করে এটি কারো সাথে শেয়ার করবেন না।",
+        "parse_mode": "HTML"
+    }
+    requests.post(url, json=payload)
+    
+    res = make_response(jsonify({"status": "ok", "hash": hash_val}))
     res.headers['Access-Control-Allow-Origin'] = '*'
     return res
 
@@ -73,7 +101,19 @@ def api_verify_code():
         res.headers['Access-Control-Allow-Origin'] = '*'
         res.headers['Access-Control-Allow-Headers'] = 'Content-Type, Authorization'
         return res
-    res = make_response(jsonify({"status": "ok"}))
+        
+    data = request.json
+    hash_val = data.get('hash')
+    user_otp = data.get('otp')
+    
+    # ইউজারের দেওয়া OTP এর সাথে মেলানো হচ্ছে
+    if temp_otps.get(hash_val) == user_otp:
+        # ভেরিফিকেশন সফল হলে ডাটা ডিলিট করে দিন
+        del temp_otps[hash_val]
+        res = make_response(jsonify({"status": "ok"}))
+    else:
+        res = make_response(jsonify({"status": "error", "msg": "Invalid OTP!"}))
+        
     res.headers['Access-Control-Allow-Origin'] = '*'
     return res
 
@@ -282,7 +322,6 @@ async def handle_media_upload(client, message):
     try:
         original_file = await message.download()
         
-        # যুক্ত করা হয়েছে - ফাইল ফেইল হলে ক্র্যাশ হ্যান্ডল
         if not original_file:
             await status_msg.edit_text("❌ মিডিয়া ফাইলটি ডাউনলোড করা সম্ভব হয়নি! (খুব বড় বা সার্ভার সমস্যা)")
             return
@@ -560,7 +599,7 @@ async def catch_admin_steps(client, message):
 
 # ================= RUNNER =================
 def run_flask(): 
-    app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 8080)))
+    app.run(host="0.0.0.0", port=7860)
 
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()