diff --git a/src/main/java/net/krakatoaapi/KrakatoaAPI.java b/src/main/java/net/krakatoaapi/KrakatoaAPI.java index 0f10134..baef735 100755 --- a/src/main/java/net/krakatoaapi/KrakatoaAPI.java +++ b/src/main/java/net/krakatoaapi/KrakatoaAPI.java @@ -34,104 +34,104 @@ import java.util.UUID; @Getter public class KrakatoaAPI extends JavaPlugin { - @Getter - private static KrakatoaAPI instance; + @Getter + private static KrakatoaAPI instance; - private ConfigHandler configHandler; - private KraSocketClientProtocol kraSocketClientProtocol; - private KraSocketClient kraSocketClient; - private KraSocketClientEventInitiater kraSocketClientEventInitiater; - private KraSocketClientEventInterface kraSocketClientEventInterface; + private ConfigHandler configHandler; + private KraSocketClientProtocol kraSocketClientProtocol; + private KraSocketClient kraSocketClient; + private KraSocketClientEventInitiater kraSocketClientEventInitiater; + private KraSocketClientEventInterface kraSocketClientEventInterface; - private MongoManager mongoManager; - private RedisManager redisManager; + private MongoManager mongoManager; + private RedisManager redisManager; - private Formatter formatter; + private Formatter formatter; - @Override - public void onEnable() { - super.onEnable(); + @Override + public void onEnable() { + super.onEnable(); - instance = this; - this.configHandler = new ConfigHandler(); + instance = this; + this.configHandler = new ConfigHandler(); - try { - this.configHandler.load(); - } catch (IOException | InvalidConfigurationException e) { - e.printStackTrace(); + try { + this.configHandler.load(); + } catch (IOException | InvalidConfigurationException e) { + e.printStackTrace(); + } + + this.kraSocketClientProtocol = new KraSocketClientProtocol(); + + KraSocketClientConfig kraSocketClientConfig = new KraSocketClientConfig( + this.configHandler.getWebSocketProtocol(), this.configHandler.getWebSocketHost(), + this.configHandler.getWebSocketPort(), this.configHandler.getWebSocketAccessKey(), + CloudNetDriver.getInstance().getComponentName(), + this.configHandler.getWebSocketAckTimeouts()); + + this.kraSocketClientEventInitiater = new KraSocketClientEventInitiater(); + this.kraSocketClientEventInterface = new SocketClientMessageListener(); + + try { + this.kraSocketClient = new KraSocketClient(kraSocketClientConfig, + this.kraSocketClientEventInterface, this.kraSocketClientProtocol); + } catch (URISyntaxException e) { + e.printStackTrace(); + } + + this.kraSocketClient.getSocketClient().connect(); + + this.getLogger().info("testaa lol"); + + this.mongoManager = new MongoManager(new MongoConfig(this.configHandler.getMongodbHost(), + this.configHandler.getMongodbPort(), this.configHandler.getMongodbUsername(), + this.configHandler.getMongodbPassword(), + this.configHandler.getMongodbDatabase())); + this.mongoManager.connect(); + + this.redisManager = new RedisManager( + new RedisConfig(this.configHandler.getRedisHost(), this.getConfigHandler().getRedisPort())); + this.redisManager.connect(); + + this.formatter = new Formatter(); + + loadListeners(); + loadCommands(); + + // call to proxy that the server is only for the auto restart system + Bukkit.getScheduler().runTaskLaterAsynchronously(this, () -> { + KraSocketClientProtocolMessage kraSocketClientProtocolMessage = new KraSocketClientProtocolMessage( + KraSocketClientProtocolStatus.SEND.getStatus(), 0, + KraSocketClientProtocolDest.PROXY.getStatus(), + UUID.fromString("c7b023ac-0303-4275-923d-3a1028e887a0"), + (short) 59739, + CloudNetDriver.getInstance().getComponentName(), null); + + this.kraSocketClient.getSocketClient().SendMessage(kraSocketClientProtocolMessage); + }, 3 * 20); } - this.kraSocketClientProtocol = new KraSocketClientProtocol(); + @Override + public void onDisable() { + super.onDisable(); - KraSocketClientConfig kraSocketClientConfig = new KraSocketClientConfig( - this.configHandler.getWebSocketProtocol(), this.configHandler.getWebSocketHost(), - this.configHandler.getWebSocketPort(), this.configHandler.getWebSocketAccessKey(), - CloudNetDriver.getInstance().getComponentName(), - this.configHandler.getWebSocketAckTimeouts()); + this.mongoManager.shutdown(); - this.kraSocketClientEventInitiater = new KraSocketClientEventInitiater(); - this.kraSocketClientEventInterface = new SocketClientMessageListener(); + this.kraSocketClient.getSocketClient().getConnection().close(); + this.kraSocketClient.getSocketClient().getConnection().closeConnection(1, ""); - try { - this.kraSocketClient = new KraSocketClient(kraSocketClientConfig, - this.kraSocketClientEventInterface, this.kraSocketClientProtocol); - } catch (URISyntaxException e) { - e.printStackTrace(); + instance = null; } - this.kraSocketClient.getSocketClient().connect(); + public void loadListeners() { + PluginManager pluginManager = Bukkit.getPluginManager(); + List.of(new PlayerJoinListener(), new PlayerQuitListener()).forEach(listener -> { + pluginManager.registerEvents(listener, this); + }); + } - this.getLogger().info("testaa"); - - this.mongoManager = new MongoManager(new MongoConfig(this.configHandler.getMongodbHost(), - this.configHandler.getMongodbPort(), this.configHandler.getMongodbUsername(), - this.configHandler.getMongodbPassword(), - this.configHandler.getMongodbDatabase())); - this.mongoManager.connect(); - - this.redisManager = new RedisManager( - new RedisConfig(this.configHandler.getRedisHost(), this.getConfigHandler().getRedisPort())); - this.redisManager.connect(); - - this.formatter = new Formatter(); - - loadListeners(); - loadCommands(); - - // call to proxy that the server is only for the auto restart system - Bukkit.getScheduler().runTaskLaterAsynchronously(this, () -> { - KraSocketClientProtocolMessage kraSocketClientProtocolMessage = new KraSocketClientProtocolMessage( - KraSocketClientProtocolStatus.SEND.getStatus(), 0, - KraSocketClientProtocolDest.PROXY.getStatus(), - UUID.fromString("c7b023ac-0303-4275-923d-3a1028e887a0"), - (short) 59739, - CloudNetDriver.getInstance().getComponentName(), null); - - this.kraSocketClient.getSocketClient().SendMessage(kraSocketClientProtocolMessage); - }, 3 * 20); - } - - @Override - public void onDisable() { - super.onDisable(); - - this.mongoManager.shutdown(); - - this.kraSocketClient.getSocketClient().getConnection().close(); - this.kraSocketClient.getSocketClient().getConnection().closeConnection(1, ""); - - instance = null; - } - - public void loadListeners() { - PluginManager pluginManager = Bukkit.getPluginManager(); - List.of(new PlayerJoinListener(), new PlayerQuitListener()).forEach(listener -> { - pluginManager.registerEvents(listener, this); - }); - } - - public void loadCommands() { - Objects.requireNonNull(getCommand("krakatoa")).setExecutor(new KrakataoCommand()); - } + public void loadCommands() { + Objects.requireNonNull(getCommand("krakatoa")).setExecutor(new KrakataoCommand()); + } }