fixed tests

Author: germanosin

api/src/test/java/io/kafbat/ui/KafkaConnectServiceTests.java

@@ -38,15 +38,15 @@
 class KafkaConnectServiceTests extends AbstractIntegrationTest {
   private final String connectName = "kafka-connect";
   private final String connectorName = UUID.randomUUID().toString();
+  private final String topicName = "test-topic";
   private final Map<String, Object> config = Map.of(
       "name", connectorName,
       "connector.class", "org.apache.kafka.connect.file.FileStreamSinkConnector",
       "tasks.max", "1",
-      "topics", "output-topic",
+      "topics", topicName,
       "file", "/tmp/test",
       "test.password", "******"
   );
-  private final String topicName = "test-topic";
 
   @Autowired
   private WebTestClient webTestClient;
@@ -84,20 +84,6 @@ void setUp() {
                 "test.password", "test-credentials")))
         .exchange()
         .expectStatus().isOk();
-
-    webTestClient.post()
-        .uri("/api/clusters/{clusterName}/connects/{connectName}/connectors", LOCAL, connectName)
-        .bodyValue(new NewConnectorDTO()
-            .name(connectorName + "source")
-            .config(Map.of(
-                "connector.class", "org.apache.kafka.connect.file.FileStreamSourceConnector",
-                "tasks.max", "1",
-                "topic", topicName,
-                "file", "/tmp/test",
-                "test.password", "test-credentials")))
-        .exchange()
-        .expectStatus().isOk();
-
     // Force cache refresh
     statisticsService.updateCache(kafkaCluster).block();
   }
@@ -109,11 +95,6 @@ void tearDown() {
             connectName, connectorName)
         .exchange()
         .expectStatus().isOk();
-    webTestClient.delete()
-        .uri("/api/clusters/{clusterName}/connects/{connectName}/connectors/{connectorName}", LOCAL,
-            connectName, connectorName + "source")
-        .exchange()
-        .expectStatus().isOk();
   }
 
   @Test
@@ -241,7 +222,7 @@ void shouldUpdateConfig() {
         .bodyValue(Map.of(
             "connector.class", "org.apache.kafka.connect.file.FileStreamSinkConnector",
             "tasks.max", "1",
-            "topics", "another-topic",
+            "topics", topicName,
             "file", "/tmp/new"
             )
         )
@@ -258,7 +239,7 @@ void shouldUpdateConfig() {
         .isEqualTo(Map.of(
             "connector.class", "org.apache.kafka.connect.file.FileStreamSinkConnector",
             "tasks.max", "1",
-            "topics", "another-topic",
+            "topics", topicName,
             "file", "/tmp/new",
             "name", connectorName
         ));
@@ -348,7 +329,7 @@ void shouldReturn400WhenConnectReturns400ForInvalidConfigUpdate() {
         .isEqualTo(Map.of(
             "connector.class", "org.apache.kafka.connect.file.FileStreamSinkConnector",
             "tasks.max", "1",
-            "topics", "output-topic",
+            "topics", topicName,
             "file", "/tmp/test",
             "name", connectorName,
             "test.password", "******"
@@ -377,7 +358,7 @@ void shouldReturn400WhenConnectReturns500ForInvalidConfigUpdate() {
         .isEqualTo(Map.of(
             "connector.class", "org.apache.kafka.connect.file.FileStreamSinkConnector",
             "tasks.max", "1",
-            "topics", "output-topic",
+            "topics", topicName,
             "file", "/tmp/test",
             "test.password", "******",
             "name", connectorName

api/src/test/java/io/kafbat/ui/service/mcp/McpSpecificationGeneratorTest.java

@@ -43,7 +43,7 @@ void testConvertController() {
     List<AsyncToolSpecification> specifications =
         MCP_SPECIFICATION_GENERATOR.convertTool(topicsController);
 
-    assertThat(specifications).hasSize(14);
+    assertThat(specifications).hasSize(15);
     List<McpSchema.Tool> tools = List.of(
         new McpSchema.Tool(
             "recreateTopic",