X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fclient%2Fsfi.py;h=b1a4379e69a48d079595efe3c2aec138d2c25952;hb=182847b5418db4d0ff522956aad4be0e994f8d93;hp=ca614632199d7d4fe99d15fef09d29267dc250fb;hpb=657e8290ebbb4d6b6bcf337a3bc03aff9b42e62b;p=sfa.git diff --git a/sfa/client/sfi.py b/sfa/client/sfi.py index ca614632..b1a4379e 100755 --- a/sfa/client/sfi.py +++ b/sfa/client/sfi.py @@ -12,7 +12,6 @@ from types import StringTypes, ListType from optparse import OptionParser from sfa.trust.certificate import Keypair, Certificate from sfa.trust.credential import Credential -from sfa.util.geniclient import GeniClient from sfa.util.sfaticket import SfaTicket from sfa.util.record import * from sfa.util.namespace import * @@ -107,7 +106,7 @@ def save_record_to_file(filename, record): elif record['type'] in ['authority', 'ma', 'sa']: record = AuthorityRecord(dict = record) else: - record = GeniRecord(dict = record) + record = SfaRecord(dict = record) str = record.save_to_string() file(filename, "w").write(str) return @@ -116,7 +115,7 @@ def save_record_to_file(filename, record): # load methods def load_record_from_file(filename): str = file(filename, "r").read() - record = GeniRecord(string=str) + record = SfaRecord(string=str) return record @@ -304,8 +303,6 @@ class Sfi: self.cert_file = cert_file self.cert = Certificate(filename=cert_file) # Establish connection to server(s) - #self.slicemgr = GeniClient(sm_url, key_file, cert_file, self.options.protocol) - #self.registry = GeniClient(reg_url, key_file, cert_file, self.options.protocol) self.registry = xmlrpcprotocol.get_server(reg_url, key_file, cert_file) self.slicemgr = xmlrpcprotocol.get_server(sm_url, key_file, cert_file) return @@ -452,7 +449,7 @@ class Sfi: raise Exception, "Error: Didn't find a %(type)s record for %(hrn)s" % locals() # the gid of the user who will be delegated too - record = GeniRecord(dict=records[0]) + record = SfaRecord(dict=records[0]) delegee_gid = record.get_gid_object() delegee_hrn = delegee_gid.get_hrn() @@ -575,7 +572,7 @@ class Sfi: elif record['type'] in ['authority', 'ma', 'sa']: record = AuthorityRecord(dict = record) else: - record = GeniRecord(dict = record) + record = SfaRecord(dict = record) if (opts.format=="text"): record.dump() else: @@ -786,7 +783,7 @@ class Sfi: raise Exception, "No such aggregate %s" % opts.aggregate aggregate = aggregates[0] url = "http://%s:%s" % (aggregate['addr'], aggregate['port']) - server = GeniClient(url, self.key_file, self.cert_file, self.options.protocol) + server = xmlrpcprotocol.get_server(url, self.key_file, self.cert_file, self.options.protocol) return server.create_slice(slice_cred, slice_hrn, rspec) # get a ticket for the specified slice @@ -803,7 +800,7 @@ class Sfi: raise Exception, "No such aggregate %s" % opts.aggregate aggregate = aggregates[0] url = "http://%s:%s" % (aggregate['addr'], aggregate['port']) - server = GeniClient(url, self.key_file, self.cert_file, self.options.protocol) + server = xmlrpcprotocol.get_server(url, self.key_file, self.cert_file, self.options.protocol) ticket_string = server.get_ticket(slice_cred, slice_hrn, rspec) file = os.path.join(self.options.sfi_dir, get_leaf(slice_hrn) + ".ticket") print "writing ticket to ", file