hvddZddlmZddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddl Z dd lmZdd lmZe rdd lmZdd lmZdd lmZe j.j0j3d*dZGddZGddZGddZ d+ d,dZ d- d.dZ d/ d0dZ d1 d2dZ! d1 d3dZ"Gdde#Z$Gdde$Z%Gdde$Z&Gd d!e$Z'Gd"d#e$Z(Gd$d%e$Z)Gd&d'e$Z*Gd(d)e$Z+y)4aKThis module provides the main client and helper classes for interacting with the Mailjet API. The `mailjet_rest.client` module includes the core `Client` class for managing API requests, configuration, and error handling, as well as utility functions and classes for building request headers, URLs, and parsing responses. Classes: - Config: Manages configuration settings for the Mailjet API. - Endpoint: Represents specific API endpoints and provides methods for common HTTP operations like GET, POST, PUT, and DELETE. - Client: The main API client for authenticating and making requests. - ApiError: Base class for handling API-specific errors, with subclasses for more specific error types (e.g., `AuthorizationError`, `TimeoutError`). Functions: - prepare_url: Prepares URLs for API requests. - api_call: A helper function that sends HTTP requests to the API and handles responses. - build_headers: Builds HTTP headers for the requests. - build_url: Constructs the full API URL based on endpoint and parameters. - parse_response: Parses API responses and handles error conditions. Exceptions: - ApiError: Base exception for API errors, with subclasses to represent specific error types, such as `AuthorizationError`, `TimeoutError`, `ActionDeniedError`, and `ValidationError`. ) annotationsN)datetime)timezone)Match) TYPE_CHECKING)Any)urljoin) get_version)Callable)Mapping)Responsecl|jd}|jrd|jzSy)apReplace capital letters in the input string with a dash prefix and converts them to lowercase. Parameters: key (Match[str]): A match object representing a substring from the input string. The substring should contain a single capital letter. Returns: str: A string containing a dash followed by the lowercase version of the input capital letter. r-)groupisupperlower)key char_elems d/home/www/lekema-backend.kofcorporation.com/venv/lib/python3.12/site-packages/mailjet_rest/client.py prepare_urlr9s2 ! IY__&&& cleZdZUdZdZded<dZded<dZded<d ezZ ded <ddd Z dd Z y )ConfigaConfiguration settings for interacting with the Mailjet API. This class stores and manages API configuration details, including the API URL, version, and user agent string. It provides methods for initializing these settings and generating endpoint-specific URLs and headers as required for API interactions. Attributes: DEFAULT_API_URL (str): The default base URL for Mailjet API requests. API_REF (str): Reference URL for Mailjet's API documentation. version (str): API version to use, defaulting to 'v3'. user_agent (str): User agent string including the package version for tracking. zhttps://api.mailjet.com/strDEFAULT_API_URLz%https://dev.mailjet.com/email-api/v3/API_REFv3versionzmailjet-apiv3-python/v user_agentNc@|||_|xs |j|_y)aInitialize a new Config instance with specified or default API settings. This initializer sets the API version and base URL. If no version or URL is provided, it defaults to the predefined class values. Parameters: - version (str | None): The API version to use. If None, the default version ('v3') is used. - api_url (str | None): The base URL for API requests. If None, the default URL (DEFAULT_API_URL) is used. N)rrapi_url)selfrr"s r__init__zConfig.__init__[s#  "DL6$"6"6 rct|j|jdz}d|jd}|j dk(rt|d}d|d<nS|j dk(rt|d}d |d<n.|j d k7r|jd k7r t|d }||j d dj z }||fS)aRetrieve the API endpoint URL and headers for a given key. This method builds the URL and headers required for specific API interactions. The URL is adjusted based on the API version, and additional headers are appended depending on the endpoint type. Specific keys modify content-type for endpoints expecting CSV or plain text. Parameters: - key (str): The name of the API endpoint, which influences URL structure and header configuration. Returns: - tuple[str, dict[str, str]]: A tuple containing the constructed URL and headers required for the specified endpoint. Examples: For the "contactslist_csvdata" key, a URL pointing to 'DATA/' and a 'Content-type' of 'text/plain' is returned. For the "batchjob_csverror" key, a URL with 'DATA/' and a 'Content-type' of 'text/csv' is returned. /application/json) Content-typez User-agentcontactslist_csvdatazDATA/ text/plainr(batchjob_csverrortext/csvsendv4zREST/_r)r r"rr rsplit)r#rurlheaderss r __getitem__zConfig.__getitem__is,dllDLL3$67.//#  99;0 0#w'C&2GN # YY[/ /#w'C&0GN # YY[F "t||t';#w'C syy~a &&((G|rNN)r str | Noner"r5returnNone)rrr6ztuple[str, dict[str, str]]) __name__ __module__ __qualname____doc__r__annotations__rrr r r$r3rrrrHsB 6OS5:GS:GS.>J> 7$rrceZdZdZ d d dZ d d dZ d ddZ d ddZ d ddZ d ddZ dd Z y)EndpointaA class representing a specific Mailjet API endpoint. This class provides methods to perform HTTP requests to a given API endpoint, including GET, POST, PUT, and DELETE requests. It manages URL construction, headers, and authentication for interacting with the endpoint. Attributes: - _url (str): The base URL of the endpoint. - headers (dict[str, str]): The headers to be included in API requests. - _auth (tuple[str, str] | None): The authentication credentials. - action (str | None): The specific action to be performed on the endpoint. Methods: - _get: Internal method to perform a GET request. - get_many: Performs a GET request to retrieve multiple resources. - get: Performs a GET request to retrieve a specific resource. - create: Performs a POST request to create a new resource. - update: Performs a PUT request to update an existing resource. - delete: Performs a DELETE request to delete a resource. NcB||||f\|_|_|_|_y)aDInitialize a new Endpoint instance. Args: url (str): The base URL for the endpoint. headers (dict[str, str]): Headers for API requests. auth (tuple[str, str] | None): Authentication credentials. action (str | None): Action to perform on the endpoint, if any. N)_urlr2_authaction)r#r1r2authrCs rr$zEndpoint.__init__s# rctjdt|}|jd}|d}d}t |dkDr|d}|dk(rd}|dk(rd }|j |\}}t |tfi||||j S) aSDynamically access API endpoints as attributes. This method allows for flexible, attribute-style access to API endpoints. It constructs the appropriate endpoint URL and headers based on the attribute name, which it parses to identify the resource and optional sub-resources. Parameters: - name (str): The name of the attribute being accessed, corresponding to the Mailjet API endpoint. Returns: - Endpoint: An instance of the `Endpoint` class, initialized with the constructed URL, headers, action, and authentication details. z[A-Z]r/rNcsvdatazcsvdata/text:plaincsverrorzcsverror/text:csv)r1r2rCrD) resubrr0lenrmtyper?rD)r#name name_regexr0fnamerCr1r2s r __getattr__zClient.__getattr__s&&;= %++C01X! u:>1XF"-#,{{4( W+tEH;+   rrc)rDrerLrr6r7)rvrr6r)r8r9r:r;r$ryr=rrrkrkis ?&  rrkc ^t||| || }tt|} d} |r&djd|j D} | ||| |||dd}|S#tj j $rttj$r}t|d}~wt$rwxYw)aMake an API call to a specified URL using the provided method, headers, and other parameters. Parameters: - auth (tuple[str, str] | None): A tuple containing the API key and secret for authentication. - method (str): The HTTP method to be used for the API call (e.g., 'get', 'post', 'put', 'delete'). - url (str): The URL to which the API call will be made. - headers (dict[str, str]): A dictionary containing the headers to be included in the API call. - data (str | bytes | None): The data to be sent in the request body. - filters (Mapping[str, str | Any] | None): A dictionary containing filters to be applied in the request. - resource_id (str | None): The ID of the specific resource to be accessed. - timeout (int): The timeout for the API call in seconds. - debug (bool): A flag indicating whether debug mode is enabled. - action (str | None): The specific action to be performed on the resource. - action_id (str | None): The ID of the specific action to be performed. - **kwargs (Any): Additional keyword arguments to be passed to the API call. Returns: - Response | Any: The response object from the API call if the request is successful, or an exception if an error occurs. )methodrCrIrGN&c30K|]\}}|d|yw)=Nr=).0kvs r zapi_call..s"J$!QaS!:"JsTF)rVparamsr2rDtimeoutverifystream) build_urlgetattrrequestsjoinitems exceptionsTimeout TimeoutErrorRequestExceptionApiError Exception)rDr{r1r2rVrHrIrdebugrCrGrL req_method filters_strresponsees rrJrJsB    C6*J"& (("J'--/"JJK   $    & &  $ $qk  s:A5B, BB,cddi}|jdk(r|jdk(rddi}n*|jdk(r|jdk(rddi}|r|j||S) aBuild headers based on resource and action. Parameters: - resource (str): The name of the resource for which headers are being built. - action (str): The specific action being performed on the resource. - extra_headers (dict[str, str] | None): Additional headers to be included in the request. Defaults to None. Returns: - dict[str, str]: A dictionary containing the headers to be included in the API request. r(r' contactslistrpr*batchjobrqr,)rr`)resourcerC extra_headersr2s r build_headersrso ./ABG~~>)flln .I!<0  Z 'FLLNj,H!:.}% NrcB|r|d|z }|r|d|z }|r|d|z }|S)aConstruct a URL for making an API request. This function takes the base URL, method, action, resource ID, and action ID as parameters and constructs a URL by appending the resource ID, action, and action ID to the base URL. Parameters: url (str): The base URL for the API request. method (str | None): The HTTP method for the API request (e.g., 'get', 'post', 'put', 'delete'). action (str | None): The specific action to be performed on the resource. Defaults to None. resource_id (str | None): The ID of the specific resource to be accessed. Defaults to None. action_id (str | None): The ID of the specific action to be performed. Defaults to None. Returns: str: The constructed URL for the API request. r&r=)r1r{rCrIrGs rrrsC, ;-    6(|  Qyk? "C Jrctj}|jtjtjd}|rqt j tj}|jd}|d}tj|}|j||j|tjtj}|j||j||S)aJCreate and configure a logger for logging API requests. This function creates a logger object and configures it to handle both standard output (stdout) and a file if the `to_file` parameter is set to True. The logger is set to log at the DEBUG level and uses a custom formatter to include the log level and message. Parameters: to_file (bool): A flag indicating whether to log to a file. If True, logs will be written to a file. Defaults to False. Returns: logging.Logger: A configured logger object for logging API requests. z%(levelname)s | %(message)s)tzz %Y%m%d_%H%M%Sz.log)logging getLoggersetLevelDEBUG Formatterrnowrutcstrftime FileHandler setFormatter addHandler StreamHandlersysstdout)to_filelogger formatterr date_timelog_file file_handlerstdout_handlers rlogging_handlerr-s"   F OOGMM"!!"?@Illhll+LL1 [%**84 !!),,'**3::6N * n% Mrc|j}|r|}|jd|jj|jd|jj|jd|jj |jd|j |jd|j|jd|jtjjj|S)aqParse the response from an API request and return the JSON data. Parameters: response (Response): The response object from the API request. log (Callable): A function or method that logs debug information. debug (bool): A flag indicating whether debug mode is enabled. Defaults to False. Returns: Any: The JSON data from the API response. z REQUEST: %szREQUEST_HEADERS: %szREQUEST_CONTENT: %sz RESPONSE: %szRESP_HEADERS: %sz RESP_CODE: %s) rXrrequestr1r2bodycontent status_coderrhandlersclear)rlogrrVlgrs rparse_responserRs ==?D e -!1!1!5!56 ')9)9)A)AB ')9)9)>)>? .("2"23 $h&6&67 /8#7#78$$**, KrceZdZdZy)rzBase class for all API-related errors. This exception serves as the root for all custom API error types, allowing for more specific error handling based on the type of API failure encountered. Nr8r9r:r;r=rrrrrrrceZdZdZy)AuthorizationErrorzError raised for authorization failures. This error is raised when the API request fails due to invalid or missing authentication credentials. Nrr=rrrr{rrceZdZdZy)ActionDeniedErrorzError raised when an action is denied by the API. This exception is triggered when an action is requested but is not permitted, likely due to insufficient permissions. Nrr=rrrrrrrceZdZdZy)CriticalApiErrorzError raised for critical API failures. This error represents severe issues with the API or infrastructure that prevent requests from completing. Nrr=rrrrrrrceZdZdZy)ApiRateLimitErrorzError raised when the API rate limit is exceeded. This exception is raised when the user has made too many requests within a given time frame, as enforced by the API's rate limit policy. Nrr=rrrrrrrceZdZdZy)rzError raised when an API request times out. This error is raised if an API request does not complete within the allowed timeframe, possibly due to network issues or server load. Nrr=rrrrrrrceZdZdZy)DoesNotExistErrorzError raised when a requested resource does not exist. This exception is triggered when a specific resource is requested but cannot be found in the API, indicating a potential data mismatch or invalid identifier. Nrr=rrrrrrrceZdZdZy)ValidationErrorzError raised for invalid input data. This exception is raised when the input data for an API request does not meet validation requirements, such as incorrect data types or missing fields. Nrr=rrrrrrr)rz Match[str]r6r)NNN<FNN)rDrer{rr1rr2rdrVzstr | bytes | NonerHrgrIr5rintrrirCr5rGr5rLrr6zResponse | Anyrc)rrrCrrzdict[str, str] | Noner6rdrf) r1rr{r5rCr5rIr5rGr5r6r)F)rrir6zlogging.Logger)rr rr rrir6r),r; __future__rrXrrrrrrrtypingrrrrequests.compatr mailjet_rest.utils.versionr collections.abcr r requests.modelsr packagesurllib3disable_warningsrrr?rkrJrrrrrrrrrrrrrr=rrrsQ8#   #2('( **, EEPV V rC C V $.2" @ @ @ @ @  @ , @@@ @ @@@@L,0 ) >"         @" ""P   @yx8hr