43 lines
1.2 KiB
Go
43 lines
1.2 KiB
Go
package serverCommunication
|
|
|
|
import (
|
|
"time"
|
|
|
|
"krakatoa.net/backend/modules/cache"
|
|
"krakatoa.net/backend/modules/configs/kraSettingsConfig"
|
|
"krakatoa.net/backend/modules/logger"
|
|
)
|
|
|
|
/*
|
|
func getClientByDest(dest int, uuid string) (*structs.WebClient, *structs.MinecraftClient) {
|
|
switch dest {
|
|
case kraProtocol.DestVoice:
|
|
return GetWebClientByUuid(uuid), nil
|
|
case kraProtocol.DestMobile:
|
|
return GetWebClientByUuid(uuid), nil
|
|
case kraProtocol.DestProxy:
|
|
return nil, GetMinecraftClientByName("proxy-1")
|
|
case kraProtocol.DestPlayersCurrentServer:
|
|
return nil, GetMinecraftClientByName("lobby-1")
|
|
default:
|
|
logger.Web.Println("conn for dest is nil")
|
|
return nil, nil
|
|
}
|
|
}
|
|
*/
|
|
|
|
func AckHandler() {
|
|
ticker := time.NewTicker(5 * time.Second) // 20 * time.Millisecond
|
|
|
|
for _ = range ticker.C {
|
|
/*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, kraSettingsConfig.Cfg.WebSocket.AckTimeouts[2])
|
|
}
|
|
}
|
|
}
|