Update app.py

app.py

@@ -6,7 +6,7 @@ from flask import Flask, request, jsonify
 
 # Configuration
 BOT_TOKEN = '7484321656:AAExhpS7sOGMu2BCuPQrDjuXpY3sEQmBgfY'
-WEBHOOK_SECRET = 'my_secret'  # URL-encoded secret
+WEBHOOK_SECRET = 'A3%26c8%21jP%23xZ1v*Qw5kL%5E0tR%40u9%25yS6'  # URL-encoded secret
 POWER_USER_ID = 75516649
 
 # Proxy Configuration
@@ -49,9 +49,21 @@ def handle_update():
 
         if message_text:
             try:
-                response_text = "This is a static response for testing purposes."
-                asyncio.run(bot_send_message(chat_id, response_text))
-                logger.info(f"Static response sent to chat_id {chat_id}")
+                # Forward message to Gradio and get the response
+                async def forward_message():
+                    async with httpx.AsyncClient(proxies=PROXY_URL) as client:
+                        response = await client.post(
+                            'http://localhost:7860/',  # Gradio app URL
+                            json={'text': message_text}
+                        )
+                        if response.status_code == 200:
+                            response_text = response.json().get('data', 'Error processing request.')
+                        else:
+                            response_text = 'Error occurred while processing your request.'
+                        await bot_send_message(chat_id, response_text)
+
+                asyncio.run(forward_message())
+                logger.info(f"Response sent to chat_id {chat_id}")
 
             except Exception as e:
                 logger.error(f"Error during processing: {e}")
@@ -61,9 +73,9 @@ def handle_update():
 
     return jsonify({'status': 'ok'}), 200
 
-async def set_telegram_webhook():
-    """Sets the webhook for the Telegram bot with proxy configuration."""
-    webhook_url = f"https://measmonysuon-flyingbird.hf.space/webhooks/{WEBHOOK_SECRET}"
+async def set_telegram_webhook(flask_url):
+    """Sets the webhook for the Telegram bot using the provided Flask URL."""
+    webhook_url = f"{flask_url}/webhooks/{WEBHOOK_SECRET}"
     retry_attempts = 5
     retry_delay = 1  # seconds
     
@@ -91,7 +103,8 @@ async def set_telegram_webhook():
 
 def run_flask_app():
     """Launches the Flask app and sets the Telegram webhook."""
-    asyncio.run(set_telegram_webhook())  # Set the webhook before starting the Flask app
+    flask_url = "https://your-flask-url.com"  # Replace with your actual Flask URL
+    asyncio.run(set_telegram_webhook(flask_url))  # Set the webhook before starting the Flask app
     app.run(host="0.0.0.0", port=5000, debug=True)
 
 if __name__ == "__main__":