Sha256: f99de8fd162f9600be91ab7fd46bd87697665991d3cb35433a2d1498395a8f29
Contents?: true
Size: 1.96 KB
Versions: 5
Compression:
Stored size: 1.96 KB
Contents
class ThinkingSphinx::Middlewares::ActiveRecordTranslator < ThinkingSphinx::Middlewares::Middleware def call(contexts) contexts.each do |context| Inner.new(context).call end app.call contexts end private class Inner def initialize(context) @context = context end def call results_for_models # load now to avoid segfaults context[:results] = if sql_options[:order] results_for_models.values.first else context[:results].collect { |row| result_for(row) } end end private attr_reader :context def ids_for_model(model_name) context[:results].collect { |row| row['sphinx_internal_id'] if row['sphinx_internal_class'] == model_name }.compact end def model_names @model_names ||= context[:results].collect { |row| row['sphinx_internal_class'] }.uniq end def reset_memos @model_names = nil @results_for_models = nil end def result_for(row) results_for_models[row['sphinx_internal_class']].detect { |record| record.id == row['sphinx_internal_id'] } end def results_for_models @results_for_models ||= model_names.inject({}) do |hash, name| model = name.constantize hash[name] = model_relation_with_sql_options(model.unscoped).where( model.primary_key => ids_for_model(name) ) hash end end def model_relation_with_sql_options(relation) relation = relation.includes sql_options[:include] if sql_options[:include] relation = relation.joins sql_options[:joins] if sql_options[:joins] relation = relation.order sql_options[:order] if sql_options[:order] relation = relation.select sql_options[:select] if sql_options[:select] relation = relation.group sql_options[:group] if sql_options[:group] relation end def sql_options context.search.options[:sql] || {} end end end
Version data entries
5 entries across 5 versions & 1 rubygems