Test blob-missing skips record creation

Author: marianards

api.Tests/Integration/EndToEndPipelineTests.cs

@@ -122,6 +122,25 @@ await _context
         Assert.Equal(AnalysisRunStatus.Succeeded, workflow.AnalysisRun.Status);
     }
 
+    [Fact]
+    public async Task BlobDoesNotExist_NoInspectionRecordOrWorkflowCreated_AndNoAnalysisTriggered()
+    {
+        _factory.BlobStorageService.BlobExists = false;
+        var message = _db.NewIsarInspectionResultMessage(requiredAnalysis: ["per-record-test"]);
+
+        await ProcessInspectionResultInScope(message);
+
+        Assert.False(
+            await _context.InspectionRecords.AnyAsync(TestContext.Current.CancellationToken),
+            "No inspection record should be created when the ISAR blob does not exist."
+        );
+        Assert.False(
+            await _context.Workflows.AnyAsync(TestContext.Current.CancellationToken),
+            "No workflow should be created when the ISAR blob does not exist."
+        );
+        Assert.DoesNotContain(_factory.ArgoHttpHandler.Requests, r => r.Method == HttpMethod.Post);
+    }
+
     [Fact]
     public async Task MultiStepChain_SecondWorkflowTriggeredAfterFirstSucceeds()
     {

api.Tests/Mocks/BlobStorageServiceMock.cs

@@ -8,6 +8,8 @@ namespace Api.Test.Mocks;
 
 public class BlobStorageServiceMock : IBlobStorageService
 {
+    public bool BlobExists { get; set; } = true;
+
     public async Task<MemoryStream> DownloadBlobAsync(BlobStorageLocation location)
     {
         var stream = new MemoryStream();
@@ -36,4 +38,10 @@ public async Task<Uri> CreateReadSasUri(BlobStorageLocation location)
             $"https://{location.StorageAccount}.blob.core.windows.net/{location.BlobContainer}/{location.BlobName}?{mockSAS}"
         );
     }
+
+    public async Task<bool> ExistsAsync(BlobStorageLocation location)
+    {
+        await Task.CompletedTask;
+        return BlobExists;
+    }
 }

api.Tests/TestWebApplicationFactory.cs

@@ -36,6 +36,7 @@ public class TestWebApplicationFactory<TProgram>(string postgresConnectionString
     public RecordingHttpMessageHandler ArgoHttpHandler { get; } = new();
     public RecordingEmailService EmailService { get; } = new();
     public RecordingTimeseriesService TimeseriesService { get; } = new();
+    public BlobStorageServiceMock BlobStorageService { get; } = new();
 
     /// <summary>
     /// Returns the configured Argo trigger URL for the given workflow type.
@@ -148,7 +149,7 @@ private void ReplaceBlobStorageService(IServiceCollection services)
         {
             services.Remove(descriptor);
         }
-        services.AddScoped<IBlobStorageService, BlobStorageServiceMock>();
+        services.AddSingleton<IBlobStorageService>(BlobStorageService);
     }
 
     private static void RemoveHostedServices(IServiceCollection services)