fix(engine): test execution of declarative commands

pkg/engine/cmd.go

@@ -0,0 +1 @@
+package engine

pkg/engine/engine.go

@@ -6,6 +6,7 @@ import (
 	"net/http"
 	"sync"
 
+	"github.com/nicklasfrahm/k3se/pkg/sshx"
 	"github.com/rs/zerolog"
 )
 
@@ -78,5 +79,16 @@ func (e *Engine) Configure(node *Node) error {
 
 // Cleanup removes all temporary files from the node.
 func (e *Engine) Cleanup(node *Node) error {
-	return node.Run("rm -rf /tmp/k3se")
+	if err := node.Do(sshx.Cmd{
+		Cmd: "echo $MYVAR > ~/test.txt",
+		Env: map[string]string{
+			"MYVAR": "hello",
+		},
+	}); err != nil {
+		return err
+	}
+
+	return node.Do(sshx.Cmd{
+		Cmd: "rm -rf /tmp/k3se",
+	})
 }

pkg/engine/node.go

@@ -76,17 +76,7 @@ func (node *Node) Upload(dst string, src io.Reader) error {
 	return err
 }
 
-// Run executes the specified command on the node.
-func (node *Node) Run(cmd string) error {
-	session, err := node.Client.SSH.NewSession()
-	if err != nil {
-		return err
-	}
-	defer session.Close()
-
-	if err := session.Run(cmd); err != nil {
-		return err
-	}
-
-	return nil
+// Do executes a command on the node.
+func (node *Node) Do(cmd sshx.Cmd) error {
+	return node.Client.Do(cmd)
 }