Contents

module Pione
  module Agent
    # RuleProvider is an agent for providing rules to other agents.
    class RuleProvider < TupleSpaceClient
      set_agent_type :rule_provider

      def initialize(tuple_space_server)
        super(tuple_space_server)
        @table = {}

        # import system rules
        Model::SYSTEM_RULES.each do |command_rule|
          @table[command_rule.rule_path] = command_rule
        end
      end

      def read_document(doc)
        doc.rules.each do |rule_path, rule|
          add_rule(rule_path, rule)
        end
      end

      def add_rule(rule_path, content)
        raise ArgumentError unless content.kind_of?(Rule)
        @table[rule_path] = content
      end

      # Return known rule pathes.
      def known_rules
        @table.keys
      end

      define_state :request_waiting
      define_state :rule_loading

      define_state_transition :initialized => :request_waiting
      define_state_transition :request_waiting => :rule_loading
      define_state_transition :rule_loading => :request_waiting

      private

      def transit_to_request_waiting
        return take(Tuple[:request_rule].any)
      end

      def transit_to_rule_loading(request)
        if known_rule?(request.rule_path)
          write(Tuple[:rule].new(rule_path: request.rule_path, content: @table[request.rule_path]))
        else
          processing_error("rule '%s' is unknonw" % request.rule_path)
        end
      end

      def known_rule?(rule_path)
        @table.has_key?(rule_path)
      end
    end

    set_agent RuleProvider
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
pione-0.1.4	lib/pione/agent/rule-provider.rb
pione-0.1.3	lib/pione/agent/rule-provider.rb