www/printbadnodes.py

[monitor.git] / rt.py

diff --git a/rt.py b/rt.py
index 4a951b9..0ea0a55 100644 (file)
--- a/rt.py
+++ b/rt.py
@@ -7,15 +7,12 @@ import logging
 import Queue
 import time 
 import re
-import comon
-import soltesz
+import database
 from threading import *
+import monitorconfig
 
 # TODO: merge the RT mailer from mailer.py into this file.
 
-# RT database access constants file
-RT_DB_CONSTANTS_PATH='rt_db'
-
 #Logging
 logger = logging.getLogger("monitor")
 
@@ -69,17 +66,17 @@ def readConstantsFile( file_path ):
 def open_rt_db():
 
        # read plc database passwords and connect
-       rt_db_constants= readConstantsFile(RT_DB_CONSTANTS_PATH)
-       if rt_db_constants is None:
-               print "Unable to read database access constants from %s" % \
-                         RT_DB_CONSTANTS_PATH
-               return -1
+       #rt_db_constants= readConstantsFile(RT_DB_CONSTANTS_PATH)
+       #if rt_db_constants is None:
+       #       print "Unable to read database access constants from %s" % \
+       #                 RT_DB_CONSTANTS_PATH
+       #       return -1
 
        try:
-               rt_db = MySQLdb.connect(host=rt_db_constants['RT_DB_HOST'],
-                               user=rt_db_constants['RT_DB_USER'],
-                               passwd=rt_db_constants['RT_DB_PASSWORD'],
-                               db=rt_db_constants['RT_DB_NAME'])
+               rt_db = MySQLdb.connect(host=monitorconfig.RT_DB_HOST,
+                                                               user=monitorconfig.RT_DB_USER,
+                                                               passwd=monitorconfig.RT_DB_PASSWORD,
+                                                               db=monitorconfig.RT_DB_NAME)
        except Exception, err:
                print "Failed to connect to RT database: %s" %err
                return -1
@@ -142,7 +139,7 @@ def rt_tickets():
 #WHERE Tk.Queue != 10 AND Tk.id > 10000 AND 
 #Tr.id=At.TransactionID AND ( Tk.Status = 'open' OR
 #Tk.Status = 'new') """
-       sqlall = """SELECT distinct Tk.id, Tk.Status, Tk.Subject, At.Content, Us.EmailAddress, Tk.LastUpdated FROM Tickets AS Tk, Attachments AS At, Users as Us JOIN Transactions AS Tr ON Tk.id=Tr.ObjectId WHERE (Tk.Queue=3 OR Tk.Queue=22) AND Tk.id > 10000 AND Tr.id=At.TransactionID AND ( Tk.Status = 'open' OR Tk.Status = 'new') AND Us.id=Tk.LastUpdatedBy """
+       sqlall = """SELECT distinct Tk.id, Tk.Status, Tk.Subject, At.Content, Us.EmailAddress, Tk.LastUpdated, Q.Name, Tk.Owner FROM Tickets AS Tk, Attachments AS At, Queues as Q, Users as Us JOIN Transactions AS Tr ON Tk.id=Tr.ObjectId WHERE (Tk.Queue=3 OR Tk.Queue=22) AND Tk.id > 10000 AND Tr.id=At.TransactionID AND ( Tk.Status = 'open' OR Tk.Status = 'new') AND Us.id=Tk.LastUpdatedBy AND Q.id=Tk.Queue """
 
 
        raw = fetch_from_db(db, sql)
@@ -163,6 +160,8 @@ def rt_tickets():
                                "content":str(x[3]),
                                "email":str(x[4]),
                                "lastupdated":str(x[5]),
+                               "queue":str(x[6]),
+                               "owner":str(x[7]),
                                },
                                raw)
 
@@ -171,7 +170,7 @@ def rt_tickets():
        idTickets = {}
        for t in tickets_all:
                idTickets[t['ticket_id']] = t
-       soltesz.dbDump("idTickets", idTickets)
+       database.dbDump("idTickets", idTickets)
 
        return tickets
 
@@ -204,7 +203,7 @@ def is_host_in_rt_tickets(host, ticket_blacklist, ad_rt_tickets):
                return (False, None)
 
        # This search, while O(tickets), takes less than a millisecond, 05-25-07
-       #t = soltesz.MyTimer()
+       #t = commands.MyTimer()
        ret = search_tickets(host, ad_rt_tickets)
        #del t
 
@@ -310,7 +309,7 @@ def main():
        logger.addHandler(ch)
 
        tickets = rt_tickets()
-       soltesz.dbDump("ad_dbTickets", tickets)
+       database.dbDump("ad_dbTickets", tickets)
 
 
 if __name__ == '__main__':