Cookies_Github_mirror/AquaDX
4
0
Fork 1
mirror of https://github.com/MewoLab/AquaDX.git synced 2026-02-08 09:38:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

[-] Revert aeab453e

Browse Source
This commit is contained in:
Azalea
2025-01-17 06:17:32 -05:00
parent a374f7a44b
commit 2b6c283cd1
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariRelay.kt
View File

@@ -64,6 +64,11 @@ fun ActiveClient.handle(msg: Msg) {
lastHeartbeat = millis() lastHeartbeat = millis()
send(ctlMsg(Command.CTL_HEARTBEAT)) 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.DATA_SEND -> {
target ?: return log.warn("Send: Target not found: ${msg.dst}") target ?: return log.warn("Send: Target not found: ${msg.dst}")

2
src/main/java/icu/samnyan/aqua/sega/maimai2/worldslink/FutariTypes.kt
View File

@@ -8,9 +8,11 @@ import ext.str
object Command { object Command {
// Control plane // Control plane
const val CTL_START = 1u const val CTL_START = 1u
const val CTL_BIND = 2u
const val CTL_HEARTBEAT = 3u const val CTL_HEARTBEAT = 3u
const val CTL_TCP_CONNECT = 4u // Accept a new multiplexed TCP stream const val CTL_TCP_CONNECT = 4u // Accept a new multiplexed TCP stream
const val CTL_TCP_ACCEPT = 5u const val CTL_TCP_ACCEPT = 5u
const val CTL_TCP_ACCEPT_ACK = 6u
const val CTL_TCP_CLOSE = 7u const val CTL_TCP_CLOSE = 7u
// Data plane // Data plane