| Server IP : 188.114.96.3 / Your IP : 216.73.216.30 Web Server : LiteSpeed System : Linux vmi2710904 5.15.0-144-generic #157-Ubuntu SMP Mon Jun 16 07:33:10 UTC 2025 x86_64 User : rarch5794 ( 1006) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/cloudinit/__pycache__/ |
Upload File : |
o
x[h�� � @ sJ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
Z
m Z d dl m
Z
d dlmZ d dlmZ d dlmZ d dlmZ d dlmZmZmZmZmZm Z m Z m Z m Z d d l m!Z!m"Z"m#Z#m$Z$ d dl%Z%d d
l%m&Z& d d l'm(Z(m)Z)m*Z* e�+e,�Z-d Z.e ed
ge/f Z0dd� Z1dd� Z2de3fdd�Z4d[de5de6de7ddfdd�Z8d e5dd fd d �Z9de d fd!d"�Z:G d#d$� d$�Z;G d%d � d e;�Z<G d&d� de;�Z=G d'd(� d(�Z>G d)d
� d
e?�Z@d*d+� ZAd,e5de6fd-d.�ZBdd/�d0e@d1e0de e6 fd2d3�ZCddd d4ddddd5d5ddd6d5d7d6d8�d1e0d9e/de>fd:d;�ZD d\d<ed=ef d>e5de3d?ejEd@e e6 def dAdB�ZF C Dd]d<ed=ef dEee5 dFe6de3de e e5 e e> f f
dGdH�ZGG dIdJ� dJe �ZHe6dK�de-jIdddddd7d5dCdL� dMe6de e6 dNedOe e dPe e6 d1e0dQe eee6ge6f dRe5dSe/dTe6fdUdV�ZJG dWdX� dX�ZK d\dYdZ�ZLdS )^� N)�ThreadPoolExecutor� TimeoutError� as_completed)� parsedate)�partial)� NOT_FOUND)�count)�create_default_context) �Any�Callable�Iterator�List�Mapping�
NamedTuple�Optional�Tuple�Union)�quote�urlparse�urlsplit�
urlunparse)�
exceptions)� performance�util�version�REDACTED�UrlErrorc C s< t t| dd��}|d s|d r|d |d< d|d< t|�S )N�http)�scheme� � � )�listr r )�url�
parsed_url� r% �6/usr/lib/python3/dist-packages/cloudinit/url_helper.py� _cleanurl1 s
r' c G s$ dd� }| }|D ]}|||�}q|S )Nc S sN t t| ��}|d }|r|�d�s|d7 }|tt|�dd�7 }||d< t|�S )Nr �/z/:)�safe)r" r �endswithr �strr )r# �add_on�
url_parsed�pathr% r% r& �combine_single< s z#combine_url.<locals>.combine_singler% )�base�add_onsr/ r# r, r% r% r& � combine_url; s
r2 �returnc
C sX t jdt jdt jdt jdtdi}|�t| ��}|s*t| t �r#| j
}|S t � d� d}|S )z4helper for read_ftps to map return codes to a number�, � �� iX i� z9Unexpected exception type while connecting to ftp server.i����)
�ftplib� error_reply�
error_temp�
error_perm� error_proto�EOFError�get�type�
isinstance�OSError�errno�LOG�warning)�exc�ftp_error_codes�coder% r% r& �"ftp_get_return_code_from_exceptionK s �
��rG � @r# �timeout�kwargs� FtpResponsec K s� t | �}|jstdtd| d��t�� ��_}|jpd}|jp d}d|jkr�zt j
t � d�}t �
d| |� |j|j||p;d d
� W n! t jy` } zt|�} td | � d | � d
�| d| d�|�d}~ww t �
d|� z|j||jpodd� t �
d� |�� W n t jy� } zt �d� tddd| d�|�d}~ww zNz,t �
d|j� |jd|j� �|jd� t|�� | �W W t �
d� |�� W d � S t jy� } zt|�} td| � d | � d
�| d| d�|�d}~ww t �
d� |�� w zwzTt � � }
t �
d| |� |
j|j||�pd d
� t �
d|� |
j||j�pdd� t �
d|j� |
jd|j� �|jd� t|�� | �W W t �
d� |
�� W d � S t j�yh } zt|�} td| � d | � d
�| d| d�|�d}~ww t �
d� |
�� w 1 �sww Y dS )az connect 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��causerF �headersr# � � anonymous�ftps)�contextz3Attempting to connect to %s via port [%s] over tls.rH )�host�portrI z1Reading file from server over tls failed for url z [�]z"Attempting to login with user [%s]r! )�user�passwdz Creating 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.r6 zReading file: %szRETR )�callbackzClosing connectionz,Reading file from ftp server failed for url z(Attempting to connect to %s via port %s.) r �hostnamer r �io�BytesIOrT �usernamer r7 �FTP_TLSr rB �debug�connect�
all_errorsrG �login�password�prot_pr: rC r. �
retrbinary�writerK �getvalue�close�FTP) r# rI rJ � url_parts�bufferrT rV �ftp_tls�erF �ftpr% r% r& � read_ftpsb s �
��
������� �
�� ����
�<������
��
�
�]������
�rn r. � FileResponsec
K s� |� d�r t�d| � z t�| �}t|| �W S ty+ } z t|td| d�|�d}~w t y@ } z
t||j
d| d�|�d}~ww )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 %sNrL ) r= rB rC r �load_binary_filero �FileNotFoundErrorr r �IOErrorrA )r. rJ �contentsrl r% r% r& �
_read_file� s
���ru )ro � UrlResponserK c
K s� | � � } zt| �}W n ty } zt|| d�|�d}~ww |j}|dks-| r6d| d kr6t|jfi |��S |dv rBt| fi |��S |dv rNt| fi |��S t �
d|� t| fi |��S ) a0 Wrapper 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.
)rM r# N�filer( r )rm rQ )r �httpsz Attempting unknown protocol %s) �lstripr �
ValueErrorr r ru r. rn �readurlrB rC )r# rJ �parsedrl r r% r% r& �read_file_or_url� s
�� r} c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
�StringResponse�� c C s || _ i | _|| _|| _d S �N)rF rN rt r# ��selfrt r# rF r% r% r& �__init__ s
zStringResponse.__init__c O s
| j dkS )Nr �rF �r� �argsrJ r% r% r& �ok �
zStringResponse.okc C s | j �d�S )Nzutf-8)rt �decode�r� r% r% r& �__str__ s zStringResponse.__str__N�r )�__name__�
__module__� __qualname__r� r� r� r% r% r% r& r~ s
r~ c s( e Zd Zddedef� fdd�
Z� ZS )ro r rt r# c s t � j|||d� d S )Nr� ��superr� r� �� __class__r% r& r� ! s zFileResponse.__init__r� �r� r� r� �bytesr+ r� �
__classcell__r% r% r� r& ro s c s& e Zd Zdedef� fdd� Z� ZS )rK rt r# c s t � �||� d S r� r� )r� rt r# r� r% r& r� & s zFtpResponse.__init__r� r% r% r� r& rK % s c @ s� e Zd Zdejfdd�Zedefdd��Zede fdd��Z
dde fd
d �Z ed d
� �Z
edefdd��Zdd� Z ddee de dee fdd�ZdS )rv �responsec C s
|| _ d S r� )� _response)r� r� r% r% r& r� + r� zUrlResponse.__init__r3 c C s | j jd u rdS | j jS )N� )r� �contentr� r% r% r& rt . s zUrlResponse.contentsc C � | j jS r� )r� r# r� r% r% r& r# 4 � zUrlResponse.urlFc C s. d}|rd}d| j kr|k rdS dS dS )Nr4 r5 r TFr� )r� � redirects_ok�upperr% r% r& r� 8 s �zUrlResponse.okc C r� r� )r� rN r� r% r% r& rN A r� zUrlResponse.headersc C r� r� )r� � status_coder� r% r% r& rF E r� zUrlResponse.codec C r� r� )r� �textr� r% r% r& r� I s zUrlResponse.__str__r �
chunk_size�decode_unicodec c s � | j �||�E dH dS )at Iterates 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)r� r� r� r% r% r& r� L s � zUrlResponse.iter_contentN)F)r F)r� r� r� �requests�Responser� �propertyr� rt r+ r# �boolr� rN �intrF r� r r r� r% r% r% r& rv * s(
����rv c
@ s: e Zd Z ddedee dee dee fdd�ZdS ) r NrM rF rN r# c C s8 t �| t|�� || _|| _|d u ri n|| _|| _d S r� )rs r� r+ rM rF rN r# )r� rM rF rN r# r% r% r& r� \ s
zUrlError.__init__)NNN) r� r� r� r
r r� r r+ r� r% r% r% r& r [ s �����c C s� i }t | �j}|dkr@|r@d|v r |d r |d |d< nd|d< d|v r4d|v r4|d |d g|d< |S d|v r@t|d �|d< |S )Nrx �ca_certs�verifyT� cert_file�key_file�cert)r r r+ )r# � ssl_details�ssl_argsr r% r% r& �
_get_ssl_argsj s
��r� � retry_afterc C s� zt | �}W |S tyH zt| �}|std��t t�|�t�� �}W n ty6 t�d| � d}Y nw |dk rEt�d� d}Y |S Y |S w )a< Parse a Retry-After header value into an integer.
: param retry_after: The value of the Retry-After header.
https://www.rfc-editor.org/rfc/rfc9110.html#section-10.2.3
https://www.rfc-editor.org/rfc/rfc2616#section-3.3
: return: The number of seconds to wait before retrying the request.
z(Failed to parse Retry-After header valuezGFailed to parse Retry-After header value: %s. Waiting 1 second instead.r r zBRetry-After header value is in the past. Waiting 1 second instead.)�floatrz r �time�mktimerB �info)r� �to_wait�
time_tupler% r% r& �_get_retry_after| s2
� �����r� �� exception_cb�errorr� c C s\ |r|| �rdS | j r(| j dkr(t�d� | jr!t| j�dd��S t�d� dS |s,dS | �)a� Handle exceptions raised during request processing.
If we have no exception callback or the callback handled the error or we
got a 503, return with an optional timeout so the request can be retried.
Otherwise, raise the error.
:param error: The exception raised during the request.
:param response: The response object.
:param exception_cb: Callable to handle the exception.
:return: Optional time to wait before retrying the request.
Ni� zEEndpoint returned a 503 error. HTTP endpoint is overloaded. Retrying.z Retry-After�1z7Unable to introspect response header. Waiting 1 second.r )rF rB rC rN r� r= r� )r� r� r% r% r& �
_handle_error� s �
r� r TFr! )rp rI �retries� sec_betweenrN �
headers_cb�headers_redactr� � check_status�allow_redirectsr� �session�infinite� log_req_resp�request_method�streamr� c s� t | �} | |d�}|�t| |�� |
|d< |s |rdnd}||d< |dur8t|t�r/||d< n tt|�d�|d< |du r>g }d }|rKtt|�d d �}d
t� � }|durZ|�
� }ni }|rb||d < |du rhd }| du rpt � � } t
� D �]}|r||| �}d
|vr�||d
< ||d< i }|�� D ]1\}� |d kr�q�|dkr�|r�� fdd�|D �}|r�t
�� �||< |D ]}t|| |< q�q�� ||< q�z3|r�t�d||
r�dn|| |� | jdi |��}| r�|�� t�d| |jt|j�|d � t|�W S tj�y } zt|| d�|�d}~w tj �y) } zt||j j|j j | d�}|} W Y d}~n"d}~w tj �yF } zt|| d�}|} d}W Y d}~nd}~ww t || d�} | �s_|
�pX|d |k } | �s_|| �| �pc|} |dk�rw|�rrt�d|� t!�"| � qst#d��)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 to handle exception and returns
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� r� �POST�GET�methodNrI r r z
Cloud-Init/%srp ���z
User-AgentrN c s g | ] }� � |�r|�qS r% )r= )�.0�k��vr% r& �
<listcomp>' s zreadurl.<locals>.<listcomp>z'[%s/%s] open '%s' with %s configurationr� z(Read from %s (%s, %sb) after %s attempts�r# �rF rN r# r� �1Please wait %s seconds while we wait to try againz"This path should be unreachable...r% )$r' �updater� r? �tuple�maxr� r� r �version_string�copyr� �Sessionr �items�deepcopyr rB r^ �request�raise_for_statusr� �lenr� rv r �SSLErrorr � HTTPErrorr� rN �RequestExceptionr� r� �sleep� RuntimeError) r# rp rI r� r� rN r� r� r� r� r� r� r� r� r� r� r� �req_args� manual_tries�
user_agent�i�filtered_req_argsr� �matched_headers�keyr� rl � url_error�raised_exception�response_sleep_time�
will_retry�
sleep_timer% r� r& r{ � s� 5�
�
��
��� ���
�
�r{ �func.�addr�event�delayc C s |r
|j |d�r
dS | ||�S )z Execute func with optional delay�rI N��wait�r� r� rI r� r� r% r% r& �_run_func_with_delayp s
r� �333333�?�
� addresses�
stagger_delayc s. d}d}d}g }t �� �tt|�d�� z|zW� ����fdd�t|�D �}t|�d�D ],} || }| �� }
|
r>|
}|�|� q*| �� }|rV�� � ||f W W � j
dd� S q*|rbt � d||� |�t �
d |� td
�� ty� t � d d �|�d �tt|��� Y nw W � j
dd� ||fS � j
dd� w )
a execute 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 | ]\}}� j t�|��|� d �|�qS )r� )�submitr� )r� r� r� ��executorr� �is_doner� rI r% r& �
<dictcomp>� s ���z dual_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�Eventr r� � enumerater � exception�append�result�set�shutdownrB r^ r� rz r �join�mapr+ ) r� r� r� rI �
return_result�returned_address�last_exceptionr �futures�future�return_exceptionr% r r& �
dual_stack� sT
�
� � �� �r c @ s2 e Zd ZU ee ed< ee ed< ee ed< dS )�HandledResponser# r� � wait_timeN)r� r� r� r r+ �__annotations__rv r� r% r% r% r& r � s
r �inf) �max_waitrI � status_cbr� r� r� r� �
sleep_time_cbr� �connect_synchronously� async_delayr r r� r� r r� r r c s� dt dtf�
fdd� } d#dtdtdtfd d
�� d tt d tt dttt tf fd
d��dttgttt tt f f dt tt
t f dt dt dtdt f ��fdd� �d tdt dtf��� fdd� �dt f������ � fdd� }
dt f� ��� fdd� }t
�� }�
r�|r�td ��|
r�|
n|}|p�| }d�d } |||||�}d �|jr�|j|jjfS |jr�t
�|j� �d �d �q�||��}� �||�r� d"S �d �t�d!|� t
�|� t
�� }|r�|| |� kr�|| }|dkr� d"S q�)$a
Wait for a response from one of the urls provided.
:param urls: List of urls to try
:param 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
:param timeout: Timeout provided to urlopen
:param status_cb: Callable with string message when a url is not available
:param headers_cb: Callable with single argument of url to get headers
for request.
:param headers_redact: List of header names to redact from the log
:param 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`.
:param exception_cb: Callable to handle exception and returns True if
retries are permitted.
:param sleep_time_cb: Callable with 2 arguments (response, loop_n) that
generates the next sleep time. Cannot be specified
along with 'sleep_time`.
:param request_method: Indicates the type of HTTP request:
GET, PUT, or POST
:param connect_synchronously: If false, enables executing requests
in parallel
:param async_delay: Delay before parallel metadata requests, see RFC 6555
:return: tuple of (url, response contents), on failure, (False, None)
:raises: UrlError on unrecoverable error
� loop_numberr3 c s � d ur� S |d d S )N� r r% )�_r )r� r% r& �default_sleep_time
s z(wait_for_url.<locals>.default_sleep_timer r �
start_timer� c S s0 | t d�dfv r
dS | dkpt�� | | | kS )z4Check if time is up based on start time and max waitr NFr )r� r� � monotonic)r r# r� r% r% r& �timeup s
�z wait_for_url.<locals>.timeupr� r# c
S s� d}d}| r|sd}t t|��}||fS z| j�� W n& tjjyA } zt ||jj|jj |d�}|t
|�fW Y d}~S d}~ww | j sZd| j }t t|�| j | j |d�}||fS | �
� sod| j }t t|�| j | j |d�}||fS )z?Map requests response code/contents to internal "UrlError" typer! NzRequest timed outr� zempty response [%s]zbad status code [%s])r rz r� r� r� r r� r� r� rN r+ rt rF r� )r� r# �reason�url_excrl r% r% r& �handle_url_response sH ���
��
�z)wait_for_url.<locals>.handle_url_response�
url_reader_cb�urls�exc_cb�log_cbc
s d}d}z| |�\}}� ||�\}}|s t ||dd�W S W n/ ty5 } z d| }| }W Y d} ~ n d} ~ w tyL } z d| }| }W Y d} ~ nd} ~ ww tt�� | �}
�r[d� nd} d|pet|d d �|
| |f } || � t ddt|t�rt||d
�d �S dd �S ) z:Execute request, handle response, optionally log exceptionr! N)r zrequest error [%s]zunexpected error [%s]z%ss� unlimitedz Calling '%s' failed [%s/%s]: %sr# r� �r# r� r ) r r � Exceptionr� r� r$ �getattrr? r� )
r) r* r# r+ r, r& r# r� r' rl �
time_taken� max_wait_str�
status_msg)r( r r% r& �read_url_handle_exceptionsA sD
����� ���z0wait_for_url.<locals>.read_url_handle_exceptionsrI c s$ t | � d u ri n� | ��|d�d�S )NF)rN r� rI r� r� )r{ )r# rI )r� r� r� r% r& � read_url_cbm s �z!wait_for_url.<locals>.read_url_cbc
s� dt f�� fdd� }g }�D ]H}t�� }�dkr>�s>��| �r(tdddd� S �dur>� r>|� | � kr>t| � | �� �||| ||�}|jrM| S |jrV|�|j� q|r]t|�nd} tdd| d�S )z|iterate over list of urls, request each one and handle responses
and thrown exceptions individually per url
r# c s | � | ��fS r� r% r� )r5 rI r% r& �url_reader_serial~ � z@wait_for_url.<locals>.read_url_serial.<locals>.url_reader_serialr Nr. ) r+ r� r$ r r� r� r r r� )
r# rI r+ r, r6 �
wait_timesr# �now�outr )�loop_nr �must_try_againr5 r4 r% r* r� r& �read_url_serialw s0
��
� �z%wait_for_url.<locals>.read_url_serialc s t t�� |d�}�|�| ||�S )z�pass list of urls to dual_stack which sends requests in parallel
handle response and exceptions of the first endpoint to respond
)r� rI )r r )r# rI r+ r, �url_reader_parallel)r r5 r4 r* r% r& �read_url_parallel� s �
�z'wait_for_url.<locals>.read_url_parallelz3sleep_time and sleep_time_cb are mutually exclusiveNTFr r� )FN)r )r� r� r rv r+ r r r r
r r
�ExceptionCallbackr r� r$ rz r� r# rt r r� rB r^ )r* r rI r r� r� r� r� r r� r r r" r= r? r# � do_read_url�calculate_sleep_timer� �resp�current_sleep_time� current_timer% )
r r( r� r� r; r r< r5 r4 r� r� r% r* r& � wait_for_url� s� /��
�)������� ,
�$�
�
��
�rF c @ sh e Zd Z ddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dd� Z
dd� Z dd� Z dS )�OauthUrlHelperN�/run/oauth_skew.jsonc C st || _ |pd| _|| _|| _|| _d| _d| _| j| j| j f}t|�s'd| _nt|�s/t d��| �
� }|p6i | _ d S )Nr! Tr 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�allrz �read_skew_file� skew_data)r� rI rK rL rJ rM �required�oldr% r% r& r� � s
�zOauthUrlHelper.__init__c C s� | j rGtj�| j �rGt�d| j � ���, t| j dd��}t�|�W d � W d � S 1 s2w Y W d � d S 1 sBw Y d S )NzReading �r��mode) rM �osr. �isfiler �Timed�open�json�load)r� �fpr% r% r& rR � s �:��z OauthUrlHelper.read_skew_filec C s� | j sd S | �� }|d u ri }|||< t�d| j � ���0 t| j dd��}|�t�|�� W d � n1 s7w Y W d � d S W d � d S 1 sOw Y d S )NzWriting �wrW )rM rR r r[ r\ re r] �dumps)r� rS �value�curr_ r% r% r& �update_skew_file s �P�z OauthUrlHelper.update_skew_filec
C s� t |t�r|jdks|jdksd S d|jvr t�d|j� d S |jd }z t�t|��}W n t yG } zt�d||� W Y d }~d S d }~ww t
|t�� �}t |j �j
}| j�|d�}t|| �| jkrs| �||� t�d||� || j|< d S )Ni� i� �datez$Missing header 'date' in %s responsez#Failed to convert datetime '%s': %sr z$Setting oauth clockskew for %s to %d)r? r rF rN rB rC r� r� r r/ r� r r# �netlocrS r= �absrO rd )r� r re � remote_timerl �skewrS �old_skewr% r% r& r� s. �
��
zOauthUrlHelper.exception_cbc C sZ | j si S d }t|�j}| jr || jv r tt�� �| j| }t|| j| j| j | j
|d�S )N)r# rI rK rL rJ � timestamp) rN r rf rS r� r� �
oauth_headersrI rK rL rJ )r� r# rk rS r% r% r& r� * s
�zOauthUrlHelper.headers_cbc C s: t | j|�d��|d< t | j|�d��|d< ||i |��S )Nr� r� )r � _headers_cbr= �
_exception_cb)r� � wrapped_funcr� rJ r% r% r& �_wrapped< s � �zOauthUrlHelper._wrappedc O � | � t||�S r� )rp rF r� r% r% r& rF E r7 zOauthUrlHelper.wait_for_urlc O rq r� )rp r{ r� r% r% r& r{ H r7 zOauthUrlHelper.readurlc C s> d}z|r||�}W | � |� |S W | � |� |S | � |� w )NTr� )r� �extra_exception_cbr �retr% r% r& rn K s
�
�z OauthUrlHelper._exception_cbc C s$ i }|r||�}|� | �|�� |S r� )r� r� )r� �extra_headers_cbr# rN r% r% r& rm T s
zOauthUrlHelper._headers_cb)NNNNrH )
r� r� r� r� rR rd r� r� rp rF r{ rn rm r% r% r% r& rG � s
�
rG c
C sr zdd l m} W n ty } ztd�|�d }~ww |r!t|�}nd }|j|||||j|d�}|�| �\} }
} |
S )Nr z oauth support is not available)�
client_secret�resource_owner_key�resource_owner_secret�signature_methodrk )�oauthlib.oauth1�oauth1� ImportError�NotImplementedErrorr+ �Client�SIGNATURE_PLAINTEXT�sign) r# rI rK rL rJ rk rz rl �client�_uri�signed_headers�_bodyr% r% r& rl \ s&
��
�rl )rH r� )r� r� )Mr� r7 rZ r] �loggingrY r r� �concurrent.futuresr r r � email.utilsr � functoolsr � http.clientr � itertoolsr �sslr �typingr
r r r
r r r r r � urllib.parser r r r r� r � cloudinitr r r � getLoggerr� rB r r� r@ r' r2 r� rG r+ r� �dictrn ru r} r~ ro rK rv rs r r� r� r� r{ r r� r r r^ rF rG rl r% r% r% r& �<module> s
,
� 1%���
�%�
��
� 6�
�����
��
����
�S ������ �
� � �
� �