Enable millisecond precision for timestamps

Use raw Time.now.to_f instead of Engine.now until
fluent/fluentd@c9be93c
is merged or fluent/fluentd#461 resolved

Author: pgrm

clean_and_test.sh

@@ -1,3 +1,3 @@
 rm Gemfile.lock
 bundle install
-rake
+rake

fluent-plugin-logtank-http.gemspec

@@ -2,7 +2,7 @@
 
 Gem::Specification.new do |gem|
   gem.name          = "fluent-plugin-logtank-http"
-  gem.version       = '0.0.4'
+  gem.version       = '0.0.5'
 
   gem.authors       = ["Peter Grman"]
   gem.email         = ["[email protected]"]
@@ -26,4 +26,4 @@ Gem::Specification.new do |gem|
 
   gem.add_development_dependency("rake")
   gem.add_development_dependency("simplecov")
-end
+end

lib/fluent/plugin/in_logtank_http.rb

@@ -134,9 +134,13 @@ def on_request(path_info, params)
 
         time = if param_time = params['time']
                  param_time = param_time.to_i
-                 param_time.zero? ? Engine.now : param_time
+                 # Engine.now has only second-precision, use Time.now.to_f to get millisecond precision
+                 # param_time.zero? ? Engine.now : param_time
+                 param_time.zero? ? Time.now.to_f : param_time
                else
-                 record_time.nil? ? Engine.now : record_time
+                 # Engine.now has only second-precision, use Time.now.to_f to get millisecond precision
+                 # record_time.nil? ? Engine.now : record_time
+                 record_time.nil? ? Time.now.to_f : record_time
                end
       rescue
         return ["400 Bad Request", {'Content-type'=>'text/plain'}, "400 Bad Request\n#{$!}\n"]

test/plugin/test_in_logtank_http.rb

@@ -29,22 +29,26 @@ def test_configure
     assert_equal false, d.instance.add_http_headers
   end
 
-  def test_time
-    d = create_driver
-
-    time = Time.parse("2011-01-02 13:14:15 UTC").to_i
-    Fluent::Engine.now = time
-
-    d.expect_emit "tag1", time, {"a"=>1}
-    d.expect_emit "tag2", time, {"a"=>2}
-
-    d.run do
-      d.expected_emits.each {|tag,time,record|
-        res = post("/#{tag}", {"json"=>record.to_json})
-        assert_equal "200", res.code
-      }
-    end
-  end
+  # TODO: this plugin doesn't use Engine.now because it isn't precise enough.
+  #       Change back to Engine.now and uncomment this test, when
+  #       https://github.com/fluent/fluentd/commit/c9be93cfc5c6905e7b18720709e6c8d835859941
+  #       will be merged or https://github.com/fluent/fluentd/issues/461 resolved
+  # def test_time
+  #   d = create_driver
+
+  #   time = Time.parse("2011-01-02 13:14:15 UTC").to_i
+  #   Fluent::Engine.now = time
+
+  #   d.expect_emit "tag1", time, {"a"=>1}
+  #   d.expect_emit "tag2", time, {"a"=>2}
+
+  #   d.run do
+  #     d.expected_emits.each {|tag,time,record|
+  #       res = post("/#{tag}", {"json"=>record.to_json})
+  #       assert_equal "200", res.code
+  #     }
+  #   end
+  # end
 
   def test_json
     d = create_driver