+ self.logger.log_exc(
+ "PlImporter: failed to import node {}".format(node_hrn))
+ continue
+ else:
+ # xxx update the record ...
+ pass
+ node_record.stale = False
+
+ site_pis = []
+ # import persons
+ for person_id in site['person_ids']:
+ proceed = False
+ if person_id in persons_by_id:
+ person = persons_by_id[person_id]
+ proceed = True
+ elif person_id in disabled_person_ids:
+ pass
+ else:
+ self.logger.warning("PlImporter: cannot locate person_id {} in site {} - ignored"
+ .format(person_id, site_hrn))
+ # make sure to NOT run this if anything is wrong
+ if not proceed:
+ continue
+
+ #person_hrn = email_to_hrn(site_hrn, person['email'])
+ person_hrn = person['hrn']
+ if person_hrn is None:
+ self.logger.warn(
+ "Person {} has no hrn - skipped".format(person['email']))
+ continue
+ # xxx suspicious again
+ if len(person_hrn) > 64:
+ person_hrn = person_hrn[:64]
+ person_urn = hrn_to_urn(person_hrn, 'user')
+
+ user_record = self.locate_by_type_hrn('user', person_hrn)
+
+ # return a tuple pubkey (a plc key object) and pkey (a Keypair
+ # object)
+ def init_person_key(person, plc_keys):
+ pubkey = None
+ if person['key_ids']:
+ # randomly pick first key in set
+ pubkey = plc_keys[0]
+ try:
+ pkey = convert_public_key(pubkey['key'])
+ except:
+ self.logger.warn('PlImporter: unable to convert public key for {}'
+ .format(person_hrn))
+ pkey = Keypair(create=True)
+ else:
+ # the user has no keys. Creating a random keypair for
+ # the user's gid
+ self.logger.warn("PlImporter: person {} does not have a PL public key"
+ .format(person_hrn))
+ pkey = Keypair(create=True)
+ return (pubkey, pkey)
+
+ # new person
+ try:
+ 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,
+ email=person['email'])
+ user_record = RegUser(hrn=person_hrn, gid=person_gid,
+ pointer=person['person_id'],
+ authority=get_authority(
+ person_hrn),
+ email=person['email'])
+ if pubkey:
+ user_record.reg_keys = [
+ RegKey(pubkey['key'], pubkey['key_id'])]
+ else:
+ self.logger.warning(
+ "No key found for user {}".format(user_record))
+ user_record.just_created()
+ global_dbsession.add(user_record)
+ global_dbsession.commit()
+ self.logger.info(
+ "PlImporter: imported person: {}".format(user_record))
+ self.remember_record(user_record)
+ else:
+ # update the record ?
+ #
+ # if a user key has changed then we need to update the
+ # users gid by forcing an update here
+ #
+ # right now, SFA only has *one* key attached to a user, and this is
+ # the key that the GID was made with
+ # so the logic here is, we consider that things are OK (unchanged) if
+ # all the SFA keys are present as PLC keys
+ # otherwise we trigger the creation of a new gid from *some* plc key
+ # and record this on the SFA side
+ # it would make sense to add a feature in PLC so that one could pick a 'primary'
+ # key but this is not available on the myplc side for now
+ # = or = it would be much better to support several keys in SFA but that
+ # does not seem doable without a major overhaul in the data model as
+ # a GID is attached to a hrn, but it's also linked to a key, so...
+ # NOTE: with this logic, the first key entered in PLC remains the one
+ # current in SFA until it is removed from PLC
+ sfa_keys = user_record.reg_keys
+
+ def sfa_key_in_list(sfa_key, plc_keys):
+ for plc_key in plc_keys:
+ if plc_key['key'] == sfa_key.key:
+ return True
+ return False
+ # are all the SFA keys known to PLC ?
+ new_keys = False
+ 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)
+ person_gid.set_email(person['email'])
+ if not pubkey:
+ user_record.reg_keys = []
+ 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: {}".format(user_record))
+ user_record.email = person['email']
+ global_dbsession.commit()
+ user_record.stale = False
+ # accumulate PIs - PLCAPI has a limitation that when someone has PI role
+ # this is valid for all sites she is in..
+ # PI is coded with role_id == 20
+ if 20 in person['role_ids']:
+ site_pis.append(user_record)
+
+ # PL Admins need to marked as PI of the top authority
+ # record
+ if 10 in person['role_ids'] and user_record not in top_auth_record.reg_pis:
+ admins.append(user_record)
+
+ except:
+ self.logger.log_exc("PlImporter: failed to import person {} {}"
+ .format(person['person_id'], person['email']))
+
+ # maintain the list of PIs for a given site
+ # for the record, Jordan had proposed the following addition as a welcome hotfix to a previous version:
+ # site_pis = list(set(site_pis))
+ # this was likely due to a bug in the above logic, that had to do with disabled persons
+ # being improperly handled, and where the whole loop on persons
+ # could be performed twice with the same person...
+ # so hopefully we do not need to eliminate duplicates explicitly
+ # here anymore
+ site_record.reg_pis = list(set(site_pis))
+ global_dbsession.commit()