mirror of https://github.com/containers/podman.git
86 lines
2.8 KiB
Go
86 lines
2.8 KiB
Go
package registries
|
|
|
|
// TODO: this package should not exist anymore. Users should either use
|
|
// c/image's `sysregistriesv2` package directly OR, even better, we cache a
|
|
// config in libpod's image runtime so we don't need to parse the
|
|
// registries.conf files redundantly.
|
|
|
|
import (
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/containers/image/v5/pkg/sysregistriesv2"
|
|
"github.com/containers/image/v5/types"
|
|
"github.com/containers/podman/v3/pkg/rootless"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
// userRegistriesFile is the path to the per user registry configuration file.
|
|
var userRegistriesFile = filepath.Join(os.Getenv("HOME"), ".config/containers/registries.conf")
|
|
|
|
// SystemRegistriesConfPath returns an appropriate value for types.SystemContext.SystemRegistriesConfPath
|
|
// (possibly "", which is not an error), taking into account rootless mode and environment variable overrides.
|
|
//
|
|
// FIXME: This should be centralized in a global SystemContext initializer inherited throughout the code,
|
|
// not haphazardly called throughout the way it is being called now.
|
|
func SystemRegistriesConfPath() string {
|
|
if envOverride, ok := os.LookupEnv("CONTAINERS_REGISTRIES_CONF"); ok {
|
|
return envOverride
|
|
}
|
|
if envOverride, ok := os.LookupEnv("REGISTRIES_CONFIG_PATH"); ok {
|
|
return envOverride
|
|
}
|
|
|
|
if rootless.IsRootless() {
|
|
if _, err := os.Stat(userRegistriesFile); err == nil {
|
|
return userRegistriesFile
|
|
}
|
|
}
|
|
|
|
return ""
|
|
}
|
|
|
|
// GetRegistriesData obtains the list of registries
|
|
func GetRegistriesData() ([]sysregistriesv2.Registry, error) {
|
|
registries, err := sysregistriesv2.GetRegistries(&types.SystemContext{SystemRegistriesConfPath: SystemRegistriesConfPath()})
|
|
if err != nil {
|
|
return nil, errors.Wrapf(err, "unable to parse the registries.conf file")
|
|
}
|
|
return registries, nil
|
|
}
|
|
|
|
// GetRegistries obtains the list of search registries defined in the global registries file.
|
|
func GetRegistries() ([]string, error) {
|
|
return sysregistriesv2.UnqualifiedSearchRegistries(&types.SystemContext{SystemRegistriesConfPath: SystemRegistriesConfPath()})
|
|
}
|
|
|
|
// GetBlockedRegistries obtains the list of blocked registries defined in the global registries file.
|
|
func GetBlockedRegistries() ([]string, error) {
|
|
var blockedRegistries []string
|
|
registries, err := GetRegistriesData()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
for _, reg := range registries {
|
|
if reg.Blocked {
|
|
blockedRegistries = append(blockedRegistries, reg.Prefix)
|
|
}
|
|
}
|
|
return blockedRegistries, nil
|
|
}
|
|
|
|
// GetInsecureRegistries obtains the list of insecure registries from the global registration file.
|
|
func GetInsecureRegistries() ([]string, error) {
|
|
var insecureRegistries []string
|
|
registries, err := GetRegistriesData()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
for _, reg := range registries {
|
|
if reg.Insecure {
|
|
insecureRegistries = append(insecureRegistries, reg.Prefix)
|
|
}
|
|
}
|
|
return insecureRegistries, nil
|
|
}
|