fix component_id urn

[sfa.git] / sfa / plc / aggregate.py

diff --git a/sfa/plc/aggregate.py b/sfa/plc/aggregate.py
index 8fa7c80..77784cb 100644 (file)
--- a/sfa/plc/aggregate.py
+++ b/sfa/plc/aggregate.py
@@ -3,6 +3,7 @@ from sfa.util.xrn import hrn_to_urn, urn_to_hrn
 from sfa.util.plxrn import PlXrn, hostname_to_urn, hrn_to_pl_slicename
 from sfa.rspecs.rspec import RSpec
 from sfa.rspecs.elements.link import Link
+from sfa.rspecs.elements.interface import Interface
 from sfa.managers.vini.topology import PhysicalLinks
 from sfa.rspecs.version_manager import VersionManager
 from sfa.plc.vlink import get_tc_rate
@@ -66,8 +67,8 @@ class Aggregate:
                 site1_hrn = self.api.hrn + '.' + site1['login_base']
                 site2_hrn = self.api.hrn + '.' + site2['login_base']
                 # get the first node
-                node1 = self.nodes[site1['node_id'][0]]
-                node2 = self.nodes[site2['node_id'][0]]
+                node1 = self.nodes[site1['node_ids'][0]]
+                node2 = self.nodes[site2['node_ids'][0]]
 
                 # set interfaces
                 # just get first interface of the first node
@@ -82,7 +83,7 @@ class Aggregate:
                 link['interface1'] = if1
                 link['interface2'] = if2
                 link['component_name'] = "%s:%s" % (site1['login_base'], site2['login_base'])
-                link['component_id'] = PlXrn(auth=self.api.hrn, link=link['component_name'])
+                link['component_id'] = PlXrn(auth=self.api.hrn, interface=link['component_name']).get_urn()
                 link['component_manager_id'] =  hrn_to_urn(self.api.hrn, 'authority+am')
                 self.links[link['component_name']] = link