Managed by Terraform, updates managed through: https://github.com/Air…

…things/kotlin-libraries

build.gradle.kts

@@ -1,273 +1,40 @@
-/*
- * This file was generated by the Gradle 'init' task.
- *
- * This is a general purpose Gradle build.
- * Learn more about Gradle by exploring our samples at https://docs.gradle.org/7.4.2/samples
- * This project uses @Incubating APIs which are subject to change.
- */
+import com.airthings.buildtools.util.Dependencies
+import com.airthings.buildtools.util.Library
+import com.airthings.buildtools.util.testImplementationAll
 
-import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
-import org.gradle.api.tasks.testing.logging.TestExceptionFormat
-import java.time.LocalDateTime
-import java.time.format.DateTimeFormatter
-import java.net.URI
-
-val defaultJdkVersion = 17
-java {
-    toolchain {
-        languageVersion.set(JavaLanguageVersion.of(11))
-    }
-}
-
-
-buildscript {
-    repositories {
-        mavenCentral()
-        maven{ url = uri("https://s01.oss.sonatype.org/content/repositories/snapshots/") }
-    }
-}
+group = "com.airthings.cloud.clickhouse-kafka-connect"
 
 plugins {
-    idea
     `java-library`
     `maven-publish`
-    signing
-   // checkstyle
-    id("com.github.gmazzo.buildconfig") version "5.5.0"
-    id("com.diffplug.spotless") version "6.25.0"
-    id("com.github.johnrengelman.shadow") version "7.1.2"
-    id("co.uzzu.dotenv.gradle") version "4.0.0" apply true
 }
 
-group = "com.airthings.clickhouse"
-version = file("VERSION").readText().trim()
-description = "The official ClickHouse Apache Kafka Connect Connector."
+kotlin {
+    explicitApi()
+}
 
 repositories {
     mavenCentral()
-    maven("https://packages.confluent.io/maven/")
-    maven("https://jitpack.io")
 }
 
-extra.apply {
-    set("clickHouseDriverVersion", "0.7.1")
-    set("kafkaVersion", "2.7.0")
-
-    // Testing dependencies
-    set("junitJupiterVersion", "5.9.2")
-    set("junitPlatformVersion", "1.8.1")
-    set("hamcrestVersion", "2.2")
-    set("mockitoVersion", "4.0.0")
-
-    // Integration test dependencies
-    set("confluentVersion", "6.0.1")
-    set("scalaVersion", "2.13")
-    set("curatorVersion", "2.9.0")
-    set("connectUtilsVersion", "0.4+")
-}
-
-val clickhouseDependencies: Configuration by configurations.creating
-
 dependencies {
-    implementation("org.apache.kafka:connect-api:${project.extra["kafkaVersion"]}")
-    implementation("com.clickhouse:clickhouse-client:${project.extra["clickHouseDriverVersion"]}")
-    implementation("com.clickhouse:clickhouse-http-client:${project.extra["clickHouseDriverVersion"]}")
-    implementation("com.clickhouse:clickhouse-data:${project.extra["clickHouseDriverVersion"]}")
-    implementation("com.clickhouse:client-v2:${project.extra["clickHouseDriverVersion"]}")
-    implementation("io.projectreactor:reactor-core:3.7.0")
-    implementation("com.google.code.gson:gson:2.11.0")
-    // https://mvnrepository.com/artifact/org.apache.httpcomponents.client5/httpclient5
-    implementation("org.apache.httpcomponents.client5:httpclient5:5.3.1")
-    // https://mvnrepository.com/artifact/com.google.guava/guava
-    implementation("com.google.guava:guava:33.3.1-jre")
-
-
-    // Avoid telescoping constructors problem with the builder pattern using Lombok
-    compileOnly("org.projectlombok:lombok:1.18.34")
-    annotationProcessor("org.projectlombok:lombok:1.18.34")
-
-    // To parse JSON response from ClickHouse to parse complex data types correctly
-    implementation("com.fasterxml.jackson.core:jackson-core:2.17.2")
-    implementation("com.fasterxml.jackson.core:jackson-databind:2.17.2")
-    implementation("com.fasterxml.jackson.core:jackson-annotations:2.18.1")
-
-
-    // TODO: need to remove ???
-    implementation("org.slf4j:slf4j-reload4j:2.0.13")
-    implementation("org.junit.jupiter:junit-jupiter-api:5.11.3")
-    implementation("org.testcontainers:testcontainers:1.20.1")
-    implementation("org.testcontainers:toxiproxy:1.20.1")
-
-    /*
-        Will in side the Confluent Archive
-     */
-    clickhouseDependencies("org.apache.httpcomponents.client5:httpclient5:5.3.1")
-    clickhouseDependencies("io.lettuce:lettuce-core:6.5.0.RELEASE")
-    clickhouseDependencies("com.clickhouse:clickhouse-client:${project.extra["clickHouseDriverVersion"]}")
-    clickhouseDependencies("com.clickhouse:client-v2:${project.extra["clickHouseDriverVersion"]}")
-    clickhouseDependencies("com.clickhouse:clickhouse-http-client:${project.extra["clickHouseDriverVersion"]}")
-    clickhouseDependencies("com.google.code.gson:gson:2.11.0")
-    clickhouseDependencies("com.fasterxml.jackson.core:jackson-core:2.17.2")
-    clickhouseDependencies("com.fasterxml.jackson.core:jackson-databind:2.17.2")
-    clickhouseDependencies("com.fasterxml.jackson.core:jackson-annotations:2.18.1")
-
-    // Unit Tests
-    testImplementation(platform("org.junit:junit-bom:${project.extra["junitJupiterVersion"]}"))
-    testImplementation("org.junit.jupiter:junit-jupiter")
-    testImplementation("org.junit.platform:junit-platform-runner")
-    testImplementation("org.apiguardian:apiguardian-api:1.1.2") // https://github.com/gradle/gradle/issues/18627
-    testImplementation("org.hamcrest:hamcrest:${project.extra["hamcrestVersion"]}")
-    testImplementation("org.mockito:mockito-junit-jupiter:${project.extra["mockitoVersion"]}")
-
-    // IntegrationTests
-    testImplementation("org.testcontainers:clickhouse:1.20.3")
-    testImplementation("org.testcontainers:kafka:1.20.1")
-    testImplementation("com.squareup.okhttp3:okhttp:4.12.0")
-    testImplementation("org.json:json:20240303")
-    testImplementation("org.testcontainers:toxiproxy:1.20.1")
-    testImplementation("org.apache.httpcomponents.client5:httpclient5:5.3.1")
-    testImplementation("com.clickhouse:clickhouse-jdbc:${project.extra["clickHouseDriverVersion"]}:all")
-    testImplementation("com.clickhouse:clickhouse-client:${project.extra["clickHouseDriverVersion"]}")
-    testImplementation("com.clickhouse:client-v2:${project.extra["clickHouseDriverVersion"]}")
-    testImplementation("com.clickhouse:clickhouse-http-client:${project.extra["clickHouseDriverVersion"]}")
-
-}
-
-
-sourceSets.create("integrationTest") {
-    java.srcDir("src/integrationTest/java")
-    compileClasspath += sourceSets["main"].output + configurations["testRuntimeClasspath"]
-    runtimeClasspath += output + compileClasspath + sourceSets["test"].runtimeClasspath
-}
-tasks.create("integrationTest", Test::class.java) {
-    description = "Runs the integration tests"
-    group = "verification"
-    testClassesDirs = sourceSets["integrationTest"].output.classesDirs
-    classpath = sourceSets["integrationTest"].runtimeClasspath
-    outputs.upToDateWhen { false }
-    dependsOn("prepareConfluentArchive")
-    mustRunAfter("test")
-    systemProperties = System.getProperties() as Map<String, Any>
-}
-
-tasks.withType<JavaCompile> {
-    options.compilerArgs.addAll(listOf("-Xlint:unchecked", "-Xlint:deprecation"))
-}
-
-tasks.withType<Test> {
-    maxParallelForks = (Runtime.getRuntime().availableProcessors() / 2).takeIf { it > 0 } ?: 1
-    tasks.getByName("check").dependsOn(this)
-    systemProperty("file.encoding", "windows-1252") // run tests with different encoding
-    useJUnitPlatform()
-    testLogging {
-        events("passed", "skipped", "failed")
-    }
-    testLogging.exceptionFormat = TestExceptionFormat.FULL
-    val javaVersion: Int = (project.findProperty("javaVersion") as String? ?: defaultJdkVersion.toString()).toInt()
-    logger.info("Running tests using JDK$javaVersion")
-    javaLauncher.set(javaToolchains.launcherFor {
-        languageVersion.set(JavaLanguageVersion.of(javaVersion))
-    })
-
-    systemProperties(mapOf("com.clickhouse.test.uri" to System.getProperty("com.clickhouse.test.uri", "")))
-
-    val jdkHome = project.findProperty("jdkHome") as String?
-    jdkHome.let {
-        val javaExecutablesPath = File(jdkHome, "bin/java")
-        if (javaExecutablesPath.exists()) {
-            executable = javaExecutablesPath.absolutePath
-        }
-    }
-
-    addTestListener(object : TestListener {
-        override fun beforeTest(testDescriptor: TestDescriptor?) {}
-        override fun beforeSuite(suite: TestDescriptor?) {}
-        override fun afterTest(testDescriptor: TestDescriptor?, result: TestResult?) {}
-        override fun afterSuite(d: TestDescriptor?, r: TestResult?) {
-            if (d != null && r != null && d.parent == null) {
-                val resultsSummary = """Tests summary:
-                    | ${r.testCount} tests,
-                    | ${r.successfulTestCount} succeeded,
-                    | ${r.failedTestCount} failed,
-                    | ${r.skippedTestCount} skipped""".trimMargin().replace("\n", "")
-
-                val border = "=".repeat(resultsSummary.length)
-                logger.lifecycle("\n$border")
-                logger.lifecycle("Test result: ${r.resultType}")
-                logger.lifecycle(resultsSummary)
-                logger.lifecycle("${border}\n")
-            }
-        }
-    })
-}
-
-/*
- * ShadowJar
- */
-tasks.withType<Jar> {
-    manifest {
-        attributes["Implementation-Title"] = "ClickHouse-Kafka-Connect"
-        attributes["Implementation-Version"] = project.version.toString()
-    }
-}
-tasks.register<ShadowJar>("confluentJar") {
-    archiveClassifier.set("confluent")
-    from(clickhouseDependencies, sourceSets.main.get().output)
-}
-
-/*
-tasks.register<ShadowJar>("allJar") {
-    archiveClassifier.set("all")
-    from(clickhouseDependencies, sourceSets.main.get().output)
+    testImplementationAll(*Dependencies.kotest)
+    testImplementationAll(*Dependencies.moshi)
+    testImplementation(Dependencies.kotlinsnapshot)
+    implementation(Dependencies.sensortype)
 }
-*/
-
-
-// Confluent Archive
-val releaseDate by extra(DateTimeFormatter.ISO_LOCAL_DATE.format(LocalDateTime.now()))
-val archiveFilename = "clickhouse-kafka-connect"
-tasks.register<Copy>("prepareConfluentArchive") {
-    group = "Confluent"
-    description = "Prepares the Confluent Archive ready for the hub"
-    dependsOn("confluentJar")
-
-    val baseDir = "$archiveFilename-${project.version}"
-    from("config/archive/manifest.json") {
-        expand(project.properties)
-        destinationDir = file("$buildDir/confluentArchive/$baseDir")
-    }
-
-    from("config/archive/assets") {
-        into("assets")
-    }
 
-    from("$buildDir/libs") {
-        include(listOf("${project.name}-${project.version}-confluent.jar"))
-        into("lib")
-    }
+val latestTag = command("git describe --tags --abbrev=0") ?: "dummy.version" // dummy version for builds != deployment/publish
 
-    from(".") {
-        include(listOf("README.md", "LICENSE"))
-        into("doc")
-    }
-}
-
-tasks.register<Zip>("createConfluentArchive") {
-    group = "Confluent"
-    description = "Creates the Confluent Archive zipfile to be uploaded to the Confluent Hub"
-    dependsOn("prepareConfluentArchive")
-    from(files("$buildDir/confluentArchive"))
-    archiveBaseName.set("")
-    archiveAppendix.set(archiveFilename)
-    archiveVersion.set(project.version.toString())
-    destinationDirectory.set(file("$buildDir/confluent"))
+subprojects {
+    version = latestTag
 }
 
 publishing {
     repositories {
         maven {
-            name = "GitHubPackages"
-            url = URI("https://maven.pkg.github.com/airthings/clickhouse-kafka-connect")
+            name = "AirthingsGitHubPackages"
+            url = uri("https://maven.pkg.github.com/airthings/lib-clickhouse-kafka-connect")
             credentials {
                 username = System.getenv("GITHUB_ACTOR")
                 password = System.getenv("GITHUB_TOKEN")
@@ -276,8 +43,18 @@ publishing {
     }
 
     publications {
-        register<MavenPublication>("gpr") {
-            from(components["java"])
+        withType<MavenPublication> {
+            pom {
+                artifactId = "clickhouse-kafka-connect"
+            }
         }
     }
-}
+}
+
+fun command(command: String): String? {
+    val cmd = command.split(" ").toTypedArray()
+    val process = ProcessBuilder(*cmd)
+        .redirectOutput(ProcessBuilder.Redirect.PIPE)
+        .start()
+    return process.inputStream.bufferedReader().readLine()?.trim()
+}