diff --git a/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py b/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py index 271d0923..0dc6b348 100755 --- a/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py +++ b/apps/coordinator-api/src/app/agent_identity/wallet_adapter_enhanced.py @@ -858,7 +858,6 @@ class AITBCWalletAdapter(EnhancedWalletAdapter): # Also accept 0x addresses for backward compatibility if address.startswith("0x") and len(address) == 42: return True - logger.debug(f"Address validation failed for {address}: starts with 'ait1': {address.startswith('ait1')}, len: {len(address)}") return False except Exception as e: logger.error(f"Address validation exception for {address}: {e}") @@ -978,7 +977,6 @@ class WalletAdapterFactory: if not adapter_class: raise ValueError(f"Unsupported chain ID: {chain_id}") - logger.info(f"Creating {adapter_class.__name__} adapter for chain {chain_id}") return adapter_class(rpc_url, security_level) @staticmethod diff --git a/apps/coordinator-api/src/app/contexts/cross_chain/services/cross_chain/bridge_enhanced.py b/apps/coordinator-api/src/app/contexts/cross_chain/services/cross_chain/bridge_enhanced.py index b420a5ca..114e45a7 100755 --- a/apps/coordinator-api/src/app/contexts/cross_chain/services/cross_chain/bridge_enhanced.py +++ b/apps/coordinator-api/src/app/contexts/cross_chain/services/cross_chain/bridge_enhanced.py @@ -87,7 +87,6 @@ class CrossChainBridgeService: async def initialize_bridge(self, chain_configs: dict[int, dict[str, Any]]) -> None: """Initialize bridge service with chain configurations""" try: - logger.info(f"Initializing bridge service for chain configs: {list(chain_configs.keys())}") for chain_id, config in chain_configs.items(): # Create wallet adapter for each chain adapter = WalletAdapterFactory.create_adapter( @@ -96,7 +95,6 @@ class CrossChainBridgeService: security_level=SecurityLevel(config.get("security_level", "medium")), ) self.wallet_adapters[chain_id] = adapter - logger.info(f"Initialized adapter for chain {chain_id}: {type(adapter).__name__}") # Initialize bridge protocol protocol = config.get("protocol", BridgeProtocol.ATOMIC_SWAP) @@ -132,8 +130,14 @@ class CrossChainBridgeService: deadline_minutes: int = 30, ) -> dict[str, Any]: """Create a new cross-chain bridge request""" - try: + # Check whitelist first + if (source_chain_id, target_chain_id) not in self.allowed_transfers: + logger.warning(f"Chain pair {source_chain_id}->{target_chain_id} not in whitelist") + raise ValueError( + f"Cross-chain transfer from chain {source_chain_id} to {target_chain_id} " + "is not permitted (chain isolation policy)" + ) # Validate chains if source_chain_id not in self.wallet_adapters or target_chain_id not in self.wallet_adapters: raise ValueError("Unsupported chain ID")