package com.crizzhhh.config; import lombok.Getter; import net.kyori.adventure.text.Component; import net.kyori.adventure.text.minimessage.MiniMessage; import org.spongepowered.configurate.ConfigurationNode; import org.spongepowered.configurate.yaml.YamlConfigurationLoader; import java.io.IOException; import java.io.InputStream; import java.nio.file.Files; import java.nio.file.Path; import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; @Getter public class ConfigManager { private final Path dataDirectory; private final Path configPath; private final MiniMessage miniMessage; private ConfigurationNode config; private ProxyType proxyType; private String javaProxyIp; private String bedrockProxyIp; private boolean redisEnabled; private String redisHost; private int redisPort; private String redisPassword; private String redisChannelPrefix; private List bedrockOnJavaKickLines; private List javaOnBedrockKickLines; private String messagePrefix; private String reloadSuccessMessage; private String reloadFailedMessage; private String redisConnectedMessage; private String redisDisconnectedMessage; private String playerCountSyncedMessage; private boolean debug; public ConfigManager(Path dataDirectory) { this.dataDirectory = dataDirectory; this.configPath = dataDirectory.resolve("config.yml"); this.miniMessage = MiniMessage.miniMessage(); createDefaultConfig(); reload(); } private void createDefaultConfig() { try { if (!Files.exists(dataDirectory)) { Files.createDirectories(dataDirectory); } if (!Files.exists(configPath)) { try (InputStream in = getClass().getClassLoader().getResourceAsStream("config.yml")) { if (in != null) { Files.copy(in, configPath); System.out.println("[Crizzhhh] Created default configuration file"); } } } } catch (IOException e) { System.err.println("[Crizzhhh] Failed to create default config: " + e.getMessage()); } } public boolean reload() { try { YamlConfigurationLoader loader = YamlConfigurationLoader.builder() .path(configPath) .build(); config = loader.load(); proxyType = ProxyType.fromString(config.node("proxy", "type").getString("JAVA")); javaProxyIp = config.node("network", "java_proxy_ip").getString("play.example.com"); bedrockProxyIp = config.node("network", "bedrock_proxy_ip").getString("bedrock.example.com"); redisEnabled = config.node("redis", "enabled").getBoolean(true); redisHost = config.node("redis", "host").getString("localhost"); redisPort = config.node("redis", "port").getInt(6379); redisPassword = config.node("redis", "password").getString(""); redisChannelPrefix = config.node("redis", "channel_prefix").getString("crizzhhh"); bedrockOnJavaKickLines = getStringList(config.node("kick_messages", "bedrock_on_java")); javaOnBedrockKickLines = getStringList(config.node("kick_messages", "java_on_bedrock")); messagePrefix = config.node("messages", "prefix").getString("[<#00ffff>Crizzhhh<#00ffff>] "); reloadSuccessMessage = config.node("messages", "reload_success").getString("Configuration reloaded successfully!"); reloadFailedMessage = config.node("messages", "reload_failed").getString("Failed to reload configuration."); redisConnectedMessage = config.node("messages", "redis_connected").getString("Connected to Redis successfully"); redisDisconnectedMessage = config.node("messages", "redis_disconnected").getString("Redis connection unavailable"); playerCountSyncedMessage = config.node("messages", "player_count_synced").getString("Player count synchronized"); debug = config.node("debug").getBoolean(false); System.out.println("[Crizzhhh] Configuration loaded successfully"); System.out.println("[Crizzhhh] Proxy type: " + proxyType); System.out.println("[Crizzhhh] Redis enabled: " + redisEnabled); return true; } catch (Exception e) { System.err.println("[Crizzhhh] Failed to reload configuration: " + e.getMessage()); e.printStackTrace(); return false; } } private List getStringList(ConfigurationNode node) { List list = new ArrayList<>(); if (node.isList()) { node.childrenList().forEach(child -> { String value = child.getString(); if (value != null) { list.add(value); } }); } return list; } public Component getBedrockOnJavaKickMessage() { return buildKickMessage(bedrockOnJavaKickLines, bedrockProxyIp); } public Component getJavaOnBedrockKickMessage() { return buildKickMessage(javaOnBedrockKickLines, javaProxyIp); } private Component buildKickMessage(List lines, String replacementIp) { String joined = lines.stream() .map(line -> line.replace("{bedrock_ip}", bedrockProxyIp) .replace("{java_ip}", javaProxyIp)) .collect(Collectors.joining("\n")); return miniMessage.deserialize(joined); } public Component formatMessage(String message) { return miniMessage.deserialize(messagePrefix + message); } public Component getReloadSuccessMessage() { return formatMessage(reloadSuccessMessage); } public Component getReloadFailedMessage() { return formatMessage(reloadFailedMessage); } public void log(String message) { if (debug) { System.out.println("[Crizzhhh] [DEBUG] " + message); } } }