| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/cloudinit/sources/__pycache__/ |
Upload File : |
o
x[hg � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m
Z
m Z ddl m
Z
mZ e�e�ZdZdd� Zd ed
efd d �Zd
eje fd
d�Zdd� Zdd� Zdd� Zdd� Z dd� Z G dd� de j �Z e e j ffgZ!dd � Z"dS ) zr
This file contains code used to gather the user data passed to an
instance on rootbox / hyperone cloud platforms
� N)� IPv4Address)�sources�subp�util)�
EventScope� EventTypez
/etc/hostsc C s. t jtdd�} | rt�d� dS t�d� dS )NT)�quietz5/etc/hosts exists - setting manage_etc_hosts to FalseFz=/etc/hosts does not exists - setting manage_etc_hosts to True)r �load_text_file� ETC_HOSTS�LOG�debug)�hosts� r �F/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceRbxCloud.py�get_manage_etc_hosts s
r �inc�returnc C s t ttt| ��| ��S �N)�strr �int)�addrr r r r � increment_ip# s r c C s | t | d�t | d�gS )z�Return a list of 3 IP addresses: [addr, addr + 2, addr + 3]
@param addr: an object that is passed to IPvAddress
@return: list of strings
� � )r )r r r r �
get_three_ips' s �r c C s t � dg| �S )z�
Uses the preferred cloud-init subprocess def of subp.subp
and runs arping. Breaking this to a separate function
for later use in mocking and unittests
�arping)r )�cmdr r r �_sub_arp4 s r c C s| d}|j dv r d}| D ]0}ztdd||d |d g� W q tjy; } zt�d|d |d |� W Y d }~q d }~ww d S ) Nz-S)�fedora�centos�rhelz-sz-c�2�source� destinationz&Failed to arping from "%s" to "%s": %s)�namer r �ProcessExecutionErrorr �warning)�items�distro� source_param�item�errorr r r �gratuitous_arp= s$
�����r, c C s� t t�d�t�d� �} | sdS | D ]>}ztj|tg d�d�}|r&|W S W q ty@ } z
|jtjkr6� W Y d}~qd}~w tjyP t� t
d|� Y qw t
� dd � | �� dS )
zAReturns False (not found or error) or a dictionary with metadata.z
LABEL=CLOUDMDz
LABEL=cloudmdF)�vfat�fat�msdosfs)�device�callback�mtypeNz-Failed to mount %s when looking for user dataz0Did not find RbxCloud data, searched devices: %s�,)
�setr �find_devs_with�mount_cb�read_user_data_callback�OSError�errno�ENOENT�MountFailedError�logexcr r �join)�devicesr0 �rbx_data�errr r r �get_mdR s> ���
� ����
�rA c C s ddd� t | �D �d�S )z�Generate network configuration
@param netadps: A list of network adapter settings
@returns: A dict containing network config
� c sB g | ] \}� d d� t|��� d �� � fdd�� d D �d��qS )�physicalzeth{}�
macaddressc s> g | ]}d |d � d d d� d d � d d d d��qS ) �static�address�network�netmask�auto�gateway�dns� nameservers)�typerF rH �controlrJ �dns_nameserversr )�.0�ip��netadpr r �
<listcomp> s �
���z6generate_network_config.<locals>.<listcomp>.<listcomp>rQ )rM r$ � mac_address�subnets)�formatr �lower)rP �ir rR r rT z s �
���z+generate_network_config.<locals>.<listcomp>)�version�config)� enumerate)�netadpsr r r �generate_network_configq s
��r^ c
C s t jt jtj�| d�d�d�}t jtj�| d�dd�}d|vs#d|vr+t �td � d
S |� d i �� d �}|� d i �� d
g �}d
}|� d i �� d�rQ|d d d }t
|d �}||d d |d d g d�dd� |d D �ddd||dg|d|d�i|t � d�d�}t� d� t� |� |S ) a This callback will be applied by util.mount_cb() on the mounted
drive.
@param mount_dir: String representing path of directory where mounted drive
is available
@returns: A dict containing userdata, metadata and cfg based on metadata.
z
cloud.json)�fname)�textz user.dataT)r_ r �vmrS z(Failed to load metadata. Invalid format.N�additionalMetadata�username�sshKeys�password�sha512�_idr$ )z instance-idzlocal-hostname� public-keysc S s> g | ]}|d D ]}t |d d �D ] }|d |d��qqqS )rQ rG rJ rF )r" r# )r )rP rS rQ �targetr r r rT � s �� �
�z+read_user_data_callback.<locals>.<listcomp>� default_userzALL=(ALL) NOPASSWD:ALLF)r$ �gecos�sudo�passwd� lock_passwd�ssh_authorized_keys)�
ssh_pwauth� disable_root� system_info�network_config�manage_etc_hosts)�userdata�metadatar, �cfgzreturning DATA object:)
r � load_json�load_binary_file�os�pathr= r r< r �getr^ r r )� mount_dir� meta_data� user_datarc �ssh_keys�hashrG �datar r r r7 � sR ��
����
��
r7 c @ sj e Zd ZdZejejejej hiZ
dd� Z dd� Z dd� Z
edd � �Zd
d � Zd d
� Zdd� Zdd� ZdS )�DataSourceRbxCloud�RbxCloudc C s( t j�| |||� d | _d | _d | _d S r )r �
DataSource�__init__�seedr, rw )�self�sys_cfgr( �pathsr r r r� � s
zDataSourceRbxCloud.__init__c C s t j�| �}d|| jf S )Nz %s [seed=%s])r r� �__str__r� )r� �rootr r r r� � s zDataSourceRbxCloud.__str__c C s> t � }|du r dS |d | _|d | _|d | _|d | _dS )zw
Metadata is passed to the launching instance which
is used to perform instance configuration.
Fru rv r, rw T)rA � userdata_rawrv r, rw )r� r? r r r � _get_data� s
z DataSourceRbxCloud._get_datac C �
| j d S )Nrs �rw �r� r r r rs � s
z!DataSourceRbxCloud.network_configc C r� )Nrh )rv r� r r r �get_public_ssh_keys� s
z&DataSourceRbxCloud.get_public_ssh_keysc C � | j S r )r� r� r r r �get_userdata_raw� � z#DataSourceRbxCloud.get_userdata_rawc C r� r r� r� r r r �get_config_obj� r� z!DataSourceRbxCloud.get_config_objc C s t | j | j� d S r )r, r( )r� rw �is_new_instancer r r �activate s zDataSourceRbxCloud.activateN)�__name__�
__module__� __qualname__�dsnamer �NETWORKr �BOOT_NEW_INSTANCE�BOOT� BOOT_LEGACY�default_update_eventsr� r� r� �propertyrs r� r� r� r� r r 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� )#�__doc__r9 �loggingrz �os.path�typing� ipaddressr � cloudinitr r r �cloudinit.eventr r � getLoggerr� r r
r r r r �Listr r r, rA r^ r7 r� r� �DEP_FILESYSTEMr� r� r r r r �<module> s.
!@
5�