class Aws::RDS::EventSubscription

def add_subscriber(options = {})
  options = options.merge(subscription_name: @name)
  resp = Aws::Plugins::UserAgent.feature('resource') do
    @client.add_source_identifier_to_subscription(options)
  end
  EventSubscription.new(
    name: resp.data.event_subscription.cust_subscription_id,
    data: resp.data.event_subscription,
    client: @client
  )
end

def client
  @client
end

def create(options = {})
  options = options.merge(subscription_name: @name)
  resp = Aws::Plugins::UserAgent.feature('resource') do
    @client.create_event_subscription(options)
  end
  EventSubscription.new(
    name: resp.data.event_subscription.cust_subscription_id,
    data: resp.data.event_subscription,
    client: @client
  )
end

def customer_aws_id
  data[:customer_aws_id]
end

def data
  load unless @data
  @data
end

def data_loaded?
  !!@data
end

def delete(options = {})
  options = options.merge(subscription_name: @name)
  resp = Aws::Plugins::UserAgent.feature('resource') do
    @client.delete_event_subscription(options)
  end
  EventSubscription.new(
    name: resp.data.event_subscription.cust_subscription_id,
    data: resp.data.event_subscription,
    client: @client
  )
end

def enabled
  data[:enabled]
end

def event_categories_list
  data[:event_categories_list]
end

def event_subscription_arn
  data[:event_subscription_arn]
end

def extract_name(args, options)
  value = args[0] || options.delete(:name)
  case value
  when String then value
  when nil then raise ArgumentError, "missing required option :name"
  else
    msg = "expected :name to be a String, got #{value.class}"
    raise ArgumentError, msg
  end
end

def identifiers
  { name: @name }
end

def initialize(*args)
  options = Hash === args.last ? args.pop.dup : {}
  @name = extract_name(args, options)
  @data = options.delete(:data)
  @client = options.delete(:client) || Client.new(options)
  @waiter_block_warned = false
end

def load
  resp = Aws::Plugins::UserAgent.feature('resource') do
    @client.describe_event_subscriptions(subscription_name: @name)
  end
  @data = resp.event_subscriptions_list[0]
  self
end

def modify(options = {})
  options = options.merge(subscription_name: @name)
  resp = Aws::Plugins::UserAgent.feature('resource') do
    @client.modify_event_subscription(options)
  end
  EventSubscription.new(
    name: resp.data.event_subscription.cust_subscription_id,
    data: resp.data.event_subscription,
    client: @client
  )
end

def name
  @name
end

def remove_subscriber(options = {})
  options = options.merge(subscription_name: @name)
  resp = Aws::Plugins::UserAgent.feature('resource') do
    @client.remove_source_identifier_from_subscription(options)
  end
  EventSubscription.new(
    name: resp.data.event_subscription.cust_subscription_id,
    data: resp.data.event_subscription,
    client: @client
  )
end

def sns_topic_arn
  data[:sns_topic_arn]
end

def source_ids_list
  data[:source_ids_list]
end

def source_type
  data[:source_type]
end

def status
  data[:status]
end

def subscription_creation_time
  data[:subscription_creation_time]
end

def wait_until(options = {}, &block)
  self_copy = self.dup
  attempts = 0
  options[:max_attempts] = 10 unless options.key?(:max_attempts)
  options[:delay] ||= 10
  options[:poller] = Proc.new do
    attempts += 1
    if block.call(self_copy)
      [:success, self_copy]
    else
      self_copy.reload unless attempts == options[:max_attempts]
      :retry
    end
  end
  Aws::Plugins::UserAgent.feature('resource') do
    Aws::Waiters::Waiter.new(options).wait({})
  end
end