X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=monitor_policy.py;h=45242eaf00c1d9ebd6d581b9e834f57caf11eb54;hb=6f2351e4b44590221425fa9b4bfa77c92db49b6a;hp=3dd244c9a940fe702d171c26afda848a6302a482;hpb=c3f2afdc81c6711c3825c82e2cd4970671575438;p=monitor.git

diff --git a/monitor_policy.py b/monitor_policy.py
index 3dd244c..45242ea 100644
--- a/monitor_policy.py
+++ b/monitor_policy.py
@@ -2,15 +2,24 @@ import config
 import database
 import time
 import mailer
-from www.printbadnodes import cmpCategoryVal
+from unified_model import cmpCategoryVal
 import sys
 import emailTxt
 import string
 
-from policy import get_ticket_id, print_stats, close_rt_backoff, reboot_node
 from rt import is_host_in_rt_tickets
 import plc
 
+def get_ticket_id(record):
+	if 'ticket_id' in record and record['ticket_id'] is not "" and record['ticket_id'] is not None:
+		return record['ticket_id']
+	elif 		'found_rt_ticket' in record and \
+		 record['found_rt_ticket'] is not "" and \
+		 record['found_rt_ticket'] is not None:
+		return record['found_rt_ticket']
+	else:
+		return None
+
 # Time to enforce policy
 POLSLEEP = 7200
 
@@ -821,6 +830,17 @@ class Diagnose:
 
 		return up
 
+def close_rt_backoff(args):
+	if 'ticket_id' in args and (args['ticket_id'] != "" and args['ticket_id'] != None):
+		mailer.closeTicketViaRT(args['ticket_id'], 
+								"Ticket CLOSED automatically by SiteAssist.")
+		plc.enableSlices(args['hostname'])
+		plc.enableSliceCreation(args['hostname'])
+	return
+
+def reboot_node(args):
+	host = args['hostname']
+	return reboot.reboot_policy(host, True, config.debug)
 
 class Action:
 	def __init__(self, diagnose_out):
@@ -874,7 +894,7 @@ class Action:
 		#print_stats("sites_observed", stats)
 		#print_stats("sites_diagnosed", stats)
 		#print_stats("nodes_diagnosed", stats)
-		print_stats("sites_emailed", stats)
+		self.print_stats("sites_emailed", stats)
 		#print_stats("nodes_actedon", stats)
 		print string.join(stats['allsites'], ",")
 
@@ -917,18 +937,22 @@ class Action:
 		if ADMIN & roles:
 			contacts += [config.email]
 		if TECH & roles:
-			contacts += [TECHEMAIL % loginbase]
+			#contacts += [TECHEMAIL % loginbase]
+			contacts += plc.getTechEmails(loginbase)
 		if PI & roles:
-			contacts += [PIEMAIL % loginbase]
+			#contacts += [PIEMAIL % loginbase]
+			contacts += plc.getPIEmails(loginbase)
 		if USER & roles:
+			contacts += plc.getSliceUserEmails(loginbase)
 			slices = plc.slices(loginbase)
 			if len(slices) >= 1:
-				for slice in slices:
-					contacts += [SLICEMAIL % slice]
 				print "SLIC: %20s : %d slices" % (loginbase, len(slices))
 			else:
 				print "SLIC: %20s : 0 slices" % loginbase
 
+		unique_contacts = set(contacts)
+		contacts = [ c for c in unique_contacts ]	# convert back into list
+
 		try:
 			subject = message[0] % args
 			body = message[1] % args