Add search_pipeline to path

Signed-off-by: Tam Chau <[email protected]>

lib/opensearch/api/actions/search.rb

@@ -101,6 +101,9 @@ def search(arguments = {})
                else
                  '_search'
                end
+
+        path = "#{path}?search_pipeline=#{arguments[:body].delete(:search_pipeline)}" unless arguments.dig(:body, :search_pipeline).nil?
+
         params = Utils.__validate_and_extract_params arguments, ParamsRegistry.get(__method__)
 
         body = arguments[:body]

spec/opensearch/api/actions/search_spec.rb

@@ -124,4 +124,21 @@
       end.to raise_exception(ArgumentError)
     end
   end
+
+  context 'when a search pipeline is specified' do
+    let(:body) do
+      {
+        query: { match: {} },
+        search_pipeline: 'my_pipeline'
+      }
+    end
+    let(:method) { 'POST' }
+    let(:url) do
+      '_search?search_pipeline=my_pipeline'
+    end
+
+    it 'performs the request' do
+      expect(client_double.search(body: body))
+    end
+  end
 end