[#449] Added support for URL parameters such as refresh or `consist…

…ency` in the Index#bulk API

lib/tire/index.rb

@@ -130,7 +130,13 @@ def bulk(action, documents, options={})
       count = 0
 
       begin
-        @response = Configuration.client.post("#{url}/_bulk", payload.join("\n"))
+        params = {}
+        params[:consistency] = options.delete(:consistency)
+        params[:refresh]     = options.delete(:refresh)
+        params               = params.reject { |name,value| !value }
+        params_encoded       = params.empty? ? '' : "?#{params.to_param}"
+
+        @response = Configuration.client.post("#{url}/_bulk#{params_encoded}", payload.join("\n"))
         raise RuntimeError, "#{@response.code} > #{@response.body}" if @response && @response.failure?
         @response
       rescue StandardError => error

test/unit/index_test.rb

@@ -578,6 +578,23 @@ class MyDocument;end; document = MyDocument.new
 
         end
 
+        should "pass URL parameters such as refresh or consistency" do
+          Configuration.client.
+            expects(:post).
+            with do |url, payload|
+              # p url
+              assert_match /\?consistency=one/, url
+              assert_match /&refresh=true/, url
+            end.
+            returns(mock_response('{}'), 200)
+
+          @index.bulk :index,
+                      [ {:id => '1', :title => 'One' } ],
+                      :consistency => 'one',
+                      :refresh => true
+
+        end
+
         should "serialize ActiveModel instances as payload" do
           Configuration.client.
             expects(:post).