Sha256: f328b5562543ae1de7862b83d36beabdda7a10f48796f2d5a7bc34e9e72b22a3
Contents?: true
Size: 1.83 KB
Versions: 14
Compression:
Stored size: 1.83 KB
Contents
module Neo4j
module ActiveNode
module Unpersisted
def pending_associations
@pending_associations ||= []
end
def pending_associations?
!@pending_associations.blank?
end
private
# TODO: Change this method's name.
# Takes the pending_associations hash, which is in the format { cache_key => [:association_name, :association_operator]},
# and returns them as { association_name => [[nodes_for_persistence], :operator] }
def pending_associations_with_nodes
return unless pending_associations?
{}.tap do |deferred_nodes|
pending_associations.uniq.each do |association_name|
nodes_for_creation = association_proxy(association_name)
nodes_for_creation = nodes_for_creation.reject(&:persisted?) if self.persisted?
deferred_nodes[association_name] = nodes_for_creation
end
end
end
# @param [Hash] deferred_nodes A hash created by :pending_associations_with_nodes
def process_unpersisted_nodes!(deferred_nodes)
deferred_nodes.each_pair do |k, v|
save_and_associate_queue(k, v)
end
end
def save_and_associate_queue(association_name, node_queue)
association_proc = proc { |node| save_and_associate_node(association_name, node) }
node_queue.each do |element|
element.is_a?(Array) ? element.each { |node| association_proc.call(node) } : association_proc.call(element)
end
end
def save_and_associate_node(association_name, node)
if node.respond_to?(:changed?)
node.save if node.changed? || !node.persisted?
fail "Unable to defer node persistence, could not save #{node.inspect}" unless node.persisted?
end
association_proxy(association_name) << node
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems