diff options
Diffstat (limited to 'lib/edoors/room.rb')
| -rw-r--r-- | lib/edoors/room.rb | 190 |
1 files changed, 190 insertions, 0 deletions
diff --git a/lib/edoors/room.rb b/lib/edoors/room.rb new file mode 100644 index 0000000..1c855c1 --- /dev/null +++ b/lib/edoors/room.rb @@ -0,0 +1,190 @@ +#! /usr/bin/env ruby +# -*- coding: UTF-8 -*- +# +# Copyright 2012 Jérémy Zurcher <jeremy@asynk.ch> +# +# This file is part of edoors-ruby. +# +# edoors-ruby is free software: you can redistribute it and/or modify +# it under the terms of the GNU Affero General Public License as published by +# the Free Software Foundation, either version 3 of the License, or +# (at your option) any later version. +# +# edoors-ruby is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU Affero General Public License for more details. +# +# You should have received a copy of the GNU Affero General Public License +# along with edoors-ruby. If not, see <http://www.gnu.org/licenses/>. + +# +module Edoors + # + ERROR_ROUTE_NS = 'routing error: no source'.freeze + ERROR_ROUTE_RRWD = 'routing error: right room, wrong door'.freeze + ERROR_ROUTE_DNE = 'routing error: does not exists'.freeze + ERROR_ROUTE_NDNL = 'routing error: no destination, no link'.freeze + ERROR_ROUTE_SND = 'routing error: system no destination'.freeze + # + class Room < Iota + # + def initialize n, p + super n, p + @iotas = {} + @links = {} + end + # + def to_json *a + { + 'kls' => self.class.name, + 'name' => @name, + 'iotas' => @iotas, + 'links' => @links + }.to_json *a + end + # + def self.json_create o + raise Edoors::Exception.new "JSON #{o['kls']} != #{self.name}" if o['kls'] != self.name + room = self.new o['name'], o['parent'] + o['iotas'].each do |name,iota| + eval( iota['kls'] ).json_create(iota.merge!('parent'=>room)) + end + o['links'].each do |src,links| + links.each do |link| + room.add_link Edoors::Link.json_create(link) + end + end + room + end + # + def add_iota s + raise Edoors::Exception.new "Iota #{s.name} already has #{s.parent.name} as parent" if not s.parent.nil? and s.parent!=self + raise Edoors::Exception.new "Iota #{s.name} already exists in #{path}" if @iotas.has_key? s.name + s.parent = self if s.parent.nil? + @iotas[s.name]=s + end + # + def add_link l + l.door = @iotas[l.src] + raise Edoors::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 @spin.debug_routing + @iotas.values.each do |iota| iota.start! end + end + # + def stop! + puts " * stop #{path}" if @spin.debug_routing + @iotas.values.each do |iota| iota.stop! end + end + # + def search_down spath + return self if spath==path + return nil if (spath=~/^#{path}\/(\w+)\/?/)!=0 + if iota = @iotas[$1] + return iota if iota.path==spath # needed as Door doesn't implement #search_down + return iota.search_down spath + end + nil + end + # + def _try_links p + puts " -> try_links ..." if @spin.debug_routing + 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 pending_link + p2 = @spin.require_p p.class + p2.clone_data p + p2.apply_link! link + send_p p2 + end + pending_link = link + end + end + if pending_link + p.apply_link! pending_link + _send false, p + end + pending_link + end + private :_try_links + # + def _route p + if p.room.nil? or p.room==path + if door = @iotas[p.door] + p.dst_routed! door + else + p.error! Edoors::ERROR_ROUTE_RRWD + end + elsif door = @spin.search_world(p.room+Edoors::PATH_SEP+p.door) + p.dst_routed! door + else + p.error! Edoors::ERROR_ROUTE_DNE + end + end + private :_route + # + def _send sys, p + if not sys and p.src.nil? + # do not route non system orphan particles !! + p.error! Edoors::ERROR_ROUTE_NS, @spin + elsif p.dst + # direct routing through pointer + return + elsif p.door + # direct routing through path + _route p + elsif p.next_dst + p.split_dst! + if p.door + _route p + elsif not sys + # boomerang + p.dst_routed! p.src + elsif p.action + p.dst_routed! @spin + end + elsif not sys and _try_links p + return + else + p.error!( sys ? Edoors::ERROR_ROUTE_SND : Edoors::ERROR_ROUTE_NDNL) + end + end + private :_send + # + def send_p p + puts " * send_p #{(p.next_dst.nil? ? 'no dst' : p.next_dst)} ..." if @spin.debug_routing + _send false, p + puts " -> #{p.dst.path}#{Edoors::ACT_SEP}#{p.action}" if @spin.debug_routing + @spin.post_p p + end + # + def send_sys_p p + puts " * send_sys_p #{(p.next_dst.nil? ? 'no dst' : p.next_dst)} ..." if @spin.debug_routing + _send true, p + puts " -> #{p.dst.path}#{Edoors::ACT_SEP}#{p.action}" if @spin.debug_routing + @spin.post_sys_p p + end + # + def process_sys_p p + if p.action==Edoors::SYS_ACT_ADD_LINK + add_link Edoors::Link.from_particle_data p + end + @spin.release_p p + end + # + end + # +end +# +# EOF |