require_relative 'region_settings'
module GameMachine
  module GameSystems
    class RegionManager < Actor::Base
      include GameMachine::Commands
      include GameMachine::Models

      attr_reader :regions, :servers
      def post_init(*args)
        @regions = {}
        @servers = {}
        load_from_config
        schedule_message('check_regions',2,:seconds)
      end

      def check_regions
        unassign_down_servers
        assign_servers
        notify_managers
      end

      def notify_managers
        regions.each do |name,region|
          if region.manager && region.server
            region.manager.constantize.find_by_address(region.server).tell(region)
          end
        end
      end

      def load_from_config
        RegionSettings.regions.each do |name,manager|
          unless region = Region.find!(name)
            region = Region.new(
              :id => name,
              :name => name,
              :manager => manager
            )
            region.save!
          end
          regions[name] = region
          if region.server
            servers[region.server] = name
          end
        end
      end

      def unassign_down_servers
        regions.each do |name,region|
          if region.server
            unless ClusterMonitor.cluster_members.has_key?(region.server)
              GameMachine.logger.warn "Node #{region.server} no longer in cluster, region #{region.name} dissasociated"
              servers.delete(region.server)
              region.server = nil
              region.save!
            end
          end
        end
      end

      def assign_servers
        regions.each do |name,region|
          if region.server.nil?
            ClusterMonitor.cluster_members.keys.each do |address|
              unless servers.has_key?(address)
                region.server = address
                servers[address] = name
                region.save!
                GameMachine.logger.warn "Region #{region.name} assigned to #{region.server}"
                break
              end
            end
          end
        end
      end

      def on_receive(message)
        if message.is_a?(String)
          if message == 'check_regions'
            check_regions
          else
            regions_msg = MessageLib::Regions.new.set_regions(regions_string)
            entity = MessageLib::Entity.new.set_id(message.player.id).set_regions(regions_msg)
            commands.player.send_message(entity,message.player.id)
            #GameMachine.logger.info "#{self.class.name} sent regions to #{message.player.id}"
          end
        end
      end

    end
  end
end