Add tracking of RequestBody/ResponseTransfromer implementations used in UserAgent (#6171)

* Add useragent metadata execution attributes and apply them to useragent.
Add basic tracking of requestbody/responeTransformer implementations to UA metadata.

* Add delegate getter to the Notifying transformer + handle empty class names w/ unknown

* Add name methods to body/response transfromer interfaces + add implementations

* Checkstyle fixes + changelog

* Update docs + AdditionalMetadata use builder + change all name methods to just name.

* Use enum + single letter short form for RequestBody/ContentStreamProvider

* Migrate to single character name + enum for remaining types

* Fix test failures

* Fix checkstyle, start adding tests

* Add more tests

* Try and fix arch test failure

* Fix arch test + more test coverage

* Improve test coverage

* Improve regex for classWithInnerClassesToPattern

* Fix minor pr issues

* Fix unknown string to use enum

* Fix changelog

Author: alextwoods

.changes/next-release/feature-AWSSDKforJavav2-cc2fe6f.json

@@ -0,0 +1,6 @@
+{
+    "type": "feature",
+    "category": "AWS SDK for Java v2",
+    "contributor": "",
+    "description": "Add tracking of RequestBody/ResponseTransfromer implementations used in UserAgent."
+}

codegen/src/main/java/software/amazon/awssdk/codegen/poet/client/specs/JsonProtocolSpec.java

@@ -235,6 +235,10 @@ public CodeBlock executionHandler(OperationModel opModel) {
 
         codeBlock.add(RequestCompressionTrait.create(opModel, model));
 
+        if (opModel.hasStreamingOutput()) {
+            codeBlock.add(".withResponseTransformer(responseTransformer)");
+        }
+
         if (opModel.hasStreamingInput()) {
             codeBlock.add(".withRequestBody(requestBody)")
                      .add(".withMarshaller($L)", syncStreamingMarshaller(model, opModel, marshaller));
@@ -310,6 +314,10 @@ public CodeBlock asyncExecutionHandler(IntermediateModel intermediateModel, Oper
             builder.add(NoneAuthTypeRequestTrait.create(opModel));
         }
 
+        if (opModel.hasStreamingOutput()) {
+            builder.add(".withAsyncResponseTransformer(asyncResponseTransformer)");
+        }
+
         builder.add(RequestCompressionTrait.create(opModel, model))
                .add(".withInput($L)$L)",
                     opModel.getInput().getVariableName(), asyncResponseTransformerVariable(isStreaming, isRestJson, opModel))

codegen/src/main/java/software/amazon/awssdk/codegen/poet/client/specs/QueryProtocolSpec.java

@@ -128,7 +128,9 @@ public CodeBlock executionHandler(OperationModel opModel) {
         }
 
         codeBlock.add(RequestCompressionTrait.create(opModel, intermediateModel));
-
+        if (opModel.hasStreamingOutput()) {
+            codeBlock.add(".withResponseTransformer(responseTransformer)");
+        }
         if (opModel.hasStreamingInput()) {
             return codeBlock.add(".withRequestBody(requestBody)")
                             .add(".withMarshaller($L));", syncStreamingMarshaller(intermediateModel, opModel, marshaller))
@@ -170,6 +172,10 @@ public CodeBlock asyncExecutionHandler(IntermediateModel intermediateModel, Oper
 
         builder.add(RequestCompressionTrait.create(opModel, intermediateModel));
 
+        if (opModel.hasStreamingOutput()) {
+            builder.add(".withAsyncResponseTransformer(asyncResponseTransformer)");
+        }
+
         builder.add(hostPrefixExpression(opModel) + asyncRequestBody + ".withInput($L)$L);",
                     opModel.getInput().getVariableName(),
                     opModel.hasStreamingOutput() ? ", asyncResponseTransformer" : "");