Contents

class ThinkingSphinx::RealTime::Transcriber
  def initialize(index)
    @index = index
  end

  def copy(*instances)
    items = instances.select { |instance|
      instance.persisted? && copy?(instance)
    }
    return unless items.present?

    values = items.collect { |instance|
      TranscribeInstance.call(instance, index, properties)
    }

    insert = Riddle::Query::Insert.new index.name, columns, values
    sphinxql = insert.replace!.to_sql

    ThinkingSphinx::Logger.log :query, sphinxql do
      ThinkingSphinx::Connection.take do |connection|
        connection.execute sphinxql
      end
    end
  end

  class TranscribeInstance
    def self.call(instance, index, properties)
      new(instance, index, properties).call
    end

    def initialize(instance, index, properties)
      @instance, @index, @properties = instance, index, properties
    end

    def call
      properties.each_with_object([document_id]) do |property, instance_values|
        instance_values << property.translate(instance)
      end
    end

    private

    attr_reader :instance, :index, :properties

    def document_id
      index.document_id_for_key instance.id
    end
  end

  private

  attr_reader :index

  def columns
    @columns ||= properties.each_with_object(['id']) do |property, columns|
      columns << property.name
    end
  end

  def copy?(instance)
    index.conditions.empty? || index.conditions.all? { |condition|
      case condition
      when Symbol
        instance.send(condition)
      when Proc
        condition.call instance
      else
        "Unexpected condition: #{condition}. Expecting Symbol or Proc."
      end
    }
  end

  def properties
    @properties ||= index.fields + index.attributes
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
thinking-sphinx-3.4.2	lib/thinking_sphinx/real_time/transcriber.rb
thinking-sphinx-3.4.1	lib/thinking_sphinx/real_time/transcriber.rb
thinking-sphinx-3.4.0	lib/thinking_sphinx/real_time/transcriber.rb
thinking-sphinx-3.3.0	lib/thinking_sphinx/real_time/transcriber.rb
thinking-sphinx-3.2.0	lib/thinking_sphinx/real_time/transcriber.rb