Function TestProcessesRequestWithShuntBackend

proxy/proxy_test.go:1151–1183

(t *testing.T)

}

func TestProcessesRequestWithShuntBackend(t *testing.T) {
	u, _ := url.ParseRequestURI("https://www.example.org/hello")
	reqBody := strings.NewReader("sample request body")
	r := &http.Request{
		URL:    u,
		Method: "POST",
		Body:   io.NopCloser(reqBody),
		Header: http.Header{"X-Test-Header": []string{"test value"}}}
	w := httptest.NewRecorder()

	fr := make(filters.Registry)
	fr.Register(builtin.NewAppendResponseHeader())

	doc := `hello: Path("/hello") -> appendResponseHeader("X-Test-Response-Header", "response header value") -> <shunt>`
	tp, err := newTestProxyWithFilters(fr, doc, FlagsNone)
	if err != nil {
		t.Error(err)
		return
	}

	defer tp.close()

	tp.proxy.ServeHTTP(w, r)

	if h, ok := w.Header()["X-Test-Response-Header"]; !ok || h[0] != "response header value" {
		t.Error("wrong response header")
	}
	_, err = reqBody.ReadByte()
	if err != io.EOF {
		t.Error("request body was not read")
	}

}

func TestProcessesRequestWithPriorityRoute(t *testing.T) {
	s := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {