Merge pull request #78 from GoogleCloudPlatform/add-pubsub-snippets-for-deletions

Add Pub/Sub snippets for deleting topics and subscriptions

Author: remi Taylor

pubsub/sample.rb

@@ -30,23 +30,48 @@ def create_topic
   # [END create_topic]
 end
 
+def delete_topic
+  # [START delete_topic]
+  gcloud = Google::Cloud.new "my-gcp-project-id"
+  pubsub = gcloud.pubsub
+  topic  = pubsub.topic "my-topic"
+
+  topic.delete
+
+  puts "Deleted topic my-topic"
+  # [END delete_topic]
+end
+
 def create_subscription
   # [START create_subscription]
   gcloud = Google::Cloud.new "my-gcp-project-id"
   pubsub = gcloud.pubsub
-  topic = pubsub.topic "my-topic"
+  topic  = pubsub.topic "my-topic"
 
   subscription = topic.subscribe "my-subscription"
 
   puts "Subscription created #{subscription.name}"
   # [END create_subscription]
 end
 
+def delete_subscription
+  # [START delete_subscription]
+  gcloud       = Google::Cloud.new "my-gcp-project-id"
+  pubsub       = gcloud.pubsub
+  topic        = pubsub.topic "my-topic"
+  subscription = topic.subscription "my-subscription"
+
+  subscription.delete
+
+  puts "Deleted subscription my-subscription"
+  # [END delete_subscription]
+end
+
 def create_push_subscription
   # [START create_push_subscription]
   gcloud = Google::Cloud.new "my-gcp-project-id"
   pubsub = gcloud.pubsub
-  topic = pubsub.topic "my-topic"
+  topic  = pubsub.topic "my-topic"
 
   subscription = topic.subscribe(
     "my-subscription-push",
@@ -69,8 +94,8 @@ def publish_message
 
 def pull_messages
   # [START pull_messages]
-  gcloud = Google::Cloud.new "my-gcp-project-id"
-  pubsub = gcloud.pubsub
+  gcloud       = Google::Cloud.new "my-gcp-project-id"
+  pubsub       = gcloud.pubsub
   subscription = pubsub.subscription "my-subscription"
 
   puts "Messages pulled:"
@@ -96,8 +121,8 @@ def list_topics
 
 def list_subscriptions
   # [START list_subscriptions]
-  gcloud = Google::Cloud.new "my-gcp-project-id"
-  pubsub = gcloud.pubsub
+  gcloud        = Google::Cloud.new "my-gcp-project-id"
+  pubsub        = gcloud.pubsub
   subscriptions = pubsub.subscriptions
 
   puts "Subscriptions:"
@@ -111,7 +136,7 @@ def get_topic_policy
   # [START get_topic_policy]
   gcloud = Google::Cloud.new "my-gcp-project-id"
   pubsub = gcloud.pubsub
-  topic = pubsub.topic "my-topic"
+  topic  = pubsub.topic "my-topic"
 
   policy = topic.policy
 
@@ -122,8 +147,8 @@ def get_topic_policy
 
 def get_subscription_policy
   # [START get_subscription_policy]
-  gcloud = Google::Cloud.new "my-gcp-project-id"
-  pubsub = gcloud.pubsub
+  gcloud       = Google::Cloud.new "my-gcp-project-id"
+  pubsub       = gcloud.pubsub
   subscription = pubsub.subscription "my-subscription"
 
   policy = subscription.policy
@@ -135,8 +160,8 @@ def get_subscription_policy
 
 def set_subscription_policy
   # [START set_subscription_policy]
-  gcloud = Google::Cloud.new "my-gcp-project-id"
-  pubsub = gcloud.pubsub
+  gcloud       = Google::Cloud.new "my-gcp-project-id"
+  pubsub       = gcloud.pubsub
   subscription = pubsub.subscription "my-subscription"
 
   policy = subscription.policy do |p|
@@ -152,7 +177,7 @@ def set_topic_policy
   # [START set_topic_policy]
   gcloud = Google::Cloud.new "my-gcp-project-id"
   pubsub = gcloud.pubsub
-  topic = pubsub.topic "my-topic"
+  topic  = pubsub.topic "my-topic"
 
   policy = topic.policy do |p|
     p.add "roles/pubsub.publisher",
@@ -165,8 +190,8 @@ def set_topic_policy
 
 def test_subscription_permissions
   # [START test_subscription_permissions]
-  gcloud = Google::Cloud.new "my-gcp-project-id"
-  pubsub = gcloud.pubsub
+  gcloud       = Google::Cloud.new "my-gcp-project-id"
+  pubsub       = gcloud.pubsub
   subscription = pubsub.subscription "my-subscription"
 
   permissions = subscription.test_permissions "pubsub.subscriptions.consume",
@@ -181,7 +206,7 @@ def test_topic_permissions
   # [START test_topic_permissions]
   gcloud = Google::Cloud.new "my-gcp-project-id"
   pubsub = gcloud.pubsub
-  topic = pubsub.topic "my-topic"
+  topic  = pubsub.topic "my-topic"
 
   permissions = topic.test_permissions "pubsub.topics.attachSubscription",
                                        "pubsub.topics.publish",

pubsub/spec/sample_spec.rb

@@ -61,6 +61,15 @@ def expect_with_retry attempts: 5
     expect(topic.name).to include(TOPIC_NAME)
   end
 
+  it "deletes topic" do
+    @pubsub.create_topic TOPIC_NAME
+    expect(@pubsub.topic TOPIC_NAME).not_to be nil
+
+    expect { delete_topic }.to output("Deleted topic #{TOPIC_NAME}\n").to_stdout
+
+    expect(@pubsub.topic TOPIC_NAME).to be nil
+  end
+
   it "creates subscription" do
     expect(@pubsub.subscription(SUBSCRIPTION_NAME)).to be nil
     @pubsub.create_topic TOPIC_NAME
@@ -74,6 +83,22 @@ def expect_with_retry attempts: 5
     expect(subscription.topic.name).to include(TOPIC_NAME)
   end
 
+  it "deletes subscription" do
+    topic = @pubsub.create_topic TOPIC_NAME
+    @pubsub.create_subscription(
+      TOPIC_NAME,
+      SUBSCRIPTION_NAME,
+      autocreate: true
+    )
+    expect(topic.subscription SUBSCRIPTION_NAME).not_to be nil
+
+    expect { delete_subscription }.to output(
+      "Deleted subscription #{SUBSCRIPTION_NAME}\n"
+    ).to_stdout
+
+    expect(topic.subscription SUBSCRIPTION_NAME).to be nil
+  end
+
   it "creates push subscription" do
     subscription_name = "my-subscription-push"