"""Module provides CruxConfig object to manage API configuration settings."""

import os
import platform
import re
from typing import Dict, MutableMapping, Optional, Text, Union  # noqa: F401

import requests
from requests.packages.urllib3.util.retry import (  # Dynamic load pylint: disable=import-error
    Retry,
)

from crux.__version__ import __version__
from crux._utils import create_logger, get_session, str_to_bool

log = create_logger(__name__)


class CruxConfig(object):
    """
    Crux Configuration Class.
    """

    def __init__(  # pylint: disable=too-many-branches
        self,
        api_key=None,  # type: Optional[str]
        api_host=None,  # type: str
        api_prefix=None,  # type: str
        proxies=None,  # type: Optional[MutableMapping[Text, Text]]
        user_agent=None,  # type: str
        only_use_crux_domains=None,  # type: bool
        session=None,  # type: requests.Session
        api_prefix_v2=None,  # type: str
    ):
        # type: (...) -> None
        """
        Args:
            api_key (str): API Key. Defaults to None.
            api_host (str): API URL. Defaults to None.
            api_prefix (str): API prefix to be used. Defaults to None.
            proxies (dict): Proxies to be used. Defaults to None.
            user_agent (str): User agent to be used. Defaults to None.
            only_use_crux_domains (bool): True if Crux domain should be
                use for upload and download, False otherwise.
                Defaults to False.
            session(requests.Session): Session to be used with connection.

        Raises:
            ValueError: If CRUX_API_KEY is not set.
        """
        if api_key is None:
            if "CRUX_API_KEY" in os.environ:
                log.debug("Fetching API KEY from OS Environment Variable")
                self.api_key = os.environ.get("CRUX_API_KEY")  # type: Optional[str]
                log.trace("API KEY: %s", self.api_key)
            else:
                raise ValueError("API KEY is required")
        else:
            self.api_key = api_key
            log.trace("API KEY: %s", self.api_key)

        if api_host is None:
            self.api_host = os.environ.get(
                "CRUX_API_HOST", "https://api.cruxinformatics.com"
            )
            log.debug("Setting API host to %s", self.api_host)
        else:
            self.api_host = api_host
            log.debug("Setting API host to %s", self.api_host)

        if api_prefix is None:
            self.api_prefix = os.environ.get("CRUX_API_PREFIX", "plat-api")
        else:
            self.api_prefix = api_prefix
        log.trace("Setting API prefix to %s", self.api_prefix)

        if api_prefix_v2 is None:
            self.api_prefix_v2 = os.environ.get("CRUX_API_PREFIX_V2", "v2")
        else:
            self.api_prefix_v2 = api_prefix_v2
        log.trace("Setting API prefix-v2 to %s", self.api_prefix_v2)

        if user_agent is None:
            self.user_agent = self._default_user_agent()
            log.debug("Setting User Agent to %s", self.user_agent)
        else:
            self.user_agent = user_agent
            log.debug("Setting User Agent to %s", self.user_agent)

        self.proxies = (
            proxies if proxies else {}
        )  # type: Optional[MutableMapping[Text, Text]]

        if only_use_crux_domains is None:
            self.only_use_crux_domains = str_to_bool(
                os.environ.get("CRUX_ONLY_USE_CRUX_DOMAINS", "false")
            )
            log.debug("Setting only_use_crux_domain to %s", self.only_use_crux_domains)
        else:
            self.only_use_crux_domains = only_use_crux_domains
            log.debug("Setting only_use_crux_domain to %s", self.only_use_crux_domains)

        if session is None:
            retries = Retry(
                total=20,
                backoff_factor=0.3,
                status_forcelist=(
                    500,
                    502,
                    503,
                    504,
                    520,
                    521,
                    522,
                    523,
                    524,
                    525,
                    527,
                    530,
                ),
                method_whitelist=("GET", "PUT", "DELETE", "POST"),
                redirect=10,
                connect=10,
                read=10,
            )
            self.session = get_session(retries=retries, proxies=self.proxies)
        else:
            self.session = session

    def _default_user_agent(self):
        # type: () -> str
        user_agent = (
            "crux-python/{ver}"
            " requests/{req_ver} {py_impl}/{py_ver} "
            "{os}/{os_ver} {cpu}/{machine}"
        ).format(
            ver=__version__,
            req_ver=self._sanitize_user_agent_part(requests.__version__),
            py_impl=self._sanitize_user_agent_part(platform.python_implementation()),
            py_ver=self._sanitize_user_agent_part(platform.python_version()),
            os=self._sanitize_user_agent_part(platform.system()),
            os_ver=self._sanitize_user_agent_part(platform.release()),
            cpu=self._sanitize_user_agent_part(platform.processor()),
            machine=self._sanitize_user_agent_part(platform.machine()),
        )

        return user_agent

    def _sanitize_user_agent_part(self, part):  # pylint: disable=no-self-use
        # type: (str) -> str
        if part:
            no_space_part = re.sub(r"\s+", "_", part)
            sanitized_part = re.sub(r"[^a-zA-Z0-9._+~-]", "", no_space_part)
            if sanitized_part:
                return sanitized_part
        return "unknown"

"""Module provides CruxConfig object to manage API configuration settings."""

import os
import platform
import re
from typing import Dict, MutableMapping, Optional, Text, Union  # noqa: F401

import requests
from requests.packages.urllib3.util.retry import (  # Dynamic load pylint: disable=import-error
    Retry,
)

from crux.__version__ import __version__
from crux._utils import create_logger, get_session, str_to_bool

log = create_logger(__name__)


class CruxConfig(object):
    """
    Crux Configuration Class.
    """

    def __init__(  # pylint: disable=too-many-branches
        self,
        api_key=None,  # type: Optional[str]
        api_host=None,  # type: str
        api_prefix=None,  # type: str
        proxies=None,  # type: Optional[MutableMapping[Text, Text]]
        user_agent=None,  # type: str
        only_use_crux_domains=None,  # type: bool
        session=None,  # type: requests.Session
        api_prefix_v2=None,  # type: str
    ):
        # type: (...) -> None
        """
        Args:
            api_key (str): API Key. Defaults to None.
            api_host (str): API URL. Defaults to None.
            api_prefix (str): API prefix to be used. Defaults to None.
            proxies (dict): Proxies to be used. Defaults to None.
            user_agent (str): User agent to be used. Defaults to None.
            only_use_crux_domains (bool): True if Crux domain should be
                use for upload and download, False otherwise.
                Defaults to False.
            session(requests.Session): Session to be used with connection.

        Raises:
            ValueError: If CRUX_API_KEY is not set.
        """
        if api_key is None:
            if "CRUX_API_KEY" in os.environ:
                log.debug("Fetching API KEY from OS Environment Variable")
                self.api_key = os.environ.get("CRUX_API_KEY")  # type: Optional[str]
                log.trace("API KEY: %s", self.api_key)
            else:
                raise ValueError("API KEY is required")
        else:
            self.api_key = api_key
            log.trace("API KEY: %s", self.api_key)

        if api_host is None:
            self.api_host = os.environ.get(
                "CRUX_API_HOST", "https://api.cruxinformatics.com"
            )
            log.debug("Setting API host to %s", self.api_host)
        else:
            self.api_host = api_host
            log.debug("Setting API host to %s", self.api_host)

        if api_prefix is None:
            self.api_prefix = os.environ.get("CRUX_API_PREFIX", "plat-api")
        else:
            self.api_prefix = api_prefix
        log.trace("Setting API prefix to %s", self.api_prefix)

        if api_prefix_v2 is None:
            self.api_prefix_v2 = os.environ.get("CRUX_API_PREFIX_V2", "v2")
        else:
            self.api_prefix_v2 = api_prefix_v2
        log.trace("Setting API prefix-v2 to %s", self.api_prefix_v2)

        if user_agent is None:
            self.user_agent = self._default_user_agent()
            log.debug("Setting User Agent to %s", self.user_agent)
        else:
            self.user_agent = user_agent
            log.debug("Setting User Agent to %s", self.user_agent)

        self.proxies = (
            proxies if proxies else {}
        )  # type: Optional[MutableMapping[Text, Text]]

        if only_use_crux_domains is None:
            self.only_use_crux_domains = str_to_bool(
                os.environ.get("CRUX_ONLY_USE_CRUX_DOMAINS", "false")
            )
            log.debug("Setting only_use_crux_domain to %s", self.only_use_crux_domains)
        else:
            self.only_use_crux_domains = only_use_crux_domains
            log.debug("Setting only_use_crux_domain to %s", self.only_use_crux_domains)

        if session is None:
            retries = Retry(
                total=20,
                backoff_factor=0.3,
                status_forcelist=(
                    500,
                    502,
                    503,
                    504,
                    520,
                    521,
                    522,
                    523,
                    524,
                    525,
                    527,
                    530,
                ),
                method_whitelist=("GET", "PUT", "DELETE", "POST"),
                redirect=10,
                connect=10,
                read=10,
            )
            self.session = get_session(retries=retries, proxies=self.proxies)
        else:
            self.session = session

    def _default_user_agent(self):
        # type: () -> str
        user_agent = (
            "crux-python/{ver}"
            " requests/{req_ver} {py_impl}/{py_ver} "
            "{os}/{os_ver} {cpu}/{machine}"
        ).format(
            ver=__version__,
            req_ver=self._sanitize_user_agent_part(requests.__version__),
            py_impl=self._sanitize_user_agent_part(platform.python_implementation()),
            py_ver=self._sanitize_user_agent_part(platform.python_version()),
            os=self._sanitize_user_agent_part(platform.system()),
            os_ver=self._sanitize_user_agent_part(platform.release()),
            cpu=self._sanitize_user_agent_part(platform.processor()),
            machine=self._sanitize_user_agent_part(platform.machine()),
        )

        return user_agent

    def _sanitize_user_agent_part(self, part):  # pylint: disable=no-self-use
        # type: (str) -> str
        if part:
            no_space_part = re.sub(r"\s+", "_", part)
            sanitized_part = re.sub(r"[^a-zA-Z0-9._+~-]", "", no_space_part)
            if sanitized_part:
                return sanitized_part
        return "unknown"

Module provides CruxConfig object to manage API configuration settings. # noqa: F401 # Dynamic load pylint: disable=import-error Crux Configuration Class. # pylint: disable=too-many-branches # type: Optional[str] # type: str # type: str # type: Optional[MutableMapping[Text, Text]] # type: str # type: bool # type: requests.Session # type: str # type: (...) -> None Args:             api_key (str): API Key. Defaults to None.             api_host (str): API URL. Defaults to None.             api_prefix (str): API prefix to be used. Defaults to None.             proxies (dict): Proxies to be used. Defaults to None.             user_agent (str): User agent to be used. Defaults to None.             only_use_crux_domains (bool): True if Crux domain should be                 use for upload and download, False otherwise.                 Defaults to False.             session(requests.Session): Session to be used with connection.          Raises:             ValueError: If CRUX_API_KEY is not set. # type: Optional[str] # type: Optional[MutableMapping[Text, Text]] # type: () -> str # pylint: disable=no-self-use # type: (str) -> str