# encoding: utf-8 module Mongoid class Criteria module Findable # Execute the criteria or raise an error if no documents found. # # @example Execute or raise # criteria.execute_or_raise(id) # # @param [ Object ] args The arguments passed. # # @raise [ Errors::DocumentNotFound ] If nothing returned. # # @return [ Document, Array ] The document(s). # # @since 2.0.0 def execute_or_raise(ids, multi) result = multiple_from_db(ids) check_for_missing_documents!(result, ids) multi ? result : result.first end # Find the matchind document(s) in the criteria for the provided ids. # # @example Find by an id. # criteria.find(BSON::ObjectId.new) # # @example Find by multiple ids. # criteria.find([ BSON::ObjectId.new, BSON::ObjectId.new ]) # # @param [ Array ] args The ids to search for. # # @return [ Array, Document ] The matching document(s). # # @since 1.0.0 def find(*args) ids = args.__find_args__ raise_invalid if ids.any?(&:nil?) for_ids(ids).execute_or_raise(ids, args.multi_arged?) end # Adds a criterion to the +Criteria+ that specifies an id that must be matched. # # @example Add a single id criteria. # criteria.for_ids([ 1 ]) # # @example Add multiple id criteria. # criteria.for_ids([ 1, 2 ]) # # @param [ Array ] ids The array of ids. # # @return [ Criteria ] The cloned criteria. def for_ids(ids) ids = mongoize_ids(ids) if ids.size > 1 send(id_finder, { _id: { "$in" => ids }}) else send(id_finder, { _id: ids.first }) end end # Get the documents from the identity map, and if not found hit the # database. # # @example Get the documents from the map or criteria. # criteria.multiple_from_map_or_db(ids) # # @param [ ids ] The searched ids. # # @return [ Array ] The found documents. def multiple_from_db(ids) return entries if embedded? ids = mongoize_ids(ids) ids.empty? ? [] : from_database(ids) end private # Get the finder used to generate the id query. # # @api private # # @example Get the id finder. # criteria.id_finder # # @return [ Symbol ] The name of the finder method. # # @since 3.1.0 def id_finder @id_finder ||= extract_id ? :all_of : :where end # Get documents from the database only. # # @api private # # @example Get documents from the database. # criteria.from_database(ids) # # @param [ Array ] ids The ids to fetch with. # # @return [ Array ] The matching documents. # # @since 3.0.0 def from_database(ids) (ids.size > 1 ? any_in(id: ids) : where(id: ids.first)).entries end # Convert all the ids to their proper types. # # @api private # # @example Convert the ids. # criteria.mongoize_ids(ids) # # @param [ Array ] ids The ids to convert. # # @return [ Array ] The converted ids. # # @since 3.0.0 def mongoize_ids(ids) ids.map do |id| id = id[:id] if id.respond_to?(:keys) && id[:id] klass.fields["_id"].mongoize(id) end end # Convenience method of raising an invalid options error. # # @example Raise the error. # criteria.raise_invalid # # @raise [ Errors::InvalidOptions ] The error. # # @since 2.0.0 def raise_invalid raise Errors::InvalidFind.new end end end end