3 from optparse import OptionParser
5 from PLC.Namespace import hostname_to_hrn, email_to_hrn, slicename_to_hrn
9 from sfa.util.config import Config
10 toplevel=Config().SFA_INTERFACE_HRN
12 toplevel=api.config.PLC_HRN_ROOT
14 def handle_nodes (sites,sites_by_id, dry_run, verbose):
15 nodes=GetNodes ({'peer_id':None},['node_id','hostname','hrn'])
16 nodes_by_id = dict ( [ (node['node_id'],node) for node in nodes ] )
18 login_base=site['login_base']
19 for node_id in site.get('node_ids', []):
20 try: node=nodes_by_id[node_id]
21 except: print 'cannot find node %s'%node_id; continue
22 hrn=hostname_to_hrn (toplevel, login_base, node['hostname'])
23 if node['hrn'] != hrn:
24 print "Node %s - current hrn %s, should be %s"%(node['hostname'], node['hrn'], hrn)
26 SetNodeHrn (node['node_id'],hrn)
28 if verbose: print "Node %s OK"%node['hostname']
30 def handle_persons (sites,sites_by_id, dry_run,verbose):
31 persons=GetPersons ({'peer_id':None},['person_id','email','hrn','site_ids'])
32 persons_by_id = dict ( [ (person['person_id'],person) for person in persons ] )
34 login_base=site['login_base']
35 for person_id in site.get('person_ids', []):
36 try: person=persons_by_id[person_id]
37 except: print 'cannot find person %s'%person_id; continue
38 how_many=len(person['site_ids'])
40 if verbose: print "Checking persons in exactly one site -- person %s in %s site(s) -- ignored"%(person['email'],how_many)
43 hrn=email_to_hrn ("%s.%s"%(toplevel,login_base),person['email'])
44 if person['hrn'] != hrn:
45 print "Person %s - current hrn %s, should be %s"%(person['email'], person['hrn'], hrn)
47 SetPersonHrn (person['person_id'],hrn)
49 if verbose: print "Person %s OK"%person['email']
52 def handle_slices (sites,sites_by_id, dry_run,verbose):
53 slices=GetSlices ({'peer_id':None},['slice_id','name','hrn','site_id'])
54 slices_by_id = dict ( [ (slice['slice_id'],slice) for slice in slices ] )
56 login_base=site['login_base']
57 for slice_id in site.get('slice_ids', []):
58 try: slice=slices_by_id[slice_id]
59 except: print 'cannot find slice %s'%slice_id; continue
60 hrn=slicename_to_hrn (toplevel, slice['name'])
61 if slice['hrn'] != hrn:
62 print "Slice %s - current hrn %s, should be %s"%(slice['name'], slice['hrn'], hrn)
64 SetSliceHrn (slice['slice_id'],hrn)
66 if verbose: print "Slice %s OK"%slice['name']
69 def handle_sites (sites,sites_by_id, dry_run,verbose):
71 hrn='.'.join([toplevel, site['login_base']])
72 if site['hrn'] != hrn:
73 print "Site %s - current hrn %s, should be %s"%(site['name'], site['hrn'], hrn)
75 SetSiteHrn (site['site_id'],hrn)
77 if verbose: print "Site %s OK"%site['name']
83 Checks that the hrn tags are correctly set
87 parser = OptionParser(usage=usage)
88 parser.add_option("-p", "--person", action = "store_true", default = False,
89 dest='persons',help="run on persons")
90 parser.add_option("-n", "--node", action = "store_true", default = False,
91 dest='nodes',help="run on nodes")
92 parser.add_option("-S", "--slice", action = "store_true", default = False,
93 dest='slices',help="run on slices")
94 parser.add_option("-t", "--site", action = "store_true", default = False,
95 dest='sites',help="run on sites")
96 parser.add_option("-s", "--show", action = "store_true", default = False,
97 dest='show', help="dry run, only show discrepencies")
98 parser.add_option("-v", "--verbose", action = "store_true", default = False,
99 dest='verbose', help="be verbose")
100 (options, args) = parser.parse_args()
105 # if neither -p nor -n, run both
106 if not options.nodes and not options.persons and not options.slices and not options.sites:
113 verbose=options.verbose
114 # optimizing : we compute the set of sites only once
115 sites = GetSites({'peer_id':None},['site_id','login_base','node_ids','person_ids','name','hrn'])
116 # remove external sites created through SFA
117 sites = [site for site in sites if not site['name'].startswith('sfa:')]
118 sites_by_id = dict ( [ (site['site_id'], site) for site in sites ] )
120 if options.nodes: handle_nodes(sites,sites_by_id,dry_run,verbose)
121 if options.persons: handle_persons(sites,sites_by_id,dry_run,verbose)
122 if options.slices: handle_slices(sites,sites_by_id,dry_run,verbose)
123 if options.sites: handle_sites(sites,sites_by_id,dry_run,verbose)
125 if __name__ == "__main__":