aljaz/BTCPayServerPlugins
1
0
Fork 0
mirror of https://github.com/aljazceru/BTCPayServerPlugins.git synced 2025-12-17 07:34:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

zapper for the zaps

Browse Source
This commit is contained in:
Kukks
2023-09-15 12:58:28 +02:00
parent cdbf4ccc21
commit feae3e6253
3 changed files with 26 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
Plugins/BTCPayServer.Plugins.NIP05/Zapper.cs
View File

@@ -136,27 +136,31 @@ public class Zapper : IHostedService
}
var waitingToken = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
waitingToken.CancelAfter(TimeSpan.FromMinutes(2));
while (!waitingToken.IsCancellationRequested)
{
if (_pendingZapEvents.Count > 10)
{
waitingToken.Cancel();
}
else
{
try
{
await Task.Delay(100, waitingToken.Token);
}
catch (TaskCanceledException e)
{
break;
}
}
}
await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
//we used to have some waiting logic so that we dont open a websocket to every relay for every individual zap only.
//but people need their instant gratification so we removed it.
// var waitingToken = CancellationTokenSource.CreateLinkedTokenSource();
// waitingToken.CancelAfter(TimeSpan.FromSeconds(5));
// while (!waitingToken.IsCancellationRequested)
// {
// if (_pendingZapEvents.Count > 10)
// {
// waitingToken.Cancel();
// }
// else
// {
// try
// {
//
// await Task.Delay(100, waitingToken.Token);
// }
// catch (TaskCanceledException e)
// {
// break;
// }
// }
// }
}
}