| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/cloudinit/sources/__pycache__/ |
Upload File : |
a
-@=j� � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m
Z
m Z ddl m
Z
mZ e�e�ZdZdd� Zeed �d
d �Zeje d �d
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�} | r t�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 �H/usr/lib/python3.9/site-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 )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
Zarping)r )�cmdr r r �_sub_arp4 s r c C s~ d}|j dv rd}| D ]b}z tdd||d |d g� W q tjyv } z$t�d|d |d |� W Y d }~qd }~0 0 qd S ) Nz-S)Z almalinuxZfedoraZcentosZ
cloudlinuxZrhelz-sz-c�2�source� destinationz&Failed to arping from "%s" to "%s": %s)�namer r ZProcessExecutionErrorr Zwarning)�items�distroZ source_param�item�errorr r r �gratuitous_arp= s
��r% c C s� t t�d�t�d� �} | s dS | D ]~}z&tj|tg d�d�}|rL|W S W q$ ty� } z|jtjkrl� W Y d}~q$d}~0 tjy� t� t
d|� Y q$0 q$t
� dd � | �� dS )
zAReturns False (not found or error) or a dictionary with metadata.z
LABEL=CLOUDMDz
LABEL=cloudmdF)ZvfatZfatZmsdosfs)�device�callbackZmtypeNz-Failed to mount %s when looking for user dataz0Did not find RbxCloud data, searched devices: %s�,)
�setr Zfind_devs_withZmount_cb�read_user_data_callback�OSError�errno�ENOENTZMountFailedError�logexcr r �join)Zdevicesr& �rbx_data�errr r r �get_mdR s6 ��� �
�r2 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 )Zphysicalzeth{}Z
macaddressc s> g | ]6}d |d � d d d� d d � d d d d��qS ) Zstatic�address�network�netmask�auto�gatewayZdnsZ nameservers)�typer4 r6 Zcontrolr8 Zdns_nameserversr )�.0�ip��netadpr r �
<listcomp> s �
��z6generate_network_config.<locals>.<listcomp>.<listcomp>r; )r9 r Z mac_address�subnets)�formatr �lower)r: �ir r< r r> z s �
��z+generate_network_config.<locals>.<listcomp>)�versionZconfig)� enumerate)Znetadpsr r r �generate_network_configq s
��rE c
C s t jt jtj�| d�d�d�}t jtj�| d�dd�}d|vsFd|vrVt �td � d
S |� d i �� d �}|� d i �� d
g �}d
}|� d i �� d�r�|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)rF r Zvmr= z(Failed to load metadata. Invalid format.NZadditionalMetadata�usernameZsshKeys�passwordZsha512Z_idr )z instance-idzlocal-hostname� public-keysc S s> g | ]6}|d D ](}t |d d �D ]}|d |d��q$qqS )r; r5 r8 r4 )r r )r )r: r= r; �targetr r r r> � s �z+read_user_data_callback.<locals>.<listcomp>Z default_userzALL=(ALL) NOPASSWD:ALLF)r ZgecosZsudo�passwdZ lock_passwdZssh_authorized_keys)Z
ssh_pwauthZ disable_rootZ system_info�network_configZmanage_etc_hosts)�userdata�metadatar% �cfgzreturning DATA object:)
r Z load_jsonZload_binary_file�os�pathr/ r r. r �getrE r r )Z mount_dirZ meta_dataZ user_datarH Zssh_keys�hashr5 �datar r r r* � sR ��
����
��
r* c @ sj e Zd ZdZejejejej hiZ
dd� Z dd� Z dd� Z
edd � �Zd
d � Zd d
� Zdd� Zdd� ZdS )�DataSourceRbxCloudZRbxCloudc C s( t j�| |||� d | _d | _d | _d S r )r �
DataSource�__init__�seedr% rP )�selfZsys_cfgr" �pathsr r r rX � s zDataSourceRbxCloud.__init__c C s t j�| �}d|| jf S )Nz %s [seed=%s])r rW �__str__rY )rZ �rootr r r r\ � s zDataSourceRbxCloud.__str__c C s> t � }|du rdS |d | _|d | _|d | _|d | _dS )zw
Metadata is passed to the launching instance which
is used to perform instance configuration.
FrN rO r% rP T)r2 � userdata_rawrO r% rP )rZ r0 r r r � _get_data� s
z DataSourceRbxCloud._get_datac C s
| j d S )NrM �rP �rZ r r r rM � s z!DataSourceRbxCloud.network_configc C s
| j d S )NrJ )rO ra r r r �get_public_ssh_keys� s z&DataSourceRbxCloud.get_public_ssh_keysc C s | j S r )r^ ra r r r �get_userdata_raw� s z#DataSourceRbxCloud.get_userdata_rawc C s | j S r r` ra r r r �get_config_obj� s z!DataSourceRbxCloud.get_config_objc C s t | j | j� d S r )r% r" )rZ rP Zis_new_instancer r r �activate s zDataSourceRbxCloud.activateN)�__name__�
__module__� __qualname__Zdsnamer ZNETWORKr ZBOOT_NEW_INSTANCEZBOOTZ BOOT_LEGACYZdefault_update_eventsrX r\ r_ �propertyrM rb rc rd re r r r r rV � s ��
rV c C s t �| t�S r )r Zlist_from_depends� datasources)Zdependsr r r �get_datasource_list s rk )#�__doc__r, ZloggingrQ Zos.path�typing� ipaddressr Z cloudinitr r r Zcloudinit.eventr r Z getLoggerrf r r
r r r r �Listr r r% r2 rE r* rW rV ZDEP_FILESYSTEMrj rk r r r r �<module> s,
!@5
�