ó
oBú]c @ so d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l Z d d l
m Z d d l
m Z
d d l m Z m Z d d l
m Z e
j e ƒ Z e j Z e j Z e j Z d
Z d d g Z d
d g Z d g Z d Z d Z d Z d d d d d d d d g Z d Z d g Z! d „ Z" d „ Z# d e$ f d „ ƒ YZ% d „ Z& e d „ Z' d S(! iÿÿÿÿN( t MIMEBase( t
MIMEMultipart( t MIMENonMultipart( t MIMEText( t handlers( t log( t read_file_or_urlt UrlError( t utils Content-Types
text/plains text/x-not-multiparts text/x-include-urls text/x-include-once-urls text/cloud-config-archives text/cloud-configs application/octet-streams application/gzips application/gzip-compresseds application/gzippeds application/x-compresss application/x-compresseds application/x-gunzips application/x-gzips application/x-gzip-compresseds Number-Attachmentsc C s | | =| | | <d S( N( ( t msgt keyt value( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt _replace_header? s c C s' | d =| j d d d t | ƒ ƒd S( Ns Content-Dispositiont
attachmentt filename( t
add_headert str( R R ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt
_set_filenameD s t UserDataProcessorc B se e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d
d „ Z d „ Z RS( c C s | | _ t j | ƒ | _ d S( N( t pathsR t fetch_ssl_detailst ssl_details( t selfR ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt __init__K s c C s\ t ƒ } t | t ƒ rB x= | D] } | j t | ƒ | ƒ q Wn | j t | ƒ | ƒ | S( N( R t
isinstancet listt _process_msgt convert_string( R t blobt accumulating_msgt b( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt processO s
c C s* d „ } x| j ƒ D] } t | ƒ r. q n d } | j ƒ } t j | ƒ } t } | t k rÁ y% t j | d t ƒ} d } t } WqÁ t j
k
r½ } t j d | t
| ƒ | ƒ q qÁ Xn | sÐ t } n | t k rë | | ƒ } n | d k r | } n | rŸ| j d d ƒ \ }
} t |
| ƒ } | j | ƒ | j ƒ r\t | | j ƒ ƒ n x7 d D]/ }
|
| k rct | |
t | |
ƒ ƒ qcqcW| } n | | k r¾t | t | ƒ n | t k rà| j | | ƒ q n | t k r| j | | ƒ q n t | t | ƒ | j | | ƒ q Wd S( Nc S s
t j | ƒ S( N( R t type_from_starts_with( t payload( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt
find_ctypeZ s t quiets< Failed decompressing payload from %s of length %s due to: %st /i s Launch-Index( s Launch-Index( t walkt is_skippablet Nonet get_content_typeR t fully_decoded_payloadt Falset DECOMP_TYPESt decomp_gzipt Truet DecompressionErrort LOGt warningt lent
UNDEF_TYPEt TYPE_NEEDEDt splitR t set_payloadt get_filenameR R R t CONTENT_TYPEt
INCLUDE_TYPESt _do_includet
ARCHIVE_TYPESt _explode_archivet _attach_part( R t base_msgt
append_msgR" t partt ctypet
ctype_origR! t was_compressedt et maintypet subtypet n_partt h( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR X sV
! c C sï | j d d ƒ } d } | j ƒ t k rx y7 t j | j d t ƒ ƒ } | r` | j d ƒ } n Wqx t k
rt qx Xn | d k r | } n | d k r¢ | } n | d k rë y | j d t
t | ƒ ƒ ƒ Wqë t t
f k
rç që Xn d S( Ns Launch-Indext decodes launch-index( t getR' R( t EXAMINE_FOR_LAUNCH_INDEXR t load_yamlt get_payloadR- t ExceptionR R t intt
ValueErrort TypeError( R R t
header_idxt payload_idxR! ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt _attach_launch_index¡ s$
c C s7 t j | d d ƒ } t j j | j j d ƒ d | ƒ S( Nt md5i@ t datat urlcache( R t hash_blobt ost patht joinR t
get_ipath_cur( R t entryt entry_fn( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt _get_include_once_filename¹ s c C s1 | j ƒ s t | t | ƒ n | j | ƒ d S( N( R6 R t PART_FN_TPLRS ( R R t attached_id( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt _process_before_attach¾ s c
C s& t } x| j ƒ D] } | j ƒ } | j d ƒ rS | t d ƒ j ƒ } t } n. | j d ƒ r | t d ƒ j ƒ } t } n | j d ƒ r– q n | j ƒ } | s® q n d } d } | rÒ | j | ƒ } n | rü t
j j | ƒ rü t
j | ƒ } n÷ y t | d d d d d | j ƒ} | rN| j ƒ rNt
j | | j d d
ƒn | j ƒ rf| j } n t j d | | j ƒ Wns t k
rÍ} t | ƒ }
| |
k r½|
d j | ƒ 7}
n t j |
ƒ n& t k
rò} t j d
| | ƒ n X| d k r t | ƒ } | j | | ƒ q q Wd S( Ns
#include-onces #includet #t timeouti t retriesi
R t modei€ s6 Fetching from %s resulted in a invalid http code of %ss
for url: {0}s Fetching from %s resulted in %s( R* t
splitlinest lowert
startswithR1 t lstripR- t stripR' R^ RX RY t isfileR t load_fileR R t okt
write_filet contentsR/ R0 t codeR R t formatt IOErrorR R (
R t contentR> t include_once_ont linet lc_linet include_urlt include_once_fnt respt urlet messaget ioet new_msg( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR9 Ã sR
c
C s t j | d g d t t f ƒ} xÛ| D]Ó} t | t j ƒ rP i | d 6} n t | t ƒ se q( n | j d d ƒ } | j d ƒ } | s t } t | t j
ƒ r t } n t j
| | ƒ } n | j d d ƒ \ } } | d k r t | t j
ƒ r| j ƒ } n t | d | ƒ}
n t | | ƒ }
|
j | ƒ d
| k rXt |
| d
ƒ n d | k r|
j d t | d ƒ ƒ n xg t | j ƒ ƒ D]S } | j ƒ d d
d d d
t j ƒ t j ƒ f k rÓq”n |
j | | | ƒ q”W| j | |
ƒ q( Wd S( Nt defaultt allowedRs t t typeR$ i t textt _subtypeR s launch-indexs Launch-Indexs content-disposition( R RK R t setR t sixt string_typest dictRI t ARCHIVE_UNDEF_TYPEt binary_typet ARCHIVE_UNDEF_BINARY_TYPER R R4 RH R R R5 R R R t keysRg t ATTACHMENT_FIELDR7 R< ( R t archiveR> t entriest entRs t mtypeR~ RD RE R t header( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR; ý s@ !
c C s‘ t | k r d | t <n | d k r> t | t t | ƒ ƒ n d } y t | j t ƒ ƒ } Wn- t t f k
rŒ t | t t | ƒ ƒ n X| S( s
Return the number of attachments to this MIMEMultipart by looking
at its 'Number-Attachments' header.
t 0i N( RΠR' R R RN RI RO RP ( R t outer_msgt new_countt
fetched_count( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt _multi_part_count, s
c C sH | j | ƒ } | j | | d ƒ | j | ƒ | j | | d ƒ d S( s¸
Attach a message to an outer message. outermsg must be a MIMEMultipart.
Modifies a header in the outer message to keep track of number of
attachments.
i N( R– Ra t attach( R R“ R? t
part_count( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR< > s
N(
t __name__t
__module__R R R RS R^ Ra R9 R; R' R– R< ( ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR J s I : / c C s, | j ƒ p d } | j ƒ d k r( t St S( NR€ t multipart( t get_content_maintypeRg R- R* ( R? t
part_maintype( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR& J s c C sž | s d } n d „ } t | t j ƒ r< | j d ƒ } n | } t j | d t ƒ} d | d d !j ƒ k r‹ t j | j d ƒ ƒ } n | | | ƒ } | S( sJ convert a string (more likely bytes) or a message into
a mime message.R€ c S s8 | j d d ƒ \ } } t | | ƒ } | j | ƒ | S( NR$ i ( R4 R R5 ( RU t content_typeRD RE R ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt
create_binmsgY s
s utf-8RH s
mime-version:i i (
R R… t text_typet encodeR R, R* Rg t message_from_stringRH ( t raw_dataRž RŸ t bdataR ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyR S s (( RX t email.mime.baseR t email.mime.multipartR t email.mime.nonmultipartR t email.mime.textR R… t cloudinitR R t loggingt cloudinit.url_helperR R R t getLoggerR™ R/ t NOT_MULTIPART_TYPER_ t
OCTET_TYPER7 R3 R8 R: R2 Rˆ RŠ R+ RŒ RJ R R t objectR R& R ( ( ( s7 /usr/lib/python2.7/site-packages/cloudinit/user_data.pyt <module> sH ÿ