Function TestFstatRemote

pkg/discovery/content/reader/reader_test.go:98–139

(t *testing.T)

}

func TestFstatRemote(t *testing.T) {
	m := map[string][]string{}

	expected := "expected-result"
	svr := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if "?"+r.URL.RawQuery == query {
			w.Header().Set("Content-Type", "application/octet-stream")
			// nolint:errcheck
			w.Write([]byte(expected))
		} else {
			w.WriteHeader(http.StatusNotFound)
		}
	}))
	defer svr.Close()
	p := svr.URL + "/some-path"
	u := "http://127.0.0.1:5000/blobs/" + p + query
	req, err := http.NewRequest("GET", u, nil)
	if err != nil {
		t.Fatal(err)
	}

	router := mocks.NewMockRouter(m)
	c, _ := gin.CreateTestContext(httptest.NewRecorder())
	c.Request = req
	c.Params = []gin.Param{
		{Key: "url", Value: p},
	}

	pc := pcontext.FromContext(c)

	pc.Set(pcontext.BlobUrlCtxKey, pcontext.BlobUrl(pc))
	pc.Set(pcontext.BlobRangeCtxKey, "bytes=0-0")

	r := NewReader(pc, router, 3, 500*time.Millisecond, mr).(*reader)

	got, err := r.FstatRemote()
	if err != nil {
		t.Fatal(err)
	} else if got != int64(len(expected)) {
		t.Fatalf("expected %v, got %v", len(expected), got)
	}
}

func TestFstatRemotePartialContent(t *testing.T) {
	m := map[string][]string{}