ack handling

master
Alex 2022-03-19 00:06:31 +01:00
parent 254fd6c74a
commit 10b3c83ed5
1 changed files with 9 additions and 5 deletions

View File

@ -33,16 +33,18 @@ func AckHandler() {
for _ = range ticker.C {
currentTime := time.Now()
logger.Web.Debugln("ack handler running")
for _, webClient := range cache.WebClients {
if len(webClient.SendVoiceQueueMessages) > 0 {
logger.Web.Debugln("ackHandler voice:", webClient.SendVoiceQueueMessages)
}
for _, msg := range webClient.SendVoiceQueueMessages {
handleSendQueueMessage(currentTime, webClient, true, nil, msg)
}
if len(webClient.SendMobileQueueMessages) > 0 {
logger.Web.Debugln("ackHandler mobile:", webClient.SendMobileQueueMessages)
}
for _, msg := range webClient.SendMobileQueueMessages {
handleSendQueueMessage(currentTime, webClient, false, nil, msg)
@ -50,7 +52,9 @@ func AckHandler() {
}
for _, mcClient := range cache.MinecraftClients {
if len(mcClient.SendQueueMessages) > 0 {
logger.Web.Debugln("ackHandler mcClient:", mcClient.Name, "msgs:", mcClient.SendQueueMessages)
}
for _, msg := range mcClient.SendQueueMessages {
handleSendQueueMessage(currentTime, nil, false, mcClient, msg)