test_out_map.rb in fluent-plugin-map-0.0.6

- old
+ new

@@ -14,27 +14,27 @@
     Fluent::Test::OutputTestDriver.new(Fluent::MapOutput, tag).configure(conf)
   end
 
   def test_tag_convert
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code' => '300'}
 
     d1 = create_driver %[
       map ["newtag", time, record]
     ], tag
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 1, emits.length
-    assert_equal ["newtag", time.to_i, record], emits[0]
+    assert_equal ["newtag", time, record], emits[0]
   end
 
   def test_convert_multi_tag
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code' => '300'}
 
     d1 = create_driver %[
       map [["tag1", time, record], ["tag2", time, record]]
       multi true
@@ -42,49 +42,49 @@
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 2, emits.length
-    assert_equal ["tag1", time.to_i, record], emits[0]
-    assert_equal ["tag2", time.to_i, record], emits[1]
+    assert_equal ["tag1", time, record], emits[0]
+    assert_equal ["tag2", time, record], emits[1]
   end
 
   def test_syntax_error
     tag = "tag"
-    time = Time.local(2012, 10, 10, 10, 10, 0)
+    time = Time.local(2012, 10, 10, 10, 10, 0).to_i
     record = {'code' => '300'}
 
     #map is syntax error
     syntax_error_config = %[
       map tag.
     ]
     d1 = create_driver(syntax_error_config, tag)
-    es = Fluent::OneEventStream.new(time.to_i, record)
+    es = Fluent::OneEventStream.new(time, record)
     chain = Fluent::Test::TestOutputChain.new
     e =  d1.instance.emit(tag, es, chain)
     assert e.kind_of?(SyntaxError)
   end
 
   def test_syntax_error2
     tag = "tag"
-    time = Time.local(2012, 10, 10, 10, 10, 0)
+    time = Time.local(2012, 10, 10, 10, 10, 0).to_i
     record = {'code' => '300'}
 
     #map output lligal format
     syntax_error_config = %[
       map tag
     ]
     d1 = create_driver(syntax_error_config, tag)
-    es = Fluent::OneEventStream.new(time.to_i, record)
+    es = Fluent::OneEventStream.new(time, record)
     chain = Fluent::Test::TestOutputChain.new
     e =  d1.instance.emit(tag, es, chain)
     assert e.kind_of?(SyntaxError)
   end
 
   def test_tag_convert_using_tag_time_record
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code' => '300'}
 
     d1 = create_driver %[
       tag "newtag"
       time time
@@ -93,17 +93,17 @@
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 1, emits.length
-    assert_equal ["newtag", time.to_i, record], emits[0]
+    assert_equal ["newtag", time, record], emits[0]
   end
 
   #deprected specification test
   def test_tag_convert_using_key_time_record
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code' => '300'}
 
     d1 = create_driver %[
       key "newtag"
       time time
@@ -112,16 +112,16 @@
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 1, emits.length
-    assert_equal ["newtag", time.to_i, record], emits[0]
+    assert_equal ["newtag", time, record], emits[0]
   end
 
   def test_config_error_tag
     tag = "tag"
-    time = Time.local(2012, 10, 10, 10, 10, 0)
+    time = Time.local(2012, 10, 10, 10, 10, 0).to_i
     record = {'code' => '300'}
 
     #require time
     assert_raise(Fluent::ConfigError){
       create_driver %[
@@ -144,11 +144,11 @@
     }
   end
 
   def test_config_error_record
     tag = "tag"
-    time = Time.local(2012, 10, 10, 10, 10, 0)
+    time = Time.local(2012, 10, 10, 10, 10, 0).to_i
 
     #require record
     assert_raise(Fluent::ConfigError){
       create_driver %[
         tag "newtag"
@@ -157,12 +157,11 @@
     }
   end
 
   def test_config_error_multi
     tag = "tag"
-    time = Time.local(2012, 10, 10, 10, 10, 0)
-    #time = Time.local(2012, 10, 10, 10, 10, 0)
+    time = Time.local(2012, 10, 10, 10, 10, 0).to_i
     record = {'code' => '300'}
 
     #require time
     assert_raise(Fluent::ConfigError){
       create_driver %[
@@ -174,11 +173,11 @@
     }
   end
 
   def test_timeout
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code' => '300'}
 
     d1 = create_driver %[
       key "newtag"
       time sleep 10
@@ -193,15 +192,15 @@
   end
 
   # Add format test
   ## test format type (map, record, maps)
   ## test Backward compatibility without format
-  ## 
+  ##
 
   def test_convert_format_map
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code1' => '300', 'code2' => '400'}
 
     d1 = create_driver %[
       format map
       map [["tag1", time, record["code1"]], ["tag2", time, record["code2"]]]
@@ -210,17 +209,17 @@
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 2, emits.length
-    assert_equal ["tag1", time.to_i, record["code1"]], emits[0]
-    assert_equal ["tag2", time.to_i, record["code2"]], emits[1]
+    assert_equal ["tag1", time, record["code1"]], emits[0]
+    assert_equal ["tag2", time, record["code2"]], emits[1]
   end
 
   def test_tag_convert_format_record
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code' => '300'}
 
     d1 = create_driver %[
       format record
       tag "newtag"
@@ -230,16 +229,16 @@
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 1, emits.length
-    assert_equal ["newtag", time.to_i, record], emits[0]
+    assert_equal ["newtag", time, record], emits[0]
   end
 
   def test_convert_format_multimap
     tag = 'tag'
-    time = Time.local(2012, 10, 10, 10, 10, 10)
+    time = Time.local(2012, 10, 10, 10, 10, 10).to_i
     record = {'code1' => '300', 'code2' => '400'}
 
     d1 = create_driver %[
       format multimap
       mmap1 ["tag1", time, record["code1"]]
@@ -248,9 +247,9 @@
     d1.run do
       d1.emit(record, time)
     end
     emits = d1.emits
     assert_equal 2, emits.length
-    assert_equal ["tag1", time.to_i, record["code1"]], emits[0]
-    assert_equal ["tag2", time.to_i, record["code2"]], emits[1]
+    assert_equal ["tag1", time, record["code1"]], emits[0]
+    assert_equal ["tag2", time, record["code2"]], emits[1]
   end
 end