- person_record = RegUser ()
- person_record.type='user'
- person_record.hrn=hrn
- person_record.gid=person_gid
- person_record.pointer=person['person_id']
- person_record.authority=get_authority(hrn)
- dbsession.add (person_record)
- dbsession.commit()
- self.logger.info("PlImporter: imported person: %s" % person_record)
+ if previous_record:
+ previous_record.gid=person_gid
+ if pubkey: previous_record.keys=[RegKey (pubkey['key'], pubkey['key_id'])]
+ self.logger.info("PlImporter: updated person: %s" % previous_record)
+ else:
+ new_record = RegUser (hrn=hrn, gid=person_gid,
+ pointer=person['person_id'],
+ authority=get_authority(hrn),
+ email=person['email'])
+ if pubkey: new_record.keys=[RegKey (pubkey['key'], pubkey['key_id'])]
+ dbsession.add (new_record)
+ dbsession.commit()
+ self.logger.info("PlImporter: imported person: %s" % new_record)