require 'net/http'
require 'uri'
require 'json'
require 'yaml'
require 'addressable/uri'

module Onering
  module API
    module Errors
      class NotConnected < Exception; end
      class ClientError < Exception; end
      class ServerError < Exception; end
    end

    class Base
      DEFAULT_BASE="http://onering"
      DEFAULT_PATH="/api"
      DEFAULT_OPTIONS={}

      class<<self

        def connect(host=nil)
          if host.is_a?(URI)
            @_uri = host
          elsif host.is_a?(String)
            @_uri = Addressable::URI.parse("#{host}/#{DEFAULT_PATH}")
          else
            @_uri = Addressable::URI.parse("#{DEFAULT_BASE}/#{DEFAULT_PATH}")
          end


          if @_uri
            @_http = Net::HTTP.new(@_uri.host, @_uri.port)
          end
        end

        def request(endpoint, options={})
          options = DEFAULT_OPTIONS.merge(options)
          request = nil

          uri = Addressable::URI.parse("#{@_uri.to_s}/#{endpoint}")
          uri.query_values = options[:fields] if options[:fields]

          raise Errors::NotConnected unless @_http

          #STDERR.puts "DEBUG: Request #{options[:method].to_s.upcase} #{uri.normalize.to_s}"

          case options[:method]
          when :post
            request = Net::HTTP::Post.new(uri.request_uri)
            request.body = options[:data].to_json if options[:data]

          when :delete
            request = Net::HTTP::Delete.new(uri.request_uri)

          else
            request = Net::HTTP::Get.new(uri.request_uri)

          end

          response = @_http.request(request)

          if response.code.to_i >= 400
            rv = JSON.load(response.body) unless response.body.empty?

            if rv['errors']
              msg = "#{rv['errors']['type']}: #{rv['errors']['message']}"
            end

            if response.code.to_i >= 500
              raise Errors::ServerError.new("HTTP #{response.code}: #{msg}")
            else
              raise Errors::ClientError.new("HTTP #{response.code}: #{msg}")
            end
          else
            if response['Content-Type'] == 'application/json'
              rv = (response.body.empty? ? nil : JSON.load(response.body))
            else
              rv = response.body
            end
          end

          rv
        end

        def make_filter(filter)
          filter = filter.collect{|k,v| "#{k}/#{v}" } if filter.is_a?(Hash)
          filter = filter.collect{|i| i.sub(':','/') }.join("/") if filter.is_a?(Array)
          filter
        end

        def echo(obj)
          if obj.is_a?(Array)
            obj.each do |i|
              puts i
            end
          end
        end
      end
    end
  end
end