From a078590a3e9f31157b31318188da60f772e30f52 Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Mon, 10 Feb 2020 09:07:08 -0800 Subject: [PATCH] docs(regen): update sample code to set total timeout, add API client header test --- .../v1beta1/DataCatalogSettings.java | 8 +- ...PolicyTagManagerSerializationSettings.java | 8 +- .../v1beta1/PolicyTagManagerSettings.java | 8 +- .../v1beta1/stub/DataCatalogStubSettings.java | 8 +- ...cyTagManagerSerializationStubSettings.java | 8 +- .../stub/PolicyTagManagerStubSettings.java | 8 +- .../v1beta1/DataCatalogClientTest.java | 58 +- .../v1beta1/PolicyTagManagerClientTest.java | 557 ++++++++++++++++++ ...licyTagManagerSerializationClientTest.java | 83 +++ synth.metadata | 12 +- 10 files changed, 735 insertions(+), 23 deletions(-) diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java index 11d774bb..a2f17fb5 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java @@ -61,8 +61,12 @@ * * DataCatalogSettings.Builder dataCatalogSettingsBuilder = * DataCatalogSettings.newBuilder(); - * dataCatalogSettingsBuilder.createEntryGroupSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * dataCatalogSettingsBuilder + * .createEntryGroupSettings() + * .setRetrySettings( + * dataCatalogSettingsBuilder.createEntryGroupSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * DataCatalogSettings dataCatalogSettings = dataCatalogSettingsBuilder.build(); * * diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java index d4a8b1c1..aa19c823 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java @@ -51,8 +51,12 @@ * * PolicyTagManagerSerializationSettings.Builder policyTagManagerSerializationSettingsBuilder = * PolicyTagManagerSerializationSettings.newBuilder(); - * policyTagManagerSerializationSettingsBuilder.importTaxonomiesSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * policyTagManagerSerializationSettingsBuilder + * .importTaxonomiesSettings() + * .setRetrySettings( + * policyTagManagerSerializationSettingsBuilder.importTaxonomiesSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * PolicyTagManagerSerializationSettings policyTagManagerSerializationSettings = policyTagManagerSerializationSettingsBuilder.build(); * * diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java index b7a7fa62..7c68ebaf 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java @@ -57,8 +57,12 @@ * * PolicyTagManagerSettings.Builder policyTagManagerSettingsBuilder = * PolicyTagManagerSettings.newBuilder(); - * policyTagManagerSettingsBuilder.createTaxonomySettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * policyTagManagerSettingsBuilder + * .createTaxonomySettings() + * .setRetrySettings( + * policyTagManagerSettingsBuilder.createTaxonomySettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * PolicyTagManagerSettings policyTagManagerSettings = policyTagManagerSettingsBuilder.build(); * * diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java index 59781c04..c0ff684c 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java @@ -110,8 +110,12 @@ * * DataCatalogStubSettings.Builder dataCatalogSettingsBuilder = * DataCatalogStubSettings.newBuilder(); - * dataCatalogSettingsBuilder.createEntryGroupSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * dataCatalogSettingsBuilder + * .createEntryGroupSettings() + * .setRetrySettings( + * dataCatalogSettingsBuilder.createEntryGroupSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * DataCatalogStubSettings dataCatalogSettings = dataCatalogSettingsBuilder.build(); * * diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java index cde94570..9dd92857 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java @@ -64,8 +64,12 @@ * * PolicyTagManagerSerializationStubSettings.Builder policyTagManagerSerializationSettingsBuilder = * PolicyTagManagerSerializationStubSettings.newBuilder(); - * policyTagManagerSerializationSettingsBuilder.importTaxonomiesSettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * policyTagManagerSerializationSettingsBuilder + * .importTaxonomiesSettings() + * .setRetrySettings( + * policyTagManagerSerializationSettingsBuilder.importTaxonomiesSettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * PolicyTagManagerSerializationStubSettings policyTagManagerSerializationSettings = policyTagManagerSerializationSettingsBuilder.build(); * * diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java index 6b90681a..327d196f 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java @@ -80,8 +80,12 @@ * * PolicyTagManagerStubSettings.Builder policyTagManagerSettingsBuilder = * PolicyTagManagerStubSettings.newBuilder(); - * policyTagManagerSettingsBuilder.createTaxonomySettings().getRetrySettings().toBuilder() - * .setTotalTimeout(Duration.ofSeconds(30)); + * policyTagManagerSettingsBuilder + * .createTaxonomySettings() + * .setRetrySettings( + * policyTagManagerSettingsBuilder.createTaxonomySettings().getRetrySettings().toBuilder() + * .setTotalTimeout(Duration.ofSeconds(30)) + * .build()); * PolicyTagManagerStubSettings policyTagManagerSettings = policyTagManagerSettingsBuilder.build(); * * diff --git a/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClientTest.java b/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClientTest.java index 072247d6..6639b9c3 100644 --- a/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClientTest.java +++ b/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClientTest.java @@ -497,6 +497,57 @@ public void getEntryExceptionTest() throws Exception { } } + @Test + @SuppressWarnings("all") + public void lookupEntryTest() { + String name = "name3373707"; + String linkedResource = "linkedResource1544625012"; + String userSpecifiedType = "userSpecifiedType-940364963"; + String userSpecifiedSystem = "userSpecifiedSystem-1776119406"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + Entry expectedResponse = + Entry.newBuilder() + .setName(name) + .setLinkedResource(linkedResource) + .setUserSpecifiedType(userSpecifiedType) + .setUserSpecifiedSystem(userSpecifiedSystem) + .setDisplayName(displayName) + .setDescription(description) + .build(); + mockDataCatalog.addResponse(expectedResponse); + + LookupEntryRequest request = LookupEntryRequest.newBuilder().build(); + + Entry actualResponse = client.lookupEntry(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockDataCatalog.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + LookupEntryRequest actualRequest = (LookupEntryRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void lookupEntryExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockDataCatalog.addException(exception); + + try { + LookupEntryRequest request = LookupEntryRequest.newBuilder().build(); + + client.lookupEntry(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + @Test @SuppressWarnings("all") public void listEntryGroupsTest() { @@ -640,9 +691,8 @@ public void updateEntryGroupTest2() { mockDataCatalog.addResponse(expectedResponse); EntryGroup entryGroup = EntryGroup.newBuilder().build(); - FieldMask updateMask = FieldMask.newBuilder().build(); - EntryGroup actualResponse = client.updateEntryGroup(entryGroup, updateMask); + EntryGroup actualResponse = client.updateEntryGroup(entryGroup); Assert.assertEquals(expectedResponse, actualResponse); List actualRequests = mockDataCatalog.getRequests(); @@ -650,7 +700,6 @@ public void updateEntryGroupTest2() { UpdateEntryGroupRequest actualRequest = (UpdateEntryGroupRequest) actualRequests.get(0); Assert.assertEquals(entryGroup, actualRequest.getEntryGroup()); - Assert.assertEquals(updateMask, actualRequest.getUpdateMask()); Assert.assertTrue( channelProvider.isHeaderSent( ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), @@ -665,9 +714,8 @@ public void updateEntryGroupExceptionTest2() throws Exception { try { EntryGroup entryGroup = EntryGroup.newBuilder().build(); - FieldMask updateMask = FieldMask.newBuilder().build(); - client.updateEntryGroup(entryGroup, updateMask); + client.updateEntryGroup(entryGroup); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { // Expected exception diff --git a/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClientTest.java b/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClientTest.java index 618ea217..77365171 100644 --- a/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClientTest.java +++ b/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClientTest.java @@ -16,16 +16,32 @@ package com.google.cloud.datacatalog.v1beta1; import com.google.api.gax.core.NoCredentialsProvider; +import com.google.api.gax.grpc.GaxGrpcProperties; import com.google.api.gax.grpc.testing.LocalChannelProvider; import com.google.api.gax.grpc.testing.MockGrpcService; import com.google.api.gax.grpc.testing.MockServiceHelper; +import com.google.api.gax.rpc.ApiClientHeaderProvider; +import com.google.api.gax.rpc.InvalidArgumentException; +import com.google.iam.v1.GetIamPolicyRequest; +import com.google.iam.v1.Policy; +import com.google.iam.v1.SetIamPolicyRequest; +import com.google.iam.v1.TestIamPermissionsRequest; +import com.google.iam.v1.TestIamPermissionsResponse; +import com.google.protobuf.AbstractMessage; +import com.google.protobuf.ByteString; +import com.google.protobuf.Empty; +import io.grpc.Status; +import io.grpc.StatusRuntimeException; import java.io.IOException; import java.util.Arrays; +import java.util.List; import java.util.UUID; import org.junit.After; import org.junit.AfterClass; +import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; +import org.junit.Test; @javax.annotation.Generated("by GAPIC") public class PolicyTagManagerClientTest { @@ -70,4 +86,545 @@ public void setUp() throws IOException { public void tearDown() throws Exception { client.close(); } + + @Test + @SuppressWarnings("all") + public void createTaxonomyTest() { + String name = "name3373707"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + Taxonomy expectedResponse = + Taxonomy.newBuilder() + .setName(name) + .setDisplayName(displayName) + .setDescription(description) + .build(); + mockPolicyTagManager.addResponse(expectedResponse); + + CreateTaxonomyRequest request = CreateTaxonomyRequest.newBuilder().build(); + + Taxonomy actualResponse = client.createTaxonomy(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + CreateTaxonomyRequest actualRequest = (CreateTaxonomyRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void createTaxonomyExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + CreateTaxonomyRequest request = CreateTaxonomyRequest.newBuilder().build(); + + client.createTaxonomy(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void deleteTaxonomyTest() { + Empty expectedResponse = Empty.newBuilder().build(); + mockPolicyTagManager.addResponse(expectedResponse); + + DeleteTaxonomyRequest request = DeleteTaxonomyRequest.newBuilder().build(); + + client.deleteTaxonomy(request); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + DeleteTaxonomyRequest actualRequest = (DeleteTaxonomyRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void deleteTaxonomyExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + DeleteTaxonomyRequest request = DeleteTaxonomyRequest.newBuilder().build(); + + client.deleteTaxonomy(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void updateTaxonomyTest() { + String name = "name3373707"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + Taxonomy expectedResponse = + Taxonomy.newBuilder() + .setName(name) + .setDisplayName(displayName) + .setDescription(description) + .build(); + mockPolicyTagManager.addResponse(expectedResponse); + + UpdateTaxonomyRequest request = UpdateTaxonomyRequest.newBuilder().build(); + + Taxonomy actualResponse = client.updateTaxonomy(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + UpdateTaxonomyRequest actualRequest = (UpdateTaxonomyRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void updateTaxonomyExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + UpdateTaxonomyRequest request = UpdateTaxonomyRequest.newBuilder().build(); + + client.updateTaxonomy(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void listTaxonomiesTest() { + String nextPageToken = "nextPageToken-1530815211"; + ListTaxonomiesResponse expectedResponse = + ListTaxonomiesResponse.newBuilder().setNextPageToken(nextPageToken).build(); + mockPolicyTagManager.addResponse(expectedResponse); + + ListTaxonomiesRequest request = ListTaxonomiesRequest.newBuilder().build(); + + ListTaxonomiesResponse actualResponse = client.listTaxonomies(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + ListTaxonomiesRequest actualRequest = (ListTaxonomiesRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void listTaxonomiesExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + ListTaxonomiesRequest request = ListTaxonomiesRequest.newBuilder().build(); + + client.listTaxonomies(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void getTaxonomyTest() { + String name = "name3373707"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + Taxonomy expectedResponse = + Taxonomy.newBuilder() + .setName(name) + .setDisplayName(displayName) + .setDescription(description) + .build(); + mockPolicyTagManager.addResponse(expectedResponse); + + GetTaxonomyRequest request = GetTaxonomyRequest.newBuilder().build(); + + Taxonomy actualResponse = client.getTaxonomy(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + GetTaxonomyRequest actualRequest = (GetTaxonomyRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void getTaxonomyExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + GetTaxonomyRequest request = GetTaxonomyRequest.newBuilder().build(); + + client.getTaxonomy(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void createPolicyTagTest() { + String name = "name3373707"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + String parentPolicyTag = "parentPolicyTag2071382466"; + PolicyTag expectedResponse = + PolicyTag.newBuilder() + .setName(name) + .setDisplayName(displayName) + .setDescription(description) + .setParentPolicyTag(parentPolicyTag) + .build(); + mockPolicyTagManager.addResponse(expectedResponse); + + CreatePolicyTagRequest request = CreatePolicyTagRequest.newBuilder().build(); + + PolicyTag actualResponse = client.createPolicyTag(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + CreatePolicyTagRequest actualRequest = (CreatePolicyTagRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void createPolicyTagExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + CreatePolicyTagRequest request = CreatePolicyTagRequest.newBuilder().build(); + + client.createPolicyTag(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void deletePolicyTagTest() { + Empty expectedResponse = Empty.newBuilder().build(); + mockPolicyTagManager.addResponse(expectedResponse); + + DeletePolicyTagRequest request = DeletePolicyTagRequest.newBuilder().build(); + + client.deletePolicyTag(request); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + DeletePolicyTagRequest actualRequest = (DeletePolicyTagRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void deletePolicyTagExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + DeletePolicyTagRequest request = DeletePolicyTagRequest.newBuilder().build(); + + client.deletePolicyTag(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void updatePolicyTagTest() { + String name = "name3373707"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + String parentPolicyTag = "parentPolicyTag2071382466"; + PolicyTag expectedResponse = + PolicyTag.newBuilder() + .setName(name) + .setDisplayName(displayName) + .setDescription(description) + .setParentPolicyTag(parentPolicyTag) + .build(); + mockPolicyTagManager.addResponse(expectedResponse); + + UpdatePolicyTagRequest request = UpdatePolicyTagRequest.newBuilder().build(); + + PolicyTag actualResponse = client.updatePolicyTag(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + UpdatePolicyTagRequest actualRequest = (UpdatePolicyTagRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void updatePolicyTagExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + UpdatePolicyTagRequest request = UpdatePolicyTagRequest.newBuilder().build(); + + client.updatePolicyTag(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void listPolicyTagsTest() { + String nextPageToken = "nextPageToken-1530815211"; + ListPolicyTagsResponse expectedResponse = + ListPolicyTagsResponse.newBuilder().setNextPageToken(nextPageToken).build(); + mockPolicyTagManager.addResponse(expectedResponse); + + ListPolicyTagsRequest request = ListPolicyTagsRequest.newBuilder().build(); + + ListPolicyTagsResponse actualResponse = client.listPolicyTags(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + ListPolicyTagsRequest actualRequest = (ListPolicyTagsRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void listPolicyTagsExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + ListPolicyTagsRequest request = ListPolicyTagsRequest.newBuilder().build(); + + client.listPolicyTags(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void getPolicyTagTest() { + String name = "name3373707"; + String displayName = "displayName1615086568"; + String description = "description-1724546052"; + String parentPolicyTag = "parentPolicyTag2071382466"; + PolicyTag expectedResponse = + PolicyTag.newBuilder() + .setName(name) + .setDisplayName(displayName) + .setDescription(description) + .setParentPolicyTag(parentPolicyTag) + .build(); + mockPolicyTagManager.addResponse(expectedResponse); + + GetPolicyTagRequest request = GetPolicyTagRequest.newBuilder().build(); + + PolicyTag actualResponse = client.getPolicyTag(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + GetPolicyTagRequest actualRequest = (GetPolicyTagRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void getPolicyTagExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + GetPolicyTagRequest request = GetPolicyTagRequest.newBuilder().build(); + + client.getPolicyTag(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void getIamPolicyTest() { + int version = 351608024; + ByteString etag = ByteString.copyFromUtf8("21"); + Policy expectedResponse = Policy.newBuilder().setVersion(version).setEtag(etag).build(); + mockPolicyTagManager.addResponse(expectedResponse); + + GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder().build(); + + Policy actualResponse = client.getIamPolicy(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + GetIamPolicyRequest actualRequest = (GetIamPolicyRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void getIamPolicyExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder().build(); + + client.getIamPolicy(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void setIamPolicyTest() { + int version = 351608024; + ByteString etag = ByteString.copyFromUtf8("21"); + Policy expectedResponse = Policy.newBuilder().setVersion(version).setEtag(etag).build(); + mockPolicyTagManager.addResponse(expectedResponse); + + SetIamPolicyRequest request = SetIamPolicyRequest.newBuilder().build(); + + Policy actualResponse = client.setIamPolicy(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + SetIamPolicyRequest actualRequest = (SetIamPolicyRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void setIamPolicyExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + SetIamPolicyRequest request = SetIamPolicyRequest.newBuilder().build(); + + client.setIamPolicy(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void testIamPermissionsTest() { + TestIamPermissionsResponse expectedResponse = TestIamPermissionsResponse.newBuilder().build(); + mockPolicyTagManager.addResponse(expectedResponse); + + TestIamPermissionsRequest request = TestIamPermissionsRequest.newBuilder().build(); + + TestIamPermissionsResponse actualResponse = client.testIamPermissions(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManager.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + TestIamPermissionsRequest actualRequest = (TestIamPermissionsRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void testIamPermissionsExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManager.addException(exception); + + try { + TestIamPermissionsRequest request = TestIamPermissionsRequest.newBuilder().build(); + + client.testIamPermissions(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } } diff --git a/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationClientTest.java b/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationClientTest.java index d17c0514..3a0628d2 100644 --- a/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationClientTest.java +++ b/google-cloud-datacatalog/src/test/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationClientTest.java @@ -16,16 +16,25 @@ package com.google.cloud.datacatalog.v1beta1; import com.google.api.gax.core.NoCredentialsProvider; +import com.google.api.gax.grpc.GaxGrpcProperties; import com.google.api.gax.grpc.testing.LocalChannelProvider; import com.google.api.gax.grpc.testing.MockGrpcService; import com.google.api.gax.grpc.testing.MockServiceHelper; +import com.google.api.gax.rpc.ApiClientHeaderProvider; +import com.google.api.gax.rpc.InvalidArgumentException; +import com.google.protobuf.AbstractMessage; +import io.grpc.Status; +import io.grpc.StatusRuntimeException; import java.io.IOException; import java.util.Arrays; +import java.util.List; import java.util.UUID; import org.junit.After; import org.junit.AfterClass; +import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; +import org.junit.Test; @javax.annotation.Generated("by GAPIC") public class PolicyTagManagerSerializationClientTest { @@ -70,4 +79,78 @@ public void setUp() throws IOException { public void tearDown() throws Exception { client.close(); } + + @Test + @SuppressWarnings("all") + public void importTaxonomiesTest() { + ImportTaxonomiesResponse expectedResponse = ImportTaxonomiesResponse.newBuilder().build(); + mockPolicyTagManagerSerialization.addResponse(expectedResponse); + + ImportTaxonomiesRequest request = ImportTaxonomiesRequest.newBuilder().build(); + + ImportTaxonomiesResponse actualResponse = client.importTaxonomies(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManagerSerialization.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + ImportTaxonomiesRequest actualRequest = (ImportTaxonomiesRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void importTaxonomiesExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManagerSerialization.addException(exception); + + try { + ImportTaxonomiesRequest request = ImportTaxonomiesRequest.newBuilder().build(); + + client.importTaxonomies(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } + + @Test + @SuppressWarnings("all") + public void exportTaxonomiesTest() { + ExportTaxonomiesResponse expectedResponse = ExportTaxonomiesResponse.newBuilder().build(); + mockPolicyTagManagerSerialization.addResponse(expectedResponse); + + ExportTaxonomiesRequest request = ExportTaxonomiesRequest.newBuilder().build(); + + ExportTaxonomiesResponse actualResponse = client.exportTaxonomies(request); + Assert.assertEquals(expectedResponse, actualResponse); + + List actualRequests = mockPolicyTagManagerSerialization.getRequests(); + Assert.assertEquals(1, actualRequests.size()); + ExportTaxonomiesRequest actualRequest = (ExportTaxonomiesRequest) actualRequests.get(0); + + Assert.assertTrue( + channelProvider.isHeaderSent( + ApiClientHeaderProvider.getDefaultApiClientHeaderKey(), + GaxGrpcProperties.getDefaultApiClientHeaderPattern())); + } + + @Test + @SuppressWarnings("all") + public void exportTaxonomiesExceptionTest() throws Exception { + StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT); + mockPolicyTagManagerSerialization.addException(exception); + + try { + ExportTaxonomiesRequest request = ExportTaxonomiesRequest.newBuilder().build(); + + client.exportTaxonomies(request); + Assert.fail("No exception raised"); + } catch (InvalidArgumentException e) { + // Expected exception + } + } } diff --git a/synth.metadata b/synth.metadata index 9b54a0f6..74a471cf 100644 --- a/synth.metadata +++ b/synth.metadata @@ -1,20 +1,20 @@ { - "updateTime": "2020-02-07T09:46:34.577310Z", + "updateTime": "2020-02-08T09:46:14.920584Z", "sources": [ { "generator": { "name": "artman", - "version": "0.44.4", - "dockerImage": "googleapis/artman@sha256:19e945954fc960a4bdfee6cb34695898ab21a8cf0bac063ee39b91f00a1faec8" + "version": "0.45.0", + "dockerImage": "googleapis/artman@sha256:6aec9c34db0e4be221cdaf6faba27bdc07cfea846808b3d3b964dfce3a9a0f9b" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "e46f761cd6ec15a9e3d5ed4ff321a4bcba8e8585", - "internalRef": "293710856", - "log": "e46f761cd6ec15a9e3d5ed4ff321a4bcba8e8585\nGenerate the Bazel build file for recommendengine public api\n\nPiperOrigin-RevId: 293710856\n\n68477017c4173c98addac0373950c6aa9d7b375f\nMake `language_code` optional for UpdateIntentRequest and BatchUpdateIntentsRequest.\n\nThe comments and proto annotations describe this parameter as optional.\n\nPiperOrigin-RevId: 293703548\n\n16f823f578bca4e845a19b88bb9bc5870ea71ab2\nAdd BUILD.bazel files for managedidentities API\n\nPiperOrigin-RevId: 293698246\n\n2f53fd8178c9a9de4ad10fae8dd17a7ba36133f2\nAdd v1p1beta1 config file\n\nPiperOrigin-RevId: 293696729\n\n052b274138fce2be80f97b6dcb83ab343c7c8812\nAdd source field for user event and add field behavior annotations\n\nPiperOrigin-RevId: 293693115\n\n1e89732b2d69151b1b3418fff3d4cc0434f0dded\ndatacatalog: v1beta1 add three new RPCs to gapic v1beta1 config\n\nPiperOrigin-RevId: 293692823\n\n9c8bd09bbdc7c4160a44f1fbab279b73cd7a2337\nchange the name of AccessApproval service to AccessApprovalAdmin\n\nPiperOrigin-RevId: 293690934\n\n" + "sha": "e7d8a694f4559201e6913f6610069cb08b39274e", + "internalRef": "293903652", + "log": "e7d8a694f4559201e6913f6610069cb08b39274e\nDepend on the latest gapic-generator and resource names plugin.\n\nThis fixes the very old an very annoying bug: https://github.com/googleapis/gapic-generator/pull/3087\n\nPiperOrigin-RevId: 293903652\n\n806b2854a966d55374ee26bb0cef4e30eda17b58\nfix: correct capitalization of Ruby namespaces in SecurityCenter V1p1beta1\n\nPiperOrigin-RevId: 293903613\n\n1b83c92462b14d67a7644e2980f723112472e03a\nPublish annotations and grpc service config for Logging API.\n\nPiperOrigin-RevId: 293893514\n\n" } }, {