chore: remove unused parts of credentialprovider

Author: plaffitt

internal/registry/credentialprovider/OWNERS

@@ -19,20 +19,8 @@ package credentialprovider
 import (
 	"encoding/base64"
 	"encoding/json"
-	"errors"
 	"fmt"
-	"io"
-	"net/http"
-	"os"
-	"path/filepath"
 	"strings"
-	"sync"
-
-	"k8s.io/klog/v2"
-)
-
-const (
-	maxReadLength = 10 * 1 << 20 // 10MB
 )
 
 // DockerConfigJSON represents ~/.docker/config.json file info
@@ -53,190 +41,6 @@ type DockerConfigEntry struct {
 	Username string
 	Password string
 	Email    string
-	Provider DockerConfigProvider
-}
-
-var (
-	preferredPathLock sync.Mutex
-	preferredPath     = ""
-	workingDirPath    = ""
-	homeDirPath, _    = os.UserHomeDir()
-	rootDirPath       = "/"
-	homeJSONDirPath   = filepath.Join(homeDirPath, ".docker")
-	rootJSONDirPath   = filepath.Join(rootDirPath, ".docker")
-
-	configFileName     = ".dockercfg"
-	configJSONFileName = "config.json"
-)
-
-// SetPreferredDockercfgPath set preferred docker config path
-func SetPreferredDockercfgPath(path string) {
-	preferredPathLock.Lock()
-	defer preferredPathLock.Unlock()
-	preferredPath = path
-}
-
-// GetPreferredDockercfgPath get preferred docker config path
-func GetPreferredDockercfgPath() string {
-	preferredPathLock.Lock()
-	defer preferredPathLock.Unlock()
-	return preferredPath
-}
-
-// DefaultDockercfgPaths returns default search paths of .dockercfg
-func DefaultDockercfgPaths() []string {
-	return []string{GetPreferredDockercfgPath(), workingDirPath, homeDirPath, rootDirPath}
-}
-
-// DefaultDockerConfigJSONPaths returns default search paths of .docker/config.json
-func DefaultDockerConfigJSONPaths() []string {
-	return []string{GetPreferredDockercfgPath(), workingDirPath, homeJSONDirPath, rootJSONDirPath}
-}
-
-// ReadDockercfgFile attempts to read a legacy dockercfg file from the given paths.
-// if searchPaths is empty, the default paths are used.
-func ReadDockercfgFile(searchPaths []string) (cfg DockerConfig, err error) {
-	if len(searchPaths) == 0 {
-		searchPaths = DefaultDockercfgPaths()
-	}
-
-	for _, configPath := range searchPaths {
-		absDockerConfigFileLocation, err := filepath.Abs(filepath.Join(configPath, configFileName))
-		if err != nil {
-			klog.Errorf("while trying to canonicalize %s: %v", configPath, err)
-			continue
-		}
-		klog.V(4).Infof("looking for .dockercfg at %s", absDockerConfigFileLocation)
-		contents, err := os.ReadFile(absDockerConfigFileLocation)
-		if os.IsNotExist(err) {
-			continue
-		}
-		if err != nil {
-			klog.V(4).Infof("while trying to read %s: %v", absDockerConfigFileLocation, err)
-			continue
-		}
-		cfg, err := ReadDockerConfigFileFromBytes(contents)
-		if err != nil {
-			klog.V(4).Infof("couldn't get the config from %q contents: %v", absDockerConfigFileLocation, err)
-			continue
-		}
-
-		klog.V(4).Infof("found .dockercfg at %s", absDockerConfigFileLocation)
-		return cfg, nil
-
-	}
-	return nil, fmt.Errorf("couldn't find valid .dockercfg after checking in %v", searchPaths)
-}
-
-// ReadDockerConfigJSONFile attempts to read a docker config.json file from the given paths.
-// if searchPaths is empty, the default paths are used.
-func ReadDockerConfigJSONFile(searchPaths []string) (cfg DockerConfig, err error) {
-	if len(searchPaths) == 0 {
-		searchPaths = DefaultDockerConfigJSONPaths()
-	}
-	for _, configPath := range searchPaths {
-		absDockerConfigFileLocation, err := filepath.Abs(filepath.Join(configPath, configJSONFileName))
-		if err != nil {
-			klog.Errorf("while trying to canonicalize %s: %v", configPath, err)
-			continue
-		}
-		klog.V(4).Infof("looking for %s at %s", configJSONFileName, absDockerConfigFileLocation)
-		cfg, err = ReadSpecificDockerConfigJSONFile(absDockerConfigFileLocation)
-		if err != nil {
-			if !os.IsNotExist(err) {
-				klog.V(4).Infof("while trying to read %s: %v", absDockerConfigFileLocation, err)
-			}
-			continue
-		}
-		klog.V(4).Infof("found valid %s at %s", configJSONFileName, absDockerConfigFileLocation)
-		return cfg, nil
-	}
-	return nil, fmt.Errorf("couldn't find valid %s after checking in %v", configJSONFileName, searchPaths)
-
-}
-
-// ReadSpecificDockerConfigJSONFile attempts to read docker configJSON from a given file path.
-func ReadSpecificDockerConfigJSONFile(filePath string) (cfg DockerConfig, err error) {
-	var contents []byte
-
-	if contents, err = os.ReadFile(filePath); err != nil {
-		return nil, err
-	}
-	return readDockerConfigJSONFileFromBytes(contents)
-}
-
-// ReadDockerConfigFile read a docker config file from default path
-func ReadDockerConfigFile() (cfg DockerConfig, err error) {
-	if cfg, err := ReadDockerConfigJSONFile(nil); err == nil {
-		return cfg, nil
-	}
-	// Can't find latest config file so check for the old one
-	return ReadDockercfgFile(nil)
-}
-
-// HTTPError wraps a non-StatusOK error code as an error.
-type HTTPError struct {
-	StatusCode int
-	URL        string
-}
-
-// Error implements error
-func (he *HTTPError) Error() string {
-	return fmt.Sprintf("http status code: %d while fetching url %s",
-		he.StatusCode, he.URL)
-}
-
-// ReadURL read contents from given url
-func ReadURL(url string, client *http.Client, header *http.Header) (body []byte, err error) {
-	req, err := http.NewRequest("GET", url, nil)
-	if err != nil {
-		return nil, err
-	}
-	if header != nil {
-		req.Header = *header
-	}
-	resp, err := client.Do(req)
-	if err != nil {
-		return nil, err
-	}
-	defer resp.Body.Close()
-
-	if resp.StatusCode != http.StatusOK {
-		klog.V(2).InfoS("Failed to read URL", "statusCode", resp.StatusCode, "URL", url)
-		return nil, &HTTPError{
-			StatusCode: resp.StatusCode,
-			URL:        url,
-		}
-	}
-
-	limitedReader := &io.LimitedReader{R: resp.Body, N: maxReadLength}
-	contents, err := io.ReadAll(limitedReader)
-	if err != nil {
-		return nil, err
-	}
-
-	if limitedReader.N <= 0 {
-		return nil, errors.New("the read limit is reached")
-	}
-
-	return contents, nil
-}
-
-// ReadDockerConfigFileFromBytes read a docker config file from the given bytes
-func ReadDockerConfigFileFromBytes(contents []byte) (cfg DockerConfig, err error) {
-	if err = json.Unmarshal(contents, &cfg); err != nil {
-		return nil, errors.New("error occurred while trying to unmarshal json")
-	}
-	return
-}
-
-func readDockerConfigJSONFileFromBytes(contents []byte) (cfg DockerConfig, err error) {
-	var cfgJSON DockerConfigJSON
-	if err = json.Unmarshal(contents, &cfgJSON); err != nil {
-		return nil, errors.New("error occurred while trying to unmarshal json")
-	}
-	cfg = cfgJSON.Auths
-	return
 }
 
 // dockerConfigEntryWithAuth is used solely for deserializing the Auth field
@@ -272,18 +76,9 @@ func (ident *DockerConfigEntry) UnmarshalJSON(data []byte) error {
 	return err
 }
 
-// MarshalJSON implements the json.Marshaler interface.
-func (ident DockerConfigEntry) MarshalJSON() ([]byte, error) {
-	toEncode := dockerConfigEntryWithAuth{ident.Username, ident.Password, ident.Email, ""}
-	toEncode.Auth = encodeDockerConfigFieldAuth(ident.Username, ident.Password)
-
-	return json.Marshal(toEncode)
-}
-
 // decodeDockerConfigFieldAuth deserializes the "auth" field from dockercfg into a
 // username and a password. The format of the auth field is base64(<username>:<password>).
 func decodeDockerConfigFieldAuth(field string) (username, password string, err error) {
-
 	var decoded []byte
 
 	// StdEncoding can only decode padded string
@@ -311,9 +106,3 @@ func decodeDockerConfigFieldAuth(field string) (username, password string, err e
 
 	return
 }
-
-func encodeDockerConfigFieldAuth(username, password string) string {
-	fieldValue := username + ":" + password
-
-	return base64.StdEncoding.EncodeToString([]byte(fieldValue))
-}