#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-

#
module EvenDoors
    #
    class Room < Spot
        #
        def initialize n, p=nil
            super n, p
            @spots = {}
            @links = {}
            @cache = {}
            @parent.add_spot self if @parent
        end
        #
        def add_spot s
            raise EvenDoors::Exception.new "Spot #{s.name} already has #{s.parent.name} as parent" if not s.parent.nil? and s.parent!=self
            raise EvenDoors::Exception.new "Spot #{s.name} already exists in #{path}" if @spots.has_key? s.name
            s.parent = self if s.parent.nil?
            @spots[s.name]=s
        end
        #
        def add_link l
            l.door = @spots[l.src]
            raise EvenDoors::Exception.new "Link source #{l.src} does not exist in #{path}" if l.door.nil?
            (@links[l.src] ||= [])<< l
        end
        #
        def start!
            puts " * start #{path}" if EvenDoors::Twirl.debug
            @spots.values.each do |spot| spot.start! if spot.respond_to? :start! end
        end
        #
        def stop!
            puts " * stop #{path}" if EvenDoors::Twirl.debug
            @spots.values.each do |spot| spot.stop! if spot.respond_to? :stop! end
        end
        #
        def space
            ( @parent.nil? ? self : @parent.space )
        end
        #
        def try_links p
            puts "   -> try_links ..." if EvenDoors::Twirl.debug
            links = @links[p.src.name]
            return false if links.nil?
            pending_link = nil
            apply_link = false
            links.each do |link|
                apply_link = link.cond_fields.nil?  # unconditional link
                p.set_link_fields link.cond_fields if not apply_link
                if apply_link or (p.link_value==link.cond_value)
                    # link matches !
                    if not pending_link.nil?
                        p2 = EvenDoors::Twirl.require_p p.class
                        p2.clone_data p
                        p2.src = link.door
                        p2.clear_dsts!
                        p2.add_dsts link.dsts
                        p2.set_link_fields link.fields
                        send_p p2
                    end
                    pending_link = link
                end
            end
            if pending_link
                p.src = pending_link.door
                p.clear_dsts!
                p.add_dsts pending_link.dsts
                p.set_link_fields pending_link.fields
                send_p p
            end
            (not pending_link.nil?)
        end
        #
        def route_p p
            if p.room.nil? or p.room==path
                if door = @spots[p.door]
                    p.dst_routed! door
                else
                    p.error! EvenDoors::ERROR_ROUTE_RRWD
                end
            elsif (p.room=~/^#{path}/)==0
                # TODO allow drill down ?!?
                p.error! EvenDoors::ERROR_ROUTE_RRNDD
            elsif @parent
                @parent.route_p p
            else
                p.error! EvenDoors::ERROR_ROUTE_TRWR
            end
        end
        #
        def send_p p
            puts " * send_p #{(p.next_dst.nil? ? 'no dst' : p.next_dst)} ..." if EvenDoors::Twirl.debug
            if p.next_dst
                p.split_dst!
                if p.door
                    p.src = space if p.src.nil? # send error to space if needed
                    route_p p
                elsif p.src
                    p.dst_routed! p.src
                else
                    p.error! EvenDoors::ERROR_ROUTE_NDNS, space
                end
            elsif p.src.nil?
                p.error! EvenDoors::ERROR_ROUTE_NDNS, space
            elsif not try_links p
                p.error! EvenDoors::ERROR_ROUTE_NDNL
            end
            puts "   -> #{p.dst.path}#{EvenDoors::ACT_SEP}#{p.action}" if EvenDoors::Twirl.debug
            EvenDoors::Twirl.send_p p
        end
        #
        def send_sys_p p
            puts " * send_sys_p #{(p.next_dst.nil? ? 'no dst' : p.next_dst)} ..." if EvenDoors::Twirl.debug
            if p.next_dst
                p.split_dst!
                if p.door.empty?
                    if p.action.nil?
                        p.error! EvenDoors::ERROR_ROUTE_SNDNA
                    else
                        p.dst_routed! space
                    end
                else
                    route_p p
                end
            else
                p.error! EvenDoors::ERROR_ROUTE_SND
            end
            puts "   -> #{p.dst.path}#{EvenDoors::ACT_SEP}#{p.action}" if EvenDoors::Twirl.debug
            EvenDoors::Twirl.send_sys_p p
        end
        #
        def process_sys_p p
            if p.action==SYS_ACT_ADD_LINK
                add_link EvenDoors::Link.from_particle_data p
            end
            EvenDoors::Twirl.release_p p
        end
        #
    end
    #
end
#
# EOF