(func) send unread message notice every time player recovery from afk if they have any

Author: Lori3f6

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>cat.nyaa</groupId>
     <artifactId>ukit</artifactId>
-    <version>1.7.1</version>
+    <version>1.7.2</version>
 
     <properties>
         <maven.compiler.source>21</maven.compiler.source>

src/main/java/cat/nyaa/ukit/loginpush/LoginPushFunction.java

@@ -4,6 +4,7 @@
 import cat.nyaa.ukit.utils.SubCommandExecutor;
 import cat.nyaa.ukit.utils.SubTabCompleter;
 import land.melon.lab.simplelanguageloader.utils.Pair;
+import net.ess3.api.events.AfkStatusChangeEvent;
 import net.kyori.adventure.text.Component;
 import org.bukkit.Bukkit;
 import org.bukkit.command.Command;
@@ -77,20 +78,17 @@ public boolean invokeCommand(CommandSender commandSender, Command command, Strin
     @EventHandler
     public void onPlayerJoin(PlayerJoinEvent event) {
         Bukkit.getAsyncScheduler().runNow(pluginInstance,(task)->{
-            try {
-                int unreadPush = loginPushRecorder.countUnreadPush(event.getPlayer().getUniqueId());
-                if (unreadPush > 0) {
-                    Bukkit.getGlobalRegionScheduler().runDelayed(pluginInstance, (ignored) -> event.getPlayer().sendMessage(pluginInstance.language.loginPushLang.login_push_notice.produce(
-                            Pair.of("number", unreadPush)
-                    )), 20 * 3);
-                }
-            } catch (SQLException e) {
-                e.printStackTrace();
-                event.getPlayer().sendMessage(pluginInstance.language.commonLang.sqlErrorOccurred.produce());
-            }
+            countAndSendMessageIfHasMessage(event.getPlayer());
         });
     }
 
+    @EventHandler
+    public void onAFKStatusChange(AfkStatusChangeEvent event) {
+        if (!event.getValue()) {
+            countAndSendMessageIfHasMessage(event.getAffected().getBase());
+        }
+    }
+
     @Override
     public String getHelp() {
         return pluginInstance.language.loginPushLang.news_help.produce();
@@ -109,4 +107,18 @@ public boolean checkPermission(CommandSender commandSender) {
     public LoginPushRecorder getLoginPushRecorder() {
         return loginPushRecorder;
     }
+
+    private void countAndSendMessageIfHasMessage(Player player) {
+        try {
+            int unreadPush = loginPushRecorder.countUnreadPush(player.getUniqueId());
+            if (unreadPush > 0) {
+                Bukkit.getGlobalRegionScheduler().runDelayed(pluginInstance, (ignored) -> player.sendMessage(pluginInstance.language.loginPushLang.login_push_notice.produce(
+                        Pair.of("number", unreadPush)
+                )), 20 * 3);
+            }
+        } catch (SQLException e) {
+            pluginInstance.getLogger().warning(e.getMessage());
+            player.sendMessage(pluginInstance.language.commonLang.sqlErrorOccurred.produce());
+        }
+    }
 }