apply ignore list to chat messages

Author: zefir-git

src/main/java/pro/cloudnode/smp/cloudnodemsg/CloudnodeMSG.java

@@ -9,6 +9,7 @@
 import pro.cloudnode.smp.cloudnodemsg.command.MessageCommand;
 import pro.cloudnode.smp.cloudnodemsg.command.ReplyCommand;
 import pro.cloudnode.smp.cloudnodemsg.command.UnIgnoreCommand;
+import pro.cloudnode.smp.cloudnodemsg.listener.AsyncChatListener;
 
 import java.util.Objects;
 
@@ -32,6 +33,8 @@ public void onEnable() {
         Objects.requireNonNull(getCommand("reply")).setExecutor(new ReplyCommand());
         Objects.requireNonNull(getCommand("ignore")).setExecutor(new IgnoreCommand());
         Objects.requireNonNull(getCommand("unignore")).setExecutor(new UnIgnoreCommand());
+
+        getServer().getPluginManager().registerEvents(new AsyncChatListener(), this);
     }
 
     @Override

src/main/java/pro/cloudnode/smp/cloudnodemsg/listener/AsyncChatListener.java

@@ -0,0 +1,37 @@
+package pro.cloudnode.smp.cloudnodemsg.listener;
+
+import io.papermc.paper.event.player.AsyncChatEvent;
+import net.kyori.adventure.audience.Audience;
+import org.bukkit.OfflinePlayer;
+import org.bukkit.Server;
+import org.bukkit.entity.Player;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.EventPriority;
+import org.bukkit.event.Listener;
+import org.jetbrains.annotations.NotNull;
+import pro.cloudnode.smp.cloudnodemsg.CloudnodeMSG;
+import pro.cloudnode.smp.cloudnodemsg.Permission;
+import pro.cloudnode.smp.cloudnodemsg.message.Message;
+
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Set;
+
+public final class AsyncChatListener implements Listener {
+    @EventHandler (priority = EventPriority.LOWEST)
+    public void onAsyncChat(final @NotNull AsyncChatEvent event) {
+        final @NotNull Set<@NotNull Audience> audience = event.viewers();
+        final @NotNull Iterator<@NotNull Audience> iterator = audience.iterator();
+        final @NotNull Player sender = event.getPlayer();
+
+        while (iterator.hasNext()) {
+            final @NotNull Audience a = iterator.next();
+            if (a instanceof final @NotNull Player player) {
+                final @NotNull Server server = CloudnodeMSG.getInstance().getServer();
+                final @NotNull HashSet<@NotNull OfflinePlayer> ignored = Message.getIgnored(player).stream().map(server::getOfflinePlayer).collect(HashSet::new, HashSet::add, HashSet::addAll);
+
+                if (ignored.contains(sender) && !sender.hasPermission(Permission.IGNORE_IMMUNE)) iterator.remove();
+            }
+        }
+    }
+}