refactor(cr): validate stages storage repo address

Signed-off-by: Alexey Igrychev <alexey.igrychev@flant.com>

pkg/docker_registry/api.go

@@ -8,6 +8,7 @@ import (
 	"math/rand"
 	"net/http"
 	"os"
+	"regexp"
 	"strings"
 	"time"
 
@@ -379,6 +380,15 @@ func (api *api) parseReferenceParts(reference string) (referenceParts, error) {
 	return referenceParts, nil
 }
 
+func ValidateRepositoryReference(reference string) error {
+	reg := regexp.MustCompile(`^` + dockerReference.NameRegexp.String() + `$`)
+	if !reg.MatchString(reference) {
+		return fmt.Errorf("invalid repository address %q", reference)
+	}
+
+	return nil
+}
+
 func IsStatusNotFoundErr(err error) bool {
 	var transportError *transport.Error
 	if errors.As(err, &transportError) && transportError.StatusCode == 404 {

pkg/docker_registry/docker_registry.go

@@ -102,6 +102,10 @@ func NewDockerRegistry(repositoryAddress string, implementation string, options
 }
 
 func newDockerRegistry(repositoryAddress string, implementation string, options DockerRegistryOptions) (Interface, error) {
+	if err := ValidateRepositoryReference(repositoryAddress); err != nil {
+		return nil, err
+	}
+
 	switch implementation {
 	case AwsEcrImplementationName:
 		return newAwsEcr(options.awsEcrOptions())