require "forwardable"
#require "oauth"
require "hashie"
require "httparty"
require "json"

module MambaNation
  include HTTParty
  API_VERSION = "2".freeze
  base_uri "api.mambanation.com/v#{API_VERSION}"
  format :json

  class MambaNationError < StandardError
    attr_reader :data

    def initialize(data)
      @data = data
      super
    end
  end

  class RateLimitExceeded < MambaNationError; end
  class Unauthorized      < MambaNationError; end
  class General           < MambaNationError; end

  class Unavailable       < StandardError; end
  class InformMambaNation < StandardError; end
  class NotFound          < StandardError; end

  # Options: user_id, facebook_id
  def self.user(*user)
    perform_get("/users/show.json", :body => { :user => user })
  end

  # Options: user_id, facebook_id
  def self.user_facets(query = {})
    perform_get("/users/facets.json", :query => query)
  end

  # Options: user_id, :limit
  def self.user_media(query = {})
    perform_get("/users/media.json", :query => query)
  end

  # Options: user_id, facebook_id
  def self.user_friends(query = {})
    perform_get("/users/friends.json", :query => query)
  end
  
  private

  def self.perform_get(uri, options = {})
    make_friendly(get(uri, options))
  end

  def self.make_friendly(response)
    raise_errors(response)
    data = parse(response)
    # Don't mash arrays of integers
    if data && data.is_a?(Array) && data.first.is_a?(Integer)
      data
    else
      mash(data)
    end
  end

  def self.raise_errors(response)
    case response.code.to_i
      when 400
        data = parse(response)
        raise RateLimitExceeded.new(data), "(#{response.code}): #{response.message} - #{data['error'] if data}"
      when 401
        data = parse(response)
        raise Unauthorized.new(data), "(#{response.code}): #{response.message} - #{data['error'] if data}"
      when 403
        data = parse(response)
        raise General.new(data), "(#{response.code}): #{response.message} - #{data['error'] if data}"
      when 404
        raise NotFound, "(#{response.code}): #{response.message}"
      when 500
        raise InformMambaNation, "MambaNation had an internal error. Please let them know in the group. (#{response.code}): #{response.message}"
      when 502..503
        raise Unavailable, "(#{response.code}): #{response.message}"
    end
  end

  def self.parse(response)
    return '' if response.body == ''
    JSON.parse(response.body)
  rescue
    response.body # Text body response
  end

  def self.mash(obj)
    if obj.is_a?(Array)
      obj.map{|item| make_mash_with_consistent_hash(item)}
    elsif obj.is_a?(Hash)
      make_mash_with_consistent_hash(obj)
    else
      obj
    end
  end

  # Lame workaround for the fact that mash doesn't hash correctly
  def self.make_mash_with_consistent_hash(obj)
    m = Hashie::Mash.new(obj)
    def m.hash
      inspect.hash
    end
    return m
  end

end

module Hashie
  class Mash
    # Converts all of the keys to strings, optionally formatting key name
    def rubyify_keys!
      keys.each{|k|
        v = delete(k)
        new_key = k.to_s.underscore
        self[new_key] = v
        v.rubyify_keys! if v.is_a?(Hash)
        v.each{|p| p.rubyify_keys! if p.is_a?(Hash)} if v.is_a?(Array)
      }
      self
    end
  end
end

directory = File.expand_path(File.dirname(__FILE__))

require File.join(directory, "mambanation", "base")
require File.join(directory, "mambanation", "httpauth")
require File.join(directory, "mambanation", "oauth")
require File.join(directory, "mambanation", "request")