Adds validation for role object
execute "fuel-ccp validate {type,}" to validate specified types
for component repositories. If type list is not specified - validation
of all available types will be performed.
This patch supports only validation for "service-def" type.
Also service validation is added before each deploy action.
Change-Id: Icf34c722ba441537b213671f93f9d322d3a8325a
This commit is contained in:
Dmitriy Ukhlov
253
fuel_ccp/validation/service.py
Normal file
253
fuel_ccp/validation/service.py
Normal file
@@ -0,0 +1,253 @@
|
||||
import copy
|
||||
|
||||
from fuel_ccp.validation import base as validation_base
|
||||
import jsonschema
|
||||
from oslo_log import log as logging
|
||||
|
||||
|
||||
LOG = logging.getLogger(__name__)
|
||||
|
||||
|
||||
# RegExp for range 1-65535
|
||||
ALL_PORT_RE = (
|
||||
r'([1-5][0-9]{4}|6[0-4][0-9]{3}|65([0-4][0-9]{2}|655([0-2][0-9]{1}|'
|
||||
r'6553([0-5])'
|
||||
)
|
||||
# RegExp for range 30000-32767
|
||||
HOST_PORT_RE = (
|
||||
r'(3[0-1][0-9]{3}|32[0-6][0-9]{2}|327[0-5][0-9]|3276[0-7])'
|
||||
)
|
||||
|
||||
PATH_RE = r'^(/|((/[\w.-]+)+/?))$'
|
||||
FILE_PATH_RE = r'^(/|((/[\w.-]+)+))$'
|
||||
|
||||
NOT_EMPTY_STRING_SCHEMA = {
|
||||
"type": "string",
|
||||
"pattern": r"^\s*\S.*$"
|
||||
}
|
||||
|
||||
NOT_EMPTY_STRING_ARRAY_SCHEMA = {
|
||||
"type": "array",
|
||||
"minItems": 1,
|
||||
|
||||
"items": NOT_EMPTY_STRING_SCHEMA
|
||||
}
|
||||
|
||||
LOCAL_COMMAND_SCHEMA = {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["command"],
|
||||
|
||||
"properties": {
|
||||
"name": NOT_EMPTY_STRING_SCHEMA,
|
||||
"command": NOT_EMPTY_STRING_SCHEMA,
|
||||
"dependencies": NOT_EMPTY_STRING_ARRAY_SCHEMA,
|
||||
"type": {
|
||||
"enum": ["local"]
|
||||
},
|
||||
"files": NOT_EMPTY_STRING_ARRAY_SCHEMA,
|
||||
"user": NOT_EMPTY_STRING_SCHEMA
|
||||
}
|
||||
}
|
||||
|
||||
SINGLE_COMMAND_SCHEMA = copy.deepcopy(LOCAL_COMMAND_SCHEMA)
|
||||
SINGLE_COMMAND_SCHEMA["required"] = ["name", "command", "type"]
|
||||
SINGLE_COMMAND_SCHEMA["properties"]["type"]["enum"] = ["single"]
|
||||
|
||||
COMMAND_SCHEMA = {
|
||||
"type": "object",
|
||||
"oneOf": [
|
||||
LOCAL_COMMAND_SCHEMA,
|
||||
SINGLE_COMMAND_SCHEMA
|
||||
]
|
||||
}
|
||||
|
||||
NOT_EMPTY_COMMAND_ARRAY_SCHEMA = {
|
||||
"type": "array",
|
||||
"minItems": 1,
|
||||
|
||||
"items": COMMAND_SCHEMA
|
||||
}
|
||||
|
||||
EMPTY_DIR_VOLUME_SCHEMA = {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["name", "path"],
|
||||
|
||||
"properties": {
|
||||
"name": NOT_EMPTY_STRING_SCHEMA,
|
||||
"type": {
|
||||
"enum": ["empty-dir"]
|
||||
},
|
||||
"path": {
|
||||
"type": "string",
|
||||
"pattern": PATH_RE
|
||||
},
|
||||
"mount-path": {
|
||||
"type": "string",
|
||||
"pattern": PATH_RE
|
||||
},
|
||||
"readOnly": {
|
||||
"type": "boolean"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
HOST_VOLUME_SCHEMA = copy.deepcopy(EMPTY_DIR_VOLUME_SCHEMA)
|
||||
HOST_VOLUME_SCHEMA["required"] = ["name", "path", "type"]
|
||||
HOST_VOLUME_SCHEMA["properties"]["type"]["enum"] = ["host"]
|
||||
|
||||
VOLUME_SCHEMA = {
|
||||
"type": "object",
|
||||
"oneOf": [
|
||||
EMPTY_DIR_VOLUME_SCHEMA,
|
||||
HOST_VOLUME_SCHEMA
|
||||
]
|
||||
}
|
||||
|
||||
SERVICE_SCHEMA = {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["service"],
|
||||
|
||||
"properties": {
|
||||
"service": {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["name", "containers"],
|
||||
|
||||
"properties": {
|
||||
"name": NOT_EMPTY_STRING_SCHEMA,
|
||||
"ports": {
|
||||
"type": "array",
|
||||
"minItems": 1,
|
||||
|
||||
"items": {
|
||||
"oneOf": [
|
||||
{
|
||||
"type": "integer",
|
||||
"minimum": 1,
|
||||
"maximum": 65535
|
||||
},
|
||||
{
|
||||
"type": "string",
|
||||
"pattern": r"^{}(:{})?$".format(
|
||||
ALL_PORT_RE, HOST_PORT_RE
|
||||
)
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"daemonset": {
|
||||
"type": "boolean"
|
||||
},
|
||||
"host-net": {
|
||||
"type": "boolean"
|
||||
},
|
||||
"containers": {
|
||||
"type": "array",
|
||||
"minItems": 1,
|
||||
|
||||
"items": {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["name", "image", "daemon"],
|
||||
|
||||
"properties": {
|
||||
"name": NOT_EMPTY_STRING_SCHEMA,
|
||||
"image": NOT_EMPTY_STRING_SCHEMA,
|
||||
"privileged": {
|
||||
"type": "boolean"
|
||||
},
|
||||
"probes": {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
|
||||
"properties": {
|
||||
"readiness": NOT_EMPTY_STRING_SCHEMA,
|
||||
"liveness": NOT_EMPTY_STRING_SCHEMA
|
||||
}
|
||||
},
|
||||
"volumes": {
|
||||
"type": "array",
|
||||
"minItems": 1,
|
||||
|
||||
"items": VOLUME_SCHEMA
|
||||
},
|
||||
"pre": NOT_EMPTY_COMMAND_ARRAY_SCHEMA,
|
||||
"daemon": LOCAL_COMMAND_SCHEMA,
|
||||
"post": NOT_EMPTY_COMMAND_ARRAY_SCHEMA,
|
||||
"env": {
|
||||
"type": "array",
|
||||
"minItems": 1,
|
||||
"items": {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["name"],
|
||||
|
||||
"properties": {
|
||||
"name": NOT_EMPTY_STRING_SCHEMA,
|
||||
"value": NOT_EMPTY_STRING_SCHEMA,
|
||||
"valueFrom": {"type": "object"}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"files": {
|
||||
"type": "object",
|
||||
"patternProperties": {
|
||||
r"^[\w][\w.-]*$": {
|
||||
"type": "object",
|
||||
"additionalProperties": False,
|
||||
"required": ["path", "content"],
|
||||
|
||||
"properties": {
|
||||
"path": {
|
||||
"type": "string",
|
||||
"pattern": FILE_PATH_RE
|
||||
},
|
||||
"content": NOT_EMPTY_STRING_SCHEMA,
|
||||
"perm": {
|
||||
"type": "string",
|
||||
"pattern": "[0-7]{3,4}"
|
||||
},
|
||||
"user": NOT_EMPTY_STRING_SCHEMA
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
def validate_service_definitions(components_map, components):
|
||||
if not components:
|
||||
components = components_map.keys()
|
||||
else:
|
||||
validation_base.validate_components_names(components, components_map)
|
||||
|
||||
not_passed_components = set()
|
||||
|
||||
for component in components:
|
||||
try:
|
||||
jsonschema.validate(components_map[component]["service_content"],
|
||||
SERVICE_SCHEMA)
|
||||
except jsonschema.ValidationError as e:
|
||||
LOG.error("Validation of service definitions for component '%s' "
|
||||
"is not passed: '%s'", component, e.message)
|
||||
not_passed_components.add(component)
|
||||
|
||||
if not_passed_components:
|
||||
raise RuntimeError(
|
||||
"Validation of service definitions for {} of {} components is "
|
||||
"not passed.".format(len(not_passed_components), len(components))
|
||||
)
|
||||
else:
|
||||
LOG.info(
|
||||
"Validation of service definitions for %s components passed "
|
||||
"successfully!", len(components)
|
||||
)
|
||||
Reference in New Issue
Block a user