testing web3 log processor

This commit is contained in:
ThatBen 2025-06-26 18:15:48 +02:00
parent b31591d276
commit 74eff2f158
No known key found for this signature in database
GPG Key ID: 62C543548433D43E

View File

@ -114,7 +114,7 @@ namespace NethereumWorkflow
var p = web3.Processing.Logs.CreateProcessor(
action: logs.Add,
minimumBlockConfirmations: 1,
criteria: l => l.Address == address
criteria: l => l.IsLogForEvent<TEvent>()
);
var from = new BlockParameter(fromBlockNumber);
@ -122,7 +122,6 @@ namespace NethereumWorkflow
var ct = new CancellationTokenSource().Token;
Time.Wait(p.ExecuteAsync(toBlockNumber: to.BlockNumber, cancellationToken: ct, startAtBlockNumberIfNotProcessed: from.BlockNumber));
return logs
.Where(l => l.IsLogForEvent<TEvent>())
.Select(l => l.DecodeEvent<TEvent>())