Sometimes you just forget to call the function

This commit is contained in:
Ben 2025-04-17 14:05:10 +02:00
parent e4d99932dd
commit abe03abff6
No known key found for this signature in database
GPG Key ID: 0F16E812E736C24B
2 changed files with 12 additions and 21 deletions

View File

@ -16,27 +16,12 @@ namespace BiblioTech.Rewards
this.repo = repo;
}
public async Task Process(ActiveChainAddresses activeChainAddresses)
public async Task ProcessChainActivity(ActiveChainAddresses activeChainAddresses)
{
if (!activeChainAddresses.HasAny())
{
Log("Received empty activeChainAddresses.");
return;
}
if (!activeChainAddresses.HasAny()) return;
var activeUserIds = ConvertToUserIds(activeChainAddresses);
if (!activeUserIds.HasAny())
{
Log("Empty userIds after lookup of addresses: " + activeChainAddresses);
return;
}
if (!HasChanged(activeUserIds))
{
Log("Active userIds has not changed: " + activeUserIds);
return;
}
if (!activeUserIds.HasAny()) return;
if (!HasChanged(activeUserIds)) return;
await GiveAndRemoveRoles(activeUserIds);
}

View File

@ -38,16 +38,22 @@ namespace BiblioTech.Rewards
[HttpPost]
public async Task<string> Give(EventsAndErrors cmd)
{
await Safe(() => Program.ChainActivityHandler.ProcessChainActivity(cmd.ActiveChainAddresses));
await Safe(() => Program.EventsSender.ProcessChainEvents(cmd.EventsOverview, cmd.Errors));
return "OK";
}
private async Task Safe(Func<Task> action)
{
try
{
await Program.EventsSender.ProcessChainEvents(cmd.EventsOverview, cmd.Errors);
await action();
}
catch (Exception ex)
{
Program.Log.Error("Exception: " + ex);
}
return "OK";
}
}
}