Contents

# frozen_string_literal: true

class ThinkingSphinx::Subscribers::PopulatorSubscriber
  def self.attach_to(namespace)
    subscriber = new

    subscriber.public_methods(false).each do |event|
      next if event == :call

      ActiveSupport::Notifications.subscribe(
        "#{event}.#{namespace}", subscriber
      )
    end
  end

  def call(message, *args)
    send message.split('.').first,
      ActiveSupport::Notifications::Event.new(message, *args)
  end

  def error(event)
    error    = event.payload[:error].inner_exception
    instance = event.payload[:error].instance

    puts <<-MESSAGE

Error transcribing #{instance.class} #{instance.id}:
#{error.message}
    MESSAGE
  end

  def start_populating(event)
    puts "Generating index files for #{event.payload[:index].name}"
  end

  def populated(event)
    print '.' * event.payload[:instances].length
  end

  def finish_populating(event)
    print "\n"
  end

  private

  delegate :output, :to => ThinkingSphinx
  delegate :puts, :print, :to => :output
end

ThinkingSphinx::Subscribers::PopulatorSubscriber.attach_to(
  'thinking_sphinx.real_time'
)

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
thinking-sphinx-4.3.2	lib/thinking_sphinx/subscribers/populator_subscriber.rb
thinking-sphinx-4.3.1	lib/thinking_sphinx/subscribers/populator_subscriber.rb
thinking-sphinx-4.3.0	lib/thinking_sphinx/subscribers/populator_subscriber.rb
thinking-sphinx-4.2.0	lib/thinking_sphinx/subscribers/populator_subscriber.rb
thinking-sphinx-4.1.0	lib/thinking_sphinx/subscribers/populator_subscriber.rb
thinking-sphinx-4.0.0	lib/thinking_sphinx/subscribers/populator_subscriber.rb