Contents

# frozen_string_literal: true

class ThinkingSphinx::Callbacks::Appender
  def self.call(model, reference, options, &block)
    new(model, reference, options, &block).call
  end

  def initialize(model, reference, options, &block)
    @model = model
    @reference = reference
    @options = options
    @block = block
  end

  def call
    add_core_callbacks
    add_delta_callbacks     if behaviours.include?(:deltas)
    add_real_time_callbacks if behaviours.include?(:real_time)
    add_update_callbacks    if behaviours.include?(:updates)
  end

  private

  attr_reader :model, :reference, :options, :block

  def add_core_callbacks
    model.after_commit(
      ThinkingSphinx::ActiveRecord::Callbacks::DeleteCallbacks,
      on: :destroy
    )
  end

  def add_delta_callbacks
    if path.empty?
      model.before_save  ThinkingSphinx::ActiveRecord::Callbacks::DeltaCallbacks
      model.after_commit ThinkingSphinx::ActiveRecord::Callbacks::DeltaCallbacks
    else
      model.after_commit(
        ThinkingSphinx::ActiveRecord::Callbacks::AssociationDeltaCallbacks
          .new(path)
      )
    end
  end

  def add_real_time_callbacks
    model.after_commit(
      ThinkingSphinx::RealTime.callback_for(reference, path, &block),
      on: [:create, :update]
    )
  end

  def add_update_callbacks
    model.after_update ThinkingSphinx::ActiveRecord::Callbacks::UpdateCallbacks
  end

  def behaviours
    options[:behaviours] || []
  end

  def path
    options[:path] || []
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
thinking-sphinx-5.6.0	lib/thinking_sphinx/callbacks/appender.rb
thinking-sphinx-5.5.1	lib/thinking_sphinx/callbacks/appender.rb
thinking-sphinx-5.5.0	lib/thinking_sphinx/callbacks/appender.rb
thinking-sphinx-5.4.0	lib/thinking_sphinx/callbacks/appender.rb
thinking-sphinx-5.3.0	lib/thinking_sphinx/callbacks/appender.rb