/usr/lib/python3/dist-packages/cloudinit/sources/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/sources/__pycache__/DataSourceMAAS.cpython-310.pyc (11918B)
o
thc; @ s d dl Z d dlZd dlZd dlZd dlmZmZmZ d dlm Z d dl
m Z e e
ZdZg dZG dd dejZG d d
d
eZd d Zd
d Zdd ZddeddfddZdd ZG dd deZG dd deZeej ffeej ej ffgZ dd Z e
dkrd d Z e dS dS ) N)sources
url_helperutil)KlibcNetworkConfigSource)NetworkConfigSourcez
2012-03-01))meta-data/instance-idr FF)meta-data/local-hostnamer FF)meta-data/public-keysr FT)zmeta-data/vendor-data vendor-dataTT) user-datar TTc @ sh e Zd ZdZdZdZdZdZdZdd Z e
dd Z d
d Z d d
Z
dd Zdd Zdd Zdd ZdS )DataSourceMAASz
DataSourceMAAS reads instance information from MAAS.
Given a config metadata_url, and oauth tokens, it expects to find
files under the root named:
instance-id
user-data
hostname
vendor-data
MAASNx 2 c C s: t j| ||| d | _tj|jd| _t| j | _
d S )Nmaas) r
DataSource__init__base_urlospathjoinseed_dirget_id_from_ds_cfgds_cfgid_hash)selfsys_cfgdistropaths r B/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceMAAS.pyr 2 s zDataSourceMAAS.__init__c C s | j s t| j| _ | j S N)
_oauth_helperget_oauth_helperr r r r r oauth_helper8 s zDataSourceMAAS.oauth_helperc C s t j| }d|| jf S )Nz%s [%s])r r __str__r )r rootr r r r& > s zDataSourceMAAS.__str__c
C s | j }z
| | jt| j W dS ty Y n ty- } z td| j| d }~ww |dd }|s8dS z| |sAW dS | |t
|| j j | j
dd W dS tyc ttd| Y dS w )NTz%s was malformed: %s metadata_urlF )read_file_or_urlr retriesz$Failed fetching metadata from url %s)r _set_datar read_maas_seed_dirMAASSeedDirNoneMAASSeedDirMalformedLOGwarninggetwait_for_metadata_serviceread_maas_seed_urlr% readurlr Exceptionr logexc)r mcfgexcurlr r r _get_dataB s>
zDataSourceMAAS._get_datac
C sp || _ |\}}}|| _|| _|r6z t|| _W d S ty5 } ztd| d | _W Y d }~d S d }~ww d S )Nz"Invalid content in vendor-data: %s) r userdata_rawmetadatar convert_vendordatavendordata_raw
ValueErrorr0 r1 )r r: dataudmdvder r r r, i s
zDataSourceMAAS._set_datac C s
d| j S )z/Return the subplatform metadata source details.z
seed-dir (%s))r r$ r r r _get_subplatformv s
z DataSourceMAAS._get_subplatformc C s | }|jdkr dS t }|d}d|tf }|g}| jj||j|jd\}}|r6t
d| t
|S t d|t t | t
|S )Nr F/z%s/%s/meta-data/instance-id)urlsmax_waittimeoutzUsing metadata source: '%s'z(Giving up on md from %s after %i seconds)get_url_paramsmax_wait_secondstime monotonicrstrip
MD_VERSIONr% wait_for_urltimeout_secondsr0 debugcriticalintbool)r r:
url_params starttime check_urlrH _responser r r r3 z s*
z(DataSourceMAAS.wait_for_metadata_servicec C s0 | j du rdS t|d| jfi }| j t|kS )a locally check if the current system is the same instance.
MAAS doesn't provide a real instance-id, and if it did, it is
still only available over the network. We need to check based
only on local resources. So compute a hash based on Oauth tokens.NF
datasource)r r get_cfg_by_pathdsnamer )r r ncfgr r r check_instance_id s
z DataSourceMAAS.check_instance_id)__name__
__module__ __qualname____doc__r] r r" url_max_wait url_timeoutr propertyr% r& r; r, rF r3 r_ r r r r r s
'
r c s0 e Zd ZejejejejfZ fddZ Z
S )DataSourceMAASLocalc s, t s td dS td t S )Nz No initramfs applicable configFz!Found initramfs applicable config)r
is_applicabler0 rS superr; r$ __class__r r r; s
z DataSourceMAASLocal._get_data) r` ra rb r CMD_LINE
SYSTEM_CFGDS INITRAMFSnetwork_config_sourcesr;
__classcell__r r rj r rg s rg c s* d}t fdd|D }tjdi |S )zReturn an oauth helper instance for values in cfg.
@raises ValueError from OauthUrlHelper if some required fields have
true-ish values but others do not.) consumer_keyconsumer_secret token_key token_secretc s g | ] }| |fqS r r2 ).0rcfgr r
s z$get_oauth_helper..Nr )dictr OauthUrlHelper)rz keyskwargsr ry r r# s r# c s4 d}d fdd|D }dt|d S )z;Given a config, generate a unique identifier for this node.)rr rt ru c s g | ]} |d qS ) rv )rw fr r r r{ s z&get_id_from_ds_cfg..zv1:zutf-8)r hashlibsha256encode hexdigest)r fieldsidstrr r r r s r c C sD | dr | dd } tj| rt| stdtd| d dS )Nfile:// z%s: not a directoryz file://%s)version)
startswithr r isdirlistdirr. r4 )seed_dr r r r- s
r- c C s |du rt j}| dr| dd } i }tD ]n\}}} }
|du r'd| |f } nd| ||f } z,t|} || ||| d}
|
rQ| rH|
j||< nt|
j||< nt
d| |
j W q t j y } z |j dkrs|
sst
d ||f ||j dkrz|W Y d}~qd}~ww t|| S )
a
Read the maas datasource at seed_url.
read_file_or_url is a method that should provide an interface
like util.read_file_or_url
Expected format of seed_url is are the following files:
* //meta-data/instance-id
* //meta-data/local-hostname
* //user-data
If version is None, then / will not be used.
NrG z%s/%sz%s/%s/%s)r+ rJ ssl_detailsz4Fetching from %s resulted in an invalid http code %si zMissing required %s: %s)r r* endswith DS_FIELDSr fetch_ssl_detailsokcontents
decode_binaryr0 r1 codeUrlErrorr/ check_seed_contents)seed_urlr* rJ r r r+ rC r _dictnamebinaryoptionalr: r resprE r r r r4 sJ
r4 c
C s i }g }t D ]5\}}}}|| vr|s|| qd|v r5|d\}} }
||vr,i ||< | | || |
< q| | ||< q|sDtd| |rNtd||f d} |drkt } tj|d| td} | | u rktd|d|d | fS )
zValidate if dictionary content valid as a return for a datasource.
Either return a (userdata, metadata, vendordata) tuple or
Raise MAASSeedDirMalformed or MAASSeedDirNone
rG z%s: no data files foundz%s: missing files %sNr
)defaultallowedz%vendor-data was not loadable as yaml.r meta-data) r append partitionr. r/ r2 objectr load_yaml)
contentseedretmissingspathdpath_binaryr top_pvd_dataerrr r r r s4
r c @ e Zd ZdS )r. Nr` ra rb r r r r r. 0 r. c @ r )r/ Nr r r r r r/ 4 r r/ c C s t | tS r! )r list_from_depends datasources)dependsr r r get_datasource_list@ s r __main__c s ddl } ddl}ddl}| jdd}|jddddd |jd d
d dd |jd d
d
dd |jddddd |jddddd |jdddtd |jddd}dD ]\}}|j||d}|jd d d dd qQ| }|j |j
|j |j d } |j
du rd!D ] }
d"|
d# } tj| rt| tjr|jd$| | |_
q||j
rt|j
} d%| v r| d% d& } | D ]}
|
| v r| |
du r| |
| |
< q|jdu rd'| v r| d' |_|jdu r|jd( |d) t| fd*d+fd,d- fd.d/ |jd0krc|jd1|j j }|jd d2ks |j d3r't |j\}}}n
t |j|j |d4d5\}}}t!d6 t!|du r@d7n|" t!d8 || t!d9 ||du r^d7 dS | dS |jd:krp|j dS |jd;kr|j#d2sd<|j |_ |j dS dS )=z
Call with single argument of directory or http or https url.
If url is given additional arguments are allowed, which will be
interpreted as consumer_key, token_key, token_secret, consumer_secret
r NzInteract with MAAS DS) descriptionz--configfilezspecify DS config file)metavarhelpr z--ckeykeyz the consumer key to auth withz--tkeyzthe token key to auth withz--csecsecretz the consumer secret (likely '')r z--tsecz the token secret to auth withz--apiverr z the apiver to use ( can be used) subcommandssubcmd)titledest))crawlzcrawl the datasource)r2 z do a single GET of provided url)
check-seedzread and verify seed at url)r r: zthe datasource url?)r nargsr )rr rt ru rs )91_kernel_cmdline_url 90_dpkg_maasz/etc/cloud/cloud.cfg.d/z.cfgzUsed config in %s.
r[ r
r( z)Must provide a url or a config with url.
r) c s j | ddjS )Nr) )r+ )r5 r r: )r% r r geturl s zmain..geturlc s t d| | f d S )Nz == %s ==
%s
)printdecoder )r r r printurl s zmain..printurlc sv | dr5| D ]%}| dr d| |f q
|dkr* d| df q
d| |f q
d S | d S )NrG z%s%sr z
meta-data/)r r
splitlines)r: line)r r r r r r s
zmain..crawlr zChecking seed at %s
rG r )r r* r+ z=== user-data ===zN/Az=== meta-data ===z=== vendor-data ===r2 r z%s/)$argparsepprintsysArgumentParser add_argumentrP add_subparsers
add_parser
parse_argsckeytkeytseccsecconfigr r existsaccessR_OKstderrwriter read_confr~ r: exitr# r r5 r r- r4 apiverr r r )r r r parsersubcmdsnamer r argscredsfnamefpathrz r r5 userdatar= rD r )r r r% r r mainF s
" r )!r loggingr rM cloudinitr r r cloudinit.net.cmdliner cloudinit.sourcesr getLoggerr` r0 rP r r r rg r# r r- r4 r r6 r. r/ DEP_FILESYSTEM DEP_NETWORKr r r r r r r sF
:'