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.to_s}/describe").body
  else
    api_get('sobjects').body['sobjects']
  end
end

def describe_layouts(sobject, layout_id = nil)
  if layout_id
    api_get("sobjects/#{sobject.to_s}/describe/layouts/#{layout_id}").body
  else
    api_get("sobjects/#{sobject.to_s}/describe/layouts").body
  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 find(sobject, id, field=nil)
  api_get(field ? "sobjects/#{sobject}/#{field}/#{id}" : "sobjects/#{sobject}/#{id}").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 search(sosl)
  api_get('search', :q => sosl).body
end

def select(sobject, id, select, field=nil)
  path = field ? "sobjects/#{sobject}/#{field}/#{id}" : "sobjects/#{sobject}/#{id}"
  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.delete(attrs.keys.find { |k| k.to_s.downcase == 'id' })
  raise ArgumentError, 'Id field missing from attrs.' unless id
  api_patch "sobjects/#{sobject}/#{id}", attrs
  true
end

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

def upsert!(sobject, field, attrs)
  external_id = attrs.delete(attrs.keys.find { |k| k.to_s.downcase == field.to_s.downcase })
  response = api_patch "sobjects/#{sobject}/#{field.to_s}/#{external_id}", attrs
  (response.body && response.body['id']) ? response.body['id'] : true
end