Also ingore public chat messages when using /ignore (#19)

Also ingore public chat messages when using `/ignore`

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/Permission.java

@@ -26,5 +26,5 @@ public final class Permission {
     /**
      * Player's messages are immune to ignoring
      */
-    public final static @NotNull String IGNORE_IMMUNE = "cloudnodemsg.ignore.bypass";
+    public final static @NotNull String IGNORE_BYPASS = "cloudnodemsg.ignore.bypass";
 }

src/main/java/pro/cloudnode/smp/cloudnodemsg/command/IgnoreCommand.java

@@ -32,8 +32,8 @@ public boolean run(final @NotNull CommandSender sender, final @NotNull String la
     }
 
     public static boolean ignore(final @NotNull Player player, final @NotNull OfflinePlayer target) {
-        if (target.isOnline() && Objects.requireNonNull(target.getPlayer()).hasPermission(Permission.IGNORE_IMMUNE)) return new CannotIgnoreError(Optional.ofNullable(target.getName()).orElse("Unknown Player")).send(player);
-        if (!target.hasPlayedBefore()) return new NeverJoinedError(Optional.ofNullable(target.getName()).orElse("Unknown Player")).send(player);
+        if (target.isOnline() && Objects.requireNonNull(target.getPlayer()).hasPermission(Permission.IGNORE_BYPASS)) return new CannotIgnoreError(Optional.ofNullable(target.getName()).orElse("Unknown Player")).send(player);
+        if (!target.isOnline() && !target.hasPlayedBefore()) return new NeverJoinedError(Optional.ofNullable(target.getName()).orElse("Unknown Player")).send(player);
         Message.ignore(player, target);
         return sendMessage(player, CloudnodeMSG.getInstance().config().ignored(Optional.ofNullable(target.getName()).orElse("Unknown Player")));
     }

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_BYPASS)) iterator.remove();
+            }
+        }
+    }
+}

src/main/java/pro/cloudnode/smp/cloudnodemsg/message/Message.java

@@ -41,7 +41,7 @@ public void send() throws InvalidPlayerError {
         if (
                 (recipient.isOnline() && Message.isIgnored(Objects.requireNonNull(recipient.getPlayer()), sender))
                 &&
-                (sender.isOnline() && !Objects.requireNonNull(sender.getPlayer()).hasPermission(Permission.IGNORE_IMMUNE))
+                (sender.isOnline() && !Objects.requireNonNull(sender.getPlayer()).hasPermission(Permission.IGNORE_BYPASS))
         ) return;
         sendMessage(recipient, CloudnodeMSG.getInstance().config()
                 .incoming(senderUsername, recipientUsername, message));