Skip to content

Commit b6a61b4

Browse files
committed
Cleanups from PR + expand tests
1 parent e24191e commit b6a61b4

File tree

3 files changed

+35
-5
lines changed

3 files changed

+35
-5
lines changed

codegen/src/test/java/software/amazon/awssdk/codegen/poet/rules/EndpointRulesClientTestSpecTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public void endpointProviderTestClassWithStringArray() {
3838
@Test
3939
public void endpointProviderTestClassWithUnknownProperties() {
4040
ClassSpec endpointProviderSpec = new EndpointProviderTestSpec(ClientTestModels.queryServiceModelsWithUnknownEndpointProperties());
41-
assertThat(endpointProviderSpec, generatesTo("endpoint-rules-unknownproperty-test-class.java"));
41+
assertThat(endpointProviderSpec, generatesTo("endpoint-rules-unknown-property-test-class.java"));
4242
}
4343

4444
@Test

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

Lines changed: 34 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525

2626
import java.net.URI;
2727
import java.util.Arrays;
28+
import java.util.Collections;
2829
import java.util.HashSet;
2930
import java.util.List;
3031
import java.util.Map;
@@ -59,16 +60,47 @@ public class EndpointMetricValuesTest {
5960
void setup() {
6061
capturingInterceptor = new CapturingInterceptor();
6162
mockEndpointProvider = mock(RestJsonEndpointProvidersEndpointProvider.class);
63+
}
64+
65+
@Test
66+
void endpointMetricValuesAreAddedToUserAgent() {
67+
List<String> metricValues = Arrays.asList("O", "K");
6268
when(mockEndpointProvider.resolveEndpoint(any(RestJsonEndpointProvidersEndpointParams.class)))
6369
.thenReturn(CompletableFuture.completedFuture(
6470
Endpoint.builder()
6571
.url(URI.create("https://my-service.com"))
66-
.putAttribute(AwsEndpointAttribute.METRIC_VALUES, Arrays.asList("O", "K"))
72+
.putAttribute(AwsEndpointAttribute.METRIC_VALUES, metricValues)
6773
.build()));
74+
75+
RestJsonEndpointProvidersClient client =
76+
RestJsonEndpointProvidersClient.builder()
77+
.endpointProvider(mockEndpointProvider)
78+
.region(Region.US_WEST_2)
79+
.credentialsProvider(CREDENTIALS_PROVIDER)
80+
.overrideConfiguration(c -> c.addExecutionInterceptor(capturingInterceptor))
81+
.build();
82+
83+
assertThatThrownBy(() -> client.operationWithNoInputOrOutput(r -> {
84+
})).hasMessageContaining("short-circuit");
85+
86+
String userAgent = assertAndGetUserAgentString();
87+
Matcher businessMetricMatcher = Pattern.compile("m/([^\\s]+)").matcher(userAgent);
88+
assertTrue(businessMetricMatcher.find());
89+
assertNotNull(businessMetricMatcher.group(1));
90+
Set<String> metrics = new HashSet<>(Arrays.asList((businessMetricMatcher.group(1).split(","))));
91+
assertTrue(metrics.containsAll(metricValues));
6892
}
6993

7094
@Test
71-
void endpointMetricValuesAreAddedToUserAgent() {
95+
void endpointMetricValuesDoesNotFailOnEmptyList() {
96+
List<String> metricValues = Collections.emptyList();
97+
when(mockEndpointProvider.resolveEndpoint(any(RestJsonEndpointProvidersEndpointParams.class)))
98+
.thenReturn(CompletableFuture.completedFuture(
99+
Endpoint.builder()
100+
.url(URI.create("https://my-service.com"))
101+
.putAttribute(AwsEndpointAttribute.METRIC_VALUES, metricValues)
102+
.build()));
103+
72104
RestJsonEndpointProvidersClient client =
73105
RestJsonEndpointProvidersClient.builder()
74106
.endpointProvider(mockEndpointProvider)
@@ -84,8 +116,6 @@ void endpointMetricValuesAreAddedToUserAgent() {
84116
Matcher businessMetricMatcher = Pattern.compile("m/([^\\s]+)").matcher(userAgent);
85117
assertTrue(businessMetricMatcher.find());
86118
assertNotNull(businessMetricMatcher.group(1));
87-
Set<String> metrics = new HashSet<>(Arrays.asList((businessMetricMatcher.group(1).split(","))));
88-
assertTrue(metrics.containsAll(Arrays.asList("O", "K")));
89119
}
90120

91121
private String assertAndGetUserAgentString() {

0 commit comments

Comments
 (0)