update

Author: AlphaMSq

build.gradle

@@ -30,11 +30,15 @@ dependencies {
     compileOnly('io.papermc.paper:paper-api:1.20.2-R0.1-SNAPSHOT')
     compileOnly('me.clip:placeholderapi:2.11.5')
     compileOnly('org.projectlombok:lombok:1.18.30')
-    compileOnly('com.github.nuvotifier.NuVotifier:nuvotifier-api:2.7.2')
     annotationProcessor('org.projectlombok:lombok:1.18.30')
 
     implementation('com.fasterxml.jackson.core:jackson-databind:2.15.2')
     implementation('com.fasterxml.jackson.core:jackson-core:2.15.2')
+    implementation('mysql:mysql-connector-java:8.0.33')
+
+    compileOnly "com.github.NuVotifier.NuVotifier:nuvotifier-api:2.7.2"
+    compileOnly "com.github.NuVotifier.NuVotifier:nuvotifier-common:2.7.2"
+    compileOnly "com.github.NuVotifier.NuVotifier:nuvotifier-bukkit:2.7.2"
 }
 
 task deleteUnusableJar(type: Delete) {

nuvotifier.jar

@@ -6,18 +6,25 @@
 import org.bukkit.plugin.java.JavaPlugin;
 
 import io.greitan.mineserv.commands.MineservCommand;
+import io.greitan.mineserv.methods.Methods;
 import io.greitan.mineserv.network.Network;
 import io.greitan.mineserv.utils.*;
 import java.io.IOException;
-
 import java.util.Objects;
 
+import com.vexsoftware.votifier.VoteHandler;
+import com.vexsoftware.votifier.NuVotifierBukkit;
+import org.bukkit.Server;
+import org.bukkit.plugin.Plugin;
+import org.bukkit.plugin.PluginManager;
+
 public class MineservRewards extends JavaPlugin {
     private static @Getter MineservRewards instance;
     private @Getter boolean isRunned = false;
     private @Getter String host = "";
     private @Getter int port = 0;
     private @Getter String secretKey = "";
+    private @Getter VoteHandler VoteHandler;
 
     private String lang;
 
@@ -35,6 +42,8 @@ public void onEnable() {
             new Placeholder(this).register();
         }
 
+        new Methods(this);
+        VoteHandler = getVoteHandler();
         this.reload();
     }
 
@@ -68,4 +77,16 @@ public Boolean connect(String host, int port, String secretKey) {
             }
         } else return false;
     }
+
+    public NuVotifierBukkit createVoteHandler() {
+        Server server = getServer();
+        PluginManager pluginManager = server.getPluginManager();
+        Plugin votifierPlugin = pluginManager.getPlugin("Votifier");
+
+        if (votifierPlugin instanceof NuVotifierBukkit) {
+            return (NuVotifierBukkit) votifierPlugin;
+        } else {
+            return null;
+        }
+    }
 }

src/main/java/io/greitan/mineserv/MineservRewards.java

@@ -0,0 +1,82 @@
+package io.greitan.mineserv.methods;
+
+import org.bukkit.Bukkit;
+
+import io.greitan.mineserv.MineservRewards;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+
+import com.vexsoftware.votifier.model.Vote;
+import com.vexsoftware.votifier.VoteHandler;
+import com.vexsoftware.votifier.net.VotifierSession;
+
+public class Methods {
+    private static MineservRewards plugin;
+
+    public Methods(MineservRewards plugin) {
+        Methods.plugin = plugin;
+    }
+
+    public static void runMethods(String project, String username, String timestamp, String signature) {
+        // Проверка, включен ли NuVotifier в конфиге
+        if (plugin.getConfig().getBoolean("config.methods.NuVotifier.enabled")) {
+            votifier(project, username, timestamp, signature);
+        }
+
+        // Проверка, включен ли Commands в конфиге
+        if (plugin.getConfig().getBoolean("config.methods.Commands.enabled")) {
+            commands(project, username, timestamp, signature);
+        }
+
+        // Проверка, включен ли MySqlRequests в конфиге
+        if (plugin.getConfig().getBoolean("config.methods.MySqlRequests.enabled")) {
+            mysql(project, username, timestamp, signature);
+        }
+    }
+
+    private static void votifier(String project, String username, String timestamp, String signature) {
+        Vote vote = new Vote("mineserv.top", username, "mineserv.top", timestamp);
+        VoteHandler voteHandler = plugin.getVoteHandler();
+        try {
+            voteHandler.onVoteReceived(vote, VotifierSession.ProtocolVersion.UNKNOWN, "mineserv.top");
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    private static void commands(String project, String username, String timestamp, String signature) {
+        List<String> commands = plugin.getConfig().getStringList("config.methods.Commands.commands");
+        executeCommands(commands, username);
+    }
+
+    private static void executeCommands(List<String> commands, String username) {
+        for (String command : commands) {
+            String processedCommand = command.replace("$player", username);
+            Bukkit.getServer().dispatchCommand(Bukkit.getConsoleSender(), processedCommand);
+        }
+    }
+
+    private static void mysql(String project, String username, String timestamp, String signature) {
+        String url = plugin.getConfig().getString("config.methods.MySqlRequests.url");
+        String database = plugin.getConfig().getString("config.methods.MySqlRequests.database");
+        String dbUsername = plugin.getConfig().getString("config.methods.MySqlRequests.username");
+        String dbPassword = plugin.getConfig().getString("config.methods.MySqlRequests.password");
+
+        List<String> sqlQueries = plugin.getConfig().getStringList("config.methods.MySqlRequests.sqlQuery");
+
+        try (Connection connection = DriverManager.getConnection(url + database, dbUsername, dbPassword)) {
+            for (String sqlQuery : sqlQueries) {
+                String processedQuery = sqlQuery.replace("$player", username);
+                try (PreparedStatement preparedStatement = connection.prepareStatement(processedQuery)) {
+                    preparedStatement.executeUpdate();
+                }
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+}

src/main/java/io/greitan/mineserv/methods/Methods.java

@@ -17,8 +17,7 @@
 import java.net.InetSocketAddress;
 import java.net.URLDecoder;
 
-import org.bukkit.Bukkit;
-
+import io.greitan.mineserv.methods.Methods;
 import io.greitan.mineserv.utils.*;
 
 public class Network {
@@ -64,7 +63,7 @@ public void handle(HttpExchange t) throws IOException {
                 if (isSuccess) {
                     response = "done";
                     t.sendResponseHeaders(200, response.length());
-                    main(project, username, timestamp, signature);
+                    Methods.runMethods(project, username, timestamp, signature);
                 } else {
                     response = "error";
                     t.sendResponseHeaders(500, response.length());
@@ -116,10 +115,6 @@ private static boolean checkSign(String project, String username, String timesta
         }
     }
 
-    private static void main(String project, String username, String timestamp, String signature) {
-        Bukkit.getLogger().info(project + username + timestamp + signature);
-    }
-
     private static Map<String, String> parse(String queryString) {
         Map<String, String> parameters = new HashMap<>();
 

src/main/java/io/greitan/mineserv/network/Network.java

@@ -2,17 +2,25 @@ config:
   debug: false
 
   host: "0.0.0.0"
-  port: 80
+  port: 9999
   secret-key: "key"
 
   methods:
     NuVotifier:
       enabled: false
-    СommandRun:
+    Commands:
       enabled: false
-      commands: []
+      commands: [
+        "give $player diamond 20"
+      ]
     MySqlRequests:
+      enabled: false
+      url: "jdbc:mysql://localhost:3306/"
+
       database: "mineserv"
       username: "mineserv"
       password: "mineserv"
-      sqlQuery: []
+
+      sqlQuery: [
+        "UPDATE `iconomy` SET `balance`=`balance`+100 WHERE `username`='$player'"
+      ]