Sha256: d1c5f1f4933d3956c2f9792d8fd582ffcaf195a07ab9fcc4ebf7a74da1683b95
Contents?: true
Size: 1.21 KB
Versions: 56
Compression:
Stored size: 1.21 KB
Contents
# frozen_string_literal: true
#
# Collect SNS resources
#
class SNS < Mapper
#
# Returns an array of resources.
#
def collect
resources = []
#
# list_topics
#
@client.list_topics.each_with_index do |response, page|
log(response.context.operation_name, page)
response.topics.each do |topic|
log(response.context.operation_name, topic.topic_arn, page)
# get_topic_attributes
struct = OpenStruct.new(@client.get_topic_attributes({ topic_arn: topic.topic_arn }).attributes.to_h)
struct.type = 'topic'
struct.arn = topic.topic_arn
struct.policy = struct.delete_field('Policy').parse_policy
struct.effective_delivery_policy = struct.delete_field('EffectiveDeliveryPolicy').parse_policy
struct.subscriptions = []
# list_subscriptions_by_topic
@client.list_subscriptions_by_topic({ topic_arn: topic.topic_arn }).each_with_index do |response, page|
log(response.context.operation_name, topic.topic_arn, page)
response.subscriptions.each do |sub|
struct.subscriptions.push(sub.to_h)
end
end
resources.push(struct.to_h)
end
end
resources
end
end
Version data entries
56 entries across 56 versions & 1 rubygems