feat(controller): patch CRDs to upgrade them

Makefile

@@ -209,6 +209,7 @@ informer:
 manifests:
 	@echo "+ Generating zfs localPV crds"
 	$(PWD)/buildscripts/generate-manifests.sh
+	for file in volume snapshot restore;do cp ./deploy/yamls/zfs"$$file"-crd.yaml ./pkg/patcher/;done
 
 helm:
 	@echo "+ Copying generated CRDs to helm charts"

pkg/driver/controller.go

@@ -85,6 +85,7 @@ func NewController(d *CSIDriver) csi.ControllerServer {
 }
 
 func (cs *controller) init() error {
+
 	cfg, err := k8sapi.Config().Get()
 	if err != nil {
 		return errors.Wrapf(err, "failed to build kubeconfig")

pkg/driver/driver.go

@@ -19,6 +19,8 @@ package driver
 import (
 	"github.com/container-storage-interface/spec/lib/go/csi"
 	config "github.com/openebs/zfs-localpv/pkg/config"
+	"github.com/openebs/zfs-localpv/pkg/patcher"
+	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/klog/v2"
 )
 
@@ -64,6 +66,39 @@ func New(config *config.Config) *CSIDriver {
 
 	switch config.PluginType {
 	case "controller":
+		// CRD upgrade
+		// Ref: https://github.com/openebs/zfs-localpv/pull/439
+		// Ref: https://github.com/openebs/zfs-localpv/pull/457
+		crdGvr := schema.GroupVersionResource{
+			Group:    "apiextensions.k8s.io",
+			Version:  "v1",
+			Resource: "CustomResourceDefinition",
+		}
+
+		oldCrd, _ := patcher.OldZfsVolumesCrd()
+		newCrd, _ := patcher.NewZfsVolumesCrd()
+		patcher.PatchCrdOrIgnore(crdGvr, "").WithMergePatchFrom(
+			"zfsvolumes.zfs.openebs.io",
+			oldCrd,
+			newCrd,
+		)
+
+		oldCrd, _ = patcher.OldZfsSnapshotsCrd()
+		newCrd, _ = patcher.NewZfsSnapshotsCrd()
+		patcher.PatchCrdOrIgnore(crdGvr, "").WithMergePatchFrom(
+			"zfssnapshots.zfs.openebs.io",
+			oldCrd,
+			newCrd,
+		)
+
+		oldCrd, _ = patcher.OldZfsRestoresCrd()
+		newCrd, _ = patcher.NewZfsRestoresCrd()
+		patcher.PatchCrdOrIgnore(crdGvr, "").WithMergePatchFrom(
+			"zfsrestores.zfs.openebs.io",
+			oldCrd,
+			newCrd,
+		)
+
 		driver.cs = NewController(driver)
 
 	case "agent":

pkg/patcher/newcrd.go

@@ -0,0 +1,27 @@
+package patcher
+
+import (
+	_ "embed"
+	"sigs.k8s.io/yaml"
+)
+
+//go:embed zfsvolume-crd.yaml
+var vol []byte
+
+//go:embed zfssnapshot-crd.yaml
+var snap []byte
+
+//go:embed zfsrestore-crd.yaml
+var res []byte
+
+func NewZfsVolumesCrd() ([]byte, error) {
+	return yaml.YAMLToJSON(vol)
+}
+
+func NewZfsSnapshotsCrd() ([]byte, error) {
+	return yaml.YAMLToJSON(snap)
+}
+
+func NewZfsRestoresCrd() ([]byte, error) {
+	return yaml.YAMLToJSON(res)
+}