Switch to better RakNet library

Author: RaphiMC

build.gradle

@@ -26,22 +26,6 @@ repositories {
             includeGroupByRegex "net\\.raphimc(\\..+)?"
         }
     }
-    maven {
-        name = "OpenCollab Releases"
-        url = "https://repo.opencollab.dev/maven-releases"
-
-        content {
-            includeGroupByRegex "org\\.cloudburstmc(\\..+)?"
-        }
-    }
-    maven {
-        name = "OpenCollab Snapshots"
-        url = "https://repo.opencollab.dev/maven-snapshots"
-
-        content {
-            includeGroupByRegex "org\\.cloudburstmc(\\..+)?"
-        }
-    }
     maven {
         name = "Minecraft Libraries"
         url = "https://libraries.minecraft.net"
@@ -67,7 +51,7 @@ dependencies {
     compileOnly "net.raphimc:ViaLegacy:3.0.11"
     compileOnly "com.viaversion:viaaprilfools-common:4.0.5"
     compileOnly "net.raphimc:ViaBedrock:0.0.24-SNAPSHOT"
-    compileOnly "org.cloudburstmc.netty:netty-transport-raknet:1.0.0.CR3-SNAPSHOT"
+    compileOnly "dev.kastle.netty:netty-transport-raknet:1.4.0"
 
     api "com.google.guava:guava:33.5.0-jre"
     api "org.slf4j:slf4j-api:2.0.17"

src/main/java/com/viaversion/vialoader/netty/VLLegacyPipeline.java

@@ -20,6 +20,8 @@
  */
 package com.viaversion.vialoader.netty;
 
+import com.viaversion.vialoader.netty.viabedrock.DisconnectHandler;
+import com.viaversion.vialoader.netty.viabedrock.RakNetMessageEncapsulationCodec;
 import com.viaversion.viaversion.api.Via;
 import com.viaversion.viaversion.api.connection.UserConnection;
 import com.viaversion.viaversion.api.protocol.version.ProtocolVersion;
@@ -32,8 +34,6 @@
 import net.raphimc.viabedrock.netty.PacketEncapsulationCodec;
 import net.raphimc.vialegacy.netty.PreNettyLengthPrepender;
 import net.raphimc.vialegacy.netty.PreNettyLengthRemover;
-import com.viaversion.vialoader.netty.viabedrock.DisconnectHandler;
-import com.viaversion.vialoader.netty.viabedrock.RakMessageEncapsulationCodec;
 
 public abstract class VLLegacyPipeline extends ChannelInboundHandlerAdapter {
 
@@ -82,7 +82,7 @@ public void handlerAdded(ChannelHandlerContext ctx) {
     @Override
     public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
         if (CompressionReorderEvent.INSTANCE.equals(evt)) {
-            final int decoderIndex = ctx.pipeline().names().indexOf(decompressName());
+            final int decoderIndex = ctx.pipeline().names().indexOf(this.decompressName());
             if (decoderIndex == -1) return;
 
             if (decoderIndex > ctx.pipeline().names().indexOf(VIA_DECODER_NAME)) {
@@ -92,8 +92,8 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exc
                 ctx.pipeline().remove(decoder);
                 ctx.pipeline().remove(encoder);
 
-                ctx.pipeline().addAfter(decompressName(), VIA_DECODER_NAME, decoder);
-                ctx.pipeline().addAfter(compressName(), VIA_ENCODER_NAME, encoder);
+                ctx.pipeline().addAfter(this.decompressName(), VIA_DECODER_NAME, decoder);
+                ctx.pipeline().addAfter(this.compressName(), VIA_ENCODER_NAME, encoder);
             }
         }
 
@@ -121,7 +121,7 @@ protected ChannelHandler createViaBedrockDisconnectHandler() {
     }
 
     protected ChannelHandler createViaBedrockFrameEncapsulationHandler() {
-        return new RakMessageEncapsulationCodec();
+        return new RakNetMessageEncapsulationCodec();
     }
 
     protected ChannelHandler createViaBedrockBatchLengthCodec() {

src/main/java/com/viaversion/vialoader/netty/VLPipeline.java

@@ -20,6 +20,8 @@
  */
 package com.viaversion.vialoader.netty;
 
+import com.viaversion.vialoader.netty.viabedrock.DisconnectHandler;
+import com.viaversion.vialoader.netty.viabedrock.RakNetMessageEncapsulationCodec;
 import com.viaversion.viaversion.api.Via;
 import com.viaversion.viaversion.api.connection.UserConnection;
 import com.viaversion.viaversion.api.protocol.version.ProtocolVersion;
@@ -32,8 +34,6 @@
 import net.raphimc.viabedrock.netty.BatchLengthCodec;
 import net.raphimc.viabedrock.netty.PacketEncapsulationCodec;
 import net.raphimc.vialegacy.netty.PreNettyLengthCodec;
-import com.viaversion.vialoader.netty.viabedrock.DisconnectHandler;
-import com.viaversion.vialoader.netty.viabedrock.RakMessageEncapsulationCodec;
 
 public abstract class VLPipeline extends ChannelInboundHandlerAdapter {
 
@@ -100,7 +100,7 @@ protected ChannelHandler createViaBedrockDisconnectHandler() {
     }
 
     protected ChannelHandler createViaBedrockFrameEncapsulationHandler() {
-        return new RakMessageEncapsulationCodec();
+        return new RakNetMessageEncapsulationCodec();
     }
 
     protected ChannelHandler createViaBedrockBatchLengthCodec() {

…edrock/RakMessageEncapsulationCodec.java …ock/RakNetMessageEncapsulationCodec.javasrc/main/java/com/viaversion/vialoader/netty/viabedrock/RakMessageEncapsulationCodec.java renamed to src/main/java/com/viaversion/vialoader/netty/viabedrock/RakNetMessageEncapsulationCodec.java src/main/java/com/viaversion/vialoader/netty/viabedrock/RakMessageEncapsulationCodec.java renamed to src/main/java/com/viaversion/vialoader/netty/viabedrock/RakNetMessageEncapsulationCodec.java

@@ -30,7 +30,7 @@
 
 import java.util.List;
 
-public class RakMessageEncapsulationCodec extends MessageToMessageCodec<RakMessage, ByteBuf> {
+public class RakNetMessageEncapsulationCodec extends MessageToMessageCodec<RakMessage, ByteBuf> {
 
     private static final int FRAME_ID = 0xFE;
 

…y/viabedrock/PingEncapsulationCodec.java …edrock/RakNetPingEncapsulationCodec.javasrc/main/java/com/viaversion/vialoader/netty/viabedrock/PingEncapsulationCodec.java renamed to src/main/java/com/viaversion/vialoader/netty/viabedrock/RakNetPingEncapsulationCodec.java src/main/java/com/viaversion/vialoader/netty/viabedrock/PingEncapsulationCodec.java renamed to src/main/java/com/viaversion/vialoader/netty/viabedrock/RakNetPingEncapsulationCodec.java

@@ -30,11 +30,11 @@
 import java.net.InetSocketAddress;
 import java.util.List;
 
-public class PingEncapsulationCodec extends MessageToMessageCodec<RakPong, ByteBuf> {
+public class RakNetPingEncapsulationCodec extends MessageToMessageCodec<RakPong, ByteBuf> {
 
     private final InetSocketAddress remoteAddress;
 
-    public PingEncapsulationCodec(final InetSocketAddress remoteAddress) {
+    public RakNetPingEncapsulationCodec(final InetSocketAddress remoteAddress) {
         this.remoteAddress = remoteAddress;
     }