From 048ae993f4bbb2d9d594347436b4758b36389863 Mon Sep 17 00:00:00 2001
From: carm <carm@carm.cc>
Date: Fri, 5 Jan 2024 01:55:29 +0800
Subject: [PATCH] feat: Finished base functions

---
 README.md                                     |  16 ++-
 pom.xml                                       |   2 +-
 .../artformgames/plugin/tempflight/Main.java  |  15 ++-
 .../tempflight/command/TempFlightCommand.java |  81 +++++++++++++
 .../command/TempFlightCommands.java           |  24 ++++
 .../plugin/tempflight/conf/PluginConfig.java  |  20 ++-
 .../tempflight/conf/PluginMessages.java       |  65 +++++++++-
 .../tempflight/listener/TempFlyListener.java  |  26 ++++
 .../tempflight/manager/FlightManager.java     | 114 ++++++++++++++++++
 .../plugin/tempflight/user/FlightAccount.java |  45 +++++++
 src/main/resources/plugin.yml                 |   6 +
 11 files changed, 399 insertions(+), 15 deletions(-)
 create mode 100644 src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommand.java
 create mode 100644 src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommands.java
 create mode 100644 src/main/java/com/artformgames/plugin/tempflight/listener/TempFlyListener.java
 create mode 100644 src/main/java/com/artformgames/plugin/tempflight/manager/FlightManager.java
 create mode 100644 src/main/java/com/artformgames/plugin/tempflight/user/FlightAccount.java

diff --git a/README.md b/README.md
index df2cb9a..c0e350e 100644
--- a/README.md
+++ b/README.md
@@ -28,13 +28,19 @@ see  [Dependencies](https://github.com/ArtformGames/TempFlight/network/dependenc
 
 ## Commands
 
-The main command is `/TempFlight` or `/tsp`.
+The main command is `/TempFlight` or `/TempFly`.
 
 ```text
 
-# subcommand <force-arg> <optional-arg>
-@ Player command
-- Description
+# start <player> <time> [teleport-back]
+@ Admin command
+- Start a temporary flight for a player.
+- If "teleport-back" is true, the player will be teleported 
+-       back to the original location after the flight ends.
+
+# stop <player>
+@ Admin command
+- Stop a temporary flight for a player.
 
 ```
 
@@ -57,7 +63,7 @@ Will be generated on the first boot up.
 
 ## Statistics
 
-[![bStats](https://bstats.org/signatures/bukkit/TemplatePlugin.svg)](https://bstats.org/plugin/bukkit/TemplatePlugin/18946)
+[![bStats](https://bstats.org/signatures/bukkit/TempFlight.svg)](https://bstats.org/plugin/bukkit/TempFlight/20647)
 
 ## Open Source Licence
 
diff --git a/pom.xml b/pom.xml
index cea0fd8..4087602 100644
--- a/pom.xml
+++ b/pom.xml
@@ -11,7 +11,7 @@
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
 
         <project.package>${project.groupId}.plugin.${project.groupId}</project.package>
-        <deps.core.version>1.0.0</deps.core.version>
+        <deps.core.version>1.0.2</deps.core.version>
     </properties>
     <groupId>com.artformgames</groupId>
     <artifactId>tempflight</artifactId>
diff --git a/src/main/java/com/artformgames/plugin/tempflight/Main.java b/src/main/java/com/artformgames/plugin/tempflight/Main.java
index b0b4507..e347a4d 100644
--- a/src/main/java/com/artformgames/plugin/tempflight/Main.java
+++ b/src/main/java/com/artformgames/plugin/tempflight/Main.java
@@ -5,6 +5,8 @@
 import com.artformgames.core.utils.GHUpdateChecker;
 import com.artformgames.plugin.tempflight.conf.PluginConfig;
 import com.artformgames.plugin.tempflight.conf.PluginMessages;
+import com.artformgames.plugin.tempflight.listener.TempFlyListener;
+import com.artformgames.plugin.tempflight.manager.FlightManager;
 import org.bstats.bukkit.Metrics;
 
 public class Main extends EasyPlugin {
@@ -16,10 +18,10 @@ public Main() {
     }
 
     protected MineConfiguration configuration;
+    protected FlightManager flightManager;
 
     @Override
     protected void load() {
-
         log("Loading plugin configurations...");
         configuration = new MineConfiguration(this);
         configuration.initializeConfig(PluginConfig.class);
@@ -29,14 +31,18 @@ protected void load() {
     @Override
     protected boolean initialize() {
 
+        log("Initialize flight manager...");
+        this.flightManager = new FlightManager(this);
+
         log("Register listeners...");
+        registerListener(new TempFlyListener());
 
         log("Register commands...");
 
 
         if (PluginConfig.METRICS.getNotNull()) {
             log("Initializing bStats...");
-            new Metrics(this, 0);
+            new Metrics(this, 20647);
         }
 
         if (PluginConfig.CHECK_UPDATE.getNotNull()) {
@@ -53,6 +59,7 @@ protected boolean initialize() {
     protected void shutdown() {
 
         log("Shutting down...");
+        getFlightManager().shutdown();
 
     }
 
@@ -77,4 +84,8 @@ public static Main getInstance() {
         return instance;
     }
 
+    public static FlightManager getFlightManager() {
+        return getInstance().flightManager;
+    }
+
 }
diff --git a/src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommand.java b/src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommand.java
new file mode 100644
index 0000000..f37e58b
--- /dev/null
+++ b/src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommand.java
@@ -0,0 +1,81 @@
+//package com.artformgames.plugin.tempflight.command;
+//
+//import cc.carm.lib.easysql.api.util.TimeDateUtils;
+//import org.bukkit.Bukkit;
+//import org.bukkit.command.Command;
+//import org.bukkit.command.CommandExecutor;
+//import org.bukkit.command.CommandSender;
+//import org.bukkit.command.ConsoleCommandSender;
+//import org.bukkit.entity.Player;
+//import org.jetbrains.annotations.NotNull;
+//
+//public class TempFlightCommand implements CommandExecutor {
+//
+//    // /tempFlight <Player> <Time> [back]
+//
+//    @Override
+//    public boolean onCommand(@NotNull CommandSender sender, @NotNull Command command,
+//                             @NotNull String label, @NotNull String[] args) {
+//        if (!PluginConfig.TEMP_FLY.ENABLE.getNotNull()) {
+//            PluginMessages.DISABLED.send(sender);
+//            return true;
+//        }
+//        if (!(sender instanceof ConsoleCommandSender)) {
+//            sender.sendMessage("该指令只能在控制台使用。");
+//            return true;
+//        }
+//
+//        if (args.length < 2) return false;
+//
+//        Player target = Bukkit.getPlayer(args[0]);
+//        if (target == null) {
+//            sender.sendMessage("目标玩家不在线。");
+//            return true;
+//        }
+//
+//        long time = TimeStringUtils.toMilliSecPlus(args[1]);
+//        if (time < 0) {
+//            sender.sendMessage("时间格式错误。");
+//            return true;
+//        }
+//
+//        boolean back = true;
+//        if (args.length > 2) {
+//            if (args[2].equalsIgnoreCase("0") || args[2].equalsIgnoreCase("false")) {
+//                back = false;
+//            } else if (!args[2].equalsIgnoreCase("1") && !args[2].equalsIgnoreCase("true")) {
+//                sender.sendMessage("参数错误，是否返回可选 true 或 false。");
+//                return true;
+//            }
+//        }
+//
+//        TempFlyData data = UserHandler.get(target, TempFlyData.class);
+//        if (data == null) {
+//            sender.sendMessage("玩家暂未加载飞行时间数据，请稍后再试。");
+//            return true;
+//        }
+//
+//        if (data.isTempFlying()) {
+//            sender.sendMessage("玩家正在进行临时飞行，无法再次操作。");
+//            PluginMessages.FLY.FLYING.send(target, TimeDateUtils.toDHMSStyle(data.getRemainMillis() / 1000));
+//            return true;
+//        }
+//
+//        long cooldown = data.getCooldownMillis();
+//        if (cooldown > 0) {
+//            sender.sendMessage("玩家的临时飞行时间正在冷却中，请稍后再试。");
+//            PluginMessages.FLY.COOLING.send(target, TimeDateUtils.toDHMSStyle(cooldown / 1000));
+//            return true;
+//        }
+//
+//        if (data.startFly(target, time, back ? target.getLocation() : null)) {
+//            sender.sendMessage("成功为玩家启用为期 " + (time / 1000) + " 秒的临时飞行。");
+//            PluginMessages.FLY.ENABLED.send(target, TimeDateUtils.toDHMSStyle(time / 1000));
+//            if (back) PluginMessages.FLY.WILL_BACK.send(target);
+//        } else {
+//            sender.sendMessage("玩家正在进行临时飞行，无法再次操作。");
+//        }
+//        return true;
+//    }
+//
+//}
diff --git a/src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommands.java b/src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommands.java
new file mode 100644
index 0000000..b7832c9
--- /dev/null
+++ b/src/main/java/com/artformgames/plugin/tempflight/command/TempFlightCommands.java
@@ -0,0 +1,24 @@
+package com.artformgames.plugin.tempflight.command;
+
+import dev.rollczi.litecommands.annotations.argument.Arg;
+import dev.rollczi.litecommands.annotations.command.Command;
+import dev.rollczi.litecommands.annotations.description.Description;
+import dev.rollczi.litecommands.annotations.optional.OptionalArg;
+import dev.rollczi.litecommands.annotations.permission.Permission;
+import org.bukkit.entity.Player;
+
+
+@Command(name = "tempflight", aliases = {"tempfly"})
+@Description("TempFlight commands")
+@Permission("tempflight.admin")
+public class TempFlightCommands {
+
+    void start(@Arg Player player, @Arg String duration, @OptionalArg Boolean back) {
+
+    }
+
+    void stop(@Arg Player player) {
+
+    }
+
+}
diff --git a/src/main/java/com/artformgames/plugin/tempflight/conf/PluginConfig.java b/src/main/java/com/artformgames/plugin/tempflight/conf/PluginConfig.java
index 52e2529..aab0975 100644
--- a/src/main/java/com/artformgames/plugin/tempflight/conf/PluginConfig.java
+++ b/src/main/java/com/artformgames/plugin/tempflight/conf/PluginConfig.java
@@ -1,12 +1,14 @@
 package com.artformgames.plugin.tempflight.conf;
 
-import cc.carm.lib.configuration.core.ConfigurationRoot;
+import cc.carm.lib.configuration.core.Configuration;
 import cc.carm.lib.configuration.core.annotation.HeaderComment;
+import cc.carm.lib.configuration.core.value.ConfigValue;
 import cc.carm.lib.configuration.core.value.type.ConfiguredValue;
+import com.artformgames.core.utils.TimeStringUtils;
 
-public class PluginConfig extends ConfigurationRoot {
+public interface PluginConfig extends Configuration {
 
-    public static final ConfiguredValue<Boolean> DEBUG = ConfiguredValue.of(Boolean.class, false);
+    ConfiguredValue<Boolean> DEBUG = ConfiguredValue.of(Boolean.class, false);
 
     @HeaderComment({
             "Statistics Settings",
@@ -14,7 +16,7 @@ public class PluginConfig extends ConfigurationRoot {
             "Of course, you can also choose to turn it off here for this plugin,",
             "or turn it off for all plugins in the configuration file under \"plugins/bStats\"."
     })
-    public static final ConfiguredValue<Boolean> METRICS = ConfiguredValue.of(Boolean.class, true);
+    ConfiguredValue<Boolean> METRICS = ConfiguredValue.of(Boolean.class, true);
 
     @HeaderComment({
             "Check update settings",
@@ -22,6 +24,14 @@ public class PluginConfig extends ConfigurationRoot {
             "If you do not want the plug-in to check for updates and prompt you, you can choose to close.",
             "Checking for updates is an asynchronous operation that will never affect performance and user experience."
     })
-    public static final ConfiguredValue<Boolean> CHECK_UPDATE = ConfiguredValue.of(Boolean.class, true);
+    ConfiguredValue<Boolean> CHECK_UPDATE = ConfiguredValue.of(Boolean.class, true);
+
+    @HeaderComment("The cooldown time for the player to use the flight command, format: 1d,2h,3m,4s")
+    ConfiguredValue<Long> COOLDOWN = ConfigValue.builder()
+            .asValue(Long.class).fromString()
+            .parseValue((v, d) -> TimeStringUtils.toMilliSecPlus(v))
+            .serializeValue(TimeStringUtils::toTimeString)
+            .defaults(60000L).build();
+
 
 }
diff --git a/src/main/java/com/artformgames/plugin/tempflight/conf/PluginMessages.java b/src/main/java/com/artformgames/plugin/tempflight/conf/PluginMessages.java
index 68c641a..b5b29d3 100644
--- a/src/main/java/com/artformgames/plugin/tempflight/conf/PluginMessages.java
+++ b/src/main/java/com/artformgames/plugin/tempflight/conf/PluginMessages.java
@@ -1,6 +1,67 @@
 package com.artformgames.plugin.tempflight.conf;
 
-import cc.carm.lib.configuration.core.ConfigurationRoot;
+import cc.carm.lib.configuration.core.Configuration;
+import cc.carm.lib.mineconfiguration.bukkit.builder.message.CraftMessageListBuilder;
+import cc.carm.lib.mineconfiguration.bukkit.builder.message.CraftMessageValueBuilder;
+import cc.carm.lib.mineconfiguration.bukkit.value.ConfiguredMessage;
+import cc.carm.lib.mineconfiguration.bukkit.value.ConfiguredMessageList;
+import de.themoep.minedown.MineDown;
+import me.clip.placeholderapi.PlaceholderAPI;
+import net.md_5.bungee.api.chat.BaseComponent;
+import org.bukkit.command.CommandSender;
+import org.bukkit.entity.Player;
+import org.jetbrains.annotations.NotNull;
+
+import java.util.function.BiFunction;
+
+public interface PluginMessages extends Configuration {
+    static @NotNull CraftMessageListBuilder<BaseComponent[]> list() {
+        return ConfiguredMessageList.create(getParser())
+                .whenSend((sender, message) -> message.forEach(m -> sender.spigot().sendMessage(m)));
+    }
+
+    static @NotNull CraftMessageValueBuilder<BaseComponent[]> value() {
+        return ConfiguredMessage.create(getParser())
+                .whenSend((sender, message) -> sender.spigot().sendMessage(message));
+    }
+
+    private static @NotNull BiFunction<CommandSender, String, BaseComponent[]> getParser() {
+        return (sender, message) -> {
+            if (sender == null) return MineDown.parse(message);
+            if (sender instanceof Player player) {
+                return MineDown.parse(PlaceholderAPI.setPlaceholders(player, message));
+            } else {
+                return MineDown.parse(message);
+            }
+        };
+    }
+
+    ConfiguredMessageList<BaseComponent[]> COOLING = list()
+            .defaults("&fYou need to wait for &e%(time) &fseconds before you can use the timed flight again.")
+            .params("time")
+            .build();
+
+    ConfiguredMessageList<BaseComponent[]> FLYING = list()
+            .defaults("&fYou have enabled time-limited flying, and the remaining flight time is &e%(time) &fseconds.")
+            .params("time")
+            .build();
+
+    ConfiguredMessageList<BaseComponent[]> ENABLED = list()
+            .defaults("&fYou &a&l&Enabled &f for timed flights, and from now on you can fly &e%(time) &fseconds.")
+            .params("time")
+            .build();
+
+    ConfiguredMessageList<BaseComponent[]> DISABLED = list()
+            .defaults("&fYour timed flight has ended and your flight status has been automatically turned off.")
+            .build();
+
+    ConfiguredMessageList<BaseComponent[]> MODE_CHANGE = list()
+            .defaults("&fYou've switched to &eCreative Mode&f, so there's no longer a time limit for flying.")
+            .build();
+
+    ConfiguredMessageList<BaseComponent[]> WILL_BACK = list()
+            .defaults("&7Note: Teleport back to your current location after the flight is over!")
+            .build();
+
 
-public class PluginMessages extends ConfigurationRoot {
 }
diff --git a/src/main/java/com/artformgames/plugin/tempflight/listener/TempFlyListener.java b/src/main/java/com/artformgames/plugin/tempflight/listener/TempFlyListener.java
new file mode 100644
index 0000000..0daf555
--- /dev/null
+++ b/src/main/java/com/artformgames/plugin/tempflight/listener/TempFlyListener.java
@@ -0,0 +1,26 @@
+package com.artformgames.plugin.tempflight.listener;
+
+import com.artformgames.core.ArtCore;
+import com.artformgames.plugin.tempflight.conf.PluginMessages;
+import com.artformgames.plugin.tempflight.user.FlightAccount;
+import org.bukkit.GameMode;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.PlayerGameModeChangeEvent;
+
+public class TempFlyListener implements Listener {
+
+    @EventHandler
+    public void onModeChange(PlayerGameModeChangeEvent event) {
+        if (event.getNewGameMode() != GameMode.CREATIVE) return;
+
+        FlightAccount data = ArtCore.getHandler(event.getPlayer(), FlightAccount.class);
+
+        if (data.isTempFlying()) {
+            PluginMessages.MODE_CHANGE.send(event.getPlayer());
+            data.reset();
+        }
+
+    }
+
+}
diff --git a/src/main/java/com/artformgames/plugin/tempflight/manager/FlightManager.java b/src/main/java/com/artformgames/plugin/tempflight/manager/FlightManager.java
new file mode 100644
index 0000000..260c05d
--- /dev/null
+++ b/src/main/java/com/artformgames/plugin/tempflight/manager/FlightManager.java
@@ -0,0 +1,114 @@
+package com.artformgames.plugin.tempflight.manager;
+
+import com.artformgames.core.ArtCore;
+import com.artformgames.plugin.tempflight.Main;
+import com.artformgames.plugin.tempflight.conf.PluginConfig;
+import com.artformgames.plugin.tempflight.conf.PluginMessages;
+import com.artformgames.plugin.tempflight.user.FlightAccount;
+import org.bukkit.Bukkit;
+import org.bukkit.entity.Player;
+import org.bukkit.scheduler.BukkitRunnable;
+import org.jetbrains.annotations.NotNull;
+
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+import java.util.UUID;
+
+public class FlightManager {
+
+    /**
+     * Used to record the last time the user enabled an ad-hoc flight
+     * The UUID is the user's UUID, and the time is the timestamp when the user theoretically ended the flight
+     */
+    protected final @NotNull Map<UUID, Long> lastTime = new HashMap<>();
+    public static @NotNull BukkitRunnable repeatRunnable = new BukkitRunnable() {
+        @Override
+        public void run() {
+            Bukkit.getOnlinePlayers().forEach(Main.getFlightManager()::checkFlight);
+            Main.getFlightManager().purgeCooldownData();
+        }
+    };
+
+
+    public FlightManager(Main main) {
+        ArtCore.getUserManager().registerHandler(
+                main, FlightAccount.class,
+                FlightAccount::new, FlightAccount::new,
+                (k, a) -> lastTime.remove(k.uuid())
+        );
+        repeatRunnable.runTaskTimerAsynchronously(Main.getInstance(), 100L, 20L);
+    }
+
+    public void shutdown() {
+        if (!repeatRunnable.isCancelled()) repeatRunnable.cancel();
+    }
+
+    protected static FlightAccount getAccount(@NotNull Player player) {
+        return ArtCore.getHandler(player, FlightAccount.class);
+    }
+
+    public boolean startFly(@NotNull Player player, @NotNull Duration duration, boolean teleportBack) {
+        FlightAccount account = getAccount(player);
+        if (account.isTempFlying()) return false;
+
+        long end = account.start(duration, teleportBack ? player.getLocation() : null);
+        lastTime.put(player.getUniqueId(), end);
+
+        player.setAllowFlight(true);
+        player.setFlying(true);
+        return true;
+    }
+
+    public boolean endFly(@NotNull Player player) {
+        FlightAccount account = getAccount(player);
+        if (!account.isTempFlying()) return false;
+
+        account.reset();
+        Optional.ofNullable(account.getStartLocation()).ifPresent(player::teleport);
+
+        if (player.getAllowFlight()) {
+            player.setFlying(false);
+            player.setAllowFlight(false);
+            player.setFallDistance(-500L); //防止摔死
+            return true;
+        }
+
+        return false;
+    }
+
+    public void checkFlight(@NotNull Player player) {
+        FlightAccount account = getAccount(player);
+        if (!account.isTempFlying()) return;
+
+        if (account.getRemainMillis() <= 0) {
+            PluginMessages.DISABLED.send(player);
+            Main.getInstance().getScheduler().run(() -> endFly(player));
+        }
+    }
+
+    public boolean isCoolingDown(@NotNull Player player) {
+        return getCooldownMillis(player) > 0;
+    }
+
+    public long getCooldownMillis(@NotNull Player player) {
+        Long time = lastTime.get(player.getUniqueId());
+        if (time == null) return 0;
+
+        long cooldown = PluginConfig.COOLDOWN.getNotNull();
+        if (cooldown <= 0) return 0;
+
+        return cooldown - (System.currentTimeMillis() - time);
+    }
+
+    public void purgeCooldownData() {
+        long cooldown = PluginConfig.COOLDOWN.getNotNull();
+        if (cooldown > 0) {
+            lastTime.entrySet().removeIf(entry -> System.currentTimeMillis() - entry.getValue() > cooldown);
+        } else {
+            lastTime.clear();
+        }
+    }
+
+}
diff --git a/src/main/java/com/artformgames/plugin/tempflight/user/FlightAccount.java b/src/main/java/com/artformgames/plugin/tempflight/user/FlightAccount.java
new file mode 100644
index 0000000..f2f8afa
--- /dev/null
+++ b/src/main/java/com/artformgames/plugin/tempflight/user/FlightAccount.java
@@ -0,0 +1,45 @@
+package com.artformgames.plugin.tempflight.user;
+
+import com.artformgames.core.user.User;
+import com.artformgames.core.user.handler.AbstractUserHandler;
+import com.artformgames.core.user.handler.UserHandler;
+import org.bukkit.Location;
+import org.jetbrains.annotations.Nullable;
+
+import java.time.Duration;
+
+public class FlightAccount extends AbstractUserHandler implements UserHandler {
+
+    protected @Nullable Long endMillis;
+    protected @Nullable Location startLocation;
+
+    public FlightAccount(User user) {
+        super(user);
+    }
+
+    public long start(Duration duration, @Nullable Location startLocation) {
+        this.endMillis = System.currentTimeMillis() + duration.toMillis();
+        this.startLocation = startLocation;
+        return this.endMillis;
+    }
+
+    public void reset() {
+        this.endMillis = null;
+        this.startLocation = null;
+    }
+
+    public @Nullable Location getStartLocation() {
+        return startLocation;
+    }
+
+    public boolean isTempFlying() {
+        return this.endMillis != null;
+    }
+
+    public long getRemainMillis() {
+        if (this.endMillis == null) return 0;
+        else return (this.endMillis) - System.currentTimeMillis();
+    }
+
+
+}
diff --git a/src/main/resources/plugin.yml b/src/main/resources/plugin.yml
index 8c04ddb..a4da8ad 100644
--- a/src/main/resources/plugin.yml
+++ b/src/main/resources/plugin.yml
@@ -15,3 +15,9 @@ depend:
 
 softdepend:
   - PlaceholderAPI
+
+
+permissions:
+  "tempflight.admin":
+    default: op
+    description: Permission to use /tempflight
\ No newline at end of file