|
1 | 1 | from openapi_core.casting.schemas.exceptions import CastError |
2 | 2 |
|
3 | 3 |
|
4 | | -class PrimitiveCaster: |
| 4 | +class BaseSchemaCaster: |
5 | 5 |
|
6 | | - def __init__(self, schema, caster_callable): |
| 6 | + def __init__(self, schema): |
7 | 7 | self.schema = schema |
8 | | - self.caster_callable = caster_callable |
9 | 8 |
|
10 | 9 | def __call__(self, value): |
11 | 10 | if value is None: |
12 | 11 | return value |
| 12 | + |
| 13 | + return self.cast(value) |
| 14 | + |
| 15 | + def cast(self, value): |
| 16 | + raise NotImplementedError |
| 17 | + |
| 18 | + |
| 19 | +class CallableSchemaCaster(BaseSchemaCaster): |
| 20 | + |
| 21 | + def __init__(self, schema, caster_callable): |
| 22 | + super().__init__(schema) |
| 23 | + self.caster_callable = caster_callable |
| 24 | + |
| 25 | + def cast(self, value): |
13 | 26 | try: |
14 | 27 | return self.caster_callable(value) |
15 | 28 | except (ValueError, TypeError): |
16 | 29 | raise CastError(value, self.schema['type']) |
17 | 30 |
|
18 | 31 |
|
19 | | -class DummyCaster: |
| 32 | +class DummyCaster(BaseSchemaCaster): |
20 | 33 |
|
21 | | - def __call__(self, value): |
| 34 | + def cast(self, value): |
22 | 35 | return value |
23 | 36 |
|
24 | 37 |
|
25 | | -class ArrayCaster: |
| 38 | +class ComplexCaster(BaseSchemaCaster): |
26 | 39 |
|
27 | 40 | def __init__(self, schema, casters_factory): |
28 | | - self.schema = schema |
| 41 | + super().__init__(schema) |
29 | 42 | self.casters_factory = casters_factory |
30 | 43 |
|
| 44 | + |
| 45 | +class ArrayCaster(ComplexCaster): |
| 46 | + |
31 | 47 | @property |
32 | 48 | def items_caster(self): |
33 | 49 | return self.casters_factory.create(self.schema / 'items') |
34 | 50 |
|
35 | | - def __call__(self, value): |
36 | | - if value is None: |
37 | | - return value |
38 | | - return list(map(self.items_caster, value)) |
| 51 | + def cast(self, value): |
| 52 | + try: |
| 53 | + return list(map(self.items_caster, value)) |
| 54 | + except (ValueError, TypeError): |
| 55 | + raise CastError(value, self.schema['type']) |
0 commit comments