zlax/hptoad
zlax
/
hptoad
1
0
Fork 0
Code Issues Pull Requests Releases Activity

update

This commit is contained in:
cx uname 2012-10-12 13:40:02 +04:00
parent 1bc559ecdf
commit 357be24375
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
main.go
View File

@ -17,6 +17,7 @@ const room = "ttyh@conference.jabber.ru"
const name = "Жобе" const name = "Жобе"
const me = "hypnotoad@xmpp.ru" const me = "hypnotoad@xmpp.ru"
// const room = "kkkkkkk2@conference.jabber.ru"
var ( var (
ping time.Time ping time.Time
admin []string admin []string
@ -24,7 +25,8 @@ var (
func main() { func main() {
runtime.GOMAXPROCS(runtime.NumCPU()) runtime.GOMAXPROCS(runtime.NumCPU())
Conn, err := xmpp.Dial("xmpp.ru:5222", "hypnotoad", "xmpp.ru", "password", "AllHailHypnotoad", nil) start:
Conn, err := xmpp.Dial("xmpp.ru:5222", "hypnotoad", "xmpp.ru", "pass", "AllHailHypnotoad", nil)
if err != nil { if err != nil {
log.Fatalln("Conn", err) log.Fatalln("Conn", err)
} }
@ -35,13 +37,12 @@ func main() {
log.Fatalln("Presence", err) log.Fatalln("Presence", err)
} }
//just in case
go func() { go func() {
for { for {
select { select {
case <-time.After(60 * time.Second): case <-time.After(60 * time.Second):
if _, _, err = Conn.SendIQ("xmpp.ru", "set", "<keepalive xmlns='urn:xmpp:keepalive:0'> <interval>60</interval> </keepalive>"); err != nil { if _, _, err = Conn.SendIQ("xmpp.ru", "set", "<keepalive xmlns='urn:xmpp:keepalive:0'> <interval>60</interval> </keepalive>"); err != nil {
log.Fatalln("KeepAlive", err) log.("KeepAlive", err)
} }
log.Println("SENT 60") log.Println("SENT 60")
} }
@ -51,7 +52,10 @@ func main() {
for { for {
next, err := Conn.Next() next, err := Conn.Next()
if err != nil { if err != nil {
log.Fatalln("Next", err) log.Println("Next", err, "Conn", Conn)
Conn.Close()
time.Sleep(10 * time.Second)
goto start
} }
switch t := next.Value.(type) { switch t := next.Value.(type) {
case *xmpp.ClientPresence: case *xmpp.ClientPresence: