2018-10-28 00:35:46 +02:00
|
|
|
From 90dd8080a6033c2ec32984d813bb8b1f86a376b4 Mon Sep 17 00:00:00 2001
|
2016-07-03 08:56:31 +02:00
|
|
|
From: Troy Frew <fuzzy_bot@arenaga.me>
|
2016-11-15 16:32:02 +01:00
|
|
|
Date: Tue, 15 Nov 2016 10:31:04 -0500
|
|
|
|
Subject: [PATCH] 1.7.x Protocol Patch
|
2016-07-03 08:56:31 +02:00
|
|
|
|
|
|
|
|
2017-01-05 02:04:39 +01:00
|
|
|
diff --git a/protocol/src/main/java/io/github/waterfallmc/travertine/protocol/MultiVersionPacketV17.java b/protocol/src/main/java/io/github/waterfallmc/travertine/protocol/MultiVersionPacketV17.java
|
|
|
|
new file mode 100644
|
2018-09-04 04:15:37 +02:00
|
|
|
index 00000000..90064112
|
2017-01-05 02:04:39 +01:00
|
|
|
--- /dev/null
|
|
|
|
+++ b/protocol/src/main/java/io/github/waterfallmc/travertine/protocol/MultiVersionPacketV17.java
|
|
|
|
@@ -0,0 +1,90 @@
|
|
|
|
+package io.github.waterfallmc.travertine.protocol;
|
|
|
|
+
|
|
|
|
+import com.google.common.base.Preconditions;
|
|
|
|
+import io.netty.buffer.ByteBuf;
|
|
|
|
+
|
|
|
|
+import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
+
|
|
|
|
+public abstract class MultiVersionPacketV17 extends DefinedPacket
|
|
|
|
+{
|
|
|
|
+
|
|
|
|
+ protected void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ v17Read( buf );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void read0(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ switch ( protocolVersion )
|
|
|
|
+ {
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_7_2:
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_7_6:
|
|
|
|
+ v17Read(buf, direction, protocolVersion);
|
|
|
|
+ break;
|
|
|
|
+ default:
|
|
|
|
+ read(buf, direction, protocolVersion);
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ protected void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ v17Write( buf );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void write0(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ switch ( protocolVersion )
|
|
|
|
+ {
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_7_2:
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_7_6:
|
|
|
|
+ v17Write(buf, direction, protocolVersion);
|
|
|
|
+ break;
|
|
|
|
+ default:
|
|
|
|
+ write(buf, direction, protocolVersion);
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ protected void v17Read(ByteBuf buf)
|
|
|
|
+ {
|
|
|
|
+ throw new UnsupportedOperationException( "Packet must implement read method" );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ protected void v17Write(ByteBuf buf)
|
|
|
|
+ {
|
|
|
|
+ throw new UnsupportedOperationException( "Packet must implement write method" );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public static void v17writeArray(byte[] b, ByteBuf buf, boolean allowExtended)
|
|
|
|
+ {
|
|
|
|
+ // (Integer.MAX_VALUE & 0x1FFF9A ) = 2097050 - Forge's current upper limit
|
|
|
|
+ if ( allowExtended )
|
|
|
|
+ {
|
|
|
|
+ Preconditions.checkArgument( b.length <= ( Integer.MAX_VALUE & 0x1FFF9A ), "Cannot send array longer than 2097050 (got %s bytes)", b.length );
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ Preconditions.checkArgument( b.length <= Short.MAX_VALUE, "Cannot send array longer than Short.MAX_VALUE (got %s bytes)", b.length );
|
|
|
|
+ }
|
|
|
|
+ // Write a 2 or 3 byte number that represents the length of the packet. (3 byte "shorts" for Forge only)
|
|
|
|
+ // No vanilla packet should give a 3 byte packet, this method will still retain vanilla behaviour.
|
|
|
|
+ writeVarShort( buf, b.length );
|
|
|
|
+ buf.writeBytes( b );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public static byte[] v17readArray(ByteBuf buf)
|
|
|
|
+ {
|
|
|
|
+ // Read in a 2 or 3 byte number that represents the length of the packet. (3 byte "shorts" for Forge only)
|
|
|
|
+ // No vanilla packet should give a 3 byte packet, this method will still retain vanilla behaviour.
|
|
|
|
+ int len = readVarShort( buf );
|
|
|
|
+
|
|
|
|
+ // (Integer.MAX_VALUE & 0x1FFF9A ) = 2097050 - Forge's current upper limit
|
|
|
|
+ Preconditions.checkArgument( len <= ( Integer.MAX_VALUE & 0x1FFF9A ), "Cannot receive array longer than 2097050 (got %s bytes)", len );
|
|
|
|
+
|
|
|
|
+ byte[] ret = new byte[ len ];
|
|
|
|
+ buf.readBytes( ret );
|
|
|
|
+ return ret;
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/DefinedPacket.java b/protocol/src/main/java/net/md_5/bungee/protocol/DefinedPacket.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 10e16d79..04a34033 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/DefinedPacket.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/DefinedPacket.java
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -193,6 +193,11 @@ public abstract class DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
read( buf );
|
|
|
|
}
|
|
|
|
|
|
|
|
+ public void read0(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ read( buf, direction, protocolVersion );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
public void write(ByteBuf buf)
|
|
|
|
{
|
|
|
|
throw new UnsupportedOperationException( "Packet must implement write method" );
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -203,6 +208,11 @@ public abstract class DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
write( buf );
|
|
|
|
}
|
|
|
|
|
|
|
|
+ public void write0(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ write( buf, direction, protocolVersion );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
public abstract void handle(AbstractPacketHandler handler) throws Exception;
|
|
|
|
|
|
|
|
@Override
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java b/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 9e9ea49c..75b0f8a9 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftDecoder.java
|
|
|
|
@@ -5,10 +5,11 @@ import io.netty.buffer.ByteBufUtil;
|
|
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
|
|
import io.netty.handler.codec.DecoderException;
|
|
|
|
import io.netty.handler.codec.MessageToMessageDecoder;
|
|
|
|
-import java.util.List;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Setter;
|
|
|
|
|
|
|
|
+import java.util.List;
|
|
|
|
+
|
|
|
|
@AllArgsConstructor
|
|
|
|
public class MinecraftDecoder extends MessageToMessageDecoder<ByteBuf>
|
|
|
|
{
|
|
|
|
@@ -43,7 +44,7 @@ public class MinecraftDecoder extends MessageToMessageDecoder<ByteBuf>
|
|
|
|
if ( packet != null )
|
|
|
|
{
|
|
|
|
packetTypeInfo = packet.getClass();
|
|
|
|
- packet.read( in, prot.getDirection(), protocolVersion );
|
|
|
|
+ packet.read0( in, prot.getDirection(), protocolVersion );
|
|
|
|
|
|
|
|
if ( in.isReadable() )
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftEncoder.java b/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftEncoder.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index d4b03843..9aac7ca9 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftEncoder.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/MinecraftEncoder.java
|
|
|
|
@@ -21,6 +21,6 @@ public class MinecraftEncoder extends MessageToByteEncoder<DefinedPacket>
|
|
|
|
{
|
|
|
|
Protocol.DirectionData prot = ( server ) ? protocol.TO_CLIENT : protocol.TO_SERVER;
|
|
|
|
DefinedPacket.writeVarInt( prot.getId( msg.getClass(), protocolVersion ), out );
|
|
|
|
- msg.write( out, prot.getDirection(), protocolVersion );
|
|
|
|
+ msg.write0( out, prot.getDirection(), protocolVersion );
|
|
|
|
}
|
|
|
|
}
|
2016-07-03 08:56:31 +02:00
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/Protocol.java b/protocol/src/main/java/net/md_5/bungee/protocol/Protocol.java
|
2018-10-23 01:58:52 +02:00
|
|
|
index cc863d9b..bfa24ffa 100644
|
2016-07-03 08:56:31 +02:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/Protocol.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/Protocol.java
|
2018-07-21 18:45:51 +02:00
|
|
|
@@ -378,6 +378,8 @@ public enum Protocol
|
2016-07-03 08:56:31 +02:00
|
|
|
private final TIntObjectMap<List<Integer>> linkedProtocols = new TIntObjectHashMap<>();
|
|
|
|
{
|
|
|
|
linkedProtocols.put( ProtocolConstants.MINECRAFT_1_8, Arrays.asList(
|
|
|
|
+ ProtocolConstants.MINECRAFT_1_7_2,
|
|
|
|
+ ProtocolConstants.MINECRAFT_1_7_6,
|
2017-05-15 09:01:52 +02:00
|
|
|
ProtocolConstants.MINECRAFT_1_9,
|
2018-07-20 04:23:11 +02:00
|
|
|
ProtocolConstants.MINECRAFT_1_12,
|
|
|
|
ProtocolConstants.MINECRAFT_1_13
|
2018-10-23 01:58:52 +02:00
|
|
|
@@ -435,7 +437,11 @@ public enum Protocol
|
2016-07-31 21:04:17 +02:00
|
|
|
}
|
|
|
|
if ( !hasPacket(id, supportsForge) )
|
|
|
|
{
|
2017-01-05 02:04:39 +01:00
|
|
|
- throw new BadPacketException( "Packet with id " + id + " outside of range " );
|
2016-11-15 16:32:02 +01:00
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( version, ProtocolConstants.MINECRAFT_1_7_6 ) ) {
|
|
|
|
+ return null;
|
2017-01-05 02:04:39 +01:00
|
|
|
+ } else {
|
|
|
|
+ throw new BadPacketException( "Packet with id " + id + " outside of range " );
|
2016-11-15 16:32:02 +01:00
|
|
|
+ }
|
2016-07-31 21:04:17 +02:00
|
|
|
}
|
|
|
|
|
2017-05-15 09:01:52 +02:00
|
|
|
Constructor<? extends DefinedPacket> constructor = protocolData.packetConstructors[id];
|
2017-01-05 02:04:39 +01:00
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/ProtocolConstants.java b/protocol/src/main/java/net/md_5/bungee/protocol/ProtocolConstants.java
|
2018-10-23 01:58:52 +02:00
|
|
|
index d9a3c7e5..67f2976e 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/ProtocolConstants.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/ProtocolConstants.java
|
|
|
|
@@ -6,6 +6,8 @@ import java.util.List;
|
|
|
|
public class ProtocolConstants
|
|
|
|
{
|
|
|
|
|
|
|
|
+ public static final int MINECRAFT_1_7_2 = 4;
|
|
|
|
+ public static final int MINECRAFT_1_7_6 = 5;
|
|
|
|
public static final int MINECRAFT_1_8 = 47;
|
|
|
|
public static final int MINECRAFT_1_9 = 107;
|
|
|
|
public static final int MINECRAFT_1_9_1 = 108;
|
2018-10-23 01:58:52 +02:00
|
|
|
@@ -21,6 +23,7 @@ public class ProtocolConstants
|
2018-08-23 23:58:34 +02:00
|
|
|
public static final int MINECRAFT_1_13_1 = 401;
|
2018-10-23 01:58:52 +02:00
|
|
|
public static final int MINECRAFT_1_13_2 = 404;
|
2017-01-05 02:04:39 +01:00
|
|
|
public static final List<String> SUPPORTED_VERSIONS = Arrays.asList(
|
|
|
|
+ "1.7.x",
|
|
|
|
"1.8.x",
|
|
|
|
"1.9.x",
|
|
|
|
"1.10.x",
|
2018-10-23 01:58:52 +02:00
|
|
|
@@ -29,6 +32,8 @@ public class ProtocolConstants
|
2018-07-20 04:23:11 +02:00
|
|
|
"1.13.x"
|
2017-01-05 02:04:39 +01:00
|
|
|
);
|
|
|
|
public static final List<Integer> SUPPORTED_VERSION_IDS = Arrays.asList(
|
|
|
|
+ ProtocolConstants.MINECRAFT_1_7_2,
|
|
|
|
+ ProtocolConstants.MINECRAFT_1_7_6,
|
|
|
|
ProtocolConstants.MINECRAFT_1_8,
|
|
|
|
ProtocolConstants.MINECRAFT_1_9,
|
|
|
|
ProtocolConstants.MINECRAFT_1_9_1,
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java b/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java
|
2018-10-14 12:23:29 +02:00
|
|
|
index 880a3dc7..bf8e3423 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/Varint21FrameDecoder.java
|
|
|
|
@@ -7,10 +7,12 @@ import io.netty.handler.codec.ByteToMessageDecoder;
|
|
|
|
import io.netty.handler.codec.CorruptedFrameException;
|
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
+import java.util.concurrent.atomic.AtomicLong;
|
|
|
|
|
|
|
|
public class Varint21FrameDecoder extends ByteToMessageDecoder
|
|
|
|
{
|
|
|
|
|
|
|
|
+ private AtomicLong lastEmptyPacket = new AtomicLong(0); // Travertine
|
|
|
|
private static boolean DIRECT_WARNING;
|
2018-10-14 12:23:29 +02:00
|
|
|
// Waterfall start
|
|
|
|
private boolean allowEmptyPackets;
|
|
|
|
@@ -40,7 +42,15 @@ public class Varint21FrameDecoder extends ByteToMessageDecoder
|
2017-01-05 02:04:39 +01:00
|
|
|
int length = DefinedPacket.readVarInt( Unpooled.wrappedBuffer( buf ) );
|
2018-10-14 12:23:29 +02:00
|
|
|
if ( length == 0 && !allowEmptyPackets) // Waterfall
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
- throw new CorruptedFrameException( "Empty Packet!" );
|
|
|
|
+ // Travertine start - vanilla 1.7 client sometimes sends empty packets.
|
|
|
|
+ long currentTime = System.currentTimeMillis();
|
|
|
|
+ long lastEmptyPacket = this.lastEmptyPacket.getAndSet(currentTime);
|
|
|
|
+
|
|
|
|
+ if (currentTime - lastEmptyPacket < 50L)
|
|
|
|
+ {
|
|
|
|
+ throw new CorruptedFrameException( "Too many empty packets" );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
}
|
|
|
|
|
|
|
|
if ( in.readableBytes() < length )
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/Chat.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/Chat.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 95ad39b7..1f78125a 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/Chat.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/Chat.java
|
|
|
|
@@ -1,6 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
@@ -13,7 +13,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class Chat extends DefinedPacket
|
|
|
|
+public class Chat extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private String message;
|
|
|
|
@@ -24,6 +24,14 @@ public class Chat extends DefinedPacket
|
|
|
|
this( message, (byte) 0 );
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ message = readString( buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
@@ -34,6 +42,14 @@ public class Chat extends DefinedPacket
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( message, buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/ClientSettings.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/ClientSettings.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 5c79727c..431b2eb8 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/ClientSettings.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/ClientSettings.java
|
|
|
|
@@ -1,5 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
@@ -13,7 +14,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class ClientSettings extends DefinedPacket
|
|
|
|
+public class ClientSettings extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private String locale;
|
|
|
|
@@ -24,6 +25,19 @@ public class ClientSettings extends DefinedPacket
|
|
|
|
private byte skinParts;
|
|
|
|
private int mainHand;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ locale = readString( buf );
|
|
|
|
+ viewDistance = buf.readByte();
|
|
|
|
+ chatFlags = buf.readUnsignedByte();
|
|
|
|
+ chatColours = buf.readBoolean();
|
|
|
|
+ skinParts = buf.readByte();
|
|
|
|
+ difficulty = buf.readByte();
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
@@ -58,6 +72,19 @@ public class ClientSettings extends DefinedPacket
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( locale, buf );
|
|
|
|
+ buf.writeByte( viewDistance );
|
|
|
|
+ buf.writeByte( chatFlags );
|
|
|
|
+ buf.writeBoolean( chatColours );
|
|
|
|
+ buf.writeByte( skinParts );
|
|
|
|
+ buf.writeByte( difficulty );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void handle(AbstractPacketHandler handler) throws Exception
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionRequest.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionRequest.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index a29524ca..8d9f4ccb 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionRequest.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionRequest.java
|
|
|
|
@@ -1,25 +1,35 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
import lombok.EqualsAndHashCode;
|
|
|
|
import lombok.NoArgsConstructor;
|
|
|
|
import net.md_5.bungee.protocol.AbstractPacketHandler;
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
|
|
|
|
@Data
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class EncryptionRequest extends DefinedPacket
|
|
|
|
+public class EncryptionRequest extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private String serverId;
|
|
|
|
private byte[] publicKey;
|
|
|
|
private byte[] verifyToken;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ serverId = readString( buf );
|
|
|
|
+ publicKey = v17readArray( buf );
|
|
|
|
+ verifyToken = v17readArray( buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
@@ -28,6 +38,16 @@ public class EncryptionRequest extends DefinedPacket
|
|
|
|
verifyToken = readArray( buf );
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( serverId, buf );
|
|
|
|
+ v17writeArray( publicKey, buf, false );
|
|
|
|
+ v17writeArray( verifyToken, buf, false );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionResponse.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionResponse.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 06676e42..19a85492 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionResponse.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EncryptionResponse.java
|
|
|
|
@@ -1,6 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
@@ -13,12 +13,21 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class EncryptionResponse extends DefinedPacket
|
|
|
|
+public class EncryptionResponse extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private byte[] sharedSecret;
|
|
|
|
private byte[] verifyToken;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ sharedSecret = v17readArray( buf );
|
|
|
|
+ verifyToken = v17readArray( buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
@@ -26,6 +35,15 @@ public class EncryptionResponse extends DefinedPacket
|
|
|
|
verifyToken = readArray( buf, 128 );
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ v17writeArray( sharedSecret, buf, false );
|
|
|
|
+ v17writeArray( verifyToken, buf, false );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityEffect.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityEffect.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index d11a9ea9..07fc21b6 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityEffect.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityEffect.java
|
|
|
|
@@ -1,18 +1,19 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
import lombok.EqualsAndHashCode;
|
|
|
|
import lombok.NoArgsConstructor;
|
|
|
|
import net.md_5.bungee.protocol.AbstractPacketHandler;
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
|
|
|
|
@Data
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class EntityEffect extends DefinedPacket {
|
|
|
|
+public class EntityEffect extends MultiVersionPacketV17 {
|
|
|
|
|
|
|
|
private int entityId;
|
|
|
|
private int effectId;
|
2017-10-29 18:12:12 +01:00
|
|
|
@@ -20,6 +21,14 @@ public class EntityEffect extends DefinedPacket {
|
|
|
|
private int duration;
|
2017-01-05 02:04:39 +01:00
|
|
|
private boolean hideParticles;
|
|
|
|
|
2017-10-29 18:12:12 +01:00
|
|
|
+ @Override
|
2017-01-05 02:04:39 +01:00
|
|
|
+ protected void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion) {
|
|
|
|
+ this.entityId = buf.readInt();
|
|
|
|
+ this.effectId = buf.readUnsignedByte();
|
|
|
|
+ this.amplifier = buf.readUnsignedByte();
|
|
|
|
+ this.duration = buf.readShort();
|
|
|
|
+ }
|
|
|
|
+
|
2017-10-29 18:12:12 +01:00
|
|
|
@Override
|
2017-01-05 02:04:39 +01:00
|
|
|
public void read(ByteBuf buf) {
|
|
|
|
this.entityId = readVarInt(buf);
|
2017-10-29 18:12:12 +01:00
|
|
|
@@ -29,6 +38,14 @@ public class EntityEffect extends DefinedPacket {
|
|
|
|
this.hideParticles = buf.readBoolean();
|
2017-01-05 02:04:39 +01:00
|
|
|
}
|
|
|
|
|
2017-10-29 18:12:12 +01:00
|
|
|
+ @Override
|
2017-01-05 02:04:39 +01:00
|
|
|
+ protected void v17Write(ByteBuf buf) {
|
|
|
|
+ buf.writeInt(effectId);
|
|
|
|
+ buf.writeByte(effectId);
|
|
|
|
+ buf.writeByte(amplifier);
|
|
|
|
+ buf.writeShort(duration);
|
|
|
|
+ }
|
|
|
|
+
|
2017-10-29 18:12:12 +01:00
|
|
|
@Override
|
2017-01-05 02:04:39 +01:00
|
|
|
public void write(ByteBuf buf) {
|
|
|
|
writeVarInt(this.entityId, buf);
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityRemoveEffect.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityRemoveEffect.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 7ed2dc3a..9f8d56fc 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityRemoveEffect.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/EntityRemoveEffect.java
|
|
|
|
@@ -1,18 +1,18 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
import lombok.EqualsAndHashCode;
|
|
|
|
import lombok.NoArgsConstructor;
|
|
|
|
import net.md_5.bungee.protocol.AbstractPacketHandler;
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
|
|
|
|
@Data
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class EntityRemoveEffect extends DefinedPacket {
|
|
|
|
+public class EntityRemoveEffect extends MultiVersionPacketV17 {
|
|
|
|
|
|
|
|
private int entityId;
|
|
|
|
private int effectId;
|
2017-10-29 18:12:12 +01:00
|
|
|
@@ -23,9 +23,15 @@ public class EntityRemoveEffect extends DefinedPacket {
|
|
|
|
this.effectId = buf.readUnsignedByte();
|
2017-01-05 02:04:39 +01:00
|
|
|
}
|
|
|
|
|
2017-10-29 18:12:12 +01:00
|
|
|
+ @Override
|
2017-01-05 02:04:39 +01:00
|
|
|
+ protected void v17Read(ByteBuf buf) {
|
|
|
|
+ this.entityId = buf.readInt();
|
|
|
|
+ this.effectId = buf.readUnsignedByte();
|
|
|
|
+ }
|
|
|
|
+
|
2017-10-29 18:12:12 +01:00
|
|
|
@Override
|
2017-01-05 02:04:39 +01:00
|
|
|
public void write(ByteBuf buf) {
|
|
|
|
- writeVarInt(this.entityId, buf);
|
|
|
|
+ writeVarInt(entityId, buf);
|
2017-05-15 09:01:52 +02:00
|
|
|
buf.writeByte(effectId);
|
|
|
|
}
|
|
|
|
|
|
|
|
@@ -33,4 +39,10 @@ public class EntityRemoveEffect extends DefinedPacket {
|
|
|
|
public void handle(AbstractPacketHandler handler) throws Exception {
|
|
|
|
handler.handle(this);
|
|
|
|
}
|
2017-01-05 02:04:39 +01:00
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ protected void v17Write(ByteBuf buf) {
|
|
|
|
+ buf.writeInt(entityId);
|
2017-05-15 09:01:52 +02:00
|
|
|
+ buf.writeByte(effectId);
|
|
|
|
+ }
|
|
|
|
}
|
2017-01-05 02:04:39 +01:00
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/KeepAlive.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/KeepAlive.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 9df9ef56..56e6e522 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/KeepAlive.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/KeepAlive.java
|
|
|
|
@@ -1,6 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
@@ -13,17 +13,33 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class KeepAlive extends DefinedPacket
|
|
|
|
+public class KeepAlive extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
2017-10-29 18:12:12 +01:00
|
|
|
private long randomId;
|
2017-01-05 02:04:39 +01:00
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ randomId = buf.readInt();
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
2017-10-29 18:12:12 +01:00
|
|
|
randomId = ( protocolVersion >= ProtocolConstants.MINECRAFT_1_12_2 ) ? buf.readLong() : readVarInt( buf );
|
2017-01-05 02:04:39 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
2017-10-29 18:12:12 +01:00
|
|
|
+ buf.writeInt((int) randomId);
|
2017-01-05 02:04:39 +01:00
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/PlayerListItem.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/PlayerListItem.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 9983ef2e..ae5dad52 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/PlayerListItem.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/PlayerListItem.java
|
|
|
|
@@ -1,5 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.Data;
|
|
|
|
@@ -13,12 +14,24 @@ import java.util.UUID;
|
|
|
|
@Data
|
|
|
|
@NoArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class PlayerListItem extends DefinedPacket
|
|
|
|
+public class PlayerListItem extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private Action action;
|
|
|
|
private Item[] items;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ items = new Item[ 1 ];
|
|
|
|
+ Item item = items[ 0 ] = new Item();
|
|
|
|
+ item.displayName = item.username = readString( buf );
|
|
|
|
+ action = !buf.readBoolean() ? Action.REMOVE_PLAYER : Action.ADD_PLAYER;
|
|
|
|
+ item.ping = buf.readShort();
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
@@ -73,6 +86,17 @@ public class PlayerListItem extends DefinedPacket
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ Item item = items[0]; // Only one at a time
|
|
|
|
+ writeString( item.displayName, buf ); // TODO: Server unique only!
|
|
|
|
+ buf.writeBoolean( action != Action.REMOVE_PLAYER );
|
|
|
|
+ buf.writeShort( item.ping );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/PluginMessage.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/PluginMessage.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 0e06b49d..ac7451dc 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/PluginMessage.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/PluginMessage.java
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -3,8 +3,8 @@ package net.md_5.bungee.protocol.packet;
|
|
|
|
import com.google.common.base.Function;
|
2017-01-05 02:04:39 +01:00
|
|
|
import com.google.common.base.Preconditions;
|
|
|
|
import com.google.common.base.Predicate;
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBufUtil;
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import java.io.ByteArrayInputStream;
|
|
|
|
import java.io.DataInput;
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -21,7 +21,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
2017-01-05 02:04:39 +01:00
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class PluginMessage extends DefinedPacket
|
|
|
|
+public class PluginMessage extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
2018-07-20 04:23:11 +02:00
|
|
|
public static final Function<String, String> MODERNISE = new Function<String, String>()
|
|
|
|
@@ -79,6 +79,15 @@ public class PluginMessage extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
*/
|
|
|
|
private boolean allowExtendedPacket = false;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ tag = readString( buf );
|
|
|
|
+ data = v17readArray( buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -89,6 +98,15 @@ public class PluginMessage extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
buf.readBytes( data );
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( tag, buf );
|
|
|
|
+ v17writeArray( data, buf, allowExtendedPacket );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardObjective.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardObjective.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 6279d9f3..b4a66baf 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardObjective.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardObjective.java
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -1,6 +1,7 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
2018-07-21 19:17:08 +02:00
|
|
|
import net.md_5.bungee.protocol.DefinedPacket;
|
2017-01-05 02:04:39 +01:00
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
2018-07-20 04:23:11 +02:00
|
|
|
import java.util.Locale;
|
2017-01-05 02:04:39 +01:00
|
|
|
import lombok.AllArgsConstructor;
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -14,7 +15,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
2017-01-05 02:04:39 +01:00
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class ScoreboardObjective extends DefinedPacket
|
|
|
|
+public class ScoreboardObjective extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private String name;
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -25,6 +26,16 @@ public class ScoreboardObjective extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
*/
|
|
|
|
private byte action;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ name = readString( buf );
|
|
|
|
+ value = readString( buf );
|
|
|
|
+ action = buf.readByte();
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -43,6 +54,16 @@ public class ScoreboardObjective extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( name, buf );
|
|
|
|
+ writeString( value, buf );
|
|
|
|
+ buf.writeByte( action );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardScore.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardScore.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 6f0de535..b967f89f 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardScore.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/ScoreboardScore.java
|
|
|
|
@@ -1,6 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
|
|
|
@@ -13,7 +13,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class ScoreboardScore extends DefinedPacket
|
|
|
|
+public class ScoreboardScore extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private String itemName;
|
|
|
|
@@ -24,6 +24,20 @@ public class ScoreboardScore extends DefinedPacket
|
|
|
|
private String scoreName;
|
|
|
|
private int value;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ itemName = readString( buf );
|
|
|
|
+ action = buf.readByte();
|
|
|
|
+ if ( action != 1 )
|
|
|
|
+ {
|
|
|
|
+ scoreName = readString( buf );
|
|
|
|
+ value = buf.readInt();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
@@ -36,6 +50,20 @@ public class ScoreboardScore extends DefinedPacket
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( itemName, buf );
|
|
|
|
+ buf.writeByte( action );
|
|
|
|
+ if ( action != 1 )
|
|
|
|
+ {
|
|
|
|
+ writeString( scoreName, buf );
|
|
|
|
+ buf.writeInt( value );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/TabCompleteRequest.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/TabCompleteRequest.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index f9eaa7ce..e174ac0b 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/TabCompleteRequest.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/TabCompleteRequest.java
|
|
|
|
@@ -1,6 +1,6 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
|
|
|
-import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.Data;
|
2018-07-20 04:23:11 +02:00
|
|
|
import lombok.EqualsAndHashCode;
|
|
|
|
@@ -11,7 +11,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
@Data
|
2017-01-05 02:04:39 +01:00
|
|
|
@NoArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class TabCompleteRequest extends DefinedPacket
|
|
|
|
+public class TabCompleteRequest extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
2018-07-20 04:23:11 +02:00
|
|
|
private int transactionId;
|
|
|
|
@@ -33,6 +33,13 @@ public class TabCompleteRequest extends DefinedPacket
|
|
|
|
this.hasPositon = hasPosition;
|
|
|
|
this.position = position;
|
|
|
|
}
|
2017-01-05 02:04:39 +01:00
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ cursor = readString( buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
2018-07-20 04:23:11 +02:00
|
|
|
|
2017-01-05 02:04:39 +01:00
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -57,6 +64,14 @@ public class TabCompleteRequest extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( cursor, buf );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/protocol/src/main/java/net/md_5/bungee/protocol/packet/Team.java b/protocol/src/main/java/net/md_5/bungee/protocol/packet/Team.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index f93508d9..13af5112 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/protocol/src/main/java/net/md_5/bungee/protocol/packet/Team.java
|
|
|
|
+++ b/protocol/src/main/java/net/md_5/bungee/protocol/packet/Team.java
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -1,6 +1,7 @@
|
|
|
|
package net.md_5.bungee.protocol.packet;
|
|
|
|
|
2018-07-21 19:17:08 +02:00
|
|
|
import net.md_5.bungee.protocol.DefinedPacket;
|
2017-01-05 02:04:39 +01:00
|
|
|
+import io.github.waterfallmc.travertine.protocol.MultiVersionPacketV17;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
|
import lombok.Data;
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -13,7 +14,7 @@ import net.md_5.bungee.protocol.ProtocolConstants;
|
2017-01-05 02:04:39 +01:00
|
|
|
@NoArgsConstructor
|
|
|
|
@AllArgsConstructor
|
|
|
|
@EqualsAndHashCode(callSuper = false)
|
|
|
|
-public class Team extends DefinedPacket
|
|
|
|
+public class Team extends MultiVersionPacketV17
|
|
|
|
{
|
|
|
|
|
|
|
|
private String name;
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -39,6 +40,31 @@ public class Team extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
this.mode = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ name = readString( buf );
|
|
|
|
+ mode = buf.readByte();
|
|
|
|
+ if ( mode == 0 || mode == 2 )
|
|
|
|
+ {
|
|
|
|
+ displayName = readString( buf );
|
|
|
|
+ prefix = readString( buf );
|
|
|
|
+ suffix = readString( buf );
|
|
|
|
+ friendlyFire = buf.readByte();
|
|
|
|
+ }
|
|
|
|
+ if ( mode == 0 || mode == 3 || mode == 4 )
|
|
|
|
+ {
|
|
|
|
+ int len = buf.readShort();
|
|
|
|
+ players = new String[ len ];
|
|
|
|
+ for ( int i = 0; i < len; i++ )
|
|
|
|
+ {
|
|
|
|
+ players[i] = readString( buf );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void read(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
2018-07-25 20:14:35 +02:00
|
|
|
@@ -76,6 +102,30 @@ public class Team extends DefinedPacket
|
2017-01-05 02:04:39 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Override
|
|
|
|
+ public void v17Write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
+ {
|
|
|
|
+ writeString( name, buf );
|
|
|
|
+ buf.writeByte( mode );
|
|
|
|
+ if ( mode == 0 || mode == 2 )
|
|
|
|
+ {
|
|
|
|
+ writeString( displayName, buf );
|
|
|
|
+ writeString( prefix, buf );
|
|
|
|
+ writeString( suffix, buf );
|
|
|
|
+ buf.writeByte( friendlyFire );
|
|
|
|
+ }
|
|
|
|
+ if ( mode == 0 || mode == 3 || mode == 4 )
|
|
|
|
+ {
|
|
|
|
+ buf.writeShort( players.length );
|
|
|
|
+ for ( String player : players )
|
|
|
|
+ {
|
|
|
|
+ writeString( player, buf );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public void write(ByteBuf buf, ProtocolConstants.Direction direction, int protocolVersion)
|
|
|
|
{
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/BungeeCord.java b/proxy/src/main/java/net/md_5/bungee/BungeeCord.java
|
2018-10-14 12:23:29 +02:00
|
|
|
index e9368f0e..46848491 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/BungeeCord.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/BungeeCord.java
|
2018-03-06 22:12:24 +01:00
|
|
|
@@ -163,6 +163,14 @@ public class BungeeCord extends ProxyServer
|
|
|
|
.registerTypeAdapter( SelectorComponent.class, new SelectorComponentSerializer() )
|
2017-01-05 02:04:39 +01:00
|
|
|
.registerTypeAdapter( ServerPing.PlayerInfo.class, new PlayerInfoSerializer() )
|
|
|
|
.registerTypeAdapter( Favicon.class, Favicon.getFaviconTypeAdapter() ).create();
|
|
|
|
+ // Travertine start
|
|
|
|
+ public final Gson gsonLegacy = new GsonBuilder()
|
|
|
|
+ .registerTypeAdapter( BaseComponent.class, new ComponentSerializer() )
|
|
|
|
+ .registerTypeAdapter( TextComponent.class, new TextComponentSerializer() )
|
|
|
|
+ .registerTypeAdapter( TranslatableComponent.class, new TranslatableComponentSerializer() )
|
|
|
|
+ .registerTypeAdapter( ServerPing.PlayerInfo.class, new PlayerInfoSerializer( ProtocolConstants.MINECRAFT_1_7_2 ) )
|
|
|
|
+ .registerTypeAdapter( Favicon.class, Favicon.getFaviconTypeAdapter() ).create();
|
|
|
|
+ // Travertine end
|
|
|
|
@Getter
|
|
|
|
private ConnectionThrottle connectionThrottle;
|
|
|
|
private final ModuleManager moduleManager = new ModuleManager();
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/BungeeTitle.java b/proxy/src/main/java/net/md_5/bungee/BungeeTitle.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 494213db..1d89acf5 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/BungeeTitle.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/BungeeTitle.java
|
|
|
|
@@ -5,6 +5,7 @@ import net.md_5.bungee.api.chat.BaseComponent;
|
|
|
|
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
|
|
|
import net.md_5.bungee.chat.ComponentSerializer;
|
|
|
|
import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
import net.md_5.bungee.protocol.packet.Title.Action;
|
|
|
|
|
|
|
|
public class BungeeTitle implements Title
|
|
|
|
@@ -151,6 +152,7 @@ public class BungeeTitle implements Title
|
|
|
|
@Override
|
|
|
|
public Title send(ProxiedPlayer player)
|
|
|
|
{
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( player.getPendingConnection().getVersion(), ProtocolConstants.MINECRAFT_1_7_6 ) ) return this;
|
|
|
|
sendPacket( player, clear );
|
|
|
|
sendPacket( player, reset );
|
|
|
|
sendPacket( player, times );
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/PlayerInfoSerializer.java b/proxy/src/main/java/net/md_5/bungee/PlayerInfoSerializer.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 491cf1a1..299a216c 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/PlayerInfoSerializer.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/PlayerInfoSerializer.java
|
|
|
|
@@ -10,17 +10,32 @@ import com.google.gson.JsonSerializer;
|
|
|
|
import java.lang.reflect.Type;
|
|
|
|
import java.util.UUID;
|
|
|
|
import net.md_5.bungee.api.ServerPing;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
|
|
|
|
public class PlayerInfoSerializer implements JsonSerializer<ServerPing.PlayerInfo>, JsonDeserializer<ServerPing.PlayerInfo>
|
|
|
|
{
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ private final int protocol;
|
|
|
|
+
|
|
|
|
+ public PlayerInfoSerializer()
|
|
|
|
+ {
|
|
|
|
+ this.protocol = ProtocolConstants.MINECRAFT_1_7_6;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public PlayerInfoSerializer(int protocol)
|
|
|
|
+ {
|
|
|
|
+ this.protocol = protocol;
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
@Override
|
|
|
|
public ServerPing.PlayerInfo deserialize(JsonElement json, Type typeOfT, JsonDeserializationContext context) throws JsonParseException
|
|
|
|
{
|
|
|
|
JsonObject js = json.getAsJsonObject();
|
|
|
|
ServerPing.PlayerInfo info = new ServerPing.PlayerInfo( js.get( "name" ).getAsString(), (UUID) null );
|
|
|
|
String id = js.get( "id" ).getAsString();
|
|
|
|
- if ( !id.contains( "-" ) )
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( protocol, ProtocolConstants.MINECRAFT_1_7_2 ) || !id.contains( "-" ) ) // Travertine
|
|
|
|
{
|
|
|
|
info.setId( id );
|
|
|
|
} else
|
|
|
|
@@ -35,7 +50,15 @@ public class PlayerInfoSerializer implements JsonSerializer<ServerPing.PlayerInf
|
|
|
|
{
|
|
|
|
JsonObject out = new JsonObject();
|
|
|
|
out.addProperty( "name", src.getName() );
|
|
|
|
- out.addProperty( "id", src.getUniqueId().toString() );
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( protocol, ProtocolConstants.MINECRAFT_1_7_2 ) )
|
|
|
|
+ {
|
|
|
|
+ out.addProperty( "id", src.getId() );
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ out.addProperty( "id", src.getUniqueId().toString() );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
return out;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/ServerConnector.java b/proxy/src/main/java/net/md_5/bungee/ServerConnector.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 0937c39d..28d63f52 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/ServerConnector.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/ServerConnector.java
|
|
|
|
@@ -3,6 +3,8 @@ package net.md_5.bungee;
|
|
|
|
import com.google.common.base.Preconditions;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
|
import io.netty.buffer.ByteBufAllocator;
|
|
|
|
+
|
|
|
|
+import java.nio.charset.StandardCharsets;
|
|
|
|
import java.util.Arrays;
|
|
|
|
import java.util.Queue;
|
|
|
|
import java.util.Set;
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -245,10 +247,20 @@ public class ServerConnector extends PacketHandler
|
2017-01-05 02:04:39 +01:00
|
|
|
|
|
|
|
user.unsafe().sendPacket( modLogin );
|
|
|
|
|
|
|
|
- ByteBuf brand = ByteBufAllocator.DEFAULT.heapBuffer();
|
|
|
|
- DefinedPacket.writeString( bungee.getName() + " (" + bungee.getVersion() + ")", brand );
|
2018-07-20 04:23:11 +02:00
|
|
|
- user.unsafe().sendPacket( new PluginMessage( user.getPendingConnection().getVersion() >= ProtocolConstants.MINECRAFT_1_13 ? "minecraft:brand" : "MC|Brand", brand, handshakeHandler.isServerForge() ) );
|
2017-01-05 02:04:39 +01:00
|
|
|
- brand.release();
|
|
|
|
+ // Travertine start
|
|
|
|
+ String brandString = bungee.getName() + " (" + bungee.getVersion() + ")";
|
|
|
|
+
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( user.getPendingConnection().getVersion(), ProtocolConstants.MINECRAFT_1_7_6 ) )
|
|
|
|
+ {
|
|
|
|
+ user.unsafe().sendPacket( new PluginMessage( "MC|Brand", brandString.getBytes( StandardCharsets.UTF_8 ), handshakeHandler.isServerForge() ) );
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ ByteBuf brand = ByteBufAllocator.DEFAULT.heapBuffer();
|
|
|
|
+ DefinedPacket.writeString(brandString, brand);
|
2018-07-20 04:23:11 +02:00
|
|
|
+ user.unsafe().sendPacket( new PluginMessage( user.getPendingConnection().getVersion() >= ProtocolConstants.MINECRAFT_1_13 ? "minecraft:brand" : "MC|Brand", brand, handshakeHandler.isServerForge() ) );
|
2017-01-05 02:04:39 +01:00
|
|
|
+ brand.release();
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
|
|
|
|
user.setDimension( login.getDimension() );
|
|
|
|
} else
|
2018-07-24 02:48:55 +02:00
|
|
|
@@ -259,7 +271,7 @@ public class ServerConnector extends PacketHandler
|
|
|
|
Scoreboard serverScoreboard = user.getServerSentScoreboard();
|
|
|
|
for ( Objective objective : serverScoreboard.getObjectives() )
|
|
|
|
{
|
|
|
|
- user.unsafe().sendPacket( new ScoreboardObjective( objective.getName(), objective.getValue(), ScoreboardObjective.HealthDisplay.fromString( objective.getType() ), (byte) 1 ) );
|
|
|
|
+ user.unsafe().sendPacket( new ScoreboardObjective( objective.getName(), objective.getValue(), objective.getType() == null ? null : ScoreboardObjective.HealthDisplay.fromString(objective.getType()), (byte) 1 ) ); // Travertine - 1.7
|
|
|
|
}
|
|
|
|
for ( Score score : serverScoreboard.getScores() )
|
|
|
|
{
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -392,14 +404,23 @@ public class ServerConnector extends PacketHandler
|
2018-06-09 12:52:32 +02:00
|
|
|
{
|
|
|
|
this.handshakeHandler.handle( pluginMessage );
|
2017-01-05 02:04:39 +01:00
|
|
|
|
2018-06-09 12:52:32 +02:00
|
|
|
+ // Travertine start
|
|
|
|
+ if ( user.getForgeClientHandler().checkUserOutdated() )
|
|
|
|
+ {
|
|
|
|
+ ch.close();
|
|
|
|
+ user.getPendingConnects().remove(target);
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
2017-01-05 02:04:39 +01:00
|
|
|
+
|
2018-06-09 12:52:32 +02:00
|
|
|
// We send the message as part of the handler, so don't send it here.
|
|
|
|
throw CancelSendSignal.INSTANCE;
|
|
|
|
}
|
|
|
|
+ }else
|
2018-06-08 12:46:31 +02:00
|
|
|
+ {
|
|
|
|
+ // We have to forward these to the user, especially with Forge as stuff might break
|
|
|
|
+ // This includes any REGISTER messages we intercepted earlier.
|
|
|
|
+ user.unsafe().sendPacket( pluginMessage );
|
2018-06-09 12:52:32 +02:00
|
|
|
}
|
|
|
|
-
|
|
|
|
- // We have to forward these to the user, especially with Forge as stuff might break
|
|
|
|
- // This includes any REGISTER messages we intercepted earlier.
|
|
|
|
- user.unsafe().sendPacket( pluginMessage );
|
2018-06-08 12:46:31 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
2017-01-05 02:04:39 +01:00
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/UserConnection.java b/proxy/src/main/java/net/md_5/bungee/UserConnection.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 032ffcbe..30475b35 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/UserConnection.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/UserConnection.java
|
2018-07-30 14:20:51 +02:00
|
|
|
@@ -196,6 +196,7 @@ public final class UserConnection implements ProxiedPlayer
|
2017-01-05 02:04:39 +01:00
|
|
|
public void setDisplayName(String name)
|
|
|
|
{
|
|
|
|
Preconditions.checkNotNull( name, "displayName" );
|
|
|
|
+ Preconditions.checkArgument( name.length() <= 16, "Display name cannot be longer than 16 characters" ); // Travertine
|
|
|
|
displayName = name;
|
|
|
|
}
|
|
|
|
|
2018-07-30 14:20:51 +02:00
|
|
|
@@ -478,7 +479,7 @@ public final class UserConnection implements ProxiedPlayer
|
2018-03-06 22:12:24 +01:00
|
|
|
message = ChatComponentTransformer.getInstance().transform( this, message );
|
|
|
|
|
2017-06-13 05:14:59 +02:00
|
|
|
// Action bar doesn't display the new JSON formattings, legacy works - send it using this for now
|
|
|
|
- if ( position == ChatMessageType.ACTION_BAR )
|
|
|
|
+ if ( position == ChatMessageType.ACTION_BAR && getPendingConnection().getVersion() >= ProtocolConstants.MINECRAFT_1_8 ) // Travertine
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
sendMessage( position, ComponentSerializer.toString( new TextComponent( BaseComponent.toLegacyText( message ) ) ) );
|
|
|
|
} else
|
2018-07-30 14:20:51 +02:00
|
|
|
@@ -493,7 +494,7 @@ public final class UserConnection implements ProxiedPlayer
|
2018-03-06 22:12:24 +01:00
|
|
|
message = ChatComponentTransformer.getInstance().transform( this, message )[0];
|
|
|
|
|
2017-06-13 05:14:59 +02:00
|
|
|
// Action bar doesn't display the new JSON formattings, legacy works - send it using this for now
|
|
|
|
- if ( position == ChatMessageType.ACTION_BAR )
|
|
|
|
+ if ( position == ChatMessageType.ACTION_BAR && getPendingConnection().getVersion() >= ProtocolConstants.MINECRAFT_1_8 ) // Travertine
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
sendMessage( position, ComponentSerializer.toString( new TextComponent( BaseComponent.toLegacyText( message ) ) ) );
|
|
|
|
} else
|
2018-07-30 14:20:51 +02:00
|
|
|
@@ -672,6 +673,7 @@ public final class UserConnection implements ProxiedPlayer
|
2017-01-05 02:04:39 +01:00
|
|
|
@Override
|
|
|
|
public void setTabHeader(BaseComponent header, BaseComponent footer)
|
|
|
|
{
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( pendingConnection.getVersion(), ProtocolConstants.MINECRAFT_1_7_6 ) ) return; // Travertine
|
2018-03-06 22:12:24 +01:00
|
|
|
header = ChatComponentTransformer.getInstance().transform( this, header )[0];
|
|
|
|
footer = ChatComponentTransformer.getInstance().transform( this, footer )[0];
|
|
|
|
|
2018-07-30 14:20:51 +02:00
|
|
|
@@ -684,6 +686,7 @@ public final class UserConnection implements ProxiedPlayer
|
2017-01-05 02:04:39 +01:00
|
|
|
@Override
|
|
|
|
public void setTabHeader(BaseComponent[] header, BaseComponent[] footer)
|
|
|
|
{
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( pendingConnection.getVersion(), ProtocolConstants.MINECRAFT_1_7_6 ) ) return; // Travertine
|
2018-03-06 22:12:24 +01:00
|
|
|
header = ChatComponentTransformer.getInstance().transform( this, header );
|
|
|
|
footer = ChatComponentTransformer.getInstance().transform( this, footer );
|
|
|
|
|
2018-07-30 14:20:51 +02:00
|
|
|
@@ -713,6 +716,7 @@ public final class UserConnection implements ProxiedPlayer
|
2017-01-05 02:04:39 +01:00
|
|
|
|
|
|
|
public void setCompressionThreshold(int compressionThreshold)
|
|
|
|
{
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( pendingConnection.getVersion(), ProtocolConstants.MINECRAFT_1_7_6 ) ) return; // Travertine
|
2017-01-17 16:10:10 +01:00
|
|
|
if ( !ch.isClosing() && this.compressionThreshold == -1 && compressionThreshold >= 0 )
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
this.compressionThreshold = compressionThreshold;
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 76dc13aa..242efd91 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/connection/DownstreamBridge.java
|
2018-07-20 15:16:11 +02:00
|
|
|
@@ -144,7 +144,7 @@ public class DownstreamBridge extends PacketHandler
|
2018-07-20 07:17:40 +02:00
|
|
|
switch ( objective.getAction() )
|
|
|
|
{
|
|
|
|
case 0:
|
|
|
|
- serverScoreboard.addObjective( new Objective( objective.getName(), objective.getValue(), objective.getType().toString() ) );
|
|
|
|
+ serverScoreboard.addObjective( new Objective( objective.getName(), objective.getValue(), objective.getType() != null ? objective.getType().toString() : null) ); // Travertine - 1.7 protocol support
|
2018-07-20 15:16:11 +02:00
|
|
|
break;
|
2018-07-20 07:17:40 +02:00
|
|
|
case 1:
|
|
|
|
serverScoreboard.removeObjective( objective.getName() );
|
2018-07-20 15:16:11 +02:00
|
|
|
@@ -154,7 +154,7 @@ public class DownstreamBridge extends PacketHandler
|
2018-07-20 07:17:40 +02:00
|
|
|
if ( oldObjective != null )
|
|
|
|
{
|
|
|
|
oldObjective.setValue( objective.getValue() );
|
|
|
|
- oldObjective.setType( objective.getType().toString() );
|
|
|
|
+ oldObjective.setType( objective.getType() != null ? objective.getType().toString() : null ); // Travertine - 1.7 protocol support
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
default:
|
2018-07-20 15:16:11 +02:00
|
|
|
@@ -251,16 +251,28 @@ public class DownstreamBridge extends PacketHandler
|
2017-01-05 02:04:39 +01:00
|
|
|
|
2018-07-20 04:23:11 +02:00
|
|
|
if ( pluginMessage.getTag().equals( con.getPendingConnection().getVersion() >= ProtocolConstants.MINECRAFT_1_13 ? "minecraft:brand" : "MC|Brand" ) )
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
- ByteBuf brand = Unpooled.wrappedBuffer( pluginMessage.getData() );
|
|
|
|
- String serverBrand = DefinedPacket.readString( brand );
|
|
|
|
- brand.release();
|
|
|
|
-
|
|
|
|
- Preconditions.checkState( !serverBrand.contains( bungee.getName() ), "Cannot connect proxy to itself!" );
|
|
|
|
-
|
|
|
|
- brand = ByteBufAllocator.DEFAULT.heapBuffer();
|
|
|
|
- DefinedPacket.writeString( bungee.getName() + " (" + bungee.getVersion() + ")" + " <- " + serverBrand, brand );
|
|
|
|
- pluginMessage.setData( brand );
|
|
|
|
- brand.release();
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( ProtocolConstants.isAfterOrEq( con.getPendingConnection().getVersion(), ProtocolConstants.MINECRAFT_1_8 ) )
|
|
|
|
+ {
|
|
|
|
+ try
|
|
|
|
+ {
|
|
|
|
+ ByteBuf brand = Unpooled.wrappedBuffer(pluginMessage.getData());
|
|
|
|
+ String serverBrand = DefinedPacket.readString(brand);
|
|
|
|
+ brand.release();
|
|
|
|
+ brand = ByteBufAllocator.DEFAULT.heapBuffer();
|
|
|
|
+ DefinedPacket.writeString(bungee.getName() + " (" + bungee.getVersion() + ")" + " <- " + serverBrand, brand);
|
|
|
|
+ pluginMessage.setData(brand);
|
|
|
|
+ brand.release();
|
|
|
|
+ } catch (Exception ProtocolHacksSuck)
|
|
|
|
+ {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ String serverBrand = new String( pluginMessage.getData(), "UTF-8" );
|
|
|
|
+ pluginMessage.setData( ( bungee.getName() + " (" + bungee.getVersion() + ")" + " <- " + serverBrand ).getBytes( "UTF-8" ) );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
// changes in the packet are ignored so we need to send it manually
|
|
|
|
con.unsafe().sendPacket( pluginMessage );
|
|
|
|
throw CancelSendSignal.INSTANCE;
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java
|
2018-10-14 12:23:29 +02:00
|
|
|
index 8f63e997..e0079030 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/connection/InitialHandler.java
|
2017-05-15 09:01:52 +02:00
|
|
|
@@ -13,6 +13,13 @@ import java.util.UUID;
|
2017-01-17 16:10:10 +01:00
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
import java.util.logging.Level;
|
|
|
|
import javax.crypto.SecretKey;
|
|
|
|
+
|
|
|
|
+import com.google.common.base.Charsets;
|
|
|
|
+import com.google.common.base.Preconditions;
|
|
|
|
+import com.google.gson.Gson;
|
|
|
|
+
|
2017-01-05 02:04:39 +01:00
|
|
|
+import com.google.gson.JsonElement;
|
|
|
|
+import com.google.gson.JsonObject;
|
2017-01-17 16:10:10 +01:00
|
|
|
import lombok.Getter;
|
|
|
|
import lombok.RequiredArgsConstructor;
|
2017-01-05 02:04:39 +01:00
|
|
|
import net.md_5.bungee.BungeeCord;
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -234,8 +241,24 @@ public class InitialHandler extends PacketHandler implements PendingConnection
|
2017-01-05 02:04:39 +01:00
|
|
|
@Override
|
|
|
|
public void done(ProxyPingEvent pingResult, Throwable error)
|
|
|
|
{
|
|
|
|
- Gson gson = BungeeCord.getInstance().gson;
|
|
|
|
- unsafe.sendPacket( new StatusResponse( gson.toJson( pingResult.getResponse() ) ) );
|
|
|
|
+ Gson gson = handshake.getProtocolVersion() == ProtocolConstants.MINECRAFT_1_7_2 ? BungeeCord.getInstance().gsonLegacy : BungeeCord.getInstance().gson; // Travertine
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( handshake.getProtocolVersion() , ProtocolConstants.MINECRAFT_1_8 ) )
|
|
|
|
+ {
|
|
|
|
+ // Minecraft < 1.9 doesn't send string server descriptions as chat components. Older 1.7
|
|
|
|
+ // clients even crash when encountering a chat component instead of a string. To be on the
|
|
|
|
+ // safe side, always send legacy descriptions for < 1.9 clients.
|
|
|
|
+ JsonElement element = gson.toJsonTree(pingResult.getResponse());
|
|
|
|
+ Preconditions.checkArgument(element.isJsonObject(), "Response is not a JSON object");
|
|
|
|
+ JsonObject object = element.getAsJsonObject();
|
|
|
|
+ object.addProperty("description", pingResult.getResponse().getDescription());
|
|
|
|
+
|
|
|
|
+ unsafe.sendPacket(new StatusResponse(gson.toJson(element)));
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ unsafe.sendPacket( new StatusResponse( gson.toJson( pingResult.getResponse() ) ) );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
2018-09-04 04:15:37 +02:00
|
|
|
@@ -522,7 +545,15 @@ public class InitialHandler extends PacketHandler implements PendingConnection
|
2017-01-05 02:04:39 +01:00
|
|
|
userCon.setCompressionThreshold( BungeeCord.getInstance().config.getCompressionThreshold() );
|
|
|
|
userCon.init();
|
|
|
|
|
|
|
|
- unsafe.sendPacket( new LoginSuccess( getUniqueId().toString(), getName() ) ); // With dashes in between
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( ProtocolConstants.isAfterOrEq( getVersion() , ProtocolConstants.MINECRAFT_1_7_6 ) )
|
|
|
|
+ {
|
|
|
|
+ unsafe.sendPacket( new LoginSuccess( getUniqueId().toString(), getName() ) ); // With dashes in between
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ unsafe.sendPacket( new LoginSuccess( getUUID(), getName() ) ); // Without dashes, for older clients.
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
ch.setProtocol( Protocol.GAME );
|
|
|
|
|
|
|
|
ch.getHandle().pipeline().get( HandlerBoss.class ).setHandler( new UpstreamBridge( bungee, userCon ) );
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/connection/PingHandler.java b/proxy/src/main/java/net/md_5/bungee/connection/PingHandler.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 76f496ce..eab2523d 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/connection/PingHandler.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/connection/PingHandler.java
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -15,6 +15,7 @@ import net.md_5.bungee.protocol.MinecraftDecoder;
|
2017-01-05 02:04:39 +01:00
|
|
|
import net.md_5.bungee.protocol.MinecraftEncoder;
|
2018-07-20 04:23:11 +02:00
|
|
|
import net.md_5.bungee.protocol.PacketWrapper;
|
2017-01-05 02:04:39 +01:00
|
|
|
import net.md_5.bungee.protocol.Protocol;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
import net.md_5.bungee.protocol.packet.Handshake;
|
|
|
|
import net.md_5.bungee.protocol.packet.StatusRequest;
|
|
|
|
import net.md_5.bungee.protocol.packet.StatusResponse;
|
2018-07-20 04:23:11 +02:00
|
|
|
@@ -63,7 +64,7 @@ public class PingHandler extends PacketHandler
|
2017-01-05 02:04:39 +01:00
|
|
|
@SuppressFBWarnings("UWF_FIELD_NOT_INITIALIZED_IN_CONSTRUCTOR")
|
|
|
|
public void handle(StatusResponse statusResponse) throws Exception
|
|
|
|
{
|
|
|
|
- Gson gson = BungeeCord.getInstance().gson;
|
|
|
|
+ Gson gson = protocol == ProtocolConstants.MINECRAFT_1_7_2 ? BungeeCord.getInstance().gsonLegacy : BungeeCord.getInstance().gson; // Travertine
|
|
|
|
callback.done( gson.fromJson( statusResponse.getResponse(), ServerPing.class ), null );
|
|
|
|
channel.close();
|
|
|
|
}
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java b/proxy/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java
|
2018-10-14 12:23:29 +02:00
|
|
|
index e1be7cce..7a20078b 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/connection/UpstreamBridge.java
|
2018-04-02 11:25:58 +02:00
|
|
|
@@ -79,7 +79,12 @@ public class UpstreamBridge extends PacketHandler
|
2017-01-05 02:04:39 +01:00
|
|
|
} );
|
|
|
|
for ( ProxiedPlayer player : con.getServer().getInfo().getPlayers() )
|
|
|
|
{
|
|
|
|
- player.unsafe().sendPacket( packet );
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( ProtocolConstants.isAfterOrEq( player.getPendingConnection().getVersion(), ProtocolConstants.MINECRAFT_1_8 ) )
|
|
|
|
+ {
|
|
|
|
+ player.unsafe().sendPacket( packet );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
}
|
|
|
|
con.getServer().disconnect( "Quitting" );
|
2017-01-17 16:10:10 +01:00
|
|
|
}
|
2017-01-05 02:04:39 +01:00
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java
|
2018-10-23 01:58:52 +02:00
|
|
|
index 7c19c6fb..2bb6fbcc 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java
|
2017-01-05 02:07:36 +01:00
|
|
|
@@ -29,6 +29,10 @@ public abstract class EntityMap
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
switch ( version )
|
|
|
|
{
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_7_2:
|
|
|
|
+ return EntityMap_1_7_2.INSTANCE;
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_7_6:
|
|
|
|
+ return EntityMap_1_7_6.INSTANCE;
|
|
|
|
case ProtocolConstants.MINECRAFT_1_8:
|
|
|
|
return EntityMap_1_8.INSTANCE;
|
|
|
|
case ProtocolConstants.MINECRAFT_1_9:
|
2017-01-05 02:07:36 +01:00
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java.orig b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java.orig
|
|
|
|
new file mode 100644
|
2018-09-04 04:15:37 +02:00
|
|
|
index 00000000..d98a8056
|
2017-01-05 02:07:36 +01:00
|
|
|
--- /dev/null
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap.java.orig
|
|
|
|
@@ -0,0 +1,215 @@
|
|
|
|
+package net.md_5.bungee.entitymap;
|
|
|
|
+
|
|
|
|
+import com.flowpowered.nbt.stream.NBTInputStream;
|
|
|
|
+import com.google.common.base.Throwables;
|
|
|
|
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
|
|
|
|
+import io.netty.buffer.ByteBuf;
|
|
|
|
+import io.netty.buffer.ByteBufInputStream;
|
|
|
|
+import java.io.IOException;
|
|
|
|
+import lombok.AccessLevel;
|
|
|
|
+import lombok.NoArgsConstructor;
|
|
|
|
+import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
+
|
|
|
|
+/**
|
|
|
|
+ * Class to rewrite integers within packets.
|
|
|
|
+ */
|
|
|
|
+@NoArgsConstructor(access = AccessLevel.PACKAGE)
|
|
|
|
+public abstract class EntityMap
|
|
|
|
+{
|
|
|
|
+
|
|
|
|
+ private final boolean[] clientboundInts = new boolean[ 256 ];
|
|
|
|
+ private final boolean[] clientboundVarInts = new boolean[ 256 ];
|
|
|
|
+
|
|
|
|
+ private final boolean[] serverboundInts = new boolean[ 256 ];
|
|
|
|
+ private final boolean[] serverboundVarInts = new boolean[ 256 ];
|
|
|
|
+
|
|
|
|
+ // Returns the correct entity map for the protocol version
|
|
|
|
+ public static EntityMap getEntityMap(int version)
|
|
|
|
+ {
|
|
|
|
+ switch ( version )
|
|
|
|
+ {
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_8:
|
|
|
|
+ return EntityMap_1_8.INSTANCE;
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_9:
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_9_1:
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_9_2:
|
|
|
|
+ return EntityMap_1_9.INSTANCE;
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_9_4:
|
|
|
|
+ return EntityMap_1_9_4.INSTANCE;
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_10:
|
|
|
|
+ return EntityMap_1_10.INSTANCE;
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_11:
|
|
|
|
+ case ProtocolConstants.MINECRAFT_1_11_1:
|
|
|
|
+ return EntityMap_1_11.INSTANCE;
|
|
|
|
+ }
|
|
|
|
+ throw new RuntimeException( "Version " + version + " has no entity map" );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ protected void addRewrite(int id, ProtocolConstants.Direction direction, boolean varint)
|
|
|
|
+ {
|
|
|
|
+ if ( direction == ProtocolConstants.Direction.TO_CLIENT )
|
|
|
|
+ {
|
|
|
|
+ if ( varint )
|
|
|
|
+ {
|
|
|
|
+ clientboundVarInts[id] = true;
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ clientboundInts[id] = true;
|
|
|
|
+ }
|
|
|
|
+ } else if ( varint )
|
|
|
|
+ {
|
|
|
|
+ serverboundVarInts[id] = true;
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ serverboundInts[id] = true;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void rewriteServerbound(ByteBuf packet, int oldId, int newId)
|
|
|
|
+ {
|
|
|
|
+ rewrite( packet, oldId, newId, serverboundInts, serverboundVarInts );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void rewriteClientbound(ByteBuf packet, int oldId, int newId)
|
|
|
|
+ {
|
|
|
|
+ rewrite( packet, oldId, newId, clientboundInts, clientboundVarInts );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ protected static void rewriteInt(ByteBuf packet, int oldId, int newId, int offset)
|
|
|
|
+ {
|
|
|
|
+ int readId = packet.getInt( offset );
|
|
|
|
+ if ( readId == oldId )
|
|
|
|
+ {
|
|
|
|
+ packet.setInt( offset, newId );
|
|
|
|
+ } else if ( readId == newId )
|
|
|
|
+ {
|
|
|
|
+ packet.setInt( offset, oldId );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @SuppressFBWarnings("DLS_DEAD_LOCAL_STORE")
|
|
|
|
+ protected static void rewriteVarInt(ByteBuf packet, int oldId, int newId, int offset)
|
|
|
|
+ {
|
|
|
|
+ // Need to rewrite the packet because VarInts are variable length
|
|
|
|
+ int readId = DefinedPacket.readVarInt( packet );
|
|
|
|
+ int readIdLength = packet.readerIndex() - offset;
|
|
|
|
+ if ( readId == oldId || readId == newId )
|
|
|
|
+ {
|
|
|
|
+ ByteBuf data = packet.copy();
|
|
|
|
+ packet.readerIndex( offset );
|
|
|
|
+ packet.writerIndex( offset );
|
|
|
|
+ DefinedPacket.writeVarInt( readId == oldId ? newId : oldId, packet );
|
|
|
|
+ packet.writeBytes( data );
|
|
|
|
+ data.release();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ protected static void rewriteMetaVarInt(ByteBuf packet, int oldId, int newId, int metaIndex)
|
|
|
|
+ {
|
|
|
|
+ int readerIndex = packet.readerIndex();
|
|
|
|
+
|
|
|
|
+ short index;
|
|
|
|
+ while ( ( index = packet.readUnsignedByte() ) != 0xFF )
|
|
|
|
+ {
|
|
|
|
+ int type = DefinedPacket.readVarInt( packet );
|
|
|
|
+
|
|
|
|
+ switch ( type )
|
|
|
|
+ {
|
|
|
|
+ case 0:
|
|
|
|
+ packet.skipBytes( 1 ); // byte
|
|
|
|
+ break;
|
|
|
|
+ case 1:
|
|
|
|
+ if ( index == metaIndex )
|
|
|
|
+ {
|
|
|
|
+ int position = packet.readerIndex();
|
|
|
|
+ rewriteVarInt( packet, oldId, newId, position );
|
|
|
|
+ packet.readerIndex( position );
|
|
|
|
+ }
|
|
|
|
+ DefinedPacket.readVarInt( packet );
|
|
|
|
+ break;
|
|
|
|
+ case 2:
|
|
|
|
+ packet.skipBytes( 4 ); // float
|
|
|
|
+ break;
|
|
|
|
+ case 3:
|
|
|
|
+ case 4:
|
|
|
|
+ DefinedPacket.readString( packet );
|
|
|
|
+ break;
|
|
|
|
+ case 5:
|
|
|
|
+ if ( packet.readShort() != -1 )
|
|
|
|
+ {
|
|
|
|
+ packet.skipBytes( 3 ); // byte, short
|
|
|
|
+
|
|
|
|
+ int position = packet.readerIndex();
|
|
|
|
+ if ( packet.readByte() != 0 )
|
|
|
|
+ {
|
|
|
|
+ packet.readerIndex( position );
|
|
|
|
+
|
|
|
|
+ try
|
|
|
|
+ {
|
|
|
|
+ new NBTInputStream( new ByteBufInputStream( packet ), false ).readTag();
|
|
|
|
+ } catch ( IOException ex )
|
|
|
|
+ {
|
|
|
|
+ throw Throwables.propagate( ex );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ break;
|
|
|
|
+ case 6:
|
|
|
|
+ packet.skipBytes( 1 ); // boolean
|
|
|
|
+ break;
|
|
|
|
+ case 7:
|
|
|
|
+ packet.skipBytes( 12 ); // float, float, float
|
|
|
|
+ break;
|
|
|
|
+ case 8:
|
|
|
|
+ packet.readLong();
|
|
|
|
+ break;
|
|
|
|
+ case 9:
|
|
|
|
+ if ( packet.readBoolean() )
|
|
|
|
+ {
|
|
|
|
+ packet.skipBytes( 8 ); // long
|
|
|
|
+ }
|
|
|
|
+ break;
|
|
|
|
+ case 10:
|
|
|
|
+ DefinedPacket.readVarInt( packet );
|
|
|
|
+ break;
|
|
|
|
+ case 11:
|
|
|
|
+ if ( packet.readBoolean() )
|
|
|
|
+ {
|
|
|
|
+ packet.skipBytes( 16 ); // long, long
|
|
|
|
+ }
|
|
|
|
+ break;
|
|
|
|
+ case 12:
|
|
|
|
+ DefinedPacket.readVarInt( packet );
|
|
|
|
+ break;
|
|
|
|
+ default:
|
|
|
|
+ throw new IllegalArgumentException( "Unknown meta type " + type );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ // Handles simple packets
|
|
|
|
+ private static void rewrite(ByteBuf packet, int oldId, int newId, boolean[] ints, boolean[] varints)
|
|
|
|
+ {
|
|
|
|
+ int readerIndex = packet.readerIndex();
|
|
|
|
+ int packetId = DefinedPacket.readVarInt( packet );
|
|
|
|
+ int packetIdLength = packet.readerIndex() - readerIndex;
|
|
|
|
+
|
|
|
|
+ if (packetId < 0 || packetId > ints.length || packetId > varints.length) { // Invalid packet id
|
|
|
|
+ // Ignore these invalid packets for compatibility reasons
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if ( ints[packetId] )
|
|
|
|
+ {
|
|
|
|
+ rewriteInt( packet, oldId, newId, readerIndex + packetIdLength );
|
|
|
|
+ } else if ( varints[packetId] )
|
|
|
|
+ {
|
|
|
|
+ rewriteVarInt( packet, oldId, newId, readerIndex + packetIdLength );
|
|
|
|
+ }
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ }
|
|
|
|
+}
|
2017-01-05 02:04:39 +01:00
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap_1_7_2.java b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap_1_7_2.java
|
|
|
|
new file mode 100644
|
2018-09-04 04:15:37 +02:00
|
|
|
index 00000000..65c1a9ec
|
2017-01-05 02:04:39 +01:00
|
|
|
--- /dev/null
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap_1_7_2.java
|
|
|
|
@@ -0,0 +1,102 @@
|
|
|
|
+// Travertine start
|
|
|
|
+package net.md_5.bungee.entitymap;
|
|
|
|
+
|
|
|
|
+import io.netty.buffer.ByteBuf;
|
|
|
|
+import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
+
|
|
|
|
+class EntityMap_1_7_2 extends EntityMap
|
|
|
|
+{
|
|
|
|
+
|
|
|
|
+ static final EntityMap INSTANCE = new EntityMap_1_7_2();
|
|
|
|
+
|
|
|
|
+ EntityMap_1_7_2()
|
|
|
|
+ {
|
|
|
|
+ addRewrite( 0x04, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Equipment
|
|
|
|
+ addRewrite( 0x0A, ProtocolConstants.Direction.TO_CLIENT, false ); // Use bed
|
|
|
|
+ addRewrite( 0x0B, ProtocolConstants.Direction.TO_CLIENT, true ); // Animation
|
|
|
|
+ addRewrite( 0x0C, ProtocolConstants.Direction.TO_CLIENT, true ); // Spawn Player
|
|
|
|
+ addRewrite( 0x0D, ProtocolConstants.Direction.TO_CLIENT, false ); // Collect Item
|
|
|
|
+ addRewrite( 0x0E, ProtocolConstants.Direction.TO_CLIENT, true ); // Spawn Object
|
|
|
|
+ addRewrite( 0x0F, ProtocolConstants.Direction.TO_CLIENT, true ); // Spawn Mob
|
|
|
|
+ addRewrite( 0x10, ProtocolConstants.Direction.TO_CLIENT, true ); // Spawn Painting
|
|
|
|
+ addRewrite( 0x11, ProtocolConstants.Direction.TO_CLIENT, true ); // Spawn Experience Orb
|
|
|
|
+ addRewrite( 0x12, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Velocity
|
|
|
|
+ addRewrite( 0x14, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity
|
|
|
|
+ addRewrite( 0x15, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Relative Move
|
|
|
|
+ addRewrite( 0x16, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Look
|
|
|
|
+ addRewrite( 0x17, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Look and Relative Move
|
|
|
|
+ addRewrite( 0x18, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Teleport
|
|
|
|
+ addRewrite( 0x19, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Head Look
|
|
|
|
+ addRewrite( 0x1A, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Status
|
|
|
|
+ addRewrite( 0x1B, ProtocolConstants.Direction.TO_CLIENT, false ); // Attach Entity
|
|
|
|
+ addRewrite( 0x1C, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Metadata
|
|
|
|
+ addRewrite( 0x1D, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Effect
|
|
|
|
+ addRewrite( 0x1E, ProtocolConstants.Direction.TO_CLIENT, false ); // Remove Entity Effect
|
|
|
|
+ addRewrite( 0x20, ProtocolConstants.Direction.TO_CLIENT, false ); // Entity Properties
|
|
|
|
+ addRewrite( 0x25, ProtocolConstants.Direction.TO_CLIENT, true ); // Block Break Animation
|
|
|
|
+ addRewrite( 0x2C, ProtocolConstants.Direction.TO_CLIENT, true ); // Spawn Global Entity
|
|
|
|
+
|
|
|
|
+ addRewrite( 0x02, ProtocolConstants.Direction.TO_SERVER, false ); // Use Entity
|
|
|
|
+ addRewrite( 0x0A, ProtocolConstants.Direction.TO_SERVER, false ); // Animation
|
|
|
|
+ addRewrite( 0x0B, ProtocolConstants.Direction.TO_SERVER, false ); // Entity Action
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public void rewriteClientbound(ByteBuf packet, int oldId, int newId)
|
|
|
|
+ {
|
|
|
|
+ super.rewriteClientbound( packet, oldId, newId );
|
|
|
|
+
|
|
|
|
+ //Special cases
|
|
|
|
+ int readerIndex = packet.readerIndex();
|
|
|
|
+ int packetId = DefinedPacket.readVarInt( packet );
|
|
|
|
+ int packetIdLength = packet.readerIndex() - readerIndex;
|
|
|
|
+ if ( packetId == 0x0D /* Collect Item */ || packetId == 0x1B /* Attach Entity */ )
|
|
|
|
+ {
|
|
|
|
+ rewriteInt( packet, oldId, newId, readerIndex + packetIdLength + 4 );
|
|
|
|
+ } else if ( packetId == 0x13 /* Destroy Entities */ )
|
|
|
|
+ {
|
|
|
|
+ int count = packet.getByte( packetIdLength );
|
|
|
|
+ for ( int i = 0; i < count; i++ )
|
|
|
|
+ {
|
|
|
|
+ rewriteInt( packet, oldId, newId, packetIdLength + 1 + i * 4 );
|
|
|
|
+ }
|
|
|
|
+ } else if ( packetId == 0x0E /* Spawn Object */ )
|
|
|
|
+ {
|
|
|
|
+ DefinedPacket.readVarInt( packet );
|
|
|
|
+ int type = packet.readUnsignedByte();
|
|
|
|
+
|
|
|
|
+ if ( type == 60 || type == 90 )
|
|
|
|
+ {
|
|
|
|
+ packet.skipBytes( 14 );
|
|
|
|
+ int position = packet.readerIndex();
|
|
|
|
+ int readId = packet.readInt();
|
|
|
|
+ int changedId = -1;
|
|
|
|
+ if ( readId == oldId )
|
|
|
|
+ {
|
|
|
|
+ packet.setInt( position, newId );
|
|
|
|
+ changedId = newId;
|
|
|
|
+ } else if ( readId == newId )
|
|
|
|
+ {
|
|
|
|
+ packet.setInt( position, oldId );
|
|
|
|
+ changedId = oldId;
|
|
|
|
+ }
|
|
|
|
+ if ( changedId != -1 )
|
|
|
|
+ {
|
|
|
|
+ if ( changedId == 0 && readId != 0 )
|
|
|
|
+ { // Trim off the extra data
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ packet.writerIndex( packet.readableBytes() - 6 );
|
|
|
|
+ } else if ( changedId != 0 && readId == 0 )
|
|
|
|
+ { // Add on the extra data
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ packet.capacity( packet.readableBytes() + 6 );
|
|
|
|
+ packet.writerIndex( packet.readableBytes() + 6 );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+// Travertine end
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap_1_7_6.java b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap_1_7_6.java
|
|
|
|
new file mode 100644
|
2018-09-04 04:15:37 +02:00
|
|
|
index 00000000..6755fe84
|
2017-01-05 02:04:39 +01:00
|
|
|
--- /dev/null
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/entitymap/EntityMap_1_7_6.java
|
|
|
|
@@ -0,0 +1,62 @@
|
|
|
|
+// Travertine start
|
|
|
|
+package net.md_5.bungee.entitymap;
|
|
|
|
+
|
|
|
|
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
|
|
|
|
+import io.netty.buffer.ByteBuf;
|
|
|
|
+import net.md_5.bungee.BungeeCord;
|
|
|
|
+import net.md_5.bungee.UserConnection;
|
|
|
|
+import net.md_5.bungee.connection.LoginResult;
|
|
|
|
+import net.md_5.bungee.protocol.DefinedPacket;
|
|
|
|
+
|
|
|
|
+class EntityMap_1_7_6 extends EntityMap_1_7_2
|
|
|
|
+{
|
|
|
|
+
|
|
|
|
+ static final EntityMap_1_7_6 INSTANCE = new EntityMap_1_7_6();
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ @SuppressFBWarnings("DLS_DEAD_LOCAL_STORE")
|
|
|
|
+ public void rewriteClientbound(ByteBuf packet, int oldId, int newId)
|
|
|
|
+ {
|
|
|
|
+ super.rewriteClientbound( packet, oldId, newId );
|
|
|
|
+
|
|
|
|
+ int readerIndex = packet.readerIndex();
|
|
|
|
+ int packetId = DefinedPacket.readVarInt( packet );
|
|
|
|
+ int packetIdLength = packet.readerIndex() - readerIndex;
|
|
|
|
+ if ( packetId == 0x0C /* Spawn Player */ )
|
|
|
|
+ {
|
|
|
|
+ DefinedPacket.readVarInt( packet );
|
|
|
|
+ int idLength = packet.readerIndex() - readerIndex - packetIdLength;
|
|
|
|
+ String uuid = DefinedPacket.readString( packet );
|
|
|
|
+ String username = DefinedPacket.readString( packet );
|
|
|
|
+ int props = DefinedPacket.readVarInt( packet );
|
|
|
|
+ if ( props == 0 )
|
|
|
|
+ {
|
|
|
|
+ UserConnection player = (UserConnection) BungeeCord.getInstance().getPlayer( username );
|
|
|
|
+ if ( player != null )
|
|
|
|
+ {
|
|
|
|
+ LoginResult profile = player.getPendingConnection().getLoginProfile();
|
|
|
|
+ if ( profile != null && profile.getProperties() != null
|
|
|
|
+ && profile.getProperties().length >= 1 )
|
|
|
|
+ {
|
|
|
|
+ ByteBuf rest = packet.copy();
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ packet.writerIndex( readerIndex + packetIdLength + idLength );
|
|
|
|
+ DefinedPacket.writeString( player.getUniqueId().toString(), packet );
|
|
|
|
+ DefinedPacket.writeString( username, packet );
|
|
|
|
+ DefinedPacket.writeVarInt( profile.getProperties().length, packet );
|
|
|
|
+ for ( LoginResult.Property property : profile.getProperties() )
|
|
|
|
+ {
|
|
|
|
+ DefinedPacket.writeString( property.getName(), packet );
|
|
|
|
+ DefinedPacket.writeString( property.getValue(), packet );
|
|
|
|
+ DefinedPacket.writeString( property.getSignature(), packet );
|
|
|
|
+ }
|
|
|
|
+ packet.writeBytes( rest );
|
|
|
|
+ rest.release();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ packet.readerIndex( readerIndex );
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+// Travertine end
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandler.java b/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandler.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index c1272da3..45af7ea4 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandler.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandler.java
|
2018-06-08 12:46:31 +02:00
|
|
|
@@ -8,6 +8,7 @@ import lombok.Getter;
|
2017-01-05 02:04:39 +01:00
|
|
|
import lombok.NonNull;
|
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
|
import lombok.Setter;
|
|
|
|
+import net.md_5.bungee.BungeeCord;
|
|
|
|
import net.md_5.bungee.UserConnection;
|
|
|
|
import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
import net.md_5.bungee.protocol.packet.EntityRemoveEffect;
|
2018-06-08 12:46:31 +02:00
|
|
|
@@ -23,6 +24,12 @@ public class ForgeClientHandler
|
2017-01-05 02:04:39 +01:00
|
|
|
@NonNull
|
|
|
|
private final UserConnection con;
|
|
|
|
|
|
|
|
+ // Travertine start
|
|
|
|
+ @Getter
|
|
|
|
+ @Setter(AccessLevel.PACKAGE)
|
|
|
|
+ private boolean forgeOutdated = false;
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
/**
|
|
|
|
* The users' mod list.
|
|
|
|
*/
|
2018-06-08 12:46:31 +02:00
|
|
|
@@ -173,4 +180,22 @@ public class ForgeClientHandler
|
2017-01-05 02:04:39 +01:00
|
|
|
{
|
|
|
|
return fmlTokenInHandshake || clientModList != null;
|
|
|
|
}
|
|
|
|
+
|
|
|
|
+ // Travertine start
|
|
|
|
+ /**
|
|
|
|
+ * Checks to see if a user is using an outdated FML build, and takes
|
|
|
|
+ * appropriate action on the User side. This should only be called during a
|
|
|
|
+ * server connection, by the ServerConnector
|
|
|
|
+ *
|
|
|
|
+ * @return <code>true</code> if the user's FML build is outdated, otherwise
|
|
|
|
+ * <code>false</code>
|
|
|
|
+ */
|
|
|
|
+ public boolean checkUserOutdated() {
|
|
|
|
+ if (forgeOutdated) {
|
|
|
|
+ con.disconnect( BungeeCord.getInstance().getTranslation("connect_kick_outdated_forge") );
|
|
|
|
+ }
|
|
|
|
+ return forgeOutdated;
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
+
|
|
|
|
}
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandshakeState.java b/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandshakeState.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index 5e02f8c8..e3c1b9b9 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandshakeState.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/forge/ForgeClientHandshakeState.java
|
|
|
|
@@ -3,6 +3,7 @@ package net.md_5.bungee.forge;
|
|
|
|
import java.util.Map;
|
|
|
|
import net.md_5.bungee.ServerConnector;
|
|
|
|
import net.md_5.bungee.UserConnection;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
import net.md_5.bungee.protocol.packet.PluginMessage;
|
|
|
|
|
|
|
|
/**
|
|
|
|
@@ -84,6 +85,22 @@ enum ForgeClientHandshakeState implements IForgeClientPacketHandler<ForgeClientH
|
|
|
|
// Once we've done it, no point doing it again.
|
|
|
|
Map<String, String> clientModList = ForgeUtils.readModList( message );
|
|
|
|
con.getForgeClientHandler().setClientModList( clientModList );
|
|
|
|
+ // Travertine start
|
|
|
|
+ // If the user is below 1.8, we need to check the version of FML - it's not always an OK version.
|
|
|
|
+ if ( ProtocolConstants.isBeforeOrEq( con.getPendingConnection().getVersion(), ProtocolConstants.MINECRAFT_1_7_6 ) )
|
|
|
|
+ {
|
|
|
|
+ // Get the version from the mod list.
|
|
|
|
+ int buildNumber = ForgeUtils.getFmlBuildNumber( clientModList );
|
|
|
|
+
|
|
|
|
+ // If we get 0, we're probably using a testing build, so let it though. Otherwise, check the build number.
|
|
|
|
+ if ( buildNumber < ForgeConstants.FML_MIN_BUILD_VERSION && buildNumber != 0 )
|
|
|
|
+ {
|
|
|
|
+ // Mark the user as an old Forge user. This will then cause any Forge ServerConnectors to cancel any
|
|
|
|
+ // connections to it.
|
|
|
|
+ con.getForgeClientHandler().setForgeOutdated( true );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
}
|
|
|
|
|
|
|
|
return WAITINGSERVERDATA;
|
|
|
|
diff --git a/proxy/src/main/java/net/md_5/bungee/tab/ServerUnique.java b/proxy/src/main/java/net/md_5/bungee/tab/ServerUnique.java
|
2018-09-04 04:15:37 +02:00
|
|
|
index daf12f74..e33861ab 100644
|
2017-01-05 02:04:39 +01:00
|
|
|
--- a/proxy/src/main/java/net/md_5/bungee/tab/ServerUnique.java
|
|
|
|
+++ b/proxy/src/main/java/net/md_5/bungee/tab/ServerUnique.java
|
|
|
|
@@ -4,12 +4,14 @@ import java.util.Collection;
|
|
|
|
import java.util.HashSet;
|
|
|
|
import java.util.UUID;
|
|
|
|
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
|
|
|
+import net.md_5.bungee.protocol.ProtocolConstants;
|
|
|
|
import net.md_5.bungee.protocol.packet.PlayerListItem;
|
|
|
|
|
|
|
|
public class ServerUnique extends TabList
|
|
|
|
{
|
|
|
|
|
|
|
|
private final Collection<UUID> uuids = new HashSet<>();
|
|
|
|
+ private final Collection<String> usernames = new HashSet<>(); // Travertine - Support for <=1.7.9
|
|
|
|
|
|
|
|
public ServerUnique(ProxiedPlayer player)
|
|
|
|
{
|
|
|
|
@@ -23,10 +25,26 @@ public class ServerUnique extends TabList
|
|
|
|
{
|
|
|
|
if ( playerListItem.getAction() == PlayerListItem.Action.ADD_PLAYER )
|
|
|
|
{
|
|
|
|
- uuids.add( item.getUuid() );
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( item.getUuid() != null )
|
|
|
|
+ {
|
|
|
|
+ uuids.add( item.getUuid() );
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ usernames.add( item.getUsername() );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
} else if ( playerListItem.getAction() == PlayerListItem.Action.REMOVE_PLAYER )
|
|
|
|
{
|
|
|
|
- uuids.remove( item.getUuid() );
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( item.getUuid() != null )
|
|
|
|
+ {
|
|
|
|
+ uuids.remove( item.getUuid() );
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ usernames.remove( item.getUsername() );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
}
|
|
|
|
}
|
|
|
|
player.unsafe().sendPacket( playerListItem );
|
|
|
|
@@ -43,16 +61,44 @@ public class ServerUnique extends TabList
|
|
|
|
{
|
|
|
|
PlayerListItem packet = new PlayerListItem();
|
|
|
|
packet.setAction( PlayerListItem.Action.REMOVE_PLAYER );
|
|
|
|
- PlayerListItem.Item[] items = new PlayerListItem.Item[ uuids.size() ];
|
|
|
|
+ PlayerListItem.Item[] items = new PlayerListItem.Item[ uuids.size() + usernames.size() ]; // Travertine
|
|
|
|
int i = 0;
|
|
|
|
for ( UUID uuid : uuids )
|
|
|
|
{
|
|
|
|
PlayerListItem.Item item = items[i++] = new PlayerListItem.Item();
|
|
|
|
item.setUuid( uuid );
|
|
|
|
}
|
|
|
|
+ // Travertine start
|
|
|
|
+ for ( String username : usernames )
|
|
|
|
+ {
|
|
|
|
+ PlayerListItem.Item item = items[i++] = new PlayerListItem.Item();
|
|
|
|
+ item.setUsername( username );
|
|
|
|
+ item.setDisplayName( username );
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
packet.setItems( items );
|
|
|
|
- player.unsafe().sendPacket( packet );
|
|
|
|
+ // Travertine start
|
|
|
|
+ if ( ProtocolConstants.isAfterOrEq( player.getPendingConnection().getVersion(), ProtocolConstants.MINECRAFT_1_8 ) )
|
|
|
|
+ {
|
|
|
|
+ player.unsafe().sendPacket( packet );
|
|
|
|
+ } else
|
|
|
|
+ {
|
|
|
|
+ // Split up the packet
|
|
|
|
+ for ( PlayerListItem.Item item : packet.getItems() )
|
|
|
|
+ {
|
|
|
|
+ PlayerListItem p2 = new PlayerListItem();
|
|
|
|
+ p2.setAction( packet.getAction() );
|
|
|
|
+
|
|
|
|
+ p2.setItems( new PlayerListItem.Item[]
|
|
|
|
+ {
|
|
|
|
+ item
|
|
|
|
+ } );
|
|
|
|
+ player.unsafe().sendPacket( p2 );
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // Travertine end
|
|
|
|
uuids.clear();
|
|
|
|
+ usernames.clear(); // Travertine
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
2016-07-03 08:56:31 +02:00
|
|
|
--
|
2018-10-14 12:23:29 +02:00
|
|
|
2.19.1
|
2016-07-03 08:56:31 +02:00
|
|
|
|