Revert "enhancement: enforcing the internal registry port matching the external one (#1550)"

This reverts commit c569517.

Author: iwilltry42

Makefile

@@ -66,12 +66,13 @@ K3D_HELPER_VERSION ?=
 # Go options
 GO        ?= go
 GOENVPATH := $(shell go env GOPATH)
+PKG       := $(shell go work vendor)
 TAGS      :=
 TESTS     := ./...
 TESTFLAGS :=
 LDFLAGS   := -w -s -X github.com/k3d-io/k3d/v5/version.Version=${GIT_TAG} -X github.com/k3d-io/k3d/v5/version.K3sVersion=${K3S_TAG}
 GCFLAGS   :=
-GOFLAGS   := -mod=vendor
+GOFLAGS   := -mod=readonly
 BINDIR    := $(CURDIR)/bin
 BINARIES  := k3d
 

cmd/cluster/clusterCreate.go

@@ -575,7 +575,7 @@ func applyCLIOverrides(cfg conf.SimpleConfig) (conf.SimpleConfig, error) {
 		}
 		cfg.Registries.Create.Name = fvSplit[0]
 		if len(fvSplit) > 1 {
-			exposeAPI, err = cliutil.ParseRegistryPortExposureSpec(fvSplit[1])
+			exposeAPI, err = cliutil.ParsePortExposureSpec(fvSplit[1], "1234") // internal port is unused after all
 			if err != nil {
 				return cfg, fmt.Errorf("failed to registry port spec: %w", err)
 			}

cmd/registry/registryCreate.go

@@ -134,7 +134,7 @@ func parseCreateRegistryCmd(cmd *cobra.Command, args []string, flags *regCreateF
 	}
 
 	// --port
-	exposePort, err := cliutil.ParseRegistryPortExposureSpec(ppFlags.Port)
+	exposePort, err := cliutil.ParsePortExposureSpec(ppFlags.Port, k3d.DefaultRegistryPort)
 	if err != nil {
 		l.Log().Errorln("Failed to parse registry port")
 		l.Log().Fatalln(err)

cmd/util/ports.go

@@ -36,16 +36,8 @@ import (
 
 var apiPortRegexp = regexp.MustCompile(`^(?P<hostref>(?P<hostip>\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})|(?P<hostname>\S+):)?(?P<port>(\d{1,5}|random))$`)
 
-func ParsePortExposureSpec(exposedPortSpec, internalPort string) (*k3d.ExposureOpts, error) {
-	return parsePortExposureSpec(exposedPortSpec, internalPort, false)
-}
-
-func ParseRegistryPortExposureSpec(exposedPortSpec string) (*k3d.ExposureOpts, error) {
-	return parsePortExposureSpec(exposedPortSpec, k3d.DefaultRegistryPort, true)
-}
-
 // ParsePortExposureSpec parses/validates a string to create an exposePort struct from it
-func parsePortExposureSpec(exposedPortSpec, internalPort string, enforcePortMatch bool) (*k3d.ExposureOpts, error) {
+func ParsePortExposureSpec(exposedPortSpec, internalPort string) (*k3d.ExposureOpts, error) {
 	match := apiPortRegexp.FindStringSubmatch(exposedPortSpec)
 
 	if len(match) == 0 {
@@ -91,7 +83,7 @@ func parsePortExposureSpec(exposedPortSpec, internalPort string, enforcePortMatc
 	}
 
 	// port: get a free one if there's none defined or set to random
-	if submatches["port"] == "random" {
+	if submatches["port"] == "" || submatches["port"] == "random" {
 		l.Log().Debugf("Port Exposure Mapping didn't specify hostPort, choosing one randomly...")
 		freePort, err := GetFreePort()
 		if err != nil || freePort == 0 {
@@ -104,10 +96,6 @@ func parsePortExposureSpec(exposedPortSpec, internalPort string, enforcePortMatc
 		}
 	}
 
-	if enforcePortMatch {
-		internalPort = submatches["port"]
-	}
-
 	realPortString += fmt.Sprintf("%s:%s/tcp", submatches["port"], internalPort)
 
 	portMapping, err := nat.ParsePortSpec(realPortString)

cmd/util/ports_test.go

@@ -76,10 +76,6 @@ func RegistryCreate(ctx context.Context, runtime runtimes.Runtime, reg *k3d.Regi
 		Env:      []string{},
 	}
 
-	if reg.ExposureOpts.Binding.HostPort != "" {
-		registryNode.Env = append(registryNode.Env, fmt.Sprintf("REGISTRY_HTTP_ADDR=:%s", reg.ExposureOpts.Binding.HostPort))
-	}
-
 	if reg.Options.Proxy.RemoteURL != "" {
 		registryNode.Env = append(registryNode.Env, fmt.Sprintf("REGISTRY_PROXY_REMOTEURL=%s", reg.Options.Proxy.RemoteURL))
 

pkg/client/registry.go

@@ -320,7 +320,7 @@ func TransformSimpleToClusterConfig(ctx context.Context, runtime runtimes.Runtim
 			epSpecHost = simpleConfig.Registries.Create.Host
 		}
 
-		regPort, err := cliutil.ParseRegistryPortExposureSpec(fmt.Sprintf("%s:%s", epSpecHost, epSpecPort))
+		regPort, err := cliutil.ParsePortExposureSpec(fmt.Sprintf("%s:%s", epSpecHost, epSpecPort), k3d.DefaultRegistryPort)
 		if err != nil {
 			return nil, fmt.Errorf("failed to get port for registry: %w", err)
 		}

pkg/config/transform.go

@@ -52,7 +52,7 @@ kubectl get configmap -n kube-public local-registry-hosting -o go-template='{{in
 
 # 3. load an image into the registry
 info "Pushing an image to the registry..."
-registryPort=$(docker inspect $registryname | jq '.[0].NetworkSettings.Ports | with_entries(select(.value | . != null)) | to_entries[0].value[0].HostPort' | sed -E 's/"//g')
+registryPort=$(docker inspect $registryname | jq '.[0].NetworkSettings.Ports["5000/tcp"][0].HostPort' | sed -E 's/"//g')
 docker pull alpine:latest > /dev/null
 docker tag alpine:latest "localhost:$registryPort/alpine:local" > /dev/null
 docker push "localhost:$registryPort/alpine:local" || failed "Failed to push image to managed registry"