Sha256: c4dc3c5f6265543a843eef0a9c2971da364ee8bbc2c715803a4bd33dd931e51d
Contents?: true
Size: 1.52 KB
Versions: 9
Compression:
Stored size: 1.52 KB
Contents
# encoding: utf-8
module Mongoid #:nodoc:
module Atomicity #:nodoc:
extend ActiveSupport::Concern
# Get all the atomic updates that need to happen for the current
# +Document+. This includes all changes that need to happen in the
# entire hierarchy that exists below where the save call was made.
#
# Example:
#
# <tt>person.save</tt> # Saves entire tree
#
# Returns:
#
# A +Hash+ of all atomic updates that need to occur.
def _updates
processed = {}
_children.inject({ "$set" => _sets, "$pushAll" => {}, :other => {} }) do |updates, child|
changes = child._sets
updates["$set"].update(changes)
processed[child.class] = true unless changes.empty?
target = processed.has_key?(child.class) ? :other : "$pushAll"
child._pushes.each do |attr, val|
if updates[target].has_key?(attr)
updates[target][attr] << val
else
updates[target].update({attr => [val]})
end
end
updates
end.delete_if do |key, value|
value.empty?
end
end
protected
# Get all the push attributes that need to occur.
def _pushes
(new_record? && embedded_many? && !_parent.new_record?) ? { _path => raw_attributes } : {}
end
# Get all the attributes that need to be set.
def _sets
if changed? && !new_record?
setters
else
embedded_one? && new_record? ? { _path => raw_attributes } : {}
end
end
end
end
Version data entries
9 entries across 9 versions & 2 rubygems