Contents

class ThinkingSphinx::ActiveRecord::Callbacks::UpdateCallbacks <
  ThinkingSphinx::Callbacks

  callbacks :after_update

  def after_update
    return unless updates_enabled?

    indices.each do |index|
      update index
    end
  end

  private

  def attributes_hash_for(index)
    updateable_attributes_for(index).inject({}) do |hash, attribute|
      if instance.changed.include?(attribute.columns.first.__name.to_s)
        hash[attribute.name] = attribute.value_for(instance)
      end

      hash
    end
  end

  def configuration
    ThinkingSphinx::Configuration.instance
  end

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

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

  def update(index)
    attributes = attributes_hash_for(index)
    return if attributes.empty?

    sphinxql = Riddle::Query.update(
      index.name, index.document_id_for_key(instance.id), attributes
    )
    ThinkingSphinx::Connection.new.execute(sphinxql)
  rescue Mysql2::Error => error
    # This isn't vital, so don't raise the error.
  end

  def updateable_attributes_for(index)
    index.sources.collect(&:attributes).flatten.select { |attribute|
      attribute.updateable?
    }
  end

  def updates_enabled?
    configuration.settings['attribute_updates']
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
thinking-sphinx-3.0.4	lib/thinking_sphinx/active_record/callbacks/update_callbacks.rb
thinking-sphinx-3.0.3	lib/thinking_sphinx/active_record/callbacks/update_callbacks.rb
thinking-sphinx-3.0.2	lib/thinking_sphinx/active_record/callbacks/update_callbacks.rb
thinking-sphinx-3.0.1	lib/thinking_sphinx/active_record/callbacks/update_callbacks.rb
thinking-sphinx-3.0.0	lib/thinking_sphinx/active_record/callbacks/update_callbacks.rb
thinking-sphinx-3.0.0.rc	lib/thinking_sphinx/active_record/callbacks/update_callbacks.rb