feat: Fix async

HaHaWTH · Mar 11, 2024 · a43bb00 · a43bb00
1 parent 65c8fb5
commit a43bb00
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 10 deletions.
diff --git a/src/main/java/io/wdsj/asw/listener/packet/ASWPacketListener.java b/src/main/java/io/wdsj/asw/listener/packet/ASWPacketListener.java
@@ -78,8 +78,10 @@ public void onPacketReceive(PacketReceiveEvent event) {
                 }
                 long endTime = System.currentTimeMillis();
                 addProcessStatistic(endTime, startTime);
-                Notifier.notice(player, EventType.CHAT, originalMessage);
-                Punishment.punish(player);
+                getScheduler().runTask(()-> {
+                    Notifier.notice(player, EventType.CHAT, originalMessage);
+                    Punishment.punish(player);
+                });
                 return;
             }
 
@@ -109,8 +111,10 @@ public void onPacketReceive(PacketReceiveEvent event) {
                     }
                     long endTime = System.currentTimeMillis();
                     addProcessStatistic(endTime, startTime);
-                    Notifier.notice(player, EventType.CHAT, originalContext);
-                    Punishment.punish(player);
+                    getScheduler().runTask(()-> {
+                        Notifier.notice(player, EventType.CHAT, originalContext);
+                        Punishment.punish(player);
+                    });
                 }
             }
         } else if (packetType == PacketType.Play.Client.CHAT_COMMAND) {
@@ -143,8 +147,10 @@ public void onPacketReceive(PacketReceiveEvent event) {
                 }
                 long endTime = System.currentTimeMillis();
                 addProcessStatistic(endTime, startTime);
-                Notifier.notice(player, EventType.CHAT, "/" + originalCommand);
-                Punishment.punish(player);
+                getScheduler().runTask(()-> {
+                    Notifier.notice(player, EventType.CHAT, originalCommand);
+                    Punishment.punish(player);
+                });
             }
         }
     }

diff --git a/src/main/java/io/wdsj/asw/listener/packet/ProtocolLibListener.java b/src/main/java/io/wdsj/asw/listener/packet/ProtocolLibListener.java
@@ -75,8 +75,10 @@ public void onPacketReceiving(@NotNull com.comphenix.protocol.events.PacketEvent
                         }
                         long endTime = System.currentTimeMillis();
                         addProcessStatistic(endTime, startTime);
-                        Notifier.notice(player, EventType.CHAT, message);
-                        Punishment.punish(player);
+                        getScheduler().runTask(()-> {
+                            Notifier.notice(player, EventType.CHAT, message);
+                            Punishment.punish(player);
+                        });
                         return;
                     }
 
@@ -103,8 +105,10 @@ public void onPacketReceiving(@NotNull com.comphenix.protocol.events.PacketEvent
                             }
                             long endTime = System.currentTimeMillis();
                             addProcessStatistic(endTime, startTime);
-                            Notifier.notice(player, EventType.CHAT, originalContext);
-                            Punishment.punish(player);
+                            getScheduler().runTask(()-> {
+                                Notifier.notice(player, EventType.CHAT, originalContext);
+                                Punishment.punish(player);
+                            });
                         }
                     }
                 }