if you have multiple servers it now also links messages between those servers, & added the "score" command in Minecraft to allow any player to change scoreboards

Dainternetdude · Dainternetdude · commit 648fc5557cba · 2021-09-30T19:02:56.000-06:00
diff --git a/src/main/java/dain/CommandHandler.java b/src/main/java/dain/CommandHandler.java
@@ -0,0 +1,107 @@
+package dain;
+
+import dain.events.DiscordMessageReceiver;
+import net.dv8tion.jda.api.events.Event;
+import net.dv8tion.jda.api.events.message.MessageReceivedEvent;
+
+public class CommandHandler {
+
+    public static void handleDiscordCommand(String commandName, String[] parameters, MessageReceivedEvent event) {
+
+        switch (commandName) {
+            case "help":
+            case "h":
+                runDiscordHelp(event);
+                break;
+            case "score":
+            case "s":
+                runDiscordScore(event);
+                break;
+            case "kill":
+            case "k":
+                runDiscordKill(event);
+                break;
+            default:
+                event.getChannel().sendMessage("Unknown command. Try \"" + Settings.COMMAND_PREFIX + "help\" for options.").queue();
+                break;
+        }
+    }
+
+    public static void handleMcCommand(String commandName, String[] parameters, int serverId) {
+
+
+
+        switch (commandName) {
+            case "score":
+            case "s":
+                runMcScore(parameters, serverId);
+        }
+    }
+
+    private static void runMcScore(String[] parameters, int serverId) {
+        if (parameters.length == 1) {
+            if (parameters[0].equals("clear")) {
+                MinecraftChatBridge.sendCommandToServer("scoreboard objectives setDisplay sidebar", serverId);
+            } else {
+                MinecraftChatBridge.sendCommandToServer("scoreboard objectives setDisplay sidebar " + parameters[0], serverId);
+            }
+        } else if (parameters.length == 0) {
+            MinecraftChatBridge.sendCommandToServer("scoreboard objectives setDisplay sidebar", serverId);
+        } else {
+            MinecraftChatBridge.sendMessageAllServers("prodlem,,. Please provide a command in the form: " + Settings.COMMAND_PREFIX + "s [scoreboard name]");
+        }
+    }
+
+    private static void runDiscordKill(MessageReceivedEvent event) {
+        String messageAuthor = event.getAuthor().getName();
+        event.getChannel().sendMessage("*" + messageAuthor + " went*").queue();
+    }
+
+    private static void runDiscordScore(MessageReceivedEvent event) { //TODO
+        event.getChannel().sendMessage("soon:tm:").queue();
+
+        /*
+        int port = 21;
+
+        FTPClient ftpClient = new FTPClient();
+        try {
+
+            ftpClient.connect(Settings.SERVER_IP, port);
+            ftpClient.login(Settings.FTP_USERNAME, Settings.FTP_PASSWORD);
+            ftpClient.enterLocalPassiveMode();
+            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
+
+            String logFile = "/logs/latest.log";
+            File downloadFile1 = new File("latest.log");
+            OutputStream outputStream1 = new BufferedOutputStream(new FileOutputStream(downloadFile1));
+            boolean success = ftpClient.retrieveFile(logFile, outputStream1);
+            outputStream1.close();
+
+            event.getChannel().sendMessage("Getting file...").queue();
+
+            if (success) {
+                event.getChannel().sendMessage("File #1 has been downloaded successfully.").queue();
+            }
+
+        } catch (IOException ex) {
+            System.out.println("Error: " + ex.getMessage());
+            ex.printStackTrace();
+        } finally {
+            try {
+                if (ftpClient.isConnected()) {
+                    ftpClient.logout();
+                    ftpClient.disconnect();
+                }
+            } catch (IOException ex) {
+                ex.printStackTrace();
+            }
+        }
+         */
+    }
+
+    private static void runDiscordHelp(MessageReceivedEvent event) {
+        event.getChannel().sendMessage("There are approximately 3 commands.\n" +  //+ DiscordMessageReceiver.Commands.values().length + " commands.\n" +
+                "`" + Settings.COMMAND_PREFIX + "help" + "` = displays this message\n" +
+                "`" + Settings.COMMAND_PREFIX + "kill" + "` = kills the who sent the message").queue();
+    }
+}
diff --git a/src/main/java/dain/FTPHandler.java b/src/main/java/dain/FTPHandler.java
@@ -0,0 +1,51 @@
+package dain;
+
+import org.apache.commons.net.ftp.FTP;
+import org.apache.commons.net.ftp.FTPClient;
+
+import java.io.*;
+
+public class FTPHandler {
+
+    public static void grabFile(String file, int serverId) {
+
+        String filename = file.split("/")[file.split("/").length - 1]; //oops hyperslow but clean
+
+        int port = 21;
+        FTPClient ftpClient = new FTPClient();
+        try {
+
+            ftpClient.connect(Settings.SERVER_IPS[serverId], port);
+            ftpClient.login(Settings.FTP_USERNAMES[serverId], Settings.FTP_PASSWORDS[serverId]);
+            ftpClient.enterLocalPassiveMode();
+            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
+
+            //sendMessageAllChannels("Getting file on thread " + serverId);
+
+            File downloadFile1 = new File(serverId + filename);
+            OutputStream outputStream1 = new BufferedOutputStream(new FileOutputStream(downloadFile1));
+            boolean success = ftpClient.retrieveFile(file, outputStream1);
+            outputStream1.close();
+
+            /*
+            if (success) {
+                sendMessageAllChannels("`latest.log` has been downloaded successfully on thread " + serverId);
+            } else {
+                sendMessageAllChannels("issue downloading file on thread " + serverId);
+            }
+             */
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (ftpClient.isConnected()) {
+                    ftpClient.logout();
+                    ftpClient.disconnect();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}
diff --git a/src/main/java/dain/MinecraftChatBridge.java b/src/main/java/dain/MinecraftChatBridge.java
@@ -1,12 +1,16 @@
 package dain;
 
+import dain.events.DiscordMessageReceiver;
 import net.dv8tion.jda.api.JDA;
+import net.dv8tion.jda.api.entities.Message;
 import net.dv8tion.jda.api.entities.TextChannel;
+import net.kronos.rkon.core.Rcon;
+import net.kronos.rkon.core.ex.AuthenticationException;
 import org.apache.commons.net.ftp.FTP;
 import org.apache.commons.net.ftp.FTPClient;
 
 import java.io.*;
-import java.net.ConnectException;
+import java.util.Locale;
 import java.util.Random;
 import java.util.Scanner;
 
@@ -40,51 +44,10 @@ public void run() {
         }
     }
 
-    public void refreshLogFile() {
-
-        int port = 21;
-        FTPClient ftpClient = new FTPClient();
-        try {
-
-            ftpClient.connect(Settings.SERVER_IPS[id], port);
-            ftpClient.login(Settings.FTP_USERNAMES[id], Settings.FTP_PASSWORDS[id]);
-            ftpClient.enterLocalPassiveMode();
-            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
-
-            //sendMessageAllChannels("Getting file on thread " + id);
-
-            String logFile = "/logs/latest.log";
-            File downloadFile1 = new File(id + "latest.log");
-            OutputStream outputStream1 = new BufferedOutputStream(new FileOutputStream(downloadFile1));
-            boolean success = ftpClient.retrieveFile(logFile, outputStream1);
-            outputStream1.close();
-
-            /*
-            if (success) {
-                sendMessageAllChannels("`latest.log` has been downloaded successfully on thread " + id);
-            } else {
-                sendMessageAllChannels("issue downloading file on thread " + id);
-            }
-             */
-
-        } catch (IOException e) {
-            e.printStackTrace();
-        } finally {
-            try {
-                if (ftpClient.isConnected()) {
-                    ftpClient.logout();
-                    ftpClient.disconnect();
-                }
-            } catch (IOException e) {
-                e.printStackTrace();
-            }
-        }
-    }
-
     public void sendNewMessages() {
         //sendMessageAllChannels("thread " + id + " sending new messages");
 
-        refreshLogFile();
+        FTPHandler.grabFile("/logs/latest.log", id);
         try {
             File file = new File(id + "latest.log");
             Scanner myReader = new Scanner(file);
@@ -108,13 +71,26 @@ public void sendNewMessages() {
             return;
         }
 
-        lastLines[id] = lastLines[id].replaceAll("(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)", "[IP ADDRESS REDACTED]");
+        String processedLine = processLine(lastLines[id]);
+
+        sendMessageAllChannels(processedLine);
+    }
+
+    private void sendMessageAllChannels(String message) {
+        for (int i = 0; i < Settings.DISCORD_CHANNEL_IDS.length; i++) {
+            channels[i].sendMessage(message).queue();
+        }
+    }
+
+    private String processLine(String line) {
+
+        line = line.replaceAll("(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)", "[IP ADDRESS REDACTED]");
         // ^above replaces ipv4 IP addresses with "[IP ADDRESS REDACTED]"
 
         //break the message up into an array of strings for each word
-        String[] lastLineArray = lastLines[id].split(" ");
+        String[] lineArray = line.split(" ");
 
-        //change @ into mentions
+        //todo change @ into mentions
         /*
         for (int i = 0; i < lastLineArray.length; i++) {
             if (lastLineArray[i].startsWith("@")) {
@@ -124,35 +100,120 @@ public void sendNewMessages() {
             }
         }*/
 
+        //todo change :emoji: to emojis
+
         // make the <name> part of chat messages bold
         boolean isChatMessage;
-        if (lastLineArray[0].startsWith("<") && lastLineArray[0].endsWith(">")) {
-            lastLineArray[0] = "**" + lastLineArray[0] + "**";
+        String author = "";
+        if (lineArray[0].startsWith("<") && lineArray[0].endsWith(">")) {
+            lineArray[0] = "**" + lineArray[0] + "**";
             isChatMessage = true;
+            author = lineArray[0].substring(1, lineArray[0].length() - 2);
+
+            if (lineArray[1].startsWith(">")) {
+
+                String[] parameterArray = new String[lineArray.length - 2];
+                for (int i = 2; i < lineArray.length; i++) {
+                    parameterArray[i - 2] = lineArray[i];
+                }
+
+                CommandHandler.handleMcCommand(lineArray[1].substring(1).toLowerCase(), parameterArray, id);
+            }
         } else isChatMessage = false;
 
         //join the array of strings back up to a complete message
-        lastLines[id] = lastLineArray[0];
-        for (int i = 1; i < lastLineArray.length; i++) {
-            lastLines[id] = lastLines[id] + " " + lastLineArray[i];
+        line = lineArray[0];
+        String message = "";
+        for (int i = 1; i < lineArray.length; i++) {
+            line = line + " " + lineArray[i];
+            message = message + lineArray[i] + " ";
         }
 
         //make non-chat messages bold
         if (!isChatMessage) {
-            lastLines[id] = "**" + lastLines[id] + "**";
+            message = line;
+            line = "**" + line + "**";
         }
 
         //say if its coming from smp or cmp
-        lastLines[id] = "[" + Settings.SERVER_NAMES[id] + "] " + lastLines[id];
+        line = "[" + Settings.SERVER_NAMES[id] + "] " + line;
 
-        //scoreboard junk
+        if (isChatMessage) {
+            sendMessageAllOtherServers(author, message);
+        } else {
+            sendMessageAllOtherServers(message);
+        }
 
-        sendMessageAllChannels(lastLines[id]);
+        return line;
     }
 
-    private void sendMessageAllChannels(String message) {
-        for (int i = 0; i < Settings.DISCORD_CHANNEL_IDS.length; i++) {
-            channels[i].sendMessage(message).queue();
+    private void sendMessageAllOtherServers(String author, String message) {
+        for (int i = 0; i < Settings.SERVER_IPS.length; i++) {
+            if (i != id) {
+                sendMessageToServer(author, message, i);
+            }
+        }
+    }
+
+    private void sendMessageAllOtherServers(String message) {
+        for (int i = 0; i < Settings.SERVER_IPS.length; i++) {
+            if (i != id) {
+                sendMessageToServer(message, i);
+            }
+        }
+    }
+
+    public static void sendMessageAllServers(String message) {
+        for (int i = 0; i < Settings.SERVER_IPS.length; i++) {
+            sendMessageToServer(message, i);
+        }
+    }
+
+    public static void sendMessageToMc(Message message) {
+        //TODO replace emojis with :emoji_name:
+
+        //TODO replace attachments with text
+
+        String command = generateCommand(message.getAuthor().getName(), message.getContentRaw());
+
+        for (int id = 0; id < Settings.SERVER_IPS.length; id++) {
+            sendCommandToServer(command, id);
+        }
+    }
+
+    public static void sendMessageToServer(String author, String message, int serverId) {
+
+        String command = generateCommand(author, message);
+
+        sendCommandToServer(command, serverId);
+    }
+
+    public static void sendMessageToServer(String message, int serverId) {
+
+        String command = generateCommand(message);
+
+        sendCommandToServer(command, serverId);
+    }
+
+    private static String generateCommand(String author, String message) {
+        return "tellraw @a [\"\",{\"text\":\"<\"},{\"text\":\"@\",\"color\":\"gray\"}, {\"text\":\"" + author + "\",\"color\":\"white\"},{\"text\":\"> " + message + "\"}]";
+    }
+
+    private static String generateCommand(String message) {
+        return "tellraw @a \"" + message + "\"";
+    }
+
+    public static void sendCommandToServer(String command, int serverId) {
+        try {
+            Rcon rcon = new Rcon(Settings.SERVER_IPS[serverId], Integer.decode(Settings.RCON_PORTS[serverId]), Settings.RCON_PASSWORDS[serverId].getBytes());
+            rcon.command(command);
+            rcon.disconnect();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } catch (AuthenticationException e) {
+            e.printStackTrace();
         }
     }
+
+
 }
diff --git a/src/main/java/dain/events/DiscordMessageReceiver.java b/src/main/java/dain/events/DiscordMessageReceiver.java
