Combined delta updates

gistfile1.rb

# Usage: UserAndRelationshipDelta.perform_async user.id
#
class UserAndRelationshipDelta
  include Sidekiq::Worker
  
  def perform(user_id)
    # Set delta flags
    User.update_all({delta: true}, {id: user_id})
    Relationship.update_all({delta: true}, {user_id: user_id})

    # Process delta indices
    configuration = ThinkingSphinx::Configuration.instance
    configuration.controller.index 'user_delta', 'relationship_delta'

    # Mark non-delta user record as deleted
    configuration.indices_for_references(:user).reject(&:delta?).each do |index|
      ThinkingSphinx::Connection.new.execute Riddle::Query.update(
        index.name, index.document_id_for_key(user_id), sphinx_deleted: true
      )
    end
    
    # Mark non-delta relationship records as deleted
    indices = configuration.indices_for_references(:relationship)
    indices.reject(&:delta?).each do |index|
      Relationship.where(user_id: user_id).pluck(:id).each do |id|
        ThinkingSphinx::Connection.new.execute Riddle::Query.update(
          index.name, index.document_id_for_key(id), sphinx_deleted: true
        )
      end
    end
  end
end