check crd installation

Signed-off-by: stoneshi-yunify <stoneshi@kubesphere.io>

Author: stoneshi-yunify

pkg/webhook/pod.go

@@ -12,6 +12,8 @@ import (
 	admissionv1 "k8s.io/api/admission/v1"
 	corev1 "k8s.io/api/core/v1"
 	v1 "k8s.io/api/storage/v1"
+	"k8s.io/apiextensions-apiserver/pkg/apis/apiextensions"
+	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/klog/v2"
@@ -82,6 +84,8 @@ func (a *Admitter) serverPVCRequest(w http.ResponseWriter, r *http.Request) {
 }
 
 func (a *Admitter) Admit(ar admissionv1.AdmissionReview) *admissionv1.AdmissionResponse {
+	ctx := context.Background()
+
 	if ar.Request.Operation != admissionv1.Create {
 		return toV1AdmissionResponseWithPatch(nil)
 	}
@@ -102,6 +106,19 @@ func (a *Admitter) Admit(ar admissionv1.AdmissionReview) *admissionv1.AdmissionR
 		return toV1AdmissionResponseWithPatch(nil)
 	}
 
+	crdInitializers := &apiextensions.CustomResourceDefinition{}
+	crdInitializersName := types.NamespacedName{
+		Name: "initializers.storage.kubesphere.io",
+	}
+	err = a.client.Get(ctx, crdInitializersName, crdInitializers)
+	if err != nil {
+		if errors.IsNotFound(err) {
+			klog.Warningf("crd %s not found, skip processing", crdInitializersName.Name)
+			return toV1AdmissionResponseWithPatch(nil)
+		}
+		return toV1AdmissionResponse(err)
+	}
+
 	// the creating pod(Request.Object) may not have name or namespace set, keep that in mind. We need to set it here.
 	pod.Namespace = namespace
 

pkg/webhook/scheme.go

@@ -8,6 +8,7 @@ import (
 	admissionregistrationv1beta1 "k8s.io/api/admissionregistration/v1beta1"
 	corev1 "k8s.io/api/core/v1"
 	storagev1 "k8s.io/api/storage/v1"
+	"k8s.io/apiextensions-apiserver/pkg/apis/apiextensions"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/serializer"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
@@ -30,4 +31,5 @@ func addToScheme(scheme *runtime.Scheme) {
 	utilruntime.Must(v1alpha1.AddToScheme(scheme))
 	utilruntime.Must(tenantv1alpha1.AddToScheme(scheme))
 	utilruntime.Must(storagev1.AddToScheme(scheme))
+	utilruntime.Must(apiextensions.AddToScheme(scheme))
 }