class PhusionPassenger::Rails3Extensions::AnalyticsLogging

def self.install!(options)
	analytics_logger = options["analytics_logger"]
	return false if !analytics_logger || !options["analytics"]
	
	# If the Ruby interpreter supports GC statistics then turn it on
	# so that the info can be logged.
	GC.enable_stats if GC.respond_to?(:enable_stats)
	
	subscriber = self.new
	AnalyticsLogging.attach_to(:action_controller, subscriber)
	AnalyticsLogging.attach_to(:active_record, subscriber)
	if defined?(ActiveSupport::Cache::Store)
		ActiveSupport::Cache::Store.instrument = true
		AnalyticsLogging.attach_to(:active_support, subscriber)
	end
	
	if defined?(ActionDispatch::ShowExceptions)
		Rails.application.middleware.insert_after(
			ActionDispatch::ShowExceptions,
			ExceptionLogger, analytics_logger)
	end
	
	if defined?(ActionController::Base)
		ActionController::Base.class_eval do
			include ACExtension
		end
	end
	
	if defined?(ActiveSupport::Benchmarkable)
		ActiveSupport::Benchmarkable.class_eval do
			include ASBenchmarkableExtension
			alias_method_chain :benchmark, :passenger
		end
	end
	
	return true
end

def cache_fetch_hit(event)
	PhusionPassenger.log_cache_hit(nil, event.payload[:key])
end

def cache_generate(event)
	PhusionPassenger.log_cache_miss(nil, event.payload[:key],
		event.duration * 1000)
end

def cache_read(event)
	if event.payload[:hit]
		PhusionPassenger.log_cache_hit(nil, event.payload[:key])
	else
		PhusionPassenger.log_cache_miss(nil, event.payload[:key])
	end
end

def process_action(event)
	log = Thread.current[PASSENGER_ANALYTICS_WEB_LOG]
	if log
		view_runtime = event.payload[:view_runtime]
		log.message("View rendering time: #{(view_runtime * 1000).to_i}") if view_runtime
	end
end

def sql(event)
	log = Thread.current[PASSENGER_ANALYTICS_WEB_LOG]
	if log
		name = event.payload[:name]
		sql = event.payload[:sql]
		digest = Digest::MD5.hexdigest("#{name}\0#{sql}\0#{rand}")
		log.measured_time_points("DB BENCHMARK: #{digest}",
			event.time, event.end, "#{name}\n#{sql}")
	end
end