Contents

module HorizonClient
  class Connection
    attr_accessor :logger

    def initialize(url = nil)
      url ||=  ENV['HORIZON_REST_URL']

      @connection = Faraday.new url do |conn|
        conn.response :raise_error
        conn.use HorizonClient::Response::ParseXml
        conn.use HorizonClient::Request::EncodeXml
        conn.options.timeout = 20
        conn.options.open_timeout = 2

        conn.adapter Faraday.default_adapter
      end
    end

    def url_prefix
      @connection.url_prefix
    end

    def get(path = '', params = {})
      log "GET #{path}", params do
        response = @connection.get path, params
        response.body
      end
    end

    def post(path = '', body)
      log "GET #{path}", {body: body} do
        response = @connection.post do |req|
          req.url path
          req.headers['Content-Type'] = 'application/xml;charset=UTF-8'
          req.body = body
        end

        response.body
      end
    end

    def log(message, params = {})
      t1 = Time.now
      response = yield
    ensure
      t2 = Time.now
      duration = (t2 - t1) / 1000
      if logger
        log_item = "Horizon (#{duration}ms) #{message}" \
                   "\nBody:" \
                   "\n#{params[:body].respond_to?(:xml) ? params[:body].xml : params[:body].inspect}" \
                   "\nResponse:" \
                   "\n#{response.respond_to?(:xml) ? response.xml : response.inspect}"
        logger.info log_item
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
horizon_client-0.2.7	lib/horizon_client/connection.rb