Skip to content
This repository has been archived by the owner on Nov 22, 2023. It is now read-only.

Commit

Permalink
additional logging
Browse files Browse the repository at this point in the history
  • Loading branch information
dkackman committed Nov 19, 2023
1 parent d0764a3 commit 41781f0
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion DlMirrorSync/SyncService.cs
Expand Up @@ -27,13 +27,15 @@ public async Task SyncSubscriptions(CancellationToken stoppingToken)
var addMirrorAmount = _configuration.GetValue<ulong>("DlMirrorSync:AddMirrorAmount", 300000000);
var fee = await _chiaService.GetFee(addMirrorAmount, stoppingToken);

_logger.LogInformation("Fetching subscriptions...");
var subscriptions = await _dataLayer.Subscriptions(stoppingToken);

_logger.LogInformation("Fetching latest mirrors list...");
await foreach (var id in _mirrorService.FetchLatest(stoppingToken))
{
if (!subscriptions.Contains(id))
{
_logger.LogInformation("Subscribing to mirror {id}", id);
_logger.LogInformation("Subscribing to {id}", id);
await _dataLayer.Subscribe(id, Enumerable.Empty<string>(), stoppingToken);
}

Expand All @@ -44,6 +46,7 @@ await foreach (var id in _mirrorService.FetchLatest(stoppingToken))
var balance = await xchWallet.GetBalance(stoppingToken);
if (addMirrorAmount + fee < balance.SpendableBalance)
{
_logger.LogInformation("Adding mirror {id}", id);
await _dataLayer.AddMirror(id, addMirrorAmount, Enumerable.Empty<string>(), fee, stoppingToken);
}
else
Expand Down

0 comments on commit 41781f0

Please sign in to comment.