Update app.py

app.py

@@ -20,7 +20,7 @@ TELEGRAM_BOT_TOKEN = os.environ.get("TELEGRAM_BOT_TOKEN")
 AI_API_ENDPOINT = os.environ.get("AI_API_ENDPOINT", "https://new.yangtb2024.me/v1/chat/completions")
 AI_API_KEY = os.environ.get("AI_API_KEY")
 AI_MODEL = os.environ.get("AI_MODEL", "gemini-2.0-flash-exp")
-CF_WORKER_URL = os.environ.get("CF_WORKER_URL")
+PHP_PROXY_URL = os.environ.get("PHP_PROXY_URL")
 
 AI_API_HEADERS = {
     "Content-Type": "application/json",
@@ -120,30 +120,28 @@ class EventEmitter:
             {"document": [content], "metadata": [{"name": title, "source": url, "html": False}]},
         )
 
-async def check_cf_worker_health():
+
+async def check_php_proxy_health():
     try:
-        url = f"{CF_WORKER_URL}/health"
-        logging.info(f"Checking Cloudflare Worker health at: {url}")
+        url = f"{PHP_PROXY_URL}/health"
         async with aiohttp.ClientSession() as session:
             async with session.get(url) as response:
-                logging.info(f"Cloudflare Worker health check response status: {response.status}")
                 if response.ok:
-                    logging.info("Cloudflare Worker health check passed.")
+                    logging.info("PHP proxy health check passed.")
                     return True
                 else:
                     error_text = await response.text()
-                    logging.error(f"Cloudflare Worker health check failed: {response.status}, {error_text}")
+                    logging.error(f"PHP proxy health check failed: {response.status}, {error_text}")
                     return False
     except Exception as e:
-        logging.error(f"Cloudflare Worker health check error: {e}")
+        logging.error(f"PHP proxy health check error: {e}")
         return False
 
-
 async def set_bot_commands(bot: Bot):
     max_retries = 3
     for attempt in range(max_retries):
       try:
-        url = f"{CF_WORKER_URL}/bot{TELEGRAM_BOT_TOKEN}/deleteMyCommands"
+        url = f"{PHP_PROXY_URL}/bot{TELEGRAM_BOT_TOKEN}/deleteMyCommands"
         async with aiohttp.ClientSession() as session:
            async with session.post(url) as response:
                 if not response.ok:
@@ -155,7 +153,7 @@ async def set_bot_commands(bot: Bot):
             (command[0], command[1])
             for command in BOT_COMMANDS
         ]
-        url = f"{CF_WORKER_URL}/bot{TELEGRAM_BOT_TOKEN}/setMyCommands"
+        url = f"{PHP_PROXY_URL}/bot{TELEGRAM_BOT_TOKEN}/setMyCommands"
         async with aiohttp.ClientSession() as session:
            async with session.post(url, json={"commands": commands}) as response:
                 if not response.ok:
@@ -512,7 +510,7 @@ async def send_event_message(chat_id, event, context):
 
 
 async def send_telegram_message(chat_id, text, context, options=None):
-    url = f"{CF_WORKER_URL}/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
+    url = f"{PHP_PROXY_URL}/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
     json_data = {"chat_id": chat_id, "text": text}
     if options:
         json_data.update(options)
@@ -558,9 +556,9 @@ def get_help_message():
 
 async def main():
     logging.basicConfig(level=logging.INFO)
-    
-    if not await check_cf_worker_health():
-        logging.error("Cloudflare Worker health check failed. Exiting.")
+
+    if not await check_php_proxy_health():
+        logging.error("PHP proxy health check failed. Exiting.")
         return
 
     application = Application.builder().token(TELEGRAM_BOT_TOKEN).build()