Update app.py

app.py

@@ -2,16 +2,14 @@ import os
 import telebot
 import logging
 import httpx
-from flask import Flask, request, jsonify
 import asyncio
+from flask import Flask, request, jsonify
 
 # Configuration
 GOOGLE_API_KEY = 'AIzaSyAYXUMnwmR4nUGDCs97FJJsafcQAPAAuzE'
 BOT_TOKEN = '7484321656:AAExhpS7sOGMu2BCuPQrDjuXpY3sEQmBgfY'
 WEBHOOK_SECRET = 'A3%26c8%21jP%23xZ1v*Qw5kL%5E0tR%40u9%25yS6'  # URL-encoded secret
-
-# Proxy Configuration
-PROXY_URL = 'http://eR3LhYeoZXNWhIp:clIvQ2hSkO5CtLl@107.180.131.170:58874'
+POWER_USER_ID = 75516649
 
 # Initialize the Telegram bot
 bot = telebot.TeleBot(BOT_TOKEN)
@@ -42,15 +40,11 @@ def handle_update():
         if message_text:
             try:
                 # Forward message to Gradio and get the response
-                async def get_gradio_response(message_text):
-                    async with httpx.AsyncClient(proxies=PROXY_URL) as client:
-                        response = await client.post('http://localhost:7860/gradio', json={'message': message_text})
-                        if response.status_code == 200:
-                            return response.json().get('response', 'Sorry, I cannot process this request.')
-                        else:
-                            return 'Error occurred while processing your request.'
-
-                response_text = asyncio.run(get_gradio_response(message_text))
+                response = requests.post('http://localhost:7860/gradio', json={'message': message_text})
+                if response.status_code == 200:
+                    response_text = response.json().get('response', 'Sorry, I cannot process this request.')
+                else:
+                    response_text = 'Error occurred while processing your request.'
 
                 # Log and send the response
                 logger.debug(f"Generated response: {response_text}")
@@ -66,14 +60,14 @@ def handle_update():
     return jsonify({'status': 'ok'}), 200
 
 async def set_telegram_webhook():
-    """Sets the webhook for the Telegram bot using a proxy."""
+    """Sets the webhook for the Telegram bot."""
     webhook_url = f"https://measmonysuon-flyingbird.hf.space/webhooks/{WEBHOOK_SECRET}"
     retry_attempts = 5
     retry_delay = 1  # seconds
     
     for attempt in range(retry_attempts):
         try:
-            async with httpx.AsyncClient(proxies=PROXY_URL) as client:
+            async with httpx.AsyncClient() as client:
                 response = await client.post(
                     f"https://api.telegram.org/bot{BOT_TOKEN}/setWebhook",
                     data={"url": webhook_url},
@@ -81,6 +75,8 @@ async def set_telegram_webhook():
                 result = response.json()
                 if result.get('ok'):
                     logger.info("Webhook set successfully.")
+                    # Notify power user
+                    bot.send_message(POWER_USER_ID, "🚀 The webhook has been successfully connected! 🎉", parse_mode='Markdown')
                     return
                 elif result.get('error_code') == 429:
                     retry_after = result['parameters'].get('retry_after', retry_delay)