a minor bug-fx

[sfa.git] / sfa / managers / aggregate_manager_pl.py

diff --git a/sfa/managers/aggregate_manager_pl.py b/sfa/managers/aggregate_manager_pl.py
index 2bdfc21..f824931 100644 (file)
--- a/sfa/managers/aggregate_manager_pl.py
+++ b/sfa/managers/aggregate_manager_pl.py
@@ -42,18 +42,18 @@ def create_slice(api, hrn, rspec):
     slices = Slices(api)
     slices.create_slice(hrn, rspec)
 
-def get_ticket(api, slice_hrn, rspec):
+def get_ticket(api, slice_hrn, rspec, origin_hrn=None):
     # the the slice record
     registries = Registries(api)
     registry = registries[api.hrn]
-    credential = self.api.getCredential()
+    credential = api.getCredential()
     records = registry.resolve(credential, slice_hrn)
     
     # make sure we get a local slice record
     record = None  
     for tmp_record in records:
-        if record['type'] == 'slice' and \
-           not record['peer_authority']:
+        if tmp_record['type'] == 'slice' and \
+           not tmp_record['peer_authority']:
             record = SliceRecord(dict=tmp_record)
     if not record:
         raise RecordNotFound(slice_hrn)
@@ -70,22 +70,20 @@ def get_ticket(api, slice_hrn, rspec):
         'initscripts': initscripts,
         'slivers': slivers
     }
-    
+
     # create the ticket
-    auth_hrn = record['authority'] 
-    auth_info = api.auth.get_auth_info(auth_hrn)
     object_gid = record.get_gid_object()
     new_ticket = SfaTicket(subject = object_gid.get_subject())
     new_ticket.set_gid_caller(api.auth.client_gid)
     new_ticket.set_gid_object(object_gid)
-    new_ticket.set_issuer(key=auth_info.get_pkey_object(), subject=auth_hrn)
+    new_ticket.set_issuer(key=api.key, subject=api.hrn)
     new_ticket.set_pubkey(object_gid.get_pubkey())
     new_ticket.set_attributes(data)
     new_ticket.set_rspec(rspec)
-    new_ticket.set_parent(api.auth.hierarchy.get_auth_ticket(auth_hrn))
+    #new_ticket.set_parent(api.auth.hierarchy.get_auth_ticket(auth_hrn))
     new_ticket.encode()
     new_ticket.sign()
-
+    
     return new_ticket.save_to_string(save_parents=True)
 
 def start_slice(api, hrn):
@@ -124,9 +122,9 @@ def get_slices(api):
     return slices['hrn']
      
  
-def get_rspec(api, hrn=None, caller_cred=None):
+def get_rspec(api, hrn=None, origin_hrn=None):
     from sfa.plc.nodes import Nodes
-    nodes = Nodes(api, caller_cred=caller_cred)
+    nodes = Nodes(api, origin_hrn=origin_hrn)
     if hrn:
         rspec = nodes.get_rspec(hrn)
     else: