Membangun Sistem Monitoring On-Chain Solana Real-Time

import asyncio
from solana.rpc.async_api import AsyncClient
 
class RobustSolanaClient:
    def __init__(self, endpoints: list[str]):
        self.endpoints = endpoints
        self.current_idx = 0
 
    async def get_balance_with_retry(self, pubkey: str, max_retries: int = 3):
        for attempt in range(max_retries):
            endpoint = self.endpoints[self.current_idx]
            try:
                async with AsyncClient(endpoint) as client:
                    resp = await client.get_balance(pubkey)
                    return resp.value
            except Exception as err:
                print(f"[WARN] Endpoint {endpoint} gagal: {err}. Beralih ke fallback...")
                self.current_idx = (self.current_idx + 1) % len(self.endpoints)
                await asyncio.sleep(0.5)
        raise RuntimeError("Semua endpoint RPC gagal merespons.")