require "forwardable"

module Yao::Resources
  module RestfullyAccessible
    def self.extended(base)
      base.class_eval do
        class << self
          attr_accessor :resource_name, :resources_name

          extend Forwardable
          %w(get post put delete).each do |method_name|
            def_delegator :client, method_name, method_name.upcase
          end
        end
      end
    end

    def service=(name)
      @service = name
    end

    def service
      @service
    end

    def admin=(bool)
      @admin = bool
    end

    def return_single_on_querying=(bool)
      @return_single_on_querying = bool
    end

    def resources_path
      @resources_path || resources_name
    end

    def resources_path=(path)
      @resources_path = path.sub(%r!^\/!, "")
    end

    def client
      if @admin
        Yao.default_client.admin_pool[service]
      else
        Yao.default_client.pool[service]
      end
    end

    def as_member(&blk)
      if @admin
        @admin = false
        result = yield(blk)
        @admin = true
        result
      else
        yield blk
      end
    end

    def with_resources_path(path, &blk)
      original = @resources_path
      @resources_path = path
      result = yield(blk)
      @resources_path = original

      result
    end

    # restful methods
    def list(query={})
      json = GET(resources_path, query).body
      if @return_single_on_querying && !query.empty?
        return_resource(json[resource_name_in_json])
      else
        return_resources(json[resources_name_in_json])
      end
    end

    def list_detail(query={})
      return_resources(GET([resources_path, "detail"].join("/"), query).body[resources_name_in_json])
    end

    def get(id_or_permalink, query={})
      res = if id_or_permalink =~ /^https?:\/\//
              GET(id_or_permalink, query)
            else
              GET([resources_path, id_or_permalink].join("/"), query)
            end
      return_resource(res.body[resource_name_in_json])
    end
    alias find get

    def create(resource_params)
      params = {
        resource_name_in_json => resource_params
      }
      res = POST(resources_path) do |req|
        req.body = params.to_json
        req.headers['Content-Type'] = 'application/json'
      end
      return_resource(res.body[resource_name_in_json])
    end

    def update(id, resource_params)
      params = {
        resource_name_in_json => resource_params
      }
      res = PUT([resources_path, id].join("/")) do |req|
        req.body = params.to_json
        req.headers['Content-Type'] = 'application/json'
      end
      return_resource(res.body[resource_name_in_json])
    end

    def destroy(id)
      res = DELETE([resources_path, id].join("/"))
      res.body
    end

    private
    def resource_name_in_json
      @resource_name_in_json  ||= resource_name.sub(/^os-/, "").tr("-", "_")
    end

    def resources_name_in_json
      @resources_name_in_json ||= resources_name.sub(/^os-/, "").tr("-", "_")
    end

    def return_resource(d)
      new(d)
    end

    def return_resources(arr)
      arr.map{|d| return_resource(d) }
    end
  end
end