notify periodically for unread mail

cloudnode-pro · Feb 15, 2024 · 81b44aa · 81b44aa
1 parent 7a3001d
commit 81b44aa
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/src/main/java/pro/cloudnode/smp/cloudnodemsg/CloudnodeMSG.java b/src/main/java/pro/cloudnode/smp/cloudnodemsg/CloudnodeMSG.java
@@ -5,6 +5,8 @@
 import org.bukkit.entity.Player;
 import org.bukkit.metadata.MetadataValue;
 import org.bukkit.plugin.java.JavaPlugin;
+import org.bukkit.scheduler.BukkitRunnable;
+import org.bukkit.scheduler.BukkitTask;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 import pro.cloudnode.smp.cloudnodemsg.command.IgnoreCommand;
@@ -50,11 +52,14 @@ public void onEnable() {
 
         getServer().getPluginManager().registerEvents(new AsyncChatListener(), this);
         getServer().getPluginManager().registerEvents(new PlayerJoinListener(), this);
+
+        minuteLoop = minuteLoop();
     }
 
     @Override
     public void onDisable() {
-        dbSource.close();
+        if (dbSource != null) dbSource.close();
+        if (minuteLoop != null) minuteLoop.cancel();
     }
 
     public static boolean isVanished(final @NotNull Player player) {
@@ -124,4 +129,11 @@ public void runDDL() {
     public static void runAsync(final @NotNull Runnable runnable) {
         getInstance().getServer().getScheduler().runTaskAsynchronously(getInstance(), runnable);
     }
+
+    private @NotNull BukkitTask minuteLoop() {
+        return getServer().getScheduler().runTaskTimerAsynchronously(this, () -> {
+            Mail.notifyUnread();
+        }, 0, 20 * 60);
+    }
+    private @Nullable BukkitTask minuteLoop;
 }