logos-storage/logos-storage-nim-cs-dist-tests
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim-cs-dist-tests.git synced 2026-01-03 22:13:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
ThatBen 2025-06-26 13:40:32 +02:00
parent a0a613f2e1
commit b8def4db27
No known key found for this signature in database
GPG Key ID: E020A7DDCD52E1AB
3 changed files with 42 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
Framework/NethereumWorkflow/NethereumInteraction.cs
View File

@ -110,11 +110,47 @@ namespace NethereumWorkflow
public List<EventLog<TEvent>> GetEvents<TEvent>(string address, ulong fromBlockNumber, ulong toBlockNumber) where TEvent : IEventDTO, new()
{
var eventHandler = web3.Eth.GetEvent<TEvent>(address);
var from = new BlockParameter(fromBlockNumber);
var to = new BlockParameter(toBlockNumber);
var blockFilter = Time.Wait(eventHandler.CreateFilterBlockRangeAsync(from, to));
return Time.Wait(eventHandler.GetAllChangesAsync(blockFilter));
try
{
var logs = new List<FilterLog>();
var p = web3.Processing.Logs.CreateProcessor(l => logs.Add(l));
var from = new BlockParameter(fromBlockNumber);
var to = new BlockParameter(toBlockNumber);
var ct = new CancellationTokenSource().Token;
Time.Wait(p.ExecuteAsync(toBlockNumber: to.BlockNumber, cancellationToken: ct, startAtBlockNumberIfNotProcessed: from.BlockNumber));
var result = new List<EventLog<TEvent>>();
foreach (var l in logs)
{
if (l.IsLogForEvent<TEvent>())
{
var eee = l.DecodeEvent<TEvent>();
result.Add(eee);
}
}
return result;
//var eventHandler = web3.Eth.GetEvent<TEvent>(address);
//var blockFilter = Time.Wait(eventHandler.CreateFilterBlockRangeAsync(from, to));
//return Time.Wait(eventHandler.GetAllChangesAsync(blockFilter));
//var events = eventHandler.DecodeAllEventsForEvent(new FilterLog[]
//{
// //new FilterLog
// //{
// // BlockNumber = from.BlockNumber
// //}
//});
}
catch (Exception ex)
{
var aaa = 0;
throw;
}
}
public BlockInterval ConvertTimeRangeToBlockRange(TimeRange timeRange)

2
ProjectPlugins/CodexPlugin/CodexDockerImage.cs
View File

@ -2,7 +2,7 @@
{
public class CodexDockerImage
{
private const string DefaultDockerImage = "codexstorage/nim-codex:sha-e324ac8-dist-tests";
private const string DefaultDockerImage = "codexstorage/nim-codex:latest-dist-tests";
public static string Override { get; set; } = string.Empty;

1
Tools/BiblioTech/CommandHandler.cs
View File

@ -6,7 +6,6 @@ using BiblioTech.Rewards;
using Logging;
using BiblioTech.CodexChecking;
using Nethereum.Model;
using static Org.BouncyCastle.Math.EC.ECCurve;
namespace BiblioTech
{