Merge pull request #21 from SLNE-Development/feat/redis-streams

refactor: Use redis streams for sync structures

Author: twisti-dev

.idea/dictionaries/project.xml

@@ -0,0 +1,7 @@
+{
+    "diagnostics.globals": [
+        "redis",
+        "KEYS",
+        "ARGV"
+    ]
+}

.idea/externalDependencies.xml

@@ -1,9 +1,6 @@
 import com.github.jengelman.gradle.plugins.shadow.ShadowExtension
 import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
 import org.jetbrains.kotlin.gradle.dsl.KotlinJvmExtension
-import org.jetbrains.kotlin.gradle.dsl.KotlinJvmProjectExtension
-import org.jetbrains.kotlin.gradle.dsl.abi.AbiValidationExtension
-import org.jetbrains.kotlin.gradle.dsl.abi.ExperimentalAbiValidation
 
 buildscript {
     repositories {
@@ -45,16 +42,5 @@ subprojects {
                 optIn.add("dev.slne.surf.redis.util.InternalRedisAPI")
             }
         }
-
-        @OptIn(ExperimentalAbiValidation::class)
-        configure<KotlinJvmProjectExtension> {
-            configure<AbiValidationExtension> {
-                filters {
-                    excluded {
-                        annotatedWith.add("dev.slne.surf.redis.util.InternalRedisAPI")
-                    }
-                }
-            }
-        }
     }
 }

.luarc.json

@@ -4,4 +4,4 @@ org.gradle.parallel=true
 #org.gradle.caching=true
 #org.gradle.configureondemand=true
 
-version=1.21.11-1.1.0-SNAPSHOT
+version=1.21.11-1.0.0-SNAPSHOT

build.gradle.kts

@@ -1,11 +1,28 @@
+@file:OptIn(ExperimentalAbiValidation::class)
+
 import dev.slne.surf.surfapi.gradle.util.slneReleases
+import org.gradle.kotlin.dsl.abiValidation
 import org.jetbrains.kotlin.gradle.dsl.abi.ExperimentalAbiValidation
 
 plugins {
     id("dev.slne.surf.surfapi.gradle.core")
 //    id("dev.slne.surf.surfapi.gradle.standalone") /* Uncomment to use tests */
 }
 
+surfCoreApi {
+    withApiValidation()
+}
+
+kotlin {
+    abiValidation {
+        filters {
+            excluded {
+                annotatedWith.add("dev.slne.surf.redis.util.InternalRedisAPI")
+            }
+        }
+    }
+}
+
 dependencies {
     api("org.redisson:redisson:4.1.0") {
         exclude("org.slf4j")
@@ -35,18 +52,35 @@ publishing {
     }
 }
 
-kotlin {
-    @OptIn(ExperimentalAbiValidation::class)
-    abiValidation {
-        enabled.set(true)
-    }
-}
-
 tasks.test {
     useJUnitPlatform()
 }
 
+tasks {
+    dumpLegacyAbi {
+    }
+
+    updateLegacyAbi {
+
+    }
+}
+
+//tasks {
+//    apiBuild {
+//        inputJar.value(shadowJar.flatMap { it.archiveFile })
+//    }
+//}
+
 java {
     withSourcesJar()
     withJavadocJar()
-}
+}
+
+//afterEvaluate {
+//    tasks.named("publishPluginMavenPublicationToMaven-releasesRepository") {
+//        enabled = false
+//    }
+//    tasks.named("publishPluginMavenPublicationToMavenLocal") {
+//        enabled = false
+//    }
+//}

gradle.properties

@@ -134,6 +134,8 @@ class RedisApi private constructor(
             val config = Config()
                 .setPassword(redisURI.password)
                 .setTransportMode(transportMode)
+                .setTcpKeepAlive(true)
+                .setTcpKeepAliveInterval(5.seconds.inWholeMilliseconds.toInt())
                 .setEventLoopGroup(RedisComponentProvider.get().eventLoopGroup)
                 .setExecutor(RedisComponentProvider.get().redissonExecutorService)
                 .apply {