Add gzip sync test

Author: S-Saranya1

test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/BusinessMetricsUserAgentTest.java

@@ -48,6 +48,8 @@
 import software.amazon.awssdk.regions.Region;
 import software.amazon.awssdk.services.protocolrestjson.ProtocolRestJsonAsyncClient;
 import software.amazon.awssdk.services.protocolrestjson.ProtocolRestJsonAsyncClientBuilder;
+import software.amazon.awssdk.services.protocolrestjson.ProtocolRestJsonClient;
+import software.amazon.awssdk.services.protocolrestjson.ProtocolRestJsonClientBuilder;
 import software.amazon.awssdk.services.protocolrestjson.internal.ServiceVersionInfo;
 import software.amazon.awssdk.services.protocolrestjson.model.PaginatedOperationWithResultKeyResponse;
 import software.amazon.awssdk.services.protocolrestjson.paginators.PaginatedOperationWithResultKeyPublisher;
@@ -162,7 +164,7 @@ void when_paginatedOperationIsCalled_correctMetricIsAdded() throws Exception {
     }
 
     @Test
-    void when_compressedOperationIsCalled_metricIsRecordedAndAddedToUserAgentString() throws Exception {
+    void when_asyncCompressedOperationIsCalled_metricIsRecordedAndAddedToUserAgentString() throws Exception {
         ProtocolRestJsonAsyncClientBuilder clientBuilder = asyncClientBuilderForProtocolRestJson();
 
         assertThatThrownBy(() -> clientBuilder.build().putOperationWithRequestCompression(r -> r.body(SdkBytes.fromUtf8String(
@@ -176,6 +178,21 @@ void when_compressedOperationIsCalled_metricIsRecordedAndAddedToUserAgentString(
         assertThat(userAgent).matches(METRIC_SEARCH_PATTERN.apply(BusinessMetricFeatureId.GZIP_REQUEST_COMPRESSION.value()));
     }
 
+    @Test
+    void when_syncCompressedOperationIsCalled_metricIsRecordedAndAddedToUserAgentString() throws Exception {
+        ProtocolRestJsonClientBuilder clientBuilder = syncClientBuilderForProtocolRestJson();
+
+        assertThatThrownBy(() -> clientBuilder.build().putOperationWithRequestCompression(r -> r.body(SdkBytes.fromUtf8String(
+            "whoo")).overrideConfiguration(o -> o.compressionConfiguration(c -> c.minimumCompressionThresholdInBytes(1)))))
+            .hasMessageContaining("stop");
+
+        String userAgent = assertAndGetUserAgentString();
+        BusinessMetricCollection attribute = interceptor.executionAttributes().getAttribute(SdkInternalExecutionAttribute.BUSINESS_METRICS);
+        assertThat(attribute).isNotNull();
+        assertThat(attribute.recordedMetrics()).contains(BusinessMetricFeatureId.GZIP_REQUEST_COMPRESSION.value());
+        assertThat(userAgent).matches(METRIC_SEARCH_PATTERN.apply(BusinessMetricFeatureId.GZIP_REQUEST_COMPRESSION.value()));
+    }
+
     private String assertAndGetUserAgentString() {
         Map<String, List<String>> headers = interceptor.context.httpRequest().headers();
         assertThat(headers).containsKey(USER_AGENT_HEADER_NAME);
@@ -196,6 +213,13 @@ private ProtocolRestJsonAsyncClientBuilder asyncClientBuilderForProtocolRestJson
                                           .overrideConfiguration(c -> c.addExecutionInterceptor(interceptor));
     }
 
+    private ProtocolRestJsonClientBuilder syncClientBuilderForProtocolRestJson() {
+        return ProtocolRestJsonClient.builder()
+                                     .region(Region.US_WEST_2)
+                                     .credentialsProvider(CREDENTIALS_PROVIDER)
+                                     .overrideConfiguration(c -> c.addExecutionInterceptor(interceptor));
+    }
+
     public static class CapturingInterceptor implements ExecutionInterceptor {
         private Context.BeforeTransmission context;
         private ExecutionAttributes executionAttributes;