From f143804662d042eb1fd5a17f810c9a869f23749f Mon Sep 17 00:00:00 2001
From: Alex <alex@roese.dev>
Date: Mon, 27 Dec 2021 15:03:51 +0100
Subject: [PATCH] implemented KraSocketClient

---
 .../proxy/listener/SocketClientMessageListener.java   | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java b/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java
index 9053a50..4fb3512 100644
--- a/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java
+++ b/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java
@@ -2,6 +2,7 @@ package net.krakatoa.proxy.listener;
 
 import earth.krakatao.events.KraSocketClientEventInterface;
 import earth.krakatao.protocol.KraSocketClientProtocolMessage;
+import java.util.concurrent.TimeUnit;
 import net.krakatoa.proxy.ProxySystem;
 import net.md_5.bungee.api.ProxyServer;
 import net.md_5.bungee.api.chat.TextComponent;
@@ -68,5 +69,15 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
           new TextComponent(
               "§cSocket §8» §c" + (remote ? "Connection! Closed by remote peer" : reason)));
     }
+
+    if (code != 1) {
+      ProxyServer.getInstance().getScheduler().schedule(ProxySystem.getInstance(), () -> {
+        for (ProxiedPlayer proxiedPlayer : ProxyServer.getInstance().getPlayers()) {
+          proxiedPlayer.sendMessage(new TextComponent("§cSocket §8» §7Reconnecting..."));
+        }
+
+        ProxySystem.getInstance().getKraSocketClient().getSocketClient().Reconnect();
+      }, 3L, TimeUnit.SECONDS);
+    }
   }
 }