Function TestClientRetriesHTTP500

internal/registry/github/client_test.go:489–522

(t *testing.T)

}

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

	var attempts int
	server := newGitHubServer(t, func(writer http.ResponseWriter, request *http.Request) {
		if request.URL.Path != "/repos/acme/demo/releases/latest" {
			http.NotFound(writer, request)
			return
		}
		attempts++
		if attempts < 3 {
			http.Error(writer, `{"message":"temporary failure"}`, http.StatusInternalServerError)
			return
		}
		writeJSON(
			writer,
			`{"tag_name":"v1.2.3","draft":false,"prerelease":false,"tarball_url":"`+serverURLPlaceholder+`/downloads/source.tar.gz","assets":[]}`,
		)
	})
	defer server.Close()

	client := NewClient(
		server.URL,
		WithRetryPolicy(time.Millisecond, time.Millisecond, 2),
		WithSleep(func(context.Context, time.Duration) error { return nil }),
	)
	_, err := client.fetchLatestRelease(context.Background(), repoSlug{owner: "acme", name: "demo", full: "acme/demo"})
	if err != nil {
		t.Fatalf("fetchLatestRelease() error = %v", err)
	}
	if attempts != 3 {
		t.Fatalf("attempts = %d, want 3", attempts)
	}
}

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