GH-266 New features for Trident and Pearls

eternalcombat-api/src/main/java/com/eternalcode/combat/fight/trident/FightTridentService.java

@@ -0,0 +1,16 @@
+package com.eternalcode.combat.fight.trident;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.UUID;
+
+public interface FightTridentService {
+
+    Instant getDelay(UUID uuid);
+
+    Duration getRemainingDelay(UUID uuid);
+
+    boolean hasDelay(UUID uuid);
+
+    void markDelay(UUID uuid);
+}

eternalcombat-plugin/src/main/java/com/eternalcode/combat/CombatPlugin.java

@@ -16,6 +16,9 @@
 import com.eternalcode.combat.fight.knockback.KnockbackService;
 import com.eternalcode.combat.fight.tagout.FightTagOutService;
 import com.eternalcode.combat.fight.pearl.FightPearlService;
+import com.eternalcode.combat.fight.trident.FightTridentController;
+import com.eternalcode.combat.fight.trident.FightTridentService;
+import com.eternalcode.combat.fight.trident.FightTridentServiceImpl;
 import com.eternalcode.combat.handler.InvalidUsageHandlerImpl;
 import com.eternalcode.combat.handler.MissingPermissionHandlerImpl;
 import com.eternalcode.combat.config.ConfigService;
@@ -78,6 +81,7 @@ public final class CombatPlugin extends JavaPlugin implements EternalCombatApi {
 
     private FightManager fightManager;
     private FightPearlService fightPearlService;
+    private FightTridentService fightTridentService;
     private FightTagOutService fightTagOutService;
     private FightEffectService fightEffectService;
 
@@ -106,6 +110,7 @@ public void onEnable() {
 
         this.fightManager = new FightManagerImpl(eventManager);
         this.fightPearlService = new FightPearlServiceImpl(pluginConfig.pearl);
+        this.fightTridentService = new FightTridentServiceImpl(pluginConfig.trident);
         this.fightTagOutService = new FightTagOutServiceImpl();
         this.fightEffectService = new FightEffectServiceImpl();
 
@@ -173,7 +178,8 @@ public void onEnable() {
             new FightTagController(this.fightManager, pluginConfig),
             new FightUnTagController(this.fightManager, pluginConfig, logoutService),
             new FightActionBlockerController(this.fightManager, noticeService, pluginConfig, server),
-            new FightPearlController(pluginConfig.pearl, noticeService, this.fightManager, this.fightPearlService),
+            new FightPearlController(pluginConfig.pearl, noticeService, this.fightManager, this.fightPearlService, pluginConfig),
+            new FightTridentController(pluginConfig.trident, noticeService, this.fightManager, this.fightTridentService, pluginConfig),
             new UpdaterNotificationController(updaterService, pluginConfig, this.audienceProvider, miniMessage),
             new KnockbackRegionController(noticeService, this.regionProvider, this.fightManager, knockbackService, server),
             new FightEffectController(pluginConfig.effect, this.fightEffectService, this.fightManager, this.getServer()),

eternalcombat-plugin/src/main/java/com/eternalcode/combat/config/implementation/PluginConfig.java

@@ -5,6 +5,7 @@
 import com.eternalcode.combat.fight.effect.FightEffectSettings;
 import com.eternalcode.combat.fight.knockback.KnockbackSettings;
 import com.eternalcode.combat.fight.pearl.FightPearlSettings;
+import com.eternalcode.combat.fight.trident.FightTridentSettings;
 import eu.okaeri.configs.OkaeriConfig;
 import eu.okaeri.configs.annotation.Comment;
 import java.time.Duration;
@@ -35,6 +36,13 @@ public class PluginConfig extends OkaeriConfig {
     })
     public FightPearlSettings pearl = new FightPearlSettings();
 
+    @Comment({
+        " ",
+        "# Settings related to Trident",
+        "# Configure cooldowns, restrictions, and other behaviors for Trident during combat."
+    })
+    public FightTridentSettings trident = new FightTridentSettings();
+
     @Comment({
         " ",
         "# Custom effects applied during combat.",

eternalcombat-plugin/src/main/java/com/eternalcode/combat/fight/pearl/FightPearlController.java

@@ -1,6 +1,8 @@
 package com.eternalcode.combat.fight.pearl;
 
+import com.eternalcode.combat.config.implementation.PluginConfig;
 import com.eternalcode.combat.fight.FightManager;
+import com.eternalcode.combat.fight.event.CauseOfTag;
 import com.eternalcode.combat.notification.NoticeService;
 import com.eternalcode.combat.util.DurationUtil;
 import java.time.Duration;
@@ -14,25 +16,27 @@
 import org.bukkit.event.entity.EntityDamageByEntityEvent;
 import org.bukkit.event.entity.EntityDamageEvent;
 import org.bukkit.event.entity.ProjectileLaunchEvent;
-import org.bukkit.inventory.ItemStack;
 
 public class FightPearlController implements Listener {
 
     private final FightPearlSettings settings;
     private final NoticeService noticeService;
     private final FightManager fightManager;
     private final FightPearlService fightPearlService;
+    private final PluginConfig config;
 
     public FightPearlController(
         FightPearlSettings settings,
         NoticeService noticeService,
         FightManager fightManager,
-        FightPearlService fightPearlService
+        FightPearlService fightPearlService,
+        PluginConfig config
     ) {
         this.settings = settings;
         this.noticeService = noticeService;
         this.fightManager = fightManager;
         this.fightPearlService = fightPearlService;
+        this.config = config;
     }
 
     @EventHandler(priority = EventPriority.HIGHEST)
@@ -63,6 +67,11 @@ public void onPearlThrow(ProjectileLaunchEvent event) {
         if (this.settings.pearlCooldownEnabled) {
             handlePearlCooldown(event, player, playerId);
         }
+
+        if (this.settings.pearlResetsTimerEnabled) {
+            Duration combatTime = this.config.settings.combatTimerDuration;
+            this.fightManager.tag(playerId, combatTime, CauseOfTag.CUSTOM);
+        }
     }
 
     @EventHandler(priority = EventPriority.HIGHEST, ignoreCancelled = true)

eternalcombat-plugin/src/main/java/com/eternalcode/combat/fight/pearl/FightPearlSettings.java

@@ -21,6 +21,9 @@ public class FightPearlSettings extends OkaeriConfig {
     @Comment("# Set true, If you want add cooldown to pearls")
     public boolean pearlCooldownEnabled = false;
 
+    @Comment("# Set true, If you want to reset timer when player throws ender pearl")
+    public boolean pearlResetsTimerEnabled = true;
+
     @Comment({
         "# Block throwing pearls with delay?",
         "# If you set this to for example 3s, player will have to wait 3 seconds before throwing another pearl"

eternalcombat-plugin/src/main/java/com/eternalcode/combat/fight/trident/FightTridentController.java

@@ -0,0 +1,98 @@
+package com.eternalcode.combat.fight.trident;
+
+import com.eternalcode.combat.config.implementation.PluginConfig;
+import com.eternalcode.combat.fight.FightManager;
+
+import com.eternalcode.combat.fight.event.CauseOfTag;
+import com.eternalcode.combat.notification.NoticeService;
+import com.eternalcode.combat.util.DurationUtil;
+import org.bukkit.Material;
+import org.bukkit.entity.Player;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.EventPriority;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.PlayerInteractEvent;
+import org.bukkit.inventory.ItemStack;
+
+import java.time.Duration;
+import java.util.UUID;
+
+public class FightTridentController implements Listener {
+
+    private final FightTridentSettings settings;
+    private final NoticeService noticeService;
+    private final FightManager fightManager;
+    private final FightTridentService fightTridentService;
+    private final PluginConfig config;
+
+    public FightTridentController(
+        FightTridentSettings settings,
+        NoticeService noticeService,
+        FightManager fightManager,
+        FightTridentService fightTridentService,
+        PluginConfig config
+    ) {
+        this.settings = settings;
+        this.noticeService = noticeService;
+        this.fightManager = fightManager;
+        this.fightTridentService = fightTridentService;
+        this.config = config;
+    }
+
+
+    @EventHandler(priority = EventPriority.HIGHEST)
+    public void onTridentInteract(PlayerInteractEvent event) {
+        ItemStack item = event.getItem();
+
+        if (item == null || item.getType() != Material.TRIDENT) {
+            return;
+        }
+
+        Player player = event.getPlayer();
+        UUID playerId = player.getUniqueId();
+
+        if (!this.fightManager.isInCombat(playerId)) {
+            return;
+        }
+
+        if (this.settings.tridentThrowDisabledDuringCombat) {
+            event.setCancelled(true);
+            this.noticeService.create()
+                .player(playerId)
+                .notice(this.settings.tridentThrowBlockedDuringCombat)
+                .send();
+            return;
+        }
+
+        if (this.settings.tridentCooldownEnabled) {
+            this.handleTridentCooldown(event, player, playerId);
+        }
+
+        if (this.settings.tridentResetsTimerEnabled) {
+            Duration combatTime = this.config.settings.combatTimerDuration;
+            this.fightManager.tag(playerId, combatTime, CauseOfTag.CUSTOM);
+        }
+    }
+
+    private void handleTridentCooldown(PlayerInteractEvent event, Player player, UUID playerId) {
+        if (this.settings.tridentThrowDelay.isZero()) {
+            return;
+        }
+
+        if (this.fightTridentService.hasDelay(playerId)) {
+            event.setCancelled(true);
+            Duration remainingDelay = this.fightTridentService.getRemainingDelay(playerId);
+
+            this.noticeService.create()
+                .player(playerId)
+                .notice(this.settings.tridentThrowBlockedDelayDuringCombat)
+                .placeholder("{TIME}", DurationUtil.format(remainingDelay))
+                .send();
+            return;
+        }
+
+        this.fightTridentService.markDelay(playerId);
+        int cooldownTicks = (int) (this.settings.tridentThrowDelay.toMillis() / 50);
+        player.setCooldown(Material.TRIDENT, cooldownTicks);
+    }
+}

eternalcombat-plugin/src/main/java/com/eternalcode/combat/fight/trident/FightTridentServiceImpl.java

@@ -0,0 +1,50 @@
+package com.eternalcode.combat.fight.trident;
+
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+
+import java.time.Duration;
+import java.time.Instant;
+import java.util.UUID;
+
+public class FightTridentServiceImpl implements FightTridentService {
+    private final FightTridentSettings tridentSettings;
+    private final Cache<UUID, Instant> tridentStartTimes;
+
+    public FightTridentServiceImpl(FightTridentSettings pearlSettings) {
+        this.tridentSettings = pearlSettings;
+        this.tridentStartTimes = Caffeine.newBuilder()
+            .expireAfterWrite(pearlSettings.tridentThrowDelay)
+            .build();
+    }
+
+    @Override
+    public void markDelay(UUID uuid) {
+        this.tridentStartTimes.put(uuid, Instant.now());
+    }
+
+    @Override
+    public boolean hasDelay(UUID uuid) {
+        return this.tridentStartTimes.getIfPresent(uuid) != null;
+    }
+
+    @Override
+    public Duration getRemainingDelay(UUID uuid) {
+        Instant startTime = this.tridentStartTimes.getIfPresent(uuid);
+        if (startTime == null) {
+            return Duration.ZERO;
+        }
+
+        Duration elapsed = Duration.between(startTime, Instant.now());
+        Duration remaining = this.tridentSettings.tridentThrowDelay.minus(elapsed);
+
+        return remaining.isNegative() ? Duration.ZERO : remaining;
+    }
+
+    @Override
+    public Instant getDelay(UUID uuid) {
+        Instant startTime = this.tridentStartTimes.getIfPresent(uuid);
+        return startTime != null ? startTime.plus(this.tridentSettings.tridentThrowDelay) : Instant.MIN;
+    }
+}
+

eternalcombat-plugin/src/main/java/com/eternalcode/combat/fight/trident/FightTridentSettings.java

@@ -0,0 +1,39 @@
+package com.eternalcode.combat.fight.trident;
+
+import com.eternalcode.multification.bukkit.notice.BukkitNotice;
+import com.eternalcode.multification.notice.Notice;
+import eu.okaeri.configs.OkaeriConfig;
+import eu.okaeri.configs.annotation.Comment;
+
+import java.time.Duration;
+
+public class FightTridentSettings extends OkaeriConfig {
+
+    @Comment({
+        "# Set true, If you want to disable throwing trident during combat",
+        "# This will work globally, but can be overridden by region settings"
+    })
+    public boolean tridentThrowDisabledDuringCombat = true;
+
+    @Comment("# Set true, If you want add cooldown to trident")
+    public boolean tridentCooldownEnabled = false;
+
+    @Comment("# Set true, If you want to reset timer when player uses trident")
+    public boolean tridentResetsTimerEnabled = true;
+
+    @Comment({
+        "# Block throwing trident with delay?",
+        "# If you set this to for example 3s, player will have to wait 3 seconds before throwing trident"
+    })
+    public Duration tridentThrowDelay = Duration.ofSeconds(3);
+
+    @Comment("# Message sent when player tries to throw trident, but are disabled")
+    public Notice tridentThrowBlockedDuringCombat = BukkitNotice.builder()
+        .chat("<red>Throwing trident is prohibited during combat!")
+        .build();
+
+    @Comment("# Message sent when player tries to throw trident, but has delay")
+    public Notice tridentThrowBlockedDelayDuringCombat = BukkitNotice.builder()
+        .chat("<red>You must wait {TIME} before next throw!")
+        .build();
+}