From 8033907431d0d53897e47ce1a59a7be059e9028c Mon Sep 17 00:00:00 2001 From: Dobromir Popov Date: Fri, 11 Oct 2024 15:22:27 +0300 Subject: [PATCH] better messages --- crypto/sol/app.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/crypto/sol/app.py b/crypto/sol/app.py index 161fbca..51d82e0 100644 --- a/crypto/sol/app.py +++ b/crypto/sol/app.py @@ -1162,6 +1162,7 @@ async def subscribe_to_wallet(): while True: subscription_id = await subscribe(websocket) if subscription_id: + await send_telegram_message(f"Solana mainnet connected ({subscription_id})...") process_task = asyncio.create_task(process_messages(websocket, subscription_id)) while True: try: @@ -1189,7 +1190,7 @@ async def subscribe_to_wallet(): logger.error(f"WebSocket error: {e}") except Exception as e: logger.error(f"An unexpected error occurred: {e}") - + await send_telegram_message("reconnecting...") logger.info(f"Attempting to reconnect in {reconnect_delay} seconds...") await asyncio.sleep(reconnect_delay) reconnect_delay = min(reconnect_delay * 1.2, max_reconnect_delay) @@ -1214,7 +1215,6 @@ async def subscribe(websocket): if 'result' in response_data: subscription_id = response_data['result'] logger.info(f"Subscription successful. Subscription id: {subscription_id}") - await send_telegram_message("Solana mainnet connected... Listening for transactions.") return subscription_id else: logger.warning(f"Unexpected response: {response_data}")