module Keen
  module HTTP
    class Sync
      def initialize(base_url, proxy_url=nil, read_timeout=nil)
        require 'uri'
        require 'net/http'

        uri = URI.parse(base_url)
        arguments = [uri.host, uri.port]
        arguments+= proxy_arguments_for(proxy_url) if proxy_url

        @http = Net::HTTP.new(*arguments)
        @http.read_timeout = read_timeout if read_timeout

        if uri.scheme == "https"
          require 'net/https'
          @http.use_ssl = true;
          @http.verify_mode = OpenSSL::SSL::VERIFY_PEER
          @http.verify_depth = 5
          @http.ca_file = File.expand_path("../../../config/cacert.pem", __FILE__)
        end
      end

      def proxy_arguments_for(uri)
        proxy_uri = URI.parse(uri)
        [proxy_uri.host, proxy_uri.port, proxy_uri.user, proxy_uri.password]
      end

      def post(options)
        path, headers, body = options.values_at(
          :path, :headers, :body)
        @http.post(path, body, headers)
      end

      def put(options)
        path, headers, body = options.values_at(
          :path, :headers, :body)
        @http.put(path, body, headers)
      end

      def get(options)
        path, headers = options.values_at(
          :path, :headers)
        @http.get(path, headers)
      end

      def delete(options)
        path, headers = options.values_at(
          :path, :headers)
        @http.delete(path, headers)
      end
    end

    class Async
      def initialize(base_url, options={})
        if defined?(EventMachine) && EventMachine.reactor_running?
          require 'em-http-request'
        else
          raise Error, "An EventMachine loop must be running to use publish_async calls"
        end

        @base_url = base_url
        @proxy_url, @proxy_type = options.values_at(:proxy_url, :proxy_type)
      end

      def post(options)
        path, headers, body = options.values_at(
          :path, :headers, :body)
        uri = "#{@base_url}#{path}"
        if @proxy_url
          proxy_uri = URI.parse(@proxy_url)
          connection_options = {:proxy =>
                                    {:host => proxy_uri.host,
                                     :port => proxy_uri.port,
                                     :authorization => [proxy_uri.user, proxy_uri.password],
                                     :type => @proxy_type || "http"}}
          http_client = EventMachine::HttpRequest.new(uri, connection_options)
        else
          http_client = EventMachine::HttpRequest.new(uri)
        end
        http_client.post(
          :body => body,
          :head => headers
        )

      end
    end
  end
end