add testcase for http method

Author: HatsuneMiku3939

test/helper/stub_server.rb

@@ -1,5 +1,17 @@
 require 'webrick'
 
+class DeleteService < WEBrick::HTTPServlet::AbstractServlet
+  def service(req, res)
+    if req.request_method != "DELETE"
+      res.status = 405
+    else
+      res.status = 200
+      res['Content-Type'] = 'application/json'
+      res.body = '{ "status": "OK" }'
+    end
+  end
+end
+
 class StubServer
   def initialize
     create_server
@@ -12,6 +24,9 @@ def initialize
     @server.mount_proc '/redirect', &method(:redirect)
     @server.mount_proc '/protected', &method(:protected)
     @server.mount_proc '/custom_header', &method(:custom_header)
+
+    @server.mount_proc '/method_post', &method(:method_post)
+    @server.mount '/method_delete', DeleteService
   end
 
   def start
@@ -90,4 +105,15 @@ def custom_header(req, res)
     res['Content-Type'] = 'application/json'
     res.body = '{ "status": "OK" }'
   end
+
+  def method_post(req, res)
+    if req.request_method != "POST"
+      res.status = 405
+    else
+      res.status = 200
+      res['Content-Type'] = 'application/json'
+      res.body = '{ "status": "OK" }'
+    end
+  end
 end
+

test/plugin/test_in_http_pull.rb

@@ -563,6 +563,62 @@ class HttpPullInputTest < Test::Unit::TestCase
     end
   end
 
+  sub_test_case "request method" do
+    TEST_INTERVAL_3_POST = %[
+      tag test
+      url http://127.0.0.1:3939/method_post
+
+      interval 3s
+      format json
+      http_method post
+    ]
+
+    TEST_INTERVAL_3_DELETE = %[
+      tag test
+      url http://127.0.0.1:3939/method_delete
+
+      interval 3s
+      format json
+      http_method delete
+    ]
+
+    test 'interval 3 with :post' do
+      d = create_driver TEST_INTERVAL_3_POST
+      assert_equal("test", d.instance.tag)
+      assert_equal(3, d.instance.interval)
+
+      d.run(timeout: 8) do
+        sleep 7
+      end
+      assert_equal(2, d.events.size)
+
+      d.events.each do |tag, time, record|
+        assert_equal("test", tag)
+
+        assert_equal({"url"=>"http://127.0.0.1:3939/method_post","status"=>200, "message"=>{"status"=>"OK"}}, record)
+        assert(time.is_a?(Fluent::EventTime))
+      end
+    end
+
+    test 'interval 3 with :delete' do
+      d = create_driver TEST_INTERVAL_3_DELETE
+      assert_equal("test", d.instance.tag)
+      assert_equal(3, d.instance.interval)
+
+      d.run(timeout: 8) do
+        sleep 7
+      end
+      assert_equal(2, d.events.size)
+
+      d.events.each do |tag, time, record|
+        assert_equal("test", tag)
+
+        assert_equal({"url"=>"http://127.0.0.1:3939/method_delete","status"=>200, "message"=>{"status"=>"OK"}}, record)
+        assert(time.is_a?(Fluent::EventTime))
+      end
+    end
+  end
+
   private
 
   def create_driver(conf)