Upstream/VIAaaS
1
0
Fork 0
mirror of https://github.com/ViaVersion/VIAaaS.git synced 2024-09-16 02:56:43 +02:00
Code Issues Packages Projects Releases Wiki Activity

idk, try to fix compression, but not works on 1.7

Browse Source
This commit is contained in:
creeper123123321 2020-09-27 19:47:38 -03:00
parent 77017d4426
commit 2cfbf21bd5
1 changed files with 35 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
src/main/kotlin/com/github/creeper123123321/viaaas/CloudProtocol.kt
View File

@ -26,17 +26,20 @@ import javax.naming.directory.InitialDirContext
class CloudPipeline(userConnection: UserConnection) : ProtocolPipeline(userConnection) { class CloudPipeline(userConnection: UserConnection) : ProtocolPipeline(userConnection) {
override fun registerPackets() { override fun registerPackets() {
super.registerPackets() super.registerPackets()
add(CloudHandlerProtocol) add(CloudHeadProtocol)
add(CloudTailProtocol)
} }
override fun add(protocol: Protocol<*, *, *, *>?) { override fun add(protocol: Protocol<*, *, *, *>?) {
super.add(protocol) super.add(protocol)
pipes().remove(CloudHandlerProtocol) pipes().remove(CloudHeadProtocol)
pipes().add(CloudHandlerProtocol) // needs to be the last pipes().add(0, CloudHeadProtocol)
pipes().remove(CloudTailProtocol)
pipes().add(CloudTailProtocol)
} }
} }
object CloudHandlerProtocol : SimpleProtocol() { object CloudHeadProtocol : SimpleProtocol() {
val logger = Logger.getLogger("CloudHandlerProtocol") val logger = Logger.getLogger("CloudHandlerProtocol")
override fun registerPackets() { override fun registerPackets() {
this.registerIncoming(State.HANDSHAKE, 0, 0, object : PacketRemapper() { this.registerIncoming(State.HANDSHAKE, 0, 0, object : PacketRemapper() {
@ -124,26 +127,6 @@ object CloudHandlerProtocol : SimpleProtocol() {
} }
}) })
this.registerOutgoing(State.LOGIN, 3, 3, object : PacketRemapper() {
// set compression
override fun registerMap() {
handler {
val pipe = it.user().channel!!.pipeline()
val threshold = it.read(Type.VAR_INT)
it.cancel()
it.create(3) {
it.write(Type.VAR_INT, threshold)
}.send(CloudHandlerProtocol::class.java, true, true) // needs to be sent uncompressed
pipe.get(CloudCompressor::class.java).threshold = threshold
pipe.get(CloudDecompressor::class.java).threshold = threshold
val backPipe = pipe.get(CloudSideForwarder::class.java).other!!.pipeline()
backPipe.get(CloudCompressor::class.java)?.threshold = threshold
backPipe.get(CloudDecompressor::class.java)?.threshold = threshold
}
}
})
this.registerOutgoing(State.LOGIN, 1, 1, object : PacketRemapper() { this.registerOutgoing(State.LOGIN, 1, 1, object : PacketRemapper() {
// encryption request // encryption request
override fun registerMap() { override fun registerMap() {
@ -157,6 +140,34 @@ object CloudHandlerProtocol : SimpleProtocol() {
} }
} }
object CloudTailProtocol : SimpleProtocol() {
override fun registerPackets() {
this.registerOutgoing(State.LOGIN, 3, 3, object : PacketRemapper() {
// set compression
override fun registerMap() {
handler {
val pipe = it.user().channel!!.pipeline()
val threshold = it.read(Type.VAR_INT)
it.cancel()
try {
it.create(3) {
it.write(Type.VAR_INT, threshold)
}.send(CloudTailProtocol::class.java, true, true) // needs to be sent uncompressed
} catch (ignored: Exception) {
// ViaRewind cancels it
}
pipe.get(CloudCompressor::class.java).threshold = threshold
pipe.get(CloudDecompressor::class.java).threshold = threshold
val backPipe = pipe.get(CloudSideForwarder::class.java).other!!.pipeline()
backPipe.get(CloudCompressor::class.java)?.threshold = threshold
backPipe.get(CloudDecompressor::class.java)?.threshold = threshold
}
}
})
}
}
fun Channel.setAutoRead(b: Boolean) { fun Channel.setAutoRead(b: Boolean) {
this.config().isAutoRead = b this.config().isAutoRead = b
if (b) this.read() if (b) this.read()