6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
# File 'lib/active_record/connection_adapters/honeycomb_adapter.rb', line 6
def honeycomb_connection(config)
log_prefix = "ActiveRecord::ConnectionHandling#honeycomb_connection"
real_config = config.merge(adapter: config.fetch(:real_adapter))
logger = config[:honeycomb_logger]
logger ||= ::Honeycomb.logger if defined?(::Honeycomb.logger)
ConnectionAdapters::HoneycombAdapter.logger ||= logger
ConnectionAdapters::HoneycombAdapter.client ||= config[:honeycomb_client]
logger.debug "#{log_prefix} resolving real database config" if logger
resolver = ConnectionAdapters::ConnectionSpecification::Resolver.new(Base.configurations)
spec = resolver.spec(real_config)
real_connection = ::ActiveRecord::Base.send(spec.adapter_method, spec.config)
logger.debug "#{log_prefix} obtained real database connection: #{real_connection.class.name}" if logger
if real_connection.class.ancestors.include? ConnectionAdapters::HoneycombAdapter
logger.debug "#{log_prefix} found #{real_connection.class} with #{ConnectionAdapters::HoneycombAdapter} already included"
else
real_connection.class.prepend ConnectionAdapters::HoneycombAdapter
end
real_connection
end
|