Add function to merge multiple XML files

[nagixsc.git] / nagixsc_http2nagios.py

diff --git a/nagixsc_http2nagios.py b/nagixsc_http2nagios.py
index e0a639b3218cd6595624b13cbe46fb358ddf4052..e327bc18f46368e9017859848f4d8ac2d1e43e5a 100755 (executable)
--- a/nagixsc_http2nagios.py
+++ b/nagixsc_http2nagios.py
@@ -1,28 +1,63 @@
 #!/usr/bin/python
 
-import BaseHTTPServer
+import ConfigParser
 import base64
 import cgi
+import optparse
 import os
 import re
-import subprocess
+import sys
 
 try:
        from hashlib import md5
 except ImportError:
        from md5 import md5
 
-config = {     'ip':                   '',
-                       'port':                 15667,
-               }
+##############################################################################
 
-users = {      'nagixsc':              '019b0966d98fb71d1a4bc4ca0c81d5cc',             # PW: nagixsc
-               }
+from nagixsc import *
 
-XMLFILESIZE=102400
-X2N='./nagixsc_xml2nagios.py -O passive -vvv -f -'
+##############################################################################
 
-class HTTP2NagiosHandler(BaseHTTPServer.BaseHTTPRequestHandler):
+parser = optparse.OptionParser()
+
+parser.add_option('-c', '', dest='cfgfile', help='Config file')
+parser.add_option('-d', '--daemon', action='store_true', dest='daemon', help='Daemonize, go to background')
+parser.add_option('', '--nossl', action='store_true', dest='nossl', help='Disable SSL (overwrites config file)')
+
+parser.set_defaults(cfgfile='http2nagios.cfg')
+
+(options, args) = parser.parse_args()
+
+cfgread = ConfigParser.SafeConfigParser()
+cfgread.optionxform = str # We need case-sensitive options
+cfg_list = cfgread.read(options.cfgfile)
+
+if cfg_list == []:
+       print 'Config file "%s" could not be read!' % options.cfgfile
+       sys.exit(1)
+
+config = {}
+try:
+       config['ip']   = cfgread.get('server', 'ip')
+       config['port'] = cfgread.getint('server', 'port')
+       config['ssl']  = cfgread.getboolean('server', 'ssl')
+       config['cert'] = cfgread.get('server', 'sslcert')
+
+       config['max_xml_file_size']  = cfgread.get('server', 'max_xml_file_size')
+       config['checkresultdir'] = cfgread.get('mode_checkresult', 'dir')
+
+except ConfigParser.NoOptionError, e:
+       print 'Config file error: %s ' % e
+       sys.exit(1)
+
+users = {}
+for u in cfgread.options('users'):
+       users[u] = cfgread.get('users', u)
+
+##############################################################################
+
+class HTTP2NagiosHandler(MyHTTPRequestHandler):
 
        def http_error(self, code, output):
                self.send_response(code)
@@ -47,8 +82,6 @@ class HTTP2NagiosHandler(BaseHTTPServer.BaseHTTPRequestHandler):
 
 
        def do_POST(self):
-               cmdline = X2N
-
                # Check Basic Auth
                try:
                        authdata = base64.b64decode(self.headers['Authorization'].split(' ')[1]).split(':')
@@ -68,34 +101,40 @@ class HTTP2NagiosHandler(BaseHTTPServer.BaseHTTPRequestHandler):
                xmltext = query.get('xmlfile')[0]
 
                if len(xmltext) > 0:
-                       try:
-                               cmd     = subprocess.Popen(cmdline.split(' '), stdin=subprocess.PIPE, stdout=subprocess.PIPE)
-                               output  = cmd.communicate(xmltext)[0].rstrip()
-                               retcode = cmd.returncode
-
-                               if retcode == 0:
-                                       self.send_response(200)
-                                       self.send_header('Content-Type', 'text/plain')
-                                       self.end_headers()
-                                       self.wfile.write(output)
-                                       return
-                               else:
-                                       http_error(500, output)
-                                       return
-
-                       except OSError:
-                               http_error(500, 'Nag(IX)SC - Could not execute "%s"' % cmdline)
+                       doc = read_xml_from_string(xmltext)
+                       checks = xml_to_dict(doc)
+
+                       (count_services, count_failed, list_failed) = dict2out_checkresult(checks, xml_get_timestamp(doc), config['checkresultdir'], 0)
+
+                       if count_failed < count_services:
+                               self.send_response(200)
+                               self.send_header('Content-Type', 'text/plain')
+                               self.end_headers()
+                               self.wfile.write('Wrote %s check results, %s failed' % (count_services, count_failed))
+                               return
+                       else:
+                               self.http_error(501, 'Could not write all %s check results' % count_services)
                                return
 
                else:
-                       http_error(500, 'Nag(IX)SC - No data received')
+                       self.http_error(502, 'Nag(IX)SC - No data received')
                        return
 
 
 
 def main():
+       if options.nossl:
+               config['ssl'] = False
+
+       if config['ssl'] and not os.path.isfile(config['cert']):
+               print 'SSL certificate "%s" not found!' % config['cert']
+               sys.exit(127)
+
+       if options.daemon:
+               daemonize(pidfile='/var/run/nagixsc_http2nagios.pid')
+
+       server = MyHTTPServer((config['ip'], config['port']), HTTP2NagiosHandler, ssl=config['ssl'], sslpemfile=config['cert'])
        try:
-               server = BaseHTTPServer.HTTPServer((config['ip'], config['port']), HTTP2NagiosHandler)
                server.serve_forever()
        except:
                server.socket.close()