Skip to content

Commit 6d98115

Browse files
committed
cleanup.
1 parent 7ef7313 commit 6d98115

File tree

2 files changed

+7
-10
lines changed

2 files changed

+7
-10
lines changed

gax-java/gax-grpc/src/main/java/com/google/api/gax/grpc/InstantiatingGrpcChannelProvider.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -476,11 +476,7 @@ ChannelCredentials createMtlsChannelCredentials() throws IOException, GeneralSec
476476
@VisibleForTesting
477477
boolean isGoogleS2AEnabled() {
478478
String S2AEnv = envProvider.getenv(S2A_ENV_ENABLE_USE_S2A);
479-
boolean isS2AEnv = Boolean.parseBoolean(S2AEnv);
480-
if (isS2AEnv) {
481-
return true;
482-
}
483-
return false;
479+
return Boolean.parseBoolean(S2AEnv);
484480
}
485481

486482
@VisibleForTesting
@@ -515,7 +511,6 @@ ChannelCredentials createMtlsToS2AChannelCredentials(
515511
.build();
516512
}
517513

518-
@VisibleForTesting
519514
ChannelCredentials createS2ASecuredChannelCredentials() {
520515
S2A s2aUtils = S2A.newBuilder().build();
521516
String plaintextAddress = s2aUtils.getPlaintextS2AAddress();

gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/InstantiatingGrpcChannelProviderTest.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -290,6 +290,7 @@ void testToBuilder() {
290290
.setProcessorCount(2)
291291
.setEndpoint("fake.endpoint:443")
292292
.setMtlsEndpoint("fake.endpoint:443")
293+
.setEndpointOverride("fake.endpoint.override:443")
293294
.setMaxInboundMessageSize(12345678)
294295
.setMaxInboundMetadataSize(4096)
295296
.setKeepAliveTimeDuration(keepaliveTime)
@@ -304,6 +305,7 @@ void testToBuilder() {
304305

305306
assertThat(builder.getEndpoint()).isEqualTo("fake.endpoint:443");
306307
assertThat(builder.getMtlsEndpoint()).isEqualTo("fake.endpoint:443");
308+
assertThat(builder.getEndpointOverride()).isEqualTo("fake.endpoint.override:443");
307309
assertThat(builder.getMaxInboundMessageSize()).isEqualTo(12345678);
308310
assertThat(builder.getMaxInboundMetadataSize()).isEqualTo(4096);
309311
assertThat(builder.getKeepAliveTimeDuration()).isEqualTo(keepaliveTime);
@@ -1047,18 +1049,18 @@ void isGoogleS2AEnabled_envVarNotSet_returnsFalse() {
10471049
Mockito.when(envProvider.getenv(InstantiatingGrpcChannelProvider.S2A_ENV_ENABLE_USE_S2A))
10481050
.thenReturn("false");
10491051
InstantiatingGrpcChannelProvider provider =
1050-
InstantiatingGrpcChannelProvider.newBuilder().build();
1052+
InstantiatingGrpcChannelProvider.newBuilder().setEnvProvider(envProvider).build();
10511053
Truth.assertThat(provider.isGoogleS2AEnabled()).isFalse();
10521054
}
10531055

10541056
@Test
1055-
void isGoogleS2AEnabled_envVarNotSet_returnsTrue() {
1057+
void isGoogleS2AEnabled_envVarSet_returnsTrue() {
10561058
EnvironmentProvider envProvider = Mockito.mock(EnvironmentProvider.class);
10571059
Mockito.when(envProvider.getenv(InstantiatingGrpcChannelProvider.S2A_ENV_ENABLE_USE_S2A))
10581060
.thenReturn("true");
10591061
InstantiatingGrpcChannelProvider provider =
1060-
InstantiatingGrpcChannelProvider.newBuilder().build();
1061-
Truth.assertThat(provider.isGoogleS2AEnabled()).isFalse();
1062+
InstantiatingGrpcChannelProvider.newBuilder().setEnvProvider(envProvider).build();
1063+
Truth.assertThat(provider.isGoogleS2AEnabled()).isTrue();
10621064
}
10631065

10641066
@Test

0 commit comments

Comments
 (0)