Function TestRegisterToKontrol

test/kontrolclient_test.go:51–79

(t *testing.T)

}

func TestRegisterToKontrol(t *testing.T) {
	k := setup()
	defer k.Close()

	kiteURL := &url.URL{Scheme: "http", Host: "zubuzaretta:16500", Path: "/kite"}
	go k.RegisterForever(kiteURL)

	select {
	case <-k.KontrolReadyNotify():
		kites, err := k.GetKites(&protocol.KontrolQuery{
			Username:    k.Kite().Username,
			Environment: k.Kite().Environment,
			Name:        k.Kite().Name,
		})
		if err != nil {
			t.Fatal(err)
		}

		first := kites[0]
		if first.Username != k.Kite().Username {
			t.Errorf("unexpected kite. got: %s, want: %s", first.Kite, *k.Kite())
		}
		if first.URL != "http://zubuzaretta:16500/kite" {
			t.Errorf("unexpected url: %s", first.URL)
		}
	case <-time.After(10 * time.Second):
		t.Fatal("timeout")
	}
}

func setup() *kite.Kite {
	k := kite.New("test", "1.0.0")