One Hat Cyber Team
Your IP :
10.30.1.1
Server IP :
103.148.201.5
Server :
Linux web-olt 5.15.0-156-generic #166-Ubuntu SMP Sat Aug 9 00:02:46 UTC 2025 x86_64
Server Software :
Apache/2.4.52 (Ubuntu)
PHP Version :
8.1.29
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
cloudinit
/
__pycache__
/
View File Name :
url_helper.cpython-310.pyc
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 ������ � � � � � �