package v1

import (
	"k8s.io/client-go/kubernetes"
	ctrl "sigs.k8s.io/controller-runtime"

	v1 "open-cluster-management.io/api/work/v1"
)

type ManifestWorkWebhook struct {
	kubeClient kubernetes.Interface
}

func (r *ManifestWorkWebhook) Init(mgr ctrl.Manager) error {
	err := r.SetupWebhookWithManager(mgr)
	if err != nil {
		return err
	}
	r.kubeClient, err = kubernetes.NewForConfig(mgr.GetConfig())
	return err
}

// SetExternalKubeClientSet is function to enable the webhook injecting to kube admission
func (r *ManifestWorkWebhook) SetExternalKubeClientSet(client kubernetes.Interface) {
	r.kubeClient = client
}

func (r *ManifestWorkWebhook) SetupWebhookWithManager(mgr ctrl.Manager) error {
	return ctrl.NewWebhookManagedBy(mgr, &v1.ManifestWork{}).
		WithValidator(r).
		Complete()
}