X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fimporter%2Fplimporter.py;h=7994c8c9eb8ffb63b36b21669c0708e48ec5eb59;hb=8ebb53ace5f9319da63a67fc644486e58a94b18f;hp=1d961948711719248184de2678535c0c4eba8098;hpb=f736847dcd8410b82a2fdc6bd4674a68d8fac108;p=sfa.git diff --git a/sfa/importer/plimporter.py b/sfa/importer/plimporter.py index 1d961948..7994c8c9 100644 --- a/sfa/importer/plimporter.py +++ b/sfa/importer/plimporter.py @@ -297,8 +297,7 @@ class PlImporter: plc_keys = keys_by_person_id.get(person['person_id'],[]) if not user_record: (pubkey,pkey) = init_person_key (person, plc_keys ) - person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey) - person_gid.set_email(person['email']) + person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey, email=person['email']) user_record = RegUser (hrn=person_hrn, gid=person_gid, pointer=person['person_id'], authority=get_authority(person_hrn), @@ -339,9 +338,12 @@ class PlImporter: return False # are all the SFA keys known to PLC ? new_keys=False - for sfa_key in sfa_keys: - if not sfa_key_in_list (sfa_key,plc_keys): - new_keys = True + if not sfa_keys and plc_keys: + new_keys=True + else: + for sfa_key in sfa_keys: + if not sfa_key_in_list (sfa_key,plc_keys): + new_keys = True if new_keys: (pubkey,pkey) = init_person_key (person, plc_keys) person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey) @@ -351,6 +353,7 @@ class PlImporter: else: user_record.reg_keys=[ RegKey (pubkey['key'], pubkey['key_id'])] user_record.gid = person_gid + user_record.just_updated() self.logger.info("PlImporter: updated person: %s" % user_record) user_record.email = person['email'] dbsession.commit()