2.0.0

Author: hardcorefactions

velocity/pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>today.netshield.velocity</groupId>
     <artifactId>NetShield-Velocity</artifactId>
-    <version>1.1</version>
+    <version>2.0.0</version>
     <packaging>jar</packaging>
 
     <name>NetShield-Velocity</name>

velocity/src/main/java/today/netshield/velocity/NetShield.java

@@ -7,51 +7,54 @@
 import com.velocitypowered.api.plugin.annotation.DataDirectory;
 import com.velocitypowered.api.proxy.ProxyServer;
 import lombok.Getter;
-import lombok.SneakyThrows;
 import org.slf4j.Logger;
+
+import today.netshield.velocity.commands.impl.NetShieldCommand;
 import today.netshield.velocity.config.ConfigManager;
-import today.netshield.velocity.listeners.PlayerListener;
+import today.netshield.velocity.listeners.ConnectionListener;
 
 import java.io.File;
 import java.nio.file.Path;
 
 @Plugin(
-        id          = "netshield",
-        name        = "NetShield-Velocity",
-        version     =  "1.1",
-        description = "Secure your minecraft cracked player's accounts."
+        id = "netshield",
+        name = "NetShield",
+        authors = "jsexp",
+        version = "2.0.0"
 )
 @Getter
 public class NetShield {
-    @Getter
-    private static NetShield instance;
 
-    @Inject
-    private static Logger logger;
+    @Getter private static NetShield instance;
 
-    @DataDirectory
-    @Inject
-    private Path path;
+    private final ProxyServer server;
+    private final Logger logger;
+    private final ConfigManager configManager;
+    private final Path dataDirectory;
 
     @Inject
-    private ProxyServer proxyServer;
+    public NetShield(ProxyServer server, Logger logger, @DataDirectory Path dataDirectory) {
+        this.server = server;
+        this.logger = logger;
+        this.dataDirectory = dataDirectory;
 
-    private ConfigManager configManager;
+        File configDir = dataDirectory.toFile();
+        if (!configDir.exists()) {
+            configDir.mkdirs();
+        }
 
-    @Subscribe
-    @SneakyThrows
-    public void onProxyInitialization(ProxyInitializeEvent event) {
+        this.configManager = new ConfigManager(configDir);
         instance = this;
+    }
 
-        File dataFolder = path.toFile();
-        configManager = new ConfigManager(dataFolder);
-
-        configManager.getConfig().node("KEY", "KICK_MESSAGE");
-
-        proxyServer.getEventManager().register(this, new PlayerListener());
+    @Subscribe
+    public void onProxyInitialization(ProxyInitializeEvent event) {
+        new NetShieldCommand();
+        server.getEventManager().register(this, new ConnectionListener(this));
+        log("NetShield has been enabled!");
     }
 
-    public void log(String s) {
-        logger.info(s);
+    public void log(String message) {
+        logger.info(message);
     }
-}
+}

velocity/src/main/java/today/netshield/velocity/commands/BaseCommand.java

@@ -0,0 +1,42 @@
+package today.netshield.velocity.commands;
+
+import com.velocitypowered.api.command.CommandManager;
+import com.velocitypowered.api.command.SimpleCommand;
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.TextComponent;
+import today.netshield.velocity.NetShield;
+import today.netshield.velocity.utils.CC;
+
+/**
+ * This code was made by jsexp, in case of any unauthorized
+ * use, at least please leave credits.
+ * Find more about me @ my <a href="https://github.com/hardcorefactions">GitHub</a> :D
+ * © 2025 - jsexp
+ */
+public abstract class BaseCommand implements SimpleCommand {
+    protected static final Component CONSOLE_SENDER = CC.colorize("&#ff0000Este comando sólo puede ser ejecutado desde el juego.");
+
+    public BaseCommand(String name) {
+        CommandManager manager = NetShield.getInstance().getServer().getCommandManager();
+        manager.register(
+                manager.metaBuilder(name)
+                        .plugin(NetShield.getInstance())
+                        .build(),
+                this);
+    }
+
+    public BaseCommand(String name, String... aliases) {
+        CommandManager manager = NetShield.getInstance().getServer().getCommandManager();
+        manager.register(
+                manager.metaBuilder(name)
+                        .aliases(aliases)
+                        .plugin(NetShield.getInstance())
+                        .build(),
+                this);
+    }
+
+    @Override
+    public void execute(Invocation invocation) {
+        invocation.source().sendMessage(CC.colorize("&#ff0000Este comando no ha sido creado correctamente."));
+    }
+}

velocity/src/main/java/today/netshield/velocity/commands/impl/NetShieldCommand.java

@@ -0,0 +1,28 @@
+package today.netshield.velocity.commands.impl;
+
+import today.netshield.velocity.NetShield;
+import today.netshield.velocity.commands.BaseCommand;
+import today.netshield.velocity.utils.CC;
+
+/**
+ * This code was made by jsexp, in case of any unauthorized
+ * use, at least please leave credits.
+ * Find more about me @ my <a href="https://github.com/hardcorefactions">GitHub</a> :D
+ * © 2025 - jsexp
+ */
+public class NetShieldCommand extends BaseCommand {
+    public NetShieldCommand() {
+        super("netshield", "nsreload");
+    }
+
+    @Override
+    public void execute(Invocation invocation) {
+        NetShield.getInstance().getConfigManager().reload();
+        invocation.source().sendMessage(CC.colorize("&#20bd78La configuración de NetShield ha sido recargada con éxito."));
+    }
+
+    @Override
+    public boolean hasPermission(Invocation invocation) {
+        return invocation.source().hasPermission("netshield.admin");
+    }
+}

velocity/src/main/java/today/netshield/velocity/config/ConfigManager.java

@@ -14,7 +14,7 @@
 @Getter
 public class ConfigManager {
     private final File dataFolder;
-    private final CommentedConfigurationNode config;
+    private CommentedConfigurationNode config;
 
     public ConfigManager(File dataFolder) {
         this.dataFolder = dataFolder;
@@ -47,4 +47,19 @@ public CommentedConfigurationNode loadConfig(String s) {
             throw new RuntimeException(e);
         }
     }
-}
+
+    /**
+     * Reloads the configuration from disk
+     *
+     * @return true if the reload was successful, false otherwise
+     */
+    public boolean reload() {
+        try {
+            this.config = this.loadConfig("config");
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+}

velocity/src/main/java/today/netshield/velocity/listeners/ConnectionListener.java

@@ -0,0 +1,42 @@
+package today.netshield.velocity.listeners;
+
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.event.connection.LoginEvent;
+import com.velocitypowered.api.proxy.Player;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.TimeUnit;
+
+import today.netshield.velocity.NetShield;
+import today.netshield.velocity.utils.Authentication;
+
+/**
+ * This code was made by jsexp, in case of any unauthorized
+ * use, at least please leave credits.
+ * Find more about me @ my <a href="https://github.com/hardcorefactions">GitHub</a> :D
+ * © 2025 - jsexp
+ */
+public class ConnectionListener {
+    private final NetShield plugin;
+    private final Authentication authentication;
+
+    private static final long AUTH_TIMEOUT_MS = 3000;
+
+    public ConnectionListener(NetShield plugin) {
+        this.plugin = plugin;
+        this.authentication = new Authentication(plugin);
+    }
+
+    @Subscribe(priority = Short.MAX_VALUE)
+    public void onLogin(LoginEvent event) {
+        Player player = event.getPlayer();
+        plugin.log("Player " + player.getUsername() + " is logging in, starting authentication check");
+
+        CompletableFuture<Void> authFuture = authentication.handleAsync(player);
+        authFuture.orTimeout(AUTH_TIMEOUT_MS, TimeUnit.MILLISECONDS)
+                .exceptionally(ex -> {
+                    plugin.log("Authentication timed out or failed for player " + player.getUsername() + ": " + ex.getMessage());
+                    return null;
+                });
+
+    }
+}