Fix Integration test

michelin · Aug 28, 2024 · ebfb61a · ebfb61a
1 parent 8120cfc
commit ebfb61a
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java b/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java
@@ -913,6 +913,16 @@ void shouldDeleteSchema() {
                 .create(HttpMethod.GET, "/api/namespaces/ns1/schemas/ns1-subject4-value")
                 .bearerAuth(token), Schema.class);
 
-        assertEquals(HttpStatus.NOT_FOUND, getSchemaAfterAllVersionsDeletionResponse.getStatus());
+        // Get all schemas
+        var getResponseEmpty = ns4KafkaClient
+            .toBlocking()
+            .exchange(HttpRequest
+                .create(HttpMethod.GET, "/api/namespaces/ns1/schemas")
+                .bearerAuth(token), Argument.listOf(SchemaList.class));
+
+        assertTrue(getResponseEmpty.getBody().isPresent());
+        assertTrue(getResponseEmpty.getBody().get()
+            .stream()
+            .noneMatch(schemaList -> schemaList.getMetadata().getName().equals("ns1-subject4-value")));
     }
 }