# Copyright (C) 2014 Red Hat, Inc. Neependra Khare <nkhare@redhat.com>
# Copyright (C) 2014 Red Hat, Inc. Bryn M. Reeves <bmr@redhat.com>

# This file is part of the sos project: https://github.com/sosreport/sos
#
# This copyrighted material is made available to anyone wishing to use,
# modify, copy, or redistribute it subject to the terms and conditions of
# version 2 of the GNU General Public License.
#
# See the LICENSE file in the source distribution for further information.

from sos.plugins import Plugin, RedHatPlugin
from os import path


class kubernetes(Plugin, RedHatPlugin):

    """Kubernetes plugin
    """

    # OpenShift Container Platform uses the atomic-openshift-master package
    # to provide kubernetes
    packages = ('kubernetes', 'kubernetes-master', 'atomic-openshift-master')
    profiles = ('container',)
    # use files only for masters, rely on package list for nodes
    files = (
        "/var/run/kubernetes/apiserver.key",
        "/etc/origin/master/",
        "/etc/origin/node/pods/master-config.yaml"
    )

    option_list = [
        ("all", "also collect all namespaces output separately",
            'slow', False),
        ("describe", "capture descriptions of all kube resources",
            'fast', False),
        ("podlogs", "capture logs for pods", 'slow', False),
    ]

    def check_is_master(self):
        return any([path.exists(f) for f in self.files])

    def setup(self):
        self.add_copy_spec("/etc/kubernetes")
        self.add_copy_spec("/var/run/flannel")

        svcs = [
            'kubelet',
            'kube-apiserver',
            'kube-proxy',
            'kube-scheduler',
            'kube-controller-manager'
        ]

        for svc in svcs:
            self.add_journal(units=svc)

        # We can only grab kubectl output from the master
        if not self.check_is_master():
            return

        kube_cmd = "kubectl "
        if path.exists('/etc/origin/master/admin.kubeconfig'):
            kube_cmd += "--kubeconfig=/etc/origin/master/admin.kubeconfig"

        kube_get_cmd = "get -o json "
        for subcmd in ['version', 'config view']:
            self.add_cmd_output('%s %s' % (kube_cmd, subcmd))

        # get all namespaces in use
        kn = self.get_command_output('%s get namespaces' % kube_cmd)
        knsps = [n.split()[0] for n in kn['output'].splitlines()[1:] if n]

        resources = [
            'limitrange',
            'pods',
            'pvc',
            'rc',
            'resourcequota',
            'services'
        ]

        # nodes and pvs are not namespaced, must pull separately.
        # Also collect master metrics
        self.add_cmd_output([
            "{} get -o json nodes".format(kube_cmd),
            "{} get -o json pv".format(kube_cmd),
            "{} get --raw /metrics".format(kube_cmd)
        ])

        for n in knsps:
            knsp = '--namespace=%s' % n
            if self.get_option('all'):
                k_cmd = '%s %s %s' % (kube_cmd, kube_get_cmd, knsp)

                self.add_cmd_output('%s events' % k_cmd)

                for res in resources:
                    self.add_cmd_output('%s %s' % (k_cmd, res))

                if self.get_option('describe'):
                    # need to drop json formatting for this
                    k_cmd = '%s get %s' % (kube_cmd, knsp)
                    for res in resources:
                        r = self.get_command_output(
                            '%s %s' % (k_cmd, res))
                        if r['status'] == 0:
                            k_list = [k.split()[0] for k in
                                      r['output'].splitlines()[1:]]
                            for k in k_list:
                                k_cmd = '%s %s' % (kube_cmd, knsp)
                                self.add_cmd_output(
                                    '%s describe %s %s' % (k_cmd, res, k))

            if self.get_option('podlogs'):
                k_cmd = '%s %s' % (kube_cmd, knsp)
                r = self.get_command_output('%s get pods' % k_cmd)
                if r['status'] == 0:
                    pods = [p.split()[0] for p in
                            r['output'].splitlines()[1:]]
                    for pod in pods:
                        self.add_cmd_output('%s logs %s' % (k_cmd, pod))

        if not self.get_option('all'):
            k_cmd = '%s get --all-namespaces=true' % kube_cmd
            for res in resources:
                self.add_cmd_output('%s %s' % (k_cmd, res))

    def postproc(self):
        # First, clear sensitive data from the json output collected.
        # This will mask values when the "name" looks susceptible of
        # values worth obfuscating, i.e. if the name contains strings
        # like "pass", "pwd", "key" or "token"
        env_regexp = r'(?P<var>{\s*"name":\s*[^,]*' \
            r'(pass|pwd|key|token|cred|PASS|PWD|KEY)[^,]*,\s*"value":)[^}]*'
        self.do_cmd_output_sub('kubectl', env_regexp,
                               r'\g<var> "********"')

        # Next, we need to handle the private keys and certs in some
        # output that is not hit by the previous iteration.
        self.do_cmd_private_sub('kubectl')

# vim: et ts=5 sw=4
