Skip to content

Commit b246440

Browse files
committed
feat:update option
1 parent 87d33ea commit b246440

2 files changed

Lines changed: 9 additions & 3 deletions

File tree

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

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,11 +29,15 @@ public class TokenTransferMonitoringOptions
2929
/// </summary>
3030
public List<string> LargeAmountOnlyAddresses { get; set; } = new();
3131

32+
/// <summary>
33+
/// Minimum USD value threshold for histogram recording, default is 0
34+
/// </summary>
35+
public decimal MinUsdValueThreshold { get; set; } = 0m;
3236

3337
/// <summary>
3438
/// List of tokens to monitor
3539
/// </summary>
36-
public List<string> MonitoredTokens { get; set; } = new() { "ELF", "USDT" };
40+
public List<string> MonitoredTokens { get; set; } = new() { "ELF", "USDT", "BTC", "ETH" };
3741

3842
/// <summary>
3943
/// Scan configuration

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ public class TokenTransferMonitoringService : ITokenTransferMonitoringService, I
2626
private const int SafetyRecordLimit = 10000;
2727
private const int DefaultScanTimeMinutes = -60;
2828
private const string LastScanTimeKey = "last_scan_time";
29-
private const decimal MinUsdValueThreshold = 0m;
3029

3130
private readonly ITokenIndexerProvider _tokenIndexerProvider;
3231
private readonly IDistributedCache<string> _distributedCache;
@@ -305,8 +304,11 @@ public void SendTransferMetrics(TransferEventDto transfer)
305304
{
306305
try
307306
{
307+
// Get current options for dynamic configuration
308+
var currentOptions = _optionsMonitor.CurrentValue;
309+
308310
// Determine if this is a high-value transfer once
309-
var isHighValue = transfer.UsdValue >= MinUsdValueThreshold;
311+
var isHighValue = transfer.UsdValue >= currentOptions.MinUsdValueThreshold;
310312

311313
// Record outbound transaction (from perspective)
312314
var outboundTags = new KeyValuePair<string, object?>[]

0 commit comments

Comments
 (0)