validation.go

package validation

import (
	"github.com/GoogleCloudPlatform/kubernetes/pkg/api/errors"
	"github.com/GoogleCloudPlatform/kubernetes/pkg/api/validation"
	deployapi "github.com/openshift/origin/pkg/deploy/api"
)

// TODO: These tests validate the ReplicationControllerState in a Deployment or DeploymentConfig.
//       The upstream validation API isn't factored currently to allow this; we'll make a PR to
//       upstream and fix when it goes in.

func ValidateDeployment(deployment *deployapi.Deployment) errors.ValidationErrorList {
	result := validateDeploymentStrategy(&deployment.Strategy).Prefix("strategy")
	controllerStateErrors := validation.ValidateReplicationControllerSpec(&deployment.ControllerTemplate)
	result = append(result, controllerStateErrors.Prefix("controllerTemplate")...)

	return result
}

func ValidateDeploymentConfig(config *deployapi.DeploymentConfig) errors.ValidationErrorList {
	result := errors.ValidationErrorList{}

	for i := range config.Triggers {
		result = append(result, validateTrigger(&config.Triggers[i]).PrefixIndex(i).Prefix("triggers")...)
	}

	result = append(result, validateDeploymentStrategy(&config.Template.Strategy).Prefix("template.strategy")...)
	controllerStateErrors := validation.ValidateReplicationControllerSpec(&config.Template.ControllerTemplate)
	result = append(result, controllerStateErrors.Prefix("template.controllerTemplate")...)

	return result
}

func ValidateDeploymentConfigRollback(rollback *deployapi.DeploymentConfigRollback) errors.ValidationErrorList {
	result := errors.ValidationErrorList{}

	if len(rollback.Spec.From.Name) == 0 {
		result = append(result, errors.NewFieldRequired("spec.from.name", ""))
	}

	if len(rollback.Spec.From.Kind) == 0 {
		rollback.Spec.From.Kind = "ReplicationController"
	}

	if rollback.Spec.From.Kind != "ReplicationController" {
		result = append(result, errors.NewFieldInvalid("spec.from.kind", rollback.Spec.From.Kind, "the kind of the rollback target must be 'ReplicationController'"))
	}

	return result
}

func validateDeploymentStrategy(strategy *deployapi.DeploymentStrategy) errors.ValidationErrorList {
	result := errors.ValidationErrorList{}

	if len(strategy.Type) == 0 {
		result = append(result, errors.NewFieldRequired("type", ""))
	}

	switch strategy.Type {
	case deployapi.DeploymentStrategyTypeCustom:
		if strategy.CustomParams == nil {
			result = append(result, errors.NewFieldRequired("customParams", ""))
		} else {
			result = append(result, validateCustomParams(strategy.CustomParams).Prefix("customParams")...)
		}
	}

	return result
}

func validateCustomParams(params *deployapi.CustomDeploymentStrategyParams) errors.ValidationErrorList {
	result := errors.ValidationErrorList{}

	if len(params.Image) == 0 {
		result = append(result, errors.NewFieldRequired("image", ""))
	}

	return result
}

func validateTrigger(trigger *deployapi.DeploymentTriggerPolicy) errors.ValidationErrorList {
	result := errors.ValidationErrorList{}

	if len(trigger.Type) == 0 {
		result = append(result, errors.NewFieldRequired("type", ""))
	}

	if trigger.Type == deployapi.DeploymentTriggerOnImageChange {
		if trigger.ImageChangeParams == nil {
			result = append(result, errors.NewFieldRequired("imageChangeParams", nil))
		} else {
			result = append(result, validateImageChangeParams(trigger.ImageChangeParams).Prefix("imageChangeParams")...)
		}
	}

	return result
}

func validateImageChangeParams(params *deployapi.DeploymentTriggerImageChangeParams) errors.ValidationErrorList {
	result := errors.ValidationErrorList{}

	if len(params.RepositoryName) == 0 {
		result = append(result, errors.NewFieldRequired("repositoryName", ""))
	}

	if len(params.ContainerNames) == 0 {
		result = append(result, errors.NewFieldRequired("containerNames", ""))
	}

	return result
}