Add schema to generated NewPerVersionTranslators

Author: josvazg

internal/crapi/crapi_test.go

@@ -2000,7 +2000,7 @@ func testToAPI[T any](t *testing.T, kind string, input client.Object, objs []cli
 	crdsYML := bytes.NewBuffer(testdata.SampleCRDs)
 	crd, err := extractCRD(kind, bufio.NewScanner(crdsYML))
 	require.NoError(t, err)
-	trs, err := crapi.NewPerVersionTranslators(crd, version, sdkVersion)
+	trs, err := crapi.NewPerVersionTranslators(testScheme(t), crd, version, sdkVersion)
 	require.NoError(t, err)
 	tr := trs[sdkVersion]
 	require.NotNil(t, tr)

internal/crapi/translator.go

@@ -189,7 +189,7 @@ func NewTranslator(scheme *runtime.Scheme, crd *apiextensionsv1.CustomResourceDe
 //
 // In the above case crdVersion is "v1" and versions can be "v20250312"
 // and/or "v20250810".
-func NewPerVersionTranslators(crd *apiextensionsv1.CustomResourceDefinition, crdVersion string, versions ...string) (map[string]Translator, error) {
+func NewPerVersionTranslators(scheme *runtime.Scheme, crd *apiextensionsv1.CustomResourceDefinition, crdVersion string, versions ...string) (map[string]Translator, error) {
 	translators := map[string]Translator{}
 	specVersion := crds.SelectVersion(&crd.Spec, crdVersion)
 	for _, version := range versions {
@@ -209,6 +209,7 @@ func NewPerVersionTranslators(crd *apiextensionsv1.CustomResourceDefinition, crd
 		}
 
 		translators[version] = &translator{
+			scheme:        scheme,
 			majorVersion:  version,
 			mappingSchema: &openapi3.SchemaRef{Value: &mappingSchema},
 		}

internal/generated/controller/cluster/cluster_controller.go

@@ -74,7 +74,7 @@ func NewClusterReconciler(
 	if err != nil {
 		return nil, fmt.Errorf("failed to read CRD for Cluster: %w", err)
 	}
-	translators, err := crapi.NewPerVersionTranslators(crd, crdVersion, sdkVersions...)
+	translators, err := crapi.NewPerVersionTranslators(c.GetScheme(), crd, crdVersion, sdkVersions...)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get translator set for Cluster: %w", err)
 	}

internal/generated/controller/databaseuser/databaseuser_controller.go

@@ -74,7 +74,7 @@ func NewDatabaseUserReconciler(
 	if err != nil {
 		return nil, fmt.Errorf("failed to read CRD for DatabaseUser: %w", err)
 	}
-	translators, err := crapi.NewPerVersionTranslators(crd, crdVersion, sdkVersions...)
+	translators, err := crapi.NewPerVersionTranslators(c.GetScheme(), crd, crdVersion, sdkVersions...)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get translator set for DatabaseUser: %w", err)
 	}

internal/generated/controller/flexcluster/flexcluster_controller.go

@@ -74,7 +74,7 @@ func NewFlexClusterReconciler(
 	if err != nil {
 		return nil, fmt.Errorf("failed to read CRD for FlexCluster: %w", err)
 	}
-	translators, err := crapi.NewPerVersionTranslators(crd, crdVersion, sdkVersions...)
+	translators, err := crapi.NewPerVersionTranslators(c.GetScheme(), crd, crdVersion, sdkVersions...)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get translator set for FlexCluster: %w", err)
 	}

internal/generated/controller/group/group_controller.go

@@ -74,7 +74,7 @@ func NewGroupReconciler(
 	if err != nil {
 		return nil, fmt.Errorf("failed to read CRD for Group: %w", err)
 	}
-	translators, err := crapi.NewPerVersionTranslators(crd, crdVersion, sdkVersions...)
+	translators, err := crapi.NewPerVersionTranslators(c.GetScheme(), crd, crdVersion, sdkVersions...)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get translator set for Group: %w", err)
 	}

tools/scaffolder/internal/generate/controller.go

@@ -229,6 +229,7 @@ func generateControllerFileWithMultipleVersions(dir, controllerName, resourceNam
 		jen.List(jen.Id("translators"), jen.Id("err")).Op(":=").Qual(
 			"github.com/mongodb/mongodb-atlas-kubernetes/v2/internal/crapi", "NewPerVersionTranslators",
 		).Call(
+			jen.Id("c").Dot("GetScheme").Call(),
 			jen.Id("crd"),
 			jen.Id("crdVersion"),
 			jen.Id("sdkVersions").Op("..."),