module Pickle module Session class << self def included(world_class) proxy_to_pickle_parser(world_class) end def extended(world_object) proxy_to_pickle_parser(class << world_object; self; end) # metaclass is not 2.1 compatible end protected def proxy_to_pickle_parser(world_class) world_class.class_eval do unless methods.include?('method_missing_with_pickle_parser') alias_method_chain :method_missing, :pickle_parser alias_method_chain :respond_to?, :pickle_parser end end end end def create_model(a_model_name, fields = nil) factory, label = *parse_model(a_model_name) raise ArgumentError, "Can't create with an ordinal (e.g. 1st user)" if label.is_a?(Integer) fields = fields.is_a?(Hash) ? parse_hash(fields) : parse_fields(fields) record = pickle_config.factories[factory].create(fields) store_model(factory, label, record) end def find_model(a_model_name, fields = nil) factory, name = *parse_model(a_model_name) raise ArgumentError, "Can't find a model with an ordinal (e.g. 1st user)" if name.is_a?(Integer) model_class = pickle_config.factories[factory].klass fields = fields.is_a?(Hash) ? parse_hash(fields) : parse_fields(fields) if record = model_class.find(:first, :conditions => convert_models_to_attributes(model_class, fields)) store_model(factory, name, record) end end def find_model!(a_model_name, fields = nil) find_model(a_model_name, fields) or raise "Can't find pickle model: '#{name}' in this scenario" end def find_models(factory, fields = nil) models_by_index(factory).clear model_class = pickle_config.factories[factory].klass records = model_class.all(:conditions => convert_models_to_attributes(model_class, parse_fields(fields))) records.each {|record| store_model(factory, nil, record)} end # return the original model stored by create_model or find_model def created_model(name) factory, name_or_index = *parse_model(name) if name_or_index.blank? models_by_index(factory).last elsif name_or_index.is_a?(Integer) models_by_index(factory)[name_or_index] else models_by_name(factory)[name_or_index] or raise "Can't find pickle model: '#{name}' in this scenario" end end # predicate version which raises no errors def created_model?(name) (created_model(name) rescue nil) ? true : false end # return a newly selected model def model(name) (model = created_model(name)) && model.class.find(model.id) end # predicate version which raises no errors def model?(name) (model(name) rescue nil) ? true : false end # like model, but raise an error if it can't be found def model!(name) model(name) or raise "Can't find pickle model: '#{name}' in this scenario" end # like created_model, but raise an error if it can't be found def created_model!(name) created_model(name) or raise "Can't find pickle model: '#{name}' in this scenario" end # return all original models of specified type def created_models(factory) models_by_index(factory) end # return all models of specified type (freshly selected from the database) def models(factory) created_models(factory).map{|model| model.class.find(model.id) } end def respond_to_with_pickle_parser?(method, include_private = false) respond_to_without_pickle_parser?(method, include_private) || pickle_parser.respond_to?(method, include_private) end protected def method_missing_with_pickle_parser(method, *args, &block) if pickle_parser.respond_to?(method) pickle_parser.send(method, *args, &block) else method_missing_without_pickle_parser(method, *args, &block) end end def pickle_parser=(parser) parser.session = self @pickle_parser = parser end def pickle_parser @pickle_parser or self.pickle_parser = Pickle.parser end def pickle_config pickle_parser.config end def convert_models_to_attributes(ar_class, attrs) attrs.each do |key, val| if val.is_a?(ActiveRecord::Base) && ar_class.column_names.include?("#{key}_id") attrs["#{key}_id"] = val.id attrs["#{key}_type"] = val.class.name if ar_class.column_names.include?("#{key}_type") attrs.delete(key) end end end def models_by_name(factory) @models_by_name ||= {} @models_by_name[pickle_parser.canonical(factory)] ||= {} end def models_by_index(factory) @models_by_index ||= {} @models_by_index[pickle_parser.canonical(factory)] ||= [] end # if the factory name != the model name, store under both names def store_model(factory, name, record) store_record(record.class.name, name, record) unless pickle_parser.canonical(factory) == pickle_parser.canonical(record.class.name) store_record(factory, name, record) end def store_record(factory, name, record) models_by_name(factory)[name] = record models_by_index(factory) << record end end end