command to create channel

Author: zefir-git

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

@@ -1,5 +1,6 @@
 package pro.cloudnode.smp.cloudnodemsg.command;
 
+import org.bukkit.OfflinePlayer;
 import org.bukkit.command.CommandSender;
 import org.bukkit.entity.Player;
 import org.jetbrains.annotations.NotNull;
@@ -18,21 +19,34 @@
 import java.util.Optional;
 
 public final class MessageCommand extends Command {
-    public static final @NotNull String usage = "<player> <message>";
+    public static final @NotNull String usage = "<player> [message]";
+    public static final @NotNull String usageConsole = "<player> <message>";
 
     @Override
     public boolean run(final @NotNull CommandSender sender, final @NotNull String label, @NotNull String @NotNull [] args) {
         if (!sender.hasPermission(Permission.USE)) return new NoPermissionError().send(sender);
-        if (args.length == 0) return sendMessage(sender, CloudnodeMSG.getInstance().config().usage(label, usage));
-        if (args.length == 1) return sendMessage(sender, CloudnodeMSG.getInstance().config()
-                .usage(label, usage.replace("<player>", args[0])));
+        if (args.length == 0) {
+            return sendMessage(sender, CloudnodeMSG.getInstance().config().usage(label, sender instanceof Player ? usage : usageConsole));
+        }
+        if (args.length == 1 && !(sender instanceof Player)) return sendMessage(sender, CloudnodeMSG.getInstance().config()
+                    .usage(label, usageConsole.replace("<player>", args[0])));
 
         final @NotNull Optional<@NotNull Player> recipient = Optional.ofNullable(CloudnodeMSG.getInstance().getServer()
                 .getPlayer(args[0]));
         if (recipient.isEmpty() || (CloudnodeMSG.isVanished(recipient.get()) && !sender.hasPermission(Permission.SEND_VANISHED))) return new PlayerNotFoundError(args[0]).send(sender);
         if (sender instanceof final @NotNull Player player && recipient.get().getUniqueId().equals(player.getUniqueId()))
             return new MessageYourselfError().send(sender);
 
+        if (args.length == 1) {
+            final @NotNull Player player = (Player) sender;
+            if (Message.getChannel(player).map(r -> r.getUniqueId().equals(recipient.get().getUniqueId())).orElse(false)) {
+                Message.exitChannel(player);
+                return sendMessage(player, CloudnodeMSG.getInstance().config().channelClosed(player.getName(), recipient.get().getName(), label));
+            }
+            Message.createChannel(player, recipient.get());
+            return sendMessage(player, CloudnodeMSG.getInstance().config().channelCreated(player.getName(), recipient.get().getName(), label));
+        }
+
         try {
             new Message(Message.offlinePlayer(sender), recipient.get(), String.join(" ", Arrays.copyOfRange(args, 1, args.length))).send();
             return true;