fix: do ensureNamespace only if the namespace doesn't really exist.

Signed-off-by: Luca Di Maio <[email protected]>

Author: 89luca89

pkg/devspace/build/localregistry/local_registry.go

@@ -36,7 +36,10 @@ type LocalRegistry struct {
 	servicePort *corev1.ServicePort
 }
 
-func GetOrCreateLocalRegistry(ctx devspacecontext.Context, options Options) (*LocalRegistry, error) {
+func GetOrCreateLocalRegistry(
+	ctx devspacecontext.Context,
+	options Options,
+) (*LocalRegistry, error) {
 	localRegistriesLock.Lock()
 	defer localRegistriesLock.Unlock()
 
@@ -164,6 +167,32 @@ func (r *LocalRegistry) RewriteImageForBuilder(image string) (string, error) {
 }
 
 func (r *LocalRegistry) ensureNamespace(ctx devspacecontext.Context) error {
+	// If localregistry namespace is the same as devspace, we don't have
+	// anything to do.
+	if r.Namespace == ctx.KubeClient().Namespace() {
+		return nil
+	}
+
+	// List all namespaces, this will already return an error in case of
+	// user's permissions problems.
+	namespaces, err := ctx.KubeClient().
+		KubeClient().
+		CoreV1().
+		Namespaces().
+		List(ctx.Context(), metav1.ListOptions{})
+	if err != nil {
+		return err
+	}
+
+	// Check if the namespace already is there, if not we'll try to create it.
+	for _, namespace := range namespaces.Items {
+		if r.Namespace == namespace.Name {
+			ctx.Log().Debugf("Namespace %s already exists, skipping creation", r.Namespace)
+			return nil
+		}
+	}
+
+	ctx.Log().Debugf("Namespace %s doesn't exist, attempting creation", r.Namespace)
 	applyConfiguration, err := applyv1.ExtractNamespace(&corev1.Namespace{
 		ObjectMeta: metav1.ObjectMeta{
 			Name: r.Namespace,
@@ -198,15 +227,22 @@ func (r *LocalRegistry) waitForNodePort(ctx devspacecontext.Context) (*corev1.Se
 	var servicePort *corev1.ServicePort
 
 	kubeClient := ctx.KubeClient().KubeClient()
-	err := wait.PollImmediateWithContext(ctx.Context(), time.Second, 30*time.Second, func(ctx context.Context) (done bool, err error) {
-		service, err := kubeClient.CoreV1().Services(r.Namespace).Get(ctx, r.Name, metav1.GetOptions{})
-		if err != nil {
-			return false, err
-		}
+	err := wait.PollImmediateWithContext(
+		ctx.Context(),
+		time.Second,
+		30*time.Second,
+		func(ctx context.Context) (done bool, err error) {
+			service, err := kubeClient.CoreV1().
+				Services(r.Namespace).
+				Get(ctx, r.Name, metav1.GetOptions{})
+			if err != nil {
+				return false, err
+			}
 
-		servicePort = GetServicePort(service)
-		return servicePort.NodePort != 0, nil
-	})
+			servicePort = GetServicePort(service)
+			return servicePort.NodePort != 0, nil
+		},
+	)
 
 	return servicePort, err
 }
@@ -218,12 +254,18 @@ func (r *LocalRegistry) GetRegistryURL() string {
 
 // startPortForwarding will forward container's port into localhost in order to access registry's container in
 // the cluster, locally, to push the built image afterwards
-func (r *LocalRegistry) startPortForwarding(ctx devspacecontext.Context, imageRegistryPod *corev1.Pod) error {
+func (r *LocalRegistry) startPortForwarding(
+	ctx devspacecontext.Context,
+	imageRegistryPod *corev1.Pod,
+) error {
 	localPort := r.servicePort.NodePort
 	remotePort := r.servicePort.TargetPort.IntVal
 	ports := []string{fmt.Sprintf("%d:%d", localPort, remotePort)}
 	addresses := []string{"localhost"}
-	portsFormatted := ansi.Color(fmt.Sprintf("%d -> %d", int(localPort), int(remotePort)), "white+b")
+	portsFormatted := ansi.Color(
+		fmt.Sprintf("%d -> %d", int(localPort), int(remotePort)),
+		"white+b",
+	)
 	readyChan := make(chan struct{})
 	errorChan := make(chan error, 1)
 	pf, err := kubectl.NewPortForwarder(
@@ -266,9 +308,14 @@ func (r *LocalRegistry) startPortForwarding(ctx devspacecontext.Context, imageRe
 }
 
 func (r *LocalRegistry) waitForRegistry(ctx context.Context) error {
-	return wait.PollImmediateWithContext(ctx, time.Second, 30*time.Second, func(ctx context.Context) (done bool, err error) {
-		return r.ping(ctx)
-	})
+	return wait.PollImmediateWithContext(
+		ctx,
+		time.Second,
+		30*time.Second,
+		func(ctx context.Context) (done bool, err error) {
+			return r.ping(ctx)
+		},
+	)
 }
 
 func (r *LocalRegistry) ping(ctx context.Context) (done bool, err error) {