tests: add deploy and purge test

Author: FabianKramm

e2e/tests/deploy/deploy.go

@@ -36,6 +36,73 @@ var _ = DevSpaceDescribe("deploy", func() {
 		// TODO
 	})
 
+	ginkgo.It("should deploy concurrent deployments", func() {
+		tempDir, err := framework.CopyToTempDir("tests/deploy/testdata/helm_concurrent_new")
+		framework.ExpectNoError(err)
+		defer framework.CleanupTempDir(initialDir, tempDir)
+
+		ns, err := kubeClient.CreateNamespace("deploy")
+		framework.ExpectNoError(err)
+		defer func() {
+			err := kubeClient.DeleteNamespace(ns)
+			framework.ExpectNoError(err)
+		}()
+
+		// create a new dev command
+		deployCmd := &cmd.DeployCmd{
+			GlobalFlags: &flags.GlobalFlags{
+				NoWarn:    true,
+				Namespace: ns,
+			},
+		}
+
+		// run the command
+		err = deployCmd.Run(f)
+		framework.ExpectNoError(err)
+
+		// check if deployments are there
+		deploy, err := kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test1", metav1.GetOptions{})
+		framework.ExpectNoError(err)
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Name, "test")
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Image, "alpine")
+		deploy, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test2", metav1.GetOptions{})
+		framework.ExpectNoError(err)
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Name, "test")
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Image, "alpine")
+		deploy, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test3", metav1.GetOptions{})
+		framework.ExpectNoError(err)
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Name, "test")
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Image, "alpine")
+		deploy, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test4", metav1.GetOptions{})
+		framework.ExpectNoError(err)
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Name, "test")
+		framework.ExpectEqual(deploy.Spec.Template.Spec.Containers[0].Image, "alpine")
+		_, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "base", metav1.GetOptions{})
+		framework.ExpectError(err)
+
+		// create a new purge command
+		purgeCmd := &cmd.PurgeCmd{
+			GlobalFlags: &flags.GlobalFlags{
+				NoWarn:    true,
+				Namespace: ns,
+			},
+		}
+
+		// run the command
+		err = purgeCmd.Run(f)
+		framework.ExpectNoError(err)
+
+		// check if deployments are still there
+		_, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test1", metav1.GetOptions{})
+		framework.ExpectError(err)
+		_, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test2", metav1.GetOptions{})
+		framework.ExpectError(err)
+		_, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test3", metav1.GetOptions{})
+		framework.ExpectError(err)
+		_, err = kubeClient.RawClient().AppsV1().Deployments(ns).Get(context.TODO(), "test4", metav1.GetOptions{})
+		framework.ExpectError(err)
+	})
+
 	ginkgo.It("should deploy helm application", func() {
 		tempDir, err := framework.CopyToTempDir("tests/deploy/testdata/helm")
 		framework.ExpectNoError(err)

e2e/tests/deploy/testdata/helm_concurrent_new/devspace.yaml

@@ -0,0 +1,20 @@
+version: v2beta1
+
+deployments:
+  base:
+    helm:
+      values:
+        containers:
+          - image: alpine
+
+pipelines:
+  deploy:
+    steps:
+      - run: |-
+          echo '{"helm": {"values": {"containers": [{"image":"alpine"}]}}}' > ${devspace.tempFolder}/deployment.yaml
+          
+          create_deployments test1 test2 test3 test4 --from-file test1:${devspace.tempFolder}/deployment.yaml \
+                                                     --from test2:base \
+                                                     --set test3:helm.values.containers[0].image=alpine \
+                                                     --set-string test4:helm.values.containers[0].image=alpine \
+                                                     --set helm.values.containers[0].name=test

pkg/devspace/pipeline/engine/pipelinehandler/commands/create_deployments.go

@@ -148,6 +148,7 @@ func applySetValues(ctx *devspacecontext.Context, name, objName string, set, set
 		}
 	}
 
+	rawConfig[name].(map[string]interface{})[objName] = mapObj
 	latestConfig, err := loader.Convert(rawConfig, ctx.Log)
 	if err != nil {
 		return nil, err

pkg/devspace/pipeline/pipeline_job.go

@@ -147,7 +147,7 @@ func (j *Job) executeStep(ctx *devspacecontext.Context, step *latest.PipelineSte
 		return nil
 	})
 
-	handler := pipelinehandler.NewPipelineExecHandler(ctx, stdoutWriter, j.Pipeline, true)
+	handler := pipelinehandler.NewPipelineExecHandler(ctx, stdoutWriter, j.Pipeline)
 	_, err := engine.ExecutePipelineShellCommand(ctx.Context, step.Run, os.Args[1:], ctx.ResolvePath(step.WorkingDir), step.ContinueOnError, stdoutWriter, stdoutWriter, os.Stdin, j.getEnv(ctx), handler)
 	return err
 }