- try:
- slab_key = person['pkey']
- # new person
- if not user_record:
- (pubkey,pkey) = init_person_key (person, slab_key )
- person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey)
- person_gid.set_email(person['email'])
- user_record = RegUser (hrn=person_hrn, gid=person_gid,
- pointer='-1',
- authority=get_authority(person_hrn),
- email=person['email'])
- if pubkey:
- user_record.reg_keys=[RegKey (pubkey)]
- else:
- self.logger.warning("No key found for user %s"%user_record)
- user_record.just_created()
- dbsession.add (user_record)
- dbsession.commit()
- self.logger.info("SlabImporter: imported person: %s" % user_record)
- print>>sys.stderr, "\r\n \r\n SLAB IMPORTER PERSON IMPORT NOTuser_record %s " %(user_record)
- self.update_just_added_records_dict( user_record )
- else:
- # update the record ?
- # if user's primary key has changed then we need to update the
- # users gid by forcing an update here
- sfa_keys = user_record.reg_keys
- #def key_in_list (key,sfa_keys):
- #for reg_key in sfa_keys:
- #if reg_key.key==key['key']: return True
- #return False
- # is there a new key in myplc ?
- new_keys=False
- if key is not sfa_keys :
- new_keys = True
- if new_keys:
- (pubkey,pkey) = init_person_key (person, slab_key)
- person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey)
- if not pubkey:
- user_record.reg_keys=[]
- else:
- user_record.reg_keys=[ RegKey (pubkey)]
- self.logger.info("SlabImporter: updated person: %s" % user_record)
- user_record.email = person['email']
- dbsession.commit()
- user_record.stale=False
- except:
- self.logger.log_exc("SlabImporter: failed to import person %s"%(person) )
+ #try:
+ #slab_key = person['pkey']
+ ## new person
+ #if not user_record:
+ #(pubkey,pkey) = init_person_key (person, slab_key )
+ #person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey)
+ #person_gid.set_email(person['email'])
+ #user_record = RegUser (hrn=person_hrn, gid=person_gid,
+ #pointer='-1',
+ #authority=get_authority(person_hrn),
+ #email=person['email'])
+ #if pubkey:
+ #user_record.reg_keys=[RegKey (pubkey)]
+ #else:
+ #self.logger.warning("No key found for user %s"%user_record)
+ #user_record.just_created()
+ #dbsession.add (user_record)
+ #dbsession.commit()
+ #self.logger.info("SlabImporter: imported person: %s" % user_record)
+ #print>>sys.stderr, "\r\n \r\n SLAB IMPORTER PERSON IMPORT NOTuser_record %s " %(user_record)
+ #self.update_just_added_records_dict( user_record )
+ #else:
+ ## update the record ?
+ ## if user's primary key has changed then we need to update the
+ ## users gid by forcing an update here
+ #sfa_keys = user_record.reg_keys
+ ##def key_in_list (key,sfa_keys):
+ ##for reg_key in sfa_keys:
+ ##if reg_key.key==key['key']: return True
+ ##return False
+ ## is there a new key in myplc ?
+ #new_keys=False
+ #if key is not sfa_keys :
+ #new_keys = True
+ #if new_keys:
+ #(pubkey,pkey) = init_person_key (person, slab_key)
+ #person_gid = self.auth_hierarchy.create_gid(person_urn, create_uuid(), pkey)
+ #if not pubkey:
+ #user_record.reg_keys=[]
+ #else:
+ #user_record.reg_keys=[ RegKey (pubkey)]
+ #self.logger.info("SlabImporter: updated person: %s" % user_record)
+ #user_record.email = person['email']
+ #dbsession.commit()
+ #user_record.stale=False
+ #except:
+ #self.logger.log_exc("SlabImporter: failed to import person %s"%(person) )