Sha256: 6cea9e5474d492a3fb1461217f0ee66a875e2dc5a3ce044aa16559cb8a216da1
Contents?: true
Size: 1.69 KB
Versions: 11
Compression:
Stored size: 1.69 KB
Contents
module Awspec::Helper
module Finder
module SNSTopic
class SnsTopic
# to make testing results easier to the eyes instead of using Rspec
# include matcher for hashes
attr_reader :policy, :owner, :pending_subscriptions, :topic_arn, :effective_delivery_policy,
:display_name, :confirmed_subscriptions, :deleted_subscriptions, :name
def initialize(attribs)
@policy = attribs['Policy']
@owner = attribs['Owner']
@pending_subscriptions = attribs['SubscriptionsPending'].to_i
@topic_arn = attribs['TopicArn']
@effective_delivery_policy = attribs['EffectiveDeliveryPolicy']
@display_name = attribs['DisplayName']
@confirmed_subscriptions = attribs['SubscriptionsConfirmed'].to_i
@deleted_subscriptions = attribs['SubscriptionsDeleted'].to_i
@name = attribs['TopicArn'].split(':')[-1]
end
def to_s
output = ["SnsTopic: #{self.name}"]
self.instance_variables.each do |attrib|
tmp = attrib.to_s.sub('@', '')
output << " #{tmp} = #{self.send(tmp)}"
end
output.join("\n")
end
end
def find_sns_topic(topic_arn)
response = sns_client.get_topic_attributes({ topic_arn: topic_arn })
SnsTopic.new(response.attributes)
end
def find_sns_topic_subs(topic_arn)
response = sns_client.list_subscriptions_by_topic({ topic_arn: topic_arn })
subscriptions = {}
response.subscriptions.each do |subscribed|
subscriptions[subscribed['subscription_arn'].to_sym] = subscribed
end
subscriptions
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems