File: //usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyc
�
d�bc @ s� d d l Z d d l Z d d l Z d d l j j Z d d l j j Z d d l m Z d d l
m Z d d l m
Z
d d l m Z d d l m Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d d
l m Z d d l m Z m Z m Z m Z m! Z! d Z" d
Z# d Z$ d Z% d Z& d Z' d Z( d e) f d � � YZ* d e) f d � � YZ+ d e) f d � � YZ, d e) f d � � YZ- d e) f d � � YZ. d S( i����N( t AgentGlobals( t set_properties( t IncompleteGoalStateError( t
ProtocolError( t ustr( t ExtensionsGoalStateFactory( t Certt CertListt RemoteAccessUsert RemoteAccessUsersList( t fileutil( t CryptUtil( t parse_doct findallt findt findtextt getattribs" http://{0}/machine/?comp=goalstates Certificates.xmls Certificates.p7ms Certificates.pems TransportCert.pems TransportPrivate.pemi t GoalStatec B s e Z d � Z d � Z RS( c C s� t j | j � � } x� t d t � D]h } | j | | j � � | _ t | j � } t | d � | _
t | d � } | r� Pn t j
d � q% Wt d j d | j
� � � y� t | d � | _ t | d � } t | d � | _ t | d
� } t | d � | _ t j | j � t | d � | _ d | _ t | d
� | _ d | _ t | d � | _ d | _ t | d � | _ d | _ d | _ t | d � | _ Wn( t k
r�} t d d d | � � n Xd S( s�
Fetches the goal state using the given wire client.
__init__ fetches only the goal state itself, not including inner properties such as ExtensionsConfig; to fetch the entire goal state
use the fetch_full_goal_state().
i t Incarnationt RoleInstanceg �?s= Fetched goal state without a RoleInstance [incarnation {inc}]t inct
InstanceIdt
Configurationt
ConfigNamet Containert ContainerIdt HostingEnvironmentConfigt SharedConfigt Certificatest RemoteAccessInfot ExtensionsConfigt msgs Error fetching goal statet innerN(! t GOAL_STATE_URIt formatt get_endpointt ranget _NUM_GS_FETCH_RETRIESt fetch_configt
get_headert xml_textR R t incarnationR t timet sleepR t role_instance_idt role_config_namet container_idR t update_container_idt _hosting_env_urit Nonet hosting_envt _shared_conf_urit shared_conft
_certs_urit certst _remote_access_urit
remote_accesst extensions_configt _extensions_config_urit ExceptionR ( t selft wire_clientt urit _t xml_doct
role_instancet role_configt containert exception( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyt __init__/ s: c C s� zy:t j d | j � | j | j | j � � } t | � | _ | j | j | j � � } t | � | _
| j d k r� | j | j | j
� � } t | � | _ n | j d k r� | j | j | j
� � } t | � | _ n | j d k rt j � | _ n6 | j | j | j � � } t j | j | | � | _ Wn> t k
r}} t j d t | � � t d d d | � � n XWd t j d � Xd S( Ns% Fetching goal state [incarnation {0}]s# Fetching the goal state failed: {0}R s Error fetching goal stateR s Fetch goal state completed( t loggert infoR) R& R0 R' t
HostingEnvR2 R3 R R4 R5 R1 t get_header_for_certR R6 R7 t RemoteAccessR8 R: R t create_emptyR9 t create_from_extensions_configR; t warnR R ( R< R= R( RD ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyt fetch_full_goal_state_ s* ( t __name__t
__module__RE RN ( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyR . s 0RH c B s e Z d � Z RS( c C s| | | _ t | � } t | d � } t | d � | _ t | d � } t | d � | _ t | d � } t | d � | _ d S( NR t instancet Rolet namet
Deployment( R( R R R t vm_namet role_namet deployment_name( R< R( R@ R) t rolet
deployment( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRE ~ s ( RO RP RE ( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRH } s R c B s e Z d � Z RS( c C s
| | _ d S( N( R( ( R< R( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRE � s ( RO RP RE ( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyR � s R c B s e Z d � Z e d � � Z RS( c C s t � | _ t j j t j � t � } t j | | � t
| � } t | d � } | d k rb d St | d � } | r� | d k r� t
j d | � d St t j � � } t j j t j � t � } d j | | | � } t j | | � t j j t j � t � } t j j t j � t � }
t j j t j � t � } | j | | |
| � g } t }
t } i } i } d } g } t | � �q} xg| j � D]Y} | j | � t j d | � r�t } q�t j d | � r�t }
q�t j d | � r9t j | d
| � } | j | � } | | | <g } | d 7} t } q�t j d | � r�t j | d
| � } | j! | � } | j" | � } | | | <d j | � } | j i d d 6| d 6� t j# | t j j t j � | � � g } | d 7} t }
q�q�WWd QXx� | D]z } | | } | rn| | } d j | � } t j# | t j j t j � | � � t
j$ d j | � � qt
j d � qWx= | D]5 } | | k r�d } t
j$ | j | | � � q�q�Wx: | D]2 } t% � } t& d | | � | j j' j | � q�Wd S( Nt Datat Formatt Pkcs7BlobWithPfxContentss6 The Format is not Pkcs7BlobWithPfxContents. Format is s� MIME-Version:1.0
Content-Disposition: attachment; filename="{0}"
Content-Type: application/x-pkcs7-mime; name="{1}"
Content-Transfer-Encoding: base64
{2}i s [-]+BEGIN.*KEY[-]+s [-]+BEGIN.*CERTIFICATE[-]+s [-]+END.*KEY[-]+t prvi s [-]+END.*CERTIFICATE[-]+t crts {0}.crtRS t
thumbprints {0}.prvs) Found private key matching thumbprint {0}s2 Found NO matching cert/thumbprint for private key!s< Certificate with thumbprint {0} has no matching private key.R6 (( R t cert_listt ost patht joint conft get_lib_dirt CERTS_FILE_NAMER
t
write_fileR R R1 RF RM R t get_openssl_cmdt
P7M_FILE_NAMER" t TRANSPORT_PRV_FILE_NAMEt TRANSPORT_CERT_FILE_NAMEt
PEM_FILE_NAMEt decrypt_p7mt Falset opent readlinest appendt ret matcht TrueR t _write_to_tmp_filet get_pubkey_from_prvt get_pubkey_from_crtt get_thumbprint_from_crtt renameRG R R t certificates( R< R( t
local_fileR@ t datat certificateFormatt cryptutilt p7m_filet p7mt trans_prv_filet trans_cert_filet pem_filet buft begin_crtt begin_prvt prvst thumbprintst indext v1_cert_listt pemt linet tmp_filet pubR_ R^ t pubkeyR] R t v1_certt cert( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRE � s�
%
%
!
c C sD t j j t j � d j | | � � } t j | d j | � � | S( Ns {0}.{1}t ( Ra Rb Rc Rd Re R" R
Rg ( R� t suffixR� t file_name( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRu � s '( RO RP RE t staticmethodRu ( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyR � s cRJ c B s& e Z d Z d � Z e d � � Z RS( s;
Object containing information about user accounts
c C s� | | _ d | _ d | _ t � | _ | j d k sK t | j � d k rO d St | j � } t | d � | _ t | d � | _ t | d � } t
| d � } x0 | D]( } t j | � } | j j
j | � q� Wd S( Ni t VersionR t Userst User( R( R1 t versionR) R t user_listt lenR R R R
RJ t _parse_usert usersRq ( R< R( R@ t user_collectionR� t usert remote_access_user( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRE
s $
c C sC t | d � } t | d � } t | d � } t | | | � } | S( Nt Namet Passwordt
Expiration( R R ( R� RS t encrypted_passwordt
expirationR� ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyR� s
( RO RP t __doc__RE R� R� ( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyRJ � s (/ Ra Rr R* t azurelinuxagent.common.conft commonRd t azurelinuxagent.common.loggerRF t# azurelinuxagent.common.AgentGlobalsR t# azurelinuxagent.common.datacontractR t azurelinuxagent.common.exceptionR R t azurelinuxagent.common.futureR t= azurelinuxagent.common.protocol.extensions_goal_state_factoryR t' azurelinuxagent.common.protocol.restapiR R R R t azurelinuxagent.common.utilsR
t& azurelinuxagent.common.utils.cryptutilR t% azurelinuxagent.common.utils.textutilR R
R R R R! Rf Ri Rl Rk Rj R% t objectR RH R R RJ ( ( ( sN /usr/lib/python2.7/site-packages/azurelinuxagent/common/protocol/goal_state.pyt <module> s4 "(O k