check file path

Signed-off-by: xin.li <xin.li@daocloud.io>

pkg/karmadactl/cmdinit/karmada/deploy.go

@@ -59,26 +59,8 @@ func InitKarmadaResources(dir, caBase64, systemNamespace string) error {
 	}
 
 	// Initialize crd
-	basesCRDsFiles := utils.ListFiles(dir + "/crds/bases")
-	klog.Infof("Initialize karmada bases crd resource `%s/crds/bases`", dir)
-	for _, v := range basesCRDsFiles {
-		if path.Ext(v) != ".yaml" {
-			continue
-		}
-		if err := createCRDs(crdClient, v); err != nil {
-			return err
-		}
-	}
-
-	patchesCRDsFiles := utils.ListFiles(dir + "/crds/patches")
-	klog.Infof("Initialize karmada patches crd resource `%s/crds/patches`", dir)
-	for _, v := range patchesCRDsFiles {
-		if path.Ext(v) != ".yaml" {
-			continue
-		}
-		if err := patchCRDs(crdClient, caBase64, v); err != nil {
-			return err
-		}
+	if err = crdInitialize(crdClient, dir, caBase64); err != nil {
+		klog.Exitln(err)
 	}
 
 	// create webhook configuration
@@ -106,6 +88,38 @@ func InitKarmadaResources(dir, caBase64, systemNamespace string) error {
 	return nil
 }
 
+// crdInitialize initialize crd
+func crdInitialize(crdClient *clientset.Clientset, dir, caBase64 string) error {
+	if err := utils.PathExists(dir + "/crds/bases"); err != nil {
+		return err
+	}
+	basesCRDsFiles := utils.ListFiles(dir + "/crds/bases")
+	klog.Infof("Initialize karmada bases crd resource `%s/crds/bases`", dir)
+	for _, v := range basesCRDsFiles {
+		if path.Ext(v) != ".yaml" {
+			continue
+		}
+		if err := createCRDs(crdClient, v); err != nil {
+			return err
+		}
+	}
+
+	if err := utils.PathExists(dir + "/crds/patches"); err != nil {
+		return err
+	}
+	patchesCRDsFiles := utils.ListFiles(dir + "/crds/patches")
+	klog.Infof("Initialize karmada patches crd resource `%s/crds/patches`", dir)
+	for _, v := range patchesCRDsFiles {
+		if path.Ext(v) != ".yaml" {
+			continue
+		}
+		if err := patchCRDs(crdClient, caBase64, v); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
 func crdPatchesResources(filename, caBundle string) ([]byte, error) {
 	data, err := ioutil.ReadFile(filename)
 	if err != nil {

pkg/karmadactl/cmdinit/utils/util.go

@@ -120,6 +120,15 @@ func ioCopyN(outFile *os.File, tr *tar.Reader) error {
 	return nil
 }
 
+// PathExists check if the file path exists
+func PathExists(path string) error {
+	_, err := os.Stat(path)
+	if os.IsNotExist(err) {
+		return err
+	}
+	return nil
+}
+
 // ListFiles traverse directory files
 func ListFiles(path string) []string {
 	var files []string