/* * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * https://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.maps.routing.v2; import com.google.api.gax.core.NoCredentialsProvider; import com.google.api.gax.grpc.GaxGrpcProperties; import com.google.api.gax.grpc.testing.LocalChannelProvider; import com.google.api.gax.grpc.testing.MockGrpcService; import com.google.api.gax.grpc.testing.MockServiceHelper; import com.google.api.gax.grpc.testing.MockStreamObserver; import com.google.api.gax.rpc.ApiClientHeaderProvider; import com.google.api.gax.rpc.InvalidArgumentException; import com.google.api.gax.rpc.ServerStreamingCallable; import com.google.api.gax.rpc.StatusCode; import com.google.protobuf.AbstractMessage; import com.google.protobuf.Duration; import com.google.protobuf.Timestamp; import com.google.rpc.Status; import io.grpc.StatusRuntimeException; import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.UUID; import java.util.concurrent.ExecutionException; import javax.annotation.Generated; import org.junit.After; import org.junit.AfterClass; import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; import org.junit.Test; @Generated("by gapic-generator-java") public class RoutesClientTest { private static MockRoutes mockRoutes; private static MockServiceHelper mockServiceHelper; private LocalChannelProvider channelProvider; private RoutesClient client; @BeforeClass public static void startStaticServer() { mockRoutes = new MockRoutes(); mockServiceHelper = new MockServiceHelper( UUID.randomUUID().toString(), Arrays.asList(mockRoutes)); mockServiceHelper.start(); } @AfterClass public static void stopServer() { mockServiceHelper.stop(); } @Before public void setUp() throws IOException { mockServiceHelper.reset(); channelProvider = mockServiceHelper.createChannelProvider(); RoutesSettings settings = RoutesSettings.newBuilder() .setTransportChannelProvider(channelProvider) .setCredentialsProvider(NoCredentialsProvider.create()) .build(); client = RoutesClient.create(settings); } @After public void tearDown() throws Exception { client.close(); } @Test public void computeRoutesTest() throws Exception { ComputeRoutesResponse expectedResponse = ComputeRoutesResponse.newBuilder() .addAllRoutes(new ArrayList()) .setFallbackInfo(FallbackInfo.newBuilder().build()) .setGeocodingResults(GeocodingResults.newBuilder().build()) .build(); mockRoutes.addResponse(expectedResponse); ComputeRoutesRequest request = ComputeRoutesRequest.newBuilder() .setOrigin(Waypoint.newBuilder().build()) .setDestination(Waypoint.newBuilder().build()) .addAllIntermediates(new ArrayList()) .setTravelMode(RouteTravelMode.forNumber(0)) .setRoutingPreference(RoutingPreference.forNumber(0)) .setPolylineQuality(PolylineQuality.forNumber(0)) .setPolylineEncoding(PolylineEncoding.forNumber(0)) .setDepartureTime(Timestamp.newBuilder().build()) .setComputeAlternativeRoutes(true) .setRouteModifiers(RouteModifiers.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setRegionCode("regionCode-1991004415") .setUnits(Units.forNumber(0)) .addAllRequestedReferenceRoutes(new ArrayList()) .addAllExtraComputations(new ArrayList()) .build(); ComputeRoutesResponse actualResponse = client.computeRoutes(request); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockRoutes.getRequests(); Assert.assertEquals(1, actualRequests.size()); ComputeRoutesRequest actualRequest = ((ComputeRoutesRequest) actualRequests.get(0)); Assert.assertEquals(request.getOrigin(), actualRequest.getOrigin()); Assert.assertEquals(request.getDestination(), actualRequest.getDestination()); Assert.assertEquals(request.getIntermediatesList(), actualRequest.getIntermediatesList()); Assert.assertEquals(request.getTravelMode(), actualRequest.getTravelMode()); Assert.assertEquals(request.getRoutingPreference(), actualRequest.getRoutingPreference()); Assert.assertEquals(request.getPolylineQuality(), actualRequest.getPolylineQuality()); Assert.assertEquals(request.getPolylineEncoding(), actualRequest.getPolylineEncoding()); Assert.assertEquals(request.getDepartureTime(), actualRequest.getDepartureTime()); Assert.assertEquals( request.getComputeAlternativeRoutes(), actualRequest.getComputeAlternativeRoutes()); Assert.assertEquals(request.getRouteModifiers(), actualRequest.getRouteModifiers()); Assert.assertEquals(request.getLanguageCode(), actualRequest.getLanguageCode()); Assert.assertEquals(request.getRegionCode(), actualRequest.getRegionCode()); Assert.assertEquals(request.getUnits(), actualRequest.getUnits()); Assert.assertEquals( request.getRequestedReferenceRoutesList(), actualRequest.getRequestedReferenceRoutesList()); Assert.assertEquals( request.getExtraComputationsList(), actualRequest.getExtraComputationsList()); Assert.assertTrue( channelProvider.isHeaderSent( ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), GaxGrpcProperties.getDefaultApiClientHeaderPattern())); } @Test public void computeRoutesExceptionTest() throws Exception { StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); mockRoutes.addException(exception); try { ComputeRoutesRequest request = ComputeRoutesRequest.newBuilder() .setOrigin(Waypoint.newBuilder().build()) .setDestination(Waypoint.newBuilder().build()) .addAllIntermediates(new ArrayList()) .setTravelMode(RouteTravelMode.forNumber(0)) .setRoutingPreference(RoutingPreference.forNumber(0)) .setPolylineQuality(PolylineQuality.forNumber(0)) .setPolylineEncoding(PolylineEncoding.forNumber(0)) .setDepartureTime(Timestamp.newBuilder().build()) .setComputeAlternativeRoutes(true) .setRouteModifiers(RouteModifiers.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setRegionCode("regionCode-1991004415") .setUnits(Units.forNumber(0)) .addAllRequestedReferenceRoutes(new ArrayList()) .addAllExtraComputations(new ArrayList()) .build(); client.computeRoutes(request); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void computeRouteMatrixTest() throws Exception { RouteMatrixElement expectedResponse = RouteMatrixElement.newBuilder() .setOriginIndex(2078721657) .setDestinationIndex(-1296954015) .setStatus(Status.newBuilder().build()) .setCondition(RouteMatrixElementCondition.forNumber(0)) .setDistanceMeters(1958857108) .setDuration(Duration.newBuilder().build()) .setStaticDuration(Duration.newBuilder().build()) .setTravelAdvisory(RouteTravelAdvisory.newBuilder().build()) .setFallbackInfo(FallbackInfo.newBuilder().build()) .build(); mockRoutes.addResponse(expectedResponse); ComputeRouteMatrixRequest request = ComputeRouteMatrixRequest.newBuilder() .addAllOrigins(new ArrayList()) .addAllDestinations(new ArrayList()) .setTravelMode(RouteTravelMode.forNumber(0)) .setRoutingPreference(RoutingPreference.forNumber(0)) .setDepartureTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setRegionCode("regionCode-1991004415") .addAllExtraComputations(new ArrayList()) .build(); MockStreamObserver responseObserver = new MockStreamObserver<>(); ServerStreamingCallable callable = client.computeRouteMatrixCallable(); callable.serverStreamingCall(request, responseObserver); List actualResponses = responseObserver.future().get(); Assert.assertEquals(1, actualResponses.size()); Assert.assertEquals(expectedResponse, actualResponses.get(0)); } @Test public void computeRouteMatrixExceptionTest() throws Exception { StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT); mockRoutes.addException(exception); ComputeRouteMatrixRequest request = ComputeRouteMatrixRequest.newBuilder() .addAllOrigins(new ArrayList()) .addAllDestinations(new ArrayList()) .setTravelMode(RouteTravelMode.forNumber(0)) .setRoutingPreference(RoutingPreference.forNumber(0)) .setDepartureTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setRegionCode("regionCode-1991004415") .addAllExtraComputations(new ArrayList()) .build(); MockStreamObserver responseObserver = new MockStreamObserver<>(); ServerStreamingCallable callable = client.computeRouteMatrixCallable(); callable.serverStreamingCall(request, responseObserver); try { List actualResponses = responseObserver.future().get(); Assert.fail("No exception thrown"); } catch (ExecutionException e) { Assert.assertTrue(e.getCause() instanceof InvalidArgumentException); InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause()); Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode()); } } }