Saas 6078 (#101)

* create ns if not exists (lazy)

Author: oren-codefresh

package.json

@@ -1,6 +1,6 @@
 {
   "name": "venona",
-  "version": "1.0.5",
+  "version": "1.0.6",
   "description": "Codefresh agent to run on Codefresh's runtime environment and execute pipeline",
   "main": "index.js",
   "scripts": {

venonactl/VERSION

@@ -1 +1 @@
-1.0.5
+1.0.6

venonactl/pkg/kube/kube.go

@@ -1,16 +1,20 @@
 package kube
 
 import (
+	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	v1Core "k8s.io/api/core/v1"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
 	clientcmdapi "k8s.io/client-go/tools/clientcmd/api"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
 type (
 	Kube interface {
 		BuildClient() (*kubernetes.Clientset, error)
 		BuildConfig() (clientcmd.ClientConfig)
+		EnsureNamespaceExists(cs *kubernetes.Clientset) (error)
 	}
 
 	kube struct {
@@ -48,7 +52,20 @@ func (k *kube) BuildClient() (*kubernetes.Clientset, error) {
 	if err != nil {
 		return nil, err
 	}
-	return kubernetes.NewForConfig(config)
+	cs, err := kubernetes.NewForConfig(config)
+	return cs, nil
+}
+
+func (k *kube) EnsureNamespaceExists(cs *kubernetes.Clientset) (error) {
+	_, err := cs.CoreV1().Namespaces().Get(k.namespace, v1.GetOptions{})
+	if err != nil  {
+		nsSpec := &v1Core.Namespace{ObjectMeta: metav1.ObjectMeta {Name: k.namespace}};
+		_, err := cs.CoreV1().Namespaces().Create(nsSpec)
+		if err != nil {
+			return  err
+		} 
+	}
+	return nil
 }
 
 func (k *kube) BuildConfig() (clientcmd.ClientConfig) {

venonactl/pkg/plugins/engine.go

@@ -41,6 +41,11 @@ func (u *enginePlugin) Install(opt *InstallOptions, v Values) (Values, error) {
 		u.logger.Error(fmt.Sprintf("Cannot create kubernetes clientset: %v ", err))
 		return nil, err
 	}
+	err = opt.KubeBuilder.EnsureNamespaceExists(cs)
+	if err != nil {
+		u.logger.Error(fmt.Sprintf("Cannot ensure namespace exists: %v", err))
+		return nil, err
+	}
 	return v, install(&installOptions{
 		logger:         u.logger,
 		templates:      templates.TemplatesMap(),

venonactl/pkg/plugins/plugin.go

@@ -56,10 +56,12 @@ type (
 		KubeBuilder           interface {
 			BuildClient() (*kubernetes.Clientset, error)
 			BuildConfig() clientcmd.ClientConfig
+			EnsureNamespaceExists(cs *kubernetes.Clientset) (error)
 
 		}
 		AgentKubeBuilder	  interface {
 			BuildClient() (*kubernetes.Clientset, error)
+			EnsureNamespaceExists(cs *kubernetes.Clientset) (error)
 		}
 		DryRun               bool
 		KubernetesRunnerType bool

venonactl/pkg/plugins/runtime-attach.go

@@ -43,6 +43,10 @@ func buildRuntimeConfig(opt *InstallOptions, v Values) (RuntimeConfiguration, er
 	if err != nil {
 		return RuntimeConfiguration{}, fmt.Errorf("Failed to create client on runtime cluster: %v", err)
 	}
+	err = opt.KubeBuilder.EnsureNamespaceExists(cs)
+	if err != nil {
+		return RuntimeConfiguration{}, fmt.Errorf("Failed to ensure namespace on runtime cluster: %v", err)
+	}
 
 	// get default service account for the namespace
 	var getOpt metav1.GetOptions
@@ -99,6 +103,11 @@ func (u *runtimeAttachPlugin) Install(opt *InstallOptions, v Values) (Values, er
 		u.logger.Error(fmt.Sprintf("Cannot create kubernetes clientset: %v ", err))
 		return nil, err
 	}
+	err = opt.AgentKubeBuilder.EnsureNamespaceExists(cs)
+	if err != nil {
+		u.logger.Error(fmt.Sprintf("Cannot ensure namespace exists: %v", err))
+		return nil, err
+	}
 
 	// read current venona conf
 	currentVenonaConf, err := readCurrentVenonaConf(opt.AgentKubeBuilder, opt.ClusterNamespace)

venonactl/pkg/plugins/runtime-environment.go

@@ -40,6 +40,12 @@ func (u *runtimeEnvironmentPlugin) Install(opt *InstallOptions, v Values) (Value
 	if err != nil {
 		return nil, fmt.Errorf("Cannot create kubernetes clientset: %v ", err)
 	}
+	
+	err = opt.KubeBuilder.EnsureNamespaceExists(cs)
+	if err != nil {
+		u.logger.Error(fmt.Sprintf("Cannot ensure namespace exists: %v", err))
+		return nil, err
+	}
 
 	cfOpt := &codefresh.APIOptions{
 		Logger:                u.logger,

venonactl/pkg/plugins/venona.go

@@ -67,6 +67,11 @@ func (u *venonaPlugin) Install(opt *InstallOptions, v Values) (Values, error) {
 		u.logger.Error(fmt.Sprintf("Cannot create kubernetes clientset: %v ", err))
 		return nil, err
 	}
+	err = opt.KubeBuilder.EnsureNamespaceExists(cs)
+	if err != nil {
+		u.logger.Error(fmt.Sprintf("Cannot ensure namespace exists: %v", err))
+		return nil, err
+	}
 	return v, install(&installOptions{
 		logger:         u.logger,
 		templates:      templates.TemplatesMap(),