X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=syncplcdb.py;h=6d28e34e9c7994eca0f53b64c7668498d0a06a27;hb=refs%2Fheads%2F1.0;hp=0bae012fcb758213222ea9df4a1797d2e61cf48f;hpb=66b2c2382b2c4550f962a7224466f26a23510820;p=monitor.git

diff --git a/syncplcdb.py b/syncplcdb.py
index 0bae012..6d28e34 100755
--- a/syncplcdb.py
+++ b/syncplcdb.py
@@ -1,12 +1,10 @@
 #!/usr/bin/python
 
 import plc
-from config import config
-import soltesz
+import config
+import database
 import sys
 
-config = config()
-
 def dsites_from_lsites(l_sites):
 	d_sites = {}
 	id2lb = {}
@@ -20,6 +18,7 @@ def dsites_from_lsites(l_sites):
 	return (d_sites, id2lb)
 
 def dsn_from_dsln(d_sites, id2lb, l_nodes):
+	lb2hn = {}
 	dsn = {}
 	hn2lb = {}
 	for node in l_nodes:
@@ -27,44 +26,72 @@ def dsn_from_dsln(d_sites, id2lb, l_nodes):
 		if node['site_id'] in id2lb.keys():
 			login_base = id2lb[node['site_id']]
 		else:
+			print "%s has a foreign site_id %s" % (node['hostname'], 
+													node['site_id'])
+			continue
 			for i in id2lb:
 				print i, " ", id2lb[i]
 			raise Exception, "Node has missing site id!! %s %d" %(node['hostname'], node['site_id'])
 		if not login_base in dsn:
+			lb2hn[login_base] = []
 			dsn[login_base] = {}
 			dsn[login_base]['plc'] = d_sites[login_base]
 			dsn[login_base]['monitor'] = {} # event log, or something
 
 		hostname = node['hostname']
+		lb2hn[login_base].append(node)
 		dsn[login_base][hostname] = {}
 		dsn[login_base][hostname]['plc'] = node
 		dsn[login_base][hostname]['comon'] = {}
 		dsn[login_base][hostname]['monitor'] = {}
 
 		hn2lb[hostname] = login_base
-	return (dsn, hn2lb)
+	return (dsn, hn2lb, lb2hn)
+
+def create_netid2ip(l_nodes, l_nodenetworks):
+	netid2ip = {}
+	for node in l_nodes:
+		for netid in node['interface_ids']:
+			found = False
+			for nn in l_nodenetworks:
+				if nn['interface_id'] == netid:
+					found = True
+					netid2ip[netid] = nn['ip']
+			if not found:
+				print "ERROR! %s" % node
+
+	return netid2ip
 
 def create_plcdb():
 
 	# get sites, and stats
-	l_sites = plc.getSites({'peer_id':None}, ['login_base', 'site_id'])
+	l_sites = plc.getSites({'peer_id':None}, ['login_base', 'site_id', 'abbreviated_name', 'latitude', 'longitude', 
+											  'max_slices', 'slice_ids', 'node_ids' ])
 	if len(l_sites) == 0:
 		sys.exit(1)
 	(d_sites,id2lb) = dsites_from_lsites(l_sites)
 
 	# get nodes at each site, and 
-	l_nodes = plc.getNodes({'peer_id':None}, ['hostname', 'site_id', 'version', 'last_updated', 'date_created', 'last_contact', 'pcu_ids'])
-	(plcdb, hn2lb) = dsn_from_dsln(d_sites, id2lb, l_nodes)
+	l_nodes = plc.getNodes({'peer_id':None}, ['hostname', 'node_id', 'ports', 'site_id', 'version', 
+	                                          'last_updated', 'date_created', 'last_contact', 'pcu_ids', 'interface_ids'])
+
+	l_nodenetworks = plc.getNodeNetworks()
+	(plcdb, hn2lb, lb2hn) = dsn_from_dsln(d_sites, id2lb, l_nodes)
+	netid2ip = create_netid2ip(l_nodes, l_nodenetworks)
 
 	# save information for future.
 	id2lb = id2lb
 	hn2lb = hn2lb
 	db = plcdb
 
-	if config.cachenodes:
-		soltesz.dbDump("plcdb_hn2lb", hn2lb)
-		soltesz.dbDump("l_plcnodes", l_nodes)
-		soltesz.dbDump("l_plcsites", l_sites)
+	if ('cachenodes' in dir(config) and config.cachenodes) or \
+		'cachenodes' not in dir(config):
+		database.dbDump("plcdb_hn2lb", hn2lb)
+		database.dbDump("plcdb_lb2hn", lb2hn)
+		database.dbDump("plcdb_netid2ip", netid2ip)
+		database.dbDump("l_plcnodenetworks", l_nodenetworks)
+		database.dbDump("l_plcnodes", l_nodes)
+		database.dbDump("l_plcsites", l_sites)
 	
 	return l_nodes