Revision e82a264b
Added by Marc Dequènes over 13 years ago
- ID e82a264b9c5f51c4eb0d1cfffb37d5628c41bc88
| lib/cyborghood/cyborg/interface.rb | ||
|---|---|---|
|
end
|
||
|
end
|
||
|
|
||
|
module CyborgServerEmbededInterface
|
||
|
module CyborgServerEmbeddedInterface
|
||
|
def self.included(base)
|
||
|
base.class_eval("include CyborgServerInterfaceBase")
|
||
|
base.export_parent_methods
|
||
|
end
|
||
|
end
|
||
|
|
||
|
module CyborgServerStatefulInterface
|
||
|
end
|
||
|
|
||
|
module CyborgServerInterfaceBase
|
||
|
NODE_PATTERN = "((?:\/|(?:\/[a-zA-Z0-9._]+)+[?=]?))"
|
||
|
|
||
| ... | ... | |
|
def api_methods
|
||
|
methods = self.class.exported_methods
|
||
|
methods += self.class.public_instance_methods(false) if self.class.auto_export_public_instance_methods
|
||
|
methods -= ["initialize", "__destroy", "method_missing"]
|
||
|
methods & self.methods
|
||
|
end
|
||
|
|
||
| ... | ... | |
|
(api_klasses.keys + api_methods).sort
|
||
|
end
|
||
|
|
||
|
def find_node_action(node_name)
|
||
|
def find_node_action(session, node_name)
|
||
|
node_name.gsub!(/^\//, "")
|
||
|
next_node_name, other_nodes_names = node_name.split('/', 2)
|
||
|
|
||
| ... | ... | |
|
# cannot use method(), as this method may not exist at all (but still
|
||
|
# be usuable through metaprogramming
|
||
|
return lambda do |*args|
|
||
|
r = self.send(next_node_name, *args)
|
||
|
r = child_node(next_node_name, session, *args)
|
||
|
# dynamic tree construction: method may return a node
|
||
|
if r.class.ancestors.include? CyborgHood::CyborgServerInterfaceBase
|
||
|
if r.is_a? CyborgHood::CyborgServerInterfaceBase
|
||
|
r.api_nodes
|
||
|
else
|
||
|
r
|
||
|
end
|
||
|
end
|
||
|
end
|
||
|
next_node = self.send(next_node_name)
|
||
|
next_node = child_node(next_node_name, session)
|
||
|
else
|
||
|
# unknown method
|
||
|
return
|
||
| ... | ... | |
|
end
|
||
|
|
||
|
# search deeper
|
||
|
if next_node.class.ancestors.include? CyborgHood::CyborgServerInterfaceBase
|
||
|
next_node.find_node_action(other_nodes_names)
|
||
|
if next_node.is_a? CyborgHood::CyborgServerInterfaceBase
|
||
|
next_node.find_node_action(session, other_nodes_names)
|
||
|
else
|
||
|
# it is not a node, so there are no children
|
||
|
return
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def child_node(next_node_name, session, *args)
|
||
|
args.unshift session if self.is_a? CyborgHood::CyborgServerStatefulInterface
|
||
|
self.send(next_node_name, *args)
|
||
|
end
|
||
|
|
||
|
def has_node?(cmd)
|
||
|
not find_node_action(cmd).nil?
|
||
|
not find_node_action(nil, cmd).nil?
|
||
|
end
|
||
|
|
||
|
# preliminary incoming message handling
|
||
|
def call(cmd, data)
|
||
|
action = find_node_action(cmd)
|
||
|
def call(session, cmd, data)
|
||
|
action = find_node_action(session, cmd)
|
||
|
return "551 unknown node" if action.nil?
|
||
|
|
||
|
if data.nil?
|
||
Also available in: Unified diff
[evol] added session management to the cyborg server (refs #31)