hack it all together

Author: nateprewitt

codegen/core/src/main/java/software/amazon/smithy/python/codegen/ClientGenerator.java

@@ -488,6 +488,8 @@ async def _handle_attempt(
 
         writer.pushState(new SignRequestSection());
         if (context.applicationProtocol().isHttpProtocol() && supportsAuth) {
+            writer.addStdlibImport("binascii", "hexlify");
+            writer.addStdlibImport("re");
             writer.write("""
                             # Step 7i: sign the request
                             if auth_option and signer:
@@ -496,8 +498,6 @@ async def _handle_attempt(
                                     "Signer properties: %s",
                                     auth_option.signer_properties
                                 )
-                                context._identity = identity
-                                context._signer_properties = auth_option.signer_properties
                                 context._transport_request = await signer.sign(
                                     http_request=context.transport_request,
                                     identity=identity,

codegen/core/src/main/java/software/amazon/smithy/python/codegen/integrations/RestJsonProtocolGenerator.java

@@ -409,12 +409,13 @@ public void wrapEventStream(GenerationContext context, PythonWriter writer) {
                 codec = JSONCodec(default_timestamp_format=TimestampFormat.EPOCH_SECONDS)
                 if has_input_stream:
                     # TODO - Move this out of the RestJSON generator
-                    authorization_header = context.transport_request.fields.get("Authorization", "")
-                    signature = re.split("Signature=", authorization_header)[-1]
+                    signer_properties = context.properties.get("signer_properties")  # type: ignore
+                    identity = context.properties.get("identity")  # type: ignore
+                    signature = context.properties.get("signature")  # type: ignore
                     signer = AsyncEventSigner(
-                        signer_properties=context._signer_properties
-                        identity=context._identity,
-                        prior_signature=hexlify(signature)
+                        signing_properties=signer_properties,  # type: ignore
+                        identity=identity,  # type: ignore
+                        initial_signature=signature_bytes,  # type: ignore
                     )
 
                     if event_deserializer is not None:

packages/aws-sdk-signers/src/aws_sdk_signers/signers.py

@@ -780,13 +780,12 @@ async def _compute_payload_hash(
 
 
 class AsyncEventSigner:
-    
     def __init__(
         self,
         *,
         signing_properties: SigV4SigningProperties,
         identity: AWSCredentialIdentity,
-        intial_signature: bytes,
+        initial_signature: bytes,
     ):
         self._signing_properties = signing_properties
         self._identity = identity

packages/smithy-http/src/smithy_http/aio/crt.py

@@ -292,11 +292,14 @@ async def _marshal_request(
         """Create :py:class:`awscrt.http.HttpRequest` from
         :py:class:`smithy_http.aio.HTTPRequest`"""
         headers_list = []
-        if "Host" not in request.fields:
+        if "host" not in request.fields:
             request.fields.set_field(
-                Field(name="Host", values=[request.destination.host])
+                Field(name="host", values=[request.destination.host])
             )
 
+        if "accept" not in request.fields:
+            request.fields.set_field(Field(name="accept", values=["*/*"]))
+
         for fld in request.fields.entries.values():
             # TODO: Use literal values for "header"/"trailer".
             if fld.kind.value != FieldPosition.HEADER.value: