From a221e0db50642ec38ae1f54101e6740a134ed89d Mon Sep 17 00:00:00 2001
From: Francois Andrieu <darknao@fedoraproject.org>
Date: Jan 05 2021 22:34:01 +0000
Subject: logview: add gzip compression on logfiles


Signed-off-by: Francois Andrieu <darknao@fedoraproject.org>

---

diff --git a/callback_plugins/logdetail.py b/callback_plugins/logdetail.py
index c901475..d07c5b3 100644
--- a/callback_plugins/logdetail.py
+++ b/callback_plugins/logdetail.py
@@ -21,6 +21,7 @@ import os
 import time
 import json
 import pwd
+import gzip
 
 try:
     from ansible.utils.hashing import secure_hash
@@ -156,7 +157,7 @@ class LogMech(object):
             name = name.strip()
 
         sanitize_host = host.replace(' ', '_').replace('>', '-')
-        fd = open(self.logpath_play + '/' + sanitize_host + '.log', 'a')
+        fd = gzip.open(self.logpath_play + '/' + sanitize_host + '.log.gz', 'at')
         now = time.strftime(TIME_FORMAT, time.localtime())
         fd.write(MSG_FORMAT % dict(now=now, name=name, count=count, category=category, data=json.dumps(data)))
         fd.close()
diff --git a/scripts/logview b/scripts/logview
index 03ed34e..3b2c986 100755
--- a/scripts/logview
+++ b/scripts/logview
@@ -5,6 +5,7 @@ from optparse import OptionParser
 import os
 import glob
 from datetime import date, timedelta
+import gzip
 import dateutil.parser as dateparser
 
 logpath = '/var/log/ansible'
@@ -53,9 +54,16 @@ def parse_args(args):
 def search_logs(opts, logfiles):
     msg = ''
     for fn in sorted(logfiles):
-        hostname = os.path.basename(fn).replace('.log', '')
+        hostname = os.path.basename(fn).replace('.log', '').replace('.gz', '')
         timestamp = os.path.basename(os.path.dirname(fn))
-        for line in open(fn):
+        try:
+            with gzip.open(fn) as f:
+              f.read()
+            open_f = gzip.open(fn, "rt")
+        except:
+            open_f = open(fn)
+        
+        for line in open_f:
             things = line.split('\t')
             if len(things) < 5:
                 msg += "(logview error - unhandled line): %r\n" % line