require 'neo4j/rule/event_listener'
require 'neo4j/rule/class_methods'
require 'neo4j/rule/rule_node'

require 'neo4j/rule/functions/functions'


module Neo4j
  module Rule


    # Holds all defined rules added by the Neo4j::Rule::ClassMethods#rule method.
    #
    # See Neo4j::Rule::ClassMethods
    #
    class Rule

      attr_reader :rule_name, :filter, :triggers, :functions

      def initialize(rule_name, props, &block)
        @rule_name = rule_name
        @triggers  = props[:triggers]
        @functions = props[:functions]
        @triggers = [@triggers] if @triggers && !@triggers.respond_to?(:each)
        @functions = [@functions] if @functions && !@functions.respond_to?(:each)
        @filter = block
      end

      def to_s
        "Rule #{rule_name} props=#{props.inspect}"
      end

      def find_function(function_name, function_id)
        function_id = function_id.to_s
        @functions && @functions.find { |f| f.function_id == function_id && f.class.function_name == function_name }
      end

      # Reconstruct the properties given when created this rule
      # Needed when inheriting a rule and we want to duplicate a rule
      def props
        props = {}
        props[:triggers] = @triggers if @triggers
        props[:functions] = @functions if @functions
        props
      end

      def functions_for(property)
        @functions && @functions.find_all { |f| f.calculate?(property) }
      end

      def execute_filter(node)
        if @filter.nil?
          true
        elsif @filter.arity != 1
          node.wrapper.instance_eval(&@filter)
        else
          @filter.call(node)
        end
      end

      # ------------------------------------------------------------------------------------------------------------------
      # Class Methods
      # ------------------------------------------------------------------------------------------------------------------

      class << self
        def add(clazz, rule_name, props, &block)
          rule_node = rule_node_for(clazz.to_s)
          rule_node.remove_rule(rule_name) # remove any previously inherited rules
          rule = Rule.new(rule_name, props, &block)
          rule_node.add_rule(rule)
          rule
        end

        def has_rules?(clazz)
          !@rule_nodes[clazz.to_s].nil?
        end
        
        def rule_names_for(clazz)
          rule_node = rule_node_for(clazz)
          rule_node.rules.map { |rule| rule.rule_name }
        end

        def rule_node_for(clazz)
          return nil if clazz.nil?
          @rule_nodes             ||= {}
          @rule_nodes[clazz.to_s] ||= RuleNode.new(clazz)
        end

        def find_rule_node(node)
          @rule_nodes && @rule_nodes.values.find { |rn| rn.rule_node?(node) }
        end

        def on_neo4j_started
          @rule_nodes.each_value { |rule_node| rule_node.on_neo4j_started } if @rule_nodes
        end

        def inherit(parent_class, subclass)
          # copy all the rules
          if rule_node = rule_node_for(parent_class)
            rule_node.inherit(subclass)
          end
        end

        def delete(clazz)
          if rule_node = rule_node_for(clazz)
            rule_node.delete_node
          end
        end

        def trigger?(node)
          classname = node[:_classname]
          @rule_nodes && classname && rule_node_for(classname)
        end

        def trigger_rules(node, *changes)
          classname = node[:_classname]
          return unless classname # there are no rules if there is not a :_classname property
          rule_node = rule_node_for(classname)
          rule_node.execute_rules(node, *changes)

          # recursively add relationships for all the parent classes with rules that also pass for this node
          recursive(node,classname,*changes)
        end

        private 

          def recursive(node,classname,*changes)
            if (clazz = eval("#{classname}.superclass")) && clazz.include?(Neo4j::NodeMixin)
              rule_node = rule_node_for(clazz)
              rule_node && rule_node.execute_rules(node, *changes)
              recursive(node,clazz.name,*changes)
            end
          end
      end
    end
  end
end