Sha256: 5357a4f99f060857af069e20ec020cdced076fad018d6aced92b7cde68d9c7b6
Contents?: true
Size: 1.54 KB
Versions: 5
Compression:
Stored size: 1.54 KB
Contents
module DataMapper
module Scope
Model.append_extensions self
# @api private
def default_scope(repository_name = nil)
repository_name = self.default_repository_name if repository_name == :default || repository_name.nil?
@default_scope ||= Hash.new{|h,k| h[k] = {}}
@default_scope[repository_name]
end
# @api private
def query
scope_stack.last
end
protected
# @api semipublic
def with_scope(query, &block)
# merge the current scope with the passed in query
with_exclusive_scope(self.query ? self.query.merge(query) : query, &block)
end
# @api semipublic
def with_exclusive_scope(query, &block)
query = DataMapper::Query.new(repository, self, query) if query.kind_of?(Hash)
scope_stack << query
begin
return yield(query)
ensure
scope_stack.pop
end
end
private
# @api private
def merge_with_default_scope(query)
DataMapper::Query.new(query.repository, query.model, default_scope_for_query(query)).update(query)
end
# @api private
def scope_stack
scope_stack_for = Thread.current[:dm_scope_stack] ||= Hash.new { |h,model| h[model] = [] }
scope_stack_for[self]
end
# @api private
def default_scope_for_query(query)
repository_name = query.repository.name
default_repository_name = query.model.default_repository_name
self.default_scope(default_repository_name).merge(self.default_scope(repository_name))
end
end # module Scope
end # module DataMapper
Version data entries
5 entries across 5 versions & 3 rubygems