# frozen_string_literal: true module Karafka module Instrumentation # Default logger for Event Delegator # @note It uses ::Logger features - providing basic logging class Logger < ::Logger # Map containing information about log level for given environment ENV_MAP = { 'production' => ::Logger::ERROR, 'test' => ::Logger::ERROR, 'development' => ::Logger::INFO, 'debug' => ::Logger::DEBUG, 'default' => ::Logger::INFO }.freeze private_constant :ENV_MAP # Creates a new instance of logger ensuring that it has a place to write to # @param _args Any arguments that we don't care about but that are needed in order to # make this logger compatible with the default Ruby one def initialize(*_args) ensure_dir_exists super(target) self.level = ENV_MAP[Karafka.env] || ENV_MAP['default'] end private # @return [Karafka::Helpers::MultiDelegator] multi delegator instance # to which we will be writing logs # We use this approach to log stuff to file and to the STDOUT at the same time def target Karafka::Helpers::MultiDelegator .delegate(:write, :close) .to(STDOUT, file) end # Makes sure the log directory exists as long as we can write to it def ensure_dir_exists FileUtils.mkdir_p(File.dirname(log_path)) rescue Errno::EACCES nil end # @return [Pathname] Path to a file to which we should log def log_path @log_path ||= Karafka::App.root.join("log/#{Karafka.env}.log") end # @return [File] file to which we want to write our logs # @note File is being opened in append mode ('a') def file @file ||= File.open(log_path, 'a') end end end end