Method fetchLatestRelease

internal/registry/github/client.go:287–352

(ctx context.Context, repo repoSlug)

}

func (c *Client) fetchLatestRelease(ctx context.Context, repo repoSlug) (*release, error) {
	endpoint := c.baseURL + "/repos/" + url.PathEscape(
		repo.owner,
	) + "/" + url.PathEscape(
		repo.name,
	) + "/releases/latest"
	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("latest release response for %q", repo.full))
		if err != nil {
			return nil, joinErrors(
				fmt.Errorf("github: read latest release for %q: %w", repo.full, err),
				closeErr,
			)
		}
		if closeErr != nil {
			return nil, closeErr
		}

		var latest release
		if err := json.Unmarshal(payload, &latest); err != nil {
			return nil, fmt.Errorf("github: decode latest release for %q: %w", repo.full, err)
		}
		return &latest, nil
	case http.StatusUnauthorized:
		closeErr := closeResponseBody(
			response.Body,
			fmt.Sprintf("latest release response for %q", repo.full),
		)
		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("latest release response for %q", repo.full),
		); err != nil {
			return nil, err
		}
		releases, listErr := c.fetchReleasePage(ctx, repo)
		if listErr != nil {
			return nil, listErr
		}
		if len(releases) == 0 {
			return nil, fmt.Errorf("github: repository %q has no published releases", repo.full)
		}
		latest := releases[0]
		return &latest, nil