Function TestRequestWithBasicAuth

etcd/etcd_test.go:625–667

(t *testing.T)

}

func TestRequestWithBasicAuth(t *testing.T) {
	var authHeader string
	s := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		authHeader = r.Header.Get("Authorization")
		w.Header().Set("X-Etcd-Index", "42")
		w.Write([]byte(`{"node": {"key": "foo"}}`))
	}))
	defer s.Close()

	c, err := New(Options{[]string{s.URL}, "/skippertest", 0, false, "", "user", "password"})
	if err != nil {
		t.Fatal(err)
	}

	if err := c.Delete("foo"); err != nil {
		t.Fatal(err)
	}

	k, v, found := strings.Cut(authHeader, " ")
	if !found || k == "" || v == "" {
		t.Error("invalid auth header sent")
		t.Log(authHeader)
		return
	}

	if k != "Basic" {
		t.Error("invalid auth header sent")
		t.Log(authHeader)
		return
	}

	decodedArr, err := base64.StdEncoding.DecodeString(v)
	if err != nil {
		t.Error(err)
		t.Log("header sent:", authHeader)
		return
	}

	decoded := string(decodedArr)
	if decoded != "user:password" {
		t.Fatal("invalid token not set")
	}
}