resources.go

package webhook

import (
	routeclientset "github.com/openshift/client-go/route/clientset/versioned/typed/route/v1"
	"github.com/chetan-rns/gitops-cli/pkg/pipelines/clientconfig"
	"github.com/pkg/errors"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
)

// resources represents cluster resources that are needed by webhook management
type resources struct {
	routeClient routeclientset.RouteV1Interface
	kubeClient  kubernetes.Interface
}

// NewResources create new webhook resources
func newResources() (*resources, error) {

	config, err := clientconfig.GetRESTConfig()
	if err != nil {
		return nil, err
	}
	routeClient, err := routeclientset.NewForConfig(config)
	if err != nil {
		return nil, err
	}

	kubeClient, err := kubernetes.NewForConfig(config)
	if err != nil {
		return nil, err
	}

	return &resources{routeClient: routeClient,
		kubeClient: kubeClient}, nil
}

func (r *resources) getWebhookSecret(ns, secetName, key string) (string, error) {

	secret, err := r.kubeClient.CoreV1().Secrets(ns).Get(secetName, metav1.GetOptions{})
	if err != nil {
		return "", errors.Wrapf(err, "unable to get the secret %s", secret)
	}

	return string(secret.Data[key]), nil
}

// getListenerAddress returns TLS is configurated external address host and port Event Listener exposed by OpenShift route
func (r *resources) getListenerAddress(ns, routeName string) (bool, string, error) {

	route, err := r.routeClient.Routes(ns).Get(routeName, metav1.GetOptions{})
	if err != nil {
		return false, "", err
	}

	return route.Spec.TLS != nil, route.Spec.Host, nil
}