Implement Velocity platform and task scheduler, add metrics service integration

Author: renvins

common/src/main/java/it/renvins/serverpulse/common/MetricsService.java

@@ -102,7 +102,13 @@ private SyncMetricsSnapshot collectSnapshot() {
         try {
             double[] tps = ServerPulseProvider.get().getTPSRetriever().getTPS();
             int playerCount = platform.getOnlinePlayerCount();
-            Map<String, WorldData> worldsData = platform.getWorldsData();
+
+            Map<String, WorldData> worldsData = null;
+            try {
+                worldsData = platform.getWorldsData();
+            } catch (UnsupportedOperationException e) {
+                worldsData = Map.of();
+            }
 
             return new SyncMetricsSnapshot(tps, playerCount, worldsData);
         } catch (Exception e) {

velocity/src/main/java/it/renvins/serverpulse/velocity/ServerPulseVelocity.java

@@ -4,15 +4,23 @@
 import com.google.inject.Inject;
 import com.velocitypowered.api.plugin.Plugin;
 import com.velocitypowered.api.proxy.ProxyServer;
+import it.renvins.serverpulse.api.service.IDatabaseService;
+import it.renvins.serverpulse.api.service.IMetricsService;
+import it.renvins.serverpulse.common.DatabaseService;
+import it.renvins.serverpulse.common.MetricsService;
+import lombok.Getter;
 import org.slf4j.Logger;
 
 @Plugin(id = "serverpulse", name = "ServerPulse", version = "0.2.0-SNAPSHOT",
 description = "Effortless Minecraft performance monitoring with pre-configured Grafana/InfluxDB via Docker.", authors = {"renvins"})
 public class ServerPulseVelocity {
 
-    private final ProxyServer server;
+    @Getter private final ProxyServer server;
     private final Logger logger;
 
+    private IDatabaseService databaseService;
+    private IMetricsService metricsService;
+
     @Inject
     public ServerPulseVelocity(ProxyServer server, Logger logger) {
         this.server = server;
@@ -21,6 +29,7 @@ public ServerPulseVelocity(ProxyServer server, Logger logger) {
 
     @Subscribe
     public void onProxyInitialization() {
-
+        this.databaseService = new DatabaseService();
+        this.metricsService = new MetricsService();
     }
 }

velocity/src/main/java/it/renvins/serverpulse/velocity/ServerPulseVelocityAPI.java

@@ -0,0 +1,36 @@
+package it.renvins.serverpulse.velocity;
+
+import it.renvins.serverpulse.api.ServerPulseAPI;
+import it.renvins.serverpulse.api.metrics.IDiskRetriever;
+import it.renvins.serverpulse.api.metrics.IPingRetriever;
+import it.renvins.serverpulse.api.metrics.ITPSRetriever;
+import it.renvins.serverpulse.api.service.IDatabaseService;
+import it.renvins.serverpulse.api.service.IMetricsService;
+
+public class ServerPulseVelocityAPI implements ServerPulseAPI {
+
+    @Override
+    public IDatabaseService getDatabaseService() {
+        return null;
+    }
+
+    @Override
+    public IMetricsService getMetricsService() {
+        return null;
+    }
+
+    @Override
+    public ITPSRetriever getTPSRetriever() {
+        return null;
+    }
+
+    @Override
+    public IDiskRetriever getDiskRetriever() {
+        return null;
+    }
+
+    @Override
+    public IPingRetriever getPingRetriever() {
+        return null;
+    }
+}

velocity/src/main/java/it/renvins/serverpulse/velocity/platform/VelocityPlatform.java

@@ -0,0 +1,31 @@
+package it.renvins.serverpulse.velocity.platform;
+
+import it.renvins.serverpulse.common.platform.Platform;
+import it.renvins.serverpulse.velocity.ServerPulseVelocity;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public class VelocityPlatform implements Platform {
+
+    private final ServerPulseVelocity plugin;
+
+    @Override
+    public boolean isEnabled() {
+        return !plugin.getServer().isShuttingDown();
+    }
+
+    @Override
+    public void disable() {
+        plugin.getServer().shutdown();
+    }
+
+    @Override
+    public boolean isPrimaryThread() {
+        return true;
+    }
+
+    @Override
+    public int getOnlinePlayerCount() {
+        return plugin.getServer().getAllPlayers().size();
+    }
+}

velocity/src/main/java/it/renvins/serverpulse/velocity/scheduler/VelocityTaskScheduler.java

@@ -0,0 +1,34 @@
+package it.renvins.serverpulse.velocity.scheduler;
+
+import java.util.concurrent.TimeUnit;
+
+import it.renvins.serverpulse.common.scheduler.Task;
+import it.renvins.serverpulse.common.scheduler.TaskScheduler;
+import it.renvins.serverpulse.velocity.ServerPulseVelocity;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public class VelocityTaskScheduler implements TaskScheduler {
+
+    private final ServerPulseVelocity plugin;
+
+    @Override
+    public void runAsync(Runnable task) {
+        plugin.getServer().getScheduler().buildTask(plugin, task).schedule();
+    }
+
+    @Override
+    public Task runTaskTimerAsync(Runnable task, long delayTicks, long periodTicks) {
+        return new VelocityTaskWrapper(plugin.getServer().getScheduler().buildTask(plugin, task)
+                        .delay(delayTicks / 20, TimeUnit.SECONDS)
+                        .repeat(periodTicks / 20, TimeUnit.SECONDS)
+                        .schedule());
+    }
+
+    @Override
+    public Task runTaskLaterAsync(Runnable task, long delayTicks) {
+        return new VelocityTaskWrapper(plugin.getServer().getScheduler().buildTask(plugin, task)
+                        .delay(delayTicks / 20, TimeUnit.SECONDS)
+                        .schedule());
+    }
+}

velocity/src/main/java/it/renvins/serverpulse/velocity/scheduler/VelocityTaskWrapper.java

@@ -0,0 +1,22 @@
+package it.renvins.serverpulse.velocity.scheduler;
+
+import com.velocitypowered.api.scheduler.ScheduledTask;
+import com.velocitypowered.api.scheduler.TaskStatus;
+import it.renvins.serverpulse.common.scheduler.Task;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public class VelocityTaskWrapper implements Task {
+
+    private final ScheduledTask task;
+
+    @Override
+    public void cancel() {
+        task.cancel();
+    }
+
+    @Override
+    public boolean isCancelled() {
+        return task.status() == TaskStatus.CANCELLED;
+    }
+}