/usr/lib/python3/dist-packages/cloudinit/sources/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/sources/__pycache__/DataSourceRbxCloud.cpython-310.pyc (7552B)
o
thg @ s d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m
Z
m Z ddl m
Z
mZ eeZdZdd Zd ed
efd d Zd
eje fd
dZdd 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)sourcessubputil)
EventScope EventTypez
/etc/hostsc C s. t jtdd} | rtd dS td 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_HOSTSLOGdebug)hosts r F/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceRbxCloud.pyget_manage_etc_hosts s
r increturnc C s t ttt| | S N)strr int)addrr r r r increment_ip# s r c C s | t | dt | dgS )zReturn 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; } ztd|d |d | W Y d }~q d }~ww d S ) Nz-S)fedoracentosrhelz-sz-c2source destinationz&Failed to arping from "%s" to "%s": %s)namer r ProcessExecutionErrorr warning)itemsdistro source_paramitemerrorr r r gratuitous_arp= s$
r, c C s t tdtd } | sdS | D ]>}ztj|tg dd}|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)vfatfatmsdosfs)devicecallbackmtypeNz-Failed to mount %s when looking for user dataz0Did not find RbxCloud data, searched devices: %s,)
setr find_devs_withmount_cbread_user_data_callbackOSErrorerrnoENOENTMountFailedErrorlogexcr r join)devicesr0 rbx_dataerrr r r get_mdR s>
rA c C s ddd t | D dS )zGenerate 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 dqS )physicalzeth{}
macaddressc s> g | ]}d |d d d d d d d d d dqS ) staticaddressnetworknetmaskautogatewaydns nameservers)typerF rH controlrJ dns_nameserversr ).0ipnetadpr r
s
z6generate_network_config...rQ )rM r$ mac_addresssubnets)formatr lower)rP ir rR r rT z s
z+generate_network_config..)versionconfig) enumerate)netadpsr r r generate_network_configq s
r^ c
C s t jt jtj| ddd}t jtj| ddd}d|vs#d|vr+t td d
S | d i d }| d i d
g }d
}| d i drQ|d d d }t
|d }||d d |d d g ddd |d D ddd||dg|d|di|t dd}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.NadditionalMetadatausernamesshKeyspasswordsha512_idr$ )z instance-idzlocal-hostname public-keysc S s> g | ]}|d D ]}t |d d D ] }|d |dqqqS )rQ rG rJ rF )r" r# )r )rP rS rQ targetr r r rT s
z+read_user_data_callback.. default_userzALL=(ALL) NOPASSWD:ALLF)r$ gecossudopasswd lock_passwdssh_authorized_keys)
ssh_pwauth disable_root system_infonetwork_configmanage_etc_hosts)userdatametadatar, cfgzreturning DATA object:)
r load_jsonload_binary_fileospathr= r r< r getr^ r r ) mount_dir meta_data user_datarc ssh_keyshashrG 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 )DataSourceRbxCloudRbxCloudc C s( t j| ||| d | _d | _d | _d S r )r
DataSource__init__seedr, rw )selfsys_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_INSTANCEBOOT BOOT_LEGACYdefault_update_eventsr r r propertyrs r r r r r r r r r s"
r c C s t | tS r )r list_from_depends datasources)dependsr r r get_datasource_list s r )#__doc__r9 loggingrz os.pathtyping 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 s.
!@
5