✨ allow pass the assets path via the enviroment config

Author: camilamacedo86

pkg/envtest/server.go

@@ -62,14 +62,17 @@ const (
 	defaultKubebuilderControlPlaneStopTimeout  = 20 * time.Second
 )
 
-// Default binary path for test framework
-func defaultAssetPath(binary string) string {
-	assetPath := os.Getenv(envKubebuilderPath)
-	if assetPath == "" {
-		assetPath = defaultKubebuilderPath
+// getBinAssetPath will return the path for the binary informed
+func (te *Environment) getBinAssetPath(binary string) string {
+	if hasBinary(binary, te.BinaryDirectoryPath) {
+		return filepath.Join(te.BinaryDirectoryPath, binary)
 	}
-	return filepath.Join(assetPath, binary)
 
+	valueFromEnvVar := os.Getenv(envKubebuilderPath)
+	if hasBinary(binary, valueFromEnvVar) {
+		return filepath.Join(valueFromEnvVar, binary)
+	}
+	return filepath.Join(defaultKubebuilderPath, binary)
 }
 
 // ControlPlane is the re-exported ControlPlane type from the internal integration package
@@ -113,6 +116,10 @@ type Environment struct {
 	// values are merged.
 	CRDDirectoryPaths []string
 
+	// BinaryDirectoryPath is the path where the binaries required for the envtest are
+	// locate in the environment
+	BinaryDirectoryPath string
+
 	// UseExisting indicates that this environments should use an
 	// existing kubeconfig, instead of trying to stand up a new control plane.
 	// This is useful in cases that need aggregated API servers and the like.
@@ -217,14 +224,14 @@ func (te *Environment) Start() (*rest.Config, error) {
 		}
 
 		if os.Getenv(envKubeAPIServerBin) == "" {
-			te.ControlPlane.APIServer.Path = defaultAssetPath("kube-apiserver")
+			te.ControlPlane.APIServer.Path = te.getBinAssetPath("kube-apiserver")
 		}
 		if os.Getenv(envEtcdBin) == "" {
-			te.ControlPlane.Etcd.Path = defaultAssetPath("etcd")
+			te.ControlPlane.Etcd.Path = te.getBinAssetPath("etcd")
 		}
 		if os.Getenv(envKubectlBin) == "" {
 			// we can't just set the path manually (it's behind a function), so set the environment variable instead
-			if err := os.Setenv(envKubectlBin, defaultAssetPath("kubectl")); err != nil {
+			if err := os.Setenv(envKubectlBin, te.getBinAssetPath("kubectl")); err != nil {
 				return nil, err
 			}
 		}
@@ -267,6 +274,17 @@ func (te *Environment) Start() (*rest.Config, error) {
 	return te.Config, err
 }
 
+// hasBinary will return true when the binary was found in the path
+func hasBinary(bin, path string) bool {
+	if path == "" {
+		return false
+	}
+	if _, err := os.Stat(filepath.Join(path, bin)); os.IsNotExist(err) {
+		return false
+	}
+	return true
+}
+
 func (te *Environment) startControlPlane() error {
 	numTries, maxRetries := 0, 5
 	var err error