Add HTTP ShapeDeserializer

Author: JordonPhillips

packages/smithy-http/src/smithy_http/deserializers.py

@@ -0,0 +1,186 @@
+from collections.abc import Callable
+from typing import TYPE_CHECKING
+from decimal import Decimal
+import datetime
+
+from smithy_core.deserializers import ShapeDeserializer, SpecificShapeDeserializer
+from smithy_core.codecs import Codec
+from smithy_core.schemas import Schema
+from smithy_core.traits import (
+    HTTPTrait,
+    HTTPHeaderTrait,
+    HTTPPrefixHeadersTrait,
+    HTTPPayloadTrait,
+    HTTPResponseCodeTrait,
+    TimestampFormatTrait,
+)
+from smithy_core.utils import strict_parse_bool, strict_parse_float, ensure_utc
+from smithy_core.types import TimestampFormat
+from smithy_core.shapes import ShapeType
+
+from .aio.interfaces import HTTPResponse
+
+from .interfaces import Field, Fields
+
+if TYPE_CHECKING:
+    from smithy_core.interfaces import StreamingBlob as _Stream
+    from smithy_core.aio.interfaces import StreamingBlob as _AsyncStream
+    from smithy_core.interfaces import BytesReader as _BytesReader
+
+
+__all__ = ["HTTPResponseDeserializer"]
+
+
+class HTTPResponseDeserializer(SpecificShapeDeserializer):
+    # Note: caller will have to read the body if it's async and not streaming
+    def __init__(
+        self,
+        payload_codec: Codec,
+        http_trait: HTTPTrait,
+        response: HTTPResponse,
+        body: _Stream | None = None,
+    ) -> None:
+        self._payload_codec = payload_codec
+        self._response = response
+        self._http_trait = http_trait
+        if isinstance(body, bytearray):
+            body = bytes(body)
+        self._body = body
+
+    def read_struct(
+        self, schema: Schema, consumer: Callable[[Schema, ShapeDeserializer], None]
+    ) -> None:
+        status = self._response.status
+        if status != self._http_trait.code and status >= 300:
+            # TODO: handle exceptions
+            raise Exception()
+
+        ## add fields contains, fields get by prefix
+
+        has_body = False
+        payload_member: Schema | None = None
+
+        for member in schema.members.values():
+            if (trait := member.get_trait(HTTPHeaderTrait)) is not None:
+                if (header := self._response.fields.entries.get(trait.key)) is not None:
+                    if schema.shape_type is ShapeType.LIST:
+                        consumer(member, HTTPHeaderListDeserializer(header))
+                    else:
+                        consumer(member, HTTPHeaderDeserializer(header.as_string()))
+            elif (trait := member.get_trait(HTTPPrefixHeadersTrait)) is not None:
+                consumer(member, HTTPHeaderMapDeserializer(self._response.fields))
+            elif HTTPPayloadTrait in member:
+                has_body = True
+                payload_member = member
+            elif HTTPResponseCodeTrait in member:
+                consumer(member, HTTPResponseCodeDeserializer(self._response.status))
+            else:
+                has_body = True
+
+        if has_body and self._body is not None:
+            if payload_member is not None:
+                consumer(payload_member, RawPayloadDeserializer(self._body))
+            else:
+                payload_deserializer = self._payload_codec.create_deserializer(
+                    self._body
+                )
+                payload_deserializer.read_struct(schema, consumer)
+
+
+class HTTPHeaderDeserializer(SpecificShapeDeserializer):
+    def __init__(self, value: str) -> None:
+        self._value = value
+
+    def read_boolean(self, schema: Schema) -> bool:
+        return strict_parse_bool(self._value)
+
+    def read_byte(self, schema: Schema) -> int:
+        return self.read_integer(schema)
+
+    def read_short(self, schema: Schema) -> int:
+        return self.read_integer(schema)
+
+    def read_integer(self, schema: Schema) -> int:
+        return int(self._value)
+
+    def read_long(self, schema: Schema) -> int:
+        return self.read_integer(schema)
+
+    def read_big_integer(self, schema: Schema) -> int:
+        return self.read_integer(schema)
+
+    def read_float(self, schema: Schema) -> float:
+        return strict_parse_float(self._value)
+
+    def read_double(self, schema: Schema) -> float:
+        return self.read_float(schema)
+
+    def read_big_decimal(self, schema: Schema) -> Decimal:
+        return Decimal(self._value).canonical()
+
+    def read_string(self, schema: Schema) -> str:
+        return self._value
+
+    def read_timestamp(self, schema: Schema) -> datetime.datetime:
+        format = TimestampFormat.HTTP_DATE
+        if (trait := schema.get_trait(TimestampFormatTrait)) is not None:
+            format = trait.format
+        return ensure_utc(format.deserialize(self._value))
+
+
+class HTTPHeaderListDeserializer(SpecificShapeDeserializer):
+    def __init__(self, field: Field) -> None:
+        self._field = field
+
+    def read_list(
+        self, schema: Schema, consumer: Callable[["ShapeDeserializer"], None]
+    ) -> None:
+        for value in self._field.values:
+            consumer(HTTPHeaderDeserializer(value))
+
+
+class HTTPHeaderMapDeserializer(SpecificShapeDeserializer):
+    def __init__(self, fields: Fields) -> None:
+        self._fields = fields
+
+    def read_map(
+        self,
+        schema: Schema,
+        consumer: Callable[[str, "ShapeDeserializer"], None],
+    ) -> None:
+        prefix = schema.expect_trait(HTTPPrefixHeadersTrait).prefix
+        for field in self._fields:
+            if field.name.startswith(prefix):
+                consumer(field.name, HTTPHeaderDeserializer(field.as_string()))
+
+
+class HTTPResponseCodeDeserializer(SpecificShapeDeserializer):
+    def __init__(self, response_code: int) -> None:
+        self._response_code = response_code
+
+    def read_byte(self, schema: Schema) -> int:
+        return self._response_code
+
+    def read_short(self, schema: Schema) -> int:
+        return self._response_code
+
+    def read_integer(self, schema: Schema) -> int:
+        return self._response_code
+
+
+class RawPayloadDeserializer(SpecificShapeDeserializer):
+    def __init__(self, payload: bytes | _BytesReader) -> None:
+        self._payload = payload
+
+    def read_string(self, schema: Schema) -> str:
+        if not isinstance(self._payload, bytes):
+            self._payload = self._payload.read()
+        return self._payload.decode("utf-8")
+
+    def read_blob(self, schema: Schema) -> bytes:
+        if not isinstance(self._payload, bytes):
+            self._payload = self._payload.read()
+        return self._payload
+
+    def read_data_stream(self, schema: Schema) -> _AsyncStream:
+        return self._payload