1 files changed, 111 insertions, 0 deletions
diff --git a/scripts/health/collect.py b/scripts/health/collect.py
new file mode 100755
index 0000000..180b866
--- /dev/null
+++ b/scripts/health/collect.py
@@ -0,0 +1,111 @@
+#!/usr/bin/python3
+from __future__ import unicode_literals
+from builtins import str
+import os
+import pwd
+import hashlib
+import platform
+import crm_script
+
+import crmsh.log
+crmsh.log.setup_logging()
+from crmsh.report import utils
+
+data = crm_script.get_input()
+
+PACKAGES = ['booth', 'cluster-glue', 'corosync', 'crmsh', 'csync2', 'drbd',
+            'fence-agents', 'gfs2', 'gfs2-utils', 'ha-cluster-bootstrap',
+            'haproxy', 'hawk', 'libdlm', 'libqb', 'ocfs2', 'ocfs2-tools',
+            'pacemaker', 'pacemaker-mgmt', 'resource-agents', 'sbd']
+
+
+def rpm_info():
+    return crm_script.rpmcheck(PACKAGES)
+
+
+def logrotate_info():
+    return {}
+
+
+def get_user():
+    return pwd.getpwuid(os.getuid()).pw_name
+
+
+def sys_info():
+    sysname, nodename, release, version, machine = os.uname()
+    # The first three columns measure CPU and IO utilization of the
+    # last one, five, and 15 minute periods. The fourth column shows
+    # the number of currently running processes and the total number of
+    # processes. The last column displays the last process ID used.
+    system, node, release, version, machine, processor = platform.uname()
+    distname = utils.get_distro_info()
+    hostname = os.uname()[1]
+
+    uptime = open('/proc/uptime').read().split()
+    loadavg = open('/proc/loadavg').read().split()
+
+    return {'system': system,
+            'node': node,
+            'release': release,
+            'version': version,
+            'machine': machine,
+            'processor': processor,
+            'distname': distname,
+            'user': get_user(),
+            'hostname': hostname,
+            'uptime': uptime[0],
+            'idletime': uptime[1],
+            'loadavg': loadavg[2]  # 15 minute average
+            }
+
+
+def disk_info():
+    rc, out, err = crm_script.call(['df'], shell=False)
+    if rc == 0:
+        disk_use = []
+        for line in out.split('\n')[1:]:
+            line = line.strip()
+            if line:
+                data = line.split()
+                if len(data) >= 6:
+                    disk_use.append((data[5], data[4]))
+        return disk_use
+    return []
+
+
+# configurations out of sync
+
+FILES = [
+    '/etc/csync2/key_hagroup',
+    '/etc/csync2/csync2.cfg',
+    '/etc/corosync/corosync.conf',
+    '/etc/sysconfig/sbd',
+    '/etc/sysconfig/SuSEfirewall2',
+    '/etc/sysconfig/SuSEfirewall2.d/services/cluster'
+    ]
+
+
+def files_info():
+    ret = {}
+    for f in FILES:
+        if os.path.isfile(f):
+            try:
+                ret[f] = hashlib.sha1(open(f).read().encode('utf-8')).hexdigest()
+            except IOError as e:
+                ret[f] = "error: %s" % (e)
+        else:
+            ret[f] = ""
+    return ret
+
+
+try:
+    data = {
+        'rpm': rpm_info(),
+        'logrotate': logrotate_info(),
+        'system': sys_info(),
+        'disk': disk_info(),
+        'files': files_info()
+    }
+    crm_script.exit_ok(data)
+except Exception as e:
+    crm_script.exit_fail(str(e))