Function ValidateYAML

pkg/acquisition/schemaval_test.go:46–102

ValidateYAML validates configYAML against schemaPath.

(configYAML []byte, schemaPath string)

// ValidateYAML validates configYAML against schemaPath.
func ValidateYAML(configYAML []byte, schemaPath string) error {
	if schemaPath == "" {
		return errors.New("no schema provided")
	}

	configJSON, err := yaml.YAMLToJSON(configYAML)
	if err != nil {
		return fmt.Errorf("config: YAML->JSON: %w", err)
	}

	configDoc, err := jsonschema.UnmarshalJSON(bytes.NewReader(configJSON))
	if err != nil {
		return fmt.Errorf("config: decode JSON: %w", err)
	}

	c := jsonschema.NewCompiler()
	c.DefaultDraft(jsonschema.Draft2020)

	schemaYAML, err := os.ReadFile(schemaPath)
	if err != nil {
		return fmt.Errorf("read schema %q: %w", schemaPath, err)
	}

	schemaJSON, err := yaml.YAMLToJSON(schemaYAML)
	if err != nil {
		return fmt.Errorf("schema %q: YAML->JSON: %w", schemaPath, err)
	}

	schemaDoc, err := jsonschema.UnmarshalJSON(bytes.NewReader(schemaJSON))
	if err != nil {
		return fmt.Errorf("schema %q: decode JSON: %w", schemaPath, err)
	}

	abs, err := filepath.Abs(schemaPath)
	if err != nil {
		return fmt.Errorf("abs %q: %w", schemaPath, err)
	}

	if err := c.AddResource(abs, schemaDoc); err != nil {
		return fmt.Errorf("add schema resource %q: %w", abs, err)
	}

	sch, err := c.Compile(abs)
	if err != nil {
		return fmt.Errorf("compile schema %q: %w", abs, err)
	}

	if err := sch.Validate(configDoc); err != nil {
		var ve *jsonschema.ValidationError
		if errors.As(err, &ve) {
			return compactSchemaErr(ve)
		}
		return err
	}

	return nil
}