diff --git a/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariRelay.kt b/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariRelay.kt index 1b9ef0ae..9f786e55 100644 --- a/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariRelay.kt +++ b/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariRelay.kt @@ -64,11 +64,6 @@ fun ActiveClient.handle(msg: Msg) { lastHeartbeat = millis() send(ctlMsg(Command.CTL_HEARTBEAT)) } - 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.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}") diff --git a/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariTypes.kt b/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariTypes.kt index c011af57..58fdbcf9 100644 --- a/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariTypes.kt +++ b/src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariTypes.kt @@ -8,11 +8,9 @@ import ext.str object Command { // Control plane const val CTL_START = 1u - const val CTL_BIND = 2u const val CTL_HEARTBEAT = 3u const val CTL_TCP_CONNECT = 4u // Accept a new multiplexed TCP stream const val CTL_TCP_ACCEPT = 5u - const val CTL_TCP_ACCEPT_ACK = 6u const val CTL_TCP_CLOSE = 7u // Data plane