neo4jrb/neo4j

View on GitHub
lib/active_graph/node/dependent/query_proxy_methods.rb

Summary

Maintainability
A
1 hr
Test Coverage
module ActiveGraph
  module Node
    module Dependent
      # methods used to resolve association dependencies
      module QueryProxyMethods
        # Used as part of `dependent: :destroy` and may not have any utility otherwise.
        # It keeps track of the node responsible for a cascading `destroy` process.
        # @param owning_node [#dependent_children] source_object The node that called this method. Typically, we would use QueryProxy's `source_object` method
        # but this is not always available, so we require it explicitly.
        def each_for_destruction(owning_node)
          target = owning_node.called_by || owning_node
          objects = pluck(identity).compact.reject do |obj|
            target.dependent_children.include?(obj)
          end

          objects.each do |obj|
            obj.called_by = target
            target.dependent_children << obj
            yield obj
          end
        end

        # This will match nodes who only have a single relationship of a given type.
        # It's used  by `dependent: :delete_orphans` and `dependent: :destroy_orphans` and may not have much utility otherwise.
        # @param [ActiveGraph::Node::HasN::Association] association The Association object used throughout the match.
        # @param [String, Symbol] other_node The identifier to use for the other end of the chain.
        # @param [String, Symbol] other_rel The identifier to use for the relationship in the optional match.
        # @return [ActiveGraph::Node::Query::QueryProxy]
        def unique_nodes(association, self_identifer, other_node, other_rel, ids = [])
          fail 'Only supported by in QueryProxy chains started by an instance' unless source_object
          return false if send(association.name).empty?
          unique_nodes_query(association, self_identifer, other_node, other_rel, ids)
            .proxy_as(association.target_class, other_node)
        end

        private

        def unique_nodes_query(association, self_identifer, other_node, other_rel, ids)
          base = query.with(identity).proxy_as_optional(source_object.class, self_identifer)
                      .send(association.name, other_node, other_rel)
          base = base.where(id: ids) if ids.present?
          base.query
              .with(other_node)
              .match("()#{association.arrow_cypher(:orphan_rel)}(#{other_node})")
              .with(other_node, count: 'count(*)')
              .where('count = $one', one: 1)
              .break
        end
      end
    end
  end
end