U L¬÷d„ã @sJ ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZmZddlmZddl m!Z!m"Z"ddlm#Z#m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/dd l0m1Z1dd l2m3Z3m4Z4dd l2m5Z6dd l2m7Z7m8Z8m9Z9m:Z:m;Z;mZ>dd l?m@Z@daAe6 BeC¡ZDe jEdiZFdejGejHZIdZJdZKdd„ZLe#ƒd}dd„ƒZMe#ƒd~dd„ƒZNddd„ZOd€dd„ZPeQeQdœdd„ZRd d!„ZSGd"d#„d#ƒZTGd$d%„d%eUƒZVGd&d'„d'eUƒZWd(d)„ZXdd*d+„ZYd‚d,d-„ZZdƒd.d/„Z[d„d1d2„Z\d…d3d4„Z]dd5œe*d6œd7d8„Z^d9d:„Z_d;d<„Z`d=d>„Zad†d@dA„ZbdBdC„ZcedeedDœdEdF„ZfdGdH„Zgd?d?de6jhd?fdIdJ„Zie#ƒdKdL„ƒZje#ƒdMdN„ƒZke#ƒdOdP„ƒZle#ƒdQdR„ƒZme#ƒdSdT„ƒZne#ƒdUdV„ƒZod‡dXdY„ZpdˆdZd[„Zqd‰d\d]„ZrdŠd^d_„Zse#ƒd`da„ƒZtdbdc„Zue#ƒddde„ƒZvd‹dfdg„ZwdŒdhdi„Zxdjdk„Zyddldm„ZzdŽe.e,eednœdodp„Z{ej|dqdr„ƒZ}ej|dsdt„ƒZ~dudv„Zdwdx„Z€dd{d|„Zdd}d~„Z‚deeffdd€„Zƒd‘d‚dƒ„Z„dd5œeed6œd„d…„Z…dd5œeed6œd†d‡„Z†d’dˆd‰„Z‡d“dŠd‹„ZˆdŒd„Z‰edŽddd‘gƒZŠd”d’d“„Z‹d•d•d–„ZŒed6œd—d˜„ZŽd™dš„Zd›dœ„Zddž„Z‘dŸd „Z’d¡d¢„Z“d–d¤d¥„Z”d—d¦d§„Z•d˜d¨d©„Z–d™dªd«„Z—dšd¬d­„Z˜d›d®d¯„Z™d°d±„Zšdœd²d³„Z›e#ƒd´dµ„ƒZœd¶d·„Zed6œd¸d¹„Zždd»d¼„ZŸdžd½d¾„Z dŸd¿dÀ„Z¡dÁd„Z¢dÃdÄ„Z£dÅdÆ„Z¤d ededdÇœdÈdÉ„Z¥e j¦eQdÊœdËdÌ„Z§dÍd΄Z¨dÏdЄZ©dÑdÒ„Zªd¡dÔdÕ„Z«eeffdÖdׄZ¬dØdÙ„Z­d¢dÚdÛ„Z®ej|dÜdÝ„ƒZ¯dÞdß„Z°d£dàdá„Z±dâdã„Z²dädå„Z³d¤dædç„Z´dèdé„Zµdêdë„Zdìdí„Z¶e#ƒdîdZ·dðdñ„Z¸dòdó„Z¹d¥dWdõœeºeddöœd÷dø„Z»dùdú„Z¼dûdü„Z½dýdþ„Z¾edeºdÿœdd„Z¿edeºdœdd„ZÀededdœdd„ZÁededdœdd„ZÂede+edd œd d „ZÃd¦d?ddd œdd„ZÄdd„ZÅd§dd„ZÆdd„ZÇd¨dd„ZÈd©dd„ZÉdd„ZÊdd„ZËd d!„ZÌd"d#„ZÍe#ƒd$d%„ƒZÎd&d'„ZÏdªd)d*„ZÐd+d,„ZÑd-d.„ZÒd/d0„ZÓeDdWfd1d2„ZÔd3d4„ZÕd5d6„ZÖd7d8„Z×d9d:„ZØd;d<„ZÙd«d=d>„ZÚeDdWfd?d@„ZÛededAœdBdC„ZÜe/dDƒZÝd¬e(dEeÝfeÝdFœdGdH„ZÞdIdJ„Zßdde jàjEfdKdL„Zád­dNdO„ZâdPdQ„Zãd®dRdS„ZädTdU„Zåd¯dVdW„ZædXdY„ZçdZd[„Zèd°d\d]„Zéd±d_d`„Zêdadb„Zëd²dcdd„Zìdedf„Zídgdh„Zîdidj„Zïd³dmdn„Zðe$Gdodp„dpedpdqdrdsdtgƒƒƒZñddzduœedede-edeºdvœdwdx„Zòdzdyœededeºdzœd{d|„ZódS(´éN)Ú b64decode)ÚdequeÚ namedtuple)Úsuppress)ÚEACCESÚENOENT)Ú lru_cacheÚtotal_ordering)ÚPath)ÚCallableÚDequeÚDictÚListÚMappingÚOptionalÚSequenceÚTypeVar)Úparse)ÚfeaturesÚimporter)Úlog)ÚmergersÚnetÚsafeyamlÚsubpÚ temp_utilsÚ type_utilsÚ url_helperÚversion)Ú CFG_BUILTINÚ_z_-.())ÚtrueÚ1ZonZyes)ZoffÚ0ZnoZfalsecCs"tttt ¡j d¡dd…ƒƒS)NÚ.é)ÚtupleÚmapÚintÚosÚunameÚreleaseÚsplit©r-r-ú0/usr/lib/python3/dist-packages/cloudinit/util.pyÚkernel_versionQsr/cCstjddgd|d}|j ¡S)z´Return the sanitized string output by `dpkg --print-architecture`. N.B. This function is wrapped in functools.lru_cache, so repeated calls won't shell out every time. Zdpkgz--print-architectureT©ÚcaptureÚtarget)rÚstdoutÚstrip)r2Úoutr-r-r.Úget_dpkg_architectureUs ÿr6c sÞdddddœ}i‰z€tjddgd|d }|j ¡D],}| d ¡\}}}||kr2| ¡ˆ||<q2‡fd d „| ¡Dƒ}t|ƒrt d d  |¡¡WnFtj k rØ}z&t d|¡t dd„| ¡Dƒƒ‰W5d}~XYnXˆS)NÚcodenameZ descriptionÚidr+)ZCodenameZ DescriptionzDistributor IDZReleaseÚ lsb_releasez--allTr0ú:csg|]}|ˆkr|‘qSr-r-)Ú.0Úk©Údatar-r.Ú rszlsb_release..z.Missing fields in lsb_release --all output: %sú,z#Unable to get lsb_release --all: %scss|]}|dfVqdS)Z UNAVAILABLENr-©r;Úvr-r-r.Ú {szlsb_release..) rr3Ú splitlinesÚ partitionr4ÚvaluesÚlenÚLOGÚwarningÚjoinÚProcessExecutionErrorÚdict) r2Zfmapr5ÚlineÚfnamer ÚvalÚmissingÚerrr-r=r.r9bs,üþ (r9úutf-8cCst|tƒr|S| |¡S©N)Ú isinstanceÚstrÚdecode)ÚblobÚencodingr-r-r.Ú decode_binary€s rYcCst|tƒr|S| |¡SrS)rTÚbytesÚencode)ÚtextrXr-r-r.Ú encode_text‡s r])r>ÚreturncCsHt|tƒstdt|ƒƒ‚zt|ddWStjk rB|YSXdS)z¼base64 decode data If data is base64 encoded bytes, return b64decode(data). If not, return data unmodified. @param data: data as bytes. TypeError is raised if not bytes. zdata is '%s', expected bytesT)ZvalidateN)rTrZÚ TypeErrorÚtyperÚbinasciiÚErrorr=r-r-r.Úmaybe_b64decodeŽs  rccCsP|jdd}| ¡dkrLt|tƒrL| ¡}|r<|jr<|j}nd}| |d¡S|S)NT©rVr\rRÚsurrogateescape)Z get_payloadZget_content_maintyperTrZZ get_charsetZ input_codecrV)ÚpartZ cte_payloadÚcharsetrXr-r-r.Úfully_decoded_payloadžs ÿ  rhc@s&eZdZd dd„Zdd„Zdd„ZdS) Ú SeLinuxGuardFcCs<zt d¡|_Wntk r*d|_YnX||_||_dS)NÚselinux)rÚ import_modulerjÚ ImportErrorÚpathÚ recursive)Úselfrmrnr-r-r.Ú__init__²s  zSeLinuxGuard.__init__cCs|jr|j ¡rdSdSdS©NTF)rjÚis_selinux_enabled©ror-r-r.Ú __enter__¼szSeLinuxGuard.__enter__c CsÎ|jr|j ¡sdStj |j¡s&dStj |j¡}z"t |¡}|j ||tj ¡Wnt k rlYdSXt   d||j ¡z|jj||j dWn4t k rÈ}zt  d||j |¡W5d}~XYnXdS)Nz,Restoring selinux mode for %s (recursive=%s)©rnz,restorecon failed on %s,%s maybe badness? %s)rjrrr)rmÚlexistsÚrealpathÚlstatZ matchpathconÚstatÚST_MODEÚOSErrorrHÚdebugrnZ restoreconrI)roZ excp_typeZ excp_valueZexcp_tracebackrmZstatsÚer-r-r.Ú__exit__Âs0 ýüzSeLinuxGuard.__exit__N)F)Ú__name__Ú __module__Ú __qualname__rprtr~r-r-r-r.ri±s ric@s eZdZdS)ÚMountFailedErrorN©rr€rr-r-r-r.r‚ßsr‚c@s eZdZdS)ÚDecompressionErrorNrƒr-r-r-r.r„ãsr„c Ostt ¡}|dkr\z|||Žt d¡Wqptk rXttdt |¡ƒt d¡YqpXnt d|t |¡¡dS)Nrz&Failed forking and calling callback %séz(Forked child %s who will run callback %s) r)ÚforkÚ_exitÚ ExceptionÚlogexcrHrÚobj_namer|)Zchild_cbÚargsÚkwargsZfidr-r-r.Úfork_cbçs" ýýrcCsBt|tƒr|dkSt}|r&t|ƒ|}t|ƒ ¡ ¡|kr>dSdSrq)rTÚboolÚ TRUE_STRINGSÚlistrUÚlowerr4©rOÚaddonsZ check_setr-r-r.Úis_trueüs  r”cCsBt|tƒr|dkSt}|r&t|ƒ|}t|ƒ ¡ ¡|kr>dSdS)NFT)rTrŽÚ FALSE_STRINGSrrUr‘r4r’r-r-r.Úis_falses  r–cCs |sdSt|tƒr|St||ƒS)NF)rTrŽr”)rOr“r-r-r.Útranslate_bools  r—é cs8t ¡‰ˆstjtj‰d ‡‡fdd„td|ƒDƒ¡S)NÚcsg|]}ˆ ˆ¡‘qSr-)Zchoice)r;Z_x©ÚrÚ select_fromr-r.r?!szrand_str..r)ÚrandomZ SystemRandomÚstringÚ ascii_lettersÚdigitsrJÚrange)Ústrlenrœr-ršr.Úrand_strs r£cCs*|sd}tddd|}||krq&q|S)Nr™é)r¢r )r£)Z dictionaryZpostfixZnewkeyr-r-r.Ú rand_dict_key$s r¥©Úinstance_data_file©r^c Csìddlm}m}m}z t|ƒ}Wn:tk rZ}z|jtkrHiWY¢S‚W5d}~XYnX|rÔtj   |¡rÔz||||ƒ}t   d||¡WnH|k ržYn6|k rÒ}zt   d||t|ƒ¡W5d}~XYnX|dkràiSt|idS)z>Read a yaml config with optional template, and convert to dictr)ÚJinjaLoadErrorÚ NotJinjaErrorÚrender_jinja_payload_from_fileNz?Applied instance data in '%s' to configuration loaded from '%s'z:Could not apply Jinja template '%s' to '%s'. Exception: %s©Údefault)Z!cloudinit.handlers.jinja_templater©rªr«Ú load_fileÚIOErrorÚerrnorr)rmÚexistsrHr|rIÚreprÚ load_yaml)rNr§r©rªr«Z config_filer}r-r-r.Ú read_conf.s>   ýüûr´cGs tt|ŽƒSrS)ÚsortedÚ uniq_merge)Úlistsr-r-r.Úuniq_merge_sorted`sr¸cGsFg}|D]4}t|tƒr2| ¡ d¡}dd„|Dƒ}| |¡qt|ƒS)Nr@cSsg|] }|r|‘qSr-r-)r;Úar-r-r.r?rszuniq_merge..)rTrUr4r,ÚextendÚ uniq_list)r·Z combined_listÚa_listr-r-r.r¶ls  r¶cCs`t ¡D]\}}| ||¡}qg}|D]}|tkr&| |¡q&|D]}| |d¡}qB| ¡}|S)Nr™)ÚFN_REPLACEMENTSÚitemsÚreplaceÚ FN_ALLOWEDÚappendr4)Úfnr<rBZremovalsr-r-r.Úclean_filenamews rÃTc Cs®zht t|ƒ¡}t t ddd|¡¡:}|rFt| ¡ƒW5QR£WS| ¡W5QR£WSW5QRXWn@t k r¨}z"|rŠ|WY¢St t |ƒƒ|‚W5d}~XYnXdS)NÚrbr…) ÚioÚBytesIOr]Ú contextlibÚclosingÚgzipZGzipFilerYÚreadrˆr„rU)r>ÚquietrVÚbufZghr}r-r-r.Ú decomp_gzip„s$ rÍcCs~|sdS| dd¡}|d ¡}t|ƒdkr:|d ¡}nd}|rV|dksV| ¡dkrZd}|rr|dksr| ¡dkrvd}||fS)N)NNr:r…rr%z-1Znone)r,r4rGr‘)Zug_pairZ ug_partedÚuÚgr-r-r.Úextract_usergroup”s   rÐ)Úroot_dirr^cCshtƒ}t tj |d¡¡D]H}tj |¡s,qtj |¡dd…}| ¡}|r| d¡dkr|||<q|S)Nz*.pyréýÿÿÿr$éÿÿÿÿ) rLÚglobr)rmrJÚisfileÚbasenamer4Úfind)rÑÚentriesrNÚmodnamer-r-r.Úget_modules_from_dir¤s  rÚc Cs,t|dƒ}| |¡| ¡W5QRXdS)NÚw)ÚopenÚwriteÚflush)Úconpathr\Zwfhr-r-r.Úwrite_to_console°s  ràc CsÂ|rtj |¡|rŒd}d}tj |¡rxzt||ƒd}Wn<tk rvd}tj |›d¡|rr|  t j |¡YnX|rŒ|sŒtj |¡|r¾|ddkr²|  ||dd…¡n |  ||¡dS)Nz /dev/consoleFTzFailed to write to /dev/consoleÚ rÓ) ÚsysÚstderrrÝr)rmr±ràr{r3rÚloggingZWARNING) r\ZconsolerãrZ log_levelZfallback_to_stdoutrßZwriting_to_console_workedZ console_errorr-r-r.Ú multi_log¶s(     råcCs dt ¡kS)NZLinux©ÚplatformÚsystemr-r-r-r.Úis_LinuxâsrécCs$dt ¡krdSt ¡dkr dSdS)NZBSDTZ DragonFlyFrær-r-r-r.Úis_BSDçs   rêcCstƒddkS)NÚvariantÚfreebsd©Ú system_infor-r-r-r.Ú is_FreeBSDðsrïcCstƒddkS)NrëÚ dragonflyrír-r-r-r.Úis_DragonFlyBSDõsrñcCstƒddkS)NrëÚnetbsdrír-r-r-r.Ú is_NetBSDúsrócCstƒddkS)NrëÚopenbsdrír-r-r-r.Ú is_OpenBSDÿsrõFcCs||kr |St||ƒSrS)r—©ÚyobjÚkeyr­r-r-r.Úget_cfg_option_boolsrùcCs*||kr |S||}t|tƒs&t|ƒ}|SrS)rTrU)r÷rør­rOr-r-r.Úget_cfg_option_str s  rúcCstt|||dƒS)Nr¬)r(rúrör-r-r.Úget_cfg_option_intsrûcCsª|sd}tj |¡siSt|ƒ}d}d|kr0d}t ||¡}|r¦| ¡}d|dkr`|d|d<|d ¡ d¡d|d<|dd krŽd |d<|d|d |dd œSiS) z¦Return a dictionary of distro info fields from /etc/redhat-release. Dict keys will align with /etc/os-release keys: ID, VERSION_ID, VERSION_CODENAME z/etc/redhat-releasezA(?P.+) release (?P[\d\.]+) \((?P[^)]+)\)Z Virtuozzoz)(?P.+) release (?P[\d\.]+)Únamer7z linuxrzred hat enterpriseÚredhatr)ÚIDÚ VERSION_IDÚVERSION_CODENAME) r)rmr±r®ÚreÚmatchÚ groupdictr‘rE)Z release_fileZredhat_releaseZ redhat_regexrÚgroupr-r-r.Ú_parse_redhat_releases, ÿ    ýrc Cspd}d}d}i}d}tj d¡r,ttdƒƒ}|s:d}tƒ}|rê| dd¡}| dd¡}d|ksfd|krpt ¡}nl|d ks€|d krŽ| d d¡}nN|d kr¨|s¨| d d¡}n4| d d¡}|sÜt   d| dd¡¡}|rÜ|  ¡d}|dkrèd}n|t ƒrt  ¡ ¡}t ¡}n^d}z(z t ¡}Wntk r0YnXW5d}|D]}|r>d}q>|s`t d¡X|S|||fS)Nr™Fú/etc/os-releaseTrþrÿÚslesÚsuseÚalpineÚphotonZ PRETTY_NAMEÚ virtuozzorz[^ ]+ \((?P[^)]+)\)ZVERSIONr7Úrhelrý)r™r™r™r…zPUnable to determine distribution, template expansion may have unexpected results)r)rmr±Úload_shell_contentr®rÚgetrçÚmachinerrrrêrèr‘r+rHrIÚdistrˆ) Z distro_nameZdistro_versionZflavorZ os_releaseZos_release_rhelrrÚfoundÚentryr-r-r.Úget_linux_distro?s^        þ     ÿrcCsv|d ¡}d}|dkrf|dd ¡}|dkr6|}qr|dkrDd}qr|d krRd }qr|d kr`d }qrd}n |d krr|}|S)NrèÚunknownZlinuxrr)Z almalinuxr ZarchZcentosZ cloudlinuxZdebianZ eurolinuxZfedoraZmarinerZ miraclelinuxZ openeulerZ opencloudosZ openmandrivar r ZrockyrZ tencentosr )ÚubuntuZ linuxmintZmintrrýr )Zopensusez opensuse-leapzopensuse-microoszopensuse-tumbleweedZsle_hpcz sle-microrr)ZwindowsÚdarwinrìròrôrð)r‘)ÚinforèrëZ linux_distr-r-r.Ú _get_variant}s   rcCs<t ¡t ¡t ¡t ¡tt ¡ƒtƒdœ}t|ƒ|d<|S)N)rçrèr+Úpythonr*rrë)rçrèr+Zpython_versionrr*rr)rr-r-r.rîµs ú rîcCsX||kr |S||dkrgS||}t|tƒr@dd„|Dƒ}|St|tƒsRt|ƒ}|gS)aª Gets the C{key} config option from C{yobj} as a list of strings. If the key is present as a single string it will be returned as a list with one string arg. @param yobj: The configuration object. @param key: The configuration key to get. @param default: The default to return if key is not found. @return: The configuration option as a list of strings or default if key is not found. NcSsg|]}|‘qSr-r-rAr-r-r.r?Õsz'get_cfg_option_list..)rTrrU)r÷rør­rOZcvalr-r-r.Úget_cfg_option_listÃs    rcCs>t|tƒr| d¡}|}|D]}||kr0|S||}q|S)a×Return the value of the item at path C{keyp} in C{yobj}. example: get_cfg_by_path({'a': {'b': {'num': 4}}}, 'a/b/num') == 4 get_cfg_by_path({'a': {'b': {'num': 4}}}, 'c/d') == None @param yobj: A dictionary. @param keyp: A path inside yobj. it can be a '/' delimited string, or an iterable. @param default: The default to return if the path does not exist. @return: The value of the item at keyp." is not found.ú/)rTrUr,)r÷Zkeypr­ZcurÚtokr-r-r.Úget_cfg_by_pathÞs   rcCs t||ƒ\}}t||ƒ||fSrS)Úget_output_cfgÚredirect_output)ÚcfgÚmodeÚoutfmtÚerrfmtr-r-r.Ú fixup_outputös r$c Cs¤ttj d¡ƒrt d¡dS|s(tj}|s2tj}dd„}|rþt d||¡|  dd¡\}}|dksl|d krˆd }|dkr|d }t ||ƒ}n0|d kr¬t j |d t j |d} | j}n td|ƒ‚|rÐt | ¡| ¡¡||krþt d||¡t | ¡| ¡¡dS|r t d||¡|  dd¡\}}|dks6|d krTd }|dkrHd }t ||ƒ}n2|d krzt j |d t j |d} | j}n td|ƒ‚|r t | ¡| ¡¡dS)NZ_CLOUD_INIT_SAVE_STDOUTz5Not redirecting output due to _CLOUD_INIT_SAVE_STDOUTcSs>t d¡zt d¡j}Wntk r.Yn Xt |¡dS)a«Reconfigure umask and group ID to create output files securely. This is passed to subprocess.Popen as preexec_fn, so it is executed in the context of the newly-created process. It: * sets the umask of the process so created files aren't world-readable * if an adm group exists in the system, sets that as the process' GID (so that the created file(s) are owned by root:adm) éZadmN)r)ÚumaskÚgrpÚgetgrnamÚgr_gidÚKeyErrorÚsetgid)Zgroup_idr-r-r.Úset_subprocess_umask_and_gids z5redirect_output..set_subprocess_umask_and_gidzRedirecting %s to %sú r…ú>ú>>ÚabÚwbú|T)ÚshellÚstdinZ preexec_fnz"Invalid type for output format: %sz!Invalid type for error format: %s)r”r)ÚenvironrrHr|râr3rãr,rÜÚ subprocessÚPopenÚPIPEr4r_Údup2Úfileno) r"r#Zo_outZo_errr,r!ÚargZowithZnew_fpÚprocr-r-r.r sd  ü    ü r)Úsourcesr^cCsR|rtt|ƒƒ}i}|D]4}|rt |¡}|s6t ¡}t |¡}| ||¡}q|S)aFMerge multiple dicts according to the dict merger rules. Dict merger rules can be found in cloud-init documentation. If no mergers have been specified, entries will be recursively added, but no values get replaced if they already exist. Functionally, this means that the highest priority keys must be specified first. Example: a = { "a": 1, "b": 2, "c": [1, 2, 3], "d": { "a": 1, "b": 2, }, } b = { "a": 10, "c": [4], "d": { "a": 3, "f": 10, }, "e": 20, } mergemanydict([a, b]) results in: { 'a': 1, 'b': 2, 'c': [1, 2, 3], 'd': { 'a': 1, 'b': 2, 'f': 10, }, 'e': 20, } )rÚreversedrZdict_extract_mergersZdefault_mergersZ constructÚmerge)r=ÚreverseZ merged_cfgr Zmergers_to_applyZmergerr-r-r.Ú mergemanydictYs*   rAc cs.t ¡}zt |¡|VW5t |¡XdSrS)r)ÚgetcwdÚchdir)ZndirZcurrr-r-r.rC‘s   rCc cs&t |¡}z |VW5t |¡XdSrS)r)r&)Zn_mskÚoldr-r-r.r&›s  r&cCsdj||d|dS)Nz{0:{fill}{align}{size}}ú^)ÚfillZalignÚsize)Úformat)r\rFZmax_lenr-r-r.Úcenter¤s ÿrIcCst d|¡t |¡dS)NzRecursively deleting %s)rHr|ÚshutilZrmtree©rmr-r-r.Údel_dirªs rLr™éc Csrz0t|||ƒ\}}}||d<||d<||d<WdStjk rl}z|jtjkrZWY¢ dS‚W5d}~XYnXdS)Nú user-dataú vendor-dataú meta-dataTF)Ú read_seededrÚUrlErrorÚcodeZ NOT_FOUND)rFÚbaseÚextÚtimeoutÚmdÚudÚvdr}r-r-r.Úread_optional_seed³s  rZcCsæi}|sddg}n(tj | d¡d¡tj | d¡d¡g}t|ƒ}dd„|Dƒ}d}|D],}tj tj |d¡¡rXtj |d¡}q†qXd}|D],}tj tj |d¡¡rŽtj |d¡}q¼qŽ|rÖ|rÖ||d <||d <n |râ||d <|S) Nz/var/lib/cloud/data/sslz /var/lib/cloud/instance/data/sslr>ZsslcSs g|]}|rtj |¡r|‘qSr-)r)rmÚisdir)r;Údr-r-r.r?Îs z%fetch_ssl_details..zcert.pemzkey.pemÚ cert_fileÚkey_file)r)rmrJZ get_ipath_curZ get_cpathr¶rÕ)ÚpathsZ ssl_detailsZssl_cert_pathsr]r\r^r-r-r.Úfetch_ssl_detailsÀs4þþ r`c Cs |}t|ƒ}z\t dt|ƒ|¡t |¡}|dkrBt d¡|}n t||ƒsbtd|t  |¡fƒ‚|}Wn²tj tt fk r}zŠd}d}t |dƒr¬t |dƒr¬t |dƒ}nt |dƒrÊt |dƒrÊt |dƒ}|rð|dj|jd|jd|d 7}n|d j|d 7}t |¡W5d}~XYnX|S) NzKAttempting to load yaml from string of length %s with allowed root types %sz-loaded blob returned None, returning default.z2Yaml load allows %s root types, but got %s insteadzFailed loading yaml blobZ context_markZ problem_markz5. Invalid format at line {line} column {col}: "{err}"r…)rMÚcolrQz. {err})rQ)rYrHr|rGrÚloadrTr_rrŠZ YAMLErrorÚ ValueErrorÚhasattrÚgetattrrHrMÚcolumnrI)rWr­ZallowedZloadedZ convertedr}ÚmsgZmarkr-r-r.r³ásJü    ÿÿ  ÿÿr³é c CsV| d¡dkr@| dd|¡}| dd|¡}| dd|¡}nTtjrj|ddkrjt |¡jdkrj|d7}d |d|f}d |d|f}d |d|f}tj|||d }d} |  ¡rÂt t |j ƒid } tj|||d } d} |   ¡rä| j } d} ztj|||d } Wn2tj k r.}zt d |¡W5d}~XYnX|   ¡rB| j } n t d ¡| | | fS)Nz%srrNrOrPrÓrr™z%s%s%s)rVÚretriesr¬z!Error in vendor-data response: %szError in vendor-data response)r×r¿rZ%NOCLOUD_SEED_URL_APPEND_FORWARD_SLASHrÚurlparseZqueryrZread_file_or_urlÚokr³rYÚcontentsrRrHr|)rTrUrVriZ file_retriesZud_urlZvd_urlZmd_urlZmd_resprWZud_resprXrYZvd_respr}r-r-r.rQ sNÿÿÿ   rQc s¤tt ˆ¡dd}dd„|Dƒ}‡fdd„|Dƒ}g}|D]`}z | ttj ˆ|¡|d¡Wq:tk r˜}z|jt krˆt   dˆ|¡W5d}~XYq:Xq:t |ƒS) zRead configuration directory.T©r@cSsg|]}| d¡r|‘qS)z.cfg)Úendswith©r;Úfr-r-r.r?:s zread_conf_d..cs&g|]}tj tj ˆ|¡¡r|‘qSr-)r)rmrÕrJro©Úconfdr-r.r?=sr¦z,REDACTED config part %s/%s for non-root userN) rµr)ÚlistdirrÁr´rmrJr{r°rrHrIrA)rrr§ZconfsÚcfgsrÂr}r-rqr.Ú read_conf_d4s( þÿ ÿruc Csðtƒ}i}zt||d}Wn8tk rR}z|jtkrBt d|¡W5d}~XYn X| |¡d}d|kr¦|d}|rÂt|t ƒs˜t d|t   |¡fƒ‚qÂt |ƒ  ¡}ntj |›d¡rÂ|›d}|rètj |¡rèt||d}| |¡t|ƒS)aRead yaml file along with optional ".d" directory, return merged config Given a yaml file, load the file as a dictionary. Additionally, if there exists a same-named directory with .d extension, read all files from that directory in order and return the merged config. The template file is optional and will be applied to any applicable jinja file in the configs. For example, this function can read both /etc/cloud/cloud.cfg and all files in /etc/cloud/cloud.cfg.d and merge all configs into a single dict. r¦z)REDACTED config part %s for non-root userNr™Zconf_dz8Config file %s contains 'conf_d' with non-string type %sz.d)rr´r{r°rrHrIrÁrTrUr_rrŠr4r)rmr[ruÚ appendleftrA)Zcfgfiler§rtr r}rrZ confd_cfgr-r-r.Úread_conf_with_confdRs2     ÿÿ   rwcCstt|dƒS)N©Úcmdline)r³Úread_cc_from_cmdlinerxr-r-r.Úread_conf_from_cmdline~sr{c Cs¤|dkrtƒ}d}d}t|ƒ}t|ƒ}t|ƒ}g}| |¡}|dkrš| |||¡}|dkr`|}| t ||||… ¡¡ dd¡¡| |||¡}q, , (str, str, bool). Values can be none when metadata_only is True and no cfg or metadata provides hostname info. is_default is a bool and it's true only if hostname is localhost and was returned by util.get_hostname() as a default. This is used to differentiate with a user-defined localhost hostname. Fr…r„r$rNT)r…Ú metadata_only)r‡)rúr,r×Ú get_hostnamer„rƒ)r Zcloudr‡r†r…r„r-r-r.Úget_hostname_fqdn³s"ÿ ÿ r‰ú /etc/hostscCs’d}ztt|ƒ ¡D]b}| d¡}|dkr4|d|…}| ¡}|sBq| ¡}t|ƒdkrXq||dd…kr|d}qvqWntk rŒYnX|S)a¤ For each host a single line should be present with the following information: IP_address canonical_hostname [aliases...] Fields of the entry are separated by any number of blanks and/or tab characters. Text from a "#" character until the end of the line is a comment, and is ignored. Host names may contain only alphanumeric characters, minus signs ("-"), and periods ("."). They must begin with an alphabetic character and end with an alphanumeric character. Optional aliases provide for name changes, alternate spellings, shorter hostnames, or generic hostnames (for example, localhost). Nú#rér%r…)r®rDr×r4r,rGr¯)r„Úfilenamer…rMZhashposÚtoksr-r-r.Úget_fqdn_from_hostsÞs$    rc CsDt |¡}|j}tdkrÂtƒ}d}i}|D]‚}z`t |dddtjtj¡}g||<|D]6\}} } } } ||  d| | df¡|  | d¡qTWq*tj tj fk rªYq*Xq*|a|rÂt  d|¡z\ttƒ(t |j d¡¡rðW5QR£WdSW5QRXt |d¡}|ddd} | tkWStj tj fk r>Yd SXdS) aîdetermine if a url's network address is resolvable, return a boolean This also attempts to be resilent against dns redirection. Note, that normal nsswitch resolution is used here. So in order to avoid any utilization of 'search' entries in /etc/resolv.conf we have to append '.'. The top level 'invalid' domain is invalid per RFC. And example.com should also not exist. The '__cloud_init_expected_not_found__' entry will be resolved inside the search list. N)zdoes-not-exist.example.com.zexample.invalid.Z!__cloud_init_expected_not_found__rz%s: %szdetected dns redirection: %sz[]TéF)rrjr„Ú_DNS_REDIRECT_IPÚsetÚsocketZ getaddrinfoZ SOCK_STREAMZ AI_CANONNAMErÁÚaddZgaierrorÚerrorrHr|rrcrZ is_ip_addressZnetlocr4)ÚurlZ parsed_urlrüZbadipsZbadnamesZ badresultsZinameÚresultZ_famZ_stypeZ_protoZcnameZsockaddrZaddrr-r-r.Ú is_resolvablesD ÿ    r˜cCs t ¡}|SrS)r“Z gethostname)r„r-r-r.rˆ9srˆcCs.zt |¡dWStjk r(YdSXdS©Nr)r“Ú gethostbyaddrZherror)Zipr-r-r.rš>sršcCsttjd|t|fdS)z5determine if this url is resolvable (existing or ip).zResolving URL: )ÚlogfuncrgÚfuncr‹)Úlog_timerHr|r˜)r–r-r-r.Úis_resolvable_urlEs üržc Cs^|dkr dSt d|¡|D]<}z"t|ƒr@t d|¡|WSWqtk rVYqXqdS)zc Search through a list of mirror urls for one that works This needs to return quickly. Nz%search for mirror in candidates: '%s'zfound working mirror: '%s')rHr|ržrˆ)Z candidatesZcandr-r-r.Úsearch_for_mirrorOs  rŸc CsDttj d¡ƒrdSttjƒ}t | ¡tj  ¡¡W5QRXdS)zú reopen stdin as /dev/null so even subprocesses or other os level things get /dev/null as input. if _CLOUD_INIT_SAVE_STDIN is set in environment to a non empty and true value then input will not be closed (useful for debugging). Z_CLOUD_INIT_SAVE_STDINN) r”r)r5rrÜÚdevnullr9r:râr4)Úfpr-r-r.Ú close_stdinbs r¢ÚdevicecCsvg}|st d¡t d¡S| d¡rL| d¡}dd„d|d|fDƒ}n&|dkr`t d¡}n|d krrt d¡}|S) Nz/dev/msdosfs/*z/dev/iso9660/*úLABEL=cSsg|]}tj |¡r|‘qSr-©r)rmr±)r;Úpr-r-r.r?xs þz*find_devs_with_freebsd..z /dev/msdosfs/z /dev/iso9660/ú TYPE=vfatú TYPE=iso9660)rÔÚ startswithr})ÚcriteriaÚoformatÚtagÚno_cachermÚdevlistÚlabelr-r-r.Úfind_devs_with_freebsdps  þ  r°c CsÈg}d}d}|r8| d¡r$| d¡}| d¡r8| d¡}tjdddgdgd}|j ¡D]j} |sd|r~tjd| gdd gd\} } |rd || krqX|d kr¢d | kr¢qX|d kr´d | kr´qX| d| ¡qX|S)Nr¤zTYPE=Úsysctlú-nú hw.disknamesr©ZrcsZ mscdlabelr…z label "%s"Úiso9660zISO filesystemÚvfatú/dev/)r©r}rr3r,rÁ) rªr«r¬r­rmr®r¯Ú_typer5ÚdevZ mscdlabel_outr r-r-r.Úfind_devs_with_netbsd„s(    rºcCsŠtjdddgdgd}g}|j ¡ d¡D]P}| d¡s:q*|dkrDq*| |dd …d ¡| d ¡s*| |dd …d ¡q*d d„|DƒS)Nr±r²r³rr´r@r:zfd0:rÓr¹ÚcdÚicSsg|] }d|‘qS©r·r-©r;r¼r-r-r.r?«sz*find_devs_with_openbsd..)rr3Úrstripr,rnrÁr©)rªr«r¬r­rmr5r®rr-r-r.Úfind_devs_with_openbsds  rÀcCs€tjdddgdgd}dd„t|j ¡dd Dƒ}|d krJd d„|Dƒ}n(|d krbd d„|Dƒ}n|rrt d|¡dd„|DƒS)Nr±r²z kern.disksrr´cSs$g|]}| d¡s| d¡s|‘qS)rWZvn©r©r¾r-r-r.r?²s þz/find_devs_with_dragonflybsd..Trmr¨cSsg|]}| d¡r|‘qS©)r»ZacdrÁr¾r-r-r.r?¹s )zLABEL=CONFIG-2r§cSsg|]}| d¡s|‘qSrÂrÁr¾r-r-r.r?»s zUnexpected criteria: %scSsg|] }d|‘qSr½r-r¾r-r-r.r?¾s)rrµr3r,rHr|)rªr«r¬r­rmr5r®r-r-r.Úfind_devs_with_dragonflybsd®sþ rÃc CsFtƒrt|||||ƒStƒr,t|||||ƒStƒrBt|||||ƒStƒrXt|||||ƒSdg}g}|rt| d|¡|r†| d|¡|r˜|  ddg¡|rª| d|¡|r¸| |¡||}zt j |ddgd \}} Wn:t j k r} z| j t krd }n‚W5d } ~ XYnXg} | ¡D]} |  ¡} | r"|  | ¡q"| S) z– find devices matching given criteria (via blkid) criteria can be *one* of: TYPE= LABEL=