Sha256: 92791b17e9752f9769d5042724362bbe7e0c62b79224b57d8809f5d61ab6601d

Contents?: true

Size: 1.1 KB

Versions: 17

Compression:

Stored size: 1.1 KB

Contents

# frozen_string_literal: true

module ThinkingSphinx::Deltas
  def self.config
    ThinkingSphinx::Configuration.instance
  end

  def self.processor_for(delta)
    case delta
    when TrueClass
      ThinkingSphinx::Deltas::DefaultDelta
    when Class
      delta
    when String
      delta.constantize
    else
      nil
    end
  end

  def self.resume!
    @suspended = false
  end

  def self.suspend(reference, &block)
    suspend!
    yield
    resume!

    config.indices_for_references(reference).each do |index|
      index.delta_processor.index index if index.delta?
    end
  end

  def self.suspend_and_update(reference, &block)
    suspend reference, &block

    ids = reference.to_s.camelize.constantize.where(delta: true).pluck(:id)
    config.indices_for_references(reference).each do |index|
      ThinkingSphinx::Deletion.perform index, ids unless index.delta?
    end
  end

  def self.suspend!
    @suspended = true
  end

  def self.suspended?
    @suspended
  end
end

require 'thinking_sphinx/deltas/default_delta'
require 'thinking_sphinx/deltas/delete_job'
require 'thinking_sphinx/deltas/index_job'

Version data entries

17 entries across 17 versions & 1 rubygems

Version Path
thinking-sphinx-5.6.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.5.1 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.5.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.4.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.3.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.2.1 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.2.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.1.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-5.0.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.4.1 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.4.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.3.2 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.3.1 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.3.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.2.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.1.0 lib/thinking_sphinx/deltas.rb
thinking-sphinx-4.0.0 lib/thinking_sphinx/deltas.rb