File: //usr/lib/python3/dist-packages/duplicity/backends/pyrax_identity/__pycache__/hubic.cpython-310.pyc
o
�ka�' �
@ s� d dl mZ d dlmZ e�� d dlmZ d dlZd dlZd dl Z d dl
Z
d dl Z d dl
mZmZ d dlZzd dlZd dlmZmZ d dlmZ W n ey^ Z zedee� ��dZ[ww dZd Z ej � d
�Z G d d � d ej j!�Z"G d
d� de�Z#dS )� )�print_function)�standard_library)�strN)�quote�
quote_plus)� BaseIdentity�ServicezPHubic backend requires the pyrax library available from Rackspace.
Exception: %sz https://api.hubic.com/oauth/zhttps://api.hubic.com/1.0/z~/.hubic_tokensc @ s e Zd Zdd� Zdd� ZdS )�BearerTokenAuthc C s
|| _ d S �N)�token)�selfr � r
�I/usr/lib/python3/dist-packages/duplicity/backends/pyrax_identity/hubic.py�__init__# s
zBearerTokenAuth.__init__c C s d| j |jd< |S )NzBearer �
Authorization)r �headers)r �reqr
r
r �__call__& s zBearerTokenAuth.__call__N)�__name__�
__module__� __qualname__r r r
r
r
r r " s r c sX e Zd Z� fdd�Zdd� Z ddd�Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
� Z S )�
HubicIdentityc s t t| ��| � d S r
)�superr r �r �� __class__r
r r , s zHubicIdentity.__init__c C s dS )N� r
r r
r
r �_get_auth_endpoint/ s z HubicIdentity._get_auth_endpointFc C s8 || _ || _|| _|| _|| _|| _|r| �� dS dS )z(Sets the username and password directly.N)�_email� _password�
_client_id� tenant_id�_client_secret�
_redirect_uri� authenticate)r �email�password� client_id�
client_secret� redirect_urir$ r
r
r �set_credentials2 s �z HubicIdentity.set_credentialsc C sR |� dd�| _|� dd�| _|� dd�| _| j| _|� dd�| _|� dd�| _dS )zL
Parses the credential file with Rackspace-specific labels.
�hubicr% r& r' r( r) N)�getr r r r! r" r# )r �cfgr
r
r �_read_credential_file? s z#HubicIdentity._read_credential_filec C sD d|j vrd S tj�|j d �j}ttj�|��}|d |d d�S )N�location�error�error_description)r0 r1 )r �urllib�parse�urlsplit�query�dict� parse_qsl)r �respr5 �qsr
r
r � _parse_errorJ s
zHubicIdentity._parse_errorc C s t jtd || jdd�| j| jfd�}|jdkr3z |�� }|j|d< W n i }Y t� dt
|� ��|�� }t � � }|�
t� |�d�sJ|�d� |d d urt|�dd |d � ttd
��
}|�|� W d � n1 snw Y n t� dt
|� ��|d d ur�|�dd |d � ttd
��
}|�|� W d � n1 s�w Y nt� d ��|�dd
�r�|�dd
� ttd
��
}|�|� W d � n1 s�w Y td� |�dd��r|�dd� ttd
��
}|�|� W d � n1 s�w Y td� |S )N�token/�authorization_code)�coder) �
grant_type��data�auth�� r= �IUnable to get oauth access token, wrong client_id or client_secret ? (%s)r+ � access_token�wb�
refresh_tokenz Unable to get the refresh token.r% zEusername has been removed from the .hubic_tokens file sent to the CE.r& zEpassword has been removed from the .hubic_tokens file sent to the CE.)�requests�post�OAUTH_ENDPOINTr# r r" � status_code�json�exc�AuthenticationFailedr � configparser� ConfigParser�read� TOKENS_FILE� has_section� add_section�set�open�write�
has_option�
remove_option�print)r r= �r�err� oauth_token�config�
configfiler
r
r �_get_access_tokenQ sj �
�
�
���� ��
� �z HubicIdentity._get_access_tokenc C s0 t �� }|�t� |�dd�}|d u rt�d��d}d}d}d}d}||k r�|s�tjt d |dd
�| j
| j fd �}|j d krx|j d
kr]t
d|d� |d7 }t�|� |d }||kr\|}n z |�� } |j | d< W n i } Y t�dt| � ��d}||k r�|r(|s�t�d��|�� }
|
d d ur�|
S t�d��)Nr+ rF z-refresh_token is null. Not acquiered before ?F� r � i r; )rF r> r? rB i� zstatus_code 509: attempt #z failed� � r= rC Tz]All the attempts failed to get the refresh token: status_code = 509: Bandwidth Limit ExceededrD z*Unable to get oauth access token from json)rN rO rP rQ r, rL rM rG rH rI r r" rJ rY �time�sleeprK r ) r r] rF �success� max_retries�retries�
sleep_time�max_sleep_timerZ r[ r\ r
r
r �_refresh_access_token� s^
�
�
��� � �
z#HubicIdentity._refresh_access_tokenc C s t �� }|�t� |�dd�r| �� }n�tjtd� t
| j �t | j
�tj�� � dd�}|jdkr<t�dt| �|�� ��zdd lm} W n tyO d }Y nw |re|�|j��d
�}|rb|d j nd }nt � d |j�}|rs|� d �nd }|s|t�d
��| j d u s�| j!d u r�t�d��tj"td d|| j | j!ddd�dd�}zt#j$�%|j&d �j'}t(t#j$�)|��d }W n t�d��| �*|�}|d �+� dkr�t�d��tjt,d t-|d �d �}|�.� }d | _/|d | _0|d | _1t2| d d!d"|d# igd$��| j3d%< d | _4| _5d S )&Nr+ rF z_auth/?client_id={0}&redirect_uri={1}&scope=credentials.r,account.r&response_type=code&state={2}F)�allow_redirectsrB z%Incorrect/unauthorized client_id (%s)r )�htmlz//input[@name="oauth"]zD<input\s+[^>]*name=[\'"]?oauth[\'"]?\s+[^>]*value=[\'"]?(\d+)[\'"]?>rb z.Unable to get oauth_id from authorization pagezLCannot retrieve email and/or password. Please run expresslane-hubic-setup.shzauth/�acceptedrZ )�action�oauth�login�user_pwd�account� credentials)r@ rl r/ r= z7Unable to authorize client_id, invalid login/password ?�
token_type�bearerz Unsupported access token typezaccount/credentialsrD )rA Tr �expires�HubiC�
cloudfiles�
public_url�endpoint)�name�type� endpoints� object_store)6rN rO rP rQ rW rk rG r, rI �formatr r r r# �pyrax�utils� random_asciirJ rL rM r r: �lxmlrm � ImportError�document_fromstring�content�xpath�value�re�search�groupr r rH r2 r3 r4 r r5 r6 r7 r_ �lower� API_ENDPOINTr rK �
authenticatedr rw r �services�usernamer& ) r r] r\ rZ � lxml_htmlrp r5 r= � swift_tokenr
r
r r$ � s�
���
� ��
� �
�
��zHubicIdentity.authenticate)F) r r r r r r* r. r: r_ rk r$ �
__classcell__r
r
r r r + s
�
;9r )$�
__future__r �futurer �install_aliases�builtinsr rN �osr� rd � urllib.parser2 �requests.compatr r rG r� �pyrax.base_identityr r �pyrax.exceptions�
exceptionsrL r� �e�BackendExceptionrI r� �path�
expanduserrQ rA �AuthBaser r r
r
r
r �<module> s4 ���