fix(exception-handling): [eclipse-tractusx#841] add test

dsmf · Aug 2, 2024 · d89603b · d89603b
1 parent d3c8af7
commit d89603b
Showing 1 changed file with 42 additions and 2 deletions.
diff --git a/irs-api/src/test/java/org/eclipse/tractusx/irs/IrsWireMockIntegrationTest.java b/irs-api/src/test/java/org/eclipse/tractusx/irs/IrsWireMockIntegrationTest.java
@@ -374,6 +374,43 @@ void shouldCreateDetailedTombstoneForEdcErrors() {
         assertThat(rootCauses.get(0)).contains("502 Bad Gateway");
     }
 
+    @Test
+    void whenEmptyCatalogIsReturnedFromAllEndpoints() {
+        // Arrange
+        final String globalAssetId = "urn:uuid:334cce52-1f52-4bc9-9dd1-410bbe497bbc";
+        final List<String> edcUrls = List.of("https://test.edc1.io", "https://test.edc2.io");
+
+        WiremockSupport.successfulSemanticModelRequest();
+        WiremockSupport.successfulSemanticHubRequests();
+        WiremockSupport.successfulDiscovery(edcUrls);
+
+        edcUrls.forEach(edcUrl -> emptyCatalog(TEST_BPN, edcUrl));
+
+        // Act
+        final RegisterJob request = WiremockSupport.jobRequest(globalAssetId, TEST_BPN, 4);
+        final JobHandle jobHandle = irsService.registerItemJob(request);
+        assertThat(jobHandle.getId()).isNotNull();
+        waitForCompletion(jobHandle);
+        final Jobs jobForJobId = irsService.getJobForJobId(jobHandle.getId(), false);
+
+        // Assert
+
+        assertThat(jobForJobId.getJob().getState()).isEqualTo(JobState.COMPLETED);
+
+        assertThat(jobForJobId.getShells()).isEmpty();
+        assertThat(jobForJobId.getRelationships()).isEmpty();
+        assertThat(jobForJobId.getSubmodels()).isEmpty();
+
+        final List<Tombstone> tombstones = jobForJobId.getTombstones();
+        assertThat(tombstones).hasSize(1);
+
+        final Tombstone actualTombstone = tombstones.get(0);
+        assertThat(actualTombstone.getBusinessPartnerNumber()).isEqualTo(TEST_BPN);
+        assertThat(actualTombstone.getEndpointURL()).describedAs("Tombstone should contain all EDC URLs")
+                                                    .isEqualTo(String.join("; ", edcUrls));
+
+    }
+
     @Test
     void shouldCreateDetailedTombstoneForDiscoveryErrors() {
         // Arrange
@@ -410,8 +447,7 @@ void shouldCreateDetailedTombstoneForDiscoveryErrors() {
 
         final List<String> rootCauses = actualTombstone.getProcessingError().getRootCauses();
         assertThat(rootCauses).hasSize(1);
-        assertThat(rootCauses.get(0)).contains(
-                "No EDC Endpoints could be discovered for BPN '%s'".formatted(TEST_BPN));
+        assertThat(rootCauses.get(0)).contains("No EDC Endpoints could be discovered for BPN '%s'".formatted(TEST_BPN));
     }
 
     private void successfulRegistryAndDataRequest(final String globalAssetId, final String idShort, final String bpn,
@@ -462,6 +498,10 @@ private void failedNegotiation() {
         SubmodelFacadeWiremockSupport.prepareFailingCatalog();
     }
 
+    private void emptyCatalog(final String bpn, final String edcUrl) {
+        SubmodelFacadeWiremockSupport.prepareEmptyCatalog(bpn, edcUrl);
+    }
+
     private void waitForCompletion(final JobHandle jobHandle) {
         Awaitility.await()
                   .timeout(Duration.ofSeconds(35))