Update app.py

app.py

@@ -38,21 +38,22 @@ def handle_update():
         if message_text:
             try:
                 # 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.'
+                async def forward_message():
+                    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:
+                            response_text = response.json().get('response', 'Sorry, I cannot process this request.')
+                        else:
+                            response_text = 'Error occurred while processing your request.'
+                        await bot_send_message(chat_id, response_text)
 
-                # Log and send the response
-                logger.debug(f"Generated response: {response_text}")
-                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}")
                 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)
+                asyncio.run(bot_send_message(chat_id, error_message))
                 logger.error(f"Error message sent to chat_id {chat_id}")
 
     return jsonify({'status': 'ok'}), 200