From ce057525d39a5c97fbc3584b908c956f00ddf872 Mon Sep 17 00:00:00 2001
From: s809 <43530948+s809@users.noreply.github.com>
Date: Tue, 27 Aug 2024 16:02:15 +0500
Subject: [PATCH] Show incompatible protocol version in F3

---
 .../client/ClientNetworkState.java            | 29 +++++++++++++++++++
 .../client/SyncOnLoginRequestQueue.java       |  2 +-
 .../internal/IncompatibleMessageEvent.java    | 15 ++++++++++
 3 files changed, 45 insertions(+), 1 deletion(-)
 create mode 100644 core/src/main/java/com/seibel/distanthorizons/core/network/event/internal/IncompatibleMessageEvent.java

diff --git a/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/ClientNetworkState.java b/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/ClientNetworkState.java
index 571611e67..2e2c35e09 100644
--- a/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/ClientNetworkState.java
+++ b/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/ClientNetworkState.java
@@ -8,15 +8,19 @@ import com.seibel.distanthorizons.core.multiplayer.config.MultiplayerConfigChang
 import com.seibel.distanthorizons.core.network.INetworkObject;
 import com.seibel.distanthorizons.core.network.event.ScopedNetworkEventSource;
 import com.seibel.distanthorizons.core.network.event.internal.CloseEvent;
+import com.seibel.distanthorizons.core.network.event.internal.IncompatibleMessageEvent;
+import com.seibel.distanthorizons.core.network.messages.base.CurrentLevelKeyMessage;
 import com.seibel.distanthorizons.core.network.messages.base.RemotePlayerConfigMessage;
 import com.seibel.distanthorizons.core.network.messages.fullData.FullDataChunkMessage;
 import com.seibel.distanthorizons.core.network.messages.fullData.FullDataPartialUpdateMessage;
 import com.seibel.distanthorizons.core.network.messages.fullData.FullDataPayload;
 import com.seibel.distanthorizons.core.network.session.Session;
 import com.seibel.distanthorizons.core.sql.dto.FullDataSourceV2DTO;
+import com.seibel.distanthorizons.coreapi.ModInfo;
 import io.netty.buffer.ByteBufAllocator;
 import io.netty.buffer.CompositeByteBuf;
 import org.apache.logging.log4j.LogManager;
+import org.jetbrains.annotations.Nullable;
 
 import java.io.Closeable;
 import java.util.List;
@@ -38,6 +42,9 @@ public class ClientNetworkState implements Closeable
 	private final MultiplayerConfigChangeListener configChangeListener = new MultiplayerConfigChangeListener(this::sendConfigMessage);
 	public boolean isReady() { return this.configReceived; }
 	
+	@Nullable
+	private Integer closestProtocolVersion;
+	
 	/**
 	 * Returns the client used by this instance. <p>
 	 * If you need to subscribe to any packet events, create an instance of {@link ScopedNetworkEventSource} using the returned instance.
@@ -55,6 +62,22 @@ public class ClientNetworkState implements Closeable
 	 */
 	public ClientNetworkState()
 	{
+		this.session.registerHandler(IncompatibleMessageEvent.class, event ->
+		{
+			if (this.closestProtocolVersion == null || Math.abs(event.protocolVersion - ModInfo.PROTOCOL_VERSION) < this.closestProtocolVersion)
+			{
+				this.closestProtocolVersion = event.protocolVersion;
+			}
+		});
+		
+		this.session.registerHandler(CurrentLevelKeyMessage.class, msg ->
+		{
+			if (this.serverSupportStatus == EServerSupportStatus.NONE)
+			{
+				this.serverSupportStatus = EServerSupportStatus.LEVELS_ONLY;
+			}
+		});
+		
 		this.session.registerHandler(RemotePlayerConfigMessage.class, msg ->
 		{
 			this.serverSupportStatus = EServerSupportStatus.FULL;
@@ -121,6 +144,12 @@ public class ClientNetworkState implements Closeable
 			return;
 		}
 		
+		if (this.serverSupportStatus == EServerSupportStatus.NONE && this.closestProtocolVersion != null)
+		{
+			messageList.add("Incompatible protocol version: " + this.closestProtocolVersion + ", required: " + ModInfo.PROTOCOL_VERSION);
+			return;
+		}
+		
 		messageList.add(this.serverSupportStatus.message);
 	}
 	
diff --git a/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/SyncOnLoginRequestQueue.java b/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/SyncOnLoginRequestQueue.java
index edc36437e..5d56ee1c4 100644
--- a/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/SyncOnLoginRequestQueue.java
+++ b/core/src/main/java/com/seibel/distanthorizons/core/multiplayer/client/SyncOnLoginRequestQueue.java
@@ -15,7 +15,7 @@ public class SyncOnLoginRequestQueue extends AbstractFullDataRequestQueue
 	protected int getRequestRateLimit() { return this.networkState.config.syncOnLoginRateLimit; }
 	
 	@Override
-	protected String getQueueName() { return "Data Refresh Queue"; }
+	protected String getQueueName() { return "Sync On Login Queue"; }
 	
 	@Override
 	public boolean tick(DhBlockPos2D targetPos)
diff --git a/core/src/main/java/com/seibel/distanthorizons/core/network/event/internal/IncompatibleMessageEvent.java b/core/src/main/java/com/seibel/distanthorizons/core/network/event/internal/IncompatibleMessageEvent.java
new file mode 100644
index 000000000..d732ab4ed
--- /dev/null
+++ b/core/src/main/java/com/seibel/distanthorizons/core/network/event/internal/IncompatibleMessageEvent.java
@@ -0,0 +1,15 @@
+package com.seibel.distanthorizons.core.network.event.internal;
+
+/**
+ * This event is received instead of a message if its protocol version is incompatible with version the mod uses.
+ */
+public class IncompatibleMessageEvent extends InternalEvent
+{
+	public final int protocolVersion;
+	
+	public IncompatibleMessageEvent(int protocolVersion)
+	{
+		this.protocolVersion = protocolVersion;
+	}
+	
+}
\ No newline at end of file