Use compat instead of strict to follow json/yajl way. fix #1230

lib/fluent/env.rb

@@ -18,6 +18,7 @@ module Fluent
   DEFAULT_CONFIG_PATH = ENV['FLUENT_CONF'] || '/etc/fluent/fluent.conf'
   DEFAULT_PLUGIN_DIR = ENV['FLUENT_PLUGIN'] || '/etc/fluent/plugin'
   DEFAULT_SOCKET_PATH = ENV['FLUENT_SOCKET'] || '/var/run/fluent/fluent.sock'
+  DEFAULT_OJ_OPTIONS = {bigdecimal_load: :float, mode: :compat}
   IS_WINDOWS = /mswin|mingw/ === RUBY_PLATFORM
   private_constant :IS_WINDOWS
 

lib/fluent/plugin/formatter_json.rb

@@ -15,6 +15,7 @@
 #
 
 require 'fluent/plugin/formatter'
+require 'fluent/env'
 
 module Fluent
   module Plugin
@@ -29,7 +30,7 @@ def configure(conf)
         begin
           raise LoadError unless @json_parser == 'oj'
           require 'oj'
-          Oj.default_options = {mode: :compat}
+          Oj.default_options = Fluent::DEFAULT_OJ_OPTIONS
           @dump_proc = Oj.method(:dump)
         rescue LoadError
           @dump_proc = Yajl.method(:dump)

lib/fluent/plugin/parser_json.rb

@@ -15,6 +15,7 @@
 #
 
 require 'fluent/plugin/parser'
+require 'fluent/env'
 require 'fluent/time'
 
 require 'yajl'
@@ -38,7 +39,7 @@ def configure(conf)
         begin
           raise LoadError unless @json_parser == 'oj'
           require 'oj'
-          Oj.default_options = {bigdecimal_load: :float, mode: :strict}
+          Oj.default_options = Fluent::DEFAULT_OJ_OPTIONS
           @load_proc = Oj.method(:load)
           @error_class = Oj::ParseError
         rescue LoadError

test/plugin/test_formatter_json.rb

@@ -1,4 +1,5 @@
 require_relative '../helper'
+require 'json'
 require 'fluent/test/driver/formatter'
 require 'fluent/plugin/formatter_json'
 
@@ -20,11 +21,23 @@ def record
     {'message' => 'awesome'}
   end
 
+  def symbolic_record
+    {:message => :awesome}
+  end
+
   data('oj' => 'oj', 'yajl' => 'yajl')
   def test_format(data)
     d = create_driver('json_parser' => data)
     formatted = d.instance.format(tag, @time, record)
 
-    assert_equal("#{Yajl.dump(record)}\n", formatted)
+    assert_equal("#{JSON.generate(record)}\n", formatted)
+  end
+
+  data('oj' => 'oj', 'yajl' => 'yajl')
+  def test_format_with_symbolic_record(data)
+    d = create_driver('json_parser' => data)
+    formatted = d.instance.format(tag, @time, symbolic_record)
+
+    assert_equal("#{JSON.generate(record)}\n", formatted)
   end
 end

test/plugin/test_parser_json.rb

@@ -56,6 +56,14 @@ def test_parse_without_time(data)
     }
   end
 
+  data('oj' => 'oj', 'yajl' => 'yajl')
+  def test_parse_with_colon_string(data)
+    @parser.configure('json_parser' => data)
+    @parser.instance.parse('{"time":1362020400,"log":":message"}') { |time, record|
+      assert_equal(record['log'], ':message')
+    }
+  end
+
   data('oj' => 'oj', 'yajl' => 'yajl')
   def test_parse_with_invalid_time(data)
     @parser.configure('json_parser' => data)