| Server IP : 23.254.227.96 / Your IP : 216.73.216.7 Web Server : Apache/2.4.62 (Unix) OpenSSL/1.1.1k System : Linux hwsrv-1277026.hostwindsdns.com 4.18.0-477.13.1.el8_8.x86_64 #1 SMP Tue May 30 14:53:41 EDT 2023 x86_64 User : viralblo ( 1001) PHP Version : 8.1.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3.6/site-packages/cloudinit/sources/__pycache__/ |
Upload File : |
3
�� b
& � @ s d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
d dl m Z d dl m
Z
mZmZmZ d dlmZmZ d dlmZmZ e je�Zd Zed
ed ed d
�ZdZ dZ dd� Z G dd� dej j �Z!dd� Z"dd� Z#G dd� dej$�Z%e%ej&ffgZ'dd� Z(dS ) � N)�HTTPConnection)� PoolManager)�dmi)�log)�net�sources�
url_helper�util)�
EventScope� EventType)�EphemeralDHCPv4�NoDHCPLeaseErrorzhttp://169.254.42.42z/conf?format=jsonz/user_data/cloud-initz/vendor_data/cloud-init)� metadata_url� userdata_url�vendordata_url� �
c C s> t jd�} | dkrdS tjjd�r&dS tj� }d|kr:dS dS )a
There are three ways to detect if you are on Scaleway:
* check DMI data: not yet implemented by Scaleway, but the check is made to
be future-proof.
* the initrd created the file /var/run/scaleway.
* "scaleway" is in the kernel cmdline.
zsystem-manufacturer�ScalewayTz/var/run/scalewayZscalewayF)r Z
read_dmi_data�os�path�existsr Z get_cmdline)Z vendor_nameZcmdline� r �(/usr/lib/python3.6/DataSourceScaleway.py� on_scaleway0 s
r c s* e Zd ZdZ� fdd�Zddd�Z� ZS )�SourceAddressAdapterzF
Adapter for requests to choose the local address to bind to.
c s || _ tt| �jf |� d S )N)�source_address�superr �__init__)�selfr �kwargs)� __class__r r r L s z SourceAddressAdapter.__init__Fc C s0 t jtjtjdfg }t|||| j|d�| _d S )N� )Z num_pools�maxsize�blockr �socket_options)r Zdefault_socket_options�socketZ
SOL_SOCKETZ SO_REUSEPORTr r Z poolmanager)r Z connectionsr" r# r$ r r r �init_poolmanagerP s z%SourceAddressAdapter.init_poolmanager)F)�__name__�
__module__� __qualname__�__doc__r r& �
__classcell__r r )r r r G s r c C s` y&t j| d|d|dd� d�}tj|j�S t jk
rZ } z|jdkrHdS � W Y dd}~X nX dS )aQ
Retrieve user data or vendor data.
Scaleway user/vendor data API returns HTTP/404 if user/vendor data is not
set.
This function calls `url_helper.readurl` but instead of considering
HTTP/404 as an error that requires a retry, it considers it as empty
user/vendor data.
Also, be aware the user data/vendor API requires the source port to be
below 1024 to ensure the client is root (since non-root users can't bind
ports below 1024). If requests raises ConnectionError (EADDRINUSE), the
caller should retry to call this function on an other port.
Nr c S s |j dkot|jtjj� S )Ni� )�code�
isinstance�cause�requests�
exceptions�ConnectionError)�_�excr r r �<lambda>x s
z%query_data_api_once.<locals>.<lambda>)�data�timeout�retriesZsessionZ exception_cbi� )r �readurlr �
decode_binary�contents�UrlErrorr, )� api_addressr6 �requests_session�respr3 r r r �query_data_api_once] s
r? c C s� x�t dt|d��D ]�}yJtjd| |� tj� }|jdtd|fd�� t|||d�}tjd| � |S t j
k
r� } z$tj d | |� t j
d
� |}wW Y d d }~X qX qW |�d S ) a/ Get user or vendor data.
Handle the retrying logic in case the source port is used.
Scaleway metadata service requires the source port of the client to
be a privileged port (<1024). This is done to ensure that only a
privileged user on the system can access the metadata service.
r! � z*Trying to get %s data (bind on port %d)...zhttp://z0.0.0.0)r )r6 r= z%s-data downloadedz%Error while trying to get %s data: %sr N)�range�max�LOG�debugr/ ZSessionZmountr r? r r; �warning�timeZsleep) Zapi_typer< r7 r6 Zportr= r5 r3 �last_excr r r �query_data_api� s$
rH c s� e Zd ZdZejejejej hiZ
� fdd�Z dd� Z dd� Z
edd � �Zed
d � �Zd d
� Zdd� Zddd�Zedd� �Zedd� �Z� ZS )�DataSourceScalewayr c s� t t| �j|||� tjtj|ddgi �tg�| _| jd | _| jd | _ | jd | _
t | jj dt
��| _t | jj dt��| _d | _tj| _d S )NZ
datasourcer r r r r7 r6 )r rI r r Z
mergemanydictZget_cfg_by_path�BUILTIN_DS_CONFIGZds_cfg�metadata_address�userdata_address�vendordata_address�int�get�DEF_MD_RETRIESr7 �DEF_MD_TIMEOUTr6 �_fallback_interfacer �UNSET�_network_config)r Zsys_cfgZdistro�paths)r r r r � s
zDataSourceScaleway.__init__c C sZ t j| j| j| jd�}tjtj|j ��| _
t d| j | j| j�| _
t d| j| j| j�| _d S )N)r6 r7 z user-dataz vendor-data)r r8 rK r6 r7 �json�loadsr r9 r: �metadatarH rL Z userdata_rawrM Zvendordata_raw)r r> r r r �_crawl_metadata� s z"DataSourceScaleway._crawl_metadatac C s� t � s
dS | jd kr tj� | _y.t| j�� tjtjd| j d� W d Q R X W n0 t
k
r| } ztj tt |�� dS d }~X nX dS )NFzCrawl of metadata service)Zlogfunc�msg�funcT)
r rR r �find_fallback_nicr r Zlog_timerC rD rY r
Zlogexc�str)r �er r r � _get_data� s
z DataSourceScaleway._get_datac C s� | j dkr tjdtj� tj| _ | j tjkr2| j S | jdkrFtj� | _dd| j d�}ddig}| jd r�|d d| jd d
d| jd d d| jd d d
�g7 }||d< d|gd�| _ | j S )z`
Configure networking according to data received from the
metadata API.
Nz5Found None as cached _network_config. Resetting to %sZphysicalz%s)�type�namer` Zdhcp4Zipv6Zstatic�address�gateway�netmask)r` rb rc rd �subnetsr! )�version�config) rT rC rE r rS rR r r\ rX )r Znetcfgre r r r �network_config� s(
z!DataSourceScaleway.network_configc C s d S )Nr )r r r r � launch_index s z DataSourceScaleway.launch_indexc C s
| j d S )N�id)rX )r r r r �get_instance_id
s z"DataSourceScaleway.get_instance_idc C sb dd� | j d D �}d}t|�}x<| j jdg �D ]*}|j|�s@q0|j|d |� jdd�� q0W |S )Nc S s g | ] }|d �qS )�keyr )�.0rl r r r �
<listcomp> s z:DataSourceScaleway.get_public_ssh_keys.<locals>.<listcomp>Zssh_public_keyszAUTHORIZED_KEY=Ztagsr2 � )rX �lenrO �
startswith�append�replace)r Zssh_keysZakeypreZplen�tagr r r �get_public_ssh_keys s
z&DataSourceScaleway.get_public_ssh_keysFc C s
| j d S )NZhostname)rX )r ZfqdnZ
resolve_ipZ
metadata_onlyr r r � get_hostname s z DataSourceScaleway.get_hostnamec C s d S )Nr )r r r r �availability_zone s z$DataSourceScaleway.availability_zonec C s d S )Nr )r r r r �region# s zDataSourceScaleway.region)FFF)r' r( r) Zdsnamer
ZNETWORKr ZBOOT_NEW_INSTANCEZBOOTZ BOOT_LEGACYZdefault_update_eventsr rY r_ �propertyrh ri rk ru rv rw rx r+ r r )r r rI � s
"
rI c C s t j| t�S )N)r Zlist_from_depends� datasources)Zdependsr r r �get_datasource_list- s r{ ))rV r r% rF r/ Z$requests.packages.urllib3.connectionr Z%requests.packages.urllib3.poolmanagerr Z cloudinitr r Zloggingr r r r Zcloudinit.eventr
r Zcloudinit.net.dhcpr r
Z getLoggerr' rC Z DS_BASE_URLrJ rP rQ r ZadaptersZ HTTPAdapterr r? rH Z
DataSourcerI ZDEP_FILESYSTEMrz r{ r r r r �<module> s2
(&~