@@ -22,12 +22,15 @@ public SpectatorJob(ILogger<SpectatorJob> logger, ISitesCatalogue sitesCatalogue
22
22
23
23
public async Task Execute ( IJobExecutionContext context )
24
24
{
25
+ _logger . LogDebug ( "Starting sites observations" ) ;
25
26
var sites = await _sitesCatalogue . GetAllSites ( ) ;
26
- var siteQueue = new Queue < QueuedSite > ( sites . Select ( x => new QueuedSite ( x , 0 ) ) ) ;
27
+ _logger . LogDebug ( "Got {Count} sites to observe" , sites . Count ) ;
27
28
29
+ var siteQueue = new Queue < QueuedSite > ( sites . Select ( x => new QueuedSite ( x , 0 ) ) ) ;
28
30
while ( siteQueue . TryDequeue ( out var queuedSite ) )
29
31
{
30
32
using var _ = _logger . BeginScope ( new Dictionary < string , object > { { "HiddenService" , queuedSite . Site . SiteUri } } ) ;
33
+ _logger . LogDebug ( "Starting observations on the next site" ) ;
31
34
try
32
35
{
33
36
var observations = await ObserveSite ( queuedSite . Site . SiteUri ) ;
@@ -42,6 +45,7 @@ public async Task Execute(IJobExecutionContext context)
42
45
continue ;
43
46
}
44
47
}
48
+ _logger . LogDebug ( "Site seems to be up" ) ;
45
49
await _siteObserver . AddNewObservation ( queuedSite . Site . SiteUri , observations . IsOk ) ;
46
50
_logger . LogInformation ( "Site observed" ) ;
47
51
}
@@ -50,6 +54,7 @@ public async Task Execute(IJobExecutionContext context)
50
54
_logger . LogError ( e , "Observation for site failed" ) ;
51
55
}
52
56
}
57
+ _logger . LogDebug ( "The queue is finally empty, observations finished" ) ;
53
58
}
54
59
55
60
private record QueuedSite ( Site Site , int ObservationsCount ) ;
0 commit comments