Remove unused Download method (Olympus cleanup) (#849)

2026-02-03 11:00:32 +00:00 · 2018-11-02 13:44:23 +01:00
parent 07296736bf
commit f2f3bac51b
1 changed files with 0 additions and 147 deletions
@@ -1,147 +0,0 @@
-package module
-
-import (
-	"context"
-	"io"
-	"io/ioutil"
-	"net/http"
-	"net/url"
-	"path"
-	"sync"
-	"time"
-
-	"github.com/gomods/athens/pkg/config"
-	"github.com/gomods/athens/pkg/errors"
-	"github.com/gomods/athens/pkg/observ"
-	"github.com/gomods/athens/pkg/storage"
-	multierror "github.com/hashicorp/go-multierror"
-)
-
-// Downloader downloads a module version from a URL exposing Download Protocol endpoints
-type Downloader func(ctx context.Context, timeout time.Duration, baseURL, module, version string) (*storage.Version, error)
-
-// Download downloads the module/version from url. Returns a storage.Version
-// representing the downloaded module/version or a non-nil error if something went wrong
-func Download(ctx context.Context, timeout time.Duration, baseURL, module, version string) (*storage.Version, error) {
-	const op errors.Op = "module.Download"
-	ctx, span := observ.StartSpan(ctx, op.String())
-	defer span.End()
-	tctx, cancel := context.WithTimeout(ctx, timeout)
-	defer cancel()
-
-	var info []byte
-	var infoErr error
-
-	var mod []byte
-	var modErr error
-
-	var zip io.ReadCloser
-	var zipErr error
-
-	var wg sync.WaitGroup
-	wg.Add(3)
-
-	go func() {
-		defer wg.Done()
-		infoReq, err := getRequest(tctx, baseURL, module, version, ".info")
-		if err != nil {
-			info, infoErr = nil, err
-			return
-		}
-		infoStream, err := getResBody(infoReq, timeout)
-		if err != nil {
-			info, infoErr = nil, err
-			return
-		}
-		info, infoErr = getBytes(infoStream)
-	}()
-
-	go func() {
-		defer wg.Done()
-		modReq, err := getRequest(tctx, baseURL, module, version, ".mod")
-		if err != nil {
-			mod, modErr = nil, err
-			return
-		}
-		modStream, err := getResBody(modReq, timeout)
-		if err != nil {
-			mod, modErr = nil, err
-			return
-		}
-		mod, modErr = getBytes(modStream)
-	}()
-
-	go func() {
-		defer wg.Done()
-		zipReq, err := getRequest(tctx, baseURL, module, version, ".zip")
-		if err != nil {
-			zip, zipErr = nil, err
-			return
-		}
-		zip, zipErr = getResBody(zipReq, timeout)
-	}()
-	wg.Wait()
-
-	var errs error
-	if infoErr != nil {
-		errs = multierror.Append(errs, infoErr)
-	}
-	if modErr != nil {
-		errs = multierror.Append(errs, modErr)
-	}
-	if zipErr != nil {
-		errs = multierror.Append(errs, zipErr)
-	}
-	if errs != nil {
-		return nil, errors.E(op, errs)
-	}
-
-	ver := storage.Version{
-		Info: info,
-		Mod:  mod,
-		Zip:  zip,
-	}
-	return &ver, nil
-}
-
-func getBytes(rb io.ReadCloser) ([]byte, error) {
-	defer rb.Close()
-	return ioutil.ReadAll(rb)
-}
-
-func getResBody(req *http.Request, timeout time.Duration) (io.ReadCloser, error) {
-	const op errors.Op = "module.getResBody"
-	client := http.Client{Timeout: timeout}
-	res, err := client.Do(req)
-	if err != nil {
-		return nil, errors.E(op, err)
-	}
-	return res.Body, nil
-}
-
-func getRequest(ctx context.Context, baseURL, module, version, ext string) (*http.Request, error) {
-	const op errors.Op = "module.getRequest"
-	ctx, span := observ.StartSpan(ctx, op.String())
-	defer span.End()
-	u, err := join(baseURL, module, version, ext)
-	if err != nil {
-		return nil, errors.E(op, err)
-	}
-	req, err := http.NewRequest(http.MethodGet, u, nil)
-	if err != nil {
-		return nil, errors.E(op, err)
-	}
-	req = req.WithContext(ctx)
-	return req, nil
-}
-
-func join(baseURL string, module, version, ext string) (string, error) {
-	const op errors.Op = "module.join"
-	u, err := url.Parse(baseURL)
-	if err != nil {
-		return "", errors.E(op, err)
-	}
-	packageVersionedName := config.PackageVersionedName(module, version, ext)
-	u.Path = path.Join(u.Path, packageVersionedName)
-	return u.String(), nil
-}