X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=mailmonitor.py;h=fab3e65ab572a4bd591399cc02d44b231ddaa361;hb=57fc3f2c580971f7a31c708764557d6273b83216;hp=3257d63643efb36b85965a475ebddd43e32eeabb;hpb=03f339edc8521e36a12bfc1cdfd1b1a6ea3ab2d8;p=monitor.git

diff --git a/mailmonitor.py b/mailmonitor.py
index 3257d63..fab3e65 100644
--- a/mailmonitor.py
+++ b/mailmonitor.py
@@ -6,15 +6,15 @@
 #
 # $Id: monitor.py,v 1.7 2007/07/03 19:59:02 soltesz Exp $
 
-import database
-
-import rt
 import sys
 
-import plc
-api = plc.getAuthAPI()
+from monitor import database
+from monitor.wrapper import rt
+from monitor.wrapper import plc
+from monitor.policy import *
+from monitor.database.info.model import *
 
-from clean_policy import *
+api = plc.getAuthAPI()
 
 def reboot(hostname):
 	print "CALLING: mailmonitor.reboot(%s)" % hostname
@@ -23,9 +23,9 @@ def reboot(hostname):
 	if len(l_nodes) == 0:
 		raise Exception("No such host: %s" % hostname)
 	
-	l_blacklist = database.if_cached_else(1, "l_blacklist", lambda : [])
-	l_ticket_blacklist = database.if_cached_else(1,"l_ticket_blacklist",lambda : [])
+	q_blacklist = BlacklistRecord.query.all()
 
+	l_blacklist = [ n.hostname for n in q_blacklist ]
 	l_nodes  = filter(lambda x : not x['hostname'] in l_blacklist, l_nodes)
 	if len(l_nodes) == 0:
 		raise Exception("Host removed via blacklist: %s" % hostname)