mirror of
				https://github.com/k3s-io/kubernetes.git
				synced 2025-10-25 10:00:53 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			574 lines
		
	
	
		
			14 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			574 lines
		
	
	
		
			14 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // Copyright 2015 go-swagger maintainers
 | |
| //
 | |
| // 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 validate
 | |
| 
 | |
| import (
 | |
| 	"fmt"
 | |
| 	"reflect"
 | |
| 
 | |
| 	"github.com/go-openapi/errors"
 | |
| 	"github.com/go-openapi/spec"
 | |
| 	"github.com/go-openapi/strfmt"
 | |
| )
 | |
| 
 | |
| // An EntityValidator is an interface for things that can validate entities
 | |
| type EntityValidator interface {
 | |
| 	Validate(interface{}) *Result
 | |
| }
 | |
| 
 | |
| type valueValidator interface {
 | |
| 	SetPath(path string)
 | |
| 	Applies(interface{}, reflect.Kind) bool
 | |
| 	Validate(interface{}) *Result
 | |
| }
 | |
| 
 | |
| type itemsValidator struct {
 | |
| 	items        *spec.Items
 | |
| 	root         interface{}
 | |
| 	path         string
 | |
| 	in           string
 | |
| 	validators   []valueValidator
 | |
| 	KnownFormats strfmt.Registry
 | |
| }
 | |
| 
 | |
| func newItemsValidator(path, in string, items *spec.Items, root interface{}, formats strfmt.Registry) *itemsValidator {
 | |
| 	iv := &itemsValidator{path: path, in: in, items: items, root: root, KnownFormats: formats}
 | |
| 	iv.validators = []valueValidator{
 | |
| 		&typeValidator{
 | |
| 			Type:   spec.StringOrArray([]string{items.Type}),
 | |
| 			Format: items.Format,
 | |
| 			In:     in,
 | |
| 			Path:   path,
 | |
| 		},
 | |
| 		iv.stringValidator(),
 | |
| 		iv.formatValidator(),
 | |
| 		iv.numberValidator(),
 | |
| 		iv.sliceValidator(),
 | |
| 		iv.commonValidator(),
 | |
| 	}
 | |
| 	return iv
 | |
| }
 | |
| 
 | |
| func (i *itemsValidator) Validate(index int, data interface{}) *Result {
 | |
| 	tpe := reflect.TypeOf(data)
 | |
| 	kind := tpe.Kind()
 | |
| 	mainResult := new(Result)
 | |
| 	path := fmt.Sprintf("%s.%d", i.path, index)
 | |
| 
 | |
| 	for _, validator := range i.validators {
 | |
| 		validator.SetPath(path)
 | |
| 		if validator.Applies(i.root, kind) {
 | |
| 			result := validator.Validate(data)
 | |
| 			mainResult.Merge(result)
 | |
| 			mainResult.Inc()
 | |
| 			if result != nil && result.HasErrors() {
 | |
| 				return mainResult
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 	return mainResult
 | |
| }
 | |
| 
 | |
| func (i *itemsValidator) commonValidator() valueValidator {
 | |
| 	return &basicCommonValidator{
 | |
| 		In:      i.in,
 | |
| 		Default: i.items.Default,
 | |
| 		Enum:    i.items.Enum,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (i *itemsValidator) sliceValidator() valueValidator {
 | |
| 	return &basicSliceValidator{
 | |
| 		In:           i.in,
 | |
| 		Default:      i.items.Default,
 | |
| 		MaxItems:     i.items.MaxItems,
 | |
| 		MinItems:     i.items.MinItems,
 | |
| 		UniqueItems:  i.items.UniqueItems,
 | |
| 		Source:       i.root,
 | |
| 		Items:        i.items.Items,
 | |
| 		KnownFormats: i.KnownFormats,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (i *itemsValidator) numberValidator() valueValidator {
 | |
| 	return &numberValidator{
 | |
| 		In:               i.in,
 | |
| 		Default:          i.items.Default,
 | |
| 		MultipleOf:       i.items.MultipleOf,
 | |
| 		Maximum:          i.items.Maximum,
 | |
| 		ExclusiveMaximum: i.items.ExclusiveMaximum,
 | |
| 		Minimum:          i.items.Minimum,
 | |
| 		ExclusiveMinimum: i.items.ExclusiveMinimum,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (i *itemsValidator) stringValidator() valueValidator {
 | |
| 	return &stringValidator{
 | |
| 		In:              i.in,
 | |
| 		Default:         i.items.Default,
 | |
| 		MaxLength:       i.items.MaxLength,
 | |
| 		MinLength:       i.items.MinLength,
 | |
| 		Pattern:         i.items.Pattern,
 | |
| 		AllowEmptyValue: false,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (i *itemsValidator) formatValidator() valueValidator {
 | |
| 	return &formatValidator{
 | |
| 		In: i.in,
 | |
| 		//Default:      i.items.Default,
 | |
| 		Format:       i.items.Format,
 | |
| 		KnownFormats: i.KnownFormats,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| type basicCommonValidator struct {
 | |
| 	Path    string
 | |
| 	In      string
 | |
| 	Default interface{}
 | |
| 	Enum    []interface{}
 | |
| }
 | |
| 
 | |
| func (b *basicCommonValidator) SetPath(path string) {
 | |
| 	b.Path = path
 | |
| }
 | |
| 
 | |
| func (b *basicCommonValidator) Applies(source interface{}, kind reflect.Kind) bool {
 | |
| 	switch source.(type) {
 | |
| 	case *spec.Parameter, *spec.Schema, *spec.Header:
 | |
| 		return true
 | |
| 	}
 | |
| 	return false
 | |
| }
 | |
| 
 | |
| func (b *basicCommonValidator) Validate(data interface{}) (res *Result) {
 | |
| 	if len(b.Enum) > 0 {
 | |
| 		for _, enumValue := range b.Enum {
 | |
| 			if data != nil && reflect.DeepEqual(enumValue, data) {
 | |
| 				return nil
 | |
| 			}
 | |
| 		}
 | |
| 		return sErr(errors.EnumFail(b.Path, b.In, data, b.Enum))
 | |
| 	}
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| // A HeaderValidator has very limited subset of validations to apply
 | |
| type HeaderValidator struct {
 | |
| 	name         string
 | |
| 	header       *spec.Header
 | |
| 	validators   []valueValidator
 | |
| 	KnownFormats strfmt.Registry
 | |
| }
 | |
| 
 | |
| // NewHeaderValidator creates a new header validator object
 | |
| func NewHeaderValidator(name string, header *spec.Header, formats strfmt.Registry) *HeaderValidator {
 | |
| 	p := &HeaderValidator{name: name, header: header, KnownFormats: formats}
 | |
| 	p.validators = []valueValidator{
 | |
| 		&typeValidator{
 | |
| 			Type:   spec.StringOrArray([]string{header.Type}),
 | |
| 			Format: header.Format,
 | |
| 			In:     "header",
 | |
| 			Path:   name,
 | |
| 		},
 | |
| 		p.stringValidator(),
 | |
| 		p.formatValidator(),
 | |
| 		p.numberValidator(),
 | |
| 		p.sliceValidator(),
 | |
| 		p.commonValidator(),
 | |
| 	}
 | |
| 	return p
 | |
| }
 | |
| 
 | |
| // Validate the value of the header against its schema
 | |
| func (p *HeaderValidator) Validate(data interface{}) *Result {
 | |
| 	result := new(Result)
 | |
| 	tpe := reflect.TypeOf(data)
 | |
| 	kind := tpe.Kind()
 | |
| 
 | |
| 	for _, validator := range p.validators {
 | |
| 		if validator.Applies(p.header, kind) {
 | |
| 			if err := validator.Validate(data); err != nil {
 | |
| 				result.Merge(err)
 | |
| 				if err.HasErrors() {
 | |
| 					return result
 | |
| 				}
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| func (p *HeaderValidator) commonValidator() valueValidator {
 | |
| 	return &basicCommonValidator{
 | |
| 		Path:    p.name,
 | |
| 		In:      "response",
 | |
| 		Default: p.header.Default,
 | |
| 		Enum:    p.header.Enum,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *HeaderValidator) sliceValidator() valueValidator {
 | |
| 	return &basicSliceValidator{
 | |
| 		Path:         p.name,
 | |
| 		In:           "response",
 | |
| 		Default:      p.header.Default,
 | |
| 		MaxItems:     p.header.MaxItems,
 | |
| 		MinItems:     p.header.MinItems,
 | |
| 		UniqueItems:  p.header.UniqueItems,
 | |
| 		Items:        p.header.Items,
 | |
| 		Source:       p.header,
 | |
| 		KnownFormats: p.KnownFormats,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *HeaderValidator) numberValidator() valueValidator {
 | |
| 	return &numberValidator{
 | |
| 		Path:             p.name,
 | |
| 		In:               "response",
 | |
| 		Default:          p.header.Default,
 | |
| 		MultipleOf:       p.header.MultipleOf,
 | |
| 		Maximum:          p.header.Maximum,
 | |
| 		ExclusiveMaximum: p.header.ExclusiveMaximum,
 | |
| 		Minimum:          p.header.Minimum,
 | |
| 		ExclusiveMinimum: p.header.ExclusiveMinimum,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *HeaderValidator) stringValidator() valueValidator {
 | |
| 	return &stringValidator{
 | |
| 		Path:            p.name,
 | |
| 		In:              "response",
 | |
| 		Default:         p.header.Default,
 | |
| 		Required:        true,
 | |
| 		MaxLength:       p.header.MaxLength,
 | |
| 		MinLength:       p.header.MinLength,
 | |
| 		Pattern:         p.header.Pattern,
 | |
| 		AllowEmptyValue: false,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *HeaderValidator) formatValidator() valueValidator {
 | |
| 	return &formatValidator{
 | |
| 		Path: p.name,
 | |
| 		In:   "response",
 | |
| 		//Default:      p.header.Default,
 | |
| 		Format:       p.header.Format,
 | |
| 		KnownFormats: p.KnownFormats,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| // A ParamValidator has very limited subset of validations to apply
 | |
| type ParamValidator struct {
 | |
| 	param        *spec.Parameter
 | |
| 	validators   []valueValidator
 | |
| 	KnownFormats strfmt.Registry
 | |
| }
 | |
| 
 | |
| // NewParamValidator creates a new param validator object
 | |
| func NewParamValidator(param *spec.Parameter, formats strfmt.Registry) *ParamValidator {
 | |
| 	p := &ParamValidator{param: param, KnownFormats: formats}
 | |
| 	p.validators = []valueValidator{
 | |
| 		&typeValidator{
 | |
| 			Type:   spec.StringOrArray([]string{param.Type}),
 | |
| 			Format: param.Format,
 | |
| 			In:     param.In,
 | |
| 			Path:   param.Name,
 | |
| 		},
 | |
| 		p.stringValidator(),
 | |
| 		p.formatValidator(),
 | |
| 		p.numberValidator(),
 | |
| 		p.sliceValidator(),
 | |
| 		p.commonValidator(),
 | |
| 	}
 | |
| 	return p
 | |
| }
 | |
| 
 | |
| // Validate the data against the description of the parameter
 | |
| func (p *ParamValidator) Validate(data interface{}) *Result {
 | |
| 	result := new(Result)
 | |
| 	tpe := reflect.TypeOf(data)
 | |
| 	kind := tpe.Kind()
 | |
| 
 | |
| 	// TODO: validate type
 | |
| 	for _, validator := range p.validators {
 | |
| 		if validator.Applies(p.param, kind) {
 | |
| 			if err := validator.Validate(data); err != nil {
 | |
| 				result.Merge(err)
 | |
| 				if err.HasErrors() {
 | |
| 					return result
 | |
| 				}
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| func (p *ParamValidator) commonValidator() valueValidator {
 | |
| 	return &basicCommonValidator{
 | |
| 		Path:    p.param.Name,
 | |
| 		In:      p.param.In,
 | |
| 		Default: p.param.Default,
 | |
| 		Enum:    p.param.Enum,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *ParamValidator) sliceValidator() valueValidator {
 | |
| 	return &basicSliceValidator{
 | |
| 		Path:         p.param.Name,
 | |
| 		In:           p.param.In,
 | |
| 		Default:      p.param.Default,
 | |
| 		MaxItems:     p.param.MaxItems,
 | |
| 		MinItems:     p.param.MinItems,
 | |
| 		UniqueItems:  p.param.UniqueItems,
 | |
| 		Items:        p.param.Items,
 | |
| 		Source:       p.param,
 | |
| 		KnownFormats: p.KnownFormats,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *ParamValidator) numberValidator() valueValidator {
 | |
| 	return &numberValidator{
 | |
| 		Path:             p.param.Name,
 | |
| 		In:               p.param.In,
 | |
| 		Default:          p.param.Default,
 | |
| 		MultipleOf:       p.param.MultipleOf,
 | |
| 		Maximum:          p.param.Maximum,
 | |
| 		ExclusiveMaximum: p.param.ExclusiveMaximum,
 | |
| 		Minimum:          p.param.Minimum,
 | |
| 		ExclusiveMinimum: p.param.ExclusiveMinimum,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *ParamValidator) stringValidator() valueValidator {
 | |
| 	return &stringValidator{
 | |
| 		Path:            p.param.Name,
 | |
| 		In:              p.param.In,
 | |
| 		Default:         p.param.Default,
 | |
| 		AllowEmptyValue: p.param.AllowEmptyValue,
 | |
| 		Required:        p.param.Required,
 | |
| 		MaxLength:       p.param.MaxLength,
 | |
| 		MinLength:       p.param.MinLength,
 | |
| 		Pattern:         p.param.Pattern,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (p *ParamValidator) formatValidator() valueValidator {
 | |
| 	return &formatValidator{
 | |
| 		Path: p.param.Name,
 | |
| 		In:   p.param.In,
 | |
| 		//Default:      p.param.Default,
 | |
| 		Format:       p.param.Format,
 | |
| 		KnownFormats: p.KnownFormats,
 | |
| 	}
 | |
| }
 | |
| 
 | |
| type basicSliceValidator struct {
 | |
| 	Path           string
 | |
| 	In             string
 | |
| 	Default        interface{}
 | |
| 	MaxItems       *int64
 | |
| 	MinItems       *int64
 | |
| 	UniqueItems    bool
 | |
| 	Items          *spec.Items
 | |
| 	Source         interface{}
 | |
| 	itemsValidator *itemsValidator
 | |
| 	KnownFormats   strfmt.Registry
 | |
| }
 | |
| 
 | |
| func (s *basicSliceValidator) SetPath(path string) {
 | |
| 	s.Path = path
 | |
| }
 | |
| 
 | |
| func (s *basicSliceValidator) Applies(source interface{}, kind reflect.Kind) bool {
 | |
| 	switch source.(type) {
 | |
| 	case *spec.Parameter, *spec.Items, *spec.Header:
 | |
| 		return kind == reflect.Slice
 | |
| 	}
 | |
| 	return false
 | |
| }
 | |
| 
 | |
| func sErr(err errors.Error) *Result {
 | |
| 	return &Result{Errors: []error{err}}
 | |
| }
 | |
| 
 | |
| func (s *basicSliceValidator) Validate(data interface{}) *Result {
 | |
| 	val := reflect.ValueOf(data)
 | |
| 
 | |
| 	size := int64(val.Len())
 | |
| 	if s.MinItems != nil {
 | |
| 		if err := MinItems(s.Path, s.In, size, *s.MinItems); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if s.MaxItems != nil {
 | |
| 		if err := MaxItems(s.Path, s.In, size, *s.MaxItems); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if s.UniqueItems {
 | |
| 		if err := UniqueItems(s.Path, s.In, data); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if s.itemsValidator == nil && s.Items != nil {
 | |
| 		s.itemsValidator = newItemsValidator(s.Path, s.In, s.Items, s.Source, s.KnownFormats)
 | |
| 	}
 | |
| 
 | |
| 	if s.itemsValidator != nil {
 | |
| 		for i := 0; i < int(size); i++ {
 | |
| 			ele := val.Index(i)
 | |
| 			if err := s.itemsValidator.Validate(i, ele.Interface()); err != nil && err.HasErrors() {
 | |
| 				return err
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| func (s *basicSliceValidator) hasDuplicates(value reflect.Value, size int) bool {
 | |
| 	dict := make(map[interface{}]struct{})
 | |
| 	for i := 0; i < size; i++ {
 | |
| 		ele := value.Index(i)
 | |
| 		if _, ok := dict[ele.Interface()]; ok {
 | |
| 			return true
 | |
| 		}
 | |
| 		dict[ele.Interface()] = struct{}{}
 | |
| 	}
 | |
| 	return false
 | |
| }
 | |
| 
 | |
| type numberValidator struct {
 | |
| 	Path             string
 | |
| 	In               string
 | |
| 	Default          interface{}
 | |
| 	MultipleOf       *float64
 | |
| 	Maximum          *float64
 | |
| 	ExclusiveMaximum bool
 | |
| 	Minimum          *float64
 | |
| 	ExclusiveMinimum bool
 | |
| }
 | |
| 
 | |
| func (n *numberValidator) SetPath(path string) {
 | |
| 	n.Path = path
 | |
| }
 | |
| 
 | |
| func (n *numberValidator) Applies(source interface{}, kind reflect.Kind) bool {
 | |
| 	switch source.(type) {
 | |
| 	case *spec.Parameter, *spec.Schema, *spec.Items, *spec.Header:
 | |
| 		isInt := kind >= reflect.Int && kind <= reflect.Uint64
 | |
| 		isFloat := kind == reflect.Float32 || kind == reflect.Float64
 | |
| 		r := isInt || isFloat
 | |
| 		// fmt.Printf("schema props validator for %q applies %t for %T (kind: %v)\n", n.Path, r, source, kind)
 | |
| 		return r
 | |
| 	}
 | |
| 	// fmt.Printf("schema props validator for %q applies %t for %T (kind: %v)\n", n.Path, false, source, kind)
 | |
| 	return false
 | |
| }
 | |
| 
 | |
| func (n *numberValidator) convertToFloat(val interface{}) float64 {
 | |
| 	v := reflect.ValueOf(val)
 | |
| 	switch v.Kind() {
 | |
| 	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
 | |
| 		return float64(v.Int())
 | |
| 	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
 | |
| 		return float64(v.Uint())
 | |
| 	case reflect.Float32, reflect.Float64:
 | |
| 		return v.Float()
 | |
| 	}
 | |
| 	return 0
 | |
| }
 | |
| 
 | |
| func (n *numberValidator) Validate(val interface{}) *Result {
 | |
| 	data := n.convertToFloat(val)
 | |
| 
 | |
| 	if n.MultipleOf != nil {
 | |
| 		if err := MultipleOf(n.Path, n.In, data, *n.MultipleOf); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 	if n.Maximum != nil {
 | |
| 		if err := Maximum(n.Path, n.In, data, *n.Maximum, n.ExclusiveMaximum); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 	if n.Minimum != nil {
 | |
| 		if err := Minimum(n.Path, n.In, data, *n.Minimum, n.ExclusiveMinimum); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 	result := new(Result)
 | |
| 	result.Inc()
 | |
| 	return result
 | |
| }
 | |
| 
 | |
| type stringValidator struct {
 | |
| 	Default         interface{}
 | |
| 	Required        bool
 | |
| 	AllowEmptyValue bool
 | |
| 	MaxLength       *int64
 | |
| 	MinLength       *int64
 | |
| 	Pattern         string
 | |
| 	Path            string
 | |
| 	In              string
 | |
| }
 | |
| 
 | |
| func (s *stringValidator) SetPath(path string) {
 | |
| 	s.Path = path
 | |
| }
 | |
| 
 | |
| func (s *stringValidator) Applies(source interface{}, kind reflect.Kind) bool {
 | |
| 	switch source.(type) {
 | |
| 	case *spec.Parameter, *spec.Schema, *spec.Items, *spec.Header:
 | |
| 		r := kind == reflect.String
 | |
| 		// fmt.Printf("string validator for %q applies %t for %T (kind: %v)\n", s.Path, r, source, kind)
 | |
| 		return r
 | |
| 	}
 | |
| 	// fmt.Printf("string validator for %q applies %t for %T (kind: %v)\n", s.Path, false, source, kind)
 | |
| 	return false
 | |
| }
 | |
| 
 | |
| func (s *stringValidator) Validate(val interface{}) *Result {
 | |
| 	data := val.(string)
 | |
| 
 | |
| 	if s.Required && !s.AllowEmptyValue && (s.Default == nil || s.Default == "") {
 | |
| 		if err := RequiredString(s.Path, s.In, data); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if s.MaxLength != nil {
 | |
| 		if err := MaxLength(s.Path, s.In, data, *s.MaxLength); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if s.MinLength != nil {
 | |
| 		if err := MinLength(s.Path, s.In, data, *s.MinLength); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if s.Pattern != "" {
 | |
| 		if err := Pattern(s.Path, s.In, data, s.Pattern); err != nil {
 | |
| 			return sErr(err)
 | |
| 		}
 | |
| 	}
 | |
| 	return nil
 | |
| }
 |