Add logic to detect minimum spec version on save

Signed-off-by: Evan Lezar <[email protected]>

Author: elezar

api/producer/options.go

@@ -25,9 +25,18 @@ import (
 type Option func(*options) error
 
 type options struct {
-	specFormat  SpecFormat
-	overwrite   bool
-	permissions fs.FileMode
+	specFormat           SpecFormat
+	overwrite            bool
+	permissions          fs.FileMode
+	detectMinimumVersion bool
+}
+
+// WithDetectMinimumVersion toggles whether a minimum version should be detected for a CDI specification.
+func WithDetectMinimumVersion(detectMinimumVersion bool) Option {
+	return func(o *options) error {
+		o.detectMinimumVersion = detectMinimumVersion
+		return nil
+	}
 }
 
 // WithSpecFormat sets the output format of a CDI specification.

api/producer/set-minimum-version.go

@@ -0,0 +1,36 @@
+/*
+   Copyright © 2025 The CDI Authors
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+*/
+
+package producer
+
+import (
+	"fmt"
+
+	cdi "tags.cncf.io/container-device-interface/specs-go"
+)
+
+type setMinimumRequiredVersion struct{}
+
+// Transform detects the minimum required version required for the specified
+// spec and sets the version field accordingly.
+func (d setMinimumRequiredVersion) Transform(spec *cdi.Spec) error {
+	minVersion, err := cdi.MinimumRequiredVersion(spec)
+	if err != nil {
+		return fmt.Errorf("failed to get minimum required CDI spec version: %w", err)
+	}
+	spec.Version = minVersion
+	return nil
+}

api/producer/spec-format.go

@@ -83,9 +83,22 @@ func (p *specFormatter) validate() error {
 	return nil
 }
 
+// transform applies a transform to the spec associated with the CDI spec formatter.
+// This is currently limited to detecting (and updating) the spec so that the minimum
+// CDI spec version is used, but could be extended to apply other transformations.
+func (p *specFormatter) transform() error {
+	if !p.detectMinimumVersion {
+		return nil
+	}
+	return (&setMinimumRequiredVersion{}).Transform(p.Spec)
+}
+
 // contents returns the raw contents of a CDI specification.
 // Validation is performed before marshalling the contentent based on the spec format.
 func (p *specFormatter) contents() ([]byte, error) {
+	if err := p.transform(); err != nil {
+		return nil, fmt.Errorf("failed to transform spec: %w", err)
+	}
 	if err := p.validate(); err != nil {
 		return nil, fmt.Errorf("spec validation failed: %w", err)
 	}

api/producer/writer.go

@@ -36,8 +36,9 @@ func NewSpecWriter(opts ...Option) (*SpecWriter, error) {
 		options: options{
 			overwrite: true,
 			// TODO: This could be updated to 0644 to be world-readable.
-			permissions: 0600,
-			specFormat:  DefaultSpecFormat,
+			permissions:          0600,
+			specFormat:           DefaultSpecFormat,
+			detectMinimumVersion: false,
 		},
 	}
 	for _, opt := range opts {

api/producer/writer_test.go

@@ -126,6 +126,25 @@ devices: null
 kind: example.com/class
 `,
 		},
+		{
+			description: "minimum version is detected",
+			spec: cdi.Spec{
+				Version: cdi.CurrentVersion,
+				Kind:    "example.com/class",
+				ContainerEdits: cdi.ContainerEdits{
+					DeviceNodes: []*cdi.DeviceNode{
+						{
+							Path: "/dev/foo",
+						},
+					},
+				},
+			},
+			options:             []Option{WithDetectMinimumVersion(true)},
+			filename:            "foo",
+			expectedFilename:    "foo.yaml",
+			expectedPermissions: 0600,
+			expectedOutput: `---
+cdiVersion: 0.3.0
 containerEdits:
   deviceNodes:
   - path: /dev/foo