From 2e0c567158c9af33337d4434b1a3c9f255df429e Mon Sep 17 00:00:00 2001
From: Azalea <22280294+hykilpikonna@users.noreply.github.com>
Date: Tue, 14 Jan 2025 10:11:49 -0500
Subject: [PATCH] [F] Fix broadcast fail

---
 .../icu/samnyan/aqua/sega/maimai2/worldslink/FutariServer.kt  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariServer.kt b/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariServer.kt
index f3dafadd..dcae46e8 100644
--- a/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariServer.kt
+++ b/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariServer.kt
@@ -54,7 +54,7 @@ fun ActiveClient.handle(msg: Msg) {
         Command.DATA_BROADCAST -> {
             // Broadcast to all clients. This is only used in UDP so SID is always 0
             if (msg.proto != Proto.UDP) return log.warn("TCP Broadcast received, something is wrong.")
-            clients.values.filter { it.clientKey != clientKey }.forEach { it.send(msg.copy(src = stubIp)) }
+            clients.values.forEach { it.send(msg.copy(src = stubIp)) }
         }
         Command.DATA_SEND, Command.CTL_TCP_ACCEPT_ACK -> {
             target ?: return log.warn("Send: Target not found: ${msg.dst}")
@@ -129,7 +129,7 @@ class MaimaiFutari(private val port: Int = 20101) {
         try {
             while (true) {
                 val input = (reader.readLine() ?: continue).trim('\uFEFF')
-                log.debug("Received: $input")
+                log.info("${socket.remoteSocketAddress} (${handler?.clientKey}) <<< $input")
                 val message = Msg.fromString(input)
 
                 when (message.cmd) {