This commit is contained in:
Jay 2018-09-21 23:33:52 +08:00
parent 8504a8c708
commit 83601f2dd0
1 changed files with 7 additions and 1 deletions

View File

@ -43,6 +43,12 @@ func InitIRC() {
err = client.Run()
if err != nil {
fmt.Println("twitch chat connect fail")
// reconnect after 3sec
time.Sleep(time.Second * 3)
client = nil
channels = channels[:0]
queue.Clear()
go InitIRC()
}
}
@ -156,7 +162,7 @@ func runQueue() {
client.WriteMessage(msg)
}
cnt++
if cnt > 1800 {
if cnt > 3600 {
// call rejoin
ReJoin()
cnt = 0