# Gnip PowerTrack Rules API
#
# Create, delete and list rules of a powetrack stream.

module GnipApi
  module PowerTrack
    class Rules
      # Returns an array of defined rules
      def list
        request = create_get_request
        rules = fetch_data(request)
        parse_rules(rules)
      end

      # Creates the specified rule. Parameters:
      # - rules: GnipApi::PowerTrack::Rule object
      def create rules
        raise ArgumentError.new('No rules provided') if rules.nil? || rules.empty?
        request = create_post_request(construct_rules(rules))
        response = fetch_data(request)
        return true if response.nil?
        return GnipApi::JsonParser.new.parse(response)
      end

      # Deletes the specified rule. Parameters:
      # - rules: GnipApi::PowerTrack::Rule object
      def delete rules
        raise ArgumentError.new('No rules provided') if rules.nil? || rules.empty?
        request = create_delete_request(construct_rules(rules))
        response = fetch_data(request)
        return true if response.nil?
        return GnipApi::JsonParser.new.parse(response)
      end

      def validate rules
        raise ArgumentError.new('No rules provided') if rules.nil? || rules.empty?
        byebug
        request = create_validation_request(construct_rules(rules))
        response = fetch_data(request)
        return true if response.nil?
        return GnipApi::JsonParser.new.parse(response)
      end

      # Parses an array of GnipApi::PowerTrack::Rule objects
      # to the necesary JSON format for the endpoint
      def construct_rules rules
        parsed_rules = {:rules => []}
        rules.each do |rule|
          parsed_rules[:rules] << rule.attributes
        end
        parsed_rules.to_json
      end

      def parse_rules data
        parsed_data = GnipApi::JsonParser.new.parse(data)
        parsed_data['rules'].map{|rule| GnipApi::PowerTrack::Rule.new(:value => rule['value'], :tag => rule['tag'], :id => rule['id'])}
      end

      private
      def fetch_data(request)
        request.execute!
      end

      def endpoint
        GnipApi::Endpoints.powertrack_rules
      end

      def validation_endpoint
        GnipApi::Endpoints.powertrack_rule_validator
      end

      def create_validation_request payload
        GnipApi::Request.new_post(validation_endpoint, payload)
      end

      def create_get_request
        GnipApi::Request.new_get(endpoint)
      end

      def create_post_request payload
        GnipApi::Request.new_post(endpoint, payload)
      end
      
      def create_delete_request payload
        delete_url = endpoint
        delete_url.query = '_method=delete'
        GnipApi::Request.new_post(delete_url, payload)
      end

    end
  end
end