fix: 修复 tg bot

Author: mkdir700

tgbot/app.py

@@ -104,10 +104,17 @@ def build_message(data: dict):
 
 async def get_latest_message() -> dict | None:
     message = await tg_bot.pop_message(my_chat_id)
+    """
+    (b'tgbot:5049063827', b'{"address": "EARFf4ZxBRBuPJc1DyhNwXG5GJNJYSEZHNUJwTSGhzyQ", "token_mint": "Gc2yDSR1rUZ4QuWc4yxQ3y7cvAA2AE2QmrjP3a8mpump", "token_amount": 12.85346999997273, "pre_token_balance": 283068.032564, "post_token_balance": 283055.179094, "transaction_type": "reduce", "transaction_id": "EARFf4ZxBRBuPJc1DyhNwXG5GJNJYSEZHNUJwTSGhzyQ:Gc2yDSR1rUZ4QuWc4yxQ3y7cvAA2AE2QmrjP3a8mpump:12.85346999997273:reduce", "signature": "42GPWM2XNtAdJBmuyX6owbjRK9Ej2MnkqDKP1K4mSaMgeqYnQ8S11T2MmszkHHNSx9ifnXiPCVgSkc44qVZRbotz"}')
+    """
     if message is None:
         return
-    assert isinstance(message, bytes)
-    data = json.loads(message.decode("utf-8"))
+    _, content = message
+    try:
+        data = json.loads(content.decode("utf-8"))
+    except json.JSONDecodeError:
+        logger.error(f"Failed to decode message: {content}")
+        return
     return data
 
 
@@ -161,7 +168,7 @@ async def func(bot):
         logger.info("Checking for new messages...")
         data = await get_latest_message()
         if data is None:
-            return
+            continue
         await send_message(bot, my_chat_id, data)
 
 
@@ -186,19 +193,17 @@ async def func(bot):
 
 
 def main() -> None:
-    # 替换 'YOUR_TOKEN' 为你的机器人 API Token
-    application = ApplicationBuilder().token(tg_bot_token).build()
-    bot = application.bot
-
-    # 注册处理程序
-    # application.add_handler(CommandHandler("start", start))
-    # application.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, echo))
-
-    loop = asyncio.new_event_loop()
-    loop.run_until_complete(func(bot))
-
-    # 启动机器人
-    application.run_polling()
+    # application = ApplicationBuilder().token(tg_bot_token).build()
+    # bot = application.bot
+    #
+    # # 注册处理程序
+    # # application.add_handler(CommandHandler("start", start))
+    # # application.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, echo))
+    #
+    # application.create_task(func(bot))
+    # application.run_polling()
+    bot = Bot(token=tg_bot_token)
+    asyncio.run(func(bot))
 
 
 if __name__ == "__main__":