⚝
One Hat Cyber Team
⚝
Your IP:
216.73.217.4
Server IP:
41.128.143.86
Server:
Linux host.raqmix.cloud 6.8.0-1025-azure #30~22.04.1-Ubuntu SMP Wed Mar 12 15:28:20 UTC 2025 x86_64
Server Software:
Apache
PHP Version:
8.3.23
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
cloudinit
/
__pycache__
/
View File Name :
stages.cpython-310.pyc
o 'Dg @ s d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m Z d dl m Z m Z mZmZmZmZmZmZ d dlmZmZmZmZmZmZmZm Z m Z m Z m Z m Z d dl!m"Z"m#Z# d dl$m%Z%m&Z&m'Z' d d l(m)Z) d d l*m+Z+ d d l,m-Z- d d l.m/Z/ d d l0m1Z1 d dl2m3Z3 d dl4m5Z5 d dl6m7Z7m8Z8m9Z9m:Z:m;Z; d dl<m=Z= e>e?Z@dZAdZBde jCdeDde&de%deEf ddZFG dd d ZGd eHfd d ZIdd d eHdeDfd!d"ZJdS )# N) namedtuple)suppress)Path)AnyDictIterableListOptionalSetTupleUnion) atomic_helperclouddistrosfeatureshandlershelpersimporter lifecyclenetsources type_utilsutil)Netv1Netv2) EventScope EventTypeuserdata_to_events)BootHookPartHandler)CloudConfigPartHandler)JinjaTemplatePartHandler)ShellScriptPartHandler) ShellScriptByFreqPartHandler)cmdline)events) CLOUD_CONFIGDEFAULT_RUN_DIR PER_ALWAYS PER_INSTANCEPER_ONCE)NetworkConfigSourceNO_PREVIOUS_INSTANCE_IDzAggregated cloud-config created by merging merged_system_cfg (/etc/cloud/cloud.cfg and /etc/cloud/cloud.cfg.d), metadata, vendordata and userdata. The combined_cloud_config represents the aggregated desired configuration acted upon by cloud-init. datasourcecfgevent_source_typescopereturnc C s | j }t|di }tt|t|g}tj| j |t v rOt | j }|j |d v rOtd|tj| j d ||sGt ||< || tj td| |g}dd |D } |D ]} ||| g v rvtd| j | d S qatd | | d S ) aA Determine if a particular EventType is enabled. For the `event_source_type` passed in, check whether this EventType is enabled in the `updates` section of the userdata. If `updates` is not enabled in userdata, check if defined as one of the `default_events` on the datasource. `scope` may be used to narrow the check to a particular `EventScope`. Note that on first boot, userdata may NOT be available yet. In this case, we only have the data source's `default_update_events`, so an event that should be enabled in userdata may be denied. updatesscopesz/Adding event: scope=%s EventType=%s found in %szhotplug.enabledzAllowed events: %sc S s g | ]}|j qS )value).0sr3 r3 2/usr/lib/python3/dist-packages/cloudinit/stages.py <listcomp>v s z(update_event_enabled.<locals>.<listcomp>z$Event Allowed: scope=%s EventType=%sTz$Event Denied: scopes=%s EventType=%sF)default_update_eventsr getr mergemanydictcopydeepcopyr HOTPLUGsupported_update_eventssetread_hotplug_enabled_filepathsr4 LOGdebug get_cpathadd) r, r- r. r/ default_events user_eventsallowedhotplug_enabled_filer2 scope_values evt_scoper3 r3 r7 update_event_enabledB sP rM c @ s" e Zd Zdhdeee fddZdd Zedd Z ed d Z d d Z ed d Z dd Z diddZdd ZedededefddZdd Zdjd d Zd d Zd!efd"d#Zd$d% Zd&d' Zd(d) Zd*d+ Zde j fd,d-Z d.d/ Z djd0d1Z d2efd3d4Z!d5d6 Z"d7d8 Z#d9d: Z$dkd<d=Z%d>d? Z&d@dA Z'dBdC Z(dDdE Z)dFdG Z*dHdI Z+dJdK Z,dLdM Z-djdee.j/ fdNdOZ0dPdQ Z1dRdS Z2 djdTdUZ3e4fdVdWZ5e4fdXdYZ6e4fdZd[Z7de8e9e:df fd\d]Z;de<e8e9e:df e8e=ef f fd^d_Z>d`da Z?dbdc Z@deAfdddeZBdfdg ZCdS )lInitNds_depsc C sd |d ur|| _ ntjtjg| _ i | _d | _d | _d | _d| _d | _ |d u r-t j dddd}|| _ d S )NFz init-reporterz init-desc)name descriptionreporting_enabled) rO r DEP_FILESYSTEM DEP_NETWORK_cfg_paths_distror, ds_restored _previous_iidr$ ReportEventStackreporter)selfrO r[ r3 r3 r7 __init__ s z Init.__init__c C s i | _ d | _d | _d S N)rU rV rW r\ r3 r3 r7 _reset s z Init._resetc C sf | j s0| d}|dd}t|}td| |||| j| _ | jd ur0| j | j_ | j | j_ | j S )NsystemdistroubuntuzUsing distro class %s) rW _extract_cfgpopr fetchrC rD rB r, rb r- sys_cfg)r\ system_config distro_name distro_clsr3 r3 r7 rb s z Init.distroc C s | dS )N restricted)rd r_ r3 r3 r7 r- s zInit.cfgc C s` | t| j}|dkr|dd |S |dkr#t|di }|S |dkr.t|di }|S )Nrk system_infora )rl rB )rl rB )read_cfgr< r= rU re r get_cfg_by_path)r\ restrictionocfgr3 r3 r7 rd s zInit._extract_cfgc C s& | j s| d}t|| j| _ | j S )NrB )rV rd r Pathsr, )r\ path_infor3 r3 r7 rB s z Init.pathsc C s | j j}| j j}|tj|dtj|ddtj|ddtj|ddtj|ddtj|dtj|dtj|dtj|d tj|d tj|d g }|S ) Nscriptsz per-instancezper-oncezper-bootvendorseed instancesr semdata)rB cloud_dirrun_dirospathjoin)r\ c_dirrz initial_dirsr3 r3 r7 _initial_subdirs s zInit._initial_subdirsFc C s8 | j jg}|r|| j j |D ]}t| qt|S r^ )rB boot_finishedappend instance_linkr del_filelen)r\ rm_instance_lnkrm_listfr3 r3 r7 purge_cache s zInit.purge_cachec C s | d S r^ )_initialize_filesystemr_ r3 r3 r7 initialize s zInit.initializemode_1mode_2r0 c C s | |@ S r^ r3 )r r r3 r3 r7 _get_strictest_mode s zInit._get_strictest_modec C s d}t | t | jd}|rtt | dt |}W d n1 s*w Y t j ||dd | j d}|sAi }t |t sI|g}d }|D ](}t |\}}z t ||| W d S tyu } z|}W Y d }~qMd }~ww td|d|| d S d S )Ni def_log_fileF) preserve_modesyslog_fix_permsz,Failed changing perms on '%s'. tried: %s. %s,)r ensure_dirsr get_cfg_option_strr- r OSErrorr get_permissions ensure_filer: isinstancelistextract_usergroup chownbynamerC warningr} ) r\ modelog_filepermserrorpermuger3 r3 r7 r s@ zInit._initialize_filesystemc C s | j s | || _ d S d S r^ )rU _read_cfg)r\ extra_fnsr3 r3 r7 rm s z Init.read_cfgc C sB | |i }|di di }|dtdfv r|S | ||S )z read and merge our configurationrl rB rz N)_read_bootstrap_cfgr: r& )r\ r initial_configrB r3 r3 r7 r s zInit._read_cfgbootstrapped_configc C s< t || j}|d}t j|| j|t|j|dd}|jS )Ninstance_data_sensitiveinstance_data_file)rB r, additional_fnsbase_cfg)r rq r, get_runpath ConfigMergerfetch_base_configrz r- )r\ r r no_cfg_pathsr mergerr3 r3 r7 r + s zInit._read_bootstrap_cfgc C s t | jdS )Nobj_pkl)r pkl_loadrB get_ipath_curr_ r3 r3 r7 _restore_from_cache: s zInit._restore_from_cachec C sL | j d u rdS t| jddrtj| jdddd t| j | jdS )NFmanual_cache_cleanmanual_clean_markerw )omodecontentr ) r, r get_cfg_option_boolr- write_filerB r r pkl_storer_ r3 r3 r7 _write_to_cache@ s zInit._write_to_cachec C sN | j dpg }dttfD ] }||vr|| q| j dp"g }||fS )Ndatasource_pkg_listr datasource_list)r- r: r obj_namer r )r\ pkg_listncfg_listr3 r3 r7 _get_datasourcesO s zInit._get_datasourcesc C s |dvr t d| | }|sdS | jd}tj|r&t| }nd }|| kr4|d| fS |dkr>|d| fS t |drO| | j rO|d | fS d d | fS ) N)checktrustz!Unexpected value for existing: %s)Nzno cache found instance_idz&restored from cache with run check: %sr zrestored from cache: %scheck_instance_idz restored from checked cache: %sz cache invalid in datasource: %s) ValueErrorr rB r r{ r| existsr load_text_filestripget_instance_idhasattrr r- )r\ existingds run_iid_fnrun_iidr3 r3 r7 _restore_from_checked_cacheY s$ z Init._restore_from_checked_cachec C sD | j d ur| j S tjdd| | jd }| |\}}||_t|| _t |j W d n1 s3w Y |sz+| \}}t | j | j| jt| j||| j\}}t| jj td|| W n3 t jy } z&|dkrt|| }|r| rtd| n t| jj |W Y d }~nd }~ww || _ | |S )Nz check-cachez"attempting to read from cache [%s])rP rQ parentzLoaded datasource %s - %sr z3Restored fallback datasource from checked cache: %s)r, r$ rZ r[ r rQ boolrX rC rD r r find_sourcer- rb rB r< r= rO r r r infoDataSourceNotFoundExceptionr check_if_fallback_is_allowedr` ) r\ r myrepr descr r dsnamer r3 r3 r7 _get_data_sources sX zInit._get_data_sourcec C s g dS )N)r rs rw r3 r_ r3 r3 r7 _get_instance_subdirs zInit._get_instance_subdirsc C s | j |}|s td|S )NzCNo instance directory is available. Has a datasource been fetched??)rB get_ipath RuntimeError)r\ subname instance_dirr3 r3 r7 _get_ipath s zInit._get_ipathnetcfgc C s t j| jjs dS | jd}| jd}t j|r/|t t |kr.t j ||dd nt j ||dd t j|sEt || dS dS )zCreate /var/lib/cloud/instance/network-config.json Only attempt once /var/lib/cloud/instance exists which is created by Init.instancify once a datasource is detected. Nnetwork_config r )r{ r| islinkrB r r r r r load_jsonr r write_jsonsym_link)r\ r ncfg_instance_path network_linkr3 r3 r7 _write_network_config_json s z Init._write_network_config_jsonc C s | }t| jj }|t| k}|r td nt | jj t || jj g }| D ] }| t j|| q3t| | jd}dt| j| jf }d }t j|d} z t| }W n tyq Y nw |sv|}t| d| tt j|dd| | j } t j|d} | } t| d| t| jdd| tt j|d d| | |r||krtd | S | | S ) Nz0Instance link already exists, not recreating it.rx z%s: %sr, z%s zprevious-datasource instance-idr zprevious-instance-idzJNot re-loading configuration, instance id and datasource have not changed.) r r rB r resolveabsoluterC r r r r r r r{ r| r} r rE r r r, r r Exceptionr r previous_iidr r r` ) r\ idir destinationalready_instancifieddir_listddpr previous_dsds_fniidiid_fnr r3 r3 r7 _reflect_cur_instance sT zInit._reflect_cur_instancec C sl | j d ur| j S | jd}tj|d}z t| | _ W n t y+ t | _ Y nw t d| j | j S )Nrx r zprevious iid found to be %s) rY rB rE r{ r| r} r r r r r+ rC rD )r\ r r r3 r3 r7 r s zInit.previous_iidc C s" | }|tkp|| j k}|S )zReturn true if this is a new instance. If datasource has already been initialized, this will return False, even on first boot. )r r+ r, r )r\ previousretr3 r3 r7 is_new_instance s zInit.is_new_instancer c C s | j |dS )zUoptionally load datasource from cache, otherwise discover datasource )r )r )r\ r r3 r3 r7 rf $ s z Init.fetchc C s | S r^ )r r_ r3 r3 r7 instancify* r zInit.instancifyc C s( t j| j| j| j| jt| j| jdS )N)r[ ) r Cloudr, rB r- rb r Runnersr[ r_ r3 r3 r7 cloudify- s z Init.cloudifyc C sp | | j d | | j d | | j d | | j d | | j d | | j d d S )Nuserdata vendordata vendordata2) _store_rawdatar, get_userdata_raw_store_processeddata get_userdata_store_raw_vendordataget_vendordata_rawget_vendordataget_vendordata2_rawget_vendordata2r_ r3 r3 r7 update8 s z Init.updatec C s\ t jdd| jd | jd u rtd| jj| d W d d S 1 s'w Y d S )Nzsetup-datasourcezsetting up datasourcer z!Datasource is None, cannot setup.)r )r$ rZ r[ r, r setupr r_ r3 r3 r7 setup_datasourceH s "zInit.setup_datasourcec C sh t jdd| jd! | jd u rtd| jj| j| d | W d d S 1 s-w Y d S )Nzactivate-datasourcezactivating datasourcer z$Datasource is None, cannot activate.)r- r ) r$ rZ r[ r, r activater- r r r_ r3 r3 r7 activate_datasourceP s "zInit.activate_datasourcec C s( |d u rd}t | d| |d d S )N z%s_rawr )r r r r\ rx r, r3 r3 r7 r ] s zInit._store_rawdatac C sR |d urt |tttfvrtdtt | t|tr!t|}| || d S )Nz'vendordata_raw is unsupported type '%s') typebytesstrr TypeErrorr r json_dumpsr r r3 r3 r7 r c s zInit._store_raw_vendordatac C s( |d u rd}t | |t|d d S )Nr r )r r r r! )r\ processed_datar, r3 r3 r7 r n s zInit._store_processeddatac C s |d u ri }| | j| jd tdi |}tdi |}tdi |}||ttfi |ttfi |tt fi ||t di |d|||gig}|S )N)rB r, sub_handlersr3 ) r rB r, r r! r r" r' r( r) r )r\ optscloudconfig_handlershellscript_handlerboothook_handler def_handlersr3 r3 r7 _default_handlersv s4 zInit._default_handlersc C | j ddddS )Nvendor_scriptsvendor_cloud_config script_pathcloud_config_pathr& r+ r_ r3 r3 r7 _default_vendordata_handlers z!Init._default_vendordata_handlersc C r, )Nr- vendor2_cloud_configr/ r2 r3 r_ r3 r3 r7 _default_vendordata2_handlers r5 z"Init._default_vendordata2_handlersc s |du rg }| j d}| d|fD ]}|r%|tjvr%tjd| q fdd}t || |D ]} j|dd} | rHt d| | q6| fd d } fd d } fd d} z | | | W | dS | w )zb Generalized handlers suitable for use with either vendordata or userdata Nr r c s | rt j| s d S t| }| D ]I\}}z5t|dgddg\}}|s0t d||| W qt |d }t |} |}|rKtd||| W q ty\ ttd| Y qw d S )Nr list_types handle_partzJCould not find a valid user-data handler named %s in file %s (searched %s)r z(Added custom handler for %s [%s] from %sz"Failed to register handler from %s)r{ r| isdirr get_modules_from_diritemsr find_modulerC r import_moduler fixup_handlerregisterrD r logexc)r| potential_handlersfnamemod_namemod_locs looked_locsmodtypes) c_handlersr3 r7 register_handlers_in_dir sB z3Init._do_handlers.<locals>.register_handlers_in_dirF) overwritez$Added default handler for %s from %sc s< D ]\} }| jv rqt| j| qd S r^ )r< initializedr call_beginr _ctyperG rI rx frequencyr3 r7 init_handlers s z(Init._do_handlers.<locals>.init_handlersc s( d| d}t jt j|d d S )Nr )r handlerdirrx rQ handlercountexcluded)rx )r walkwalker_callback)rU part_datarI rx data_msgrQ r r3 r7 walk_handlers s z(Init._do_handlers.<locals>.walk_handlersc s` D ])\} }| jvrq j| z t| W q ty- ttd| Y qw d S )Nz Failed to finalize handler: %s) r< rL remover call_endr r rA rC rN rP r3 r7 finalize_handlers s z,Init._do_handlers.<locals>.finalize_handlers) rB rE r sysr| insertr ContentHandlersr@ rC rD r ) r\ rZ c_handlers_listrQ rU cdirr rJ rG rH rR r[ r^ r3 rY r7 _do_handlers s0 # zInit._do_handlersc C s t jdd| jd t| jddr| | ntd W d n1 s'w Y t jdd| jd | d | W d n1 sFw Y t jd d | jd | d | W d n1 sew Y | t | j}t |d < | d|d< t |d< tj| jd|dd | jd}z tt|}W n8 ttfy } ztd|| W Y d }~d S d }~w tjt fy } ztd|| W Y d }~d S d }~ww |d |d< |d |d< tj||dd d S )Nzconsume-user-dataz reading and applying user-datar allow_userdataTz,allow_userdata = False: discarding user-datazconsume-vendor-dataz reading and applying vendor-datar zconsume-vendor-data2z!reading and applying vendor-data2r _docra rl r combined_cloud_configr r r zESkipping write of system_info/features to %s. Unable to read file: %szDSkipping write of system_info/features to %s. Invalid JSON found: %s) r$ rZ r[ r r r- _consume_userdatarC rD _consume_vendordatar` r< r= COMBINED_CLOUD_CONFIG_DOCrd r get_featuresr r rB r r r r IOErrorr jsonJSONDecodeErrorr" )r\ rQ combined_cloud_cfgjson_sensitive_file instance_jsonr r3 r3 r7 consume_data s~ zInit.consume_datac C s@ |dkr| j std dS d}n|dkr&| j s#td dS d}ntdtj| j| j g | j d d }|j |i }t |t sNd d i}t d || | d }| d d}t|sftd| dS t |trwtjd| dddd td|| |dkr| j }| } n | j }| } | j|| ||d dS )zH Consume the vendordata and run the part handlers on it r z no vendordata from datasourceN vendor_datar z no vendordata2 from datasource vendor_data2z>vendor_source arg must be either 'vendordata' or 'vendordata2'F)rB r, r r include_vendorenabledz$invalid %s setting. resetting to: %sdisabled_handlersz%s consumption is disabled.zUse of string 'z!' for 'vendor_data:enabled' fieldz23.1zUse boolean value instead.) deprecateddeprecated_version extra_messagez)%s will be consumed. disabled_handlers=%s)rU )r, r rC rD r r r r rV r- r: r dictr r is_truer! r deprecater r4 r r7 rd ) r\ vendor_sourcerQ cfg_name _cc_mergervdcfgrv no_handlersvendor_data_msgrb r3 r3 r7 ri l sd zInit._consume_vendordatac C s& | j d}| }| ||| dS )z@ Consume the userdata and run the part handlers TN)r, r r+ rd )r\ rQ user_data_msgrb r3 r3 r7 rh s zInit._consume_userdatac C s |r d|v r |d S |S )z Network configuration can be passed as a dict under a "network" key, or optionally at the top level. In both cases, return the config. networkr3 )r\ r- r3 r3 r7 _get_network_key_contents s z Init._get_network_key_contentsc C s. t j| jdd}t j|rd |fS tjt tj t tj d tj | jdi}| jr;t| jdr;| jj|tj < | jrC| jj}ntjj}|D ]9}t|tsWtd| qI||vrbtd| qI| || }t|rzt d| d |f S |r||f S qI| jddstd | j tj fS ) Nrx zupgraded-networkr r z7data source specifies an invalid network cfg_source: %sz;data source specifies an unavailable network cfg_source: %sz network config disabled by %sTzEmpty network config found) r{ r| r} rB rE r r* CMD_LINEr# read_kernel_cmdline_config INITRAMFSread_initramfs_configDS SYSTEM_CFGr- r: r, r r network_config_sourcesr DataSourcer rC r r r is_disabled_cfgrD rb generate_fallback_configFALLBACK)r\ disable_fileavailable_cfgsorder cfg_sourcencfgr3 r3 r7 _find_networking_config sR z Init._find_networking_configc C sT zt d| | jj| W d S ty) } z t d| W Y d }~d S d }~ww )Nz applying net config names for %sz Failed to rename devices: %s)rC rD rb networkingapply_network_config_namesr r )r\ r r r3 r3 r7 _apply_netcfg_names s zInit._apply_netcfg_namesc C s" t ddt| jddtfS )N Semaphorezsemaphore argsrw apply_network_config)r r FileSemaphoresrB r r) r_ r3 r3 r7 _get_per_boot_network_semaphore s z$Init._get_per_boot_network_semaphorec C s | }|jj|j S r^ )r semaphorehas_runargs)r\ rw r3 r3 r7 _network_already_configured s z Init._network_already_configuredc s ddl m}m} \}}|du rtd| dS fdd fdd}jdurD sD| sD tj sDt d | dS \}} | |r[|||j d d d d jj| | td ||| }z#|jj|j jj||dW d W S 1 sw Y W dS tjy } z td| W Y d}~dS d}~w ty tdj Y dS w )zApply the network config. Find the config, determine whether to apply it, apply it via the distro, and optionally bring it up r ) SchemaTypevalidate_cloudconfig_schemaNz network config is disabled by %sc s$ t j j| tjdo j| gS )N)r, r- r. r/ )rM r, r- r NETWORK update_metadata_if_supported) event_typer_ r3 r7 "event_enabled_and_metadata_updated( s zEInit.apply_network_config.<locals>.event_enabled_and_metadata_updatedc s o tjS r^ )r r BOOTr3 r r\ r3 r7 should_run_on_boot_event0 s z;Init.apply_network_config.<locals>.should_run_on_boot_eventzWNo network config applied. Neither a new instance nor datasource network update allowedFT)config schema_typestrict log_detailslog_deprecationsz5Applying network configuration from %s bringup=%s: %s)bring_upz@Unable to render networking. Network config is likely broken: %sz_distro '%s' does not implement apply_network_config. networking may not be configured properly.)cloudinit.config.schemar r r rC r r, r r BOOT_LEGACYrD r r NETWORK_CONFIGrb r wait_for_physdevsr r lockr r r RendererNotFoundErrorr NotImplementedErrorr ) r\ r r r r srcr rw r r3 r r7 r st ( zInit.apply_network_config)NN)Fr^ )r )D__name__ __module__ __qualname__r r r! r] r` propertyrb r- rd rB r r r staticmethodintr r rm r r{ r r r r r r r r r r r r r r rf r r r r r r r r r Handlerr+ r4 r7 rd r( rr ri rh r r r r r r* r r r r r r r3 r3 r3 r7 rN sn % 0 = v P N 6 rN rz c C s t tj| dS )Nz cloud.cfg)r read_confr{ r| r} )rz r3 r3 r7 read_runtime_configt s r r c C s, t jt t jt|dt| t gddS )Nr T)reverse)r r; get_builtin_cfgread_conf_with_confdr% r read_conf_from_cmdline)rz r r3 r3 r7 r x s r )Kr< rm loggingr{ r_ collectionsr contextlibr pathlibr typingr r r r r r r r cloudinitr r r r r r r r r r r r cloudinit.configr r cloudinit.eventr r r cloudinit.handlers.boot_hookr cloudinit.handlers.cloud_configr !cloudinit.handlers.jinja_templater cloudinit.handlers.shell_scriptr! ,cloudinit.handlers.shell_script_by_frequencyr" cloudinit.netr# cloudinit.reportingr$ cloudinit.settingsr% r& r' r( r) cloudinit.sourcesr* getLoggerr rC r+ rj r r{ r rM rN r! r r r3 r3 r3 r7 <module> s\ (8 E t