Add Fabric configuration classes and update build.gradle.kts

Author: renvins

fabric/build.gradle.kts

@@ -23,12 +23,21 @@ fabricApi {
     }
 }
 
+repositories {
+    mavenCentral()
+    maven { url = uri("https://jitpack.io") }
+}
+
 dependencies {
     minecraft("com.mojang:minecraft:1.21.5")
     mappings("net.fabricmc:yarn:1.21.5+build.1:v2")
     modImplementation("net.fabricmc:fabric-loader:0.16.10")
 
     modImplementation("net.fabricmc.fabric-api:fabric-api:0.119.5+1.21.5")
+
+    implementation(project(":api"))
+    implementation(project(":common"))
+    implementation("com.github.Carleslc.Simple-YAML:Simple-Yaml:1.8.4")
 }
 
 tasks.processResources {

fabric/src/main/java/it/renvins/serverpulse/fabric/config/FabricConfiguration.java

@@ -0,0 +1,64 @@
+package it.renvins.serverpulse.fabric.config;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.logging.Level;
+
+import it.renvins.serverpulse.fabric.ServerPulseFabric;
+import lombok.Getter;
+import org.simpleyaml.configuration.file.YamlFile;
+
+public class FabricConfiguration {
+
+    private final String name;
+
+    @Getter private final YamlFile config;
+
+    public FabricConfiguration(Path dataDir, String name) {
+        this.name = name;
+
+        try {
+            Files.createDirectories(dataDir);
+        } catch (IOException e) {
+            ServerPulseFabric.LOGGER.log(Level.SEVERE,"Failed to create data directory: " + dataDir, e);
+        }
+        this.config = new YamlFile(new File(dataDir.toFile(), name));
+    }
+
+    public boolean load() {
+        try {
+            if (!config.exists()) {
+                if (copyDefaultsFromResource()) {
+                    ServerPulseFabric.LOGGER.info("Created configuration file: " + name);
+                } else {
+                    config.createNewFile();
+                    ServerPulseFabric.LOGGER.info("Configuration file not found, created a new one: " + name);
+                }
+            } else {
+                ServerPulseFabric.LOGGER.info("Loading configuration file: " + name);
+            }
+            config.load();
+            return true;
+        } catch (Exception e) {
+            ServerPulseFabric.LOGGER.log(Level.SEVERE,"Failed to load configuration file: " + name, e);
+            return false;
+        }
+    }
+
+    private boolean copyDefaultsFromResource() {
+        try (InputStream in = getClass().getClassLoader().getResourceAsStream(name)) {
+            if (in != null) {
+                Files.copy(in, config.getConfigurationFile().toPath());
+                return true;
+            } else {
+                return false;
+            }
+        } catch (IOException e) {
+            ServerPulseFabric.LOGGER.log(Level.SEVERE,"Failed to copy default configuration file: " + name, e);
+            return false;
+        }
+    }
+}

fabric/src/main/java/it/renvins/serverpulse/fabric/config/FabricDatabaseConfiguration.java

@@ -0,0 +1,30 @@
+package it.renvins.serverpulse.fabric.config;
+
+import it.renvins.serverpulse.common.config.DatabaseConfiguration;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public class FabricDatabaseConfiguration implements DatabaseConfiguration {
+
+    private final FabricConfiguration configuration;
+
+    @Override
+    public String getHost() {
+        return configuration.getConfig().getString("metrics.influxdb.url");
+    }
+
+    @Override
+    public String getOrg() {
+        return configuration.getConfig().getString("metrics.influxdb.org");
+    }
+
+    @Override
+    public String getToken() {
+        return configuration.getConfig().getString("metrics.influxdb.token");
+    }
+
+    @Override
+    public String getBucket() {
+        return configuration.getConfig().getString("metrics.influxdb.bucket");
+    }
+}

fabric/src/main/java/it/renvins/serverpulse/fabric/config/FabricMetricsConfiguration.java

@@ -0,0 +1,40 @@
+package it.renvins.serverpulse.fabric.config;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import it.renvins.serverpulse.common.config.MetricsConfiguration;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public class FabricMetricsConfiguration implements MetricsConfiguration {
+
+    private final FabricConfiguration configuration;
+
+    @Override
+    public String getServerTag() {
+        return configuration.getConfig().getString("metrics.tags.server");
+    }
+
+    @Override
+    public String getMeasurementTable() {
+        return configuration.getConfig().getString("metrics.influxdb.table");
+    }
+
+    @Override
+    public long getMetricsInterval() {
+        return configuration.getConfig().getLong("metrics.interval");
+    }
+
+    @Override
+    public Map<String, String> getTags() {
+        Map<String, Object> tags = configuration.getConfig().getConfigurationSection("metrics.tags").getValues(false);
+        Map<String, String> stringTags = new HashMap<>();
+        tags.forEach((key, value) -> {
+            if (value instanceof String && !key.equalsIgnoreCase("server") && !key.equalsIgnoreCase("world")) {
+                stringTags.put(key, (String) value);
+            }
+        });
+        return stringTags;
+    }
+}