U Ӈg>@s ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z m Z eeZdZdZdgZdZGddde jZGd d d eZGd d d eZGd ddZddZddZddZdddZdddZddZ eZ!ee j"ffgZ#ddZ$dS)N) atomic_helpernetsourcessubputilziid-dsopennebulaZnobody context.sh)Z EPOCHREALTIMEZ EPOCHSECONDSZRANDOMZLINENOZSECONDS_ZSRANDOMZ__vc@sFeZdZdZddZddZddZdd Zed d Z dd dZ dS)DataSourceOpenNebulaZ OpenNebulacCs4tj||||d|_tj|jd|_d|_dS)NZ opennebula) r DataSource__init__seedospathjoinseed_dirnetwork)selfZsys_cfgdistropathsrH/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceOpenNebula.pyr /szDataSourceOpenNebula.__init__cCstj|}d||j|jfS)Nz%s [seed=%s][dsmode=%s])rr __str__r dsmode)rrootrrrr5s zDataSourceOpenNebula.__str__c Csdti}d}d}t}d|jkr*|jd}|jg}|t|D]}zLtj |jrht ||j |d}n(| drt jt ||j d}t||}Wn\tk rYqBYnFtk r}z|W5d}~XYn"tjk rtd|YnX|rB|}td|q qB|sdS|d } t| |g} ||d |jd g|_|jtjkr\dS||_|d |_| |_|d |_dS)Nz instance-id parseuserasuserz/dev)rrz%s was not mountablezfound datasource in %sFmetadataZDSMODErnetwork-interfacesuserdataT) DEFAULT_IIDDEFAULT_PARSEUSERZds_cfggetrextendfind_candidate_devsr risdirread_context_disk_dirr startswith functoolspartialrZmount_cbNonContextDiskDirBrokenContextDiskDirZMountFailedErrorLOGwarningdebugZ mergemanydictZ_determine_dsmoderrZDSMODE_DISABLEDr rrZ userdata_raw) rdefaultsresultsr rZ candidatesZcdevZpartially_applied_funcexcZmdrrr _get_data9s^       zDataSourceOpenNebula._get_datacCs$|j|jkrd}nd}d||jfS)z/Return the subplatform metadata source details.zseed-dirz config-diskz%s (%s))rr )rZsubplatform_typerrr_get_subplatformvs z%DataSourceOpenNebula._get_subplatformcCs|jdk r|jSdSdSN)r)rrrrnetwork_config~s z#DataSourceOpenNebula.network_configFcCs.|dkr|jtjkrd}nd}tj|||S)NTF)rrZDSMODE_NETWORKr get_hostname)rZfqdnZ resolve_ipZ metadata_onlyrrrr6s  z!DataSourceOpenNebula.get_hostnameN)FFF) __name__ __module__ __qualname__Zdsnamer rr2r3propertyr5r6rrrrr +s= r c@s eZdZdS)r*Nr7r8r9rrrrr*sr*c@s eZdZdS)r+Nr;rrrrr+sr+c@speZdZdddZddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ dddZ ddZdS)OpenNebulaNetworkNcCs|||_|dkrt|}tddt|dddD|_i|_|D],\}}t d|}|rJ| d|j| <qJdS)NcSsg|]}|qSrr.0krrr sz.OpenNebulaNetwork.__init__..cSst|dS)N)rZnatural_sort_key)r?rrrz,OpenNebulaNetwork.__init__..)keyz ^(.+)_MAC$rA) contextget_physical_nics_by_mac collections OrderedDictsorteditemsifacescontext_devnamerematchgrouplower)rrErZsystem_nics_by_macr?vmrrrr s   zOpenNebulaNetwork.__init__cCs"ddd|dddDS)N.cSsg|]}tt|dqS))strint)r>crrrr@sz,OpenNebulaNetwork.mac2ip..:)rsplit)rmacrrrmac2ipszOpenNebulaNetwork.mac2ipcCs\i}||dd}||jdd|r:||d<||dd}|rX||d<|S)NdnsZDNS addresses search_domainsearch) get_fieldrZr#rEr")rdev nameserversr]r`rrrget_nameserverssz!OpenNebulaNetwork.get_nameserverscCs ||dS)Nmturbrrcrrrget_mtuszOpenNebulaNetwork.get_mtucCs||d||S)NZip)rbr\)rrcr[rrrget_ipszOpenNebulaNetwork.get_ipcCs<g}||d}|r||||d}|r8|||S)Nip6ip6_ula)rbappend)rrc addresses6rkrlrrrget_ip6s    zOpenNebulaNetwork.get_ip6cCs||ddS)NZip6_prefix_lengthZ64rgrhrrrget_ip6_prefixsz OpenNebulaNetwork.get_ip6_prefixcCs ||dS)Ngatewayrgrhrrr get_gatewayszOpenNebulaNetwork.get_gatewaycCs||d||dS)NZ ip6_gatewaygateway6rgrhrrr get_gateway6s  zOpenNebulaNetwork.get_gateway6cCs||ddS)Nmaskz 255.255.255.0rgrhrrrget_maskszOpenNebulaNetwork.get_maskcCs*|jd||f}|dkr&|S|S)zreturn the field name in context for device dev. context stores _ (example: eth0_DOMAIN). an empty string for value will return default.r)Nr^)rEr"rupper)rrcnamedefaultvalrrrrbs zOpenNebulaNetwork.get_fieldcs6i}d|d<i|d<i}|jD]\}}|}|j||}i}d|i|d<g|d<||}tt|}|d | ||d|| |} | r| ||d fdd | D||} | r| |d <||} | r| |d <||} | r| |d <||} | r | |d <|||<q"||d<|S)NrYversion ethernetsZ macaddressrNr_/csg|]}|dqS)r}r)r>iZprefix6rrr@ sz.OpenNebulaNetwork.gen_conf..Zgateway4rsrdrf)rKrJrPrLr"rvrUrZipv4_mask_to_net_prefixrmrjrorpr#rrrtreri)rZnetconfr|r[rcZc_devZdevconfruprefixrnrqrsrdrfrrrgen_confsD         zOpenNebulaNetwork.gen_conf)N)N)r7r8r9r r\rerirjrorprrrtrvrbrrrrrr<s    r<cCs@g}dD]2}t|}||D]}||kr"||q"q|S)zE Return a list of devices that may contain the context disk. )z LABEL=CONTEXTz LABEL=CDROMz TYPE=iso9660)rZfind_devs_withsortrm)Zcombinedfdevsdrrrr$&s r$cCs dd|gS)NZsudoz-uruserrrrswitch_user_cmd5srcCs tdS)zDprint the shell environment variables within delimiters to be parsedz printf "%s\0" _start_ [ $0 != 'sh' ] && set -o posix set [ $0 != 'sh' ] && set +o posix printf "%s\0" _start_ )textwrapdedentrrrr varprinter9src Csd|krtdtd|td}g}|dk rBt|}|ddgtj||dj}i}|d d d}|d |d }}t d dt |D} t ddt |D} t |  t | D]6} | tkrq| | } | dk r| | | kr| || <q|S)a<run content and return environment variables which changed WARNING: the special variable _start_ is used to delimit content a context.sh that defines this variable might break in unexpected ways compatible with posix shells such as dash and ash and any shell which supports `set -o posix` s_start_zYUser defined _start_ variable in context.sh, this may breakcloud-init in unexpected ways.z{ %s : } > /dev/null  NZshz-e)dataz_start_rArrYcss|]}|jdddVqdS=rA)maxsplitNrZr>Zvariablerrr }sz%parse_shell_config..css|]}|jdddVqdSrrrrrrrs)encoder,r-rrr#rstdoutrZdictshlexsetkeysunion EXCLUDED_VARSr") contentrZbcmdcmdoutputZretZsectionsZbeforeZafterZpre_envZpost_envrDvaluerrrparse_shell_configFsB   rc Csi}tD]&}tj||}tj|r|||<q|sDtd|dfi}did}d|kr8|dk rzt|Wn4tk r}zt dj |d|W5d}~XYnXz(tj|d} t | } t | |d}Wndtjk r}zt d ||W5d}~XYn2tk r4}ztd ||W5d}~XYnXntd |sJ|S||d <d} d |krfd } nd|krtd} | r|| } dd| D|d d<dD]&} | |kr|| |d d<qʐqd|kr|d|d<nd|kr|d|d<d|krV|d|d}|dkrVzt|d|d<Wn tk rTtdYnXdd|D}|rt||}||d<|S)z read_context_disk_dir(source_dir): read source_dir and return a tuple with metadata dict and user-data string populated. If not a valid dir, raise a NonContextDiskDir z%s: %szno files foundN)rrrz'configured user '{user}' does not existrrzError processing context.sh: %szError reading context.sh: %szMissing context.shrZSSH_KEYZSSH_PUBLIC_KEYcSs"g|]}t|r|ds|qS)#)lenr')r>linerrrr@s z)read_context_disk_dir..z public-keys)Z SET_HOSTNAMEZHOSTNAMEZ PUBLIC_IPZ IP_PUBLICZETH0_IPzlocal-hostnameZ USER_DATArZUSERDATAZUSERDATA_ENCODINGZUSER_DATA_ENCODINGbase64z"Failed base64 decoding of userdatacSsg|]}td|r|qS)z ^ETH\d+_IP.*$)rMrNr=rrrr@s r)CONTEXT_DISK_FILESr rrisfiler*pwdgetpwnamKeyErrorr+formatrZload_text_filerrZProcessExecutionErrorIOErrorr" splitlinesrZb64d TypeErrorr,r-r<r)Z source_dirrrfoundZaffnrEr0errZ ssh_key_varlinesr?encodingZ ipaddr_keysZonetrrrr&s                r&cs"t}tfdd|DS)Ncs$g|]\}}j|r||fqSr)Z networkingZ is_physical)r>rRnrrrr@s z,get_physical_nics_by_mac..)rZget_interfaces_by_macrrJ)rrrrrrFsrFcCs t|tSr4)rZlist_from_depends datasources)Zdependsrrrget_datasource_listsr)N)N)%rGr(Zloggingr rrMrrZ cloudinitrrrrrZ getLoggerr7r,r r!rrr r Exceptionr*r+r<r$rrrr&rFZDataSourceOpenNebulaNetZDEP_FILESYSTEMrrrrrrs8  c G `