Function TestURLSource_Read_HTTPError

pkg/config/sources_test.go:274–306

(t *testing.T)

}

func TestURLSource_Read_HTTPError(t *testing.T) {
	t.Parallel()

	tests := []struct {
		name       string
		statusCode int
	}{
		{"not found", http.StatusNotFound},
		{"server error", http.StatusInternalServerError},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			t.Parallel()

			server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
				w.WriteHeader(tt.statusCode)
			}))
			t.Cleanup(server.Close)

			// Clean up any cached data for this URL to ensure we test the error path
			urlCacheDir := getURLCacheDir()
			urlHash := hashURL(server.URL)
			cachePath := filepath.Join(urlCacheDir, urlHash)
			etagPath := cachePath + ".etag"
			_ = os.Remove(cachePath)
			_ = os.Remove(etagPath)

			_, err := newURLSourceForTest(server.URL, nil).Read(t.Context())
			require.Error(t, err)
		})
	}
}

func TestURLSource_Read_ConnectionError(t *testing.T) {
	t.Parallel()