intercept messages for DM channel from chat event

Author: zefir-git

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

@@ -11,15 +11,17 @@
 import org.jetbrains.annotations.NotNull;
 import pro.cloudnode.smp.cloudnodemsg.CloudnodeMSG;
 import pro.cloudnode.smp.cloudnodemsg.Permission;
+import pro.cloudnode.smp.cloudnodemsg.error.InvalidPlayerError;
 import pro.cloudnode.smp.cloudnodemsg.message.Message;
 
 import java.util.HashSet;
 import java.util.Iterator;
+import java.util.Optional;
 import java.util.Set;
 
 public final class AsyncChatListener implements Listener {
     @EventHandler (priority = EventPriority.LOWEST)
-    public void onAsyncChat(final @NotNull AsyncChatEvent event) {
+    public void ignore(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();
@@ -34,4 +36,25 @@ public void onAsyncChat(final @NotNull AsyncChatEvent event) {
             }
         }
     }
+
+    @EventHandler (priority = EventPriority.HIGHEST)
+    public void channels(final @NotNull AsyncChatEvent event) {
+        final @NotNull Player sender = event.getPlayer();
+        final @NotNull Optional<@NotNull OfflinePlayer> channelRecipient = Message.getChannel(sender);
+        if (channelRecipient.isEmpty()) return;
+        event.setCancelled(true);
+        final @NotNull Optional<@NotNull Player> recipient = channelRecipient.map(p -> p.isOnline() ? p.getPlayer() : null);
+        if (recipient.isEmpty()) {
+            Message.exitChannel(sender);
+            sender.sendMessage(CloudnodeMSG.getInstance().config().channelOffline(sender.getName(), Optional.ofNullable(channelRecipient.get().getName()).orElse("Unknown Player")));
+            return;
+        }
+
+        try {
+            new Message(sender, recipient.get(), event.message()).send();
+        }
+        catch (final @NotNull InvalidPlayerError e) {
+            e.log().send(sender);
+        }
+    }
 }