lib/alephant/publisher/request/connection.rb in alephant-publisher-request-0.2.3 vs lib/alephant/publisher/request/connection.rb in alephant-publisher-request-0.2.4

- old
+ new

@@ -14,33 +14,33 @@ end def get(uri) JSON::parse(request(uri).body, :symbolize_names => true) rescue Faraday::ConnectionFailed => e - log_error_with_metric(e, 'DataMapper#request', uri, "PublisherRequestDataMapperConnectionFailed") + log_error_with_metric(e, 'Connection#request', uri, "PublisherRequestConnectionConnectionFailed") raise ConnectionFailed rescue InvalidApiStatus => e - log_error_with_metric(e, 'DataMapper#request', uri, "PublisherRequestDataMapperInvalidStatus#{e.status}") + log_error_with_metric(e, 'Connection#request', uri, "PublisherRequestConnectionInvalidStatus#{e.status}") raise e rescue JSON::ParserError => e - log_error_with_metric(e, 'DataMapper#get', uri, "PublisherRequestDataMapperInvalidApiResponse") + log_error_with_metric(e, 'Connection#get', uri, "PublisherRequestConnectionInvalidApiResponse") raise InvalidApiResponse, "JSON parsing error: #{response.body}" rescue StandardError => e - log_error_with_metric(e, 'DataMapper#get', uri, "PublisherRequestDataMapperApiError") + log_error_with_metric(e, 'Connection#get', uri, "PublisherRequestConnectionApiError") raise ApiError, e.message end private def request(uri) before = Time.new - logger.info "Publisher::Request::DataMapper#request: uri: #{uri}" + logger.info "Publisher::Request::Connection#request: uri: #{uri}" driver.get(uri).tap do |response| response_time = Time.new - before - logger.metric(:name => "PublisherRequestDataMapperRequestHTTPTime", :unit => 'Seconds', :value => response_time) - logger.info "Publisher::Request::DataMapper#request: API response time: #{response_time}" - logger.info "Publisher::Request::DataMapper#request: status returned: #{response.status} for #{uri}" + logger.metric(:name => "PublisherRequestConnectionRequestHTTPTime", :unit => 'Seconds', :value => response_time) + logger.info "Publisher::Request::Connection#request: API response time: #{response_time}" + logger.info "Publisher::Request::Connection#request: status returned: #{response.status} for #{uri}" raise InvalidApiStatus, response.status unless response.status == 200 end end end end