Telegram support

README.md

@@ -23,6 +23,7 @@ A CLI tool to deploy, monitor and manage validator keys for the Lido CSM.
 - Exit validators:
   - Manually, with its public key
   - Automatically, by monitoring the Lido Validator Exit Bus Oracle and actioning exit requests
+  - Telegram notifications for detected exit requests
 - Support for remote signer setups (e.g. web3signer)
 
 ## Pre-requisites
@@ -71,6 +72,10 @@ url="http://my-remote-signer.xyz:port"
 
 [monitoring]
 node_operator_ids = [420, 666]
+
+[telegram]
+bot_token = 'xxxxxxxx-telegram-bot-token'
+channel_id = '-123456'
 ```
 
 Some of these parameters are optional and can be omitted depending on the functionality you want to use. See the next section for more details.
@@ -136,6 +141,13 @@ Only required for state checks and automated exits, not for deploying validators
 
 - `node_operator_ids`: List of one or more node operator IDs to monitor for exit requests
 
+### Telegram Configuration
+
+Only required for receiving validator exit notifications via Telegram.
+
+- `bot_token`: Telegram bot token
+- `channel_id`: Telegram channel ID
+
 ## Execute
 
 ### Deploying validators 
@@ -168,6 +180,8 @@ This subcommand will submit an exit request for a validator with a given public
 
 This subcommand will monitor the Lido Validator Exit Bus Oracle and log exit requests for the configured node operator ids.
 
-`python -m swarm auto_exit [--delete]`
+`python -m swarm auto_exit [--delete] [--telegram]`
 
 The `--delete` flag indicates that the validator will be automatically exited when an exit request has been detected.
+
+The `--telegram` flag indicates that the exit request will be relayed to a Telegram channel.

config.toml.holesky.example

@@ -23,3 +23,7 @@ url="http://my-remote-signer.xyz:port"
 
 [monitoring]
 node_operator_ids = [420, 666]
+
+[telegram]
+bot_token = 'xxxxxxxx-telegram-bot-token'
+channel_id = '-123456'

config.toml.mainnet.example

@@ -23,3 +23,7 @@ url="http://my-remote-signer.xyz:port"
 
 [monitoring]
 node_operator_ids = [999999]
+
+[telegram]
+bot_token = 'xxxxxxxx-telegram-bot-token'
+channel_id = '-123456'

requirements.txt

@@ -2,3 +2,4 @@ pytest-asyncio
 requests==2.32.3
 toml==0.10.2
 web3
+python-telegram-bot

swarm/__main__.py

@@ -34,6 +34,7 @@
 
     parser_exit_monitor = subparsers.add_parser('auto_exit', help='Monitor for validator exit requests')
     parser_exit_monitor.add_argument('--delete', action='store_true', help='automatically exit validators')
+    parser_exit_monitor.add_argument('--telegram', action='store_true', help='send telegram notifications')
     parser_exit_monitor.set_defaults(func=exit.automated_exit)
 
     args = parser.parse_args()

swarm/exit.py

@@ -15,9 +15,13 @@ async def automated_exit(config: dict, args: Namespace) -> None:
     csm = CSM(config)
     handler = ExitHandler(config)
 
-
+    if args.telegram:
+        await handler.send_telegram_message('Automated exit monitor started')
+
     async for exit_event in csm.exit_monitor():
         pubkey = web3.Web3.to_hex(exit_event.args.validatorPubkey)
-        print(f'requested exit for validator with pubkey {pubkey}')
+        print(f'Requested exit for validator with pubkey {pubkey}')
         if args.delete:
             handler.exit(pubkey)
+        if args.telegram:
+            await handler.send_telegram_message(f'Requested exit for validator with pubkey {pubkey}')

swarm/validator/exit_handler.py

@@ -1,5 +1,6 @@
 from eth_typing import Address
 import requests
+import telegram
 
 from swarm.exception import ExitSignException, ExitBroadcastException, ConsensusLayerRPCException
 from ..validator.ssh_tunnel import SSHTunnel
@@ -25,6 +26,10 @@ def __init__(self, config: dict) -> None:
             'ContentType': 'application/json'
         }
 
+        if 'telegram' in config and 'bot_token' in config['telegram'] and 'channel_id' in config['telegram']:
+            self.telegram_bot_token = config['telegram']['bot_token']
+            self.telegram_channel_id = config['telegram']['channel_id']
+
     def exit(self, pubkey: Address) -> None:
         # try local validator
         with SSHTunnel(self.keymanager_ssh, self.keymanager_port):
@@ -47,3 +52,10 @@ def exit(self, pubkey: Address) -> None:
             raise(ExitBroadcastException('Could not publish signed exit message'))
 
         print(f'published exit message for validator: {pubkey}')
+
+    async def send_telegram_message(self, message: str) -> None:
+        try:
+            bot = telegram.Bot(token=self.telegram_bot_token)
+            await bot.send_message(chat_id=self.telegram_channel_id, text=message)
+        except Exception as e:
+            print(f"Error sending Telegram message: {str(e)}")