diff --git a/serverCommunication/serverCommunication.go b/serverCommunication/serverCommunication.go index e316360..5861fce 100644 --- a/serverCommunication/serverCommunication.go +++ b/serverCommunication/serverCommunication.go @@ -30,13 +30,33 @@ func AckHandler() { ticker := time.NewTicker(5 * time.Second) // 20 * time.Millisecond for _ = range ticker.C { + currentTime := time.Now() + /*for uuid, webClient := range cache.WebClients { logger.Web.Println("ackHandler web client", uuid, webClient.SendVoiceQueueMessages, webClient.SendMobileQueueMessages) } */ for serverName, mcClient := range cache.MinecraftClients { - logger.Web.Println("ackHandler mc client", serverName, mcClient.SendQueueMessages, kraSettingsConfig.Cfg.WebSocket.AckTimeouts) + logger.Minecraft.Println("ackHandler mc client", serverName, mcClient.SendQueueMessages, kraSettingsConfig.Cfg.WebSocket.AckTimeouts) + + for _, msg := range mcClient.SendQueueMessages { + logger.Minecraft.Println("msg", msg) + + if msg.TrySendCount < 5 { + msg.TrySendCount++ + } + + logger.Minecraft.Println("ackHandler mc", msg.TrySendCount, currentTime.UnixMilli()-msg.Time.UnixMilli()) + /* + if int(currentTime.UnixMilli())-int(msg.Time.UnixMilli()) > kraSettingsConfig.Cfg.WebSocket.AckTimeouts[msg.TrySendCount] { + err := mcClient.SendBinaryMessage(msg.MessageRaw) + + if err != nil { + logger.Minecraft.Println("ackHandler err sending msg", err) + } + } */ + } } } }