require_relative '../helper' require 'fluent/configurable' require 'fluent/config/element' require 'fluent/config/section' require 'fluent/system_config' module Fluent::Config class FakeLoggerInitializer attr_accessor :level def initalize @level = nil end end class FakeSupervisor def initialize @log = FakeLoggerInitializer.new @log_level = nil @suppress_interval = nil @suppress_config_dump = nil @suppress_repeated_stacktrace = nil @without_source = nil end end class TestSystemConfig < ::Test::Unit::TestCase def parse_text(text) basepath = File.expand_path(File.dirname(__FILE__) + '/../../') Fluent::Config.parse(text, '(test)', basepath, true).elements.find { |e| e.name == 'system' } end test 'should not override default configurations when no parameters' do conf = parse_text(<<-EOS) EOS s = FakeSupervisor.new sc = Fluent::SystemConfig.new(conf) sc.apply(s) assert_nil(sc.log_level) assert_nil(sc.suppress_repeated_stacktrace) assert_nil(sc.emit_error_log_interval) assert_nil(sc.suppress_config_dump) assert_nil(sc.without_source) assert_nil(s.instance_variable_get(:@log_level)) assert_nil(s.instance_variable_get(:@suppress_repeated_stacktrace)) assert_nil(s.instance_variable_get(:@emit_error_log_interval)) assert_nil(s.instance_variable_get(:@suppress_config_dump)) assert_nil(s.instance_variable_get(:@without_source)) end {'log_level' => 'error', 'suppress_repeated_stacktrace' => true, 'emit_error_log_interval' => 60, 'suppress_config_dump' => true, 'without_source' => true, }.each { |k, v| test "accepts #{k} parameter" do conf = parse_text(<<-EOS) #{k} #{v} EOS s = FakeSupervisor.new sc = Fluent::SystemConfig.new(conf) sc.apply(s) assert_not_nil(sc.instance_variable_get("@#{k}")) key = (k == 'emit_error_log_interval' ? 'suppress_interval' : k) assert_not_nil(s.instance_variable_get("@#{key}")) end } {'foo' => 'bar', 'hoge' => 'fuga'}.each { |k, v| test "should not affect settable parameters with unknown #{k} parameter" do s = FakeSupervisor.new sc = Fluent::SystemConfig.new({k => v}) sc.apply(s) assert_nil(s.instance_variable_get(:@log_level)) assert_nil(s.instance_variable_get(:@suppress_repeated_stacktrace)) assert_nil(s.instance_variable_get(:@emit_error_log_interval)) assert_nil(s.instance_variable_get(:@suppress_config_dump)) assert_nil(s.instance_variable_get(:@without_source)) end } test 'log_level' do conf = parse_text(<<-EOS) log_level warn EOS s = FakeSupervisor.new sc = Fluent::SystemConfig.new(conf) sc.apply(s) assert_equal(Fluent::Log::LEVEL_WARN, s.instance_variable_get("@log").level) end end end