const (
	keyStreams			= "streams"
	keyDefinitions			= "definitions"
	keyProperties			= "properties"
	keyRequired			= "required"
	oasSchemaVersionNotFoundFmt	= "schema not found for version %q"
)

var (
	schemaOnce	sync.Once

	oasJSONSchemas	map[string][]byte

	bentoValidators	map[bento.ValidatorKind]bento.ConfigValidator

	defaultVersion	string
)

var schemaDir embed.FS

GetOASSchema returns an oas schema for a particular version.

func GetOASSchema(version string) ([]byte, error) {
	if err := loadSchemas(); err != nil {
		return nil, fmt.Errorf("loadSchemas failed: %w", err)
	}

	if version == "" {
		return oasJSONSchemas[defaultVersion], nil
	}

	minorVersion, err := getMinorVersion(version)
	if err != nil {
		return nil, err
	}

	oasSchema, ok := oasJSONSchemas[minorVersion]
	if !ok {
		return nil, fmt.Errorf(oasSchemaVersionNotFoundFmt, version)
	}

	return oasSchema, nil
}

Cognitive complexity: 8, Cyclomatic complexity: 5

Uses: fmt.Errorf.

ValidateOASObject validates a Tyk Streams document against a particular OAS version.

func ValidateOASObject(documentBody []byte, oasVersion string) error {
	return ValidateOASObjectWithBentoConfigValidator(documentBody, oasVersion, bento.DefaultValidator)
}

Cognitive complexity: 0, Cyclomatic complexity: 1

Uses: bento.DefaultValidator.

ValidateOASObjectWithBentoConfigValidator validates a Tyk Streams document against a particular OAS version and takes an optional ConfigValidator

func ValidateOASObjectWithBentoConfigValidator(documentBody []byte, oasVersion string, bentoValidatorKind bento.ValidatorKind) error {
	oasSchema, err := GetOASSchema(oasVersion)
	if err != nil {
		return err
	}
	return validateJSON(oasSchema, documentBody, bentoValidatorKind)
}

Cognitive complexity: 2, Cyclomatic complexity: 2

ValidateOASObjectWithConfig validates a Tyk Streams document against a particular OAS version, using the provided configuration to determine if validation should be disabled.

func ValidateOASObjectWithConfig(documentBody []byte, oasVersion string, disableValidator bool) error {
	validatorKind := bento.DefaultValidator
	if disableValidator {
		validatorKind = bento.EnableAll
	}
	return ValidateOASObjectWithBentoConfigValidator(documentBody, oasVersion, validatorKind)
}

Cognitive complexity: 2, Cyclomatic complexity: 2

Uses: bento.DefaultValidator, bento.EnableAll.

ValidateOASTemplate checks a Tyk Streams OAS API template for necessary fields, acknowledging that some standard Tyk OAS API fields are optional in templates.

func ValidateOASTemplate(documentBody []byte, oasVersion string) error {
	return ValidateOASTemplateWithBentoValidator(documentBody, oasVersion, bento.DefaultValidator)
}

Cognitive complexity: 0, Cyclomatic complexity: 1

Uses: bento.DefaultValidator.

func ValidateOASTemplateWithBentoValidator(documentBody []byte, oasVersion string, bentoValidatorKind bento.ValidatorKind) error {
	oasSchema, err := GetOASSchema(oasVersion)
	if err != nil {
		return err
	}

	oasSchema = jsonparser.Delete(oasSchema, keyProperties, oas.ExtensionTykStreaming, keyRequired)
	oasSchema = jsonparser.Delete(oasSchema, keyProperties, oas.ExtensionTykAPIGateway, keyRequired)

	definitions, _, _, err := jsonparser.Get(oasSchema, keyDefinitions)
	if err != nil {
		return err
	}

	unsetReqFieldsPaths := []string{
		"X-Tyk-Info",
		"X-Tyk-State",
		"X-Tyk-Server",
		"X-Tyk-ListenPath",
		"X-Tyk-Streams",
	}

	for _, path := range unsetReqFieldsPaths {
		definitions = jsonparser.Delete(definitions, path, keyRequired)
	}

	oasSchema, err = jsonparser.Set(oasSchema, definitions, keyDefinitions)
	if err != nil {
		return err
	}

	return validateJSON(oasSchema, documentBody, bentoValidatorKind)
}

Cognitive complexity: 10, Cyclomatic complexity: 5

Uses: jsonparser.Delete, jsonparser.Get, jsonparser.Set, oas.ExtensionTykAPIGateway, oas.ExtensionTykStreaming.

findDefaultVersion (rawVersions []string) string

getMinorVersion (version string) (string, error)

loadSchemas () error

setDefaultVersion ()

validateBentoConfiguration (document []byte, bentoValidatorKind bento.ValidatorKind) error

validateJSON (schema,document []byte, bentoValidatorKind bento.ValidatorKind) error

var oasTemplateFS embed.FS