tire multisearch implementation

gistfile1.rb

module Tire
  module Search
    class Search
      attr_reader :types
    end

    class MultiSearch

      def initialize(searches, options ={})
        @searches = searches
        @options = options
      end

      def to_payload
        payload = @searches.each_with_object([]) do |search, result|
          result << {:index => search.indices, :types => search.types}.to_json
          result << search.to_json
        end
        payload << ""
        payload.join("\n")
      end

      def results
        @results  || (perform; @results)
      end

      def perform
        response = Configuration.client.post("#{Configuration.url}/_msearch", to_payload)
        json     = MultiJson.decode(response.body)

        @results = json['responses'].each_with_index.collect do |response_json, index|
          Results::Collection.new(response_json, @options.merge(@searches[index].options))
        end
      end
    end
  end
end

I was checking it with tcpdump at the time, and was observing SYN packets. Perhaps there was something different in my setup... Is curb's persistent connection handling thread safe?

Will this get rolled into Tire? For now I am gonna use the bits I need to make a multisearch request via RestClient manually until that happens.

Yes, multi search support is now available in Tire 0.5.0/master:

• Documentation, http://karmi.github.com/tire/doc/Tire/DSL.html#multi_search-instance_method
• Changes, karmi/retire@2df5d18...b63696e