Sha256: 853da50a3a9ab1589651d41cc3591e7c5da73d66c980acd3d7361683338b94ce
Contents?: true
Size: 1.54 KB
Versions: 8
Compression:
Stored size: 1.54 KB
Contents
# frozen_string_literal: true
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.each do |instance|
begin
values << ThinkingSphinx::RealTime::TranscribeInstance.call(
instance, index, properties
)
rescue ThinkingSphinx::TranscriptionError => error
instrument 'error', :error => error
end
end
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
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 instrument(message, options = {})
ActiveSupport::Notifications.instrument(
"#{message}.thinking_sphinx.real_time", options.merge(:index => index)
)
end
def properties
@properties ||= index.fields + index.attributes
end
end
Version data entries
8 entries across 8 versions & 1 rubygems