0x1949 Team - FAZEMRX - MANAGER
Edit File: DataSourceOpenNebula.cpython-310.pyc
o ���f�> � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m Z m Z m Z m Z e�e�ZdZdZdgZdZG dd� de j�ZG d d � d e�ZG d d � d e�ZG d d� d�Zdd� Zdd� Z dd� Z d dd�Z d dd�Z dd� Z eZ!ee j"ffgZ#dd � Z$dS ) � N)� atomic_helper�net�sources�subp�utilziid-dsopennebula�nobody� context.sh)� EPOCHREALTIME� EPOCHSECONDS�RANDOM�LINENO�SECONDS�_�SRANDOM�__vc @ sF e Zd ZdZdd� Zdd� Zdd� Zdd � Zed d � �Z dd d�Z dS )�DataSourceOpenNebula� OpenNebulac C s4 t j�| |||� d | _tj�|jd�| _d | _d S )N� opennebula) r � DataSource�__init__�seed�os�path�join�seed_dir�network)�self�sys_cfg�distro�paths� r �H/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceOpenNebula.pyr / s z DataSourceOpenNebula.__init__c C s t j�| �}d|| j| jf S )Nz%s [seed=%s][dsmode=%s])r r �__str__r �dsmode)r �rootr r r! r" 5 s z DataSourceOpenNebula.__str__c C sl dt i}d }d }t}d| jv r| j�d�}| jg}|�t� � |D ]Z}z&tj� | j�r4t || j |d�}n|� d�rHt jt || j d�}t�||�}W n% tyR Y q! ty_ } z|�d }~w tjyn t�d|� Y nw |r{|}t�d|� nq!|s�dS |d } t�| |g�} | �|�d �| j�d �g�| _| jtjkr�dS || _ |�d �| _ | | _ |�d �| _ dS )Nz instance-id� parseuser��asuserz/dev)r' r z%s was not mountablezfound datasource in %sF�metadata�DSMODEr# �network-interfaces�userdataT) � DEFAULT_IID�DEFAULT_PARSEUSER�ds_cfg�getr �extend�find_candidate_devsr r �isdir�read_context_disk_dirr � startswith� functools�partialr �mount_cb�NonContextDiskDir�BrokenContextDiskDir�MountFailedError�LOG�warning�debug� mergemanydict�_determine_dsmoder# r �DSMODE_DISABLEDr r r( � userdata_raw) r �defaults�resultsr r% � candidates�cdev�partially_applied_func�exc�mdr r r! � _get_data9 sb � � � �� �� z DataSourceOpenNebula._get_datac C s$ | j | jv r d}nd}d|| jf S )z/Return the subplatform metadata source details.zseed-dirz config-diskz%s (%s))r r )r �subplatform_typer r r! �_get_subplatformv s z%DataSourceOpenNebula._get_subplatformc C s | j d ur| j S d S �N)r )r r r r! �network_config~ s z#DataSourceOpenNebula.network_configFc C s. |d u r| j tjkr d}nd}tj�| ||�S )NTF)r# r �DSMODE_NETWORKr � get_hostname)r �fqdn� resolve_ip� metadata_onlyr r r! rO � s z!DataSourceOpenNebula.get_hostnameN)FFF) �__name__� __module__� __qualname__�dsnamer r" rI rK �propertyrM rO r r r r! r + s = r c @ � e Zd ZdS )r8 N�rS rT rU r r r r! r8 � � r8 c @ rX )r9 NrY r r r r! r9 � rZ r9 c @ sp e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z ddd�Z dd� ZdS )�OpenNebulaNetworkNc C s| || _ |d u r t|�}t�dd� t|�� dd� d�D ��| _i | _|�� D ]\}}t� d|�}|r;|� d�| j|� � < q%d S )Nc S s g | ]}|�qS r r ��.0�kr r r! � <listcomp>� s ��z.OpenNebulaNetwork.__init__.<locals>.<listcomp>c S s t �| d �S )N� )r �natural_sort_key)r^ r r r! �<lambda>� s z,OpenNebulaNetwork.__init__.<locals>.<lambda>)�keyz ^(.+)_MAC$r` ) �context�get_physical_nics_by_mac� collections� OrderedDict�sorted�items�ifaces�context_devname�re�match�group�lower)r rd r �system_nics_by_macr^ �v�mr r r! r � s$ ��� ��zOpenNebulaNetwork.__init__c C s" d� dd� |�d�dd � D ��S )N�.c S s g | ] }t t|d ���qS )� )�str�int)r] �cr r r! r_ � s z,OpenNebulaNetwork.mac2ip.<locals>.<listcomp>�:� )r �split)r �macr r r! �mac2ip� s "zOpenNebulaNetwork.mac2ipc C s\ i }| � |dd��� }|�| j�dd��� � |r ||d< | � |dd��� }|r,||d< |S )N�dns� �DNS� addresses� search_domain�search)� get_fieldrz r0 rd r/ )r �dev� nameserversr} r� r r r! �get_nameservers� s z!OpenNebulaNetwork.get_nameserversc C � | � |d�S )N�mtu�r� �r r� r r r! �get_mtu� � zOpenNebulaNetwork.get_mtuc C s | � |d| �|��S )N�ip)r� r| )r r� r{ r r r! �get_ip� s zOpenNebulaNetwork.get_ipc C s< g }| � |d�}|r|�|� | � |d�}|r |�|� |S )N�ip6�ip6_ula)r� �append)r r� � addresses6r� r� r r r! �get_ip6� s zOpenNebulaNetwork.get_ip6c C � | � |dd�S )N�ip6_prefix_length�64r� r� r r r! �get_ip6_prefix� � z OpenNebulaNetwork.get_ip6_prefixc C r� )N�gatewayr� r� r r r! � get_gateway� r� z OpenNebulaNetwork.get_gatewayc C s | � |d| � |d��S )N� ip6_gateway�gateway6r� r� r r r! � get_gateway6� s �z OpenNebulaNetwork.get_gateway6c C r� )N�maskz 255.255.255.0r� r� r r r! �get_mask� r� zOpenNebulaNetwork.get_maskc C s* | j �d�||f��� �}|dv r|S |S )z�return the field name in context for device dev. context stores <dev>_<NAME> (example: eth0_DOMAIN). an empty string for value will return default.r )Nr~ )rd r/ r �upper)r r� �name�default�valr r r! r� � s ��� zOpenNebulaNetwork.get_fieldc s0 i }d|d< i |d< i }| j �� D ]�\}}|�� }| j�||�}i }d|i|d< g |d< | �|�}tt�|��}|d � | � ||�d | � | � |�} | ra| � |�� |d � � fdd �| D �� | �|�} | rl| |d < | �|�} | rw| |d < | �|�} | r�| |d < | �|�} | r�| |d < |||< q||d< |S )Nry �version� ethernets� macaddressrm r� �/c s g | ]}|d � �qS )r� r )r] �i��prefix6r r! r_ s z.OpenNebulaNetwork.gen_conf.<locals>.<listcomp>�gateway4r� r� r� )rj ri ro rk r/ r� ru r �ipv4_mask_to_net_prefixr� r� r� r� r0 r� r� r� r� )r �netconfr� r{ r� �c_dev�devconfr� �prefixr� r� r� r� r� r r� r! �gen_conf� sD � zOpenNebulaNetwork.gen_confrL )rS rT rU r r| r� r� r� r� r� r� r� r� r� r� r r r r! r[ � s r[ c C s@ g } dD ]}t �|�}|�� |D ] }|| vr | �|� qq| S )zE Return a list of devices that may contain the context disk. )z LABEL=CONTEXTz LABEL=CDROMz TYPE=iso9660)r �find_devs_with�sortr� )�combined�f�devs�dr r r! r1 & s ��r1 c C s dd| gS )N�sudoz-ur ��userr r r! �switch_user_cmd5 s r� c C s t �d�S )zDprint the shell environment variables within delimiters to be parsedz� printf "%s\0" _start_ [ $0 != 'sh' ] && set -o posix set [ $0 != 'sh' ] && set +o posix printf "%s\0" _start_ )�textwrap�dedentr r r r! � varprinter9 s �r� c C s d| � � v r t�d� t� d| t� d }g }|dur!t|�}|�ddg� tj||d�j}i }|�d �d d� }|d |d }}t d d� t �|�D ��} t dd� t �|�D ��} t | � � �� t | � � ��D ]} | tv rpqi| �| �} | dur�| | �| �kr�| || < qi|S )a< run content and return environment variables which changed WARNING: the special variable _start_ is used to delimit content a context.sh that defines this variable might break in unexpected ways compatible with posix shells such as dash and ash and any shell which supports `set -o posix` s _start_ zYUser defined _start_ variable in context.sh, this may breakcloud-init in unexpected ways.z{ %s : } > /dev/null � N�shz-e)�dataz_start_ r` r ry c s � � | ] }|j d dd�V qdS ��=r` )�maxsplitN�rz �r] �variabler r r! � <genexpr>} � � �z%parse_shell_config.<locals>.<genexpr>c s r� r� r� r� r r r! r� � r� )�encoder; r< r� r� r0 r �stdoutrz �dict�shlex�set�keys�union� EXCLUDED_VARSr/ ) �contentr' �bcmd�cmd�output�ret�sections�before�after�pre_env�post_envrc �valuer r r! �parse_shell_configF sD ������� �r� c C sJ i }t D ]}tj�| |�}tj�|�r|||< q|s"td| df ��i }di d�}d|v r�|durNzt�|� W n tyM } z t dj |d��|�d}~ww ztj�| d�} t � | �} t | |d�}W n* tjyv } zt d | �|�d}~w ty� } ztd | �|�d}~ww td ��|s�|S ||d < d} d |v r�d } nd|v r�d} | r�|�| ��� } dd� | D �|d d< dD ]} | |v r�|| |d d< nq�d|v r�|d |d< n d|v r�|d |d< d|v �r|�d|�d��}|dk�rz t�|d �|d< W n t�y t�d� Y nw dd� |D �}|�r#t||�}|�� |d < |S ) z� read_context_disk_dir(source_dir): read source_dir and return a tuple with metadata dict and user-data string populated. If not a valid dir, raise a NonContextDiskDir z%s: %szno files foundN)r+ r( r z'configured user '{user}' does not existr� r& z Error processing context.sh: %sz Error reading context.sh: %szMissing context.shr( �SSH_KEY�SSH_PUBLIC_KEYc S s" g | ] }t |�r|�d �s|�qS )�#)�lenr4 )r] �liner r r! r_ � s ���z)read_context_disk_dir.<locals>.<listcomp>z public-keys)� SET_HOSTNAME�HOSTNAME� PUBLIC_IP� IP_PUBLIC�ETH0_IPzlocal-hostname� USER_DATAr+ �USERDATA�USERDATA_ENCODING�USER_DATA_ENCODING�base64z"Failed base64 decoding of userdatac S s g | ] }t �d |�r|�qS )z ^ETH\d+_IP.*$)rl rm r\ r r r! r_ � s r* )�CONTEXT_DISK_FILESr r r �isfiler8 �pwd�getpwnam�KeyErrorr9 �formatr �load_text_filer� r �ProcessExecutionError�IOErrorr/ � splitlinesr �b64d� TypeErrorr; r< r[ r� )� source_dirr r' �found�af�fnrd rC �er r� � ssh_key_var�linesr^ �encoding� ipaddr_keys�onetr r r! r3 � s� � ����� ��������� � � r3 c s" t �� }t� fdd�|�� D ��S )Nc s$ g | ]\}}� j �|�r||f�qS r )� networking� is_physical)r] rr �n�r r r! r_ � s $ z,get_physical_nics_by_mac.<locals>.<listcomp>)r �get_interfaces_by_macr� ri )r r� r r r! re � s �re c C s t �| t�S rL )r �list_from_depends� datasources)�dependsr r r! �get_datasource_list� r� r rL )%rf r5 �loggingr r� rl r� r� � cloudinitr r r r r � getLoggerrS r; r, r- r� r� r r � Exceptionr8 r9 r[ r1 r� r� r� r3 re �DataSourceOpenNebulaNet�DEP_FILESYSTEMr r r r r r! �<module> s: c G` �