tests/kubectl: Add Port Forwarding functions

Port forwarding is needed in order to fetch the alert.

This helper will be used in future commits where the alert test will be
introduced

Signed-off-by: Ram Lavi <ralavi@redhat.com>

Author: RamLavi

tests/kubectl/kubectl.go

@@ -2,6 +2,7 @@ package kubectl
 
 import (
 	"bytes"
+	"fmt"
 	"os"
 	"os/exec"
 )
@@ -25,3 +26,24 @@ func getClusterRootDirectory() string {
 	}
 	return dir
 }
+
+// StartPortForwardCommand starts a port-forward command in the background and returns the process
+func StartPortForwardCommand(namespace, podName string, sourcePort, targetPort int) (*exec.Cmd, error) {
+	// #nosec G204 -- test code with controlled inputs
+	cmd := exec.Command("./cluster/kubectl.sh", "port-forward", "-n", namespace,
+		fmt.Sprintf("pod/%s", podName), fmt.Sprintf("%d:%d", sourcePort, targetPort))
+	cmd.Dir = getClusterRootDirectory()
+
+	if err := cmd.Start(); err != nil {
+		return nil, fmt.Errorf("failed to start port-forward: %w", err)
+	}
+	return cmd, nil
+}
+
+// KillPortForwardCommand kills the port-forward process
+func KillPortForwardCommand(cmd *exec.Cmd) error {
+	if cmd == nil || cmd.Process == nil {
+		return nil
+	}
+	return cmd.Process.Kill()
+}