X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=PLC%2FMethods%2FAddNode.py;h=0ee13f5a3f2cb64a60ddf9974ee0967a39098dce;hb=bd0cbf4f7f2e4cf7ceda500bfa6f98c0a700018b;hp=7354dfe5961e01f3a009d997b80274ae50053e0b;hpb=91a1fbdf638839bb5b2ef2dfe1d3ab18e800ad49;p=plcapi.git diff --git a/PLC/Methods/AddNode.py b/PLC/Methods/AddNode.py index 7354dfe..0ee13f5 100644 --- a/PLC/Methods/AddNode.py +++ b/PLC/Methods/AddNode.py @@ -1,14 +1,14 @@ -# $Id$ from PLC.Faults import * +from PLC.Auth import Auth from PLC.Method import Method from PLC.Parameter import Parameter, Mixed from PLC.Table import Row -from PLC.Nodes import Node, Nodes -from PLC.NodeGroups import NodeGroup, NodeGroups +from PLC.Namespace import hostname_to_hrn +from PLC.Peers import Peers from PLC.Sites import Site, Sites -from PLC.Auth import Auth +from PLC.Nodes import Node, Nodes from PLC.TagTypes import TagTypes -from PLC.NodeTags import NodeTags +from PLC.NodeTags import NodeTags, NodeTag from PLC.Methods.AddNodeTag import AddNodeTag from PLC.Methods.UpdateNodeTag import UpdateNodeTag @@ -27,7 +27,8 @@ class AddNode(Method): roles = ['admin', 'pi', 'tech'] - accepted_fields = Row.accepted_fields(can_update, [Node.fields,Node.tags]) + accepted_fields = Row.accepted_fields(can_update,Node.fields) + accepted_fields.update(Node.tags) accepts = [ Auth(), @@ -42,6 +43,8 @@ class AddNode(Method): [native,tags,rejected]=Row.split_fields(node_fields,[Node.fields,Node.tags]) + # type checking + native = Row.check_fields(native, self.accepted_fields) if rejected: raise PLCInvalidArgument, "Cannot add Node with column(s) %r"%rejected @@ -68,18 +71,32 @@ class AddNode(Method): node['site_id'] = site['site_id'] node.sync() - self.event_objects = {'Site': [site['site_id']], - 'Node': [node['node_id']]} - self.message = "Node %s created" % node['node_id'] + # since hostname was specified lets add the 'hrn' node tag + root_auth = self.api.config.PLC_HRN_ROOT + login_base = site['login_base'] + tags['hrn'] = hostname_to_hrn(root_auth, login_base, node['hostname']) for (tagname,value) in tags.iteritems(): # the tagtype instance is assumed to exist, just check that - if not TagTypes(self.api,{'tagname':tagname}): + tag_types = TagTypes(self.api,{'tagname':tagname}) + if not tag_types: raise PLCInvalidArgument,"No such TagType %s"%tagname + tag_type = tag_types[0] node_tags=NodeTags(self.api,{'tagname':tagname,'node_id':node['node_id']}) if not node_tags: - AddNodeTag(self.api).__call__(auth,node['node_id'],tagname,value) + node_tag = NodeTag(self.api) + node_tag['node_id'] = node['node_id'] + node_tag['tag_type_id'] = tag_type['tag_type_id'] + node_tag['tagname'] = tagname + node_tag['value'] = value + node_tag.sync() else: - UpdateNodeTag(self.api).__call__(auth,node_tags[0]['node_tag_id'],value) + node_tag = node_tags[0] + node_tag['value'] = value + node_tag.sync() + + self.event_objects = {'Site': [site['site_id']], + 'Node': [node['node_id']]} + self.message = "Node %d=%s created" % (node['node_id'],node['hostname']) return node['node_id']