package hipchat

import (
	"time"

	"github.com/daneharrigan/hipchat"
	log "github.com/sirupsen/logrus"
)

type XmppImplementer interface {
	Say(roomID, name, body string)
	Status(s string)
	Join(roomID, resource string)
	KeepAlive()
	Messages() <-chan *hipchat.Message
}

type HipchatClient struct {
	XmppImplementer
}

func connect(username, password string, connAttempts int) *HipchatClient {
	attempts := connAttempts
	for {
		if attempts == 0 {
			log.Errorf("Can not reach hipchat server after %d attempts", connAttempts)
			return nil
		}
		// Room history is automatically sent when joining a room unless your JID resource is “bot”.
		client, err := hipchat.NewClient(username, password, "bot", "plain")

		if err != nil {
			log.Errorf("bot.hipchat.connect: Error=%s", err)
			if err.Error() == "could not authenticate" {
				return nil
			}
		}
		if client != nil && err == nil {
			log.Info("Successfully connected to hipchat server")
			return &HipchatClient{client}
		}
		log.Debugln("Can not connect to hipcaht now, wait fo 30 seconds")
		time.Sleep(30 * time.Second)
		attempts--
	}
}