Update Receive.kt

Mesagisto · Oct 3, 2023 · a161634 · a161634
1 parent 9a8eda4
commit a161634
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/src/main/kotlin/handlers/Receive.kt b/src/main/kotlin/handlers/Receive.kt
@@ -23,24 +23,21 @@ object Receive {
   suspend fun packetHandler(pkt: Packet): Result<ControlFlow<Packet, Unit>> = withCatch(Plugin.coroutineContext) fn@{
     Logger.info { "Receive msg from ${pkt.roomId}" }
     if (pkt.ctl != null) {
+      Logger.info { "Ignoring control packet" }
       return@fn ControlFlow.Continue(Unit)
     }
     val it = pkt.decrypt()
       .onFailure {
-        Logger.warn { "数据解密失败" }
+        Logger.warn { "Failed to decrypt packet" }
       }
       .getOrThrow()
     when (it) {
       is Either.Left -> {
-        val futs = arrayListOf<Deferred<Result<Unit>>>()
         for (target in Config.targetId(pkt.roomId) ?: return@fn ControlFlow.Break(pkt)) {
           if (!it.value.from.contentEquals(target.toByteArray())) {
-            futs += async {
-              msgHandler(it.value, target, "mesagisto").onFailure { e -> Logger.error(e) }
-            }
+            msgHandler(it.value, target, "mesagisto").onFailure { e -> Logger.error(e) }
           }
         }
-        futs.joinAll()
       }
       is Either.Right -> {
         when (it.value) {