Update app.py

app.py

@@ -3,18 +3,13 @@ import telebot
 import logging
 import httpx
 from flask import Flask, request, jsonify
-import time
-
-# Suppress experimental warnings
-os.environ['HF_HUB_DISABLE_EXPERIMENTAL_WARNING'] = '1'
+import asyncio
 
 # 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:[email protected]:58874'
-
 # Initialize the Telegram bot
 bot = telebot.TeleBot(BOT_TOKEN)
 
@@ -43,33 +38,35 @@ def handle_update():
 
         if message_text:
             try:
-                # Simple response mechanism
-                response_text = f"You said: {message_text}"
+                # Forward message to Gradio and get the response
+                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 the response
+                # Log and send the response
                 logger.debug(f"Generated response: {response_text}")
-
-                # Send the response to the chat
                 bot.send_message(chat_id, response_text, parse_mode='Markdown')
                 logger.info(f"Response sent to chat_id {chat_id}")
 
             except Exception as e:
                 logger.error(f"Error during processing: {e}")
-                error_message = "Sorry, I can't process this right now."
+                error_message = "Sorry, I can't answer this query right now but I will improve from time to time."
                 bot.send_message(chat_id, error_message, parse_mode='Markdown')
                 logger.error(f"Error message sent to chat_id {chat_id}")
 
     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 without using a proxy."""
     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,7 +78,7 @@ async def set_telegram_webhook():
                 elif result.get('error_code') == 429:
                     retry_after = result['parameters'].get('retry_after', retry_delay)
                     logger.warning(f"Rate limit exceeded. Retrying after {retry_after} seconds.")
-                    time.sleep(retry_after)
+                    await asyncio.sleep(retry_after)
                 else:
                     logger.error(f"Failed to set webhook: {result}")
                     return
@@ -91,7 +88,6 @@ async def set_telegram_webhook():
 
 def run_flask_app():
     """Launches the Flask app and sets the Telegram webhook."""
-    import asyncio
     asyncio.run(set_telegram_webhook())
     app.run(host="0.0.0.0", port=5000, debug=True)