avoid adding new public function

Signed-off-by: CI <ci@argoproj.com>
pull/11172/head
CI 2 years ago
parent 32a41fcfac
commit cd76fcd805

@ -207,7 +207,7 @@ func (o *repoAddOptions) run(out io.Writer) error {
if o.repoCache != "" { if o.repoCache != "" {
r.CachePath = o.repoCache r.CachePath = o.repoCache
} }
if _, _, err := r.DownloadIndexFile(); err != nil { if _, err := r.DownloadIndexFile(); err != nil {
return errors.Wrapf(err, "looks like %q is not a valid chart repository or cannot be reached", o.url) return errors.Wrapf(err, "looks like %q is not a valid chart repository or cannot be reached", o.url)
} }

@ -122,7 +122,7 @@ func updateCharts(repos []*repo.ChartRepository, out io.Writer, failOnRepoUpdate
wg.Add(1) wg.Add(1)
go func(re *repo.ChartRepository) { go func(re *repo.ChartRepository) {
defer wg.Done() defer wg.Done()
if _, _, err := re.DownloadIndexFile(); err != nil { if _, err := re.DownloadIndexFile(); err != nil {
fmt.Fprintf(out, "...Unable to get an update from the %q chart repository (%s):\n\t%s\n", re.Config.Name, re.Config.URL, err) fmt.Fprintf(out, "...Unable to get an update from the %q chart repository (%s):\n\t%s\n", re.Config.Name, re.Config.URL, err)
repoFailList = append(repoFailList, re.Config.URL) repoFailList = append(repoFailList, re.Config.URL)
} else { } else {

@ -670,7 +670,7 @@ func (m *Manager) parallelRepoUpdate(repos []*repo.Entry) error {
} }
wg.Add(1) wg.Add(1)
go func(r *repo.ChartRepository) { go func(r *repo.ChartRepository) {
if _, _, err := r.DownloadIndexFile(); err != nil { if _, err := r.DownloadIndexFile(); err != nil {
// For those dependencies that are not known to helm and using a // For those dependencies that are not known to helm and using a
// generated key name we display the repo url. // generated key name we display the repo url.
if strings.HasPrefix(r.Config.Name, managerKeyPrefix) { if strings.HasPrefix(r.Config.Name, managerKeyPrefix) {

@ -115,10 +115,10 @@ func (r *ChartRepository) Load() error {
} }
// DownloadIndexFile fetches the index from a repository. // DownloadIndexFile fetches the index from a repository.
func (r *ChartRepository) DownloadIndexFile() (string, string, error) { func (r *ChartRepository) DownloadIndexFile() (string, error) {
parsedURL, err := url.Parse(r.Config.URL) parsedURL, err := url.Parse(r.Config.URL)
if err != nil { if err != nil {
return "", "", err return "", err
} }
parsedURL.RawPath = path.Join(parsedURL.RawPath, "index.yaml") parsedURL.RawPath = path.Join(parsedURL.RawPath, "index.yaml")
parsedURL.Path = path.Join(parsedURL.Path, "index.yaml") parsedURL.Path = path.Join(parsedURL.Path, "index.yaml")
@ -133,17 +133,17 @@ func (r *ChartRepository) DownloadIndexFile() (string, string, error) {
getter.WithPassCredentialsAll(r.Config.PassCredentialsAll), getter.WithPassCredentialsAll(r.Config.PassCredentialsAll),
) )
if err != nil { if err != nil {
return "", "", err return "", err
} }
index, err := ioutil.ReadAll(resp) index, err := ioutil.ReadAll(resp)
if err != nil { if err != nil {
return "", "", err return "", err
} }
indexFile, err := loadIndex(index, r.Config.URL) indexFile, err := loadIndex(index, r.Config.URL)
if err != nil { if err != nil {
return "", "", err return "", err
} }
// Create the chart list file in the cache directory // Create the chart list file in the cache directory
@ -158,7 +158,7 @@ func (r *ChartRepository) DownloadIndexFile() (string, string, error) {
// Create the index file in the cache directory // Create the index file in the cache directory
fname := filepath.Join(r.CachePath, helmpath.CacheIndexFile(r.Config.Name)) fname := filepath.Join(r.CachePath, helmpath.CacheIndexFile(r.Config.Name))
os.MkdirAll(filepath.Dir(fname), 0755) os.MkdirAll(filepath.Dir(fname), 0755)
return fname, chartsFile, ioutil.WriteFile(fname, index, 0644) return fname, ioutil.WriteFile(fname, index, 0644)
} }
// Index generates an index for the chart repository and writes an index.yaml file. // Index generates an index for the chart repository and writes an index.yaml file.
@ -249,13 +249,14 @@ func FindChartInAuthAndTLSAndPassRepoURL(repoURL, username, password, chartName,
if err != nil { if err != nil {
return "", err return "", err
} }
idx, chart, err := r.DownloadIndexFile() // Use a random path name so it can be deleted for cleanup.
r.CachePath = helmpath.CachePath(name)
idx, err := r.DownloadIndexFile()
if err != nil { if err != nil {
return "", errors.Wrapf(err, "looks like %q is not a valid chart repository or cannot be reached", repoURL) return "", errors.Wrapf(err, "looks like %q is not a valid chart repository or cannot be reached", repoURL)
} }
// Clean up temp files. // Clean up temp files.
defer os.RemoveAll(idx) defer os.RemoveAll(r.CachePath)
defer os.RemoveAll(chart)
// Read the index file for the repository to get chart information and return chart URL // Read the index file for the repository to get chart information and return chart URL
repoIndex, err := LoadIndexFile(idx) repoIndex, err := LoadIndexFile(idx)

@ -156,7 +156,7 @@ func TestIndexCustomSchemeDownload(t *testing.T) {
} }
defer os.Remove(tempIndexFile.Name()) defer os.Remove(tempIndexFile.Name())
idx, _, err := repo.DownloadIndexFile() idx, err := repo.DownloadIndexFile()
if err != nil { if err != nil {
t.Fatalf("Failed to download index file to %s: %v", idx, err) t.Fatalf("Failed to download index file to %s: %v", idx, err)
} }

@ -237,7 +237,7 @@ func TestDownloadIndexFile(t *testing.T) {
t.Errorf("Problem creating chart repository from %s: %v", testRepo, err) t.Errorf("Problem creating chart repository from %s: %v", testRepo, err)
} }
idx, _, err := r.DownloadIndexFile() idx, err := r.DownloadIndexFile()
if err != nil { if err != nil {
t.Fatalf("Failed to download index file to %s: %#v", idx, err) t.Fatalf("Failed to download index file to %s: %#v", idx, err)
} }
@ -290,7 +290,7 @@ func TestDownloadIndexFile(t *testing.T) {
t.Errorf("Problem creating chart repository from %s: %v", testRepo, err) t.Errorf("Problem creating chart repository from %s: %v", testRepo, err)
} }
idx, _, err := r.DownloadIndexFile() idx, err := r.DownloadIndexFile()
if err != nil { if err != nil {
t.Fatalf("Failed to download index file to %s: %#v", idx, err) t.Fatalf("Failed to download index file to %s: %#v", idx, err)
} }

Loading…
Cancel
Save