Update app.py

app.py

@@ -25,11 +25,23 @@ logger = logging.getLogger(__name__)
 
 app = Flask(__name__)
 
+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}")
+
 @app.route(f'/webhooks/{WEBHOOK_SECRET}', methods=['POST'])
 def handle_update():
     """Handles incoming updates from Telegram."""
     payload = request.json
-    logger.debug(f"Received payload: {payload}")  # Log the incoming payload
+    logger.debug(f"Received payload: {payload}")
 
     if payload.get('message'):
         message_text = payload['message'].get('text')
@@ -37,9 +49,8 @@ def handle_update():
 
         if message_text:
             try:
-                # Send a static response
-                static_response = "This is a static response for testing purposes."
-                asyncio.run(bot_send_message(chat_id, static_response))
+                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}")
 
             except Exception as e:
@@ -50,20 +61,8 @@ def handle_update():
 
     return jsonify({'status': 'ok'}), 200
 
-async def delete_webhook():
-    """Deletes any existing webhook."""
-    async with httpx.AsyncClient(proxies=PROXY_URL) as client:
-        response = await client.post(f"https://api.telegram.org/bot{BOT_TOKEN}/deleteWebhook")
-        result = response.json()
-        if result.get('ok'):
-            logger.info("Existing webhook deleted.")
-        else:
-            logger.error(f"Failed to delete existing webhook: {result}")
-
 async def set_telegram_webhook():
     """Sets the webhook for the Telegram bot with proxy configuration."""
-    await delete_webhook()  # Delete existing webhook before setting a new one
-    
     webhook_url = f"https://measmonysuon-flyingbird.hf.space/webhooks/{WEBHOOK_SECRET}"
     retry_attempts = 5
     retry_delay = 1  # seconds
@@ -78,8 +77,6 @@ async def set_telegram_webhook():
                 result = response.json()
                 if result.get('ok'):
                     logger.info("Webhook set successfully.")
-                    # Notify power user
-                    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,21 +89,9 @@ 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())
+    asyncio.run(set_telegram_webhook())  # Set the webhook before starting the Flask app
     app.run(host="0.0.0.0", port=5000, debug=True)
 
 if __name__ == "__main__":