403Webshell
Server IP : 192.250.235.158  /  Your IP : 216.73.216.4
Web Server : LiteSpeed
System : Linux s4099.sgp1.stableserver.net 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64
User : vmxfzbqj ( 1905)
PHP Version : 8.3.31
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /lib/python3.9/site-packages/cloudinit/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /lib/python3.9/site-packages/cloudinit/__pycache__/url_helper.cpython-39.pyc
a

'�DgЊ�@s�ddlZddlZddlZddlZddlZddlZddlZddlZddlm	Z	m
Z
mZddlm
Z
ddlmZddlmZddlmZddlmZddlmZmZmZmZmZmZmZdd	lmZm Z m!Z!m"Z"ddl#Z#dd
l#m$Z$ddl%m&Z&m'Z'm(Z(e�)e*�Z+dZ,d
d�Z-dd�Z.e/d�dd�Z0dBe1e2e3dd�dd�Z4e1dd�dd�Z5edd�dd�Z6Gd d!�d!�Z7Gd"d�de7�Z8Gd#d�de7�Z9Gd$d%�d%�Z:Gd&d'�d'e;�Z<d(d)�Z=dCe>e:d.�d/d0�Z?dDed1efe1e/ej@ee2ed2�d3d4�ZAdEed1efee1e2e/ed7�d8d9�ZBe2d:�de+jCdddddd-d+d5fe2ee2eeeee2eeeeee2ge2fe1e>e2d;�
d<d=�ZDGd>d?�d?�ZEdFd@dA�ZFdS)G�N)�ThreadPoolExecutor�TimeoutError�as_completed)�	parsedate)�partial)�	NOT_FOUND)�count)�create_default_context)�Any�Callable�Iterator�List�Optional�Tuple�Union)�quote�urlparse�urlsplit�
urlunparse)�
exceptions)�performance�util�version�REDACTEDcCs<tt|dd��}|ds4|dr4|d|d<d|d<t|�S)N�http)�scheme���)�listrr)�urlZ
parsed_url�r!�8/usr/lib/python3.9/site-packages/cloudinit/url_helper.py�	_cleanurl&s
r#cGs$dd�}|}|D]}|||�}q|S)NcSsNtt|��}|d}|r*|�d�s*|d7}|tt|�dd�7}||d<t|�S)Nr�/z/:)�safe)rr�endswithr�strr)r �add_onZ
url_parsed�pathr!r!r"�combine_single1sz#combine_url.<locals>.combine_singler!)�baseZadd_onsr*r r(r!r!r"�combine_url0s
	r,��returnc
CsVtjdtjdtjdtjdtdi}|�t|��}|sRt|t	�rD|j
}nt�d�d}|S)z4helper for read_ftps to map return codes to a number�,���iXi�z9Unexpected exception type while connecting to ftp server.i����)
�ftplibZerror_replyZ
error_temp�
error_permZerror_proto�EOFError�get�type�
isinstance�OSError�errno�LOG�warning)�excZftp_error_codes�coder!r!r"�"ftp_get_return_code_from_exception@s�
�r>�@�FtpResponse)r �timeout�kwargsr.cKsrt|�}|jstdtd|d��t����4}|jp2d}|jp<d}d|jk�r&z6t	j
t�d�}t�
d||�|j|j||pxd	d
�WnNt	jy�}z4t|�}	td|�d|	�d
�|	d|d�|�WYd}~n
d}~00t�
d|�z*|j||jp�dd�t�
d�|��WnDt	j�yJ}z(t�d�tddd|d�|�WYd}~n
d}~00z�zXt�
d|j�|jd|j��|jd�t|��|�WWt�
d�|��Wd�St	j�y�}z4t|�}	td|�d|	�d
�|	d|d�|�WYd}~n
d}~00Wt�
d�|��nt�
d�|��0�n(�zz�t	��}
t�
d||�|
j|j||�pTd	d
�t�
d|�|
j||j�pvdd�t�
d|j�|
jd|j��|jd�t|��|�WWt�
d�|
��Wd�St	j�y"}z4t|�}	td|�d|	�d
�|	d|d�|�WYd}~n
d}~00Wt�
d�|
��nt�
d�|
��0Wd�n1�sd0YdS)azconnect to URL using ftp over TLS and read a file

    when using strict mode (ftps://), raise exception in event of failure
    when not using strict mode (ftp://), fall back to using unencrypted ftp

    url: string containing the desination to read a file from. The url is
        parsed with urllib.urlsplit to identify username, password, host,
        path, and port in the following format:
            ftps://[username:password@]host[:port]/[path]
        host is the only required component
    timeout: maximum time for the connection to take
    kwargs: unused, for compatibility with read_url
    returns: UrlResponse
    zInvalid url providedN��causer=�headersr �Z	anonymous�ftps)�contextz3Attempting to connect to %s via port [%s] over tls.r?)�host�portrAz1Reading file from server over tls failed for url z [�]z"Attempting to login with user [%s]r)�user�passwdzCreating a secure connectionz�Attempted to connect to an insecure ftp server but used a scheme of ftps://, which is not allowed. Use ftp:// to allow connecting to insecure ftp servers.r1zReading file: %szRETR )�callbackzClosing connectionz,Reading file from ftp server failed for url z(Attempting to connect to %s via port %s.)r�hostname�UrlErrorr�io�BytesIOrJ�usernamerr2ZFTP_TLSr	r:�debugZconnectZ
all_errorsr>Zlogin�passwordZprot_pr3r;r)Z
retrbinary�writer@�getvalue�closeZFTP)r rArBZ	url_parts�bufferrJrLZftp_tls�er=�ftpr!r!r"�	read_ftpsWs��

���
����	�
��	�
�
�����


�
��
�
�����


�
r\�FileResponse)r)r.c
Ks�|�d�rt�d|�zt�|�}t||�WStyb}zt|td|d�|�WYd}~n@d}~0t	y�}z t||j
d|d�|�WYd}~n
d}~00dS)zmread a binary file and return a FileResponse

    matches function signature with read_ftps and read_url
    �dataz'Unable to post data to file resource %sNrC)r5r:r;rZload_binary_filer]�FileNotFoundErrorrPr�IOErrorr9)r)rB�contentsrZr!r!r"�
_read_file�s

&rb)r]�UrlResponser@c
Ks�|��}zt|�}Wn2tyF}zt||d�|�WYd}~n
d}~00|j}|dksf|rxd|dkrxt|jfi|��S|dvr�t|fi|��S|dvr�t|fi|��St	�
d|�t|fi|��SdS)	a0Wrapper function around readurl to allow passing a file path as url.

    When url is not a local file path, passthrough any kwargs to readurl.

    In the case of parameter passthrough to readurl, default values for some
    parameters. See: call-signature of readurl in this module for param docs.
    )rDr N�filer$r)r[rG)r�httpszAttempting unknown protocol %s)�lstripr�
ValueErrorrPrrbr)r\�readurlr:r;)r rB�parsedrZrr!r!r"�read_file_or_url�s
$rjc@s&eZdZd	dd�Zdd�Zdd�ZdS)
�StringResponse��cCs||_i|_||_||_dS�N)r=rErar ��selfrar r=r!r!r"�__init__szStringResponse.__init__cOs
|jdkS)Nrl�r=�ro�argsrBr!r!r"�okszStringResponse.okcCs|j�d�S)Nzutf-8)ra�decode�ror!r!r"�__str__szStringResponse.__str__N)rl)�__name__�
__module__�__qualname__rprtrwr!r!r!r"rks
rkcs&eZdZdeed��fdd�
Z�ZS)r]rl�rar cst�j|||d�dS)Nrq��superrprn��	__class__r!r"rpszFileResponse.__init__)rl�rxryrz�bytesr'rp�
__classcell__r!r!r~r"r]scs$eZdZeed��fdd�Z�ZS)r@r{cst��||�dSrmr|)rorar r~r!r"rpszFtpResponse.__init__r�r!r!r~r"r@sc@s�eZdZejd�dd�Zeed�dd��Zee	d�dd��Z
ded�d
d�Zedd
��Z
eed�dd��Zdd�Zdeeeeed�dd�ZdS)rc)�responsecCs
||_dSrm)�	_response)ror�r!r!r"rp szUrlResponse.__init__r-cCs|jjdurdS|jjS)N�)r��contentrvr!r!r"ra#szUrlResponse.contentscCs|jjSrm)r�r rvr!r!r"r )szUrlResponse.urlFcCs2d}|rd}d|jkr"|kr*nndSdSdS)Nr/r0rlTFrq)roZredirects_ok�upperr!r!r"rt-szUrlResponse.okcCs|jjSrm)r�rErvr!r!r"rE6szUrlResponse.headerscCs|jjSrm)r��status_codervr!r!r"r=:szUrlResponse.codecCs|jjSrm)r��textrvr!r!r"rw>szUrlResponse.__str__r)�
chunk_size�decode_unicoder.ccs|j�||�EdHdS)atIterates over the response data.

        When stream=True is set on the request, this avoids reading the content
        at once into memory for large responses.

        :param chunk_size: Number of bytes it should read into memory.
        :param decode_unicode: If True, content will be decoded using the best
        available encoding based on the response.
        N)r��iter_content)ror�r�r!r!r"r�AszUrlResponse.iter_contentN)F)rF)rxryrz�requestsZResponserp�propertyr�rar'r �boolrtrE�intr=rwrrr�r!r!r!r"rcs 	
��rcc@seZdZddd�ZdS)rPNcCs<t�|t|��||_||_||_|jdur2i|_||_dSrm)r`rpr'rDr=rEr )rorDr=rEr r!r!r"rpQs
zUrlError.__init__)NNN)rxryrzrpr!r!r!r"rPPsrPcCs�i}t|�j}|dkr~|r~d|vr8|dr8|d|d<nd|d<d|vrfd|vrf|d|dg|d<nd|vr~t|d�|d<|S)NreZca_certsZverifyTZ	cert_fileZkey_fileZcert)rrr')r �ssl_detailsZssl_argsrr!r!r"�
_get_ssl_args[s
�
r�rTFr)�streamr.cst|�}||d�}|�t||��|
|d<|s:|r6dnd}||d<|durpt|t�r^||d<ntt|�d�|d<|dur|g}d	}|r�tt|�d	d	�}d
t�	�}|dur�|�
�}ni}|r�||d<|dur�d}|dur�t��}t
�D�] }|r�||�}d
|v�r
||d
<||d<i}|��D]p\}�|dk�r4�q|dk�r�|�r��fdd�|D�}|�r�t
���||<|D]}t|||<�qnn�||<�qzl|�r�t�d||
�r�dn|||�|jfi|��}|	�r�|��t�d||jt|j�|d	�t|�WStj�y2}zt||d�|�WYd}~q�d}~0tj�y}z�t|tj��r�t|d��r�t|jd��r�t||jj|jj |d�}nt||d�}|�r�||�
�|��s�||�|
�p�|d	|k}|�s�||�|dk�r�|�r�t�d|�t!�"|�WYd}~q�d}~00q�t#d��dS)a�Wrapper around requests.Session to read the url and retry if necessary

    :param url: Mandatory url to request.
    :param data: Optional form data to post the URL. Will set request_method
        to 'POST' if present.
    :param timeout: Timeout in seconds to wait for a response. May be a tuple
        if specifying (connection timeout, read timeout).
    :param retries: Number of times to retry on exception if exception_cb is
        None or exception_cb returns True for the exception caught. Default is
        to fail with 0 retries on exception.
    :param sec_between: Default 1: amount of seconds passed to time.sleep
        between retries. None or -1 means don't sleep.
    :param headers: Optional dict of headers to send during request
    :param headers_cb: Optional callable returning a dict of values to send as
        headers during request
    :param headers_redact: Optional list of header names to redact from the log
    :param ssl_details: Optional dict providing key_file, ca_certs, and
        cert_file keys for use on in ssl connections.
    :param check_status: Optional boolean set True to raise when HTTPError
        occurs. Default: True.
    :param allow_redirects: Optional boolean passed straight to Session.request
        as 'allow_redirects'. Default: True.
    :param exception_cb: Optional callable which accepts the params
        msg and exception and returns a boolean True if retries are permitted.
    :param session: Optional exiting requests.Session instance to reuse.
    :param infinite: Bool, set True to retry indefinitely. Default: False.
    :param log_req_resp: Set False to turn off verbose debug messages.
    :param request_method: String passed as 'method' to Session.request.
        Typically GET, or POST. Default: POST if data is provided, GET
        otherwise.
    :param stream: if False, the response content will be immediately
    downloaded.
    )r r��allow_redirectsZPOSTZGET�methodNrArrz
Cloud-Init/%sr^���z
User-AgentrEcsg|]}��|�r|�qSr!)r5)�.0�k��vr!r"�
<listcomp>�r�zreadurl.<locals>.<listcomp>z'[%s/%s] open '%s' with %s configuration�infinitez(Read from %s (%s, %sb) after %s attempts�r r�r��r=rEr �1Please wait %s seconds while we wait to try againz"This path should be unreachable...)$r#�updater�r7�tuple�max�floatr�rZversion_string�copyr�ZSessionr�items�deepcopyrr:rTZrequestZraise_for_statusr��lenr�rcrZSSLErrorrPZRequestExceptionZ	HTTPError�hasattrr�rE�time�sleep�RuntimeError)r r^rAZretriesZsec_betweenrE�
headers_cb�headers_redactr��check_statusr��exception_cbZsessionr�Zlog_req_resp�request_methodr�Zreq_argsZmanual_triesZ
user_agent�iZfiltered_req_argsr�Zmatched_headers�key�rrZZ	url_errorZ
will_retryr!r�r"rhms�4�




��
"
�����
�"rh.)�func�addrrA�event�delayr.cCs|r|j|d�rdS|||�S)z Execute func with optional delay�rAN��wait�r�r�rAr�r�r!r!r"�_run_func_with_delaysr��333333�?�
)r��	addresses�
stagger_delayrAr.cs8d}d}d}g}t���tt|�d��z�z������fdd�t|�D�}t|�d�D]X}	||	}|	��}
|
r||
}|�|�qT|	��}|rT��	�||fWW�j
dd�SqT|r�t�d||�|�nt�
d	|�td
��Wn4t�yt�dd�|�d�tt|���Yn0W�j
dd�n�j
dd�0||fS)
aexecute multiple callbacks in parallel

    Run blocking func against two different addresses staggered with a
    delay. The first call to return successfully is returned from this
    function and remaining unfinished calls are cancelled if they have not
    yet started
    N)�max_workersc
s,i|]$\}}�jt�|��|�d�|�qS)r�)Zsubmitr�)r�r�r���executorr�Zis_doner�rAr!r"�
<dictcomp>Is	��zdual_stack.<locals>.<dictcomp>r�Fr�z<Exception(s) %s during request to %s, raising last exceptionzEmpty result for address %szNo result returnedzJTimed out waiting for addresses: %s, exception(s) raised while waiting: %s� )�	threading�Eventrr��	enumerater�	exception�append�result�setZshutdownr:r;�errorrgr�join�mapr')r�r�r�rAZ
return_resultZreturned_addressZlast_exceptionrZfuturesZfutureZreturn_exceptionr!r�r"�
dual_stack/sN
	�
���r��inf)
�max_waitrA�	status_cbr��
sleep_timer��
sleep_time_cbr��connect_synchronously�async_delaycsLttd��	fdd�}dtttd�dd��
dd	����fd
d�����fdd
�������
�fdd�}
����fdd�}t��}�	r�|r�td��|
r�|
n|}|p�|}d�d}||��}|||||�}|r�|\}}||jfS�
�||�r�q<�d�t�d|�t�|�t��}|r�|||�kr��||}|dkr��q<q�t�	d��dS)a1	
    urls:      a list of urls to try
    max_wait:  roughly the maximum time to wait before giving up
               The max time is *actually* len(urls)*timeout as each url will
               be tried once and given the timeout provided.
               a number <= 0 will always result in only one try
    timeout:   the timeout provided to urlopen
    status_cb: call method with string message when a url is not available
    headers_cb: call method with single argument of url to get headers
                for request.
    headers_redact: a list of header names to redact from the log
    sleep_time: Amount of time to sleep between retries. If this and
                sleep_time_cb are None, the default sleep time
                defaults to 1 second and increases by 1 seconds every 5
                tries. Cannot be specified along with `sleep_time_cb`.
    exception_cb: call method with 2 arguments 'msg' (per status_cb) and
                  'exception', the exception that occurred.
    sleep_time_cb: call method with 2 arguments (response, loop_n) that
                   generates the next sleep time. Cannot be specified
                   along with 'sleep_time`.
    request_method: indicate the type of HTTP request, GET, PUT, or POST
    connect_synchronously: if false, enables executing requests in parallel
    async_delay: delay before parallel metadata requests, see RFC 6555
    returns: tuple of (url, response contents), on failure, (False, None)

    the idea of this routine is to wait for the EC2 metadata service to
    come up.  On both Eucalyptus and EC2 we have seen the case where
    the instance hit the MD before the MD service was up.  EC2 seems
    to have permanently fixed this, though.

    In openstack, the metadata service might be painfully slow, and
    unable to avoid hitting a timeout of even up to 10 seconds or more
    (LP: #894279) for a simple GET.

    Offset those needs with the need to not hang forever (and block boot)
    on a system where cloud-init is configured to look for EC2 Metadata
    service but is not going to find one.  It is possible that the instance
    data host (169.254.169.254) may be firewalled off Entirely for a system,
    meaning that the connection will block forever unless a timeout is set.

    The default value for max_wait will retry indefinitely.
    )�loop_numberr.cs�dur�S|ddS)N�rr!)�_r�)r�r!r"�default_sleep_time�sz(wait_for_url.<locals>.default_sleep_timer�r��
start_timer�cSs0|td�dfvrdS|dkp.t��|||kS)z4Check if time is up based on start time and max waitr�NFr)r�r��	monotonicr�r!r!r"�timeup�s
�zwait_for_url.<locals>.timeupcSsf|js*d|j}tt|�|j|j|d�}n4|��sVd|j}tt|�|j|j|d�}nd}d}||fS)z?Map requests response code/contents to internal "UrlError" typezempty response [%s]r�zbad status code [%s]rN)rar=rPrgrErt)r�r �reason�url_excr!r!r"�handle_url_response�s&
�
�z)wait_for_url.<locals>.handle_url_responsec

s�d}d}z,||�\}}�||�\}}|s2||fWSWn^tyd}	zd|	}|	}WYd}	~	n8d}	~	0ty�}	zd|	}|	}WYd}	~	n
d}	~	00tt��|�}
�r�d�nd}d|p�t|dd�|
||f}||�|r�|||d	�dS)
z:Execute request, handle response, optionally log exceptionrNzrequest error [%s]zunexpected error [%s]z%ssZ	unlimitedzCalling '%s' failed [%s/%s]: %sr )�msgr�)rP�	Exceptionr�r�r��getattr)
Z
url_reader_cb�urlsr��exc_cb�log_cbr�r r�r�rZZ
time_takenZmax_wait_strZ
status_msg)r�r�r!r"�read_url_handle_exceptions�s0�z0wait_for_url.<locals>.read_url_handle_exceptionscs$t|�durin�|��|d�d�S)NF)rEr�rAr�r�)rh)r rA)r�r�r�r!r"�read_url_cb�s�z!wait_for_url.<locals>.read_url_cbcs���fdd�}�D]l}t��}�dkrb��|�r6dS�durb�rb|�|�krbt|�|���|||||�}|r|SqdS)z|iterate over list of urls, request each one and handle responses
        and thrown exceptions individually per url
        cs|�|��fSrmr!r�)r�rAr!r"�url_reader_serialsz@wait_for_url.<locals>.read_url_serial.<locals>.url_reader_serialrN)r�r�r�)r�rAr�r�r�r Znow�out)�loop_nr�r�r�r�r�r�r"�read_url_serials$
���
�z%wait_for_url.<locals>.read_url_serialcs,tt��|d�}�|�|||�}|r(|SdS)z�pass list of urls to dual_stack which sends requests in parallel
        handle response and exceptions of the first endpoint to respond
        )r�rAN)rr�)r�rAr�r�Zurl_reader_parallelr�)r�r�r�r�r!r"�read_url_parallel"s�
�z'wait_for_url.<locals>.read_url_parallelz3sleep_time and sleep_time_cb are mutually exclusiveNrr�z$Timed out, no response from urls: %s)FN)r)
r�r�r�r�rgrar:rTr�r�)r�r�rAr�r�r�r�r�r�r�r�r�r�r�r�r�Zdo_read_urlZcalculate_sleep_timer�Zcurrent_sleep_timer �addressZcurrent_timer!)r�r�r�r�r�r�r�r�r�r�r�r�r"�wait_for_url�sF9 

�

�
r�c@s^eZdZddd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Zdd�Z	dd�Z
dd�Zdd�ZdS)�OauthUrlHelperN�/run/oauth_skew.jsoncCst||_|pd|_||_||_||_d|_d|_|j|j|jf}t|�sNd|_nt|�s^t	d��|�
�}|pli|_dS)NrTr�FzBall or none of token_key, token_secret, or consumer_key can be set)�consumer_key�consumer_secret�	token_key�token_secret�skew_data_file�	_do_oauth�skew_change_limit�any�allrg�read_skew_file�	skew_data)ror�r�r�r�r��required�oldr!r!r"rpbs 
�zOauthUrlHelper.__init__c	Cs�|jr�tj�|j�r�t�d|j����Vt|jdd��(}t�|�Wd�Wd�S1sd0YWd�n1s�0YdS)NzReading r���mode)	r��osr)�isfiler�Timed�open�json�load)ro�fpr!r!r"r�}s�TzOauthUrlHelper.read_skew_filec	Cs�|js
dS|��}|duri}|||<t�d|j����Nt|jdd�� }|�t�|��Wd�n1sn0YWd�n1s�0YdS)NzWriting �wr)r�r�rrrrVr�dumps)rorI�valueZcurr	r!r!r"�update_skew_file�s�zOauthUrlHelper.update_skew_filec	
Cs�t|t�r|jdks"|jdks"dSd|jvr>t�d|j�dS|jd}zt�t|��}Wn4t	y�}zt�d||�WYd}~dSd}~00t
|t���}t|j�j
}|j�|d�}t||�|jkr�|�||�t�d||�||j|<dS)Ni�i��datez$Missing header 'date' in %s responsez#Failed to convert datetime '%s': %srz$Setting oauth clockskew for %s to %d)r7rPr=rEr:r;r��mktimerr�r�rr �netlocr�r5�absr�r
)	ror�r�rZremote_timerZZskewrIZold_skewr!r!r"r��s0���


zOauthUrlHelper.exception_cbcCsZ|js
iSd}t|�j}|jr>||jvr>tt���|j|}t||j|j|j	|j
|d�S)N)r r�r�r�r��	timestamp)r�rrr�r�r��
oauth_headersr�r�r�r�)ror rrIr!r!r"r��s
�zOauthUrlHelper.headers_cbcCs:t|j|�d��|d<t|j|�d��|d<||i|��S)Nr�r�)r�_headers_cbr5�
_exception_cb)roZwrapped_funcrsrBr!r!r"�_wrapped�s��zOauthUrlHelper._wrappedcOs|�t||�Srm)rr�rrr!r!r"r��szOauthUrlHelper.wait_for_urlcOs|�t||�Srm)rrhrrr!r!r"rh�szOauthUrlHelper.readurlc
Cs6d}z|r|||�}W|�||�n|�||�0|Srm)r�)roZextra_exception_cbr�r��retr!r!r"r�szOauthUrlHelper._exception_cbcCs$i}|r||�}|�|�|��|Srm)r�r�)roZextra_headers_cbr rEr!r!r"r�s
zOauthUrlHelper._headers_cb)NNNNr�)
rxryrzrpr�r
r�r�rr�rhrrr!r!r!r"r�as�

		r�c
Cs~zddlm}Wn.ty>}ztd�|�WYd}~n
d}~00|rNt|�}nd}|j|||||j|d�}|�|�\}	}
}|
S)Nrzoauth support is not available)Z
client_secretZresource_owner_keyZresource_owner_secretZsignature_methodr)Zoauthlib.oauth1�oauth1�ImportError�NotImplementedErrorr'ZClientZSIGNATURE_PLAINTEXT�sign)r r�r�r�r�rrrZZclientZ_uriZsigned_headersZ_bodyr!r!r"r�s" 
�r)r?)NNrrNNNNTTNNFTrF)N)r�r�)N)Gr�r2rQrZloggingrr�r��concurrent.futuresrrrZemail.utilsr�	functoolsrZhttp.clientr�	itertoolsrZsslr	�typingr
rrr
rrr�urllib.parserrrrr�rZ	cloudinitrrrZ	getLoggerrxr:rr#r,r�r>r'r��dictr\rbrjrkr]r@rcr`rPr�r�rhr�r�r�rTr�r�rr!r!r!r"�<module>s�$

�1��6�
��
�U��`�

Youez - 2016 - github.com/yon3zu
LinuXploit