---

johnfmikhail · chingor13 · commit b76d0f762d68 · 2018-12-12T15:11:39.000-08:00
yaml --- r: 13019 b: refs/heads/autosynth-securitycenter c: 37955a9 h: refs/heads/master i: 13017: 5fb00c9 13015: 9eef14d
diff --git a/[refs] b/[refs]
@@ -139,7 +139,7 @@ refs/heads/autosynth-language: 8972866b016473559702424205ce5569de47b34d
 refs/heads/autosynth-os-login: daa910328b954bbe87068f684a3088ed910f1ddf
 refs/heads/autosynth-redis: 4c68cb0fbc599124e717ab3f24bd8a8a5d085ca9
 refs/heads/autosynth-scheduler: 2f0fe714a8541dc72f88b45bddd8748e5f21cf29
-refs/heads/autosynth-securitycenter: 74a4517cc99b2a3d5c3505baeb607e249f7aab82
+refs/heads/autosynth-securitycenter: 37955a9bc91b6a17a8ddbbe8369e7f36a799715e
 refs/heads/autosynth-spanner: 1804eb46dd34a05b47163758d376a7fac49188f1
 refs/heads/autosynth-speech: 631df42a628621fe42eb4974c9eb725b2fe8e473
 refs/heads/autosynth-tasks: afc9f4da54964dea5e7f3a9b164db282fc35db5c
diff --git a/branches/autosynth-securitycenter/google-cloud-clients/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/it/ITPubSubTest.java b/branches/autosynth-securitycenter/google-cloud-clients/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/it/ITPubSubTest.java
@@ -17,7 +17,9 @@
 package com.google.cloud.pubsub.it;
 
 import static com.google.common.truth.Truth.assertThat;
+import static org.junit.Assume.assumeTrue;
 
+import com.google.api.gax.rpc.PermissionDeniedException;
 import com.google.auto.value.AutoValue;
 import com.google.cloud.ServiceOptions;
 import com.google.cloud.pubsub.v1.AckReplyConsumer;
@@ -40,6 +42,7 @@
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
+import junit.framework.Assert;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.Rule;
@@ -52,6 +55,9 @@ public class ITPubSubTest {
   private static TopicAdminClient topicAdminClient;
   private static SubscriptionAdminClient subscriptionAdminClient;
   private static String projectId;
+  private static final boolean IS_VPC_TEST =
+      System.getenv("GOOGLE_CLOUD_TESTS_IN_VPCSC") != null
+          && System.getenv("GOOGLE_CLOUD_TESTS_IN_VPCSC").equalsIgnoreCase("true");
 
   @Rule public Timeout globalTimeout = Timeout.seconds(300);
 
@@ -107,6 +113,31 @@ public void testTopicPolicy() {
     topicAdminClient.deleteTopic(topicName);
   }
 
+  @Test
+  public void testVPCPushSubscriber() throws Exception {
+    assumeTrue(IS_VPC_TEST);
+    ProjectTopicName topicName =
+        ProjectTopicName.of(projectId, formatForTest("testing-vpc-push-subscriber-topic"));
+    ProjectSubscriptionName subscriptionName =
+        ProjectSubscriptionName.of(
+            projectId, formatForTest("testing-vpc-push-subscriber-subscription"));
+    topicAdminClient.createTopic(topicName);
+
+    try {
+      subscriptionAdminClient.createSubscription(
+          subscriptionName,
+          topicName,
+          PushConfig.newBuilder().setPushEndpoint("random_point").build(),
+          10);
+      subscriptionAdminClient.deleteSubscription(subscriptionName);
+      Assert.fail("No exception raised");
+    } catch (PermissionDeniedException e) {
+      // expected
+    }
+
+    topicAdminClient.deleteTopic(topicName);
+  }
+
   @Test
   public void testPublishSubscribe() throws Exception {
     ProjectTopicName topicName =
