Rewrite BrokerClient and RPC system (#10)

.github/workflows/vanilla-docker.yml

@@ -25,25 +25,25 @@ jobs:
         working-directory: ${{ env.WORKING_DIRECTORY }}
 
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           submodules: recursive
 
       - uses: gradle/wrapper-validation-action@v1
 
       - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
+        uses: docker/setup-buildx-action@v3
 
       - name: Log into Container registry
         if: github.event_name != 'pull_request'
-        uses: docker/login-action@v2
+        uses: docker/login-action@v3
         with:
           registry: ${{ env.CONTAINER_REGISTRY }}
           username: ${{ github.actor }}
           password: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Extract Docker metadata
-        uses: docker/metadata-action@v4
+        uses: docker/metadata-action@v5
         id: meta
         with:
           images: ${{ env.CONTAINER_REGISTRY }}/${{ env.IMAGE_NAME }}
@@ -54,7 +54,7 @@ jobs:
             org.opencontainers.image.description=The central cluster manager for Beemo.
 
       - name: Build and push Docker image
-        uses: docker/build-push-action@v4
+        uses: docker/build-push-action@v5
         with:
           context: .
           file: ${{ env.WORKING_DIRECTORY }}/Dockerfile

latte/build.gradle.kts

@@ -0,0 +1,52 @@
+plugins {
+    `java-library`
+    kotlin("jvm") version "1.9.20"
+    id("com.google.devtools.ksp") version "1.9.20-1.0.14"
+}
+
+group = "gg.beemo.latte"
+version = "1.0.0"
+
+dependencies {
+
+    // Kotlin
+    val kotlinCoroutinesVersion = "1.7.3"
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:$kotlinCoroutinesVersion")
+    testImplementation("org.jetbrains.kotlinx:kotlinx-coroutines-test:$kotlinCoroutinesVersion")
+
+    // Kafka
+    val kafkaVersion = "3.2.3"
+    implementation("org.apache.kafka:kafka-clients:$kafkaVersion")
+    implementation("org.apache.kafka:kafka-streams:$kafkaVersion")
+
+    // JSON
+    val moshiVersion = "1.14.0"
+    implementation("com.squareup.moshi:moshi:$moshiVersion")
+    ksp("com.squareup.moshi:moshi-kotlin-codegen:$moshiVersion")
+
+    // Misc
+    implementation("org.jetbrains:annotations:24.1.0")
+    val log4jVersion = "2.22.0"
+    compileOnly("org.apache.logging.log4j:log4j-api:$log4jVersion")
+    testImplementation("org.apache.logging.log4j:log4j-core:$log4jVersion")
+
+    // JUnit testing framework
+    val junitVersion = "5.10.1"
+    testImplementation("org.junit.jupiter:junit-jupiter-api:$junitVersion")
+    testRuntimeOnly("org.junit.jupiter:junit-jupiter-engine:$junitVersion")
+
+}
+
+repositories {
+    mavenCentral()
+}
+
+kotlin {
+    jvmToolchain(17)
+}
+
+tasks.test {
+    useJUnitPlatform()
+}
+
+defaultTasks("build")

latte/settings.gradle.kts

@@ -0,0 +1 @@
+rootProject.name = "latte"

latte/src/main/java/gg/beemo/latte/CommonConfig.kt

@@ -2,7 +2,12 @@ package gg.beemo.latte
 
 object CommonConfig {
 
-    const val INVALID_CLUSTER_ID = Integer.MIN_VALUE.toString()
-    const val VANILLA_CLUSTER_ID = "-1"
+    object BrokerServices {
+        const val TEA = "tea" // Bot
+        const val VANILLA = "vanilla" // Bot cluster coordinator
+        const val MILK = "milk" // Raid logs
+        const val SUGAR = "sugar" // Premium management
+        const val COFFEE = "coffee" // Raid bans
+    }
 
 }