Merge pull request #191 from p1c2u/refactor/move-cast-out-of-schema-models

Move deserialize/cast out of schema models

Author: p1c2u

openapi_core/casting/schemas/casters.py

@@ -1,15 +1,20 @@
+from openapi_core.casting.schemas.exceptions import CastError
 from openapi_core.schema.schemas.types import NoValue
 
 
 class PrimitiveCaster(object):
 
-    def __init__(self, caster_callable):
+    def __init__(self, schema, caster_callable):
+        self.schema = schema
         self.caster_callable = caster_callable
 
     def __call__(self, value):
         if value in (None, NoValue):
             return value
-        return self.caster_callable(value)
+        try:
+            return self.caster_callable(value)
+        except (ValueError, TypeError):
+            raise CastError(value, self.schema.type.value)
 
 
 class DummyCaster(object):

openapi_core/casting/schemas/factories.py

@@ -8,22 +8,24 @@
 
 class SchemaCastersFactory(object):
 
-    DUMMY_CASTER = DummyCaster()
+    DUMMY_CASTERS = [
+        SchemaType.STRING, SchemaType.OBJECT, SchemaType.ANY,
+    ]
     PRIMITIVE_CASTERS = {
-        SchemaType.STRING: DUMMY_CASTER,
-        SchemaType.INTEGER: PrimitiveCaster(int),
-        SchemaType.NUMBER: PrimitiveCaster(float),
-        SchemaType.BOOLEAN: PrimitiveCaster(forcebool),
-        SchemaType.OBJECT: DUMMY_CASTER,
-        SchemaType.ANY: DUMMY_CASTER,
+        SchemaType.INTEGER: int,
+        SchemaType.NUMBER: float,
+        SchemaType.BOOLEAN: forcebool,
     }
     COMPLEX_CASTERS = {
         SchemaType.ARRAY: ArrayCaster,
     }
 
     def create(self, schema):
-        if schema.type in self.PRIMITIVE_CASTERS:
-            return self.PRIMITIVE_CASTERS[schema.type]
+        if schema.type in self.DUMMY_CASTERS:
+            return DummyCaster()
+        elif schema.type in self.PRIMITIVE_CASTERS:
+            caster_callable = self.PRIMITIVE_CASTERS[schema.type]
+            return PrimitiveCaster(schema, caster_callable)
         elif schema.type in self.COMPLEX_CASTERS:
             caster_class = self.COMPLEX_CASTERS[schema.type]
-            return caster_class(schema=schema, casters_factory=self)
+            return caster_class(schema, self)

openapi_core/deserializing/__init__.py

@@ -0,0 +1,14 @@
+import attr
+
+from openapi_core.exceptions import OpenAPIError
+
+
+@attr.s(hash=True)
+class DeserializeError(OpenAPIError):
+    """Deserialize operation error"""
+    value = attr.ib()
+    style = attr.ib()
+
+    def __str__(self):
+        return "Failed to deserialize value {value} with style {style}".format(
+            value=self.value, style=self.style)

openapi_core/deserializing/exceptions.py

@@ -0,0 +1,14 @@
+from openapi_core.deserializing.exceptions import DeserializeError
+
+
+class PrimitiveDeserializer(object):
+
+    def __init__(self, mimetype, deserializer_callable):
+        self.mimetype = mimetype
+        self.deserializer_callable = deserializer_callable
+
+    def __call__(self, value):
+        try:
+            return self.deserializer_callable(value)
+        except (ValueError, TypeError, AttributeError):
+            raise DeserializeError(value, self.mimetype)

openapi_core/deserializing/media_types/__init__.py

@@ -0,0 +1,18 @@
+from openapi_core.schema.media_types.util import json_loads
+
+from openapi_core.deserializing.media_types.deserializers import (
+    PrimitiveDeserializer,
+)
+
+
+class MediaTypeDeserializersFactory(object):
+
+    MEDIA_TYPE_DESERIALIZERS = {
+        'application/json': json_loads,
+    }
+
+    def create(self, media_type):
+        deserialize_callable = self.MEDIA_TYPE_DESERIALIZERS.get(
+            media_type.mimetype, lambda x: x)
+        return PrimitiveDeserializer(
+            media_type.mimetype, deserialize_callable)

openapi_core/deserializing/media_types/deserializers.py

@@ -0,0 +1,25 @@
+from openapi_core.deserializing.exceptions import DeserializeError
+from openapi_core.deserializing.parameters.exceptions import (
+    EmptyParameterValue,
+)
+from openapi_core.schema.parameters.enums import ParameterLocation
+
+
+class PrimitiveDeserializer(object):
+
+    def __init__(self, param, deserializer_callable):
+        self.param = param
+        self.deserializer_callable = deserializer_callable
+
+    def __call__(self, value):
+        if (self.param.location == ParameterLocation.QUERY and value == "" and
+                not self.param.allow_empty_value):
+            raise EmptyParameterValue(
+                value, self.param.style, self.param.name)
+
+        if not self.param.aslist or self.param.explode:
+            return value
+        try:
+            return self.deserializer_callable(value)
+        except (ValueError, TypeError, AttributeError):
+            raise DeserializeError(value, self.param.style)

openapi_core/deserializing/media_types/factories.py

@@ -0,0 +1,11 @@
+import attr
+
+from openapi_core.deserializing.exceptions import DeserializeError
+
+
+@attr.s(hash=True)
+class EmptyParameterValue(DeserializeError):
+    name = attr.ib()
+
+    def __str__(self):
+        return "Value of parameter cannot be empty: {0}".format(self.name)