Method fetchRequestedRelease

internal/registry/github/client.go:354–417

(ctx context.Context, repo repoSlug, version string)

}

func (c *Client) fetchRequestedRelease(ctx context.Context, repo repoSlug, version string) (*release, error) {
	if version == "" {
		return c.fetchLatestRelease(ctx, repo)
	}

	endpoint := c.baseURL + "/repos/" + url.PathEscape(
		repo.owner,
	) + "/" + url.PathEscape(
		repo.name,
	) + "/releases/tags/" + url.PathEscape(
		version,
	)
	response, err := c.doRequest(ctx, endpoint, acceptJSON)
	if err != nil {
		return nil, err
	}
	defer func() {
		_ = response.Body.Close()
	}()

	switch response.StatusCode {
	case http.StatusOK:
		payload, err := io.ReadAll(response.Body)
		closeErr := closeResponseBody(response.Body, fmt.Sprintf("release response for %q at %q", repo.full, version))
		if err != nil {
			return nil, joinErrors(
				fmt.Errorf("github: read release %q for %q: %w", version, repo.full, err),
				closeErr,
			)
		}
		if closeErr != nil {
			return nil, closeErr
		}

		var result release
		if err := json.Unmarshal(payload, &result); err != nil {
			return nil, fmt.Errorf("github: decode release %q for %q: %w", version, repo.full, err)
		}
		if result.Draft || result.Prerelease {
			return nil, fmt.Errorf("github: release %q for %q is not a published full release", version, repo.full)
		}
		return &result, nil
	case http.StatusUnauthorized:
		closeErr := closeResponseBody(response.Body, fmt.Sprintf("release response for %q at %q", repo.full, version))
		if closeErr != nil {
			return nil, joinErrors(privateRepositoryError(repo.full), closeErr)
		}
		return nil, privateRepositoryError(repo.full)
	case http.StatusNotFound:
		if err := closeResponseBody(
			response.Body,
			fmt.Sprintf("release response for %q at %q", repo.full, version),
		); err != nil {
			return nil, err
		}
		return nil, fmt.Errorf("github: release %q not found for repository %q", version, repo.full)
	default:
		err := responseError(response, "release lookup", repo.full)