http_server: add an accessor to read request header

lib/fluent/plugin_helper/http_server/request.rb

@@ -14,6 +14,7 @@
 #    limitations under the License.
 #
 
+require 'cgi'
 require 'async/http/protocol'
 require 'fluent/plugin_helper/http_server/methods'
 
@@ -29,6 +30,10 @@ def initialize(request)
           @path, @query_string = path.split('?', 2)
         end
 
+        def headers
+          @request.headers
+        end
+
         def query
           @query_string && CGI.parse(@query_string)
         end

test/plugin_helper/http_server/test_request.rb

@@ -0,0 +1,18 @@
+require_relative '../../helper'
+require 'flexmock/test_unit'
+require 'fluent/plugin_helper/http_server/request'
+
+class HttpHelperRequestTest < Test::Unit::TestCase
+  def test_request
+    headers = Protocol::HTTP::Headers.new({ 'Content-Type' => 'text/html', 'Content-Encoding' => 'gzip' })
+    req = flexmock('request', path: '/path?foo=42', headers: headers)
+
+    request = Fluent::PluginHelper::HttpServer::Request.new(req)
+
+    assert_equal('/path', request.path)
+    assert_equal('foo=42', request.query_string)
+    assert_equal({'foo'=>['42']}, request.query)
+    assert_equal('text/html', request.headers['content-type'])
+    assert_equal(['gzip'], request.headers['content-encoding'])
+  end
+end