Update app.py

app.py

@@ -102,7 +102,6 @@ TOOL_DEFINITIONS = [
     },
 ]
 
-
 class EventEmitter:
     def __init__(self, event_emitter):
         self.event_emitter = event_emitter
@@ -175,7 +174,6 @@ def parse_command(user_message):
         command = command.split("@")[0]
     return command[1:]
 
-
 async def handle_telegram_update(update: Update, context):
     if not update.message:
         if update.callback_query:
@@ -287,7 +285,6 @@ async def handle_telegram_update(update: Update, context):
     else:
         await process_ai_message(chat_id, user_message, from_user_id, context)
 
-
 async def process_ai_message(chat_id, user_message, from_user_id, context):
     history = chat_histories.get(chat_id, [])
     user_temp = USER_SETTINGS.get(from_user_id, {}).get("temperature", DEFAULT_TEMP)
@@ -337,7 +334,6 @@ async def process_ai_message(chat_id, user_message, from_user_id, context):
         logging.error(f"处理消息时发生错误: {error}")
         await send_telegram_message(chat_id=chat_id, text="处理消息时发生错误，请稍后再试", context=context)
 
-
 async def handle_ai_response(ai_data, chat_id, history, event_emitter, context):
     if ai_data and ai_data.get("choices") and len(ai_data["choices"]) > 0:
         choice = ai_data["choices"][0]
@@ -387,7 +383,6 @@ async def handle_ai_response(ai_data, chat_id, history, event_emitter, context):
         return "AI 返回了无法识别的格式"
     return "AI 返回了无法识别的格式"
 
-
 async def execute_tool_call(tool_call, event_emitter):
     name = tool_call["function"]["name"]
     args = tool_call["function"].get("arguments", {})
@@ -484,7 +479,6 @@ async def execute_tool_call(tool_call, event_emitter):
             "content": "未知的工具调用",
         }
 
-
 async def handle_callback_query(callback_query, context):
     chat_id = callback_query.message.chat.id
     data = callback_query.data
@@ -502,14 +496,12 @@ async def handle_callback_query(callback_query, context):
         context=context
     )
 
-
 async def send_event_message(chat_id, event, context):
     if event["type"] == "status":
         await send_telegram_message(chat_id=chat_id, text=f"状态更新: {event['data']['description']}", context=context)
     elif event["type"] == "citation":
         await send_telegram_message(chat_id=chat_id, text=f"引用信息: {event['data']['metadata'][0]['name']}", context=context)
 
-
 async def send_telegram_message(chat_id, text, context, options=None):
     url = f"{PHP_PROXY_URL}/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
     json_data = {"chat_id": chat_id, "text": text}
@@ -524,7 +516,6 @@ async def send_telegram_message(chat_id, text, context, options=None):
     except Exception as error:
         logging.error(f"发送 Telegram 消息时发生错误: {error}")
 
-
 def get_help_message():
     return f"""
 可用指令：
@@ -554,7 +545,6 @@ def get_help_message():
   - 机器人具有攻击性，请谨慎使用。
 """
 
-
 async def main():
     logging.basicConfig(level=logging.INFO)
 
@@ -591,9 +581,12 @@ async def main():
     # Message handler for all text messages
     application.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_telegram_update))
 
+    # Initialize the bot
+    await application.initialize()
     # Start the bot
-    await application.run_polling()
+    await application.start()
+    # Start polling updates from Telegram
+    await application.updater.start_polling()
 
 if __name__ == "__main__":
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(main())
+    asyncio.run(main())