Fix UnsupportedOperationException in Folia (fixes #842)

Author: Intelli

src/main/java/net/coreprotect/paper/listener/CopperGolemChestListener.java

@@ -30,6 +30,7 @@
 import net.coreprotect.config.Config;
 import net.coreprotect.config.ConfigHandler;
 import net.coreprotect.listener.player.InventoryChangeListener;
+import net.coreprotect.thread.Scheduler;
 import net.coreprotect.utility.ItemUtils;
 
 public final class CopperGolemChestListener implements Listener {
@@ -322,11 +323,11 @@ private void unindexEmptySkip(TransactionKey containerKey, UUID golemId) {
     }
 
     private void scheduleCloseFinalize(UUID golemId, OpenInteraction interaction, TransactionKey containerKey, int attempt) {
-        plugin.getServer().getScheduler().runTaskLater(plugin, () -> finalizeContainerClose(golemId, interaction, containerKey, attempt), CLOSE_FINALIZE_DELAY_TICKS);
+        Scheduler.scheduleSyncDelayedTask(plugin, () -> finalizeContainerClose(golemId, interaction, containerKey, attempt), interaction.location, (int) CLOSE_FINALIZE_DELAY_TICKS);
     }
 
     private void scheduleUntrackedCopperChestCloseFinalize(UUID golemId, Location containerLocation, Material containerType, int attempt) {
-        plugin.getServer().getScheduler().runTaskLater(plugin, () -> finalizeUntrackedCopperChestClose(golemId, containerLocation, containerType, attempt), CLOSE_FINALIZE_DELAY_TICKS);
+        Scheduler.scheduleSyncDelayedTask(plugin, () -> finalizeUntrackedCopperChestClose(golemId, containerLocation, containerType, attempt), containerLocation, (int) CLOSE_FINALIZE_DELAY_TICKS);
     }
 
     private void finalizeContainerClose(UUID golemId, OpenInteraction interaction, TransactionKey containerKey, int attempt) {

src/main/java/net/coreprotect/thread/Scheduler.java

@@ -2,7 +2,6 @@
 
 import java.util.concurrent.TimeUnit;
 
-import org.bukkit.Bukkit;
 import org.bukkit.Location;
 import org.bukkit.entity.Entity;
 import org.bukkit.scheduler.BukkitTask;
@@ -21,10 +20,10 @@ public static void scheduleSyncDelayedTask(CoreProtect plugin, Runnable task, Ob
             if (regionData instanceof Location) {
                 Location location = (Location) regionData;
                 if (delay == 0) {
-                    Bukkit.getServer().getRegionScheduler().run(plugin, location, value -> task.run());
+                    plugin.getServer().getRegionScheduler().run(plugin, location, value -> task.run());
                 }
                 else {
-                    Bukkit.getServer().getRegionScheduler().runDelayed(plugin, location, value -> task.run(), delay);
+                    plugin.getServer().getRegionScheduler().runDelayed(plugin, location, value -> task.run(), delay);
                 }
             }
             else if (regionData instanceof Entity) {
@@ -38,19 +37,19 @@ else if (regionData instanceof Entity) {
             }
             else {
                 if (delay == 0) {
-                    Bukkit.getServer().getGlobalRegionScheduler().run(plugin, value -> task.run());
+                    plugin.getServer().getGlobalRegionScheduler().run(plugin, value -> task.run());
                 }
                 else {
-                    Bukkit.getServer().getGlobalRegionScheduler().runDelayed(plugin, value -> task.run(), delay);
+                    plugin.getServer().getGlobalRegionScheduler().runDelayed(plugin, value -> task.run(), delay);
                 }
             }
         }
         else {
             if (delay == 0) {
-                Bukkit.getServer().getScheduler().runTask(plugin, task);
+                plugin.getServer().getScheduler().runTask(plugin, task);
             }
             else {
-                Bukkit.getServer().getScheduler().scheduleSyncDelayedTask(plugin, task, delay);
+                plugin.getServer().getScheduler().runTaskLater(plugin, task, delay);
             }
         }
     }
@@ -59,36 +58,36 @@ public static Object scheduleSyncRepeatingTask(CoreProtect plugin, Runnable task
         if (ConfigHandler.isFolia) {
             if (regionData instanceof Location) {
                 Location location = (Location) regionData;
-                return Bukkit.getServer().getRegionScheduler().runAtFixedRate(plugin, location, value -> task.run(), delay, period);
+                return plugin.getServer().getRegionScheduler().runAtFixedRate(plugin, location, value -> task.run(), delay, period);
             }
             else if (regionData instanceof Entity) {
                 Entity entity = (Entity) regionData;
                 return entity.getScheduler().runAtFixedRate(plugin, value -> task.run(), task, delay, period);
             }
             else {
-                return Bukkit.getServer().getGlobalRegionScheduler().runAtFixedRate(plugin, value -> task.run(), delay, period);
+                return plugin.getServer().getGlobalRegionScheduler().runAtFixedRate(plugin, value -> task.run(), delay, period);
             }
         }
         else {
-            return Bukkit.getServer().getScheduler().scheduleSyncRepeatingTask(plugin, task, delay, period);
+            return plugin.getServer().getScheduler().scheduleSyncRepeatingTask(plugin, task, delay, period);
         }
     }
 
     public static void scheduleAsyncDelayedTask(CoreProtect plugin, Runnable task, int delay) {
         if (ConfigHandler.isFolia) {
             if (delay == 0) {
-                Bukkit.getServer().getAsyncScheduler().runNow(plugin, value -> task.run());
+                plugin.getServer().getAsyncScheduler().runNow(plugin, value -> task.run());
             }
             else {
-                Bukkit.getServer().getAsyncScheduler().runDelayed(plugin, value -> task.run(), (delay * 50L), TimeUnit.MILLISECONDS);
+                plugin.getServer().getAsyncScheduler().runDelayed(plugin, value -> task.run(), (delay * 50L), TimeUnit.MILLISECONDS);
             }
         }
         else {
             if (delay == 0) {
-                Bukkit.getServer().getScheduler().runTaskAsynchronously(plugin, task);
+                plugin.getServer().getScheduler().runTaskAsynchronously(plugin, task);
             }
             else {
-                Bukkit.getServer().getScheduler().runTaskLaterAsynchronously(plugin, task, delay);
+                plugin.getServer().getScheduler().runTaskLaterAsynchronously(plugin, task, delay);
             }
         }
     }