lib/alephant/publisher/request/data_mapper.rb in alephant-publisher-request-0.1.2 vs lib/alephant/publisher/request/data_mapper.rb in alephant-publisher-request-0.2.0

- old
+ new

@@ -1,14 +1,11 @@ -require 'alephant/logger' require 'json' module Alephant module Publisher module Request class DataMapper - include Logger - attr_reader :connection, :context def initialize(connection, context = {}) @connection = connection @context = context @@ -19,26 +16,10 @@ end protected def get(uri) - before = Time.new - response = connection.get(uri) - logger.metric(:name => "PublisherRequestDataMapperRequestHTTPTime", :unit => 'Seconds', :value => Time.new - before) - raise InvalidApiStatus, response.status unless response.status == 200 - JSON::parse(response.body, :symbolize_names => true) - rescue Faraday::ConnectionFailed - logger.metric(:name => "PublisherRequestDataMapperConnectionFailed", :unit => "Count", :value => 1) - raise ConnectionFailed - rescue JSON::ParserError - logger.metric(:name => "PublisherRequestDataMapperInvalidApiResponse", :unit => "Count", :value => 1) - raise InvalidApiResponse, "JSON parsing error: #{response.body}" - rescue InvalidApiStatus => e - logger.metric(:name => "PublisherRequestDataMapperInvalidStatus#{e.status}", :unit => "Count", :value => 1) - raise e - rescue StandardError => e - logger.metric(:name => "PublisherRequestDataMapperApiError", :unit => "Count", :value => 1) - raise ApiError, e.message + connection.get uri end end end end end