module Restforce::Concerns::API

def api_path(path)
  "/services/data/v#{options[:api_version]}/#{path}"
end

def create(*args)
  create!(*args)
rescue *exceptions
  false
end

def create!(sobject, attrs)
  api_post("sobjects/#{sobject}", attrs).body['id']
end

def describe(sobject = nil)
  if sobject
    api_get("sobjects/#{sobject}/describe").body
  else
    api_get('sobjects').body['sobjects']
  end
end

def describe_layouts(sobject, layout_id = nil)
  version_guard(28.0) do
    if layout_id
      api_get("sobjects/#{sobject}/describe/layouts/#{CGI.escape(layout_id)}").body
    else
      api_get("sobjects/#{sobject}/describe/layouts").body
    end
  end
end

def destroy(*args)
  destroy!(*args)
rescue *exceptions
  false
end

def destroy!(sobject, id)
  api_delete "sobjects/#{sobject}/#{ERB::Util.url_encode(id)}"
  true
end

def exceptions
  [Faraday::ClientError]
end

def explain(soql)
  version_guard(30.0) { api_get("query", explain: soql).body }
end

def extract_case_insensitive_string_or_symbol_key_from_hash!(hash, key)
  value = hash.delete(key.to_sym)
  value ||= hash.delete(key.to_s)
  value ||= hash.delete(key.to_s.downcase)
  value ||= hash.delete(key.to_s.downcase.to_sym)
  value
end

def find(sobject, id, field = nil)
  url = if field
          "sobjects/#{sobject}/#{field}/#{ERB::Util.url_encode(id)}"
        else
          "sobjects/#{sobject}/#{ERB::Util.url_encode(id)}"
        end
  api_get(url).body
end

def get_deleted(sobject, start_time, end_time)
  start_time = start_time.utc.iso8601
  end_time = end_time.utc.iso8601
  url = "sobjects/#{sobject}/deleted/?start=#{start_time}&end=#{end_time}"
  api_get(url).body
end

def get_updated(sobject, start_time, end_time)
  start_time = start_time.utc.iso8601
  end_time = end_time.utc.iso8601
  url = "sobjects/#{sobject}/updated/?start=#{start_time}&end=#{end_time}"
  api_get(url).body
end

def limits
  version_guard(29.0) { api_get("limits").body }
end

def list_sobjects
  describe.collect { |sobject| sobject['name'] }
end

def org_id
  query('select id from Organization').first['Id']
end

def query(soql)
  response = api_get 'query', q: soql
  mashify? ? response.body : response.body['records']
end

def query_all(soql)
  version_guard(29.0) do
    response = api_get 'queryAll', q: soql
    mashify? ? response.body : response.body['records']
  end
end

def recent(limit = nil)
  path = limit ? "recent?limit=#{limit}" : "recent"
  api_get(path).body
end

def search(sosl)
  api_get('search', q: sosl).body
end

def select(sobject, id, select, field = nil)
  path = if field
           "sobjects/#{sobject}/#{field}/#{ERB::Util.url_encode(id)}"
         else
           "sobjects/#{sobject}/#{ERB::Util.url_encode(id)}"
         end
  path = "#{path}?fields=#{select.join(',')}" if select&.any?
  api_get(path).body
end

def update(*args)
  update!(*args)
rescue *exceptions
  false
end

def update!(sobject, attrs)
  id = attrs.fetch(attrs.keys.find { |k, v| k.to_s.casecmp('id').zero? }, nil)
  raise ArgumentError, 'ID field missing from provided attributes' unless id
  attrs_without_id = attrs.reject { |k, v| k.to_s.casecmp("id").zero? }
  api_patch "sobjects/#{sobject}/#{CGI.escape(id)}", attrs_without_id
  true
end

def upsert(*args)
  upsert!(*args)
rescue *exceptions
  false
end

def upsert!(sobject, field, attrs)
  attrs = attrs.dup
  external_id =
    extract_case_insensitive_string_or_symbol_key_from_hash!(attrs, field).to_s
  if field.to_s != "Id" && (external_id.nil? || external_id.strip.empty?)
    raise ArgumentError, 'Specified external ID field missing from provided ' \
                         'attributes'
  end
  response =
    if field.to_s == "Id" && (external_id.nil? || external_id.strip.empty?)
      version_guard(37.0) do
        api_post "sobjects/#{sobject}/#{field}", attrs
      end
    else
      api_patch "sobjects/#{sobject}/#{field}/" \
        "#{ERB::Util.url_encode(external_id)}", attrs
    end
  response.body.respond_to?(:fetch) ? response.body.fetch('id', true) : true
end

def user_info
  get(api_get.body.identity).body
end

def version_guard(version)
  if version.to_f <= options[:api_version].to_f
    yield
  else
    raise APIVersionError, "You must set an `api_version` of at least #{version} " \
                           "to use this feature in the Salesforce API. Set the " \
                           "`api_version` option when configuring the client - " \
                           "see https://github.com/ejholmes/restforce/blob/master" \
                           "/README.md#api-versions"
  end
end