Infra: Add gradle p.1

.gitignore

@@ -42,4 +42,7 @@ build/
 *.tgz
 
 /docker/*.override.yaml
+out/
+node_modules/
+.gradle
 /e2e-tests/allure-results/

api/build.gradle

@@ -0,0 +1,115 @@
+
+plugins {
+    id 'antlr'
+    id 'checkstyle'
+    id 'org.springframework.boot' version '3.4.1'
+    id 'com.gorylenko.gradle-git-properties' version "2.4.2"
+}
+
+dependencies {
+    implementation project(":contract")
+    implementation project(":frontend")
+    implementation project(":serde-api")
+
+    implementation libs.spring.starter.webflux
+    implementation libs.spring.starter.security
+    implementation libs.spring.starter.actuator
+    implementation libs.spring.starter.logging
+    implementation libs.spring.starter.oauth2.client
+    implementation libs.spring.boot.actuator
+    compileOnly libs.spring.boot.devtools
+
+    implementation libs.spring.security.ldap
+
+    implementation libs.kafka.clients
+
+    implementation libs.apache.avro
+    implementation libs.apache.commons
+    implementation libs.apache.commons.pool2
+    implementation libs.apache.datasketches
+
+    implementation libs.confluent.schema.registry.client
+    implementation libs.confluent.avro.serializer
+    implementation libs.confluent.protobuf.serializer
+    implementation libs.confluent.json.schema.serializer
+
+    implementation libs.aws.msk.auth
+    implementation (libs.azure.identity) {
+        exclude group: 'io.netty', module: 'netty-tcnative-boringssl-static'
+    }
+
+    implementation libs.jackson.databind.nullable
+    implementation libs.cel
+    antlr libs.antlr
+    implementation libs.antlr.runtime
+
+    implementation libs.opendatadiscovery.oddrn
+    implementation (libs.opendatadiscovery.client) {
+        exclude group: 'org.springframework.boot', module: 'spring-boot-starter-webflux'
+        exclude group: 'io.projectreactor', module: 'reactor-core'
+        exclude group: 'io.projectreactor.ipc', module: 'reactor-netty'
+    }
+
+    runtimeOnly libs.micrometer.registry.prometheus
+
+    // CVE Fixes
+    implementation libs.apache.commons.compress
+    implementation libs.okhttp3.logging.intercepter
+
+    // Annotation processors
+    implementation libs.lombok
+    implementation libs.mapstruct
+    annotationProcessor libs.lombok
+    annotationProcessor libs.mapstruct.processor
+    annotationProcessor libs.spring.boot.configuration.processor
+    testAnnotationProcessor libs.lombok
+    testAnnotationProcessor libs.mapstruct.processor
+
+    // Tests
+    testImplementation libs.spring.starter.test
+    testImplementation libs.reactor.test
+    testImplementation libs.testcontainers
+    testImplementation libs.testcontainers.kafka
+    testImplementation libs.testcontainers.jupiter
+    testImplementation libs.junit.jupiter.engine
+    testImplementation libs.mockito.core
+    testImplementation libs.mockito.jupiter
+    testImplementation libs.bytebuddy
+    testImplementation libs.assertj
+    testImplementation libs.jsonschemavalidator
+
+    testImplementation libs.okhttp3
+    testImplementation libs.okhttp3.mockwebserver
+}
+
+generateGrammarSource {
+    maxHeapSize = "64m"
+    arguments += ["-package", "ksql"]
+}
+
+sourceSets {
+    main {
+        antlr {
+            srcDirs = ["src/main/antlr4"]
+        }
+        java {
+            srcDirs += generateGrammarSource.outputDirectory
+        }
+    }
+}
+
+tasks.withType(Checkstyle) {
+    exclude '**/ksql/**'
+}
+
+checkstyle {
+    toolVersion '10.3.1'
+    configFile = rootProject.file('etc/checkstyle/checkstyle-e2e.xml')
+    ignoreFailures = false
+    maxWarnings = 0
+    maxErrors = 0
+}
+
+test {
+    useJUnitPlatform()
+}

api/pom.xml

@@ -443,10 +443,10 @@
                                     <goal>copy-resources</goal>
                                 </goals>
                                 <configuration>
-                                    <outputDirectory>${basedir}/target/classes/static</outputDirectory>
+                                    <outputDirectory>${basedir}/target/classes/</outputDirectory>
                                     <resources>
                                         <resource>
-                                            <directory>../frontend/build</directory>
+                                            <directory>../frontend/build/vite/static</directory>
                                         </resource>
                                     </resources>
                                 </configuration>

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

@@ -1,7 +1,7 @@
 package io.kafbat.ui.config;
 
 import io.kafbat.ui.exception.ValidationException;
-import javax.annotation.PostConstruct;
+import jakarta.annotation.PostConstruct;
 import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;

api/src/main/java/io/kafbat/ui/config/auth/RoleBasedAccessControlProperties.java

@@ -1,9 +1,9 @@
 package io.kafbat.ui.config.auth;
 
 import io.kafbat.ui.model.rbac.Role;
+import jakarta.annotation.PostConstruct;
 import java.util.ArrayList;
 import java.util.List;
-import javax.annotation.PostConstruct;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 @ConfigurationProperties("rbac")

build.gradle

@@ -0,0 +1,31 @@
+subprojects {
+    apply plugin: "java"
+
+    repositories {
+        mavenCentral()
+        maven {
+            name = 'confluent'
+            url = 'https://packages.confluent.io/maven/'
+        }
+    }
+
+    group = 'io.kafbat'
+    version = version
+
+    java {
+        sourceCompatibility = JavaVersion.VERSION_21
+        targetCompatibility = JavaVersion.VERSION_21
+    }
+}
+
+boolean resolveBooleanProperty(String propertyName, boolean defaultValue = false) {
+    def propertyValueStr = findProperty(propertyName)
+    return propertyValueStr == null ? defaultValue : propertyValueStr.toBoolean();
+}
+
+ext {
+    prod = resolveBooleanProperty("prod")
+}
+
+
+

contract/build.gradle

@@ -0,0 +1,116 @@
+import org.openapitools.generator.gradle.plugin.tasks.GenerateTask
+
+plugins {
+    id "java-library"
+    id 'org.openapi.generator' version '7.9.0'
+}
+
+
+def specDir = project.layout.projectDirectory.dir("src/main/resources/swagger/")
+def targetDir = project.layout.buildDirectory.dir("generated").get()
+
+dependencies {
+    implementation libs.spring.starter.webflux
+    implementation libs.spring.starter.validation
+    api libs.swagger.integration.jakarta
+    api libs.jackson.databind.nullable
+    api libs.annotation.api
+    compileOnly libs.lombok
+    annotationProcessor libs.lombok
+}
+
+tasks.register('generateUiClient', GenerateTask) {
+    generatorName = "java"
+    inputSpec = specDir.file("kafbat-ui-api.yaml").asFile.absolutePath
+    outputDir = targetDir.dir("kafbat-ui-client").asFile.absolutePath
+    apiPackage = "io.kafbat.ui.api.api"
+    invokerPackage = "io.kafbat.ui.api"
+    modelPackage = "io.kafbat.ui.api.model"
+
+    configOptions = [library          : 'webclient',
+                     asyncNative      : 'true',
+                     useBeanValidation: 'true',
+                     dateLibrary      : 'java8',
+                     useJakartaEe     : 'true',]
+}
+
+tasks.register('generateBackendApi', GenerateTask) {
+    generatorName = "spring"
+    inputSpec = specDir.file("kafbat-ui-api.yaml").asFile.absolutePath
+    outputDir = targetDir.dir("api").asFile.absolutePath
+    apiPackage = "io.kafbat.ui.api"
+    invokerPackage = "io.kafbat.ui.api"
+    modelPackage = "io.kafbat.ui.model"
+    modelNameSuffix = "DTO"
+
+    additionalProperties = [removeEnumValuePrefix: "false"]
+
+    configOptions = [reactive                            : "true",
+                     interfaceOnly                       : "true",
+                     skipDefaultInterface                : "true",
+                     useTags                             : "true",
+                     useSpringBoot3                      : "true",
+                     dateLibrary                         : "java8",
+                     generateConstructorWithAllArgs      : "false",
+                     generatedConstructorWithRequiredArgs: "false",
+                     additionalModelTypeAnnotations      : """
+            @lombok.experimental.SuperBuilder
+            @lombok.AllArgsConstructor
+            @lombok.NoArgsConstructor
+            """]
+}
+
+tasks.register('generateConnectClient', GenerateTask) {
+    generatorName = "java"
+    inputSpec = specDir.file("kafka-connect-api.yaml").asFile.absolutePath
+    outputDir = targetDir.dir("kafka-connect-client").asFile.absolutePath
+    generateApiTests = false
+    generateModelTests = false
+    apiPackage = "io.kafbat.ui.connect.api"
+    modelPackage = "io.kafbat.ui.connect.model"
+    invokerPackage = "io.kafbat.ui.connect"
+
+
+    configOptions = [asyncNative      : "true",
+                     library          : "webclient",
+                     useJakartaEe     : "true",
+                     useBeanValidation: "true",
+                     dateLibrary      : "java8",]
+}
+
+tasks.register('generateSchemaRegistryClient', GenerateTask) {
+    generatorName = "java"
+    inputSpec = specDir.file("kafka-sr-api.yaml").asFile.absolutePath
+    outputDir = targetDir.dir("kafka-sr-client").asFile.absolutePath
+    generateApiTests = false
+    generateModelTests = false
+    apiPackage = "io.kafbat.ui.sr.api"
+    invokerPackage = "io.kafbat.ui.sr"
+    modelPackage = "io.kafbat.ui.sr.model"
+
+    configOptions = [asyncNative      : "true",
+                     library          : "webclient",
+                     useJakartaEe     : "true",
+                     useBeanValidation: "true",
+                     dateLibrary      : "java8",]
+}
+
+sourceSets {
+    main {
+        java {
+            srcDir targetDir.dir("api/src/main/java")
+            srcDir targetDir.dir("kafka-connect-client/src/main/java")
+            srcDir targetDir.dir("kafbat-ui-client/src/main/java")
+            srcDir targetDir.dir("kafka-sr-client/src/main/java")
+        }
+
+        resources {
+            srcDir specDir
+        }
+    }
+}
+
+compileJava.dependsOn generateUiClient, generateBackendApi, generateConnectClient, generateSchemaRegistryClient
+processResources.dependsOn generateUiClient, generateBackendApi, generateConnectClient, generateSchemaRegistryClient
+
+

e2e-tests/build.gradle

@@ -0,0 +1,48 @@
+plugins {
+    id 'java'
+    id 'checkstyle'
+    id 'io.qameta.allure' version '2.10.0'
+}
+
+ext {
+    kafkaVersion = "3.8.0"
+    aspectjVersion = "1.9.21"
+    allureVersion = "2.27.0"
+}
+
+dependencies {
+    implementation project(":contract")
+    implementation "org.apache.kafka:kafka_2.13:${kafkaVersion}"
+    implementation "org.aspectj:aspectjweaver:${aspectjVersion}"
+    implementation "commons-io:commons-io:2.16.1"
+    implementation "org.testng:testng:7.10.0"
+    implementation "com.codeborne:selenide:7.2.3"
+    implementation "io.qameta.allure:allure-testng:${allureVersion}"
+    implementation "io.qameta.allure:allure-selenide:${allureVersion}"
+    implementation "io.github.bonigarcia:webdrivermanager:5.8.0"
+    implementation libs.spring.starter.webflux
+    implementation "io.netty:netty-resolver-dns-native-macos:4.1.116.Final"
+
+    implementation libs.lombok
+
+    annotationProcessor libs.lombok
+    testAnnotationProcessor libs.lombok
+}
+
+checkstyle {
+    toolVersion '10.3.1'
+    configFile = rootProject.file('etc/checkstyle/checkstyle.xml')
+    ignoreFailures = false
+    maxWarnings = 10
+    maxErrors = 0
+}
+
+
+test {
+    useTestNG()
+}
+
+tasks.named('test') {
+    enabled = prod
+}
+