feat: add Address type

Author: EchoForge7

src/AElfScanServer.Worker.Core/Dtos/TransferEventDto.cs

@@ -29,7 +29,9 @@ public enum TransferType
 public enum AddressClassification
 {
     Normal,
-    Blacklist
+    Blacklist,
+    ToOnlyMonitored,
+    LargeAmountOnly
 }
 
 /// <summary>

src/AElfScanServer.Worker.Core/Options/TokenTransferMonitoringOptions.cs

@@ -19,10 +19,21 @@ public class TokenTransferMonitoringOptions
     /// </summary>
     public List<string> BlacklistAddresses { get; set; } = new();
 
+    /// <summary>
+    /// Addresses that are only monitored when they are recipients (to addresses)
+    /// </summary>
+    public List<string> ToOnlyMonitoredAddresses { get; set; } = new();
+
+    /// <summary>
+    /// Addresses that are only monitored for large amount transfers
+    /// </summary>
+    public List<string> LargeAmountOnlyAddresses { get; set; } = new();
+
+
     /// <summary>
     /// List of tokens to monitor
     /// </summary>
-    public List<string> MonitoredTokens { get; set; } = new() { "ELF", "USDT", "BTC", "ETH" };
+    public List<string> MonitoredTokens { get; set; } = new() { "ELF", "USDT" };
 
     /// <summary>
     /// Scan configuration

src/AElfScanServer.Worker.Core/Service/TokenTransferMonitoringService.cs

@@ -37,6 +37,8 @@ public class TokenTransferMonitoringService : ITokenTransferMonitoringService, I
     private readonly Histogram<double> _transferEventsHistogram;
     private readonly Counter<long> _transferCountsCounter;
     private readonly HashSet<string> _blacklistAddresses;
+    private readonly HashSet<string> _toOnlyMonitoredAddresses;
+    private readonly HashSet<string> _largeAmountOnlyAddresses;
     private readonly IOptionsMonitor<TokenTransferMonitoringOptions> _optionsMonitor;
 
     public TokenTransferMonitoringService(
@@ -59,10 +61,12 @@ public TokenTransferMonitoringService(
 
         // Initialize address sets for fast lookup
         _blacklistAddresses = new HashSet<string>(_options.BlacklistAddresses, StringComparer.OrdinalIgnoreCase);
+        _toOnlyMonitoredAddresses = new HashSet<string>(_options.ToOnlyMonitoredAddresses, StringComparer.OrdinalIgnoreCase);
+        _largeAmountOnlyAddresses = new HashSet<string>(_options.LargeAmountOnlyAddresses, StringComparer.OrdinalIgnoreCase);
         // Initialize histogram with configured buckets
         _transferEventsHistogram = instrumentationProvider.Meter.CreateHistogram<double>(
-            "aelf_transfer_events",
-            "ms",
+            "aelf_transfer_usd_value",
+            "usd",
             "Token transfer events with amount distribution");
 
         // Initialize counter for transfer counts
@@ -190,6 +194,10 @@ public async Task<List<TransferEventDto>> GetTransfersAsync(string chainId)
                 transfer.UsdValue = Math.Round(transfer.Amount * price, CommonConstant.UsdValueDecimals);
             }
 
+            // Reclassify addresses with USD value context
+            transfer.FromAddressType = ClassifyAddress(transfer.FromAddress, false, transfer.UsdValue);
+            transfer.ToAddressType = ClassifyAddress(transfer.ToAddress, true, transfer.UsdValue);
+            
             // Add all transfers (filtering will be done in SendTransferMetrics)
             transfers.Add(transfer);
         }
@@ -336,7 +344,7 @@ public void SendTransferMetrics(TransferEventDto transfer)
             }
             else
             {
-                _logger.LogDebug("Sent counter metrics only for transaction {TransactionId}, amount {Amount} {Symbol}, USD value {UsdValue} below histogram threshold", 
+                _logger.LogInformation("Sent counter metrics only for transaction {TransactionId}, amount {Amount} {Symbol}, USD value {UsdValue} below histogram threshold", 
                     transfer.TransactionId, transfer.Amount, transfer.Symbol, transfer.UsdValue);
             }
         }
@@ -360,16 +368,29 @@ private TransferEventDto ConvertToTransferEventDto(TokenTransferInfoDto dto)
             ToAddress = dto.To?.Address ?? "",
             Amount = dto.Quantity,
             Type = ParseTransferType(dto.Method),
-            FromAddressType = ClassifyAddress(dto.From?.Address ?? ""),
-            ToAddressType = ClassifyAddress(dto.To?.Address ?? "")
+            FromAddressType = ClassifyAddress(dto.From?.Address ?? "", false, 0m),
+            ToAddressType = ClassifyAddress(dto.To?.Address ?? "", true, 0m)
         };
     }
 
-    private AddressClassification ClassifyAddress(string address)
+    private AddressClassification ClassifyAddress(string address, bool isToAddress = false, decimal usdValue = 0m)
     {
-        return _blacklistAddresses.Contains(address) 
-            ? AddressClassification.Blacklist 
-            : AddressClassification.Normal;
+        if (string.IsNullOrEmpty(address))
+            return AddressClassification.Normal;
+
+        // Check blacklist first (highest priority)
+        if (_blacklistAddresses.Contains(address))
+            return AddressClassification.Blacklist;
+
+        // Check ToOnlyMonitored addresses (only when it's a recipient address)
+        if (isToAddress && _toOnlyMonitoredAddresses.Contains(address))
+            return AddressClassification.ToOnlyMonitored;
+
+        // Check LargeAmountOnly addresses (only for large transfers)
+        if (_largeAmountOnlyAddresses.Contains(address) )
+            return AddressClassification.LargeAmountOnly;
+
+        return AddressClassification.Normal;
     }
 
     private static TransferType ParseTransferType(string method)