diff --git a/packages/komodo_defi_framework/lib/komodo_defi_framework.dart b/packages/komodo_defi_framework/lib/komodo_defi_framework.dart index 2f57237e5..0946cae84 100644 --- a/packages/komodo_defi_framework/lib/komodo_defi_framework.dart +++ b/packages/komodo_defi_framework/lib/komodo_defi_framework.dart @@ -14,6 +14,7 @@ import 'package:logging/logging.dart'; export 'package:komodo_defi_framework/src/client/kdf_api_client.dart'; export 'package:komodo_defi_framework/src/config/event_streaming_config.dart'; export 'package:komodo_defi_framework/src/config/kdf_config.dart'; +export 'package:komodo_defi_framework/src/config/kdf_logging_config.dart'; export 'package:komodo_defi_framework/src/config/kdf_startup_config.dart'; export 'package:komodo_defi_framework/src/services/seed_node_service.dart'; export 'package:komodo_defi_framework/src/streaming/event_streaming_service.dart'; diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/bch_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/bch_activation_strategy.dart index c59b3f412..612713c1e 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/bch_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/bch_activation_strategy.dart @@ -1,6 +1,7 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; import 'package:komodo_defi_types/komodo_defi_types.dart'; @@ -93,20 +94,22 @@ class BchActivationStrategy extends ProtocolActivationStrategy { []; // Debug logging for BCH activation - log( - '[RPC] Activating BCH platform: ${asset.id.id}', - name: 'BchActivationStrategy', - ); - log( - '[RPC] Activation parameters: ${jsonEncode({ - 'ticker': asset.id.id, - 'protocol': asset.protocol.subClass.formatted, - 'slp_token_count': children?.length ?? 0, - 'slp_tokens': children?.map((e) => e.id.id).toList() ?? [], - 'activation_params': bchConfig.toRpcParams(), - })}', - name: 'BchActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Activating BCH platform: ${asset.id.id}', + name: 'BchActivationStrategy', + ); + log( + '[RPC] Activation parameters: ${jsonEncode({ + 'ticker': asset.id.id, + 'protocol': asset.protocol.subClass.formatted, + 'slp_token_count': children?.length ?? 0, + 'slp_tokens': children?.map((e) => e.id.id).toList() ?? [], + 'activation_params': bchConfig.toRpcParams(), + })}', + name: 'BchActivationStrategy', + ); + } // Enable BCH with SLP support final response = await client.rpc.slp.enableBchWithTokens( @@ -115,10 +118,12 @@ class BchActivationStrategy extends ProtocolActivationStrategy { slpTokensRequests: slpTokensRequests, ); - log( - '[RPC] Successfully activated BCH with ${children?.length ?? 0} SLP tokens', - name: 'BchActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Successfully activated BCH with ${children?.length ?? 0} SLP tokens', + name: 'BchActivationStrategy', + ); + } yield ActivationProgress( status: 'Verifying activation...', @@ -156,28 +161,32 @@ class BchActivationStrategy extends ProtocolActivationStrategy { ); // Debug logging for SLP token activation - log( - '[RPC] Activating SLP token: ${asset.id.id}', - name: 'BchActivationStrategy', - ); - log( - '[RPC] Activation parameters: ${jsonEncode({ - 'ticker': asset.id.id, - 'protocol': asset.protocol.subClass.formatted, - 'parent_id': asset.id.parentId?.id, - })}', - name: 'BchActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Activating SLP token: ${asset.id.id}', + name: 'BchActivationStrategy', + ); + log( + '[RPC] Activation parameters: ${jsonEncode({ + 'ticker': asset.id.id, + 'protocol': asset.protocol.subClass.formatted, + 'parent_id': asset.id.parentId?.id, + })}', + name: 'BchActivationStrategy', + ); + } await client.rpc.slp.enableSlpToken( ticker: asset.id.id, params: SlpActivationParams(), ); - log( - '[RPC] Successfully activated SLP token: ${asset.id.id}', - name: 'BchActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Successfully activated SLP token: ${asset.id.id}', + name: 'BchActivationStrategy', + ); + } yield ActivationProgress.success( details: ActivationProgressDetails( diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/custom_erc20_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/custom_erc20_activation_strategy.dart index 6b932aca0..9d0ce73a8 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/custom_erc20_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/custom_erc20_activation_strategy.dart @@ -1,6 +1,7 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; import 'package:komodo_defi_types/komodo_defi_type_utils.dart'; @@ -70,20 +71,22 @@ class CustomErc20ActivationStrategy extends ProtocolActivationStrategy { final contractAddress = protocolData.value('contract_address'); // Debug logging for custom ERC20 token activation - log( - '[RPC] Activating custom ERC20 token: ${asset.id.id}', - name: 'CustomErc20ActivationStrategy', - ); - log( - '[RPC] Activation parameters: ${jsonEncode({ - 'ticker': asset.id.id, - 'protocol': asset.protocol.subClass.formatted, - 'platform': platform, - 'contract_address': contractAddress, - 'activation_params': activationParams.toRpcParams(), - })}', - name: 'CustomErc20ActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Activating custom ERC20 token: ${asset.id.id}', + name: 'CustomErc20ActivationStrategy', + ); + log( + '[RPC] Activation parameters: ${jsonEncode({ + 'ticker': asset.id.id, + 'protocol': asset.protocol.subClass.formatted, + 'platform': platform, + 'contract_address': contractAddress, + 'activation_params': activationParams.toRpcParams(), + })}', + name: 'CustomErc20ActivationStrategy', + ); + } await client.rpc.erc20.enableCustomErc20Token( ticker: asset.id.id, @@ -92,10 +95,12 @@ class CustomErc20ActivationStrategy extends ProtocolActivationStrategy { contractAddress: contractAddress, ); - log( - '[RPC] Successfully activated custom ERC20 token: ${asset.id.id}', - name: 'CustomErc20ActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Successfully activated custom ERC20 token: ${asset.id.id}', + name: 'CustomErc20ActivationStrategy', + ); + } yield ActivationProgress.success( details: ActivationProgressDetails( diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/erc20_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/erc20_activation_strategy.dart index 438fca80b..5f6ccec39 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/erc20_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/erc20_activation_strategy.dart @@ -1,6 +1,7 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; import 'package:komodo_defi_types/komodo_defi_types.dart'; @@ -71,30 +72,34 @@ class Erc20ActivationStrategy extends ProtocolActivationStrategy { ); // Debug logging for ERC20 token activation - log( - '[RPC] Activating ERC20 token: ${asset.id.id}', - name: 'Erc20ActivationStrategy', - ); - log( - '[RPC] Activation parameters: ${jsonEncode({ - 'ticker': asset.id.id, - 'protocol': asset.protocol.subClass.formatted, - 'parent_id': asset.id.parentId?.id, - 'activation_params': activationParams.toRpcParams(), - 'priv_key_policy': privKeyPolicy.toJson(), - })}', - name: 'Erc20ActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Activating ERC20 token: ${asset.id.id}', + name: 'Erc20ActivationStrategy', + ); + log( + '[RPC] Activation parameters: ${jsonEncode({ + 'ticker': asset.id.id, + 'protocol': asset.protocol.subClass.formatted, + 'parent_id': asset.id.parentId?.id, + 'activation_params': activationParams.toRpcParams(), + 'priv_key_policy': privKeyPolicy.toJson(), + })}', + name: 'Erc20ActivationStrategy', + ); + } await client.rpc.erc20.enableErc20( ticker: asset.id.id, activationParams: activationParams, ); - log( - '[RPC] Successfully activated ERC20 token: ${asset.id.id}', - name: 'Erc20ActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Successfully activated ERC20 token: ${asset.id.id}', + name: 'Erc20ActivationStrategy', + ); + } yield ActivationProgress.success( details: ActivationProgressDetails( diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_task_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_task_activation_strategy.dart index e4e62a92f..be61c558a 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_task_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_task_activation_strategy.dart @@ -1,5 +1,6 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; @@ -93,24 +94,28 @@ class EthTaskActivationStrategy extends ProtocolActivationStrategy { ); // Debug logging for ETH task-based activation - log( - '[RPC] Activating ETH platform (task-based): ${asset.id.id}', - name: 'EthTaskActivationStrategy', - ); - log( - '[RPC] Activation parameters: ${jsonEncode({'ticker': asset.id.id, 'protocol': asset.protocol.subClass.formatted, 'token_count': children?.length ?? 0, 'tokens': children?.map((e) => e.id.id).toList() ?? [], 'activation_params': activationParams.toRpcParams(), 'priv_key_policy': privKeyPolicy.toJson()})}', - name: 'EthTaskActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Activating ETH platform (task-based): ${asset.id.id}', + name: 'EthTaskActivationStrategy', + ); + log( + '[RPC] Activation parameters: ${jsonEncode({'ticker': asset.id.id, 'protocol': asset.protocol.subClass.formatted, 'token_count': children?.length ?? 0, 'tokens': children?.map((e) => e.id.id).toList() ?? [], 'activation_params': activationParams.toRpcParams(), 'priv_key_policy': privKeyPolicy.toJson()})}', + name: 'EthTaskActivationStrategy', + ); + } final taskResponse = await client.rpc.erc20.enableEthInit( ticker: asset.id.id, params: activationParams, ); - log( - '[RPC] Task initiated for ${asset.id.id}, task_id: ${taskResponse.taskId}', - name: 'EthTaskActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[RPC] Task initiated for ${asset.id.id}, task_id: ${taskResponse.taskId}', + name: 'EthTaskActivationStrategy', + ); + } yield ActivationProgress( status: 'Establishing network connections...', diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_with_tokens_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_with_tokens_activation_strategy.dart index d8d3cf56a..e5b0ad25c 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_with_tokens_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/eth_with_tokens_activation_strategy.dart @@ -1,5 +1,6 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; @@ -114,24 +115,30 @@ class EthWithTokensActivationStrategy extends ProtocolActivationStrategy { ); // Debug logging for ETH platform activation - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activating ETH platform: ${asset.id.id}', name: 'EthWithTokensActivationStrategy', ); - log( + } + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activation parameters: ${jsonEncode({'ticker': asset.id.id, 'protocol': asset.protocol.subClass.formatted, 'token_count': children?.length ?? 0, 'tokens': children?.map((e) => e.id.id).toList() ?? [], 'activation_params': activationParams.toRpcParams(), 'priv_key_policy': privKeyPolicy.toJson()})}', name: 'EthWithTokensActivationStrategy', ); + } await client.rpc.erc20.enableEthWithTokens( ticker: asset.id.id, params: activationParams, ); - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Successfully activated ETH platform: ${asset.id.id} with ${children?.length ?? 0} tokens', name: 'EthWithTokensActivationStrategy', ); + } yield const ActivationProgress( status: 'Finalizing activation...', diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/qtum_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/qtum_activation_strategy.dart index fb8ace6fc..49d796660 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/qtum_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/qtum_activation_strategy.dart @@ -1,5 +1,6 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; @@ -45,11 +46,14 @@ class QtumActivationStrategy extends ProtocolActivationStrategy { ); // Debug logging for QTUM activation - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activating QTUM coin: ${asset.id.id}', name: 'QtumActivationStrategy', ); - log( + } + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activation parameters: ${jsonEncode({ 'ticker': asset.id.id, 'protocol': asset.protocol.subClass.formatted, @@ -58,16 +62,19 @@ class QtumActivationStrategy extends ProtocolActivationStrategy { })}', name: 'QtumActivationStrategy', ); + } final taskResponse = await client.rpc.qtum.enableQtumInit( ticker: asset.id.id, params: activationParams, ); - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Task initiated for ${asset.id.id}, task_id: ${taskResponse.taskId}', name: 'QtumActivationStrategy', ); + } var isComplete = false; while (!isComplete) { diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/tendermint_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/tendermint_activation_strategy.dart index 34929a17c..2df74655a 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/tendermint_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/tendermint_activation_strategy.dart @@ -1,5 +1,6 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; @@ -106,11 +107,14 @@ class TendermintWithTokensActivationStrategy final nodes = protocol.rpcUrlsMap.map(TendermintNode.fromJson).toList(); // Debug logging for Tendermint activation - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activating Tendermint platform: ${asset.id.id}', name: 'TendermintWithTokensActivationStrategy', ); - log( + } + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activation parameters: ${jsonEncode({ 'ticker': asset.id.id, 'protocol': asset.protocol.subClass.formatted, @@ -123,6 +127,7 @@ class TendermintWithTokensActivationStrategy })}', name: 'TendermintWithTokensActivationStrategy', ); + } final taskResponse = await client.rpc.tendermint.taskEnableTendermintInit( ticker: asset.id.id, @@ -130,10 +135,12 @@ class TendermintWithTokensActivationStrategy nodes: nodes, ); - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Task initiated for ${asset.id.id}, task_id: ${taskResponse.taskId}', name: 'TendermintWithTokensActivationStrategy', ); + } yield ActivationProgress( status: 'Monitoring activation progress...', diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/utxo_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/utxo_activation_strategy.dart index 39635777e..e3d6b33c3 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/utxo_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/utxo_activation_strategy.dart @@ -1,6 +1,7 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; import 'package:komodo_defi_types/komodo_defi_types.dart'; @@ -65,24 +66,28 @@ class UtxoActivationStrategy extends ProtocolActivationStrategy { ); // Debug logging for UTXO/Electrum activation - log( - '[ELECTRUM] Activating UTXO coin: ${asset.id.id}', - name: 'UtxoActivationStrategy', - ); - log( - '[ELECTRUM] Activation parameters: ${jsonEncode({'ticker': asset.id.id, 'mode': activationParams.mode?.rpc, 'utxo_params': activationParams.toRpcParams(), 'protocol_type': protocol.subClass.formatted, 'tx_version': protocol.txVersion, 'pubtype': protocol.pubtype, 'p2shtype': protocol.p2shtype, 'wiftype': protocol.wiftype, 'electrum_servers': protocol.requiredServers.toJsonRequest(), 'priv_key_policy': privKeyPolicy.toJson()})}', - name: 'UtxoActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[ELECTRUM] Activating UTXO coin: ${asset.id.id}', + name: 'UtxoActivationStrategy', + ); + log( + '[ELECTRUM] Activation parameters: ${jsonEncode({'ticker': asset.id.id, 'mode': activationParams.mode?.rpc, 'utxo_params': activationParams.toRpcParams(), 'protocol_type': protocol.subClass.formatted, 'tx_version': protocol.txVersion, 'pubtype': protocol.pubtype, 'p2shtype': protocol.p2shtype, 'wiftype': protocol.wiftype, 'electrum_servers': protocol.requiredServers.toJsonRequest(), 'priv_key_policy': privKeyPolicy.toJson()})}', + name: 'UtxoActivationStrategy', + ); + } final taskResponse = await client.rpc.utxo.enableUtxoInit( ticker: asset.id.id, params: activationParams, ); - log( - '[ELECTRUM] Task initiated for ${asset.id.id}, task_id: ${taskResponse.taskId}', - name: 'UtxoActivationStrategy', - ); + if (KdfLoggingConfig.verboseLogging) { + log( + '[ELECTRUM] Task initiated for ${asset.id.id}, task_id: ${taskResponse.taskId}', + name: 'UtxoActivationStrategy', + ); + } yield ActivationProgress( status: 'Establishing network connections...', diff --git a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/zhtlc_activation_strategy.dart b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/zhtlc_activation_strategy.dart index f20a3ef59..f6fb25bbc 100644 --- a/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/zhtlc_activation_strategy.dart +++ b/packages/komodo_defi_sdk/lib/src/activation/protocol_strategies/zhtlc_activation_strategy.dart @@ -4,6 +4,7 @@ import 'dart:convert'; import 'dart:developer' show log; +import 'package:komodo_defi_framework/komodo_defi_framework.dart'; import 'package:komodo_defi_rpc_methods/komodo_defi_rpc_methods.dart'; import 'package:komodo_defi_sdk/src/activation/_activation.dart'; @@ -103,14 +104,18 @@ class ZhtlcActivationStrategy extends ProtocolActivationStrategy { yield ZhtlcActivationProgress.validation(protocol); // Debug logging for ZHTLC activation - log( + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activating ZHTLC coin: ${asset.id.id}', name: 'ZhtlcActivationStrategy', ); - log( + } + if (KdfLoggingConfig.verboseLogging) { + log( '[RPC] Activation parameters: ${jsonEncode({'ticker': asset.id.id, 'protocol': asset.protocol.subClass.formatted, 'activation_params': params.toRpcParams(), 'zcash_params_path': userConfig.zcashParamsPath, 'scan_blocks_per_iteration': userConfig.scanBlocksPerIteration, 'scan_interval_ms': userConfig.scanIntervalMs, 'polling_interval_ms': effectivePollingInterval.inMilliseconds, 'priv_key_policy': privKeyPolicy.toJson()})}', name: 'ZhtlcActivationStrategy', ); + } // Initialize task and watch via TaskShepherd final stream = client.rpc.zhtlc