test: Rework tests that check that the CRDs are valid

Author: sbernauer

kube-derive/Cargo.toml

@@ -36,3 +36,4 @@ trybuild.workspace = true
 assert-json-diff.workspace = true
 runtime-macros.workspace = true
 prettyplease.workspace = true
+tokio = { workspace = true, features = ["rt", "macros"] }

kube-derive/tests/crd_complex_enum_tests.rs

@@ -1,6 +1,14 @@
 #![allow(missing_docs)]
+use std::time::Duration;
+
 use assert_json_diff::assert_json_eq;
-use kube::{CustomResource, CustomResourceExt};
+use k8s_openapi::apiextensions_apiserver::pkg::apis::apiextensions::v1::{
+    CustomResourceConversion, CustomResourceDefinition,
+};
+use kube::{
+    api::{DeleteParams, PostParams},
+    Api, Client, CustomResource, CustomResourceExt, ResourceExt,
+};
 use schemars::JsonSchema;
 use serde::{Deserialize, Serialize};
 use serde_json::json;
@@ -125,44 +133,41 @@ struct FlattenedUntaggedEnumTestSpec {
     foo: FlattenedUntaggedEnum,
 }
 
-/// Use `cargo test --package kube-derive print_crds -- --nocapture` to get the CRDs as YAML.
-/// Afterwards you can use `kubectl apply -f -` to see if they are valid CRDs.
-#[test]
-fn print_crds() {
-    println!("{}", serde_yaml::to_string(&NormalEnumTest::crd()).unwrap());
-    println!("---");
-    println!("{}", serde_yaml::to_string(&OptionalEnumTest::crd()).unwrap());
-    println!("---");
-    println!(
-        "{}",
-        serde_yaml::to_string(&NormalEnumWithoutDescriptionsTest::crd()).unwrap()
-    );
-    println!("---");
-    println!(
-        "{}",
-        serde_yaml::to_string(&OptionalEnumWithoutDescriptionsTest::crd()).unwrap()
-    );
-    println!("---");
-    println!("{}", serde_yaml::to_string(&ComplexEnumTest::crd()).unwrap());
-    println!("---");
-    println!(
-        "{}",
-        serde_yaml::to_string(&OptionalComplexEnumTest::crd()).unwrap()
-    );
-    println!("---");
-    println!("{}", serde_yaml::to_string(&UntaggedEnumTest::crd()).unwrap());
-    println!("---");
-    println!(
-        "{}",
-        serde_yaml::to_string(&OptionalUntaggedEnumTest::crd()).unwrap()
-    );
-    println!("---");
-    println!(
-        "{}",
-        serde_yaml::to_string(&FlattenedUntaggedEnumTest::crd()).unwrap()
-    );
+#[tokio::test]
+#[ignore = "needs apiserver to validate CRDs"]
+async fn check_are_valid_crds() {
+    let crds = [
+        NormalEnumTest::crd(),
+        OptionalEnumTest::crd(),
+        NormalEnumWithoutDescriptionsTest::crd(),
+        OptionalEnumWithoutDescriptionsTest::crd(),
+        ComplexEnumTest::crd(),
+        OptionalComplexEnumTest::crd(),
+        UntaggedEnumTest::crd(),
+        OptionalUntaggedEnumTest::crd(),
+        FlattenedUntaggedEnumTest::crd(),
+    ];
+
+    let client = Client::try_default()
+        .await
+        .expect("failed to create Kubernetes client");
+    let crd_api: Api<CustomResourceDefinition> = Api::all(client);
+    for crd in crds {
+        // Clean up existing CRDs. As these are only test CRDs and this test is not run by default
+        // this is fine.
+        let _ = crd_api.delete(&crd.name_any(), &DeleteParams::default()).await;
+
+        // Prevent "object is being deleted: customresourcedefinition already exists
+        tokio::time::sleep(Duration::from_millis(100)).await;
+
+        crd_api
+            .create(&PostParams::default(), &crd)
+            .await
+            .expect("failed to create CRD");
+    }
 }
 
+
 #[test]
 fn normal_enum() {
     assert_json_eq!(

kube-derive/tests/crd_mixed_enum_test.rs

@@ -1,6 +1,12 @@
 #![allow(missing_docs)]
+use std::time::Duration;
+
 use assert_json_diff::assert_json_eq;
-use kube::{CustomResource, CustomResourceExt};
+use k8s_openapi::apiextensions_apiserver::pkg::apis::apiextensions::v1::CustomResourceDefinition;
+use kube::{
+    api::{DeleteParams, PostParams},
+    Api, Client, CustomResource, CustomResourceExt, ResourceExt,
+};
 use schemars::JsonSchema;
 use serde::{Deserialize, Serialize};
 use serde_json::json;
@@ -86,6 +92,30 @@ enum InvalidEnum7Spec {
     },
 }
 
+#[tokio::test]
+#[ignore = "needs apiserver to validate CRDs"]
+async fn check_are_valid_crds() {
+    let crds = [ValidEnum3::crd(), ValidEnum4::crd(), ValidEnum6::crd()];
+
+    let client = Client::try_default()
+        .await
+        .expect("failed to create Kubernetes client");
+    let crd_api: Api<CustomResourceDefinition> = Api::all(client);
+    for crd in crds {
+        // Clean up existing CRDs. As these are only test CRDs and this test is not run by default
+        // this is fine.
+        let _ = crd_api.delete(&crd.name_any(), &DeleteParams::default()).await;
+
+        // Prevent "object is being deleted: customresourcedefinition already exists
+        tokio::time::sleep(Duration::from_millis(100)).await;
+
+        crd_api
+            .create(&PostParams::default(), &crd)
+            .await
+            .expect("failed to create CRD");
+    }
+}
+
 /// Use `cargo test --package kube-derive print_crds -- --nocapture` to get the CRDs as YAML.
 /// Afterwards you can use `kubectl apply -f -` to see if they are valid CRDs.
 #[test]