File: //lib/python3.6/site-packages/cloudinit/sources/__pycache__/DataSourceExoscale.cpython-36.opt-1.pyc
3
�� b�# � @ sn d dl mZ d dl mZ d dl mZ d dl mZ d dl mZmZm Z ej
e �Z dZ
dZdZd Zd
Zd ZG d d
� d
ej�ZeejejffgZdd� Ze
eeeefdd�Ze
eeeefdd�Ze dk�rjd dlZej dd�Z e j ddde
d� e j d d d ed� e j d d e d!ed"� e j d#d e d$ed"� e j d%d&e d'ed"� e j � Z!ee!j"e!j#e!j$e!j%e!j&d(�Z'e(e j)e'�� dS ))� )�dmi)� ec2_utils)�helpers)�log)�sources�
url_helper�utilzhttp://169.254.169.254z1.0i� �
� �Exoscalec sT e Zd ZdZdZ� fdd�Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z � Z S )�DataSourceExoscaler �x c s| t t| �j|||� tjd� | jjdt�| _| jjdt �| _
t | jjdt ��| _
| jjdt�| _| jjdt�| _i | _d S )Nz$Initializing the Exoscale datasource� metadata_url� api_version�password_server_port�timeout�retries)�superr �__init__�LOG�debugZds_cfg�get� METADATA_URLr � API_VERSIONr �int�PASSWORD_SERVER_PORTr � URL_TIMEOUT� url_timeout� URL_RETRIES� url_retries� extra_config)�selfZsys_cfgZdistro�paths)� __class__� �(/usr/lib/python3.6/DataSourceExoscale.pyr s
zDataSourceExoscale.__init__c C s8 d}| j jd�}tj|�}|jd| d�r4tjd� dS )z<Adjust set-passwords module to run 'always' during each bootZ
set_passwordsZsemZconfig_Nz5Overriding module set-passwords with frequency always)r" Z
get_ipath_curr ZFileSemaphores�clearr r )r! ZcfgZis_new_instance�modZsem_pathZ
sem_helperr$ r$ r% �activate+ s
zDataSourceExoscale.activatec C s6 dj | j| j�}tj|g| j| jtjd�\}}t |�S )z.Wait for the metadata service to be reachable.z{}/{}/meta-data/instance-id)ZurlsZmax_waitr Z status_cb)
�formatr r r Z wait_for_url� url_max_waitr r Zcritical�bool)r! r ZurlZ _responser$ r$ r% �wait_for_metadata_service: s z,DataSourceExoscale.wait_for_metadata_servicec C s6 t jtjd| jd�}|s i S t| j| j| j| j | j
�S )zw
Crawl the metadata service when available.
@returns: Dictionary of crawled metadata content.
z waiting for the metadata service)�logfunc�msg�func) r �log_timer �infor, �
read_metadatar r r r r )r! Zmetadata_readyr$ r$ r% �crawl_metadataJ s
z!DataSourceExoscale.crawl_metadatac C st | j � s dS tjtjd| jd�}|s(dS |d | _|d | _|jd�}i }|r^d|ddid �}tj | j
|g�| _
dS )
z�Fetch the user data, the metadata and the VM password
from the metadata service.
Please refer to the datasource documentation for details on how the
metadata server and password server are crawled.
FzCrawl of metadata service)r- r. r/ z user-dataz meta-data�passwordTZexpire)Z
ssh_pwauthr4 Zchpasswd) �_is_platform_viabler r0 r r r3 Z userdata_rawZmetadatar Z
mergemanydictr )r! �datar4 Zpassword_configr$ r$ r% � _get_dataa s&
z DataSourceExoscale._get_datac C s | j S )N)r )r! r$ r$ r% �get_config_obj� s z!DataSourceExoscale.get_config_objc C s t jd�jt�S )Nzsystem-product-name)r Z
read_dmi_data�
startswith�EXOSCALE_DMI_NAME)r! r$ r$ r% r5 � s
z&DataSourceExoscale._is_platform_viable)
�__name__�
__module__� __qualname__Zdsnamer* r r( r, r3 r7 r8 r5 �
__classcell__r$ r$ )r# r% r s
.r c C s t j| t�S )N)r Zlist_from_depends� datasources)Zdependsr$ r$ r% �get_datasource_list� s r@ c C sZ dj | ||�}tj|dddi||d�}|jjd�}|d kr>dS tj|dddi||d� |S )
z�Obtain the VM's password if set.
Once fetched the password is marked saved. Future calls to this method may
return empty string or 'saved_password'.z {}:{}/{}/NZ DomU_RequestZsend_my_password)Z ssl_detailsZheadersr r zutf-8� �saved_password)rA rB )r) r Zread_file_or_url�contents�decode)r r r r r Z password_urlZresponser4 r$ r$ r% � get_password� s$
rE c C s� i }||d< y0t j|| ||d�|d< t j|| ||d�|d< W n0 tk
rl } ztjtd| |� i S d}~X nX yt|| |||d�|d< W n4 tk
r� } ztjtd | ||� W Y dd}~X nX |S )
z8Query the metadata server and return the retrieved data.Z_metadata_api_version)r r z user-dataz meta-dataz(failed reading from metadata url %s (%s)N)r r r r r r4 z2failed to read from password server url %s:%s (%s))�ec2Zget_instance_userdataZget_instance_metadata� Exceptionr Zlogexcr rE )r r r r r Zcrawled_metadata�er$ r$ r% r2 � s4 r2 �__main__NzQuery Exoscale Metadata)� descriptionz
--endpointZURLz The url of the metadata service.)�metavar�help�defaultz --version�VERSIONz.The version of the metadata endpoint to query.z --retriesZNUMz,The number of retries querying the endpoint.)rK �typerL rM z --timeoutz.The time in seconds to wait before timing out.z--password-portZPORTz/The port on which the password endpoint listens)r r r r r )*Z cloudinitr r rF r r Zloggingr r r Z getLoggerr; r r r r r r r: Z
DataSourcer ZDEP_FILESYSTEMZ DEP_NETWORKr? r@ rE r2 �argparse�ArgumentParser�parser� add_argumentr �
parse_args�argsZendpoint�versionZ
password_portr r r6 �printZ
json_dumpsr$ r$ r$ r% �<module> s�
" &