File: //lib/python3/dist-packages/cloudinit/sources/__pycache__/DataSourceOpenStack.cpython-310.pyc
o
�Ad�) � @ s d dl Z d dlmZ d dlmZ d dlmZmZmZ d dlm Z m
Z
d dl m Z d dl
mZ d dlmZ d d lmZ e�e�Zd
d gZd Zd
eiZdZdZeegZ dZ dZ dZ e Z e e e e g7 Z G dd� dej!ej"�Z#G dd� de#�Z$d dd�Z%e$ej&ffe#ej&ej'ffgZ(dd� Z)dS ) � N)�dmi)�log)�sources�
url_helper�util)�
EventScope� EventType)�NoDHCPLeaseError)�EphemeralDHCPv4)�DataSourceOracle)� openstackzhttp://[fe80::a9fe:a9fe]zhttp://169.254.169.254ziid-dsopenstackz instance-idzOpenStack NovazOpenStack Compute�OpenTelekomCloudz
SAP CCloud VM� HUAWEICLOUDc s� e Zd ZdZejZdZej e
j e
j e
j
e
jhiZ� fdd�Zdd� Zdd� Zd d
� Zed d � �Zd
d� Zdd� Zdd� Z� ZS )�DataSourceOpenStack� OpenStackFc sH t t| ��|||� d | _t�| j�| _d | _i | _ t
j | _ t
j | _
d S �N)�superr �__init__�metadata_addressr �fetch_ssl_details�paths� ssl_details�version�filesr �UNSET� ec2_metadata� network_json)�self�sys_cfg�distror �� __class__� �G/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceOpenStack.pyr > s z DataSourceOpenStack.__init__c C s" t j�| �}d|| j| jf }|S )Nz%s [%s,ver=%s])r �
DataSource�__str__�dsmoder )r �root�mstrr" r" r# r% G s zDataSourceOpenStack.__str__c C s | j �dt�}dd� |D �}t|�t|�kr$t�dtt|�t|� �� t|�r+|}nt�d� t}g }i }|D ]}t �
|d�}|� |� |||< q8| � � }t
�
� }t j||j|jdd�\} }
| rjt�d || � n
t�d
|tt
�
� | �� |�| �| _t| �S ) N�
metadata_urlsc S s g | ] }t �|�r|�qS r" )r �is_resolvable_url)�.0�xr" r" r# �
<listcomp>N s zADataSourceOpenStack.wait_for_metadata_service.<locals>.<listcomp>z,Removed the following from metadata urls: %sz+Empty metadata url list! using default listr F)�urls�max_wait�timeout�connect_synchronouslyzUsing metadata source: '%s'z2Giving up on OpenStack md from %s after %s seconds)�ds_cfg�get� DEF_MD_URLS�set�LOG�debug�list�len�warningr � combine_url�append�get_url_params�time� wait_for_url�max_wait_seconds�timeout_seconds�intr �bool) r r. �filtered�md_urls�url2base�url�md_url�
url_params�
start_time� avail_url� _responser" r" r# �wait_for_metadata_serviceL sD �
�� z-DataSourceOpenStack.wait_for_metadata_servicec C s t �| �� �S r )r � instance_id_matches_system_uuid�get_instance_id)r r r" r" r# �check_instance_idu s z%DataSourceOpenStack.check_instance_idc C sn | j tjkr | j S t�| j�dd��rd| _ | j S | jtjkr&t� d� dS t�
d� t j | jdd�| _ | j S )z@Return a network config dict for rendering ENI or netplan files.�apply_network_configTNz<Unexpected call to network_config when network_json is None.z(network config provided via network_json)�
known_macs)
�_network_configr r r �is_falser2 r3 r r6 r: r7 r �convert_net_json)r r" r" r# �network_configy s �
�z"DataSourceOpenStack.network_configc
C s | j rHz&t| j| j�� d�� tjtjd| j d�}W d � n1 s#w Y W nA t
t j fyG } zt�
tt|�� W Y d}~dS d}~ww z| � � }W n t j yj } zt�
tt|�� W Y d}~dS d}~ww | �|�d�g�| _| jt jkr}dS |�di �}t�|tg�}|| _|�d�| _|�d �| _|�d
�| _|d | _| j�|�d i �� |�d
�}|| _ zt � |�| _ W n t y� } zt� d|� d| _ W Y d}~nd}~ww |�d�}|| _!z t � |�| _"W dS t �y } zt� d|� d| _"W Y d}~dS d}~ww )a
Crawl metadata, parse and persist that data for this instance.
@return: True when metadata discovered indicates OpenStack datasource.
False when unable to contact metadata service or when metadata
format is invalid or disabled.
)�tmp_dirzCrawl of metadata service)�logfunc�msg�funcNFr& �metadataz ec2-metadata� networkdata�userdatar r �
vendordataz"Invalid content in vendor-data: %s� vendordata2z#Invalid content in vendor-data2: %sT)#�perform_dhcp_setupr
�fallback_interfacer �get_tmp_exec_pathr �log_timer6 r7 �_crawl_metadatar r �InvalidMetaDataException�logexc�str�_determine_dsmoder3 r& �DSMODE_DISABLED�
mergemanydict�DEFAULT_METADATAr[ r r � userdata_rawr r �update�vendordata_pure�convert_vendordata�vendordata_raw�
ValueErrorr: �vendordata2_pure�vendordata2_raw)r �results�e�md�vd�vd2r" r" r# � _get_data� sp �� ��
�� ��
��
� ��z DataSourceOpenStack._get_datac
C s� z | � � s
t�d��W n ty" } z t�djt|�d���d}~ww | �� }ztjt j
dt | j g| j
|j|jd�d�}W |S tjyR } zt�t|���d}~w tjtfym } z
dj| j d �}t�|�|�d}~ww )
z�Crawl metadata service when available.
@returns: Dictionary with all metadata discovered for this datasource.
@raise: InvalidMetaDataException on unreadable or broken
metadata.
z No active metadata service foundz,IOError contacting metadata service: {error})�errorNz#Crawl of openstack metadata service)r �retriesr0 )�args�kwargsz Broken metadata address {addr})�addr)rM r re �IOError�formatrg r= r rc r6 r7 �read_metadata_servicer r � num_retriesrA r � NonReadable�BrokenMetadata)r ru rI �resultrY r" r" r# rd � sJ ����������� ��z#DataSourceOpenStack._crawl_metadatac C sp d| j �d�v }t�� sdS t�d�}|tv rdS t�d�tv r"dS |r*t� � r*dS t�
d��d�t kr6dS dS ) z<Return True when a potential OpenStack platform is detected.�Oracle�datasource_listTzsystem-product-namezchassis-asset-tag� � product_nameF) r r3 r �is_x86r �
read_dmi_data�VALID_DMI_PRODUCT_NAMES�VALID_DMI_ASSET_TAGS�oracle�_is_platform_viable� get_proc_env�DMI_PRODUCT_NOVA)r �
accept_oracler� r" r" r# � ds_detect� s
z DataSourceOpenStack.ds_detect)�__name__�
__module__� __qualname__�dsnamer r rS r` r �NETWORKr �BOOT_NEW_INSTANCE�BOOT� BOOT_LEGACY�HOTPLUG�supported_update_eventsr r% rM rP �propertyrV ry rd r� �
__classcell__r" r" r r# r , s( �� )
<*r c @ s e Zd ZdZdZdS )�DataSourceOpenStackLocalau Run in init-local using a dhcp discovery prior to metadata crawl.
In init-local, no network is available. This subclass sets up minimal
networking with dhclient on a viable nic so that it can talk to the
metadata service. If the metadata service provides network configuration
then render the network configuration for that instance based on metadata.
TN)r� r� r� �__doc__r` r" r" r" r# r� s r� � c C s t j| |||d�}|�� S )N)r r0 r{ )r �MetadataReader�read_v2)�base_urlr r0 r{ �readerr" r" r# r� s �r� c C s t �| t�S r )r �list_from_depends� datasources)�dependsr" r" r# �get_datasource_list& s r� )Nr� r� )*r> � cloudinitr r �loggingr r r �cloudinit.eventr r �cloudinit.net.dhcpr �cloudinit.net.ephemeralr
�cloudinit.sourcesr r� �cloudinit.sources.helpersr � getLoggerr� r6 r4 � DEFAULT_IIDrk r� �DMI_PRODUCT_COMPUTEr� �DMI_ASSET_TAG_OPENTELEKOM�DMI_ASSET_TAG_SAPCCLOUD�DMI_ASSET_TAG_HUAWEICLOUDr� � SourceMixinr$ r r� r� �DEP_FILESYSTEM� DEP_NETWORKr� r� r" r" r" r# �<module> sD
�� `
�