1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
require "helpers/integration_test_helper"
require "securerandom"
require "base64"
class PubSubShared < FogIntegrationTest
def setup
@client = Fog::Google::Pubsub.new
# Ensure any resources we create with test prefixes are removed
Minitest.after_run do
delete_test_resources
end
end
def delete_test_resources
topics_result = @client.list_topics
unless topics_result.topics.nil?
begin
topics_result.topics
.map(&:name)
.select { |t| t.start_with?(topic_resource_prefix) }
.each { |t| @client.delete_topic(t) }
# We ignore errors here as list operations may not represent changes applied recently.
# Hence, list operations can return a topic which has already been deleted but which we
# will attempt to delete again.
rescue Google::Apis::Error
Fog::Logger.warning("ignoring Google Api error during delete_test_resources")
end
end
subscriptions_result = @client.list_subscriptions
unless subscriptions_result.subscriptions.nil?
begin
subscriptions_result.subscriptions
.map(&:name)
.select { |s| s.start_with?(subscription_resource_prefix) }
.each { |s| @client.delete_subscription(s) }
# We ignore errors here as list operations may not represent changes applied recently.
# Hence, list operations can return a topic which has already been deleted but which we
# will attempt to delete again.
rescue Google::Apis::Error
Fog::Logger.warning("ignoring Google Api error during delete_test_resources")
end
end
end
def topic_resource_prefix
"projects/#{@client.project}/topics/fog-integration-test"
end
def subscription_resource_prefix
"projects/#{@client.project}/subscriptions/fog-integration-test"
end
def new_topic_name
"#{topic_resource_prefix}-#{SecureRandom.uuid}"
end
def new_subscription_name
"#{subscription_resource_prefix}-#{SecureRandom.uuid}"
end
def some_topic_name
# create lazily to speed tests up
@some_topic ||= new_topic_name.tap do |t|
@client.create_topic(t)
end
end
def some_subscription_name
# create lazily to speed tests up
@some_subscription ||= new_subscription_name.tap do |s|
@client.create_subscription(s, some_topic_name)
end
end
end
|
