Improve readability

ramonsmits · ramonsmits · commit aa3557a6d38b · 2025-02-17T19:57:44.000+01:00
diff --git a/src/ServiceControl.Audit/Auditing/AuditIngestion.cs b/src/ServiceControl.Audit/Auditing/AuditIngestion.cs
@@ -76,13 +76,18 @@ async Task EnsureStarted(CancellationToken cancellationToken = default)
                 await startStopSemaphore.WaitAsync(cancellationToken);
                 logger.Debug("Ensure started. Start/stop semaphore acquired");
 
-                if (!unitOfWorkFactory.CanIngestMore())
+                var canIngest = unitOfWorkFactory.CanIngestMore();
+
+                logger.DebugFormat("Ensure started {0}", canIngest);
+
+                if (canIngest)
+                {
+                    await SetUpAndStartInfrastructure(cancellationToken);
+                }
+                else
                 {
                     await StopAndTeardownInfrastructure(cancellationToken);
-                    return;
                 }
-
-                await SetUpAndStartInfrastructure(cancellationToken);
             }
             catch (Exception e)
             {

Original file line number	Diff line number	Diff line change
`@@ -76,13 +76,18 @@ async Task EnsureStarted(CancellationToken cancellationToken = default)`
`76`	`76`	`await startStopSemaphore.WaitAsync(cancellationToken);`
`77`	`77`	`logger.Debug("Ensure started. Start/stop semaphore acquired");`
`78`	`78`
`79`		`- if (!unitOfWorkFactory.CanIngestMore())`
	`79`	`+ var canIngest = unitOfWorkFactory.CanIngestMore();`
	`80`	`+`
	`81`	`+ logger.DebugFormat("Ensure started {0}", canIngest);`
	`82`	`+`
	`83`	`+ if (canIngest)`
	`84`	`+ {`
	`85`	`+ await SetUpAndStartInfrastructure(cancellationToken);`
	`86`	`+ }`
	`87`	`+ else`
`80`	`88`	`{`
`81`	`89`	`await StopAndTeardownInfrastructure(cancellationToken);`
`82`		`- return;`
`83`	`90`	`}`
`84`		`-`
`85`		`- await SetUpAndStartInfrastructure(cancellationToken);`
`86`	`91`	`}`
`87`	`92`	`catch (Exception e)`
`88`	`93`	`{`