Merge pull request #43 from devtron-labs/insecure-tls-fix

fix: use certificates data when InsecureSkipTLSVerify is false for a cluster in case of external run CI

kubewatch/pkg/cluster/ClusterRepository.go

@@ -38,6 +38,7 @@ type Cluster struct {
 	AgentInstallationStage int               `sql:"agent_installation_stage"`
 	K8sVersion             string            `sql:"k8s_version"`
 	ErrorInConnecting      string            `sql:"error_in_connecting"`
+	InsecureSkipTlsVerify  bool              `sql:"insecure_skip_tls_verify"`
 	sql.AuditLog
 }
 

kubewatch/pkg/informer/K8sInformer.go

@@ -25,6 +25,7 @@ import (
 	"github.com/argoproj/argo-workflows/v3/workflow/common"
 	pubsub "github.com/devtron-labs/common-lib/pubsub-lib"
 	k8s1 "github.com/devtron-labs/common-lib/utils/k8s"
+	"github.com/devtron-labs/common-lib/utils/k8s/commonBean"
 	repository "github.com/devtron-labs/kubewatch/pkg/cluster"
 	"github.com/devtron-labs/kubewatch/pkg/middleware"
 	"github.com/devtron-labs/kubewatch/pkg/utils"
@@ -439,10 +440,16 @@ func (impl *K8sInformerImpl) getK8sClientForCluster(clusterInfo *repository.Clus
 	} else {
 		restConfig = &rest.Config{
 			Host:            clusterInfo.ServerUrl,
-			BearerToken:     clusterInfo.Config["bearer_token"],
-			TLSClientConfig: rest.TLSClientConfig{Insecure: true},
+			BearerToken:     clusterInfo.Config[commonBean.BearerToken],
+			TLSClientConfig: rest.TLSClientConfig{Insecure: clusterInfo.InsecureSkipTlsVerify},
+		}
+		if !restConfig.TLSClientConfig.Insecure {
+			restConfig.TLSClientConfig.KeyData = []byte(clusterInfo.Config[commonBean.TlsKey])
+			restConfig.TLSClientConfig.CertData = []byte(clusterInfo.Config[commonBean.CertData])
+			restConfig.TLSClientConfig.CAData = []byte(clusterInfo.Config[commonBean.CertificateAuthorityData])
 		}
 	}
+
 	return impl.getK8sClientForConfig(restConfig)
 }