/* * 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.cloud.contactcenterinsights.v1; import static com.google.cloud.contactcenterinsights.v1.ContactCenterInsightsClient.ListAnalysesPagedResponse; import static com.google.cloud.contactcenterinsights.v1.ContactCenterInsightsClient.ListConversationsPagedResponse; import static com.google.cloud.contactcenterinsights.v1.ContactCenterInsightsClient.ListPhraseMatchersPagedResponse; import static com.google.cloud.contactcenterinsights.v1.ContactCenterInsightsClient.ListViewsPagedResponse; import com.google.api.gax.core.NoCredentialsProvider; import com.google.api.gax.httpjson.GaxHttpJsonProperties; import com.google.api.gax.httpjson.testing.MockHttpService; import com.google.api.gax.rpc.ApiClientHeaderProvider; import com.google.api.gax.rpc.ApiException; import com.google.api.gax.rpc.ApiExceptionFactory; import com.google.api.gax.rpc.InvalidArgumentException; import com.google.api.gax.rpc.StatusCode; import com.google.api.gax.rpc.testing.FakeStatusCode; import com.google.cloud.contactcenterinsights.v1.stub.HttpJsonContactCenterInsightsStub; import com.google.common.collect.Lists; import com.google.longrunning.Operation; import com.google.protobuf.Any; import com.google.protobuf.Duration; import com.google.protobuf.Empty; import com.google.protobuf.FieldMask; import com.google.protobuf.Timestamp; import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.List; 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 ContactCenterInsightsClientHttpJsonTest { private static MockHttpService mockService; private static ContactCenterInsightsClient client; @BeforeClass public static void startStaticServer() throws IOException { mockService = new MockHttpService( HttpJsonContactCenterInsightsStub.getMethodDescriptors(), ContactCenterInsightsSettings.getDefaultEndpoint()); ContactCenterInsightsSettings settings = ContactCenterInsightsSettings.newHttpJsonBuilder() .setTransportChannelProvider( ContactCenterInsightsSettings.defaultHttpJsonTransportProviderBuilder() .setHttpTransport(mockService) .build()) .setCredentialsProvider(NoCredentialsProvider.create()) .build(); client = ContactCenterInsightsClient.create(settings); } @AfterClass public static void stopServer() { client.close(); } @Before public void setUp() {} @After public void tearDown() throws Exception { mockService.reset(); } @Test public void createConversationTest() throws Exception { Conversation expectedResponse = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); Conversation conversation = Conversation.newBuilder().build(); String conversationId = "conversationId-1676095234"; Conversation actualResponse = client.createConversation(parent, conversation, conversationId); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createConversationExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); Conversation conversation = Conversation.newBuilder().build(); String conversationId = "conversationId-1676095234"; client.createConversation(parent, conversation, conversationId); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void createConversationTest2() throws Exception { Conversation expectedResponse = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; Conversation conversation = Conversation.newBuilder().build(); String conversationId = "conversationId-1676095234"; Conversation actualResponse = client.createConversation(parent, conversation, conversationId); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createConversationExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; Conversation conversation = Conversation.newBuilder().build(); String conversationId = "conversationId-1676095234"; client.createConversation(parent, conversation, conversationId); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void uploadConversationTest() throws Exception { Conversation expectedResponse = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); Operation resultOperation = Operation.newBuilder() .setName("uploadConversationTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); UploadConversationRequest request = UploadConversationRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setConversation(Conversation.newBuilder().build()) .setConversationId("conversationId-1676095234") .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); Conversation actualResponse = client.uploadConversationAsync(request).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void uploadConversationExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { UploadConversationRequest request = UploadConversationRequest.newBuilder() .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString()) .setConversation(Conversation.newBuilder().build()) .setConversationId("conversationId-1676095234") .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); client.uploadConversationAsync(request).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void updateConversationTest() throws Exception { Conversation expectedResponse = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); mockService.addResponse(expectedResponse); Conversation conversation = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); FieldMask updateMask = FieldMask.newBuilder().build(); Conversation actualResponse = client.updateConversation(conversation, updateMask); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void updateConversationExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { Conversation conversation = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); FieldMask updateMask = FieldMask.newBuilder().build(); client.updateConversation(conversation, updateMask); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getConversationTest() throws Exception { Conversation expectedResponse = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); mockService.addResponse(expectedResponse); ConversationName name = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); Conversation actualResponse = client.getConversation(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getConversationExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { ConversationName name = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); client.getConversation(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getConversationTest2() throws Exception { Conversation expectedResponse = Conversation.newBuilder() .setName(ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]").toString()) .setDataSource(ConversationDataSource.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setStartTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setAgentId("agentId-1060987136") .putAllLabels(new HashMap()) .setTranscript(Conversation.Transcript.newBuilder().build()) .setDuration(Duration.newBuilder().build()) .setTurnCount(428155597) .setLatestAnalysis(Analysis.newBuilder().build()) .setLatestSummary(ConversationSummarizationSuggestionData.newBuilder().build()) .addAllRuntimeAnnotations(new ArrayList()) .putAllDialogflowIntents(new HashMap()) .setObfuscatedUserId("obfuscatedUserId971552298") .build(); mockService.addResponse(expectedResponse); String name = "projects/project-3338/locations/location-3338/conversations/conversation-3338"; Conversation actualResponse = client.getConversation(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getConversationExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-3338/locations/location-3338/conversations/conversation-3338"; client.getConversation(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listConversationsTest() throws Exception { Conversation responsesElement = Conversation.newBuilder().build(); ListConversationsResponse expectedResponse = ListConversationsResponse.newBuilder() .setNextPageToken("") .addAllConversations(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); ListConversationsPagedResponse pagedListResponse = client.listConversations(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getConversationsList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listConversationsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); client.listConversations(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listConversationsTest2() throws Exception { Conversation responsesElement = Conversation.newBuilder().build(); ListConversationsResponse expectedResponse = ListConversationsResponse.newBuilder() .setNextPageToken("") .addAllConversations(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; ListConversationsPagedResponse pagedListResponse = client.listConversations(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getConversationsList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listConversationsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; client.listConversations(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteConversationTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); ConversationName name = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); client.deleteConversation(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteConversationExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { ConversationName name = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); client.deleteConversation(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteConversationTest2() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); String name = "projects/project-3338/locations/location-3338/conversations/conversation-3338"; client.deleteConversation(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteConversationExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-3338/locations/location-3338/conversations/conversation-3338"; client.deleteConversation(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void createAnalysisTest() throws Exception { Analysis expectedResponse = Analysis.newBuilder() .setName( AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]") .toString()) .setRequestTime(Timestamp.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setAnalysisResult(AnalysisResult.newBuilder().build()) .setAnnotatorSelector(AnnotatorSelector.newBuilder().build()) .build(); Operation resultOperation = Operation.newBuilder() .setName("createAnalysisTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); ConversationName parent = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); Analysis analysis = Analysis.newBuilder().build(); Analysis actualResponse = client.createAnalysisAsync(parent, analysis).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createAnalysisExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { ConversationName parent = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); Analysis analysis = Analysis.newBuilder().build(); client.createAnalysisAsync(parent, analysis).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void createAnalysisTest2() throws Exception { Analysis expectedResponse = Analysis.newBuilder() .setName( AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]") .toString()) .setRequestTime(Timestamp.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setAnalysisResult(AnalysisResult.newBuilder().build()) .setAnnotatorSelector(AnnotatorSelector.newBuilder().build()) .build(); Operation resultOperation = Operation.newBuilder() .setName("createAnalysisTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String parent = "projects/project-8053/locations/location-8053/conversations/conversation-8053"; Analysis analysis = Analysis.newBuilder().build(); Analysis actualResponse = client.createAnalysisAsync(parent, analysis).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createAnalysisExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-8053/locations/location-8053/conversations/conversation-8053"; Analysis analysis = Analysis.newBuilder().build(); client.createAnalysisAsync(parent, analysis).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void getAnalysisTest() throws Exception { Analysis expectedResponse = Analysis.newBuilder() .setName( AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]") .toString()) .setRequestTime(Timestamp.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setAnalysisResult(AnalysisResult.newBuilder().build()) .setAnnotatorSelector(AnnotatorSelector.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); AnalysisName name = AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]"); Analysis actualResponse = client.getAnalysis(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getAnalysisExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { AnalysisName name = AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]"); client.getAnalysis(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getAnalysisTest2() throws Exception { Analysis expectedResponse = Analysis.newBuilder() .setName( AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]") .toString()) .setRequestTime(Timestamp.newBuilder().build()) .setCreateTime(Timestamp.newBuilder().build()) .setAnalysisResult(AnalysisResult.newBuilder().build()) .setAnnotatorSelector(AnnotatorSelector.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String name = "projects/project-3940/locations/location-3940/conversations/conversation-3940/analyses/analyse-3940"; Analysis actualResponse = client.getAnalysis(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getAnalysisExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-3940/locations/location-3940/conversations/conversation-3940/analyses/analyse-3940"; client.getAnalysis(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listAnalysesTest() throws Exception { Analysis responsesElement = Analysis.newBuilder().build(); ListAnalysesResponse expectedResponse = ListAnalysesResponse.newBuilder() .setNextPageToken("") .addAllAnalyses(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); ConversationName parent = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); ListAnalysesPagedResponse pagedListResponse = client.listAnalyses(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getAnalysesList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listAnalysesExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { ConversationName parent = ConversationName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]"); client.listAnalyses(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listAnalysesTest2() throws Exception { Analysis responsesElement = Analysis.newBuilder().build(); ListAnalysesResponse expectedResponse = ListAnalysesResponse.newBuilder() .setNextPageToken("") .addAllAnalyses(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-8053/locations/location-8053/conversations/conversation-8053"; ListAnalysesPagedResponse pagedListResponse = client.listAnalyses(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getAnalysesList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listAnalysesExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-8053/locations/location-8053/conversations/conversation-8053"; client.listAnalyses(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteAnalysisTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); AnalysisName name = AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]"); client.deleteAnalysis(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteAnalysisExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { AnalysisName name = AnalysisName.of("[PROJECT]", "[LOCATION]", "[CONVERSATION]", "[ANALYSIS]"); client.deleteAnalysis(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteAnalysisTest2() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); String name = "projects/project-3940/locations/location-3940/conversations/conversation-3940/analyses/analyse-3940"; client.deleteAnalysis(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteAnalysisExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-3940/locations/location-3940/conversations/conversation-3940/analyses/analyse-3940"; client.deleteAnalysis(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void bulkAnalyzeConversationsTest() throws Exception { BulkAnalyzeConversationsResponse expectedResponse = BulkAnalyzeConversationsResponse.newBuilder() .setSuccessfulAnalysisCount(1153322545) .setFailedAnalysisCount(1044285998) .build(); Operation resultOperation = Operation.newBuilder() .setName("bulkAnalyzeConversationsTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); String filter = "filter-1274492040"; float analysisPercentage = 1609757661; BulkAnalyzeConversationsResponse actualResponse = client.bulkAnalyzeConversationsAsync(parent, filter, analysisPercentage).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void bulkAnalyzeConversationsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); String filter = "filter-1274492040"; float analysisPercentage = 1609757661; client.bulkAnalyzeConversationsAsync(parent, filter, analysisPercentage).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void bulkAnalyzeConversationsTest2() throws Exception { BulkAnalyzeConversationsResponse expectedResponse = BulkAnalyzeConversationsResponse.newBuilder() .setSuccessfulAnalysisCount(1153322545) .setFailedAnalysisCount(1044285998) .build(); Operation resultOperation = Operation.newBuilder() .setName("bulkAnalyzeConversationsTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String parent = "projects/project-5833/locations/location-5833"; String filter = "filter-1274492040"; float analysisPercentage = 1609757661; BulkAnalyzeConversationsResponse actualResponse = client.bulkAnalyzeConversationsAsync(parent, filter, analysisPercentage).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void bulkAnalyzeConversationsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; String filter = "filter-1274492040"; float analysisPercentage = 1609757661; client.bulkAnalyzeConversationsAsync(parent, filter, analysisPercentage).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void ingestConversationsTest() throws Exception { IngestConversationsResponse expectedResponse = IngestConversationsResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("ingestConversationsTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); IngestConversationsResponse actualResponse = client.ingestConversationsAsync(parent).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void ingestConversationsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); client.ingestConversationsAsync(parent).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void ingestConversationsTest2() throws Exception { IngestConversationsResponse expectedResponse = IngestConversationsResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("ingestConversationsTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String parent = "projects/project-5833/locations/location-5833"; IngestConversationsResponse actualResponse = client.ingestConversationsAsync(parent).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void ingestConversationsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; client.ingestConversationsAsync(parent).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void exportInsightsDataTest() throws Exception { ExportInsightsDataResponse expectedResponse = ExportInsightsDataResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("exportInsightsDataTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); ExportInsightsDataResponse actualResponse = client.exportInsightsDataAsync(parent).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void exportInsightsDataExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); client.exportInsightsDataAsync(parent).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void exportInsightsDataTest2() throws Exception { ExportInsightsDataResponse expectedResponse = ExportInsightsDataResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("exportInsightsDataTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String parent = "projects/project-5833/locations/location-5833"; ExportInsightsDataResponse actualResponse = client.exportInsightsDataAsync(parent).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void exportInsightsDataExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; client.exportInsightsDataAsync(parent).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void createIssueModelTest() throws Exception { IssueModel expectedResponse = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); Operation resultOperation = Operation.newBuilder() .setName("createIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); IssueModel issueModel = IssueModel.newBuilder().build(); IssueModel actualResponse = client.createIssueModelAsync(parent, issueModel).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createIssueModelExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); IssueModel issueModel = IssueModel.newBuilder().build(); client.createIssueModelAsync(parent, issueModel).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void createIssueModelTest2() throws Exception { IssueModel expectedResponse = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); Operation resultOperation = Operation.newBuilder() .setName("createIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String parent = "projects/project-5833/locations/location-5833"; IssueModel issueModel = IssueModel.newBuilder().build(); IssueModel actualResponse = client.createIssueModelAsync(parent, issueModel).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createIssueModelExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; IssueModel issueModel = IssueModel.newBuilder().build(); client.createIssueModelAsync(parent, issueModel).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void updateIssueModelTest() throws Exception { IssueModel expectedResponse = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); IssueModel issueModel = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); IssueModel actualResponse = client.updateIssueModel(issueModel, updateMask); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void updateIssueModelExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModel issueModel = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); client.updateIssueModel(issueModel, updateMask); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getIssueModelTest() throws Exception { IssueModel expectedResponse = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); IssueModel actualResponse = client.getIssueModel(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getIssueModelExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.getIssueModel(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getIssueModelTest2() throws Exception { IssueModel expectedResponse = IssueModel.newBuilder() .setName(IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setIssueCount(1779144233) .setInputDataConfig(IssueModel.InputDataConfig.newBuilder().build()) .setTrainingStats(IssueModelLabelStats.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; IssueModel actualResponse = client.getIssueModel(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getIssueModelExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; client.getIssueModel(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listIssueModelsTest() throws Exception { ListIssueModelsResponse expectedResponse = ListIssueModelsResponse.newBuilder().addAllIssueModels(new ArrayList()).build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); ListIssueModelsResponse actualResponse = client.listIssueModels(parent); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listIssueModelsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); client.listIssueModels(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listIssueModelsTest2() throws Exception { ListIssueModelsResponse expectedResponse = ListIssueModelsResponse.newBuilder().addAllIssueModels(new ArrayList()).build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; ListIssueModelsResponse actualResponse = client.listIssueModels(parent); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listIssueModelsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; client.listIssueModels(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteIssueModelTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("deleteIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.deleteIssueModelAsync(name).get(); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteIssueModelExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.deleteIssueModelAsync(name).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void deleteIssueModelTest2() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("deleteIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; client.deleteIssueModelAsync(name).get(); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteIssueModelExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; client.deleteIssueModelAsync(name).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void deployIssueModelTest() throws Exception { DeployIssueModelResponse expectedResponse = DeployIssueModelResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("deployIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); DeployIssueModelResponse actualResponse = client.deployIssueModelAsync(name).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deployIssueModelExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.deployIssueModelAsync(name).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void deployIssueModelTest2() throws Exception { DeployIssueModelResponse expectedResponse = DeployIssueModelResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("deployIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; DeployIssueModelResponse actualResponse = client.deployIssueModelAsync(name).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deployIssueModelExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; client.deployIssueModelAsync(name).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void undeployIssueModelTest() throws Exception { UndeployIssueModelResponse expectedResponse = UndeployIssueModelResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("undeployIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); UndeployIssueModelResponse actualResponse = client.undeployIssueModelAsync(name).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void undeployIssueModelExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModelName name = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.undeployIssueModelAsync(name).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void undeployIssueModelTest2() throws Exception { UndeployIssueModelResponse expectedResponse = UndeployIssueModelResponse.newBuilder().build(); Operation resultOperation = Operation.newBuilder() .setName("undeployIssueModelTest") .setDone(true) .setResponse(Any.pack(expectedResponse)) .build(); mockService.addResponse(resultOperation); String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; UndeployIssueModelResponse actualResponse = client.undeployIssueModelAsync(name).get(); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void undeployIssueModelExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-9415/locations/location-9415/issueModels/issueModel-9415"; client.undeployIssueModelAsync(name).get(); Assert.fail("No exception raised"); } catch (ExecutionException e) { } } @Test public void getIssueTest() throws Exception { Issue expectedResponse = Issue.newBuilder() .setName(IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .addAllSampleUtterances(new ArrayList()) .build(); mockService.addResponse(expectedResponse); IssueName name = IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]"); Issue actualResponse = client.getIssue(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getIssueExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueName name = IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]"); client.getIssue(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getIssueTest2() throws Exception { Issue expectedResponse = Issue.newBuilder() .setName(IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .addAllSampleUtterances(new ArrayList()) .build(); mockService.addResponse(expectedResponse); String name = "projects/project-9867/locations/location-9867/issueModels/issueModel-9867/issues/issue-9867"; Issue actualResponse = client.getIssue(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getIssueExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-9867/locations/location-9867/issueModels/issueModel-9867/issues/issue-9867"; client.getIssue(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listIssuesTest() throws Exception { ListIssuesResponse expectedResponse = ListIssuesResponse.newBuilder().addAllIssues(new ArrayList()).build(); mockService.addResponse(expectedResponse); IssueModelName parent = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); ListIssuesResponse actualResponse = client.listIssues(parent); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listIssuesExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModelName parent = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.listIssues(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listIssuesTest2() throws Exception { ListIssuesResponse expectedResponse = ListIssuesResponse.newBuilder().addAllIssues(new ArrayList()).build(); mockService.addResponse(expectedResponse); String parent = "projects/project-7032/locations/location-7032/issueModels/issueModel-7032"; ListIssuesResponse actualResponse = client.listIssues(parent); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listIssuesExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-7032/locations/location-7032/issueModels/issueModel-7032"; client.listIssues(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void updateIssueTest() throws Exception { Issue expectedResponse = Issue.newBuilder() .setName(IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .addAllSampleUtterances(new ArrayList()) .build(); mockService.addResponse(expectedResponse); Issue issue = Issue.newBuilder() .setName(IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .addAllSampleUtterances(new ArrayList()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); Issue actualResponse = client.updateIssue(issue, updateMask); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void updateIssueExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { Issue issue = Issue.newBuilder() .setName( IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .addAllSampleUtterances(new ArrayList()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); client.updateIssue(issue, updateMask); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteIssueTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); IssueName name = IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]"); client.deleteIssue(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteIssueExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueName name = IssueName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]", "[ISSUE]"); client.deleteIssue(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteIssueTest2() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); String name = "projects/project-9867/locations/location-9867/issueModels/issueModel-9867/issues/issue-9867"; client.deleteIssue(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteIssueExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-9867/locations/location-9867/issueModels/issueModel-9867/issues/issue-9867"; client.deleteIssue(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void calculateIssueModelStatsTest() throws Exception { CalculateIssueModelStatsResponse expectedResponse = CalculateIssueModelStatsResponse.newBuilder() .setCurrentStats(IssueModelLabelStats.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); IssueModelName issueModel = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); CalculateIssueModelStatsResponse actualResponse = client.calculateIssueModelStats(issueModel); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void calculateIssueModelStatsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { IssueModelName issueModel = IssueModelName.of("[PROJECT]", "[LOCATION]", "[ISSUE_MODEL]"); client.calculateIssueModelStats(issueModel); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void calculateIssueModelStatsTest2() throws Exception { CalculateIssueModelStatsResponse expectedResponse = CalculateIssueModelStatsResponse.newBuilder() .setCurrentStats(IssueModelLabelStats.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String issueModel = "projects/project-2174/locations/location-2174/issueModels/issueModel-2174"; CalculateIssueModelStatsResponse actualResponse = client.calculateIssueModelStats(issueModel); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void calculateIssueModelStatsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String issueModel = "projects/project-2174/locations/location-2174/issueModels/issueModel-2174"; client.calculateIssueModelStats(issueModel); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void createPhraseMatcherTest() throws Exception { PhraseMatcher expectedResponse = PhraseMatcher.newBuilder() .setName(PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); PhraseMatcher phraseMatcher = PhraseMatcher.newBuilder().build(); PhraseMatcher actualResponse = client.createPhraseMatcher(parent, phraseMatcher); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createPhraseMatcherExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); PhraseMatcher phraseMatcher = PhraseMatcher.newBuilder().build(); client.createPhraseMatcher(parent, phraseMatcher); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void createPhraseMatcherTest2() throws Exception { PhraseMatcher expectedResponse = PhraseMatcher.newBuilder() .setName(PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; PhraseMatcher phraseMatcher = PhraseMatcher.newBuilder().build(); PhraseMatcher actualResponse = client.createPhraseMatcher(parent, phraseMatcher); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createPhraseMatcherExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; PhraseMatcher phraseMatcher = PhraseMatcher.newBuilder().build(); client.createPhraseMatcher(parent, phraseMatcher); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getPhraseMatcherTest() throws Exception { PhraseMatcher expectedResponse = PhraseMatcher.newBuilder() .setName(PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); PhraseMatcherName name = PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]"); PhraseMatcher actualResponse = client.getPhraseMatcher(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getPhraseMatcherExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { PhraseMatcherName name = PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]"); client.getPhraseMatcher(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getPhraseMatcherTest2() throws Exception { PhraseMatcher expectedResponse = PhraseMatcher.newBuilder() .setName(PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String name = "projects/project-8010/locations/location-8010/phraseMatchers/phraseMatcher-8010"; PhraseMatcher actualResponse = client.getPhraseMatcher(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getPhraseMatcherExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-8010/locations/location-8010/phraseMatchers/phraseMatcher-8010"; client.getPhraseMatcher(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listPhraseMatchersTest() throws Exception { PhraseMatcher responsesElement = PhraseMatcher.newBuilder().build(); ListPhraseMatchersResponse expectedResponse = ListPhraseMatchersResponse.newBuilder() .setNextPageToken("") .addAllPhraseMatchers(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); ListPhraseMatchersPagedResponse pagedListResponse = client.listPhraseMatchers(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getPhraseMatchersList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listPhraseMatchersExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); client.listPhraseMatchers(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listPhraseMatchersTest2() throws Exception { PhraseMatcher responsesElement = PhraseMatcher.newBuilder().build(); ListPhraseMatchersResponse expectedResponse = ListPhraseMatchersResponse.newBuilder() .setNextPageToken("") .addAllPhraseMatchers(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; ListPhraseMatchersPagedResponse pagedListResponse = client.listPhraseMatchers(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getPhraseMatchersList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listPhraseMatchersExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; client.listPhraseMatchers(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deletePhraseMatcherTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); PhraseMatcherName name = PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]"); client.deletePhraseMatcher(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deletePhraseMatcherExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { PhraseMatcherName name = PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]"); client.deletePhraseMatcher(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deletePhraseMatcherTest2() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); String name = "projects/project-8010/locations/location-8010/phraseMatchers/phraseMatcher-8010"; client.deletePhraseMatcher(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deletePhraseMatcherExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-8010/locations/location-8010/phraseMatchers/phraseMatcher-8010"; client.deletePhraseMatcher(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void updatePhraseMatcherTest() throws Exception { PhraseMatcher expectedResponse = PhraseMatcher.newBuilder() .setName(PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); PhraseMatcher phraseMatcher = PhraseMatcher.newBuilder() .setName(PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); PhraseMatcher actualResponse = client.updatePhraseMatcher(phraseMatcher, updateMask); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void updatePhraseMatcherExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { PhraseMatcher phraseMatcher = PhraseMatcher.newBuilder() .setName( PhraseMatcherName.of("[PROJECT]", "[LOCATION]", "[PHRASE_MATCHER]").toString()) .setRevisionId("revisionId-1507445162") .setVersionTag("versionTag-670508126") .setRevisionCreateTime(Timestamp.newBuilder().build()) .setDisplayName("displayName1714148973") .setActive(true) .addAllPhraseMatchRuleGroups(new ArrayList()) .setActivationUpdateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); client.updatePhraseMatcher(phraseMatcher, updateMask); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void calculateStatsTest() throws Exception { CalculateStatsResponse expectedResponse = CalculateStatsResponse.newBuilder() .setAverageDuration(Duration.newBuilder().build()) .setAverageTurnCount(-1693477329) .setConversationCount(1994187347) .putAllSmartHighlighterMatches(new HashMap()) .putAllCustomHighlighterMatches(new HashMap()) .putAllIssueMatches(new HashMap()) .putAllIssueMatchesStats(new HashMap()) .setConversationCountTimeSeries(CalculateStatsResponse.TimeSeries.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); LocationName location = LocationName.of("[PROJECT]", "[LOCATION]"); CalculateStatsResponse actualResponse = client.calculateStats(location); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void calculateStatsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName location = LocationName.of("[PROJECT]", "[LOCATION]"); client.calculateStats(location); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void calculateStatsTest2() throws Exception { CalculateStatsResponse expectedResponse = CalculateStatsResponse.newBuilder() .setAverageDuration(Duration.newBuilder().build()) .setAverageTurnCount(-1693477329) .setConversationCount(1994187347) .putAllSmartHighlighterMatches(new HashMap()) .putAllCustomHighlighterMatches(new HashMap()) .putAllIssueMatches(new HashMap()) .putAllIssueMatchesStats(new HashMap()) .setConversationCountTimeSeries(CalculateStatsResponse.TimeSeries.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String location = "projects/project-7132/locations/location-7132"; CalculateStatsResponse actualResponse = client.calculateStats(location); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void calculateStatsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String location = "projects/project-7132/locations/location-7132"; client.calculateStats(location); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getSettingsTest() throws Exception { Settings expectedResponse = Settings.newBuilder() .setName(SettingsName.of("[PROJECT]", "[LOCATION]").toString()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setConversationTtl(Duration.newBuilder().build()) .putAllPubsubNotificationSettings(new HashMap()) .setAnalysisConfig(Settings.AnalysisConfig.newBuilder().build()) .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); SettingsName name = SettingsName.of("[PROJECT]", "[LOCATION]"); Settings actualResponse = client.getSettings(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getSettingsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { SettingsName name = SettingsName.of("[PROJECT]", "[LOCATION]"); client.getSettings(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getSettingsTest2() throws Exception { Settings expectedResponse = Settings.newBuilder() .setName(SettingsName.of("[PROJECT]", "[LOCATION]").toString()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setConversationTtl(Duration.newBuilder().build()) .putAllPubsubNotificationSettings(new HashMap()) .setAnalysisConfig(Settings.AnalysisConfig.newBuilder().build()) .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); String name = "projects/project-7640/locations/location-7640/settings"; Settings actualResponse = client.getSettings(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getSettingsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-7640/locations/location-7640/settings"; client.getSettings(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void updateSettingsTest() throws Exception { Settings expectedResponse = Settings.newBuilder() .setName(SettingsName.of("[PROJECT]", "[LOCATION]").toString()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setConversationTtl(Duration.newBuilder().build()) .putAllPubsubNotificationSettings(new HashMap()) .setAnalysisConfig(Settings.AnalysisConfig.newBuilder().build()) .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); mockService.addResponse(expectedResponse); Settings settings = Settings.newBuilder() .setName(SettingsName.of("[PROJECT]", "[LOCATION]").toString()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setConversationTtl(Duration.newBuilder().build()) .putAllPubsubNotificationSettings(new HashMap()) .setAnalysisConfig(Settings.AnalysisConfig.newBuilder().build()) .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); Settings actualResponse = client.updateSettings(settings, updateMask); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void updateSettingsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { Settings settings = Settings.newBuilder() .setName(SettingsName.of("[PROJECT]", "[LOCATION]").toString()) .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setLanguageCode("languageCode-2092349083") .setConversationTtl(Duration.newBuilder().build()) .putAllPubsubNotificationSettings(new HashMap()) .setAnalysisConfig(Settings.AnalysisConfig.newBuilder().build()) .setRedactionConfig(RedactionConfig.newBuilder().build()) .build(); FieldMask updateMask = FieldMask.newBuilder().build(); client.updateSettings(settings, updateMask); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void createViewTest() throws Exception { View expectedResponse = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); View view = View.newBuilder().build(); View actualResponse = client.createView(parent, view); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createViewExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); View view = View.newBuilder().build(); client.createView(parent, view); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void createViewTest2() throws Exception { View expectedResponse = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; View view = View.newBuilder().build(); View actualResponse = client.createView(parent, view); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void createViewExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; View view = View.newBuilder().build(); client.createView(parent, view); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getViewTest() throws Exception { View expectedResponse = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); mockService.addResponse(expectedResponse); ViewName name = ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]"); View actualResponse = client.getView(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getViewExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { ViewName name = ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]"); client.getView(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void getViewTest2() throws Exception { View expectedResponse = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); mockService.addResponse(expectedResponse); String name = "projects/project-2284/locations/location-2284/views/view-2284"; View actualResponse = client.getView(name); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void getViewExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-2284/locations/location-2284/views/view-2284"; client.getView(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listViewsTest() throws Exception { View responsesElement = View.newBuilder().build(); ListViewsResponse expectedResponse = ListViewsResponse.newBuilder() .setNextPageToken("") .addAllViews(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); ListViewsPagedResponse pagedListResponse = client.listViews(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getViewsList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listViewsExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]"); client.listViews(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void listViewsTest2() throws Exception { View responsesElement = View.newBuilder().build(); ListViewsResponse expectedResponse = ListViewsResponse.newBuilder() .setNextPageToken("") .addAllViews(Arrays.asList(responsesElement)) .build(); mockService.addResponse(expectedResponse); String parent = "projects/project-5833/locations/location-5833"; ListViewsPagedResponse pagedListResponse = client.listViews(parent); List resources = Lists.newArrayList(pagedListResponse.iterateAll()); Assert.assertEquals(1, resources.size()); Assert.assertEquals(expectedResponse.getViewsList().get(0), resources.get(0)); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void listViewsExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String parent = "projects/project-5833/locations/location-5833"; client.listViews(parent); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void updateViewTest() throws Exception { View expectedResponse = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); mockService.addResponse(expectedResponse); View view = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); FieldMask updateMask = FieldMask.newBuilder().build(); View actualResponse = client.updateView(view, updateMask); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void updateViewExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { View view = View.newBuilder() .setName(ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]").toString()) .setDisplayName("displayName1714148973") .setCreateTime(Timestamp.newBuilder().build()) .setUpdateTime(Timestamp.newBuilder().build()) .setValue("value111972721") .build(); FieldMask updateMask = FieldMask.newBuilder().build(); client.updateView(view, updateMask); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteViewTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); ViewName name = ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]"); client.deleteView(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteViewExceptionTest() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { ViewName name = ViewName.of("[PROJECT]", "[LOCATION]", "[VIEW]"); client.deleteView(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } @Test public void deleteViewTest2() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockService.addResponse(expectedResponse); String name = "projects/project-2284/locations/location-2284/views/view-2284"; client.deleteView(name); List actualRequests = mockService.getRequestPaths(); Assert.assertEquals(1, actualRequests.size()); String apiClientHeaderKey = mockService .getRequestHeaders() .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey()) .iterator() .next(); Assert.assertTrue( GaxHttpJsonProperties.getDefaultApiClientHeaderPattern() .matcher(apiClientHeaderKey) .matches()); } @Test public void deleteViewExceptionTest2() throws Exception { ApiException exception = ApiExceptionFactory.createException( new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false); mockService.addException(exception); try { String name = "projects/project-2284/locations/location-2284/views/view-2284"; client.deleteView(name); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception. } } }