o x[h @sUdZddlZddlZddlZddlmZddlmZmZddl m Z ddl m Z ddl mZddlmZd Zd Zd ZeeZd d gedgdZeed<dede de deddf ddZddZd#dedeefddZddZdd Z d!d"Z!dS)$z"Write Files: write arbitrary filesN)Optional) url_helperutil)Cloud)Config) MetaSchema) PER_INSTANCEiFz text/plaincc_write_filesall write_files)iddistros frequencyactivate_by_schema_keysmetanamecfgcloudargsreturncCsP|dg}dd|D}|std|dSt|j}t|||jj|dS)Nr cSsg|] }t|dts|qS)defer)rget_cfg_option_bool DEFAULT_DEFER).0frA/usr/lib/python3/dist-packages/cloudinit/config/cc_write_files.py $s  zhandle..zESkipping module named %s, no/empty 'write_files' key in configuration) getLOGdebugrfetch_ssl_detailspathsr distro default_owner)rrrr file_listfiltered_files ssl_detailsrrrhandle"s  r(cCsf|sd}|}|dvrdgS|dvrddgS|dvr dgS|tkr'tgS|r0td|ttgS)N)gzgzipapplication/x-gzip)z gz+base64z gzip+base64zgz+b64zgzip+b64application/base64)b64base64z%Unknown encoding type %s, assuming %s)lowerstripTEXT_PLAIN_ENCrwarning) encoding_typerrrcanonicalize_extraction4s$ r5ownerr'c Cs|sdSt|D]k\}}|d}|std|d|qtj|}t|dd||dd|dd}|durDtd|d|qt |d|\}} t |d t } t |d r_d nd } tj ||| | || d t||| qdS)Npathz3No path provided to write for entry %s in module %ssourcecontentencodingz>No content could be loaded for entry %s in module %s; skippingr6 permissionsappendabwb)omodemodeusergroup) enumeraterrr3osr7abspathread_url_or_decoderextract_usergroup decode_perms DEFAULT_PERMSr write_file chownbyname) rfilesr6r'if_infor7contentsugpermsr@rrrr MsB      c Cs|dur|Szt|ttfrt|WStt|dWSttfyRg}||fD]}z |d|Wq)tyD|d|Yq)wtjdg|R|YSw)Nz%oz%rz0Undecodable permissions %s, returning default %s) isinstanceintfloatstr TypeError ValueErrorr=rr3)permdefaultrepsrrrrrIus"   rIcCs|durdn|dd}t|}|dur|sdSd}|r@ztj||dddd|dj}Wnty?ttd|d}Ynw|durO|sOt |}t ||}|S)Nurir)headers)r`retries sec_betweenr'zVFailed to retrieve contents from source "%s"; falling back to data from "contents" keyF) rboolrread_file_or_urlrP Exceptionrlogexcrr5extract_contents)r9r'r:r;urluse_urlresult extractionsrrrrGs8     rGcCsJ|}|D]}|dkrtj|ddd}q|dkrt|}q|tkr" q|S)Nr,F)quietdecoder-)r decomp_gzipr/ b64decoder2)rPextraction_typesrktrrrrhs rh)N)"__doc__r/loggingrEtypingr cloudinitrrcloudinit.cloudrcloudinit.configrcloudinit.config.schemarcloudinit.settingsrrJrr2 getLogger__name__rr__annotations__rXlistr(r5dictr rIrGrhrrrrs2      ( %