Add /reply (#8)

Author: zefir-git

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

@@ -4,6 +4,7 @@
 import org.jetbrains.annotations.NotNull;
 import pro.cloudnode.smp.cloudnodemsg.command.MainCommand;
 import pro.cloudnode.smp.cloudnodemsg.command.MessageCommand;
+import pro.cloudnode.smp.cloudnodemsg.command.ReplyCommand;
 
 import java.util.Objects;
 
@@ -24,6 +25,7 @@ public void onEnable() {
 
         Objects.requireNonNull(getCommand("cloudnodemsg")).setExecutor(new MainCommand());
         Objects.requireNonNull(getCommand("message")).setExecutor(new MessageCommand());
+        Objects.requireNonNull(getCommand("reply")).setExecutor(new ReplyCommand());
     }
 
     @Override

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

@@ -119,5 +119,22 @@ public PluginConfig(final @NotNull FileConfiguration config) {
     public @NotNull Component messageYourself() {
         return MiniMessage.miniMessage().deserialize(Objects.requireNonNull(config.getString("errors.message-yourself")));
     }
+
+    public @NotNull Component nobodyReply() {
+        return MiniMessage.miniMessage().deserialize(Objects.requireNonNull(config.getString("errors.nobody-reply")));
+    }
+
+    /**
+     * The player that messaged you is no longer online
+     * <p>Placeholders:</p>
+     * <ul><li>{@code <player>} - the player's username</li></ul>
+     *
+     * @param player The player's username
+     */
+    public @NotNull Component replyOffline(final @NotNull String player) {
+        return MiniMessage.miniMessage().deserialize(Objects.requireNonNull(config.getString("errors.reply-offline")),
+                Placeholder.unparsed("player", player)
+        );
+    }
 }
 

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

@@ -0,0 +1,43 @@
+package pro.cloudnode.smp.cloudnodemsg.command;
+
+import org.bukkit.OfflinePlayer;
+import org.bukkit.command.CommandSender;
+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.error.NoPermissionError;
+import pro.cloudnode.smp.cloudnodemsg.error.NobodyReplyError;
+import pro.cloudnode.smp.cloudnodemsg.error.ReplyOfflineError;
+import pro.cloudnode.smp.cloudnodemsg.message.Message;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+
+public final class ReplyCommand extends Command {
+    public static final @NotNull String usage = "<message>";
+
+    @Override
+    public boolean onCommand(final @NotNull CommandSender sender, final @NotNull org.bukkit.command.Command command, 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));
+
+        final @NotNull Optional<@NotNull OfflinePlayer> recipient = Message.getReplyTo(Message.offlinePlayer(sender));
+        if (recipient.isEmpty()) return new NobodyReplyError().send(sender);
+        if (!recipient.get().getUniqueId().equals(Message.console.getUniqueId()) && !recipient.get().isOnline()) return new ReplyOfflineError(Optional.ofNullable(recipient.get().getName()).orElse("Unknown Player")).send(sender);
+
+        try {
+            new Message(Message.offlinePlayer(sender), recipient.get(), String.join(" ", args)).send();
+            return true;
+        }
+        catch (final @NotNull InvalidPlayerError e) {
+            return e.log().send(sender);
+        }
+    }
+
+    @Override
+    public @NotNull List<@NotNull String> onTabComplete(final @NotNull CommandSender sender, final @NotNull org.bukkit.command.Command command, final @NotNull String label, final @NotNull String @NotNull [] args) {
+        return new ArrayList<>();
+    }
+}

src/main/java/pro/cloudnode/smp/cloudnodemsg/error/NobodyReplyError.java

@@ -0,0 +1,12 @@
+package pro.cloudnode.smp.cloudnodemsg.error;
+
+import pro.cloudnode.smp.cloudnodemsg.CloudnodeMSG;
+
+/**
+ * Player has no username (somehow)
+ */
+public final class NobodyReplyError extends Error {
+    public NobodyReplyError() {
+        super(CloudnodeMSG.getInstance().config().nobodyReply());
+    }
+}

src/main/java/pro/cloudnode/smp/cloudnodemsg/error/ReplyOfflineError.java

@@ -0,0 +1,13 @@
+package pro.cloudnode.smp.cloudnodemsg.error;
+
+import org.jetbrains.annotations.NotNull;
+import pro.cloudnode.smp.cloudnodemsg.CloudnodeMSG;
+
+/**
+ * Player has no username (somehow)
+ */
+public final class ReplyOfflineError extends Error {
+    public ReplyOfflineError(final @NotNull String player) {
+        super(CloudnodeMSG.getInstance().config().replyOffline(player));
+    }
+}

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

@@ -1,10 +1,13 @@
 package pro.cloudnode.smp.cloudnodemsg.message;
 
 import net.kyori.adventure.text.Component;
+import org.bukkit.NamespacedKey;
 import org.bukkit.OfflinePlayer;
 import org.bukkit.command.CommandSender;
 import org.bukkit.entity.Player;
+import org.bukkit.persistence.PersistentDataType;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 import pro.cloudnode.smp.cloudnodemsg.CloudnodeMSG;
 import pro.cloudnode.smp.cloudnodemsg.error.InvalidPlayerError;
 
@@ -31,6 +34,9 @@ public void send() throws InvalidPlayerError {
         sendMessage(sender, CloudnodeMSG.getInstance().config().outgoing(senderUsername, recipientUsername, message));
         sendMessage(recipient, CloudnodeMSG.getInstance().config()
                 .incoming(senderUsername, recipientUsername, message));
+
+        setReplyTo(sender, recipient);
+        setReplyTo(recipient, sender);
     }
 
     public final static @NotNull OfflinePlayer console = CloudnodeMSG.getInstance().getServer()
@@ -45,4 +51,31 @@ public static void sendMessage(final @NotNull OfflinePlayer recipient, final @No
             CloudnodeMSG.getInstance().getServer().getConsoleSender().sendMessage(message);
         else if (recipient.isOnline()) Objects.requireNonNull(recipient.getPlayer()).sendMessage(message);
     }
+
+    private static @Nullable UUID consoleReply;
+
+    public static final @NotNull NamespacedKey REPLY_TO = new NamespacedKey(CloudnodeMSG.getInstance(), "reply");
+
+    public static void setReplyTo(final @NotNull OfflinePlayer sender, final @NotNull OfflinePlayer recipient) {
+        if (sender.getUniqueId().equals(console.getUniqueId())) consoleReply = recipient.getUniqueId();
+        else if (sender.isOnline())
+            Objects.requireNonNull(sender.getPlayer()).getPersistentDataContainer()
+                    .set(REPLY_TO, PersistentDataType.STRING, recipient.getUniqueId().toString());
+    }
+
+    public static @NotNull Optional<@NotNull OfflinePlayer> getReplyTo(final @NotNull OfflinePlayer player) {
+        if (player.getUniqueId().equals(console.getUniqueId())) return Optional.ofNullable(consoleReply)
+                .map(uuid -> CloudnodeMSG.getInstance().getServer().getOfflinePlayer(uuid));
+        if (player.isOnline())
+            return Optional.ofNullable(Objects.requireNonNull(player.getPlayer()).getPersistentDataContainer()
+                    .get(REPLY_TO, PersistentDataType.STRING))
+                    .map(uuid -> CloudnodeMSG.getInstance().getServer().getOfflinePlayer(UUID.fromString(uuid)));
+        return Optional.empty();
+    }
+
+    public static void removeReplyTo(final @NotNull OfflinePlayer player) {
+        if (player.getUniqueId().equals(console.getUniqueId())) consoleReply = null;
+        else if (player.isOnline())
+            Objects.requireNonNull(player.getPlayer()).getPersistentDataContainer().remove(REPLY_TO);
+    }
 }

src/main/resources/config.yml

@@ -35,3 +35,10 @@ errors:
     player-not-found: "<red>(!) Player <gray><player></gray> not found.</red>"
 
     message-yourself: "<red>(!) You can't send a message to yourself.</red>"
+
+    nobody-reply: "<red>(!) You have no one to reply to.</red>"
+
+    # The player that messaged you is no longer online
+    # Placeholders:
+    #  <player> - the player's username
+    reply-offline: "<red>(!) Player <gray><player></gray> is no longer online.</red>"

src/main/resources/plugin.yml

@@ -8,6 +8,10 @@ commands:
         description: Send a private message
         usage: /<command> <player> <message>
         aliases: [ "msg", "tell", "t", "whisper", "dm", "m", "pm" ]
+    reply:
+        description: Reply to a private message
+        usage: /<command> <message>
+        aliases: [ "r", "re" ]
     cloudnodemsg:
         description: CloudnodeMSG
         usage: /<command>