sfa/client/client_helper.py

   1 import sys
   2 def pg_users_arg(records):
   3     users = []
   4     for record in records:
   5         if record['type'] != 'user':
   6             continue
   7         user = {'urn': record['geni_urn'],
   8                 'keys': record['keys']}
   9         users.append(user)
  10     return users
  11
  12 def sfa_users_arg(records, slice_record):
  13     users = []
  14     print>>sys.stderr, " \r\n \r\n \t CLIENT_HELPER.PY sfa_users_arg slice_record %s \r\n records %s"%(slice_record,records)
  15     for record in records:
  16         if record['type'] != 'user':
  17             continue
  18         user = {#'urn': record['geni_urn'],
  19                 #'keys': record['keys'],
  20                 #'email': record['email'], # needed for MyPLC
  21                 'person_id': record['record_id'],
  22                 'hrn': record['hrn'],
  23                 'type': record['type'],
  24                 'authority' : record['authority'],
  25                 'gid' : record['gid'],
  26                 #'first_name': record['first_name'], # needed for MyPLC
  27                 #'last_name': record['last_name'], # needed for MyPLC
  28                 'slice_record': slice_record, # needed for legacy refresh peer
  29                 #'key_ids': record['key_ids'] # needed for legacy refresh peer
  30                 }
  31         users.append(user)
  32         print>>sys.stderr, " \r\n \r\n \t CLIENT_HELPER.PY sfa_users_arg user %s",user
  33     return users
  34
  35 def sfa_to_pg_users_arg(users):
  36
  37     new_users = []
  38     fields = ['urn', 'keys']
  39     for user in users:
  40         new_user = dict([item for item in user.items() \
  41           if item[0] in fields])
  42         new_users.append(new_user)
  43     return new_users