Merge pull request #11 from miohtama/feat/telegram-start-notification

Start notification for Telegram

Author: tsudmi

main.py

@@ -28,6 +28,7 @@
     InterruptHandler,
     check_default_account_balance,
     wait_prysm_ready,
+    telegram,
 )
 
 # Send notification to admins on error
@@ -63,11 +64,19 @@ def main() -> None:
     # wait for interrupt
     interrupt_handler = InterruptHandler()
 
-    # wait that node is synced before trying to do anything
-    wait_prysm_ready(
-        interrupt_handler, BEACON_CHAIN_RPC_ENDPOINT, PROCESS_INTERVAL, logger
+    # Notify Telegram the oracle is warming up, so that
+    # oracle maintainers know the service has restarted
+    telegram.notify(
+        message=f"Oracle starting with account [{web3_client.eth.defaultAccount}]"
+        f"(https://etherscan.io/address/{web3_client.eth.defaultAccount})",
+        parse_mode="markdown",
+        raise_on_errors=True,
+        disable_web_page_preview=True,
     )
 
+    # wait that node is synced before trying to do anything
+    wait_prysm_ready(interrupt_handler, BEACON_CHAIN_RPC_ENDPOINT, PROCESS_INTERVAL)
+
     reward_token_total_rewards = RewardToken(
         w3=web3_client, interrupt_handler=interrupt_handler
     )

src/utils.py

@@ -11,7 +11,7 @@
 from eth_typing.evm import HexAddress
 from google.protobuf import empty_pb2
 from grpc import insecure_channel, RpcError, StatusCode
-from loguru import logger, Logger
+from loguru import logger
 from notifiers.core import get_notifier  # type: ignore
 from web3 import Web3
 from web3.contract import Contract
@@ -206,7 +206,6 @@ def wait_prysm_ready(
     interrupt_handler: InterruptHandler,
     endpoint: str,
     process_interval: int,
-    logger: Logger,
 ) -> None:
     """Wait that Prysm accepts requests and is synced.