45 lines
946 B
Go
45 lines
946 B
Go
package main
|
|
|
|
import (
|
|
"log"
|
|
"time"
|
|
|
|
appConfig "github.com/xmpploadtesting/config"
|
|
xmppService "github.com/xmpploadtesting/services"
|
|
)
|
|
|
|
func main() {
|
|
|
|
// LOAD APPLICATION CONFIGURATION
|
|
appConfig.Load()
|
|
|
|
// Initialise XMPP service
|
|
xmppService.Init()
|
|
|
|
// Send online presence stanza
|
|
xmppServiceInstance := xmppService.Instance()
|
|
|
|
for {
|
|
|
|
for _, xmppClient := range xmppServiceInstance.XMPPClients {
|
|
|
|
// Send online presence stanza in go rutines
|
|
go func(xmppClient xmppService.XMPPClient) {
|
|
log.Printf("Online presence stanza FOR %v", xmppClient.Config.Jid)
|
|
err := xmppService.SendOnlinePresenceStanza(xmppClient.Client, xmppClient.Config.Jid)
|
|
|
|
if err != nil {
|
|
log.Printf("There was an error while sending online presence stanza %v", err)
|
|
return
|
|
}
|
|
|
|
}(xmppClient)
|
|
|
|
}
|
|
// Delay before sending another message
|
|
time.Sleep(time.Duration(appConfig.AppConfig.GeneralOptions.DelayBetweenMassages))
|
|
|
|
}
|
|
|
|
}
|