|
25 | 25 | import io.netty.channel.ChannelHandler; |
26 | 26 | import io.netty.channel.ChannelHandlerContext; |
27 | 27 | import io.netty.channel.ChannelInboundHandlerAdapter; |
28 | | -import net.raphimc.viabedrock.api.protocol.BedrockBaseProtocol; |
29 | 28 | import net.raphimc.viabedrock.netty.BatchLengthCodec; |
30 | 29 | import net.raphimc.viabedrock.netty.PacketEncapsulationCodec; |
31 | | -import net.raphimc.vialegacy.api.protocol.PreNettyBaseProtocol; |
32 | 30 | import net.raphimc.vialegacy.netty.PreNettyLengthPrepender; |
33 | 31 | import net.raphimc.vialegacy.netty.PreNettyLengthRemover; |
34 | 32 | import net.raphimc.vialoader.netty.viabedrock.DisconnectHandler; |
@@ -66,11 +64,9 @@ public void handlerAdded(ChannelHandlerContext ctx) { |
66 | 64 |
|
67 | 65 | final ProtocolVersion r1_6_4 = ProtocolVersion.getProtocol(VersionType.RELEASE_INITIAL, 78); |
68 | 66 | if (r1_6_4.isKnown() && this.version.olderThanOrEqualTo(r1_6_4)) { |
69 | | - this.user.getProtocolInfo().getPipeline().add(PreNettyBaseProtocol.INSTANCE); |
70 | 67 | ctx.pipeline().addBefore(this.lengthSplitterName(), VIALEGACY_PRE_NETTY_LENGTH_PREPENDER_NAME, this.createViaLegacyPreNettyLengthPrepender()); |
71 | 68 | ctx.pipeline().addBefore(this.lengthPrependerName(), VIALEGACY_PRE_NETTY_LENGTH_REMOVER_NAME, this.createViaLegacyPreNettyLengthRemover()); |
72 | 69 | } else if (this.version.getName().startsWith("Bedrock")) { |
73 | | - this.user.getProtocolInfo().getPipeline().add(BedrockBaseProtocol.INSTANCE); |
74 | 70 | ctx.pipeline().addBefore(this.lengthSplitterName(), VIABEDROCK_DISCONNECT_HANDLER_NAME, this.createViaBedrockDisconnectHandler()); |
75 | 71 | ctx.pipeline().addBefore(this.lengthSplitterName(), VIABEDROCK_FRAME_ENCAPSULATION_HANDLER_NAME, this.createViaBedrockFrameEncapsulationHandler()); |
76 | 72 | this.replaceLengthSplitter(ctx, this.createViaBedrockBatchLengthCodec()); |
|
0 commit comments