notifications-api/app/schema_validation/__init__.py

import json
from collections import OrderedDict

from jsonschema import Draft4Validator, ValidationError


def validate(json_to_validate, schema):
    validator = Draft4Validator(schema)
    errors = list(validator.iter_errors(json_to_validate))
    if errors.__len__() > 0:
        raise ValidationError(build_error_message(errors, schema))
    return json_to_validate


def build_error_message(errors, schema):
    fields = []
    for e in errors:
        field = "'{}' {}".format(e.path[0], e.schema.get('validationMessage')) if e.schema.get(
            'validationMessage') else e.message
        s = field.split("'")
        field = OrderedDict({"error": "ValidationError", "message": "{}{}".format(s[1], s[2])})
        fields.append(field)
    message = {
        "status_code": 400,
        "errors": fields
    }

    return json.dumps(message)