reply handling
parent
e92f715da7
commit
6ecc983eb0
|
@ -47,6 +47,28 @@ func HandleWebMessage(isVoice bool, conn *websocket.Conn, uuid string, msg []byt
|
||||||
// remove cmdID from VoiceCMDIDsByBackend list
|
// remove cmdID from VoiceCMDIDsByBackend list
|
||||||
webClient.RemoveVoiceCmdIDByBackend(cmdID)
|
webClient.RemoveVoiceCmdIDByBackend(cmdID)
|
||||||
|
|
||||||
|
// remove cmdID from minecraftCmdIDs
|
||||||
|
mcClient.RemoveCmdID(data.CmdIDFromMinecraftServer)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
for _, data := range webClient.MobileCmdIDsByBackend {
|
||||||
|
if data.WebCmdID == cmdID { // forward to target dest
|
||||||
|
mcClient := GetMinecraftClientByName(getMinecraftServerNameByDest(data.DestFromMinecraftServer))
|
||||||
|
|
||||||
|
raw = kraProtocol.EncodeJavaMessage(kraProtocol.StatusReply, data.CmdIDFromMinecraftServer, 0, webClient.Uuid, 0, "")
|
||||||
|
|
||||||
|
err = mcClient.SendBinaryMessage(raw)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
logger.Web.Warnln("write:", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// remove cmdID from VoiceCMDIDsByBackend list
|
||||||
|
webClient.RemoveMobileCmdIDByBackend(cmdID)
|
||||||
|
|
||||||
// remove cmdID from minecraftCmdIDs
|
// remove cmdID from minecraftCmdIDs
|
||||||
mcClient.RemoveCmdID(data.CmdIDFromMinecraftServer)
|
mcClient.RemoveCmdID(data.CmdIDFromMinecraftServer)
|
||||||
return
|
return
|
||||||
|
|
Loading…
Reference in New Issue