sfa/plc/peers.py

   1 from sfa.util.xrn import get_authority
   2 from types import StringTypes
   3
   4 def get_peer(api, hrn):
   5     # Because of myplc native federation,  we first need to determine if this
   6     # slice belongs to out local plc or a myplc peer. We will assume it
   7     # is a local site, unless we find out otherwise
   8     peer = None
   9
  10     # get this slice's authority (site)
  11     slice_authority = get_authority(hrn)
  12
  13     # get this site's authority (sfa root authority or sub authority)
  14     site_authority = get_authority(slice_authority).lower()
  15     # check if we are already peered with this site_authority, if so
  16     peers = api.driver.GetPeers( {}, ['peer_id', 'peername', 'shortname', 'hrn_root'])
  17     for peer_record in peers:
  18         names = [name.lower() for name in peer_record.values() if isinstance(name, StringTypes)]
  19         if site_authority in names:
  20             peer = peer_record['shortname']
  21
  22     return peer
  23
  24
  25 def get_sfa_peer(api, hrn):
  26     # return the authority for this hrn or None if we are the authority
  27     sfa_peer = None
  28     slice_authority = get_authority(hrn)
  29     site_authority = get_authority(slice_authority)
  30
  31     if site_authority != api.hrn:
  32         sfa_peer = site_authority
  33
  34     return sfa_peer
  35