optimize service

src/service/duel/gameMsg.ts

@@ -88,13 +88,9 @@ const ReplayIgnoreMsg = [
   "announce",
 ];
 
-let animation: Promise<unknown> = new Promise<void>((rs) => rs());
-
-export default async function handleGameMsg(pb: ygopro.YgoStocMsg) {
-  animation = animation.then(() => _handleGameMsg(pb));
-}
-
-async function _handleGameMsg(pb: ygopro.YgoStocMsg) {
+export default async function handleGameMsg(
+  pb: ygopro.YgoStocMsg,
+): Promise<void> {
   const msg = pb.stoc_game_msg;
 
   if (ActiveList.includes(msg.gameMsg)) {

src/service/onSocketMessage.ts

@@ -28,7 +28,15 @@ import { handleWaitingSide } from "./side/waitingSide";
  * 然后再分发到各个处理函数中去处理。
  *
  * */
+
+let animation: Promise<void> = Promise.resolve();
+
 export default async function handleSocketMessage(e: MessageEvent) {
+  // 确保按序执行
+  animation = animation.then(() => _handle(e));
+}
+
+async function _handle(e: MessageEvent) {
   const packet = YgoProPacket.deserialize(e.data);
   const pb = adaptStoc(packet);