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

fixed compression in 1.7

Browse Source
This commit is contained in:
creeper123123321 2020-09-27 20:59:09 -03:00
parent 2cfbf21bd5
commit e364f65f8e
1 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -26,15 +26,14 @@ import javax.naming.directory.InitialDirContext
class CloudPipeline(userConnection: UserConnection) : ProtocolPipeline(userConnection) {
override fun registerPackets() {
super.registerPackets()
add(CloudHeadProtocol)
add(CloudTailProtocol)
add(CloudHeadProtocol) // add() will add tail protocol
}
override fun add(protocol: Protocol<*, *, *, *>?) {
super.add(protocol)
pipes().remove(CloudHeadProtocol)
pipes().removeIf { it == CloudHeadProtocol }
pipes().add(0, CloudHeadProtocol)
pipes().remove(CloudTailProtocol)
pipes().removeIf { it == CloudTailProtocol }
pipes().add(CloudTailProtocol)
}
}
@ -149,13 +148,9 @@ object CloudTailProtocol : SimpleProtocol() {
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
}
it.create(3) {
it.write(Type.VAR_INT, threshold)
}.send(CloudTailProtocol::class.java, true, true) // needs to be sent uncompressed
pipe.get(CloudCompressor::class.java).threshold = threshold
pipe.get(CloudDecompressor::class.java).threshold = threshold