Merge branch 'main' into dependabot/gradle/it.unimi.dsi-fastutil-8.5.18

Author: UplandJacob

src/main/java/tf/tuff/NetworkListener.java

@@ -9,24 +9,24 @@
 
 public class NetworkListener implements PacketListener {
 
-    private final TuffX plugin;
+	private final TuffX plugin;
 
-    public NetworkListener(TuffX plugin) {
-        this.plugin = plugin;
-    }
+	public NetworkListener(TuffX plugin) {
+		this.plugin = plugin;
+	}
 
-    @Override
-    public void onPacketSend(PacketSendEvent event) {
-        if (event.getPacketType() == PacketType.Play.Server.CHUNK_DATA) {
-            Player player = (Player) event.getPlayer();
-            if (player == null) return;
+	@Override
+	public void onPacketSend(PacketSendEvent event) {
+		if (event.getPacketType() == PacketType.Play.Server.CHUNK_DATA) {
+			Player player = (Player) event.getPlayer();
+			if (player == null) return;
 
-            WrapperPlayServerChunkData wrapper = new WrapperPlayServerChunkData(event);
-            int chunkX = wrapper.getColumn().getX();
-            int chunkZ = wrapper.getColumn().getZ();
+			WrapperPlayServerChunkData wrapper = new WrapperPlayServerChunkData(event);
+			int chunkX = wrapper.getColumn().getX();
+			int chunkZ = wrapper.getColumn().getZ();
 
-            World world = player.getWorld();
-            plugin.y0Plugin.chunkPacketListener.handleChunk(plugin, player, world, chunkX, chunkZ);
-        }
-    }
+			World world = player.getWorld();
+			plugin.y0Plugin.chunkPacketListener.handleChunk(plugin, player, world, chunkX, chunkZ);
+		}
+	}
 }

src/main/java/tf/tuff/ServerRegistry.java

@@ -8,61 +8,61 @@
 import tf.tuff.util.SchedulerCompat;
 
 public class ServerRegistry {
-    private final JavaPlugin p;
-    private final String wsUrl;
-    private final String server;
-    private WebSocketClient client;
-    private volatile boolean running = true;
+	private final JavaPlugin p;
+	private final String wsUrl;
+	private final String server;
+	private WebSocketClient client;
+	private volatile boolean running = true;
 
-    public ServerRegistry(JavaPlugin pl, String registryUrl, String serverAddr) {
-        p = pl;
-        wsUrl = registryUrl;
-        server = serverAddr;
-    }
+	public ServerRegistry(JavaPlugin pl, String registryUrl, String serverAddr) {
+		p = pl;
+		wsUrl = registryUrl;
+		server = serverAddr;
+	}
 
-    public void connect() {
-        SchedulerCompat.runAsync(p, this::doConnect);
-    }
+	public void connect() {
+		SchedulerCompat.runAsync(p, this::doConnect);
+	}
 
-    private void doConnect() {
-        if (!running)
-            return;
+	private void doConnect() {
+		if (!running)
+			return;
 
-        try {
-            client = new WebSocketClient(new URI(wsUrl)) {
-                @Override
-                public void onOpen(ServerHandshake h) {
-                    send("{\"type\":\"register\",\"server\":\"" + server + "\"}");
-                }
+		try {
+			client = new WebSocketClient(new URI(wsUrl)) {
+				@Override
+				public void onOpen(ServerHandshake h) {
+					send("{\"type\":\"register\",\"server\":\"" + server + "\"}");
+				}
 
-                @Override
-                public void onMessage(String msg) {
-                }
+				@Override
+				public void onMessage(String msg) {
+				}
 
-                @Override
-                public void onClose(int code, String reason, boolean remote) {
-                    if (running) {
-                        SchedulerCompat.runAsyncLater(p, ServerRegistry.this::doConnect, 100L);
-                    }
-                }
+				@Override
+				public void onClose(int code, String reason, boolean remote) {
+					if (running) {
+						SchedulerCompat.runAsyncLater(p, ServerRegistry.this::doConnect, 100L);
+					}
+				}
 
-                @Override
-                public void onError(Exception e) {
-                }
-            };
-            client.setConnectionLostTimeout(30);
-            client.connect();
-        } catch (Exception e) {
-            if (running) {
-                SchedulerCompat.runAsyncLater(p, this::doConnect, 100L);
-            }
-        }
-    }
+				@Override
+				public void onError(Exception e) {
+				}
+			};
+			client.setConnectionLostTimeout(30);
+			client.connect();
+		} catch (Exception e) {
+			if (running) {
+				SchedulerCompat.runAsyncLater(p, this::doConnect, 100L);
+			}
+		}
+	}
 
-    public void disconnect() {
-        running = false;
-        if (client != null) {
-            client.close();
-        }
-    }
+	public void disconnect() {
+		running = false;
+		if (client != null) {
+			client.close();
+		}
+	}
 }