Enhance CronosTransactionAnalyzer initialization and chain ID retrieval

- Updated the CronosTransactionAnalyzer class to accept a dashboard API key for improved chain identification.
- Implemented logic to dynamically determine the RPC URL and chain ID based on the provided API key or fallback to defaults.
- Added a method to fetch the chain ID from the dashboard API, enhancing flexibility and usability in transaction analysis.
- Modified bot.py to initialize the analyzer with the dashboard API key for better integration.

Author: leejw51crypto

bot/cryptocom-ai-telegram-bot/bot.py

@@ -58,8 +58,11 @@
 # Custom storage for persistence (optional)
 custom_storage = SQLitePlugin(db_path="telegram_agent_state.db")
 
-# Initialize the Cronos transaction analyzer
-tx_analyzer = CronosTransactionAnalyzer()
+# Initialize the Cronos transaction analyzer with dashboard API key
+# This will automatically determine the correct chain and RPC endpoint
+tx_analyzer = CronosTransactionAnalyzer(
+    dashboard_api_key=os.getenv("DASHBOARD_API_KEY")
+)
 
 # Global agent instance
 agent = None

bot/cryptocom-ai-telegram-bot/cronos_tx_analyzer.py

@@ -5,18 +5,55 @@
 """
 
 import json
+import os
 from typing import Any, Dict, List, Optional
 
 import requests
 from eth_utils import to_checksum_address
 from web3 import Web3
 
+try:
+    from crypto_com_agent_client.lib.types.chain_helper import (
+        CHAIN_INFO,
+        ChainId,
+    )
+    from crypto_com_developer_platform_client import Client, Network
+    AGENT_CLIENT_AVAILABLE = True
+except ImportError:
+    AGENT_CLIENT_AVAILABLE = False
+
 
 class CronosTransactionAnalyzer:
-    def __init__(self, rpc_url: str = "https://evm.cronos.org"):
+    def __init__(self, rpc_url: Optional[str] = None, dashboard_api_key: Optional[str] = None):
         """Initialize the analyzer with Cronos EVM connection"""
-        self.web3 = Web3(Web3.HTTPProvider(rpc_url))
-        self.chain_id = 25  # Cronos mainnet
+        self.dashboard_api_key = dashboard_api_key or os.getenv("DASHBOARD_API_KEY")
+        
+        # Determine chain from dashboard API key if available
+        chain_id_from_api = self._get_chain_id_from_dashboard_api()
+        
+        if rpc_url:
+            # Use provided RPC URL
+            self.rpc_url = rpc_url
+            self.chain_id = chain_id_from_api or 25  # Default to Cronos mainnet
+        elif AGENT_CLIENT_AVAILABLE and chain_id_from_api:
+            # Get chain info from dashboard API key using agent client
+            try:
+                chain_enum = ChainId(int(chain_id_from_api))
+                chain_info = CHAIN_INFO[chain_enum]
+                self.rpc_url = chain_info["rpc"]
+                self.chain_id = int(chain_id_from_api)
+                print(f"Using chain {self.chain_id} with RPC: {self.rpc_url}")
+            except (ValueError, KeyError):
+                # Fallback to default if chain not supported
+                self.rpc_url = "https://evm.cronos.org"
+                self.chain_id = 25
+                print(f"Unsupported chain {chain_id_from_api}, using fallback")
+        else:
+            # Fallback to hardcoded RPC
+            self.rpc_url = "https://evm.cronos.org"
+            self.chain_id = 25
+            
+        self.web3 = Web3(Web3.HTTPProvider(self.rpc_url))
 
         # Known address labels for better descriptions
         self.address_labels = {
@@ -72,6 +109,36 @@ def get_address_label(self, address: str) -> str:
             checksum_addr, f"0x{address[2:6]}...{address[-4:]}"
         )
 
+    def _get_chain_id_from_dashboard_api(self) -> Optional[int]:
+        """Get chain ID from dashboard API key using developer platform client"""
+        if not self.dashboard_api_key or not AGENT_CLIENT_AVAILABLE:
+            return None
+            
+        try:
+            # Initialize client with API key
+            Client.init(api_key=self.dashboard_api_key)
+            
+            # Get chain ID from developer platform
+            chain_id_response = Network.chain_id()
+            
+            if isinstance(chain_id_response, dict):
+                # Handle nested response format: {'status': 'Success', 'data': {'chainId': '338'}}
+                if "data" in chain_id_response and isinstance(chain_id_response["data"], dict):
+                    chain_id = chain_id_response["data"].get("chainId")
+                else:
+                    chain_id = chain_id_response.get("chainId")
+                    
+                if chain_id is not None:
+                    return int(chain_id)
+            else:
+                # Direct value response
+                return int(chain_id_response)
+                
+        except Exception as e:
+            print(f"Error getting chain ID from dashboard API: {e}")
+            
+        return None
+
     def add_address_label(self, address: str, label: str) -> None:
         """Add a new address label"""
         checksum_addr = to_checksum_address(address)