# # __main__.py # # This module is the entrypoint of the `logparse` shell command and also # contains single-use functions which don't fit elsewhere. # import logging, logging.handlers import argparse import os import glob import sys from datetime import datetime import logparse from . import config from logparse import formatting, mail from .parsers import load_parsers, sudo, sshd, cron, httpd, smbd, postfix, zfs, temperature def rotate(): # rotate logs using systemd logrotate if parser.parse_args().function is None: if (config.prefs['rotate'] == 'y'): subprocess.call("/usr/sbin/logrotate -f /etc/logrotate.conf", shell=True) logger.info("rotated logfiles") else: logger.debug("user doesn't want to rotate logs") if (config.prefs['rotate'] == 's'): logger.debug("Here is the output of `logrotate -d /etc/logrotate.conf` (simulated):") sim = subprocess.check_output("/usr/sbin/logrotate -d /etc/logrotate.conf", shell=True) logger.debug(sim) def main(): # Get arguments parser = argparse.ArgumentParser(description='grab logs of some common services and send them by email') parser.add_argument('-t','--to', help='mail recipient (\"to\" address)', required=False) parser.add_argument('-c', '--config', help='path to config file', required=False) parser.add_argument('-p', '--print', help='print HTML to stdout', required=False, dest='printout', action='store_true', default=False) parser.add_argument('-d', '--destination', help='file to output HTML', required=False) parser.add_argument('-f', '--overwrite', help='force overwrite an existing output file', required=False, action='store_true', default=False) parser.add_argument('-v', '--verbose', help='verbose console/syslog output (for debugging)', required=False, default=False, action='store_true') parser.add_argument('-r', '--rotate', help='force rotate log files using systemd logrotate', required=False, default=False, action='store_true') parser.add_argument('-nr', '--no-rotate', help='do not rotate logfiles (overrides logparse.conf)', required=False, default=False, action='store_true') parser.add_argument('-l', '--logs', help='services to analyse', required=False) # Set up logging logger = logging.getLogger(__name__) loghandler = logging.handlers.SysLogHandler(address = '/dev/log') loghandler.setFormatter(logging.Formatter(fmt='logparse.py[' + str(os.getpid()) + ']: %(message)s')) loghandler.setLevel(logging.WARNING) # don't spam syslog with debug messages if parser.parse_args().verbose: print("Verbose mode is on") logging.basicConfig(level=logging.DEBUG) logger.debug("Verbose mode turned on") else: logging.basicConfig(level=logging.INFO) logger.addHandler(loghandler) # Load config if parser.parse_args().config or config.prefs['verbose']: config.prefs = config.loadconf(parser.parse_args().config, parser) else: config.prefs = config.loadconf(argparser=parser) logger.debug("Finished loading config") # Time analysis global start start = datetime.now() logger.info("Beginning log analysis at {0} {1}".format(start.strftime(formatting.DATEFMT), start.strftime(formatting.TIMEFMT))) logger.debug("This is {0} version {1}, running on Python {2}".format(logparse.__name__, logparse.__version__, sys.version)) # for l in parser.parse_args().logs.split(' '): # eval(l) # sys.exit() # print(load_parsers.search()); # Write HTML document global output_html output_html = formatting.header(config.prefs['header']) output_html += sudo.parse_log() output_html += sshd.parse_log() output_html += cron.parse_log() output_html += httpd.parse_log() output_html += smbd.parse_log() output_html += postfix.parse_log() output_html += zfs.parse_log() output_html += temperature.parse_log() output_html += formatting.closetag('body') + formatting.closetag('html') if parser.parse_args().printout: print(output_html) if parser.parse_args().destination: logger.debug("Outputting to {0}".format(parser.parse_args().destination)) if not os.path.isfile(parser.parse_args().destination) and not parser.parse_args().overwrite: with open(parser.parse_args().destination, 'w') as f: f.write(output_html) logger.info("Written output to {}".format(parser.parse_args().destination)) else: logger.warning("Destination file already exists") if input("Would you like to overwrite {0}? (y/n) [n] ".format(parser.parse_args().destination)) == 'y': with open(parser.parse_args().destination, 'w') as f: f.write(output_html) logger.debug("Written output to {}".format(parser.parse_args().destination)) else: logger.warning("No output written") if parser.parse_args().to: mail.sendmail(mailbin=config.prefs['mail']['mailbin'], body=output_html, recipient=parser.parse_args().to, subject="logparse test") # Print end message finish = datetime.now() logger.info("Finished parsing logs at {0} {1} (total time: {2})".format(finish.strftime(formatting.DATEFMT), finish.strftime(formatting.TIMEFMT), finish - start)) return