xref: /OpenGrok/tools/src/main/python/opengrok_tools/utils/commandsequence.py (revision 77cacb4d7341bca0bf4ce67f0b324fd89257bbf1)

#
# CDDL HEADER START
#
# The contents of this file are subject to the terms of the
# Common Development and Distribution License (the "License").
# You may not use this file except in compliance with the License.
#
# See LICENSE.txt included in this distribution for the specific
# language governing permissions and limitations under the License.
#
# When distributing Covered Code, include this CDDL HEADER in each
# file and include the License file at LICENSE.txt.
# If applicable, add the following below this CDDL HEADER, with the
# fields enclosed by brackets "[]" replaced with your own identifying
# information: Portions Copyright [yyyy] [name of copyright owner]
#
# CDDL HEADER END
#

#
# Copyright (c) 2017, 2022, Oracle and/or its affiliates. All rights reserved.
#

import logging

from requests.exceptions import HTTPError

from .command import Command
from .utils import is_web_uri
from .exitvals import (
    CONTINUE_EXITVAL,
    SUCCESS_EXITVAL,
    FAILURE_EXITVAL
)
from .restful import call_rest_api
from .patterns import PROJECT_SUBST, COMMAND_PROPERTY, URL_SUBST
import re


class CommandConfigurationException(Exception):
    pass


def check_command_property(command):
    """
    Check if the 'commands' parameter of CommandSequenceBase() has the right structure
    w.r.t. individual commands.
    :param command: command element
    """
    if not isinstance(command, dict):
        raise CommandConfigurationException("command '{}' is not a dictionary".format(command))

    command_value = command.get(COMMAND_PROPERTY)
    if command_value is None:
        raise CommandConfigurationException("command dictionary has no '{}' key: {}".
                                            format(COMMAND_PROPERTY, command))

    if not isinstance(command_value, list):
        raise CommandConfigurationException("command value not a list: {}".
                                            format(command_value))


class CommandSequenceBase:
    """
    Wrap the run of a set of Command instances.

    This class intentionally does not contain any logging
    so that it can be passed through Pool.map().
    """

    def __init__(self, name, commands, loglevel=logging.INFO, cleanup=None,
                 driveon=False, url=None, env=None, http_headers=None,
                 api_timeout=None):
        self.name = name

        if commands is None:
            raise CommandConfigurationException("commands is None")
        if not isinstance(commands, list):
            raise CommandConfigurationException("commands is not a list")
        self.commands = commands
        for command in self.commands:
            check_command_property(command)

        self.failed = False
        self.retcodes = {}
        self.outputs = {}

        if cleanup and not isinstance(cleanup, list):
            raise CommandConfigurationException("cleanup is not a list of commands")
        self.cleanup = cleanup
        if self.cleanup:
            for command in self.cleanup:
                check_command_property(command)

        self.loglevel = loglevel
        self.driveon = driveon
        self.env = env
        self.http_headers = http_headers
        self.api_timeout = api_timeout

        self.url = url

    def __str__(self):
        return str(self.name)

    def get_cmd_output(self, cmd, indent=""):
        """
        :param cmd: command
        :param indent: prefix for each line
        :return: command output as string
        """

        str_out = ""
        for line in self.outputs.get(cmd, []):
            str_out += '{}{}'.format(indent, line)

        return str_out

    def fill(self, retcodes, outputs, failed):
        self.retcodes = retcodes
        self.outputs = outputs
        self.failed = failed


class CommandSequence(CommandSequenceBase):

    re_program = re.compile('ERROR[:]*\\s+')

    def __init__(self, base):
        super().__init__(base.name, base.commands, loglevel=base.loglevel,
                         cleanup=base.cleanup, driveon=base.driveon,
                         url=base.url, env=base.env,
                         http_headers=base.http_headers,
                         api_timeout=base.api_timeout)

        self.logger = logging.getLogger(__name__)
        self.logger.setLevel(base.loglevel)

    def run_command(self, cmd):
        """
        Execute a command and return its return code.
        """
        cmd.execute()
        self.retcodes[str(cmd)] = cmd.getretcode()
        self.outputs[str(cmd)] = cmd.getoutput()

        return cmd.getretcode()

    def run(self):
        """
        Run the sequence of commands and capture their output and return code.
        First command that returns code other than 0 terminates the sequence.
        If the command has return code 2, the sequence will be terminated
        however it will not be treated as error (unless the 'driveon' parameter
        is True).

        If a command contains PROJECT_SUBST pattern, it will be replaced
        by project name, otherwise project name will be appended to the
        argument list of the command.

        Any command entry that is a URI, will be used to submit RESTful API
        request.
        """

        for command in self.commands:
            cmd_value = command.get(COMMAND_PROPERTY)[0]
            if cmd_value.startswith(URL_SUBST) or is_web_uri(cmd_value):
                try:
                    call_rest_api(command, {PROJECT_SUBST: self.name,
                                            URL_SUBST: self.url},
                                  self.http_headers, self.api_timeout)
                except HTTPError as e:
                    self.logger.error("RESTful command {} failed: {}".
                                      format(command, e))
                    self.failed = True
                    self.retcodes[str(command)] = FAILURE_EXITVAL

                    break
            else:
                command_args = command.get(COMMAND_PROPERTY)
                command = Command(command_args,
                                  env_vars=command.get("env"),
                                  logger=self.logger,
                                  resource_limits=command.get("limits"),
                                  args_subst={PROJECT_SUBST: self.name,
                                              URL_SUBST: self.url},
                                  args_append=[self.name], excl_subst=True)
                retcode = self.run_command(command)

                # If a command exits with non-zero return code,
                # terminate the sequence of commands.
                if retcode != SUCCESS_EXITVAL:
                    if retcode == CONTINUE_EXITVAL:
                        if not self.driveon:
                            self.logger.debug("command '{}' for project {} "
                                              "requested break".
                                              format(command, self.name))
                            self.run_cleanup()
                        else:
                            self.logger.debug("command '{}' for project {} "
                                              "requested break however "
                                              "the 'driveon' option is set "
                                              "so driving on.".
                                              format(command, self.name))
                            continue
                    else:
                        self.logger.error("command '{}' for project {} failed "
                                          "with code {}, breaking".
                                          format(command, self.name, retcode))
                        self.failed = True
                        self.run_cleanup()

                    break

    def run_cleanup(self):
        """
        Call cleanup sequence in case the command sequence failed
        or termination was requested.
        """
        if self.cleanup is None:
            return

        for cleanup_cmd in self.cleanup:
            arg0 = cleanup_cmd.get(COMMAND_PROPERTY)[0]
            if arg0.startswith(URL_SUBST) or is_web_uri(arg0):
                try:
                    call_rest_api(cleanup_cmd, {PROJECT_SUBST: self.name,
                                                URL_SUBST: self.url},
                                  self.http_headers, self.api_timeout)
                except HTTPError as e:
                    self.logger.error("RESTful command {} failed: {}".
                                      format(cleanup_cmd, e))
            else:
                command_args = cleanup_cmd.get(COMMAND_PROPERTY)
                self.logger.debug("Running cleanup command '{}'".
                                  format(command_args))
                cmd = Command(command_args,
                              logger=self.logger,
                              args_subst={PROJECT_SUBST: self.name,
                                          URL_SUBST: self.url},
                              args_append=[self.name], excl_subst=True)
                cmd.execute()
                if cmd.getretcode() != SUCCESS_EXITVAL:
                    self.logger.error("cleanup command '{}' failed with "
                                      "code {}".
                                      format(cmd.cmd, cmd.getretcode()))
                    self.logger.info('output: {}'.format(cmd.getoutputstr()))

    def print_outputs(self, logger, loglevel=logging.INFO, lines=False):
        """
        Print command outputs.
        """

        logger.debug("Output for project '{}':".format(self.name))
        for cmd in self.outputs.keys():
            if self.outputs[cmd] and len(self.outputs[cmd]) > 0:
                if lines:
                    logger.log(loglevel, "Output from '{}':".format(cmd))
                    logger.log(loglevel, '{}'.format(self.get_cmd_output(cmd)))
                else:
                    logger.log(loglevel, "'{}': {}".
                               format(cmd, self.outputs[cmd]))

    def check(self, ignore_errors):
        """
        Check the output of the commands and perform logging.

        Return SUCCESS_EXITVAL on success, 1 if error was detected.
        """

        ret = SUCCESS_EXITVAL
        self.print_outputs(self.logger, loglevel=logging.DEBUG)

        if ignore_errors and self.name in ignore_errors:
            self.logger.debug("errors of project '{}' ignored".
                              format(self.name))
            return

        self.logger.debug("retcodes = {}".format(self.retcodes))
        if any(rv != SUCCESS_EXITVAL and rv != CONTINUE_EXITVAL
               for rv in self.retcodes.values()):
            ret = 1
            self.logger.error("processing of project '{}' failed".
                              format(self))
            indent = "  "
            self.logger.error("{}failed commands:".format(indent))
            failed_cmds = {k: v for k, v in
                           self.retcodes.items() if v != SUCCESS_EXITVAL}
            indent = "    "
            for cmd in failed_cmds.keys():
                self.logger.error("{}'{}': {}".
                                  format(indent, cmd, failed_cmds[cmd]))
                out = self.get_cmd_output(cmd,
                                          indent=indent + "  ")
                if out:
                    self.logger.error(out)
            self.logger.error("")

        errored_cmds = {k: v for k, v in self.outputs.items()
                        if self.re_program.match(str(v))}
        if len(errored_cmds) > 0:
            ret = 1
            self.logger.error("Command output in project '{}'"
                              " contains errors:".format(self.name))
            indent = "  "
            for cmd in errored_cmds.keys():
                self.logger.error("{}{}".format(indent, cmd))
                out = self.get_cmd_output(cmd,
                                          indent=indent + "  ")
                if out:
                    self.logger.error(out)
                self.logger.error("")

        return ret