Folia

BuildMechanicsCore/build.gradle.kts

@@ -40,6 +40,7 @@ bukkit {
     name = "MechanicsCore" // Since we don't want to use "BuildMechanicsCore"
     version = mechanicsCoreVersion
     apiVersion = "1.13"
+    foliaSupported = true
 
     load = net.minecrell.pluginyml.bukkit.BukkitPluginDescription.PluginLoadOrder.STARTUP
     authors = listOf("DeeCaaD", "CJCrafter")
@@ -102,5 +103,9 @@ tasks.shadowJar {
         relocate("com.cryptomorin.xseries", "me.deecaad.core.lib.xseries") {
             include(dependency("com.github.cryptomorin:XSeries:"))
         }
+
+        relocate("com.cjcrafter.foliascheduler", "me.deecaad.core.lib.scheduler") {
+            include(dependency("com.cjcrafter:foliascheduler:"))
+        }
     }
 }

BuildWeaponMechanics/build.gradle.kts

@@ -5,7 +5,7 @@ plugins {
     id("me.deecaad.mechanics-project")
     //id("com.github.johnrengelman.shadow") version "8.1.1"
     id("io.github.goooler.shadow") version "8.1.7"
-    id("net.minecrell.plugin-yml.bukkit") version "0.5.1"
+    id("net.minecrell.plugin-yml.bukkit") version "0.6.0"
 }
 
 dependencies {
@@ -39,6 +39,7 @@ bukkit {
     name = "WeaponMechanics" // Since we don't want to use "BuildWeaponMechanics"
     version = weaponMechanicsVersion
     apiVersion = "1.13"
+    foliaSupported = true
 
     authors = listOf("DeeCaaD", "CJCrafter")
     depend = listOf("ProtocolLib")
@@ -93,4 +94,5 @@ tasks.shadowJar {
     // to the mechanics core lib.
     relocate("net.kyori", "me.deecaad.core.lib")
     relocate("kotlin.", "me.deecaad.weaponmechanics.lib.kotlin.")
+    relocate("com.cjcrafter.foliascheduler", "me.deecaad.core.lib.scheduler")
 }

MechanicsCore/build.gradle.kts

@@ -8,7 +8,7 @@ plugins {
 
 repositories {
     mavenCentral()
-    maven(url = "https://mvn.lumine.io/repository/maven-public/")
+    maven(url = "https://mvn.lumine.io/repository/maven-public/") // Mythic
 }
 
 dependencies {
@@ -31,8 +31,10 @@ dependencies {
     implementation("org.slf4j:slf4j-nop:1.7.30")
     implementation(Dependencies.MYTHIC_MOBS)
     implementation(Dependencies.X_SERIES)
+    implementation(Dependencies.FOLIA_SCHEDULER)
     implementation("xyz.jpenilla:reflection-remapper:0.1.1")
     implementation("net.fabricmc:mapping-io:0.5.0")
+    implementation(Dependencies.FAST_UTIL)
 
     testImplementation("org.junit.jupiter:junit-jupiter:5.9.2")
     testImplementation(Dependencies.LATEST_SPIGOT_API)

MechanicsCore/src/main/java/me/deecaad/core/MechanicsCore.java

@@ -1,5 +1,7 @@
 package me.deecaad.core;
 
+import com.cjcrafter.foliascheduler.FoliaCompatibility;
+import com.cjcrafter.foliascheduler.ServerImplementation;
 import me.deecaad.core.events.QueueSerializerEvent;
 import me.deecaad.core.events.triggers.EquipListener;
 import me.deecaad.core.file.JarSearcher;
@@ -30,6 +32,7 @@
 import org.bukkit.event.HandlerList;
 import org.bukkit.event.Listener;
 import org.bukkit.plugin.java.JavaPlugin;
+import org.jetbrains.annotations.NotNull;
 
 import java.io.File;
 import java.io.IOException;
@@ -43,10 +46,12 @@ public class MechanicsCore extends JavaPlugin {
 
     public BukkitAudiences adventure;
     public MiniMessage message;
+    public ServerImplementation foliaScheduler;
     private boolean registeredMechanics;
 
     public void onLoad() {
         instance = this;
+        foliaScheduler = new FoliaCompatibility(this).getServerImplementation();
 
         int level = getConfig().getInt("Debug_Level");
         boolean printTraces = getConfig().getBoolean("Print_Traces");
@@ -138,12 +143,15 @@ public void onQueue(QueueSerializerEvent event) throws IOException {
 
     public void onDisable() {
         HandlerList.unregisterAll(this);
-        Bukkit.getServer().getScheduler().cancelTasks(this);
         debug = null;
         adventure.close();
         adventure = null;
     }
 
+    public @NotNull ServerImplementation getFoliaScheduler() {
+        return foliaScheduler;
+    }
+
     /**
      * @return the MechanicsCore plugin instance
      */

MechanicsCore/src/main/java/me/deecaad/core/database/Database.java

@@ -2,10 +2,14 @@
 
 import me.deecaad.core.MechanicsCore;
 import me.deecaad.core.utils.LogLevel;
-import org.bukkit.scheduler.BukkitRunnable;
-
 import org.jetbrains.annotations.Nullable;
-import java.sql.*;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.sql.Statement;
 import java.util.function.Consumer;
 
 public abstract class Database {
@@ -66,11 +70,7 @@ public void executeUpdate(boolean forceSync, String... sql) {
             return;
         }
 
-        new BukkitRunnable() {
-            public void run() {
-                executeUpdate(sql);
-            }
-        }.runTaskAsynchronously(MechanicsCore.getPlugin());
+        MechanicsCore.getPlugin().getFoliaScheduler().async().runNow(() -> executeUpdate(sql));
     }
 
     private void executeUpdate(String... sql) {
@@ -130,23 +130,22 @@ private void executeUpdate(String... sql) {
     public void executeQuery(String sql, Consumer<ResultSet> consumer) {
         if (sql == null || sql.isEmpty() || consumer == null)
             throw new IllegalArgumentException("Empty statement or null consumer");
-        new BukkitRunnable() {
-            public void run() {
-                Connection connection = null;
-                PreparedStatement preparedStatement = null;
-                ResultSet resultSet = null;
-                try {
-                    connection = getConnection();
-                    preparedStatement = connection.prepareStatement(sql);
-                    resultSet = preparedStatement.executeQuery();
-                    consumer.accept(resultSet);
-                } catch (SQLException e) {
-                    MechanicsCore.debug.log(LogLevel.ERROR, e);
-                } finally {
-                    close(connection, preparedStatement, resultSet);
-                }
+
+        MechanicsCore.getPlugin().getFoliaScheduler().async().runNow(() -> {
+            Connection connection = null;
+            PreparedStatement preparedStatement = null;
+            ResultSet resultSet = null;
+            try {
+                connection = getConnection();
+                preparedStatement = connection.prepareStatement(sql);
+                resultSet = preparedStatement.executeQuery();
+                consumer.accept(resultSet);
+            } catch (SQLException e) {
+                MechanicsCore.debug.log(LogLevel.ERROR, e);
+            } finally {
+                close(connection, preparedStatement, resultSet);
             }
-        }.runTaskAsynchronously(MechanicsCore.getPlugin());
+        });
     }
 
     /**

MechanicsCore/src/main/java/me/deecaad/core/events/triggers/EquipListener.java

@@ -26,7 +26,6 @@
 import org.bukkit.inventory.PlayerInventory;
 import org.bukkit.plugin.PluginDescriptionFile;
 import org.bukkit.plugin.java.JavaPlugin;
-import org.bukkit.scheduler.BukkitRunnable;
 
 import java.lang.reflect.Field;
 import java.util.HashSet;
@@ -122,12 +121,7 @@ public void onDrop(PlayerDropItemEvent event) {
 
             // Register, then unregister in 1 tick
             Bukkit.getPluginManager().registerEvents(listener, MechanicsCore.getPlugin());
-            new BukkitRunnable() {
-                @Override
-                public void run() {
-                    HandlerList.unregisterAll(listener);
-                }
-            }.runTask(MechanicsCore.getPlugin());
+            MechanicsCore.getPlugin().getFoliaScheduler().global().run(() -> HandlerList.unregisterAll(listener));
         }
     }