k1LoW / awspec

  class Firehose < ResourceBase

    def resource_via_client

      @resource_via_client ||= find_delivery_stream(@delivery_stream_name)

    end

    def id

      @id ||= @delivery_stream_name if resource_via_client

    end

    STATES = %w(ACTIVE CREATING DELETING)

    STATES.each do |state|

      define_method state.downcase + '?' do

        resource_via_client.delivery_stream_status == state

      end

    end

    def has_source_type?(type)

      resource_via_client.delivery_stream_type == type

    end

    # TODO: Add one per destination type

    def has_splunk_destination?

      resource_via_client.destinations[0] &&

        resource_via_client.destinations[0].splunk_destination_description

    end

  end

end