Sha256: 708fb70700ec940e32b4dfe3519ab846d583e84dc9442624199261f04559f2df
Contents?: true
Size: 1.86 KB
Versions: 3
Compression:
Stored size: 1.86 KB
Contents
# frozen_string_literal: true if defined?(Excon) module Excon class Socket alias orig_connect connect def connect host = @data[:proxy] ? @data[:proxy][:host] : @data[:host] port = @data[:proxy] ? @data[:proxy][:port] : @data[:port] HttpLog.log_connection(host, port) orig_connect end end class Connection def _httplog_url(datum) "#{datum[:scheme]}://#{datum[:host]}:#{datum[:port]}#{datum[:path]}#{datum[:query]}" end alias orig_request request def request(params, &block) result = nil bm = Benchmark.realtime do result = orig_request(params, &block) end datum = @data.merge(params) datum[:headers] = @data[:headers].merge(datum[:headers] || {}) url = _httplog_url(datum) if HttpLog.url_approved?(url) HttpLog.log_compact(datum[:method], url, datum[:status] || result.status, bm) HttpLog.log_benchmark(bm) end result end alias orig_request_call request_call def request_call(datum) url = _httplog_url(datum) if HttpLog.url_approved?(url) HttpLog.log_request(datum[:method], _httplog_url(datum)) HttpLog.log_headers(datum[:headers]) HttpLog.log_data(datum[:body]) # if datum[:method] == :post end orig_request_call(datum) end alias orig_response response def response(datum = {}) return orig_response(datum) unless HttpLog.url_approved?(_httplog_url(datum)) datum = orig_response(datum) response = datum[:response] headers = response[:headers] || {} HttpLog.log_status(response[:status]) HttpLog.log_headers(headers) HttpLog.log_body(response[:body], headers['Content-Encoding'], headers['Content-Type']) datum end end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
httplog-1.1.1 | lib/httplog/adapters/excon.rb |
httplog-1.1.0 | lib/httplog/adapters/excon.rb |
httplog-1.0.3 | lib/httplog/adapters/excon.rb |