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

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

    class Base
      class<<self
        DEFAULT_URI="http://onering/api"
        DEFAULT_OPTIONS={}

        def connect(host=nil)
          if host.is_a?(URI)
            @_uri = host
          elsif host.is_a?(String)
            @_uri = URI.parse(host)
          else
            @_uri = URI.parse(DEFAULT_URI)
          end


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

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

          qs = options[:fields].collect{|k,v| "#{k}=#{v}" }.join("&") if options[:fields]
          qs = nil if qs and qs.empty?
          endpoint = [endpoint, qs].compact.join('?')
          uri = URI.parse("#{@_uri.to_s}/#{endpoint}")

          raise Errors::NotConnected unless @_http

          case options[:method]
          when :post
            request = Net::HTTP::Post.new(uri.request_uri)
            request.body = JSON.dump(options[:data]) 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)

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

            raise ClientError.new(msg)
          else
            rv = JSON.load(response.body)
          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