Add all api changes

Author: polegkashti

api/src/main/java/io/kafbat/ui/config/ClustersProperties.java

@@ -52,6 +52,7 @@ public static class Cluster {
     Long pollingThrottleRate;
     TruststoreConfig ssl;
     AuditProperties audit;
+    String supportUrl;
   }
 
   @Data

api/src/main/java/io/kafbat/ui/controller/AclsController.java

@@ -13,6 +13,7 @@
 import io.kafbat.ui.service.acl.AclsService;
 import java.util.Optional;
 import lombok.RequiredArgsConstructor;
+import org.apache.kafka.common.acl.AccessControlEntryFilter;
 import org.apache.kafka.common.resource.PatternType;
 import org.apache.kafka.common.resource.ResourcePatternFilter;
 import org.apache.kafka.common.resource.ResourceType;
@@ -67,7 +68,9 @@ public Mono<ResponseEntity<Flux<KafkaAclDTO>>> listAcls(String clusterName,
                                                           KafkaAclResourceTypeDTO resourceTypeDto,
                                                           String resourceName,
                                                           KafkaAclNamePatternTypeDTO namePatternTypeDto,
+                                                          String search,
                                                           ServerWebExchange exchange) {
+
     AccessContext context = AccessContext.builder()
         .cluster(clusterName)
         .aclActions(AclAction.VIEW)
@@ -87,7 +90,7 @@ public Mono<ResponseEntity<Flux<KafkaAclDTO>>> listAcls(String clusterName,
     return validateAccess(context).then(
         Mono.just(
             ResponseEntity.ok(
-                aclsService.listAcls(getCluster(clusterName), filter)
+                aclsService.listAcls(getCluster(clusterName), filter, search)
                     .map(ClusterMapper::toKafkaAclDto)))
     ).doOnEach(sig -> audit(context, sig));
   }

api/src/main/java/io/kafbat/ui/controller/ApplicationConfigController.java

@@ -28,6 +28,7 @@
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.codec.multipart.FilePart;
 import org.springframework.http.codec.multipart.Part;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.server.ServerWebExchange;
 import reactor.core.publisher.Flux;
@@ -80,6 +81,17 @@ public Mono<ResponseEntity<ApplicationConfigDTO>> getCurrentConfig(ServerWebExch
         .doOnEach(sig -> audit(context, sig));
   }
 
+  @Override
+  public Mono<ResponseEntity<String>> getSupportUrl(ServerWebExchange exchange) {
+    var kafkaClusters = dynamicConfigOperations.getCurrentProperties().getKafka().getClusters();
+    
+    String supportUrl = kafkaClusters != null && !kafkaClusters.isEmpty()
+        ? kafkaClusters.get(0).getSupportUrl()
+        : null;
+
+    return Mono.just(ResponseEntity.ok(supportUrl));
+  }
+
   @Override
   public Mono<ResponseEntity<Void>> restartWithConfig(Mono<RestartRequestDTO> restartRequestDto,
                                                       ServerWebExchange exchange) {

api/src/main/java/io/kafbat/ui/model/KafkaCluster.java

@@ -31,4 +31,5 @@ public class KafkaCluster {
   private final ReactiveFailover<KafkaSrClientApi> schemaRegistryClient;
   private final Map<String, ReactiveFailover<KafkaConnectClientApi>> connectsClients;
   private final ReactiveFailover<KsqlApiClient> ksqlClient;
+  private final String supportUrl;
 }

api/src/main/java/io/kafbat/ui/service/KafkaClusterFactory.java

@@ -52,6 +52,7 @@ public KafkaCluster create(ClustersProperties properties,
 
     builder.name(clusterProperties.getName());
     builder.bootstrapServers(clusterProperties.getBootstrapServers());
+    builder.supportUrl(clusterProperties.getSupportUrl());
     builder.properties(convertProperties(clusterProperties.getProperties()));
     builder.readOnly(clusterProperties.isReadOnly());
     builder.masking(DataMasking.create(clusterProperties.getMasking()));

api/src/main/java/io/kafbat/ui/service/acl/AclsService.java

@@ -31,6 +31,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.common.acl.AccessControlEntry;
+import org.apache.kafka.common.acl.AccessControlEntryFilter;
 import org.apache.kafka.common.acl.AclBinding;
 import org.apache.kafka.common.acl.AclOperation;
 import org.apache.kafka.common.resource.Resource;
@@ -68,10 +69,13 @@ public Mono<Void> deleteAcl(KafkaCluster cluster, AclBinding aclBinding) {
         .doOnSuccess(v -> log.info("ACL DELETED: [{}]", aclString));
   }
 
-  public Flux<AclBinding> listAcls(KafkaCluster cluster, ResourcePatternFilter filter) {
+  public Flux<AclBinding> listAcls(KafkaCluster cluster,
+                                   ResourcePatternFilter resourceFilter,
+                                   String principalSearch) {
     return adminClientService.get(cluster)
-        .flatMap(c -> c.listAcls(filter))
+        .flatMap(c -> c.listAcls(resourceFilter))
         .flatMapIterable(acls -> acls)
+        .filter(acl -> principalSearch == null || acl.entry().principal().contains(principalSearch))
         .sort(Comparator.comparing(AclBinding::toString));  //sorting to keep stable order on different calls
   }
 

contract/src/main/resources/swagger/kafbat-ui-api.yaml

@@ -1917,6 +1917,11 @@ paths:
           required: false
           schema:
             $ref: '#/components/schemas/KafkaAclNamePatternType'
+        - name: search
+          in: query
+          required: false
+          schema:
+            type: string
       responses:
         200:
           description: OK
@@ -2161,6 +2166,20 @@ paths:
             application/json:
               schema:
                 $ref: '#/components/schemas/ApplicationConfig'
+
+  /api/config/support-url:
+    get:
+      tags:
+        - ApplicationConfig
+      summary: Gets the support URL for the first Kafka cluster
+      operationId: getSupportUrl
+      responses:
+        200:
+          description: OK
+          content:
+            application/json:
+              schema:
+                type: string
     put:
       tags:
         - ApplicationConfig
@@ -4149,6 +4168,8 @@ components:
                         type: string
                       bootstrapServers:
                         type: string
+                      supportUrl:
+                        type: string
                       ssl:
                         type: object
                         properties: