codegen: Add support for REST-XML Union responses

Adds support for deserializing REST-XML union resources Fixes aws#939 Related to smithy-lang/smithy#678
jasdel · Dec 22, 2020 · 94b742b · 94b742b
1 parent 15e052d
commit 94b742b
Show file tree

Hide file tree

Showing 2 changed files with 60 additions and 6 deletions.
diff --git a/...go-codegen/src/main/java/software/amazon/smithy/aws/go/codegen/JsonShapeDeserVisitor.java b/...go-codegen/src/main/java/software/amazon/smithy/aws/go/codegen/JsonShapeDeserVisitor.java
@@ -244,8 +244,6 @@ protected void deserializeUnion(GenerationContext context, UnionShape shape) {
                             symbol.getNamespace()
                     ).build();
                     writer.write("uv = &$T{Tag: key}", unknownMemberSymbol);
-                    writer.writeDocs("TODO: FIX ME");
-                    writer.write("_ = value");
                     writer.write("break loop");
                 });
             });

diff --git a/...-go-codegen/src/main/java/software/amazon/smithy/aws/go/codegen/XmlShapeDeserVisitor.java b/...-go-codegen/src/main/java/software/amazon/smithy/aws/go/codegen/XmlShapeDeserVisitor.java
@@ -12,6 +12,8 @@
 import software.amazon.smithy.go.codegen.CodegenUtils;
 import software.amazon.smithy.go.codegen.GoWriter;
 import software.amazon.smithy.go.codegen.SmithyGoDependency;
+import software.amazon.smithy.go.codegen.SymbolUtils;
+import software.amazon.smithy.go.codegen.UnionGenerator;
 import software.amazon.smithy.go.codegen.integration.DocumentShapeDeserVisitor;
 import software.amazon.smithy.go.codegen.integration.ProtocolGenerator;
 import software.amazon.smithy.go.codegen.integration.ProtocolGenerator.GenerationContext;
@@ -403,10 +405,64 @@ protected void deserializeDocument(GenerationContext context, DocumentShape shap
     @Override
     protected void deserializeUnion(GenerationContext context, UnionShape shape) {
         GoWriter writer = context.getWriter();
-        // TODO: implement union deserialization
-        // The tricky part is going to be accumulating bytes for unknown members.
-        LOGGER.warning("Union type is currently unsupported for XML deserialization.");
-        context.getWriter().writeDocs("TODO: implement union serialization.");
+        SymbolProvider symbolProvider = context.getSymbolProvider();
+        Symbol symbol = symbolProvider.toSymbol(shape);
+        Model model = context.getModel();
+
+        writer.write("var uv $P", symbol);
+
+        // Iterate through the decoder. The member visitor will handle popping xml tokens
+        // enclosed within a xml start and end element.
+        // TODO [xmlUnion] need to consume closing token
+        writer.openBlock("loop: for {", "}", () -> {
+            writer.write("t, done, err := decoder.Token()");
+            writer.write("if err != nil { return err }");
+            writer.write("if done { break }");
+
+            // Create a new decoder for each member
+            writer.write("originalDecoder := decoder");
+            writer.write("decoder = smithyxml.WrapNodeDecoder(originalDecoder.Decoder, t)");
+            writer.insertTrailingNewline();
+
+            writer.openBlock("switch {", "}", () -> {
+                Set<MemberShape> members = new TreeSet<>(shape.members());
+                for (MemberShape member : members) {
+                    // check if member is not a document binding or has a xmlAttribute trait
+                    if (!memberFilter.test(member) || member.hasTrait(XmlAttributeTrait.ID)) {
+                        continue;
+                    }
+                    Symbol targetSymbol = symbolProvider.toSymbol(member);
+                    Symbol memberSymbol = SymbolUtils.createValueSymbolBuilder(
+                            symbolProvider.toMemberName(member),
+                            symbol.getNamespace()
+                    ).build();
+
+                    writer.addUseImports(SmithyGoDependency.STRINGS);
+
+                    String serializedMemberName = getSerializedMemberName(member);
+                    writer.openBlock("case strings.EqualFold($S, t.Name.Local):", "", serializedMemberName, () -> {
+                        writer.write("var mv $P", targetSymbol);
+                        model.expectShape(member.getTarget()).accept(getMemberDeserVisitor(member, "mv", false));
+                        writer.write("uv = &$T{Value: mv}", memberSymbol);
+                        writer.write("break loop");
+                    });
+                }
+
+                writer.openBlock("default:", "", () -> {
+                    // This is the function to take a value and convert it to the union type.
+                    Symbol unknownMemberSymbol = SymbolUtils.createValueSymbolBuilder(
+                            UnionGenerator.UNKNOWN_MEMBER_NAME,
+                            symbol.getNamespace()
+                    ).build();
+                    writer.write("uv = &$T{Tag: t.Name.Local}", unknownMemberSymbol);
+                    writer.write("break loop");
+                });
+            });
+            // re-assign the  original decoder
+            writer.write("decoder = originalDecoder");
+        });
+
+        writer.write("*v = uv");
         writer.write("return nil");
     }
 }