progress on requests

api/src/main/java/com/alttd/chat/config/Config.java

@@ -543,12 +543,4 @@ public final class Config {
         NICK_ALLOWED_COLOR_CODESLIST = getList("nicknames.allowed-color-codes", List.of("&0", "&1", "&2", "&3", "&4", "&5", "&6", "&7", "&8", "&9", "&a", "&b", "&c", "&d", "&e", "&f", "&r"));
         NICK_CURRENT = getString("nicknames.messages.nick-current", NICK_CURRENT);
     }
-
-    public static int DEATH_MESSAGES_MAX_PER_PERIOD = 5;
-    public static int DEATH_MESSAGES_LIMIT_PERIOD_MINUTES = 15;
-
-    private static void deathMessagesSettings() {
-        DEATH_MESSAGES_MAX_PER_PERIOD = getInt("death-messages.max-per-period", DEATH_MESSAGES_MAX_PER_PERIOD);
-        DEATH_MESSAGES_LIMIT_PERIOD_MINUTES = getInt("death-messages.limit-period-minutes", DEATH_MESSAGES_LIMIT_PERIOD_MINUTES);
-    }
 }

api/src/main/java/com/alttd/chat/config/RegexConfig.java

@@ -178,18 +178,13 @@ public final class RegexConfig {
                 String regex = entry.getValue().node("regex").getString();
                 String replacement = entry.getValue().node("replacement").getString();
                 List<String> exclusions = entry.getValue().node("exclusions").getList(io.leangen.geantyref.TypeToken.get(String.class), new ArrayList<>());
-                boolean disableInPrivate = false;
-                ConfigurationNode node = entry.getValue().node("disable-in-private");
-                if (node != null) {
-                    disableInPrivate = node.getBoolean();
-                }
                 if (type == null || type.isEmpty() || regex == null || regex.isEmpty()) {
                     ALogger.warn("Filter: " + name + " was set up incorrectly");
                 } else {
                     if (replacement == null || replacement.isEmpty()) {
                         replacement = name;
                     }
-                    ChatFilter chatFilter = new ChatFilter(name, type, regex, replacement, exclusions, disableInPrivate);
+                    ChatFilter chatFilter = new ChatFilter(name, type, regex, replacement, exclusions);
                     RegexManager.addFilter(chatFilter);
                 }
             } catch(SerializationException ex) {

api/src/main/java/com/alttd/chat/managers/RegexManager.java

@@ -8,13 +8,10 @@ import com.alttd.chat.objects.ModifiableString;
 import com.alttd.chat.util.ALogger;
 import net.luckperms.api.cacheddata.CachedPermissionData;
 import net.luckperms.api.model.user.User;
-import org.bukkit.Bukkit;
-import org.bukkit.entity.Player;
 
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
-import java.util.function.Consumer;
 import java.util.regex.Pattern;
 
 public class RegexManager {
@@ -46,24 +43,17 @@ public class RegexManager {
     }
 
     public static boolean filterText(String playerName, UUID uuid, ModifiableString modifiableString, String channel) { // TODO loop all objects in the list and check if they violate based on the MATCHER
-        return filterText(playerName, uuid, modifiableString, true, channel, null);
+        return filterText(playerName, uuid, modifiableString, true, channel);
     }
 
     public static boolean filterText(String playerName, UUID uuid, ModifiableString modifiableString, boolean matcher, String channel) {
-        return filterText(playerName, uuid, modifiableString, matcher, channel, null);
-    }
-
-    public static boolean filterText(String playerName, UUID uuid, ModifiableString modifiableString, boolean matcher, String channel, Consumer<FilterType> filterAction) {
         User user = ChatAPI.get().getLuckPerms().getUserManager().getUser(uuid);
         if (user == null) {
             ALogger.warn("Tried to check chat filters for a user who doesn't exist in LuckPerms");
             return false;
         }
         CachedPermissionData permissionData = user.getCachedData().getPermissionData();
-        boolean isPrivate = channel.equals("party");
         for(ChatFilter chatFilter : chatFilters) {
-            if (isPrivate && chatFilter.isDisabledInPrivate())
-                continue;
             switch (chatFilter.getType()) {
                 case CHAT:
                     break;
@@ -84,25 +74,6 @@ public class RegexManager {
                         chatFilter.replaceMatcher(modifiableString);
                     }
                     break;
-                case PUNISH:
-                    if (permissionData.checkPermission("chat.bypass-punish").asBoolean())
-                        break;
-                    if (chatFilter.matches(modifiableString)) {
-                        ALogger.info(playerName + " triggered the punish filter for " + chatFilter.getName()
-                                + " with: " + modifiableString.string() + ".");
-
-                        if (filterAction == null){
-                            ALogger.info("No filterAction was provided, not doing anything");
-                            return false;
-                        }
-                        Player player = Bukkit.getPlayer(uuid);
-                        if (player == null) {
-                            ALogger.warn("Tried to punish a player who triggered the filter, but the player is offline.");
-                            return false;
-                        }
-                        filterAction.accept(FilterType.PUNISH);
-                        return false;
-                    }
             }
         }
         return true;

api/src/main/java/com/alttd/chat/objects/ChatFilter.java

@@ -17,16 +17,14 @@ public class ChatFilter {
     private final Pattern pattern;
     private final String replacement;
     private final List<String> exclusions;
-    private final boolean disableInPrivate;
 
-    public ChatFilter(String name, String type, String regex, String replacement, List<String> exclusions, boolean disableInPrivate) {
+    public ChatFilter(String name, String type, String regex, String replacement, List<String> exclusions) {
         this.name = name;
         this.filterType = FilterType.getType(type);
         this.regex = regex;
         this.pattern = Pattern.compile(getRegex(), Pattern.CASE_INSENSITIVE);
         this.replacement = replacement;
         this.exclusions = exclusions;
-        this.disableInPrivate = disableInPrivate;
     }
 
     public String getName() {
@@ -49,10 +47,6 @@ public class ChatFilter {
         return this.exclusions;
     }
 
-    public boolean isDisabledInPrivate() {
-        return disableInPrivate;
-    }
-
     public boolean matches(ModifiableString filterableString) {
         String input = filterableString.string();
         Matcher matcher = pattern.matcher(input);

api/src/main/java/com/alttd/chat/objects/FilterType.java

@@ -5,8 +5,7 @@ public enum FilterType {
     EMOTE("emote"),
     CHAT("chat"),
     REPLACEMATCHER("replacematcher"),
-    BLOCK("block"),
-    PUNISH("punish");
+    BLOCK("block");
 
     private final String name;
 

api/src/main/java/com/alttd/chat/util/ALogger.java

@@ -16,10 +16,6 @@ public class ALogger {
         logger.warn(message);
     }
 
-    public static void warn(String message, Throwable throwable) {
-        logger.warn(message, throwable);
-    }
-
     public static void info(String message) {
         logger.info(message);
     }
@@ -27,8 +23,4 @@ public class ALogger {
     public static void error(String message) {
         logger.error(message);
     }
-
-    public static void error(String message, Throwable throwable) {
-        logger.error(message, throwable);
-    }
 }

galaxy/src/main/java/com/alttd/chat/ChatPlugin.java

@@ -13,6 +13,7 @@ import com.alttd.chat.nicknames.Nicknames;
 import com.alttd.chat.nicknames.NicknamesEvents;
 import com.alttd.chat.objects.channels.Channel;
 import com.alttd.chat.objects.channels.CustomChannel;
+import com.alttd.chat.requests.RequestHandler;
 import com.alttd.chat.util.ALogger;
 import com.alttd.chat.util.Utility;
 import org.bukkit.Bukkit;
@@ -29,6 +30,7 @@ public class ChatPlugin extends JavaPlugin {
 
     private ChatAPI chatAPI;
     private ChatHandler chatHandler;
+    private RequestHandler requestHandler;
 
     private String messageChannel;
     private ServerConfig serverConfig;
@@ -40,6 +42,8 @@ public class ChatPlugin extends JavaPlugin {
         chatAPI = new ChatImplementation();
         chatHandler = new ChatHandler();
         DatabaseConnection.initialize();
+        requestHandler = new RequestHandler();
+        requestHandler.loadRequests();
         serverConfig = new ServerConfig(Bukkit.getServerName());
         registerListener(new PlayerListener(serverConfig), new ChatListener(), new BookListener());
         if(serverConfig.GLOBALCHAT) {
@@ -105,6 +109,10 @@ public class ChatPlugin extends JavaPlugin {
         return chatHandler;
     }
 
+    public RequestHandler getRequestHandler() {
+        return requestHandler;
+    }
+
     public boolean serverGlobalChatEnabled() {
         return serverConfig.GLOBALCHAT;
     }

galaxy/src/main/java/com/alttd/chat/listeners/ChatListener.java

@@ -5,12 +5,13 @@ import com.alttd.chat.config.Config;
 import com.alttd.chat.handler.ChatHandler;
 import com.alttd.chat.managers.ChatUserManager;
 import com.alttd.chat.managers.RegexManager;
-import com.alttd.chat.objects.*;
+import com.alttd.chat.objects.ChatFilter;
+import com.alttd.chat.objects.ChatUser;
+import com.alttd.chat.objects.ModifiableString;
+import com.alttd.chat.objects.Toggleable;
 import com.alttd.chat.util.ALogger;
 import com.alttd.chat.util.GalaxyUtility;
 import com.alttd.chat.util.Utility;
-import com.google.common.io.ByteArrayDataOutput;
-import com.google.common.io.ByteStreams;
 import io.papermc.paper.event.player.AsyncChatCommandDecorateEvent;
 import io.papermc.paper.event.player.AsyncChatDecorateEvent;
 import io.papermc.paper.event.player.AsyncChatEvent;
@@ -86,18 +87,7 @@ public class ChatListener implements Listener {
         ModifiableString modifiableString = new ModifiableString(input);
 
          // todo a better way for this
-        if(!RegexManager.filterText(player.getName(), player.getUniqueId(), modifiableString, true, "chat", filterType -> {
-            if (!filterType.equals(FilterType.PUNISH)) {
-                ALogger.warn("Received another FilterType than punish when filtering chat and executing a filter action");
-                return;
-            }
-            ByteArrayDataOutput out = ByteStreams.newDataOutput();
-            out.writeUTF("punish");
-            out.writeUTF(player.getName());
-            out.writeUTF(player.getUniqueId().toString());
-            out.writeUTF(modifiableString.string());
-            player.sendPluginMessage(ChatPlugin.getInstance(), Config.MESSAGECHANNEL, out.toByteArray());
-        })) {
+        if(!RegexManager.filterText(player.getName(), player.getUniqueId(), modifiableString, "chat")) {
             event.setCancelled(true);
             GalaxyUtility.sendBlockedNotification("Language", player,
                     modifiableString.component(),

galaxy/src/main/java/com/alttd/chat/listeners/PlayerListener.java

@@ -11,25 +11,15 @@ import com.alttd.chat.objects.Toggleable;
 import com.alttd.chat.util.GalaxyUtility;
 import com.alttd.chat.util.Utility;
 import net.kyori.adventure.text.Component;
-import net.kyori.adventure.text.format.Style;
-import net.kyori.adventure.text.format.TextColor;
-import net.kyori.adventure.text.format.TextDecoration;
 import net.kyori.adventure.text.minimessage.MiniMessage;
 import net.kyori.adventure.text.minimessage.tag.resolver.Placeholder;
 import org.bukkit.entity.Player;
 import org.bukkit.event.EventHandler;
-import org.bukkit.event.EventPriority;
 import org.bukkit.event.Listener;
 import org.bukkit.event.block.SignChangeEvent;
-import org.bukkit.event.entity.PlayerDeathEvent;
 import org.bukkit.event.player.PlayerJoinEvent;
 import org.bukkit.event.player.PlayerQuitEvent;
-import org.jetbrains.annotations.NotNull;
 
-import java.time.Instant;
-import java.time.temporal.ChronoUnit;
-import java.util.HashMap;
-import java.util.Stack;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
@@ -96,29 +86,4 @@ public class PlayerListener implements Listener {
         }
     }
 
-    private final HashMap<UUID, Stack<Instant>> sendPlayerDeaths = new HashMap<>();
-    @EventHandler(ignoreCancelled = true, priority = EventPriority.HIGHEST)
-    public void onPlayerDeath(@NotNull PlayerDeathEvent event) {
-        UUID uuid = event.getPlayer().getUniqueId();
-        Stack<Instant> playerDeathsStack = sendPlayerDeaths.computeIfAbsent(uuid, key -> new Stack<>());
-        Instant cutOff = Instant.now().minus(Config.DEATH_MESSAGES_LIMIT_PERIOD_MINUTES, ChronoUnit.MINUTES);
-
-        while (playerDeathsStack.peek().isBefore(cutOff)) {
-            playerDeathsStack.pop();
-        }
-
-        if (playerDeathsStack.size() > Config.DEATH_MESSAGES_MAX_PER_PERIOD || serverConfig.MUTED) {
-            event.deathMessage(Component.empty());
-            return;
-        } else {
-            Component component = event.deathMessage();
-            if (component != null) {
-                component = Component.text("* ").append(component);
-                component = component.style(Style.style(TextColor.color(82, 80, 77), TextDecoration.ITALIC));
-                event.deathMessage(component);
-            }
-        }
-        playerDeathsStack.push(Instant.now());
-    }
-
 }

galaxy/src/main/java/com/alttd/chat/requests/NickNameRequest.java

@@ -0,0 +1,23 @@
+package com.alttd.chat.requests;
+
+import java.util.UUID;
+
+public class NickNameRequest extends Request {
+
+    public NickNameRequest(UUID requester, String request) {
+        super(requester, request);
+
+        this.requestType = RequestType.NICKNAME;
+    }
+
+    public NickNameRequest(UUID requester, String request, boolean completed, UUID completedBy, long dateRequested, long dateCompleted) {
+        super(requester, request, completed, completedBy, dateRequested, dateCompleted);
+
+        this.requestType = RequestType.NICKNAME;
+    }
+    @Override
+    public boolean processRequest(UUID processor) {
+        return false;
+    }
+
+}

galaxy/src/main/java/com/alttd/chat/requests/PrefixRequest.java

@@ -0,0 +1,24 @@
+package com.alttd.chat.requests;
+
+import java.util.UUID;
+
+public class PrefixRequest extends Request{
+
+    public PrefixRequest(UUID requester, String request) {
+        super(requester, request);
+
+        this.requestType = RequestType.PREFIX;
+    }
+
+    public PrefixRequest(UUID requester, String request, boolean completed, UUID completedBy, long dateRequested, long dateCompleted) {
+        super(requester, request, completed, completedBy, dateRequested, dateCompleted);
+
+        this.requestType = RequestType.NICKNAME;
+    }
+
+    @Override
+    public boolean processRequest(UUID processor) {
+        return false;
+    }
+
+}

galaxy/src/main/java/com/alttd/chat/requests/Request.java

@@ -0,0 +1,69 @@
+package com.alttd.chat.requests;
+
+import org.bukkit.Bukkit;
+
+import java.util.Date;
+import java.util.UUID;
+
+public abstract class Request {
+
+    protected UUID requester;
+    protected RequestType requestType;
+    protected String serverName;
+    protected String request;
+    protected boolean completed;
+    protected UUID completedBy;
+    protected long dateRequested;
+    protected long dateCompleted;
+
+    Request(UUID requester, String request) {
+        this.requester = requester;
+        this.request = request;
+        this.serverName = Bukkit.getServerName();
+        this.dateRequested = new Date().getTime();
+        saveRequest();
+    }
+
+    Request(UUID requester, String request, boolean completed, UUID completedBy, long dateRequested, long dateCompleted) {
+        this.requester = requester;
+        this.request = request;
+        this.completed = completed;
+        this.completedBy = completedBy;
+        this.dateRequested = dateRequested;
+        this.dateCompleted = dateCompleted;
+    }
+
+    public static Request of(UUID requester, RequestType requestType, String request) {
+        return switch (requestType) {
+            case PREFIX -> new PrefixRequest(requester, request);
+            case NICKNAME -> new NickNameRequest(requester, request);
+        };
+    }
+
+    public static Request load(UUID requester, RequestType requestType, String request, boolean completed, UUID completedBy, long dateRequested, long dateCompleted) {
+        return switch (requestType) {
+            case PREFIX -> new PrefixRequest(requester, request, completed, completedBy, dateRequested, dateCompleted);
+            case NICKNAME -> new NickNameRequest(requester, request, completed, completedBy, dateRequested, dateCompleted);
+        };
+    }
+
+    public boolean processRequest(UUID completedBy) {
+        completeRequest(completedBy);
+        return true;
+    }
+
+    public boolean isCompleted() {
+        return completed;
+    }
+
+    void completeRequest(UUID completedBy) {
+        this.completed = true;
+        this.completedBy = completedBy;
+        this.dateCompleted = new Date().getTime();
+        saveRequest();
+    }
+
+    public void saveRequest() {
+        // upsert into database
+    }
+}

galaxy/src/main/java/com/alttd/chat/requests/RequestHandler.java

@@ -0,0 +1,61 @@
+package com.alttd.chat.requests;
+
+import com.alttd.chat.config.Config;
+import com.alttd.chat.database.DatabaseConnection;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.UUID;
+
+public class RequestHandler {
+
+    private final List<Request> requests;
+
+    public RequestHandler() {
+        requests = new ArrayList<>();
+    }
+
+    public boolean addRequest(Request request) {
+        return requests.add(request);
+    }
+
+    public boolean removeRequest(Request request) {
+        return requests.remove(request);
+    }
+
+    public List<Request> getRequests() {
+        return requests;
+    }
+
+    public void loadRequests() {
+        long time = new Date().getTime() - Config.NICK_WAIT_TIME;
+        // Load all requests that have not been completed yet
+        String query = "SELECT * FROM requests WHERE completed=false and (datechanged = 0 or datechanged > " + time + ")";
+
+        try {
+            Connection connection = DatabaseConnection.getConnection();
+            ResultSet resultSet = connection.prepareStatement(query).executeQuery();
+
+            while (resultSet.next()) {
+                UUID requester = UUID.fromString(resultSet.getString("requester"));
+                RequestType requestType = RequestType.valueOf(resultSet.getString("requesttype"));
+                String requestString = resultSet.getString("request");
+                boolean completed = resultSet.getBoolean("completed");
+                UUID completedby = UUID.fromString(resultSet.getString("completedby"));
+                long dateRequested = resultSet.getLong("daterequested");
+                long dateCompleted = resultSet.getLong("datecompleted");
+
+                Request request = Request.load(requester, requestType, requestString, completed, completedby, dateRequested, dateCompleted);
+                addRequest(request);
+            }
+
+        } catch (SQLException exception) {
+            exception.printStackTrace();
+        }
+    }
+
+}

galaxy/src/main/java/com/alttd/chat/requests/RequestType.java

@@ -0,0 +1,8 @@
+package com.alttd.chat.requests;
+
+public enum RequestType {
+
+    NICKNAME,
+    PREFIX
+
+}

galaxy/src/main/java/com/alttd/chat/requests/RequestsGui.java

@@ -0,0 +1,22 @@
+package com.alttd.chat.requests;
+
+import org.bukkit.Bukkit;
+import org.bukkit.inventory.Inventory;
+import org.bukkit.inventory.InventoryHolder;
+import org.jetbrains.annotations.NotNull;
+
+public class RequestsGui implements InventoryHolder {
+
+    private final Inventory inventory;
+    private final int inventorySize = 54;
+
+    RequestsGui() {
+        inventory = Bukkit.createInventory(this, inventorySize, "A title");
+    }
+
+    @Override
+    public @NotNull Inventory getInventory() {
+        return inventory;
+    }
+
+}

velocity/src/main/java/com/alttd/velocitychat/listeners/PluginMessageListener.java

@@ -4,14 +4,11 @@ import com.alttd.chat.managers.ChatUserManager;
 import com.alttd.chat.objects.ChatUser;
 import com.alttd.chat.objects.channels.CustomChannel;
 import com.alttd.chat.util.ALogger;
-import com.alttd.proxydiscordlink.DiscordLink;
-import com.alttd.proxydiscordlink.lib.net.dv8tion.jda.api.EmbedBuilder;
 import com.alttd.velocitychat.VelocityChat;
 import com.google.common.io.ByteArrayDataInput;
 import com.google.common.io.ByteStreams;
 import com.velocitypowered.api.event.Subscribe;
 import com.velocitypowered.api.event.connection.PluginMessageEvent;
-import com.velocitypowered.api.proxy.ConsoleCommandSource;
 import com.velocitypowered.api.proxy.Player;
 import com.velocitypowered.api.proxy.ProxyServer;
 import com.velocitypowered.api.proxy.ServerConnection;
@@ -19,10 +16,8 @@ import com.velocitypowered.api.proxy.messages.ChannelIdentifier;
 import com.velocitypowered.api.proxy.server.RegisteredServer;
 import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer;
 
-import java.awt.*;
 import java.io.ByteArrayInputStream;
 import java.io.DataInputStream;
-import java.util.Optional;
 import java.util.UUID;
 
 public class PluginMessageListener {
@@ -98,20 +93,6 @@ public class PluginMessageListener {
                 proxy.getAllServers().forEach(registeredServer ->
                         registeredServer.sendPluginMessage(VelocityChat.getPlugin().getChannelIdentifier(), event.getData()));
             }
-            case "punish" -> {
-                String playerName = in.readUTF();
-                ProxyServer proxy = VelocityChat.getPlugin().getProxy();
-                ConsoleCommandSource consoleCommandSource = proxy.getConsoleCommandSource();
-                proxy.getCommandManager().executeAsync(consoleCommandSource, String.format("ban %s Automatic ban, please appeal if you feel review is needed.", playerName));
-                ALogger.info(String.format("Auto banned %s due to violating the `punish` filter.", playerName));
-
-                EmbedBuilder embedBuilder = new EmbedBuilder();
-                embedBuilder.setTitle("Automatic ban through the chat filter");
-                embedBuilder.setAuthor(playerName, null, "https://crafatar.com/avatars/" + in.readUTF() + "?overlay");
-                embedBuilder.setDescription(String.format("`%s`\n\n Auto permanent ban\n\n Auto banned for violating the `punish` chat filter. This could be a false positive! Their message was\n||%s||", playerName, in.readUTF()));
-                embedBuilder.setColor(Color.RED);
-                DiscordLink.getPlugin().getBot().sendEmbedToDiscord(514922317923614728L, embedBuilder, -1);
-            }
             default -> {
                 VelocityChat.getPlugin().getLogger().info("server " + event.getSource());
                 ProxyServer proxy = VelocityChat.getPlugin().getProxy();