X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fserver%2Fsfaapi.py;h=ad5cbe1a8ed563123a1c23b898d37125cb5c7a23;hb=e6d27e49ab5b982781e8d2b19f4029def4c1703c;hp=79a5540dc2e26451d02feaa66f7a88aa3135386c;hpb=9b9ffbbb64ae96d969005cffd1d65aa993731f56;p=sfa.git diff --git a/sfa/server/sfaapi.py b/sfa/server/sfaapi.py index 79a5540d..ad5cbe1a 100644 --- a/sfa/server/sfaapi.py +++ b/sfa/server/sfaapi.py @@ -15,8 +15,6 @@ from sfa.server.xmlrpcapi import XmlrpcApi from sfa.client.return_value import ReturnValue -# thgen xxx fixme this is wrong all right, but temporary, will use generic -from sfa.storage.table import SfaTable #################### class SfaApi (XmlrpcApi): @@ -93,9 +91,9 @@ class SfaApi (XmlrpcApi): return server - def getCredential(self): + def getCredential(self, minimumExpiration=0): """ - Return a valid credential for this interface. + Return a valid credential for this interface. """ type = 'authority' path = self.config.SFA_DATA_DIR @@ -106,7 +104,7 @@ class SfaApi (XmlrpcApi): cred = Credential(filename = cred_filename) # make sure cred isnt expired if not cred.get_expiration or \ - datetime.datetime.utcnow() < cred.get_expiration(): + datetime.datetime.utcnow() + datetime.timedelta(seconds=minimumExpiration) < cred.get_expiration(): return cred.save_to_string(save_parents=True) # get a new credential @@ -163,7 +161,8 @@ class SfaApi (XmlrpcApi): auth_hrn = hrn auth_info = self.auth.get_auth_info(auth_hrn) # xxx thgen fixme - use SfaTable hardwired for now - #table = self.SfaTable() + # thgen xxx fixme this is wrong all right, but temporary, will use generic + from sfa.storage.table import SfaTable table = SfaTable() records = table.findObjects({'hrn': hrn, 'type': 'authority+sa'}) if not records: @@ -238,6 +237,7 @@ class SfaApi (XmlrpcApi): def prepare_response_v2_am(self, result): response = { + 'geni_api': 2, 'code': self.get_geni_code(result), 'value': self.get_geni_value(result), 'output': self.get_geni_output(result), @@ -249,9 +249,8 @@ class SfaApi (XmlrpcApi): Converts the specified result into a standard GENI compliant response """ + # as of dec 13 2011 we only support API v2 if self.interface.lower() in ['aggregate', 'slicemgr']: - if hasattr(self.config, 'SFA_AGGREGATE_API_VERSION') and \ - self.config.SFA_AGGREGATE_API_VERSION == 2: - result = self.prepare_response_v2_am(result) + result = self.prepare_response_v2_am(result) return XmlrpcApi.prepare_response(self, result, method)