X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fplc%2Fapi.py;fp=sfa%2Fplc%2Fapi.py;h=f9a39020b482a72c8e339904ac4272c081274a29;hb=10e54dda543df4b6351d194143bcf21f10325104;hp=cbe321b0781e0e3a397edcaf7140a65b8c89d78f;hpb=8e2e4f82483f7f9c83b9a75054c4dad24d8d0efe;p=sfa.git diff --git a/sfa/plc/api.py b/sfa/plc/api.py index cbe321b0..f9a39020 100644 --- a/sfa/plc/api.py +++ b/sfa/plc/api.py @@ -21,7 +21,47 @@ from sfa.util.namespace import * from sfa.util.api import * from sfa.util.nodemanager import NodeManager from sfa.util.sfalogging import * -from collections import defaultdict +try: + from collections import defaultdict +except: + class defaultdict(dict): + def __init__(self, default_factory=None, *a, **kw): + if (default_factory is not None and + not hasattr(default_factory, '__call__')): + raise TypeError('first argument must be callable') + dict.__init__(self, *a, **kw) + self.default_factory = default_factory + def __getitem__(self, key): + try: + return dict.__getitem__(self, key) + except KeyError: + return self.__missing__(key) + def __missing__(self, key): + if self.default_factory is None: + raise KeyError(key) + self[key] = value = self.default_factory() + return value + def __reduce__(self): + if self.default_factory is None: + args = tuple() + else: + args = self.default_factory, + return type(self), args, None, None, self.items() + def copy(self): + return self.__copy__() + def __copy__(self): + return type(self)(self.default_factory, self) + def __deepcopy__(self, memo): + import copy + return type(self)(self.default_factory, + copy.deepcopy(self.items())) + def __repr__(self): + return 'defaultdict(%s, %s)' % (self.default_factory, + dict.__repr__(self)) + + +## end of http://code.activestate.com/recipes/523034/ }}} + def list_to_dict(recs, key): """ @@ -76,6 +116,7 @@ class SfaAPI(BaseAPI): 'AuthMethod': 'password', 'AuthString': self.config.SFA_PLC_PASSWORD} + self.plshell_type = 'xmlrpc' # connect via xmlrpc url = self.config.SFA_PLC_URL @@ -135,8 +176,8 @@ class SfaAPI(BaseAPI): new_cred = Credential(subject = object_gid.get_subject()) new_cred.set_gid_caller(object_gid) new_cred.set_gid_object(object_gid) - new_cred.set_issuer(key=auth_info.get_pkey_object(), subject=auth_hrn) - new_cred.set_pubkey(object_gid.get_pubkey()) + new_cred.set_issuer_keys(auth_info.get_privkey_filename(), auth_info.get_gid_filename()) + r1 = determine_rights(type, hrn) new_cred.set_privileges(r1)