1 files changed, 51 insertions, 0 deletions
diff --git a/src/pybind/mgr/rook/rook-client-python/rook_client/tests/test_examples.py b/src/pybind/mgr/rook/rook-client-python/rook_client/tests/test_examples.py
new file mode 100644
index 000000000..1cfd078a5
--- /dev/null
+++ b/src/pybind/mgr/rook/rook-client-python/rook_client/tests/test_examples.py
@@ -0,0 +1,51 @@
+from os.path import expanduser, dirname, realpath
+
+import yaml
+import pytest
+
+import rook_client
+from rook_client.cassandra.cluster import Cluster as CassandraCluster
+from rook_client.ceph.cephcluster import CephCluster
+from rook_client.ceph.cephfilesystem import CephFilesystem
+from rook_client.ceph.cephnfs import CephNFS
+from rook_client.ceph.cephobjectstore import CephObjectStore
+from rook_client.edgefs.cluster import Cluster as EdgefsCluster
+
+
+def _load_example(crd_base, what):
+    with open(expanduser('{crd_base}/{what}').format(crd_base=crd_base, what=what)) as f:
+        return f.read()
+
+
+@pytest.mark.parametrize(
+    "strict,cls,filename",
+    [
+        (True, CephCluster, "ceph/cluster-external.yaml"),
+        (True, CephCluster, "ceph/cluster-minimal.yaml"),
+        (True, CephCluster, "ceph/cluster-on-pvc.yaml"),
+        (True, CephCluster, "ceph/cluster.yaml"),
+        (True, CephFilesystem, "ceph/filesystem-ec.yaml"),
+        (True, CephFilesystem, "ceph/filesystem-test.yaml"),
+        (True, CephFilesystem, "ceph/filesystem.yaml"),
+        (True, CephObjectStore, "ceph/object-ec.yaml"),
+        (True, CephObjectStore, "ceph/object-openshift.yaml"),
+        (True, CephObjectStore, "ceph/object-test.yaml"),
+        (True, CephObjectStore, "ceph/object.yaml"),
+        (True, CephNFS, "ceph/nfs.yaml"),
+
+        # schema invalid:
+        # (False, CassandraCluster, "cassandra/cluster.yaml"),
+        (False, EdgefsCluster, "edgefs/cluster.yaml"),
+    ],
+)
+def test_exact_match(strict, cls, filename, crd_base):
+    crds = yaml.safe_load_all(_load_example(crd_base, filename))
+    rook_client.STRICT = strict
+    [crd] = [e for e in crds if e.get('kind', '') == cls.__name__]
+
+    c = cls.from_json(crd)
+    assert crd == c.to_json()
+
+
+
+