Update app.py

app.py

@@ -1,12 +1,10 @@
 import os
-import telebot
 import logging
 import httpx
 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
 POWER_USER_ID = 75516649
@@ -14,10 +12,7 @@ POWER_USER_ID = 75516649
 # Proxy Configuration
 PROXY_URL = 'http://eR3LhYeoZXNWhIp:clIvQ2hSkO5CtLl@107.180.131.170:58874'
 
-# Initialize the Telegram bot
-bot = telebot.TeleBot(BOT_TOKEN)
-
-# Configure logging
+# Initialize logging
 logging.basicConfig(
     level=logging.DEBUG,
     format='%(asctime)s - %(levelname)s - %(message)s',
@@ -51,13 +46,13 @@ def handle_update():
 
                 # Log and send the response
                 logger.debug(f"Generated response: {response_text}")
-                bot.send_message(chat_id, response_text, parse_mode='Markdown')
+                bot_send_message(chat_id, response_text)
                 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, parse_mode='Markdown')
+                bot_send_message(chat_id, error_message)
                 logger.error(f"Error message sent to chat_id {chat_id}")
 
     return jsonify({'status': 'ok'}), 200
@@ -79,7 +74,7 @@ async def set_telegram_webhook():
                 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')
+                    await bot_send_message(POWER_USER_ID, "🚀 The webhook has been successfully connected! 🎉")
                     return
                 elif result.get('error_code') == 429:
                     retry_after = result['parameters'].get('retry_after', retry_delay)
@@ -92,6 +87,18 @@ async def set_telegram_webhook():
             logger.error(f"Request exception: {e}")
             return
 
+async def bot_send_message(chat_id, text):
+    """Send a message to the specified chat ID using the proxy configuration."""
+    async with httpx.AsyncClient(proxies=PROXY_URL) as client:
+        response = await client.post(
+            f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage",
+            data={"chat_id": chat_id, "text": text, "parse_mode": "Markdown"}
+        )
+        if response.status_code == 200:
+            logger.info(f"Message sent successfully to chat_id {chat_id}")
+        else:
+            logger.error(f"Failed to send message: {response.text}")
+
 def run_flask_app():
     """Launches the Flask app and sets the Telegram webhook."""
     asyncio.run(set_telegram_webhook())