ap12

app.py

@@ -7,6 +7,7 @@ from werkzeug.utils import secure_filename
 import re
 import asyncio
 from telegram import Bot
+from telegram.error import TelegramError
 
 # Load environment variables
 load_dotenv()
@@ -25,6 +26,30 @@ TELEGRAM_BOT_TOKEN = "7868898974:AAH2p7sBkj0TH4sD__giOmUt-2ZXn7sg0_c"
 TELEGRAM_CHAT_ID = "5397241102"  # Hardcoded chat ID
 bot = Bot(token=TELEGRAM_BOT_TOKEN)
 
+# Add this function to verify bot connection
+async def verify_bot_connection():
+    try:
+        bot_info = await bot.get_me()
+        print(f"✅ Successfully connected to Telegram bot: @{bot_info.username}")
+        
+        # Verify chat ID
+        try:
+            await bot.send_message(
+                chat_id=TELEGRAM_CHAT_ID,
+                text="🔄 Certificate validation system is online and connected!"
+            )
+            print(f"✅ Successfully sent test message to chat ID: {TELEGRAM_CHAT_ID}")
+            return True
+        except TelegramError as chat_error:
+            print(f"❌ Failed to send message to chat ID {TELEGRAM_CHAT_ID}")
+            print(f"Error: {chat_error}")
+            return False
+            
+    except TelegramError as e:
+        print(f"❌ Failed to connect to Telegram bot")
+        print(f"Error: {e}")
+        return False
+
 async def send_invalid_certificate_notification(cert_name, details):
     """Send Telegram notification for invalid certificate."""
     try:
@@ -36,12 +61,27 @@ Details: {details}
 
 Please review this certificate as soon as possible.
 """
-        await bot.send_message(chat_id=TELEGRAM_CHAT_ID, text=message, parse_mode='HTML')
+        result = await bot.send_message(
+            chat_id=TELEGRAM_CHAT_ID, 
+            text=message, 
+            parse_mode='HTML'
+        )
+        print(f"✅ Successfully sent notification to Telegram")
         return True
-    except Exception as e:
-        print(f"Failed to send Telegram notification: {str(e)}")
+    except TelegramError as e:
+        print(f"❌ Failed to send Telegram notification: {str(e)}")
+        print(f"Chat ID used: {TELEGRAM_CHAT_ID}")
         return False
 
+# Modify the app initialization to verify bot connection
+@app.before_first_request
+def initialize():
+    print("🔄 Initializing Telegram bot connection...")
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+    loop.run_until_complete(verify_bot_connection())
+    loop.close()
+
 def check_validity_from_response(response_text):
     """Extract validity status from Gemini's response."""
     # Look for validity indicators in the response