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/#{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}/#{id}"
  true
end

def exceptions
  [Faraday::Error::ClientError]
end

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

def find(sobject, id, field = nil)
  if field
    url = "sobjects/#{sobject}/#{field}/#{URI.encode(id)}"
  else
    url = "sobjects/#{sobject}/#{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)
  if field
    path = "sobjects/#{sobject}/#{field}/#{URI.encode(id)}"
  else
    path = "sobjects/#{sobject}/#{id}"
  end
  path << "?fields=#{select.join(',')}" if select && 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.downcase == 'id' }, nil)
  raise ArgumentError, 'Id field missing from attrs.' unless id
  attrs_without_id = attrs.reject { |k, v| k.to_s.downcase == "id" }
  api_patch "sobjects/#{sobject}/#{id}", attrs_without_id
  true
end

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

def upsert!(sobject, field, attrs)
  external_id = attrs.
    fetch(attrs.keys.find { |k, v| k.to_s.downcase == field.to_s.downcase }, nil)
  attrs_without_field = attrs.
    reject { |k, v| k.to_s.downcase == field.to_s.downcase }
  response = api_patch "sobjects/#{sobject}/#{field}/#{URI.encode(external_id)}",
                       attrs_without_field
  (response.body && response.body['id']) ? response.body['id'] : 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