403Webshell
Server IP : 167.99.254.82  /  Your IP : 216.73.216.188
Web Server : Apache
System : Linux host.techisquad.com 5.15.0-190-generic #200-Ubuntu SMP Fri Aug 7 15:06:04 UTC 2026 x86_64
User : pawluxera ( 1011)
PHP Version : 8.1.34
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : ON  |  Pkexec : ON
Directory :  /lib/python3/dist-packages/cloudinit/sources/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /lib/python3/dist-packages/cloudinit/sources/__pycache__/__init__.cpython-310.pyc
o

��i��@s�ddlZddlZddlZddlZddlZddlZddlZddlmZm	Z	ddl
mZmZm
Z
mZmZmZmZmZddlmZmZmZmZmZmZmZmZmZddlmZddlm Z ddl!m"Z"m#Z#ddl$m%Z%dd	l&m'Z'dd
l(m)Z)ddl*m+Z+dZ,d
Z-dZ.dZ/e,e-e.gZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8e�9e:�Z;ddd�fddd�fddd�fd�Z<e	Gd d!�d!e��Z=Gd"d#�d#e�Z>Gd$d%�d%e?�Z@Gd&d'�d'e?�ZAGd(d)�d)e?�ZBdWd,d-�ZCe5fd.d/�ZDGd0d1�d1e�ZEGd2d3�d3e�ZFGd4d5�d5e�ZGGd6d�de)ejHd7�ZId8d9�ZJd:eeIeKffd;d<�ZLd=d>�ZM	?dXd@eKd:eNfdAdB�ZOdCdD�ZPdYdFdG�ZQGdHdI�dIeR�ZSdJdK�ZTdLeIdMeKd:eNfdNdO�ZUdMeKd:eeIfdPdQ�ZVd:eKfdRdS�ZWdTeKd:eKfdUdV�ZXdS)Z�N)�Enum�unique)�Any�Dict�List�
NamedTuple�Optional�Tuple�Union�cast)	�
atomic_helper�dmi�importer�	lifecycle�net�performance�
type_utils�	user_data�util)�
write_json)�Distro)�
EventScope�	EventType)�launch_index)�Paths)�CloudInitPickleMixin)�events�disabled�localr�pass�
FILESYSTEM�NETWORK�
DataSourcez|EXPERIMENTAL: The structure and format of content scoped under the 'ds' key may change in subsequent releases of cloud-init.zredacted for non-root user�
cloud-name�_unset�unknownz	aws-chinacC�|dkS�N�aws���cr)r)�</usr/lib/python3/dist-packages/cloudinit/sources/__init__.py�<lambda>F�r-zaws-govcCr&r'r)r*r)r)r,r-Gr.zazure-chinacCr&)N�azurer)r*r)r)r,r-Hr.)zcn-zus-gov-�chinac@s2eZdZdZdZdZdZdZdZde	fdd	�Z
d
S)�NetworkConfigSourcezb
    Represents the canonical list of network config sources that cloud-init
    knows about.
    �cmdline�ds�
system_cfg�fallback�	initramfs�returncC�|jS�N��value��selfr)r)r,�__str__Y�zNetworkConfigSource.__str__N)�__name__�
__module__�__qualname__�__doc__�CMD_LINE�DS�
SYSTEM_CFG�FALLBACK�	INITRAMFS�strr>r)r)r)r,r1Lsr1c@s&eZdZdZdZdZdefdd�ZdS)�NicOrderzRepresents ways to sort NICs�mac�nic_namer7cCr8r9r:r<r)r)r,r>cr?zNicOrder.__str__N)r@rArBrC�MAC�NIC_NAMErIr>r)r)r)r,rJ]s
rJc@�eZdZdZdS)�DatasourceUnpickleUserDataErrorzERaised when userdata is unable to be unpickled due to python upgradesN�r@rArBrCr)r)r)r,rPg�rPc@�eZdZdS)�DataSourceNotFoundExceptionN�r@rArBr)r)r)r,rTk�rTc@rO)�InvalidMetaDataExceptionz8Raised when metadata is broken, unavailable or disabled.NrQr)r)r)r,rWorRrW�r)c
Cs�t�|�}g}g}|��D]V\}}|r|d|}n|}|��|vs(|��|vr-|�|�t|t�rD|�d�rD|�|�|�dd�||<t|t	�rct
|||�}	|�|	�d��|�|	�d��|	||<q
t
|�|d<t
|�|d<|S)z�Process all instance metadata cleaning it up for persisting as json.

    Strip ci-b64 prefix and catalog any 'base64_encoded_keys' as a list

    @return Dict copy of processed metadata.
    �/zci-b64:rX�base64_encoded_keys�sensitive_keys)�copy�deepcopy�items�lower�append�
isinstancerI�
startswith�replace�dict�process_instance_metadata�extend�pop�sorted)
�metadata�key_pathr[�md_copyrZ�	sens_keys�key�val�sub_key_path�
return_valr)r)r,ress0



��recCs�|�dg�s|St�|�}|�d�D]+}|�d�}|}|D]}||vr4t||t�r4||dkr4||}q||vr=|||<q|S)z�Redact any sensitive keys from to provided metadata dictionary.

    Replace any keys values listed in 'sensitive_keys' with redact_value.
    r[rY���)�getr\r]�splitrard)ri�redact_valuerkrj�
path_parts�obj�pathr)r)r,�redact_sensitive_keys�s"

���rxc@s.eZdZUeed<eed<eed<eed<dS)�	URLParams�max_wait_seconds�timeout_seconds�num_retries�sec_between_retriesN)r@rArB�int�__annotations__r)r)r)r,ry�s

ryc@s"eZdZUeeed<eed<dS)�DataSourceHostname�hostname�
is_defaultN)r@rArBrrIr�boolr)r)r)r,r��s
r�c@s*eZdZUdZeed<eed<eed<dS)�HotplugRetrySettingsz
in seconds�force_retry�sleep_period�sleep_totalN)r@rArBrCr�rr~r)r)r)r,r��s

r�c	@seZdZUeZdZdZdZee	e
d<dZdZdZ
eeee	fe
d<ejejejejfZeedfe
d<dZd	Zd
ZdZejejejej ej!hiZ"ejejhiZ#de$fd
e$fdifddddddf	Z%eee	e&fdfe
d<dZ'dZ(ee	dfe
d<dZ)e*ddd�Z+dZ,ee	e
d<dZ-dde.de/fdd�Z0de1d dfd!d"�Z2d#d$�Z3d e4fd%d&�Z5d e4fd'd(�Z6d)d*�Z7d+d,�Z8d�d.d/�Z9e:j;d0d1d2�d e4fd3d4��Z<d�d6d7�Z=d e4fd8d9�Z>d:d;�Z?d�d<d=�Z@d>d?�ZAd@dA�ZBeCdBdC��ZDeCdDdE��ZEdFdG�ZFeCdHdI��ZGdJdK�ZHeCdLdM��ZIdNdO�ZJdPdQ�ZKdRdS�ZLdTdU�ZMdVdW�ZNdXdY�ZOdZd[�ZPd\d]�ZQd^d_�ZRd`da�ZSeCdbdc��ZTeCddde��ZUdfdg�ZVd�dhdi�ZWdjdk�ZXdleYefdmdn�ZZdleYed e4fdodp�Z[dqdr�Z\dsdt�Z]e^d�dudv��Z_eCdwdx��Z`dydz�Zad{d|�Zbd}d~�ZcdS)�r"zen_US.UTF-8�_undefN�_cloud_name�_crawled_metadata.�network_config_sourcesrq�
���ec2_metadata�network_jsonri)�userdataN)�userdata_rawN)�
vendordataN)�vendordata_rawN)�vendordata2N)�vendordata2_rawN�cached_attr_defaultsF)
�combined_cloud_config�
merged_cfg�merged_system_cfgzsecurity-credentialsr��	user-datarr��vendor-datazds/vendor_data�sensitive_metadata_keysr�extra_hotplug_udev_rules�distro�pathscCs�||_||_||_d|_i|_d|_d|_d|_d|_d|_	d|_
t|_t|_
t�|jd|jfi�|_|js9i|_|sDt�|j�|_dS||_dS)N�
datasource)�sys_cfgr�r�r�rir�r�r�r�r��metadata_address�UNSETr�r�r�get_cfg_by_path�dsname�ds_cfgr�UserDataProcessor�ud_proc)r=r�r�r�r�r)r)r,�__init__Os*�
zDataSource.__init__�ci_pkl_versionr7cCs�dddtddtdddtddd�d�}|��D]\}}t||�s%t|||�qt|d�s3t|ddd��t|d�r\|jdur^zt|j�WdSty[}z
t�	d	|�t
�|�d}~wwdSdS)
z(Perform deserialization fixes for Paths.NFr)r��_platform_type�_subplatformr�r�r�r��skip_hotplug_detectr�r��hotplug_retry_settings�check_if_fallback_is_allowedcS�dS�NFr)r)r)r)r,r-}�z&DataSource._unpickle.<locals>.<lambda>r�z:Unable to unpickle datasource: %s. Ignoring current cache.)r�r�r^�hasattr�setattrr�rI�AttributeError�LOG�debugrP)r=r��expected_attrsrmr;�er)r)r,�	_unpickleis<
�
�
����zDataSource._unpicklecCs
t�|�Sr9�r�obj_namer<r)r)r,r>�s
zDataSource.__str__cCr�)z#Check if running on this datasourceTr)r<r)r)r,�	ds_detect��zDataSource.ds_detectcCsN|j��t���krt�d|�dS|j�dg�|jgkr%t�d|�dSdS)aJOverride if either:
        - only a single datasource defined (nothing to fall back to)
        - command line argument is used (ci.ds=OpenStack)

        Note: get_cmdline() is required for the general case - when ds-identify
        does not run, _something_ needs to detect the kernel command line
        definition.
        z6Kernel command line set to use a single datasource %s.T�datasource_listz2Datasource list set to use a single datasource %s.F)r�r_�
parse_cmdliner�r�r�rrr<r)r)r,�override_ds_detect�s	��zDataSource.override_ds_detectcCs<|��r|��S|��rt�d|�|��St�d|�dS)z&Overrides runtime datasource detectionzDetected %szDid not detect %sF)r��	_get_datar�r�r�r<r)r)r,�_check_and_get_data�s�zDataSource._check_and_get_datacCs�|��j}|��}|j}|d}diddg�d|�d|�dt|j|j|j��d|j�d	|j�d
|dd�d
|dd�d|dd�d|j�d|���d|d�d|�d|�d|dd�d|�d|�|dd|j|j	|d|dd��iS)z2Return a dictionary of standardized metadata keys.�sys_info�v1�
_beta_keys�subplatform�availability-zone�availability_zone�cloud_idr#�
cloud_namer��distr�distro_versionr��distro_release��platform�public_ssh_keys�python_version�python�instance-id�instance_id�kernel_release�uname�local-hostname�local_hostname��variant)�machine�regionr��system_platformr�)
�get_hostnamer��get_instance_idr��canonical_cloud_idr�r��
platform_type�get_public_ssh_keysr�)r=�
instance_datar�r�r��sysinfor)r)r,�_get_standardized_metadata�s`
�������	�
���
�������
��z%DataSource._get_standardized_metadatar)cCsP|jsdS|r
|}n|j}|D]\}}t||�rt|||�q|s&d|_dSdS)z�Reset any cached metadata attributes to datasource defaults.

        @param attr_defaults: Optional tuple of (attr, value) pairs to
           set instead of cached_attr_defaults.
        NF)�_dirty_cacher�r�r�)r=�
attr_defaults�attr_values�	attributer;r)r)r,�clear_cached_attrs�s
�
�zDataSource.clear_cached_attrszGetting metadata�always)�log_modecCs"d|_|��}|s|S|��|S)z�Datasources implement _get_data to setup metadata and userdata_raw.

        Minimally, the datasource should return a boolean True on success.
        T)r�r��persist_instance_data)r=�return_valuer)r)r,�get_data�szDataSource.get_dataTc

Cs^|rtj�|jj�rt||j�d��|jdur2tt	t
�|j��}|�dd�|�dd�d|i}ndd|j
ii}|jtkrE|j|dd<|jtkrQ|j|dd<t|dd	<t
�|j�|d
<d|d
d	<t
�|d
�|d<d
|dd	<t��|d<|�|�|��zt�|�}tt�|�|jd�}Wn5ty�}zt�dt |��WYd}~dSd}~wt!y�}zt�dt |��WYd}~dSd}~ww|j�"d�}|d�#dd�}tj�$|jj%d�}	t�&|	�d|��|�d��d}
|	�d|��}tj�'|	��rtj�(|	�}
tj)||	dd�|
�r|
|k�rt�*|
�t+||dd�|j�"d�}t+|t,|��dS)aPProcess and write INSTANCE_JSON_FILE with all instance metadata.

        Replace any hyphens with underscores in key names for use in template
        processing.

        :param write_cache: boolean set True to persist obj.pkl when
            instance_link exists.

        @return True on successful write, False otherwise.
        �obj_pklNr�r�r3�	meta_datar�r��_docr�z<DEPRECATED: Use merged_system_cfg. Will be dropped from 24.1r�zUMerged cloud-init system config from /etc/cloud/cloud.cfg and /etc/cloud/cloud.cfg.d/r�)r[z'Error persisting instance-data.json: %sF�instance_data_sensitiver�r��nonezcloud-id�-�
T)�forcei�)�moder�)-�osrw�lexistsr��
instance_link�	pkl_store�
get_ipath_curr�rrdr\r]rgrir�r�r��EXPERIMENTAL_TEXTr�r�system_info�updater�r�
json_dumpsre�json�loadsr��	TypeErrorr��warningrI�UnicodeDecodeError�get_runpathrr�join�run_dir�
write_file�exists�realpath�sym_link�del_filerrx)
r=�write_cache�crawled_metadatar��content�processed_datar��json_sensitive_filer��
cloud_id_file�prev_cloud_id_file�new_cloud_id_file�	json_filer)r)r,r�sr
�


���
�

����
z DataSource.persist_instance_datacCstd��)z@Walk metadata sources, process crawled data and save attributes.zlSubclasses of DataSource must implement _get_data which sets self.metadata, vendordata_raw and userdata_raw.)�NotImplementedErrorr<r)r)r,r�[s�zDataSource._get_datac
CsB|j}zt|j�d|j��}Wnty$t�td|j�d�|�Ynw|j}zt	dt|j�d|j���}WntyO|j}t�td|j�d�|�Ynw|j
}zt|j�d|j
��}Wntytt�td|j�d�|�Ynw|j}zt|j�d|j��}Wnty�t�td	|j�d�|�Ynwt
||||�S)
z�Return the Datasource's preferred url_read parameters.

        Subclasses may override url_max_wait, url_timeout, url_retries.

        @return: A URLParams object with max_wait_seconds, timeout_seconds,
            num_retries.
        �max_waitz6Config max_wait '%s' is not an int, using default '%s'r�timeoutz5Config timeout '%s' is not an int, using default '%s'�retriesz5Config retries '%s' is not an int, using default '%s'r}zAConfig sec_between_retries '%s' is not an int, using default '%s')�url_max_waitr~r�rr�
ValueErrorr�logexcr��url_timeout�max�url_retries�	Exception�url_sec_between_retriesry)r=rrrr}r)r)r,�get_url_paramsbsd
��
��	
����
��	zDataSource.get_url_paramscCs2|jdur|j�|���|_|r|�|j�S|jSr9)r�r��process�get_userdata_raw�
_filter_xdata)r=�apply_filterr)r)r,�get_userdata�s

zDataSource.get_userdatacC�"|jdur|j�|���|_|jSr9)r�r�r'�get_vendordata_rawr<r)r)r,�get_vendordata��
zDataSource.get_vendordatacCr,r9)r�r�r'�get_vendordata2_rawr<r)r)r,�get_vendordata2�r/zDataSource.get_vendordata2cCs|js	|j��|_|jSr9)r�r�r_r<r)r)r,r��szDataSource.platform_typecCs|js|��|_|jS)a�Return a string representing subplatform details for the datasource.

        This should be guidance for where the metadata is sourced.
        Examples of this on different clouds:
            ec2:       metadata (http://169.254.169.254)
            openstack: configdrive (/dev/path)
            openstack: metadata (http://169.254.169.254)
            nocloud:   seed-dir (/seed/dir/path)
            lxd:   nocloud (/seed/dir/path)
        )r��_get_subplatformr<r)r)r,r��s
zDataSource.subplatformcCs|jr
d|j�d�StS)z?Subclasses should implement to return a "slug (detail)" string.z
metadata (�))r��METADATA_UNKNOWNr<r)r)r,r2�szDataSource._get_subplatformcCs~|jr|jS|jr5|j�t�r5|j�t�}t|t�r"|��|_|jS|����|_t�	dtt
|��|jS|����|_|jS)z�Return lowercase cloud name as determined by the datasource.

        Datasource can determine or define its own cloud product name in
        metadata.
        z5Ignoring metadata provided key %s: non-string type %s)r�rirr�METADATA_CLOUD_NAME_KEYrarIr_�_get_cloud_namer�r��type)r=r�r)r)r,r��s 


���zDataSource.cloud_namecCr8)z�Return the datasource name as it frequently matches cloud name.

        Should be overridden in subclasses which can run on multiple
        cloud names, such as DatasourceEc2.
        )r�r<r)r)r,r6�szDataSource._get_cloud_namecCs"|jsdSd|jvr|jdSdS)Nzlaunch-index)rir<r)r)r,r�s


zDataSource.launch_indexcCs0t�t�|j��g}|}|D]}|�|�}q|Sr9)r�Filterr�safe_int�apply)r=�processed_ud�filters�new_ud�fr)r)r,r)�s�zDataSource._filter_xdatacCr8r9)r�r<r)r)r,r(�r?zDataSource.get_userdata_rawcCr8r9)r�r<r)r)r,r-�r?zDataSource.get_vendordata_rawcCr8r9)r�r<r)r)r,r0r?zDataSource.get_vendordata2_rawcCsiSr9r)r<r)r)r,�get_config_objszDataSource.get_config_objcCst|j�d��S)Nzpublic-keys)�normalize_pubkey_datarirrr<r)r)r,r�szDataSource.get_public_ssh_keyscCr�)a5Publish the public SSH host keys (found in /etc/ssh/*.pub).

        @param hostkeys: List of host key tuples (key_type, key_value),
            where key_type is the first field in the public key file
            (e.g. 'ssh-rsa') and key_value is the key itself
            (e.g. 'AAAAB3NzaC1y...').
        Nr))r=�hostkeysr)r)r,�publish_host_keysr�zDataSource.publish_host_keyscCsdddi}|��D]'\}}|�|�sq|D]}d||t|�d�f}tj�|�r.|SqqdS)N�sd)�vd�xvd�vtbz	/dev/%s%s)r^rb�lenr�rwr
)r=�
short_name�mappings�nfrom�tlist�nto�candr)r)r,�
_remap_devices
��zDataSource._remap_devicecC�dSr9r))r=�_namer)r)r,�device_name_to_device'�z DataSource.device_name_to_devicecCs,|j}z|j��}W|StyY|Sw)z<Default locale is en_US.UTF-8, but allow distros to override)�default_localer��
get_localer)r=�localer)r)r,rT/s��zDataSource.get_localecCs2|j�d|j�d��}|r|S|j�di��d�S)Nr�r��	placement�rirr)r=�top_level_azr)r)r,r�8s�zDataSource.availability_zonecCs|j�d�S)Nr�rWr<r)r)r,r�AszDataSource.regioncCs"|jrd|jvr
dSt|jd�S)Nr�ziid-datasource)rirIr<r)r)r,r�EszDataSource.get_instance_idcCsXd}d}|}d}|jr|j�d�sW|rtd|�Sg}t��}	|	dkr$d}t�|	�}
|
r:|
�d�dkr:t|
��d�}nI|	rK|	�d�dkrKt|	��d�}n8|	rR|	|g}n1||g}n,|jd}t	�
|�r~g}|rjt�|�}|rtt|��d�}nd	|�dd
�g}n|�d�}t
|�dkr�|d}	d�|dd��}n|d}	|r�||kr�d|	|f}	t|	|�S)
a�Get hostname or fqdn from the datasource. Look it up if desired.

        @param fqdn: Boolean, set True to return hostname with domain.
        @param resolve_ip: Boolean, set True to attempt to resolve an ipv4
            address provided in local-hostname meta-data.
        @param metadata_only: Boolean, set True to avoid looking up hostname
            if meta-data doesn't have local-hostname present.

        @return: a DataSourceHostname NamedTuple
            <hostname or qualified hostname>, <is_default> (str, bool).
            is_default is a bool and
            it's true only if hostname is localhost and was
            returned by util.get_hostname() as a default.
            This is used to differentiate with a user-defined
            localhost hostname.
            Optionally return (None, False) when
            metadata_only is True and local-hostname data is not available.
        �localdomain�	localhostFr�NT�.rzip-%sr�r�z%s.%s)rirrr�rr��get_fqdn_from_hosts�findrIrsr�is_ipv4_address�
gethostbyaddrrcrGr
)r=�fqdn�
resolve_ip�
metadata_only�	defdomain�defhost�domainr��toksr��
hosts_fqdn�lhostr)r)r,r�KsF








zDataSource.get_hostnamecCs|jj|d�S)N)�data_source)r��get_package_mirror_infor<r)r)r,rj�sz"DataSource.get_package_mirror_info�source_event_typescCsPi}|D]!}|j��D]\}}||vr$|�|�st�||<||�|�qq|Sr9)�supported_update_eventsr^rr�set�add)r=rk�supported_events�event�update_scope�
update_eventsr)r)r,�get_supported_events�s�

��zDataSource.get_supported_eventsc	Cs�|�|�}|��D]\}}t�d|jd�dd�|D���|�d|tff�q	|r6|��|��}|r6dSt�d|d�dd�|D���d	S)
a�Refresh cached metadata if the datasource supports this event.

        The datasource has a list of supported_update_events which
        trigger refreshing all cached metadata as well as refreshing the
        network configuration.

        @param source_event_types: List of EventTypes which may trigger a
            metadata update.

        @return True if the datasource did successfully update cached metadata
            due to source_event_type.
        z:Update datasource metadata and %s config due to events: %s�, cS�g|]}|j�qSr)r:��.0rpr)r)r,�
<listcomp>��z;DataSource.update_metadata_if_supported.<locals>.<listcomp>z
_%s_configTz(Datasource %s not updated for events: %scSrur)r:rvr)r)r,rx�ryF)	rsr^r�r�r;r
r�r�r�)r=rkro�scope�matched_events�resultr)r)r,�update_metadata_if_supported�s&
��z'DataSource.update_metadata_if_supportedcCr�r�r))r=r�r)r)r,�check_instance_id�r�zDataSource.check_instance_idcCr�)acheck_if_fallback_is_allowed()
        Checks if a cached ds is allowed to be restored when no valid ds is
        found in local mode by checking instance-id and searching valid data
        through ds list.

        @return True if a ds allows fallback, False otherwise.
        Fr)r<r)r)r,r��sz'DataSource.check_if_fallback_is_allowedcCsT|durt}|durt}|D]}|durq||vr|St�d||�|S|S)Nz%invalid dsmode '%s', using default=%s)�DSMODE_NETWORK�
VALID_DSMODESr�r)�
candidates�default�valid�	candidater)r)r,�_determine_dsmode�s�zDataSource._determine_dsmodecCrOr9r)r<r)r)r,�network_config�r�zDataSource.network_configcCr�)a(setup(is_new_instance)

        This is called before user-data and vendor-data have been processed.

        Unless the datasource has set mode to 'local', then networking
        per 'fallback' or per 'network_config' will have been written and
        brought up the OS at this point.
        Nr))r=�is_new_instancer)r)r,�setup�s	zDataSource.setupcCr�)a�activate(cfg, is_new_instance)

        This is called before the init_modules will be called but after
        the user-data and vendor-data have been fully processed.

        The cfg is fully up to date config, it contains a merged view of
           system config, datasource config, user config, vendor config.
        It should be used rather than the sys_cfg passed to __init__.

        is_new_instance is a boolean indicating if this is a new instance.
        Nr))r=�cfgr�r)r)r,�activate�szDataSource.activatecCr�)z�
        Called when the user issues 'cloud-init clean -c datasource'
        command.
        Individual data sources should implement their own cleanup handler.
        Nr)r<r)r)r,�clean
rRzDataSource.cleanr9)r)�T)F)FFF)NN)dr@rArBr�dsmoderSr�r�rrIrr�r�r�r
rr1rDrHrFrEr�r	rr!r#r%rr!r�BOOT_NEW_INSTANCE�BOOT�BOOT_LEGACY�HOTPLUGrl�default_update_eventsr�r�rr�r�r�r�r�r��_ci_pkl_versionrrr�r~r�r>r�r�r�r�r�r�r�timedr�r�r�r&r+r.r1�propertyr�r�r2r�r6rr)r(r-r0r?r�rBrNrQrTr�r�r�r�rjrrsr}r~r��staticmethodr�r�r�r�r�r)r)r)r,r"�s�
� ����
�%
&
V
<



			


H
�
�&

)�	metaclasscCs�|sgSt|t�r
|��St|ttf�rt|�St|t�rEg}|��D]\}}t|t�r/|g}t|ttf�rB|D]	}|rA|�|�q8q#|SgSr9)rarI�
splitlines�listrmrdr^r`)�pubkey_data�keys�_keyname�klist�pkeyr)r)r,r@s$



�r@r7c	Cs.t|||�}dd�|D�}t|vrdnd}	t�d|	|�t||�D]j\}
}tjd|
�dd�d	|	|
fd
|	|
f|d�}z?|�3t�d|�||||�}
|
�t	j
g�rkd
|	|
f|_|
t�
|�fWd�WSWd�n1suwYWq!ty�t�td|�Yq!wdd�|�}t|��)NcSsg|]}t�|��qSr)r�)rwr>r)r)r,rx4szfind_source.<locals>.<listcomp>�networkrz#Searching for %s data source in: %sz	search-%sr"rXzsearching for %s data from %szno %s data found from %s)�name�description�message�parentz%Seeing if we can get any data from %szfound %s data from %szGetting data from %s failedz4Did not find any data source, searched classes: (%s)rt)�list_sources�DEP_NETWORKr�r��zipr�ReportEventStackrcr}rr�r�rr�r$rr r
rT)r�r�r��ds_deps�cfg_list�pkg_list�reporter�ds_list�ds_namesr�r��cls�myrep�s�msgr)r)r,�find_source0s>

�������r�cCs�g}t�d|||�|D]5}t�|�}t�||dg�\}}|s%t�d|�|D]}t�|�}	t|	d�}
|
|�}|r@|�|�nq'q|S)z�Return a list of classes that have the same depends as 'depends'
    iterate through cfg_list, loading "DataSource*" modules
    and calling their "get_datasource_list".
    Return an ordered list of classes that match (if any)
    zLLooking for data source in: %s, via packages %s that matches dependencies %s�get_datasource_listzDCould not import %s. Does the DataSource exist and is it importable?)	r�r�r�"match_case_insensitive_module_name�find_module�error�
import_module�getattrrf)r��dependsr��src_listr3�ds_name�m_locs�_looked_locs�m_loc�mod�lister�matchesr)r)r,r�Qs6�
��


��r��system-uuid�fieldcCs*|sdSt�|�}|s
dS|��|��kSr�)r
�
read_dmi_datar_)r�r��	dmi_valuer)r)r,�instance_id_matches_system_uuidus
r�cCsl|st}|st}|tkr|tkr|S|St��D]\}}|\}}|�|�r-||�r-|Sq|tkr4|S|S)z@Lookup the canonical cloud-id for a given cloud_name and region.)r4�CLOUD_ID_REGION_PREFIX_MAPr^rb)r�r�r��prefix�
cloud_id_testr��valid_cloudr)r)r,r��s �r�TcCsf|sdSt|t�r|St|t�rt�|�St|t�r+|dur't|�d�dd�Std��tdt	|���)aLdata: a loaded object (strings, arrays, dicts).
    return something suitable for cloudinit vendordata_raw.

    if data is:
       None: return None
       string: return string
       list: return data
             the list is then processed in UserDataProcessor
       dict: return convert_vendordata(data.get('cloud-init'))
    NTz
cloud-initF)�recursez'vendordata['cloud-init'] cannot be dictz$Unknown data type for vendordata: %s)
rarIr�r\r]rd�convert_vendordatarrrr7)�datar�r)r)r,r��s



r�c@rS)�BrokenMetadataNrUr)r)r)r,r��rVr�cCs4g}t|�}|D]\}}|t|�kr|�|�q|Sr9)rmr`)r�r��ret_list�depsetr��depsr)r)r,�list_from_depends�s
�r�rv�fnamecCsnzt�|�}Wntyt�td|�YdSwztj||ddd�WdSty6t�td|�YdSw)z[Use pickle to serialize Datasource to a file as a cache.

    :return: True on success
    zFailed pickling datasource %sF�wb�)�omoder�z Failed pickling datasource to %sT)�pickle�dumpsr$rr r�r)rvr��pk_contentsr)r)r,r��s���r�c
Cs�d}zt�|�}Wnty(}ztj�|�rt�d||�WYd}~nd}~ww|s-dSzt�	|�WSt
y=YdStyMt�td|�YdSw)zBUse pickle to deserialize a instance Datasource from a cache file.Nzfailed loading pickle in %s: %sz#Failed loading pickled blob from %s)r�load_binary_filer$r�rw�isfiler�rr�rrPr )r��pickle_contentsr�r)r)r,�pkl_load�s$���r�cCstt���S)z�Check if command line argument for this datasource was passed
    Passing by command line overrides runtime datasource detection
    )�parse_cmdline_or_dmir�get_cmdliner)r)r)r,r��sr��inputcCs�t�d|�}t�d|�}t�d|�}|p|p|}|p|}|r7|�d���}tjd|�d|��dd|�d	�d
�|rC|�d�rC|�d�SdS)Nz(?:^|\s)ds=([^\s;]+)z(?:^|\s)ci\.ds=([^\s;]+)z (?:^|\s)ci\.datasource=([^\s;]+)r�z8Defining the datasource on the command line using ci.ds=z or ci.datasource=z23.2zUse ds=z instead)�
deprecated�deprecated_version�
extra_messagerX)�re�search�group�stripr�	deprecate)r��
ds_parse_0�
ds_parse_1�
ds_parse_2r3r�r�r)r)r,r��s&��
�	
r�)rXr))r�r�)Y�abcr\r�loggingr�r�r��enumrr�typingrrrrrr	r
r�	cloudinitrr
rrrrrrr�cloudinit.atomic_helperr�cloudinit.distrosr�cloudinit.eventrr�cloudinit.filtersr�cloudinit.helpersr�cloudinit.persistencer�cloudinit.reportingr�DSMODE_DISABLED�DSMODE_LOCALr�DSMODE_PASSr��DEP_FILESYSTEMr��	DS_PREFIXr�REDACT_SENSITIVE_VALUEr5r�r4�	getLoggerr@r�r�r1rJr$rPrTrWrerxryr�r��ABCMetar"r@rIr�r�r�r�r�r��IOErrorr�r�r�r�r�r�r)r)r)r,�<module>s�
(,
�



�

#R

�!%��
�
	

Youez - 2016 - github.com/yon3zu
LinuXploit