log/console_adapter: Reflect log level of wrapped logger

Signed-off-by: Takuro Ashie <[email protected]>

lib/fluent/log/console_adapter.rb

@@ -20,7 +20,14 @@ module Fluent
   class Log
     class ConsoleAdapter < Console::Terminal::Logger
       def self.wrap(logger)
-        Console::Logger.new(ConsoleAdapter.new(logger))
+        _, level = Console::Logger::LEVELS.find { |key, value|
+          if logger.level <= 0
+            key == :debug
+          else
+            value == logger.level - 1
+          end
+        }
+        Console::Logger.new(ConsoleAdapter.new(logger), level: level)
       end
 
       def initialize(logger)

test/log/test_console_adapter.rb

@@ -13,7 +13,6 @@ def setup
     @logger = ServerEngine::DaemonLogger.new(@logdev)
     @fluent_log = Fluent::Log.new(@logger)
     @console_logger = Fluent::Log::ConsoleAdapter.wrap(@fluent_log)
-    @console_logger.level = :debug
   end
 
   def teardown
@@ -25,6 +24,20 @@ def test_expected_log_levels
                  Console::Logger::LEVELS)
   end
 
+  data(trace: [Fluent::Log::LEVEL_TRACE, :debug],
+       debug: [Fluent::Log::LEVEL_DEBUG, :debug],
+       info: [Fluent::Log::LEVEL_INFO, :info],
+       warn: [Fluent::Log::LEVEL_WARN, :warn],
+       error: [Fluent::Log::LEVEL_ERROR, :error],
+       fatal: [Fluent::Log::LEVEL_FATAL, :fatal])
+  def test_reflect_log_level(data)
+    level, expected = data
+    @fluent_log.level = level
+    console_logger = Fluent::Log::ConsoleAdapter.wrap(@fluent_log)
+    assert_equal(Console::Logger::LEVELS[expected],
+                 console_logger.level)
+  end
+
   data(debug: :debug,
        info: :info,
        warn: :warn,