Method shell_exec_monitor

owtf/shell/base.py:164–228

Monitor shell command execution :param command: Command to run :type command: `str` :param plugin_info: Plugin context info :type plugin_info: `dict` :return: Scrubbed output from the command :rtype: `str`

(self, session, command, plugin_info)

        return proc

    def shell_exec_monitor(self, session, command, plugin_info):
        """Monitor shell command execution

        :param command: Command to run
        :type command: `str`
        :param plugin_info: Plugin context info
        :type plugin_info: `dict`
        :return: Scrubbed output from the command
        :rtype: `str`
        """
        cmd_info = self.start_cmd(command, command)
        target, can_run = self.can_run_cmd(session=session, command=cmd_info)
        if not can_run:
            message = "The command was already run for target: {!s}".format(target)
            return message
        logging.info("")
        logging.info("Executing :\n\n%s\n\n", command)
        logging.info(
            "------> Execution Start Date/Time: %s",
            self.timer.get_start_date_time_as_str("Command"),
        )
        logging.info("")
        output = ""
        cancelled = False
        proc = None
        try:
            proc = self.create_subprocess(command)
            while True:
                line = proc.stdout.readline()
                if not line:
                    break
                logging.info(
                    line.decode("utf-8").strip()
                )  # Show progress on the screen too!
                output += line.decode(
                    "utf-8"
                )  # Save as much output as possible before a tool crashes! :)
        except KeyboardInterrupt:
            os.killpg(proc.pid, signal.SIGINT)
            out, err = proc.communicate()
            logging.warn(out.decode("utf-8"))
            output += out.decode("utf-8")
            try:
                os.killpg(
                    os.getpgid(proc.pid), signal.SIGTERM
                )  # Plugin KIA (Killed in Action)
            except OSError:
                pass  # Plugin RIP (Rested In Peace)
            cancelled = True
            output += user_abort("Command", output)  # Identify as Command Level abort
        finally:
            try:
                self.finish_cmd(
                    session=session,
                    cmd_info=cmd_info,
                    was_cancelled=cancelled,
                    plugin_info=plugin_info,
                )