26 lines
634 B
Go
26 lines
634 B
Go
package socketclients
|
|
|
|
import (
|
|
"strconv"
|
|
"time"
|
|
|
|
"clickandjoin.app/managementsystem/modules/cache"
|
|
gocnjhelper "git.clickandjoin.umbach.dev/ClickandJoin/go-cnj-helper"
|
|
)
|
|
|
|
func BroadcastLogMessage(rabbitMqLogMessage []gocnjhelper.RabbitMqLogMessage) {
|
|
for _, client := range cache.GetSocketClients() {
|
|
client.SendMessage(rabbitMqLogMessage)
|
|
}
|
|
}
|
|
|
|
func BroadcastViewersCountMessage(joined int) {
|
|
BroadcastLogMessage([]gocnjhelper.RabbitMqLogMessage{{
|
|
MessageType: 100,
|
|
ServiceName: 100,
|
|
ServiceType: uint8(joined),
|
|
Msg: strconv.Itoa(len(cache.GetSocketClients())),
|
|
Timestamp: time.Now().UnixMilli(),
|
|
}})
|
|
}
|