ó
    x[h‰  ã                   ó¼  • % S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKrS SKrS SK	r	S SK
JrJrJrJrJr  S SKJrJr  \R&                  " \5      rSSSSSS	S
SSSSSSS.rSSSS.rSrSrSrS\/r/ SQrSrSrSr\\\\/ SSS 0S!.r SS"SSS#.0SS$SS%./S&.r!S'r"S(r# " S) S*\RH                  5      r% " S+ S,\&5      r' " S- S.\'5      r( " S/ S05      r) " S1 S2\)5      r* " S3 S4\)5      r+ " S5 S6\+5      r,S\\\S4S7 jr-S8 r. SGS9 jr/SHS: jr0 SIS; jr1\%\Rd                  44/r3S< r4\S=:X  a´  S SK5r5\-" 5       r6\6c  \7" S>5        \5Rp                  " S?5        \9" \5Rt                  5      S?:X  a2  \;" \Ry                  5       5      \;" \Ry                  5       5      -   S@/-   r<O\5Rt                  S?S r<SA r=0 r>\?\@SB'   \< H  rA\=" \6\A\>SC9  M     \7" \R„                  " \>S?SDSESF95        gg)Jé    N)Úatomic_helperÚdmiÚsourcesÚsubpÚutil)Ú
EventScopeÚ	EventType)zsdc:uuidT)ÚhostnameT)Úroot_authorized_keysT)úuser-scriptF)ú	user-dataF)zcloud-init:user-dataF)Úiptables_disableT)Úmotd_sys_infoT)úsdc:datacenter_nameT)zsdc:vendor-dataF)zsdc:operator-scriptF)zsdc:hostnameT)zsdc:dns_domainT)úinstance-idúlocal-hostnamezpublic-keysr   úlegacy-user-datar   r   r   Úavailability_zoneúvendor-dataúoperator-scriptr
   Ú
dns_domainzsdc:nicszsdc:resolversz
sdc:routes)únetwork-dataÚdns_serversÚrouteszlx-brandÚkvmÚSmartOSÚ
datasource)r   r   r   r   zsdc:uuiduser-datar   z"/native/.zonecontrol/metadata.sockz
/dev/ttyS1é<   FÚ
ephemeral0z/dev/vdb)Úserial_deviceÚserial_timeoutÚmetadata_sockfileÚno_base64_decodeÚbase64_keysÚ
base64_allÚdisk_aliasesÚmbr)Ú
table_typeÚlayoutÚ	overwriteÚext4)ÚlabelÚ
filesystemÚdevice)Ú
disk_setupÚfs_setupaU  #cloud-boothook
#!/bin/sh
fname="%(per_boot_d)s/01_smartos_vendor_data.sh"
mkdir -p "${fname%%/*}"
cat > "$fname" <<"END_SCRIPT"
#!/bin/sh
##
# This file is written as part of the default vendor data for SmartOS.
# The SmartOS datasource writes the listed file from the listed metadata key
#   sdc:operator-script -> %(operator_script)s
#   user-script -> %(user_script)s
#
# You can view content with 'mdata-get <key>'
#
for script in "%(operator_script)s" "%(user_script)s"; do
    [ -x "$script" ] || continue
    echo "executing '$script'" 1>&2
    "$script"
done
END_SCRIPT
chmod +x "$fname"
z/var/dbc                   óì   • \ rS rSrSr\R                  r\R                  r\	R                  \R                  \R                  \R                  10rS rS rS rS rS rS rS	 rS
 rS r\S 5       rSrg)ÚDataSourceSmartOSé¤   ÚJoyentc                 ó¢  • [         R                  R                  XX#5        [        R                  " U R
                  [        R                  " U[        0 5      [        /5      U l        0 U l	        S U l
        S U l        S U l        [        R                  R                  U R                   R#                  S5      5      U l        U R'                  5         g )NÚscripts)r   Ú
DataSourceÚ__init__r   ÚmergemanydictÚds_cfgÚget_cfg_by_pathÚDS_CFG_PATHÚBUILTIN_DS_CONFIGÚmetadataÚnetwork_dataÚ_network_configÚroutes_dataÚosÚpathÚjoinÚpathsÚ	get_cpathÚscript_base_dÚ_init)ÚselfÚsys_cfgÚdistrorE   s       ÚE/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceSmartOS.pyr8   ÚDataSourceSmartOS.__init__²   s™   € Ü×Ñ×#Ñ# D°6ÔAÜ×(Ò(à—‘Ü×$Ò$ W¬k¸2Ó>Ü!ðó
ˆŒð ˆŒØ ˆÔØ#ˆÔØˆÔäŸW™WŸ\™\¨$¯*©*×*>Ñ*>¸yÓ*IÓJˆÔà�
‰
�ó    c                 óh   • [         R                  R                  U 5      nU< SU R                  < S3$ )Nz	 [client=Ú])r   r7   Ú__str__Ú	md_client)rI   Úroots     rL   rQ   ÚDataSourceSmartOS.__str__Å   s'   € Ü×!Ñ!×)Ñ)¨$Ó/ˆÛ#'¨¯¬Ð8Ð8rN   c                 óH  • U R                   [        R                  :X  a#  [        5       U l         U R                   c  S U l        U R                  [        R                  :X  aC  [        U R                   U R                  S   U R                  S   U R                  S   S9U l        g g )Nr"   r    r!   )Úsmartos_typer"   r    r!   )rV   r   ÚUNSETÚget_smartos_environrR   Újmc_client_factoryr:   ©rI   s    rL   rH   ÚDataSourceSmartOS._initÉ   s‚   € Ø×Ñ¤§¡Ó-Ü 3Ó 5ˆDÔØ× Ñ Ñ(Ø!%�”à�>‰>œWŸ]™]Ó*Ü/Ø!×.Ñ.Ø"&§+¡+Ð.AÑ"BØ"Ÿk™k¨/Ñ:Ø#Ÿ{™{Ð+;Ñ<ñ	ˆD�Nð +rN   c                 ó  • [         R                  S5        Sn[        R                  R	                  SR                  US/5      5      (       a:  [        R                  " SR                  US/5      SR                  US/5      5        gg)aS  Mark the instance provisioning state as successful.

When run in a zone, the host OS will look for /var/svc/provisioning
to be renamed as /var/svc/provision_success.   This should be done
after meta-data is successfully retrieved and from this point
the host considers the provision of the zone to be a success and
keeps the zone running.
z-Instance provisioning state set as successfulz/var/svcÚ/ÚprovisioningÚprovision_successN)ÚLOGÚdebugrB   rC   ÚexistsrD   Úrename)rI   Úsvc_paths     rL   Ú_set_provisionedÚ"DataSourceSmartOS._set_provisioned×   sl   € ô 	�	‰	ÐAÔBØˆÜ�7‰7�>‰>˜#Ÿ(™( H¨nÐ#=Ó>×?Ñ?Ü�IŠIØ—‘˜( NÐ3Ó4Ø—‘˜(Ð$7Ð8Ó9õð @rN   c                 óÔ  • U R                  5         0 nSnU R                  (       d  [        R                  S5        gU R                  R                  5       (       d!  [        R                  SU R                  5        gU R                  R                  5         [        R                  5        H$  u  p4Uu  pVU R                  R                  XVS9X'   M&     [        R                  5        H"  u  p5U R                  R                  U5      X'   M$     U R                  R                  5         [        R                  R                  U R                   R#                  5       SUS   S5      n[        R                  R                  US	5      nS
[$        -  n	['        UR                  S	5      UU	SSS9  [        R                  R                  US5      n
['        UR                  S5      U
SSS9  UR                  S5      nS[$        -  n['        X¼5        US   (       d  US   (       a	  US   US'   OUS   US'   S nUS   (       a  US   nUS   (       dG  [(        UU
[        R                  R                  U R                   R#                  S5      S5      S.-  US'   [*        R,                  " XR.                  /5      U l        X l        US   U l        US   U l        US   U l        U R9                  5         g)NÚ zNot running on smartosFz4No metadata device '%r' found for SmartOS datasource©ÚstripÚ	instancesr   Údatar   z%s/user-scriptTiÀ  )Ú	content_fÚlinkÚshebangÚmoder   )rm   ro   rp   r   z%s/mdata-user-datar   r
   r   r   r6   zper-boot)Úuser_scriptÚoperator_scriptÚ
per_boot_dr   r   )rH   rV   r`   ra   rR   rb   Úopen_transportÚSMARTOS_ATTRIB_MAPÚitemsÚgetÚSMARTOS_ATTRIB_JSONÚget_jsonÚclose_transportrB   rC   rD   rE   rF   ÚLEGACY_USER_DÚwrite_boot_contentÚBUILTIN_VENDOR_DATAr   r9   r>   Úuserdata_rawÚvendordata_rawr?   rA   re   )rI   ÚmdÚudÚci_nounÚ	attributeÚsmartos_nounrj   Údata_drq   Ú
u_script_lrr   Úu_dataÚu_data_fs                rL   Ú	_get_dataÚDataSourceSmartOS._get_dataé   s�  € Ø�
‰
ŒàˆØˆà× × Ü�I‰IÐ.Ô/Øà�~‰~×$Ñ$×&Ñ&Ü�I‰IØFØ—‘ôð ð 	�‰×%Ñ%Ô'ä"4×":Ñ":Ö"<ÑˆGØ"+ÑˆLØŸ.™.×,Ñ,¨\Ð,ÐGˆB‹Kñ #=ô &9×%>Ñ%>Ö%@Ñ!ˆGØŸ.™.×1Ñ1°,Ó?ˆB‹Kñ &Að 	�‰×&Ñ&Ô(ô —‘—‘Ø�J‰J× Ñ Ó" K°°MÑ1BÀFó
ˆô —g‘g—l‘l 6¨=Ó9ˆØ%¬Ñ5ˆ
ÜØ�F‰F�=Ó!Ø!ØØØò	
ô Ÿ'™'Ÿ,™, vÐ/@ÓAˆÜØ�F‰FÐ$Ó%Ø%ØØò		
ð —‘Ð*Ó+ˆØ'¬-Ñ7ˆÜ˜6Ô,ð Ð"×#Ø�*�~Ø')¨*¡~�Ð#Ò$à')¨-Ñ'8�Ð#Ñ$àˆØˆk�?Ø�K‘ˆBà�-× Ü 3Ø*Ø#2Ü Ÿg™gŸl™lØ—J‘J×(Ñ(¨Ó3°Zóñ7ñ !ˆBˆ}Ñô ×*Ò*¨B·±Ð+>Ó?ˆŒØÔØ  Ñ/ˆÔØ˜~Ñ.ˆÔØ˜h™<ˆÔà×ÑÔØrN   c                 ó   • S[         -  $ )Nzserial (%s))ÚSERIAL_DEVICErZ   s    rL   Ú_get_subplatformÚ"DataSourceSmartOS._get_subplatformL  s   € Øœ}Ñ,Ð,rN   c                 ó>   • U R                   S   R                  U5      $ )Nr&   )r:   rw   )rI   Únames     rL   Údevice_name_to_deviceÚ'DataSourceSmartOS.device_name_to_deviceO  s   € Ø�{‰{˜>Ñ*×.Ñ.¨tÓ4Ð4rN   c                 ó:   • U R                   [        :X  a  [        $ 0 $ ©N)rV   ÚSMARTOS_ENV_KVMÚBUILTIN_CLOUD_CONFIGrZ   s    rL   Úget_config_objÚ DataSourceSmartOS.get_config_objR  s   € Ø×Ñ¤Ó/Ü'Ð'Øˆ	rN   c                 ó    • U R                   S   $ )Nr   )r>   rZ   s    rL   Úget_instance_idÚ!DataSourceSmartOS.get_instance_idW  s   € Ø�}‰}˜]Ñ+Ð+rN   c                 ó  • U R                   [        R                  :X  a  S U l         U R                   cL  U R                  b?  [	        U R                  U R
                  S   U R
                  S   U R                  S9U l         U R                   $ )Nr   r   ©r?   r   r   r   )r@   r   rW   r?   Úconvert_smartos_network_datar>   rA   rZ   s    rL   Únetwork_configÚ DataSourceSmartOS.network_configZ  s{   € ð ×Ñ¤7§=¡=Ó0Ø#'ˆDÔ à×ÑÑ'Ø× Ñ Ñ,Ü'CØ!%×!2Ñ!2Ø $§¡¨mÑ <Ø#Ÿ}™}¨\Ñ:Ø×+Ñ+ñ	(�Ô$ð ×#Ñ#Ð#rN   )
r@   r:   rR   r>   r?   rA   rG   rV   r~   r   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Údsnamer   rW   rV   rR   r   ÚNETWORKr	   ÚBOOT_NEW_INSTANCEÚBOOTÚBOOT_LEGACYÚdefault_update_eventsr8   rQ   rH   re   r‰   r�   r‘   r—   rš   ÚpropertyrŸ   Ú__static_attributes__© rN   rL   r2   r2   ¤   s‹   † à€Fà—=‘=€LØ—‘€Ià×ÑØ×'Ñ'Ø�N‰NØ×!Ñ!ð
ðÐòò&9òòò$aòF-ò5òò
,ð ñ$ó ó$rN   r2   c                   ó   • \ rS rSrSrg)ÚJoyentMetadataFetchExceptionik  r­   N©r¡   r¢   r£   r¤   r¬   r­   rN   rL   r¯   r¯   k  ó   † ÚrN   r¯   c                   ó   • \ rS rSrSrg)ÚJoyentMetadataTimeoutExceptionio  r­   Nr°   r­   rN   rL   r³   r³   o  r±   rN   r³   c                   ó¦   • \ rS rSrSr\R                  " S5      rSS jrS r	S r
S rS	 rS
 rSS jrSS jrSS jrS rS rS rS rS rS rSrg)ÚJoyentMetadataClientis  z›
A client implementing v2 of the Joyent Metadata Protocol Specification.

The full specification can be found at
http://eng.joyent.com/mdata/protocol.html
z~V2 (?P<length>\d+) (?P<checksum>[0-9a-f]+) (?P<body>(?P<request_id>[0-9a-f]+) (?P<status>SUCCESS|NOTFOUND)( (?P<payload>.+))?)Nc                 ó6   • Uc
  [        5       nXl        X l        g r”   )rX   rV   Úfp)rI   rV   r·   s      rL   r8   ÚJoyentMetadataClient.__init__�  s   € ØÑÜ.Ó0ˆLØ(ÔØ�rN   c                 óp   • SR                  [        R                  " UR                  S5      5      S-  5      $ )Nú{0:08x}zutf-8ì   ÿÿ )ÚformatÚbinasciiÚcrc32Úencode)rI   Úbodys     rL   Ú	_checksumÚJoyentMetadataClient._checksum‡  s/   € Ø×ÑÜ�NŠN˜4Ÿ;™; wÓ/Ó0°:Ñ=ó
ð 	
rN   c           	      ó`  • U R                   R                  U5      R                  5       n[        US   5      [	        US   5      :w  a*  [        SR                  US   [	        US   5      5      5      eU R                  US   5      nUS   U:w  a  [        SR                  XCS   5      5      eUS   U:w  a  [        SR                  XS   5      5      eUR                  SS 5      (       d  [        R                  S	5        g [        R                  " US   5      n[        R                  S
U5        U$ )NÚlengthrÀ   z*Incorrect frame length given ({0} != {1}).Úchecksumz*Invalid checksum (expected: {0}; got {1}).Ú
request_idz-Request ID mismatch (expected: {0}; got {1}).ÚpayloadzNo value found.zValue "%s" found.)Ú
line_regexÚmatchÚ	groupdictÚintÚlenr¯   r¼   rÁ   rw   r`   ra   r   Úb64d)rI   Úexpected_request_idÚframeÚ
frame_dataÚexpected_checksumÚvalues         rL   Ú_get_value_from_frameÚ*JoyentMetadataClient._get_value_from_frameŒ  s0  € Ø—_‘_×*Ñ*¨5Ó1×;Ñ;Ó=ˆ
Üˆz˜(Ñ#Ó$¬¨J°vÑ,>Ó(?Ó?Ü.Ø<×CÑCØ˜xÑ(¬#¨j¸Ñ.@Ó*Aóóð ð
 !ŸN™N¨:°fÑ+=Ó>ÐØ�jÑ!Ð%6Ó6Ü.Ø<×CÑCØ%°*Ñ'=óóð ð
 �lÑ#Ð':Ó:Ü.Ø?×FÑFØ'°LÑ)Aóóð ð
 �~‰~˜i¨×.Ñ.Ü�I‰IÐ'Ô(ØÜ×"Ò" :¨iÑ#8Ó9ˆÜ�	‰	Ð% uÔ-ØˆrN   c                 óL  ^• / mU4S jnSn  U R                   R                  S5      nU(       d  [        X!" 5       -  5      eUS:X  a  U" 5       $ TR                  U5        MU  ! [         a7  nUR
                  [
        R                  :X  a  [        X!" 5       -  5      Uee SnAff = f)zÓ
Reads a line a byte at a time until \n is encountered.  Returns an
ascii string with the trailing newline removed.

If a timeout (per-byte) is set and it expires, a
JoyentMetadataFetchException will be thrown.
c                  óD   >• SR                  T 5      R                  S5      $ )NrN   Úascii)rD   Údecode)Úresponses   €rL   Úas_asciiÚ0JoyentMetadataClient._readline.<locals>.as_ascii²  s   ø€ Ø—8‘8˜HÓ%×,Ñ,¨WÓ5Ð5rN   zPartial response: '%s'é   ó   
N)r·   Úreadr³   ÚappendÚOSErrorÚerrnoÚEAGAIN)rI   rÚ   ÚmsgÚbyteÚexcrÙ   s        @rL   Ú	_readlineÚJoyentMetadataClient._readline¨  s¥   ø€ ð ˆõ	6ð 'ˆØðØ—w‘w—|‘| A“�ÞÜ8¸¸x»zÑ9IÓJÐJØ˜5“=Ù#›:Ð%Ø—‘ Ô%ñ øô ó Ø—9‘9¤§¡Ó,Ü8Ø˜h›jÑ(óàðð ûðús   ŽA A" ÁA" Á"
B#Á,2BÂB#c                 óŒ   • U R                   R                  UR                  S5      5        U R                   R                  5         g )Nr×   )r·   Úwriter¿   Úflush)rI   rã   s     rL   Ú_writeÚJoyentMetadataClient._writeÅ  s(   € Ø�‰�‰�c—j‘j Ó)Ô*Ø�‰�‰�rN   c                 óî   • [         R                  S5        U R                  S5        U R                  5       n[         R                  SU5        US:w  a  [	        SU-  5      e[         R                  S5        g )NzNegotiating protocol V2zNEGOTIATE V2
z	read "%s"ÚV2_OKz'Invalid response "%s" to "NEGOTIATE V2"zNegotiation complete)r`   ra   rë   ræ   r¯   )rI   rÙ   s     rL   Ú
_negotiateÚJoyentMetadataClient._negotiateÉ  sb   € Ü�	‰	Ð+Ô,Ø�‰Ð$Ô%Ø—>‘>Ó#ˆÜ�	‰	�+˜xÔ(Ø�wÓÜ.Ø9¸HÑDóð ô 	�	‰	Ð(Õ)rN   c                 óŽ  • SR                  [        R                  " SS5      5      nSR                  UU45      nU(       a8  US[        R
                  " UR                  5       5      R                  5       -   -  nSR                  [        U5      U R                  U5      U5      n[        R                  SU5        SnU R                  (       d  U R                  5         SnU R                  U5        U R                  5       nU(       a  U R!                  5         [        R                  S	U5        S
U;  a  g U R#                  X75      nU$ )Nrº   r   r»   Ú zV2 {0} {1} {2}
z#Writing "%s" to metadata transport.FTz"Read "%s" from metadata transport.ÚSUCCESS)r¼   ÚrandomÚrandintrD   Úbase64Ú	b64encoder¿   rØ   rÌ   rÁ   r`   ra   r·   rt   rë   ræ   rz   rÓ   )	rI   ÚrtypeÚparamrÆ   Úmessage_bodyrã   Ú
need_closerÙ   rÒ   s	            rL   ÚrequestÚJoyentMetadataClient.requestÔ  s  € Ø×%Ñ%¤f§n¢n°Q¸
Ó&CÓDˆ
Ø—x‘xàØðó
ˆö Ø˜C¤&×"2Ò"2°5·<±<³>Ó"B×"IÑ"IÓ"KÑKÑKˆLØ ×'Ñ'Ü�Ó˜tŸ~™~¨lÓ;¸\ó
ˆô 	�	‰	Ð7¸Ô=àˆ
Ø�w�wØ×ÑÔ!ØˆJà�‰�CÔØ—>‘>Ó#ˆÞØ× Ñ Ô"ä�	‰	Ð6¸ÔAà˜HÓ$Øà×*Ñ*¨:Ó@ˆØˆrN   c                 ól   • U R                  SUS9nUc  U$ U(       a  U(       a  UR                  5       nU$ )NÚGET©rø   rù   )rü   rj   )rI   ÚkeyÚdefaultrj   Úresults        rL   rw   ÚJoyentMetadataClient.getõ  s3   € Ø—‘ E°�Ð5ˆØ‰>ØˆNÞ–eØ—\‘\“^ˆFØˆrN   c                 óV   • U R                  XS9nUc  U$ [        R                  " U5      $ )N)r  )rw   ÚjsonÚloads)rI   r  r  r  s       rL   ry   ÚJoyentMetadataClient.get_jsoný  s+   € Ø—‘˜#�Ð/ˆØ‰>ØˆNÜ�zŠz˜&Ó!Ð!rN   c                 óT   • U R                  SS9nU(       d  / $ UR                  S5      $ )NÚKEYS)rø   Ú
)rü   Úsplit)rI   r  s     rL   ÚlistÚJoyentMetadataClient.list  s)   € Ø—‘ F�Ð+ˆÞØˆIØ�|‰|˜DÓ!Ð!rN   c           	      óÒ   • SR                  X4 Vs/ s H'  n[        R                  " UR                  5       5      PM)     sn5      R	                  5       nU R                  SUS9$ s  snf )Nó    ÚPUTr   )rD   rö   r÷   r¿   rØ   rü   )rI   r  ÚvalÚirù   s        rL   ÚputÚJoyentMetadataClient.put	  sY   € Ø—	‘	Ø47±:Ó>²:¨aŒV×Ò˜aŸh™h›jÖ)±:Ñ>ó
ç
‰&‹(ð 	ð �|‰| %¨uˆ|Ð5Ð5ùò ?s   ‘.A$c                 ój   • U R                   (       a"  U R                   R                  5         S U l         g g r”   )r·   ÚcloserZ   s    rL   rz   Ú$JoyentMetadataClient.close_transport  s"   € Ø�7�7Ø�G‰G�M‰MŒOØˆD�Gð rN   c                 óL   • U R                   (       a  U $ U R                  5         U $ r”   )r·   rt   rZ   s    rL   Ú	__enter__ÚJoyentMetadataClient.__enter__  s   € Ø�7�7ØˆKØ×ÑÔØˆrN   c                 ó$   • U R                  5         g r”   )rz   )rI   Úexc_typeÚ	exc_valueÚ	tracebacks       rL   Ú__exit__ÚJoyentMetadataClient.__exit__  s   € Ø×ÑÔØrN   c                 ó   • [         er”   )ÚNotImplementedErrorrZ   s    rL   rt   Ú#JoyentMetadataClient.open_transport  s   € Ü!Ð!rN   )r·   rV   ©NNr”   ©NF)r¡   r¢   r£   r¤   Ú__doc__ÚreÚcompilerÈ   r8   rÁ   rÓ   ræ   rë   rï   rü   rw   ry   r  r  rz   r  r   rt   r¬   r­   rN   rL   rµ   rµ   s  sh   † ñð —’ð	 ó€Jôò
ò
ò8ò:ò	*ôôBô"ò"ò6òò
òõ"rN   rµ   c                   ó@   ^ • \ rS rSr\4U 4S jjrS rS rS rSr	U =r
$ )ÚJoyentMetadataSocketClienti"  c                 ó8   >• [         [        U ]  U5        Xl        g r”   )Úsuperr+  r8   Ú
socketpath)rI   r.  rV   Ú	__class__s      €rL   r8   Ú#JoyentMetadataSocketClient.__init__#  s   ø€ ÜÔ(¨$Ñ8¸ÔFØ$�rN   c                 óì   • [         R                   " [         R                  [         R                  5      nUR                  U R                  5        UR                  S5      U l        U R                  5         g )NÚrwb)ÚsocketÚAF_UNIXÚSOCK_STREAMÚconnectr.  Úmakefiler·   rï   )rI   Úsocks     rL   rt   Ú)JoyentMetadataSocketClient.open_transport'  sF   € Ü�}Š}œVŸ^™^¬V×-?Ñ-?Ó@ˆØ�‰�T—_‘_Ô%Ø—-‘- Ó&ˆŒØ�‰ÕrN   c                 óT   • [         R                  R                  U R                  5      $ r”   )rB   rC   rb   r.  rZ   s    rL   rb   Ú!JoyentMetadataSocketClient.exists-  s   € Ü�w‰w�~‰~˜dŸo™oÓ.Ð.rN   c                 óR   • U R                   R                  < SU R                  < S3$ )Nz(socketpath=Ú))r/  r¡   r.  rZ   s    rL   Ú__repr__Ú#JoyentMetadataSocketClient.__repr__0  s   € Ø&*§n¡n×&=Ô&=¸t¿¼ÐOÐOrN   )r·   r.  )r¡   r¢   r£   r¤   ÚSMARTOS_ENV_LX_BRANDr8   rt   rb   r>  r¬   Ú__classcell__©r/  s   @rL   r+  r+  "  s!   ø† Ø0D÷ %òò/÷Pð PrN   r+  c                   óJ   ^ • \ rS rSrS\S4U 4S jjrS rS rS rS r	S	r
U =r$ )
ÚJoyentMetadataSerialClienti4  é
   Nc                 óD   >• [         [        U ]  X45        Xl        X l        g r”   )r-  rD  r8   r.   Útimeout)rI   r.   rG  rV   r·   r/  s        €rL   r8   Ú#JoyentMetadataSerialClient.__init__5  s   ø€ ô 	Ô(¨$Ñ8¸ÔJØŒØ�rN   c                 óT   • [         R                  R                  U R                  5      $ r”   )rB   rC   rb   r.   rZ   s    rL   rb   Ú!JoyentMetadataSerialClient.exists<  s   € Ü�w‰w�~‰~˜dŸk™kÓ*Ð*rN   c                 óœ  • U R                   c�   SS KnUR	                  U R
                  U R                  S9nUR                  5       (       d  [        SU R
                  -  5      eX0l         [        R                  " U[        R                  5        U R                  5         U R                  5         g ! [         a  n[        S5      UeS nAff = f)Nr   zserial support is not available)rG  zUnable to open %s)r·   ÚserialÚImportErrorr#  ÚSerialr.   rG  ÚisOpenÚSystemErrorÚfcntlÚlockfÚLOCK_EXÚ_flushrï   )rI   rL  ÚeÚsers       rL   rt   Ú)JoyentMetadataSerialClient.open_transport?  sž   € Ø�7‰7‰?ðÛð
 —-‘- §¡°T·\±\�-ÐBˆCØ—:‘:—<‘<Ü!Ð"5¸¿¹Ñ"CÓDÐDØŒGÜ�KŠK˜œUŸ]™]Ô+Ø�‰ŒØ�‰Õøô ó Ü)Ø5óàðûðús   �B0 Â0
CÂ:CÃCc                 ó¼  • [         R                  S5        U R                  R                  nSU R                  l          U R	                  5         M  ! [
         a     Of = f[         R                  S5        US:”  a  SU R                  l        OXR                  l         [         R                  S5        U R                  S5         U R	                  5       nUS:X  a  O[US:X  a  [         R                  S	5        M\  [         R                  S
U5        O%! [
         a    [         R                  S5         Of = fM™  [         R                  S5        XR                  l        g )NzFlushing inputgš™™™™™¹?zInput emptyé   z,Writing newline, expecting "invalid command"r  zinvalid commandÚFAILUREzGot "FAILURE".  Retrying.z%Unexpected response "%s" during flushzQTimeout while initializing metadata client. Is the host metadata service running?z'Got "invalid command".  Flush complete.)r`   ra   r·   rG  ræ   r³   rë   Úwarning)rI   rG  rÙ   s      rL   rT  Ú!JoyentMetadataSerialClient._flushO  s  € Ü�	‰	Ð"Ô#à—'‘'—/‘/ˆØˆ�‰ŒØðØ—‘Ô ñ øô 2ó Ùðúä�	‰	�-Ô ð �Q‹;ØˆD�G‰G�Oà%�G‰GŒOØÜ�I‰IÐDÔEØ�K‰K˜ÔðØŸ>™>Ó+�ØÐ0Ó0ØØ˜yÓ(Ü—I‘IÐ9Ô:ÙÜ—‘ÐCÀXÕNøÜ1ó Ü—‘ð<öðúñ ô  	�	‰	Ð;Ô<Ø!�‰�s/   ¿A Á
AÁAÃD ÃD Ã:D ÄD3Ä2D3c                 ón   • U R                   R                  < SU R                  < SU R                  < S3$ )Nz(device=z
, timeout=r=  )r/  r¡   r.   rG  rZ   s    rL   r>  Ú#JoyentMetadataSerialClient.__repr__v  s'   € à�N‰N×#Ô#Ø�KŒKØ�LŒLð
ð 	
rN   )r.   r·   rG  )r¡   r¢   r£   r¤   r•   r8   rb   rt   rT  r>  r¬   rA  rB  s   @rL   rD  rD  4  s)   ø† à ¨À4÷ò+òò %"÷N
ð 
rN   rD  c                   ó^   ^ • \ rS rSrSrS	U 4S jjrS
S jrSU 4S jjrS
S jrSS jr	Sr
U =r$ )Ú JoyentMetadataLegacySerialClienti~  a‘  V1 of the protocol was not safe for all values.
Thus, we allowed the user to pass values in as base64 encoded.
Users may still reasonably expect to be able to send base64 data
and have it transparently decoded.  So even though the V2 format is
now used, and is safe (using base64 itself), we keep legacy support.

The way for a user to do this was:
  a.) specify 'base64_keys' key whose value is a comma delimited
      list of keys that were base64 encoded.
  b.) base64_all: string interpreted as a boolean that indicates
      if all keys are base64 encoded.
  c.) set a key named b64-<keyname> with a boolean indicating that
<keyname> is base64 encoded.c                 óf   >• [        [        U 5      nUR                  XU5        S U l        S U l        g r”   )r-  r`  r8   r$   r%   )rI   r.   rG  rV   Úsr/  s        €rL   r8   Ú)JoyentMetadataLegacySerialClient.__init__�  s-   ø€ ÜÔ2°DÓ9ˆØ	�
‰
�6 LÔ1ØˆÔØˆ�rN   c                 óÜ  • U(       a  S U l         S U l        S nU R                  cH  U R                  5       nSU;   a+  [        R                  " U R                  S5      5      U l        OSU l        U R                  (       a  g U R                   cÜ  Uc  U R                  5       n[        5       nSU;   a)  [        U R                  S5      R                  S5      5      nU Vs/ s H  oDR                  S5      (       d  M  USS  PM!     sn HX  n[        R                  " U R                  U5      5      (       a  UR                  U5        M@  XS;   d  MG  UR                  U5        MZ     X0l         g g s  snf )Nr%   Fr$   Ú,zb64-é   )r$   r%   r  r   Úis_trueÚ_getÚsetr  Ú
startswithÚaddÚremove)rI   ÚresetÚkeysÚb64_keysÚkr  s         rL   Ú_init_base64_keysÚ2JoyentMetadataLegacySerialClient._init_base64_keys“  s  € ÞØ#ˆDÔØ"ˆDŒOàˆØ�?‰?Ñ"Ø—9‘9“;ˆDØ˜tÓ#Ü"&§,¢,¨t¯y©y¸Ó/FÓ"G�•à"'�”à�?�?àà×ÑÑ#Ø‰|Ø—y‘y“{�Ü“uˆHØ Ó$Ü˜tŸy™y¨Ó7×=Ñ=¸cÓBÓC�ñ (,ÓD¢t !¯|©|¸F×/C›˜˜!˜"›¡tÔD�Ü—<’< §	¡	¨#£×/Ñ/Ø—L‘L Ö%à•Ø Ÿ™¨Ö,ñ Eð  (Õð $ùò Es   ÃE)Ã9	E)c                 ó(   >• [         [        U ]  XUS9$ )N)r  rj   )r-  r`  rw   )rI   r  r  rj   r/  s       €rL   rh  Ú%JoyentMetadataLegacySerialClient._getµ  s#   ø€ ÜÔ5°tÑ@Ø¨ð Að 
ð 	
rN   c                 óv   • U[         ;   a  gU R                  US9  U R                  (       a  gXR                  ;   $ )NF)rm  T)ÚNO_BASE64_DECODErq  r%   r$   )rI   r  rm  s      rL   Úis_b64_encodedÚ/JoyentMetadataLegacySerialClient.is_b64_encodedº  s8   € ØÔ"Ó"Øà×Ñ UÐÑ+Ø�?�?Øà×&Ñ&Ñ&Ð&rN   c                 óh  • [        5       nU R                  USUS9nXTL a  U$ U R                  U5      (       a3   [        R                  " UR                  5       5      R                  5       nU(       a  UR                  5       nU$ ! [        R                   a    [        R                  SX5         NEf = f)NF)rj   r  z#Failed base64 decoding key '%s': %s)Úobjectrh  rw  rö   Ú	b64decoder¿   rØ   r½   ÚErrorr`   r[  rj   )rI   r  r  rj   Úmdefaultr  s         rL   rw   Ú$JoyentMetadataLegacySerialClient.getÄ  s˜   € Ü“8ˆØ�i‰i˜ 5°(ˆiÐ;ˆØŠ?ØˆNà×Ñ˜s×#Ñ#ðMÜ×&Ò& s§z¡z£|Ó4×;Ñ;Ó=�ö Ø—)‘)“+ˆCàˆ
øô —>‘>ó MÜ—‘ÐAÀ3ÖLðMús   ¹2B Â*B1Â0B1)r%   r$   )rE  N)Fr&  )r¡   r¢   r£   r¤   r'  r8   rq  rh  rw  rw   r¬   rA  rB  s   @rL   r`  r`  ~  s'   ø† ñ$÷ô (÷D
ô
'÷ò rN   r`  c                 ó’   • U c  [        U5      n U c  g U [        :X  a  [        UUU S9$ U [        :X  a	  [	        XS9$ [        SU -  5      e)N)r.   rG  rV   )r.  rV   z"Unknown value for smartos_type: %s)rX   r•   r`  r@  r+  Ú
ValueError)rV   r"   r    r!   Úuname_versions        rL   rY   rY   Ö  si   € ð ÑÜ*¨=Ó9ˆàÑØØ	œÓ	(Ü/Ø Ø"Ø%ñ
ð 	
ð
 
Ô-Ó	-Ü)Ø(ñ
ð 	
ô Ð9¸LÑHÓ
IÐIrN   c                 ó  • SSSU /nS n [         R                   " U5      u  p#[        R                  SX5        Uc  S $ UR                  5       $ ! [         R                   a*  n[        R
                  " [        SU -  U45         S nANNS nAff = f)NÚfilez--briefz--mime-typezscript %s mime type is %sz%Failed to identify script type for %s)r   r`   ra   ÚProcessExecutionErrorr   Úlogexcrj   )rm   ÚcmdÚf_typeÚ_errrU  s        rL   Úidentify_filer‰  ñ  sˆ   € Ø�9˜m¨YÐ
7€CØ€Fð
ÜŸš 3›‰ˆÜ�	‰	Ð-¨yÔAð
 ‘>ˆ4Ð5 v§|¡|£~Ð5øô	 ×%Ñ%ó 
Ü�ŠÜÐ9¸IÑEÀqÐI÷	
ñ 	
ûð
ús   Š.A ÁBÁ! BÂBc                 óð  • U (       d:  [         R                  R                  U5      (       a  [         R                  " U5        U(       a:  [         R                  R	                  U5      (       a  [         R                  " U5        U (       d  g[
        R                  " XUS9  U(       ad  U R                  S5      (       dN  [        U5      nUS:X  a=  [
        R                  " USR                  SU /5      US9  [        R                  SU5        U(       a²   [         R                  R	                  U5      (       a  [         R                  " U5        U (       ao  [         R                  R                  U5      (       aJ  [
        R                  " [         R                  R                  U5      5        [         R                  " X5        gggg! [         a&  n[
        R                   " [        SU5         SnAgSnAff = f)	aÌ  
Write the content to content_f. Under the following rules:
    1. If no content, remove the file
    2. Write the content
    3. If executable and no file magic, add it
    4. If there is a link, create it

@param content: what to write
@param content_f: the file name
@param backup_d: the directory to save the backup at
@param link: if defined, location to create a symlink to
@param shebang: if no file magic, set shebang
@param mode: file mode

Because of the way that Cloud-init executes scripts (no shell),
a script will fail to execute if does not have a magic bit (shebang) set
for the file. If shebang=True, then the script will be checked for a magic
bit and to the SmartOS default of assuming that bash.
N)rp   z#!z
text/plainr  z#!/bin/bashzadded shebang to file %sz$failed establishing content link: %s)rB   rC   rb   ÚunlinkÚislinkr   Ú
write_filerj  r‰  rD   r`   ra   Ú
ensure_dirÚdirnameÚsymlinkÚIOErrorr…  )Úcontentrm   rn   ro   rp   r‡  rU  s          rL   r|   r|   þ  sE  € ö. ”r—w‘w—~‘~ i×0Ñ0Ü
�	Š	�)ÔÞ”—‘—‘˜t×$Ñ$Ü
�	Š	�$ŒÞØä‡O‚O�I¨TÒ2æ�w×)Ñ)¨$×/Ñ/Ü˜yÓ)ˆØ�\Ó!Ü�OŠOØ˜4Ÿ9™9 m°WÐ%=Ó>ÀTòô �I‰IÐ0°)Ô<æð	HÜ�w‰w�~‰~˜d×#Ñ#Ü—	’	˜$”Þœ2Ÿ7™7Ÿ>™>¨)×4Ñ4Ü—’¤§¡§¡°Ó 5Ô6Ü—
’
˜9Õ+ð 5ˆwð	 øô ó 	HÜ�KŠKœÐCÀQ×GÑGûð	Hús   ÄB.G Ç
G5ÇG0Ç0G5c                 óÔ   • [         R                  " 5       nU c  US   n U S:X  a  [        $ Uc  [        R                  " S5      nOUnU(       a  UR                  S5      (       a  [        $ g )Nrf  zBrandZ virtual linuxzsystem-product-nameÚSmartDC)rB   Úunamer@  r   Úread_dmi_datarj  r•   )r�  Úproduct_namer•  Úsystem_types       rL   rX   rX   1  se   € Ü�HŠH‹J€Eð ÑØ˜a™ˆØÐ.Ó.Ü#Ð#àÑÜ×'Ò'Ð(=Ó>‰à"ˆæ�{×-Ñ-¨i×8Ñ8ÜÐàrN   c                 óX  ^• / SQ/ SQSS/S.mU(       a  [        U[        [        45      (       d  U/nO/ nU(       a  [        U[        [        45      (       d  U/nO/ nU(       d  / nS nS nUSS	.USS	.S
.n/ nU  GH  n[        U4S jUR	                  5        5       5      n	U	R                  SUS   S.5        SU;   a  U	R                  SUS   05        / n
UR                  S/ 5       GHn  nUS:X  a  SS0nGOMUS:X  a  SS0nGOA/ n[        U4S jUR	                  5        5       5      nUR                  SUS.5        U" U5      (       a  SOSnSU;   a‹  UR                  SS5      (       at  Xn   S   (       dh  UR                  S/ 5       Vs/ s H  nXn   S    " U5      (       d  M  UPM     nn[        U5      (       a"  US!   Xn   S'   UR                  SXn   S   05        U H`  n[        U4S" jUR	                  5        5       5      nUR                  SUS#   05        UR                  U5        UR                  S$U05        Mb     U
R                  U5        GMq     U	R                  S%U
05        UR                  U	5        GM     U(       a  UR                  S&UUS'.5        S(US).$ s  snf )*aÄ  Return a dictionary of network_config by parsing provided
   SMARTOS sdc:nics configuration data

sdc:nics data is a dictionary of properties of a nic and the ip
configuration desired.  Additional nic dictionaries are appended
to the list.

Converting the format is straightforward though it does include
duplicate information as well as data which appears to be relevant
to the hostOS rather than the guest.

For each entry in the nics list returned from query sdc:nics, we
create a type: physical entry, and extract the interface properties:
'mac' -> 'mac_address', 'mtu', 'interface' -> 'name'.  The remaining
keys are related to ip configuration.  For each ip in the 'ips' list
we create a subnet entry under 'subnets' pairing the ip to a one in
the 'gateways' list.

Each route in sdc:routes is mapped to a route on each interface.
The sdc:routes properties 'dst' and 'gateway' map to 'network' and
'gateway'.  The 'linklocal' sdc:routes property is ignored.
)Úmac_addressÚmtur�   ÚparamsÚsubnetsÚtype)	ÚaddressÚ	broadcastÚdns_nameserversÚ
dns_searchÚmetricÚpointopointr   Úscoperž  ÚnetworkÚgateway)ÚphysicalÚsubnetÚroutec                 ó   • SU ;   $ )NÚ.r­   ©Úaddrs    rL   Úis_valid_ipv4Ú3convert_smartos_network_data.<locals>.is_valid_ipv4Š  ó   € Ø�d‰{ÐrN   c                 ó   • SU ;   $ )NÚ:r­   r­  s    rL   Úis_valid_ipv6Ú3convert_smartos_network_data.<locals>.is_valid_ipv6�  r±  rN   N)rÉ   Úgw)Úipv4Úipv6c              3   óD   >#   • U  H  u  pUTS    ;   d  M  X4v •  M     g7f)r¨  Nr­   ©Ú.0rp  ÚvÚ
valid_keyss      €rL   Ú	<genexpr>Ú/convert_smartos_network_data.<locals>.<genexpr>—  s&   øé € ð 
Ú*‘t�q¨a°:¸jÑ3IÑ.I‹FˆQ�Fš{ùó   ƒ –
 r¨  Ú	interface)rž  r�   Úmacrš  ÚipsÚdhcprž  Údhcp4ÚaddrconfÚdhcp6c              3   óD   >#   • U  H  u  pUTS    ;   d  M  X4v •  M     g7f)r©  Nr­   rº  s      €rL   r¾  r¿  ¦  s&   øé € ð Ú'2™t˜q°a¸:ÀhÑ;OÑ6O“F�Q•F¢{ùrÀ  Ústatic)rž  rŸ  r·  r¸  ÚprimaryFr¶  ÚgatewaysrÉ   r   c              3   óD   >#   • U  H  u  pUTS    ;   d  M  X4v •  M     g7f)rª  Nr­   rº  s      €rL   r¾  r¿  Â  s+   øé € ð  â$1™D˜AØ 
¨7Ñ 3Ñ3ó ˜�Ú$1ùrÀ  Údstr   r�  Ú
nameserver)rž  rŸ  ÚsearchrÜ   )ÚversionÚconfig)	Ú
isinstancer  ÚtupleÚdictrv   Úupdaterw   rÌ   rß   )r?   r   r   r   r¯  r´  ÚpgwsrÑ  ÚnicÚcfgr�  Úipr©  Ú	routeentsÚprotor¶  rË  rª  Úrcfgr½  s                      @rL   rž   rž   G  sÐ  ø€ ò6
ò

ð Øð
ñ)€Jö4 Ü˜+¬¬e }×5Ñ5Ø&˜-ˆKøàˆæÜ˜*¤t¬U m×4Ñ4Ø$˜ˆJøàˆ
æØˆòòð (¨tÑ4Ø'¨tÑ4ñ€Dð
 €FÜˆÜô 
Ø"Ÿy™yœ{ó
ó 
ˆð 	�
‰
˜J°°KÑ0@ÑAÔBØ�C‹<Ø�J‰J˜ s¨5¡zÐ2Ô3àˆØ—'‘'˜% ×$ˆBØ�V‹|Ø  'Ð*’Ø�zÓ!Ø  'Ð*’à�	Üô Ø'*§y¡y¤{óó �ð —‘à (Ø#%ñôñ #0°×"3Ñ"3™¸�à Ó#¨¯©°	¸5×(AÑ(Að
  ™; t×,ð '*§g¡g¨j¸"Ô&=ó$â&= Ø#™{¨7Ò3°B×7÷ Ù&=ð !ð $ô
 ˜xŸ=™=Ø08¸±˜D™K¨Ñ-Ø"ŸM™M¨9°d±kÀ$Ñ6GÐ*HÔIã#�EÜô  à$)§K¡K¤Mó ó �Dð" —K‘K ¨E°%©LÐ 9Ô:Ø×$Ñ$ TÔ*Ø—M‘M 8¨YÐ"7Ö8ñ) $ð, �N‰N˜6×"ñq %ðr 	�
‰
�I˜wÐ'Ô(Ø�‰�c×ñG öJ Ø�‰à$Ø&Ø$ñô	
ð  FÑ+Ð+ùòY$s   ÆJ'Æ'J'c                 ó8   • [         R                  " U [        5      $ r”   )r   Úlist_from_dependsÚdatasources)Údependss    rL   Úget_datasource_listrá  î  s   € Ü×$Ò$ W¬kÓ:Ð:rN   Ú__main__zDo not appear to be on smartos.rÜ   rŸ   c                 ó6  • X;   a  X!   $ U[         ;   a   [         U   nU R                  U5      X!'   X!   $ US:X  a3  S H  n[        XU5        M     [        US   US   US   US   S9X!'   X!   $ U[        ;   a  [        U   u  p5OUSpSU R                  X5S	9X!'   X!   $ )
NrŸ   )r   r   r   r   r   r   r   r   r�   Fri   )rx   ry   Úload_keyrž   ru   rw   )Úclientr  rl   ÚkeynameÚdepkeyrj   s         rL   rä  rä    sÐ   € Ø‹;Ø‘9ÐàÔ%Ó%Ü)¨#Ñ.ˆGØŸ™¨Ó0ˆD‰Ið, ‰yÐð+ Ð$Ó$ó�ô ˜¨Ö.ñô 5Ø! .Ñ1Ø  Ñ/Ø Ñ-Ø˜H‘~ñ	ˆD‰Ið ‰yÐð Ô(Ó(Ü!3°CÑ!8‘�˜à"% u˜ØŸ
™
 7˜
Ð8ˆD‰Ià‰yÐrN   rl   )rå  r  rl   T)re  z: )ÚindentÚ	sort_keysÚ
separators)NFé   r%  )NNNN)Crö   r½   rá   rQ  r  ÚloggingrB   rô   r(  r3  Ú	cloudinitr   r   r   r   r   Úcloudinit.eventr   r	   Ú	getLoggerr¡   r`   ru   rx   r@  r•   ÚDS_NAMEr<   rv  ÚMETADATA_SOCKFILErŒ   ÚSERIAL_TIMEOUTr=   r–   r}   r{   r7   r2   Ú	Exceptionr¯   r³   rµ   r+  rD  r`  rY   r‰  r|   rX   rž   ÚDEP_FILESYSTEMrß  rá  ÚsysÚjmcÚprintÚexitrÌ   Úargvr  rn  rä  rl   rÔ  Ú__annotations__r  Údumpsr­   rN   rL   Ú<module>rü     s­  ðô. Û Û Û Û Û Û 	Û Û 	Û ç =Õ =ß 1à×Ò˜Ó!€ð &Ø(Ø1Ø)Ø,Ø0Ø2Ø,Ø6Ø-Ø5Ø&Ø*ñÐ ð& Ø"Øñ	Ð ð "Ð Ø€à
€Ø˜WÐ%€òÐ ð 9Ð Ø€Ø€ð" #Ø$Ø*Ø(ØØØ! :Ð.ñÐ ð 	ØØØñ
ðð ¨fÀÑMðñÐ ð8Ð ð8 €ôD$˜×*Ñ*ô D$ôN	 9ô 	ô	Ð%Aô 	÷l"ñ l"ô^PÐ!5ô Pô$G
Ð!5ô G
ôTUÐ'Aô Uðr Ø'ØØ!ØôJò6
6ð 8=ô0Hôfð. BFô],ðD ˜×/Ñ/Ð1Ð2ð€ò;ð ˆzÓÛá
Ó
€CØ
�{ÙÐ/Ô0Ø�Š�ŒÙ
ˆ3�8‰8ƒ}˜ÓáÐ$×)Ñ)Ó+Ó,ÙÐ%×*Ñ*Ó,Ó-ñ.àÐ ñ!ñ 	ð �x‰x˜˜ˆ|ˆòð< €Dˆ$ƒOÛˆÙ˜ ¨4Ô0ñ ñ 
ˆ$�*Š*�T !¨tÀÑ
LÕMðe rN   