codegen: Fix EventSteam code generation bug (#1638)

* codegen: Fix EventSteam deserializer generation bug * codegen: Namespace event stream writer and reader implementations * Regnerated Clients
aws · Mar 23, 2022 · cd1c8a3 · cd1c8a3
1 parent 5399c50
commit cd1c8a3
Show file tree

Hide file tree

Showing 8 changed files with 500 additions and 496 deletions.
diff --git a/...s-go-codegen/src/main/java/software/amazon/smithy/aws/go/codegen/AwsEventStreamUtils.java b/...s-go-codegen/src/main/java/software/amazon/smithy/aws/go/codegen/AwsEventStreamUtils.java
diff --git a/...codegen/src/main/java/software/amazon/smithy/aws/go/codegen/JsonRpcProtocolGenerator.java b/...codegen/src/main/java/software/amazon/smithy/aws/go/codegen/JsonRpcProtocolGenerator.java
@@ -203,7 +203,8 @@ public void generateEventStreamComponents(GenerationContext context) {
 
     @Override
     protected void writeOperationSerializerMiddlewareEventStreamSetup(GenerationContext context, EventStreamInfo info) {
-        AwsEventStreamUtils.writeOperationSerializerMiddlewareEventStreamSetup(context, info);
+        AwsEventStreamUtils.writeOperationSerializerMiddlewareEventStreamSetup(context, info,
+                "httpBindingEncoder");
     }
 
     @Override
@@ -315,7 +316,7 @@ protected void generateEventStreamDeserializers(
                                     payloadTarget, ctx.getService(), getProtocolName());
                             var ctxWriter = ctx.getWriter().get();
                             ctxWriter.openBlock("if err := $L(&$L, shape); err != nil {", "}", functionName, operand,
-                                    () -> handleDecodeError(ctxWriter))
+                                            () -> handleDecodeError(ctxWriter))
                                     .write("return nil");
                         });
 
@@ -348,7 +349,7 @@ protected void generateEventStreamDeserializers(
                         AwsProtocolUtils.initializeJsonEventMessageDeserializer(ctx, "nil,");
                         var ctxWriter = ctx.getWriter().get();
                         ctxWriter.openBlock("if err := $L(&$L, shape); err != nil {", "}", functionName, operand,
-                                () -> handleDecodeError(ctxWriter, "nil,"))
+                                        () -> handleDecodeError(ctxWriter, "nil,"))
                                 .write("return v, nil");
                     });
             var initialMessageMembers = streamInfo.getInitialMessageMembers()

diff --git a/...odegen/src/main/java/software/amazon/smithy/aws/go/codegen/RestJsonProtocolGenerator.java b/...odegen/src/main/java/software/amazon/smithy/aws/go/codegen/RestJsonProtocolGenerator.java
@@ -519,7 +519,7 @@ public void generateEventStreamComponents(GenerationContext context) {
 
     @Override
     protected void writeOperationSerializerMiddlewareEventStreamSetup(GenerationContext context, EventStreamInfo info) {
-        AwsEventStreamUtils.writeOperationSerializerMiddlewareEventStreamSetup(context, info);
+        AwsEventStreamUtils.writeOperationSerializerMiddlewareEventStreamSetup(context, info, "restEncoder");
     }
 
     @Override

diff --git a/...codegen/src/main/java/software/amazon/smithy/aws/go/codegen/RestXmlProtocolGenerator.java b/...codegen/src/main/java/software/amazon/smithy/aws/go/codegen/RestXmlProtocolGenerator.java
@@ -475,7 +475,7 @@ public void generateEventStreamComponents(GenerationContext context) {
 
     @Override
     protected void writeOperationSerializerMiddlewareEventStreamSetup(GenerationContext context, EventStreamInfo info) {
-        AwsEventStreamUtils.writeOperationSerializerMiddlewareEventStreamSetup(context, info);
+        AwsEventStreamUtils.writeOperationSerializerMiddlewareEventStreamSetup(context, info, "restEncoder");
     }
 
     @Override

diff --git a/service/kinesis/eventstream.go b/service/kinesis/eventstream.go
diff --git a/service/lexruntimev2/eventstream.go b/service/lexruntimev2/eventstream.go