Gecko [ goons4good.org ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2022-10-11 05:09
__init__.py	73 B	-rw-r--r--	2022-05-16 09:16
api.py	2.32 KB	-rw-r--r--	2022-05-16 09:16
batch.py	12 KB	-rw-r--r--	2022-05-16 09:16
call.py	1.67 KB	-rw-r--r--	2022-05-16 09:16
caller.py	11.48 KB	-rw-r--r--	2022-05-16 09:16
cp.py	9.37 KB	-rw-r--r--	2022-05-16 09:16
daemons.py	21.05 KB	-rw-r--r--	2022-05-16 09:16
key.py	487 B	-rw-r--r--	2022-05-16 09:16
run.py	1.95 KB	-rw-r--r--	2022-05-16 09:16
salt.py	17.08 KB	-rw-r--r--	2022-05-16 09:16
spm.py	803 B	-rw-r--r--	2022-05-16 09:16
ssh.py	583 B	-rw-r--r--	2022-05-16 09:16

Rename

"""
    salt.cli.api
    ~~~~~~~~~~~~~

Salt's api cli parser.

"""

import logging

import salt.client.netapi
import salt.utils.files
import salt.utils.parsers as parsers
from salt.utils.verify import check_user, verify_log, verify_log_files

log = logging.getLogger(__name__)

class SaltAPI(parsers.SaltAPIParser):
    """
    The cli parser object used to fire up the salt api system.
    """

def prepare(self):
        """
        Run the preparation sequence required to start a salt-api daemon.

If sub-classed, don't **ever** forget to run:

super(YourSubClass, self).prepare()
        """
        super().prepare()

try:
            if self.config["verify_env"]:
                logfile = self.options.api_logfile
                if logfile is not None:
                    # Logfile is not using Syslog, verify
                    with salt.utils.files.set_umask(0o027):
                        verify_log_files([logfile], self.config["user"])
        except OSError as err:
            log.exception("Failed to prepare salt environment")
            self.shutdown(err.errno)

self.setup_logfile_logger()
        verify_log(self.config)
        log.info("Setting up the Salt API")
        self.api = salt.client.netapi.NetapiClient(self.config)
        self.daemonize_if_required()
        self.set_pidfile()

def start(self):
        """
        Start the actual master.

If sub-classed, don't **ever** forget to run:

super(YourSubClass, self).start()

NOTE: Run any required code before calling `super()`.
        """
        super().start()
        if check_user(self.config["user"]):
            log.info("The salt-api is starting up")
            self.api.run()

def shutdown(self, exitcode=0, exitmsg=None):
        """
        If sub-classed, run any shutdown operations on this method.
        """
        log.info("The salt-api is shutting down..")
        msg = "The salt-api is shutdown. "
        if exitmsg is not None:
            exitmsg = msg + exitmsg
        else:
            exitmsg = msg.strip()
        super().shutdown(exitcode, exitmsg)

def _handle_signals(self, signum, sigframe):
        # escalate signal to the process manager processes
        self.api.process_manager._handle_signals(signum, sigframe)
        super()._handle_signals(signum, sigframe)