Contents

# A simple job for flagging a specified Sphinx document in a given index as
# 'deleted'.
#  
class ThinkingSphinx::Deltas::FlagAsDeletedJob
  attr_accessor :indexes, :document_id
  
  # Initialises the object with an index name and document id. Please note that
  # the document id is Sphinx's unique identifier, and will almost certainly not
  # be the model instance's primary key value.
  # 
  # @param [String] index The index name
  # @param [Integer] document_id The document id
  # 
  def initialize(indexes, document_id)
    @indexes, @document_id = indexes, document_id
  end
  
  # Updates the sphinx_deleted attribute for the given document, setting the
  # value to 1 (true). This is not a special attribute in Sphinx, but is used
  # by Thinking Sphinx to ignore deleted values between full re-indexing. It's
  # particularly useful in this situation to avoid old values in the core index
  # and just use the new values in the delta index as a reference point.
  # 
  # @return [Boolean] true
  # 
  def perform
    config = ThinkingSphinx::Configuration.instance
    
    indexes.each do |index|
      config.client.update(
        index,
        ['sphinx_deleted'],
        {@document_id => [1]}
      ) if ThinkingSphinx.sphinx_running? &&
        ThinkingSphinx::Search.search_for_id(@document_id, index)
    end
    
    true
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
warp-ts-delayed-delta-1.0.3	lib/thinking_sphinx/deltas/delayed_delta/flag_as_deleted_job.rb
warp-ts-delayed-delta-1.0.2	lib/thinking_sphinx/deltas/delayed_delta/flag_as_deleted_job.rb
ts-delayed-delta-1.0.2	lib/thinking_sphinx/deltas/delayed_delta/flag_as_deleted_job.rb
ts-delayed-delta-1.0.1	lib/thinking_sphinx/deltas/delayed_delta/flag_as_deleted_job.rb