test: add e2e test for ssh

Author: lizardruss

e2e/e2e_suite_test.go

@@ -22,6 +22,7 @@ import (
 	_ "github.com/loft-sh/devspace/e2e/tests/pullsecret"
 	_ "github.com/loft-sh/devspace/e2e/tests/render"
 	_ "github.com/loft-sh/devspace/e2e/tests/replacepods"
+	_ "github.com/loft-sh/devspace/e2e/tests/ssh"
 	_ "github.com/loft-sh/devspace/e2e/tests/sync"
 	_ "github.com/loft-sh/devspace/e2e/tests/terminal"
 )

e2e/tests/ssh/framework.go

@@ -0,0 +1,8 @@
+package ssh
+
+import "github.com/onsi/ginkgo"
+
+// DevSpaceDescribe annotates the test with the label.
+func DevSpaceDescribe(text string, body func()) bool {
+	return ginkgo.Describe("[ssh] "+text, body)
+}

e2e/tests/ssh/ssh.go

@@ -0,0 +1,82 @@
+package ssh
+
+import (
+	"context"
+	"os"
+	"os/exec"
+	"time"
+
+	"github.com/loft-sh/devspace/cmd"
+	"github.com/loft-sh/devspace/cmd/flags"
+	"github.com/loft-sh/devspace/e2e/framework"
+	"github.com/loft-sh/devspace/e2e/kube"
+	"github.com/loft-sh/devspace/pkg/util/factory"
+	"github.com/onsi/ginkgo"
+	"k8s.io/apimachinery/pkg/util/wait"
+)
+
+var _ = DevSpaceDescribe("ssh", func() {
+	initialDir, err := os.Getwd()
+	if err != nil {
+		panic(err)
+	}
+
+	// create a new factory
+	var (
+		f          factory.Factory
+		kubeClient *kube.KubeHelper
+	)
+
+	ginkgo.BeforeEach(func() {
+		f = framework.NewDefaultFactory()
+
+		kubeClient, err = kube.NewKubeHelper()
+		framework.ExpectNoError(err)
+	})
+
+	ginkgo.It("devspace dev should start an SSH service", func() {
+		tempDir, err := framework.CopyToTempDir("tests/ssh/testdata/ssh-simple")
+		framework.ExpectNoError(err)
+		defer framework.CleanupTempDir(initialDir, tempDir)
+
+		ns, err := kubeClient.CreateNamespace("ssh")
+		framework.ExpectNoError(err)
+		defer framework.ExpectDeleteNamespace(kubeClient, ns)
+
+		// create a new dev command and start it
+		done := make(chan error)
+		cancelCtx, cancel := context.WithCancel(context.Background())
+		defer cancel()
+
+		go func() {
+			defer ginkgo.GinkgoRecover()
+
+			devCmd := &cmd.DevCmd{
+				GlobalFlags: &flags.GlobalFlags{
+					NoWarn:    true,
+					Namespace: ns,
+				},
+				Ctx: cancelCtx,
+			}
+
+			done <- devCmd.Run(f)
+		}()
+
+		// connect to the SSH server
+		err = wait.PollImmediate(time.Second, time.Minute*2, func() (bool, error) {
+			cmd := exec.Command("ssh", "test.ssh-simple.devspace", "ls")
+			err := cmd.Run()
+			if err != nil {
+				return false, nil
+			}
+
+			return true, nil
+		})
+		framework.ExpectNoError(err)
+
+		cancel()
+
+		err = <-done
+		framework.ExpectNoError(err)
+	})
+})

e2e/tests/ssh/testdata/ssh-simple/devspace.yaml

@@ -0,0 +1,21 @@
+version: v2beta1
+vars:
+  IMAGE: alpine
+deployments:
+  test:
+    helm:
+      chart:
+        name: component-chart
+        repo: https://charts.devspace.sh
+      values:
+        containers:
+          - image: ${IMAGE}
+            command: ["sleep"]
+            args: ["999999999999"]
+dev:
+  test:
+    imageSelector: ${IMAGE}
+    ssh:
+      enabled: true
+      localHostname: test.ssh-simple.devspace
+      localPort: 10022