Upstream/VIAaaS
1
0
Fork 0
mirror of https://github.com/ViaVersion/VIAaaS.git synced 2024-11-24 12:25:39 +01:00
Code Issues Packages Projects Releases Wiki Activity

fixed 1.8 comparison, invalidate detection fails

Browse Source 
fixes #231
This commit is contained in:
creeper123123321 2023-07-09 08:59:10 -03:00
parent bb07aaebb8
commit f09da91810
3 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle.kts
View File

@ -96,7 +96,7 @@ dependencies {
implementation("org.jline:jline-terminal-jansi:3.23.0")
implementation("org.slf4j:slf4j-api:$slf4jVer")
val ktorVersion = "2.3.0"
val ktorVersion = "2.3.2"
implementation("io.ktor:ktor-network-tls-certificates-jvm:$ktorVersion")
implementation("io.ktor:ktor-server-websockets:$ktorVersion")
implementation("io.ktor:ktor-server-netty-jvm:$ktorVersion")

2
src/main/kotlin/com/viaversion/aas/handler/BackEndInit.kt
View File

@ -21,7 +21,7 @@ class BackEndInit(val connectionData: ConnectionData, val proxyUri: URI?, val pr
val user = UserConnectionImpl(ch, true)
val pipeline = ProtocolPipelineImpl(user)
val version = connectionData.backServerVer!!
val isLegacy = LegacyProtocolVersion.protocolCompare(version, ProtocolVersion.v_1_6_4.version) <= 0
val isLegacy = LegacyProtocolVersion.protocolCompare(version, LegacyProtocolVersion.r1_6_4.version) <= 0
if (isLegacy) {
pipeline.add(PreNettyBaseProtocol.INSTANCE)

14
src/main/kotlin/com/viaversion/aas/handler/autoprotocol/ProtocolDetector.kt
View File

@ -32,7 +32,7 @@ import java.util.concurrent.TimeUnit
object ProtocolDetector {
val coroutineScope = CoroutineScope(SupervisorJob())
private val loader = CacheLoader.from<InetSocketAddress, CompletableFuture<ProtocolVersion>> { address ->
val loader = CacheLoader.from<InetSocketAddress, CompletableFuture<ProtocolVersion>> { address ->
val future = CompletableFuture<ProtocolVersion>()
coroutineScope.launch {
try {
@ -78,9 +78,17 @@ object ProtocolDetector {
future
}
private val SERVER_VER = CacheBuilder.newBuilder()
private val versionCache = CacheBuilder.newBuilder()
.expireAfterWrite(VIAaaSConfig.protocolDetectorCache.toLong(), TimeUnit.SECONDS)
.build(loader)
fun detectVersion(address: InetSocketAddress): CompletableFuture<ProtocolVersion> = SERVER_VER[address]
fun detectVersion(address: InetSocketAddress): CompletableFuture<ProtocolVersion> {
val future = versionCache[address]
future.whenComplete { _, throwable ->
if (throwable != null) {
versionCache.invalidate(address)
}
}
return future
}
}