diff --git a/serverCommunication/serverCommunication.go b/serverCommunication/serverCommunication.go index 524c802..0efd28f 100644 --- a/serverCommunication/serverCommunication.go +++ b/serverCommunication/serverCommunication.go @@ -63,29 +63,28 @@ func handleSendQueueMessage(currentTime time.Time, webClient *structs.WebClient, if int(currentTime.UnixMilli())-int(msg.Time.UnixMilli()) > kraSettingsConfig.Cfg.WebSocket.AckTimeouts[msg.TrySendCount] { var err error - if webClient != nil && mcClient != nil { - msg.Time = currentTime + msg.Time = currentTime - if webClient != nil { - if isVoice { - logger.WebVoice.Debugln("ackHandler -> send msg to voice client") - err = webClient.SendBinaryMessage(webClient.VoiceConn, msg.MessageRaw) - } else { - logger.WebMobile.Debugln("ackHandler -> send msg to mobile client") - err = webClient.SendBinaryMessage(webClient.MobileConn, msg.MessageRaw) - } + if webClient != nil { + if isVoice { + logger.WebVoice.Debugln("ackHandler -> send msg to voice client") + err = webClient.SendBinaryMessage(webClient.VoiceConn, msg.MessageRaw) } else { - logger.Minecraft.Debugln("ackHandler -> send msg to mc client", mcClient.Name) - err = mcClient.SendBinaryMessage(msg.MessageRaw) + logger.WebMobile.Debugln("ackHandler -> send msg to mobile client") + err = webClient.SendBinaryMessage(webClient.MobileConn, msg.MessageRaw) } + } else { + logger.Minecraft.Debugln("ackHandler -> send msg to mc client", mcClient.Name) + err = mcClient.SendBinaryMessage(msg.MessageRaw) + } - if err != nil { - logger.Web.Println("ackHandler err sending msg", err) - } + if err != nil { + logger.Web.Println("ackHandler err sending msg", err) + } - if msg.TrySendCount < 4 { - msg.TrySendCount++ - } + if msg.TrySendCount < 4 { + msg.TrySendCount++ } } + }