module MarketSharp
  class Client
    module Customers

      def customers(params = {})
        page = params[:page] || 1
        page_size = params[:page_size] || 100
        date_to_filter_on = params[:filter_date] || 'lastUpdate'
        sort_by = params[:sort_by] || 'lastUpdate'
        sort_direction = params[:sort_direction] || 'asc'
        start_date = params[:start_date].strftime("%Y-%m-%dT%H:%M:%S")
        end_date = params[:end_date].strftime("%Y-%m-%dT%H:%M:%S")

        connection.Contacts.skip(page.to_i * page_size).top(page_size).filter("#{date_to_filter_on} ge datetime'#{start_date}'").filter("#{date_to_filter_on} le datetime'#{end_date}'").expand('Address').expand('ContactPhone').order_by("#{sort_by} #{sort_direction}")

        response = connection.execute
        return JSON.parse(response.to_json)
      rescue OData::ServiceError => e
        case e.http_code
        when  401
          raise(MarketSharp::AuthorizationError, e.message)
        when 404
          raise(MarketSharp::RecordNotFoundError, e.message)
        when 503
          raise(MarketSharp::ServiceUnavailableError, e.message)
        when 400
          raise(MarketSharp::BadRequestError, e.message)
        when 500
          raise(MarketSharp::ConnectionError, e.message)
        else
          raise(MarketSharp::Error, e.message)
        end
      rescue StandardError => e
        raise(MarketSharp::Error, e.message)
      end

      def customer(id, params = {})
        connection.Contacts.filter("id eq '#{id}'")

        response = connection.execute
        return JSON.parse(response.to_json)
      end

    end
  end
end