module NetSuite module Support class SearchResult attr_accessor :response attr_reader :total_records attr_reader :total_pages attr_reader :current_page # header from a basic customer search: # # # 2770 # 5 # 554 # 1 # WEBSERVICES_738944_SB2_03012013650784545962753432_28d96bd280 def initialize(response, result_class, credentials) @result_class = result_class @response = response @credentials = credentials @total_records = response.body[:total_records].to_i @total_pages = response.body[:total_pages].to_i @current_page = response.body[:page_index].to_i if @total_records > 0 if response.body.has_key?(:record_list) # basic search results record_list = response.body[:record_list][:record] record_list = [record_list] unless record_list.is_a?(Array) record_list.each do |record| results << result_class.new(record) end elsif response.body.has_key? :search_row_list # advanced search results record_list = response.body[:search_row_list][:search_row] record_list = [record_list] unless record_list.is_a?(Array) record_list.each do |record| # TODO because of customFieldList we need to either make this recursive # or handle the customFieldList as a special case record.each_pair do |search_group, search_data| # skip all attributes: look for :basic and all :xxx_join next if search_group.to_s.start_with?('@') record[search_group].each_pair do |k, v| # all return values are wrapped in a # extract the value from to make results easier to work with if v.is_a?(Hash) && v.has_key?(:search_value) # Here's an example of a record ref and string response # # # # # open # # in both cases, header-level field's value should be set to the # child `searchValue` result: if it's a record ref, the internalId # attribute will be transitioned to the parent, and in the case # of a string response the parent node's value will be to the string record[search_group][k] = v[:search_value] else # NOTE need to understand this case more, in testing, only the namespace definition hits this condition end end end if record[:basic][:internal_id] record[:basic][:internal_id] = record[:basic][:internal_id][:@internal_id] end result_wrapper = result_class.new(record.delete(:basic)) result_wrapper.search_joins = record results << result_wrapper end else raise "uncaught search result" end end end def results @results ||= [] end def results_in_batches return if self.total_records.zero? while @response.body[:total_pages] != @response.body[:page_index] yield results next_search = @result_class.search( { search_id: @response.body[:search_id], page_index: @response.body[:page_index].to_i + 1 }, @credentials ) @results = next_search.results @response = next_search.response @current_page = response.body[:page_index].to_i end yield results end end end end