Contents

class ThinkingSphinx::ActiveRecord::Callbacks::DeltaCallbacks <
  ThinkingSphinx::Callbacks

  callbacks :after_commit, :before_save

  def after_commit
    return unless delta_indices? && processors.any? { |processor|
      processor.toggled?(instance)
    } && !ThinkingSphinx::Deltas.suspended?

    delta_indices.each do |index|
      index.delta_processor.index index
    end

    core_indices.each do |index|
      index.delta_processor.delete index, instance
    end
  end

  def before_save
    return unless delta_indices?

    processors.each { |processor| processor.toggle instance }
  end

  private

  def config
    ThinkingSphinx::Configuration.instance
  end

  def core_indices
    @core_indices ||= indices.reject { |index| index.delta? }
  end

  def delta_indices
    @delta_indices ||= indices.select { |index| index.delta? }
  end

  def delta_indices?
    delta_indices.any?
  end

  def indices
    @indices ||= config.indices_for_references reference
  end

  def processors
    delta_indices.collect &:delta_processor
  end

  def reference
    instance.class.name.underscore.to_sym
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
thinking-sphinx-3.0.0	lib/thinking_sphinx/active_record/callbacks/delta_callbacks.rb
thinking-sphinx-3.0.0.rc	lib/thinking_sphinx/active_record/callbacks/delta_callbacks.rb
thinking-sphinx-3.0.0.pre	lib/thinking_sphinx/active_record/callbacks/delta_callbacks.rb