Contents

require 'excon'

module Inquisitio
  class Indexer

    def self.index(documents)
      new(documents).index
    end

    def initialize(documents)
      raise InquisitioError.new("Document(s) is null") if documents.nil?
      raise InquisitioError.new("Document(s) is empty") unless documents.any?

      @documents = documents
    end

    def index
      Inquisitio.config.logger.info "Indexer posting to #{batch_index_url}"
      if Inquisitio.config.dry_run
        Inquisitio.config.logger.info "Skipping POST as running in dry-run mode"
      else
        post_to_endpoint
      end
    end

    private

    def body
      @body ||= "[#{@documents.map(&:to_sdf).join(", ")}]"
    end

    def batch_index_url
      "#{Inquisitio.config.document_endpoint}/#{Inquisitio.config.api_version}/documents/batch"
    end
      
    def post_to_endpoint
      response = Excon.post(batch_index_url,
                           :body => body,
                           :headers => {"Content-Type" =>"application/json"})
      Inquisitio.config.logger.info "Response - status: #{response.status}"
      raise InquisitioError.new("Index failed with status code: #{response.status} Message: #{response.body}") unless response.status == 200
      response.body
    end    
    
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
inquisitio-2.1.2	lib/inquisitio/indexer.rb
inquisitio-2.1.1	lib/inquisitio/indexer.rb
inquisitio-2.1.0	lib/inquisitio/indexer.rb
inquisitio-2.0.0	lib/inquisitio/indexer.rb