Method hello

kontrol/helper_test.go:188–241

(remote *HelloKite, force bool)

}

func (hk *HelloKite) hello(remote *HelloKite, force bool) (string, error) {
	const timeout = 10 * time.Second

	c, ok := hk.clients[remote.Kite.Id]
	if !ok || force {
		if hk.Token {
			query := &protocol.KontrolQuery{
				ID: remote.Kite.Id,
			}

			kites, err := hk.Kite.GetKites(query)
			if err != nil {
				return "", fmt.Errorf("%s: %+v", err, query)
			}

			if len(kites) != 1 {
				return "", fmt.Errorf("%s: expected to get 1 kite, got %d", remote.Kite.Id, len(kites))
			}

			c = kites[0]
			c.OnTokenExpire(hk.onTokenExpire)
			c.OnTokenRenew(hk.onTokenRenew)
		} else {
			c = hk.Kite.NewClient(remote.URL.String())
			c.Auth = &kite.Auth{
				Type: "kiteKey",
				Key:  hk.Kite.KiteKey(),
			}
		}

		if err := c.DialTimeout(timeout); err != nil {
			return "", err
		}

		hk.clients[remote.Kite.Id] = c
	}

	res, err := c.TellWithTimeout("hello", timeout)
	if err != nil {
		// TODO(rjeczalik): remove "timeout" - see comment in (*Client).sendHub method
		if e, ok := err.(*kite.Error); ok && (e.Type == "disconnect" || e.Type == "timeout") && !force {
			return hk.hello(remote, true)
		}

		return "", err
	}

	s, err := res.String()
	if err != nil {
		return "", err
	}

	return s, nil
}

func (hk *HelloKite) Close() error {
	for _, c := range hk.clients {