U Ӈg:@s.ddlZddlZddlZddlZddlZddlmZddlZddlm Z ddl m Z ddl m Z ddlmZmZmZmZmZddlmZmZddlmZdd lmZmZdd lmZdd lmZe e!Z"d d gZ#dZ$dZ%dZ&Gdddej'j(Z)ddZ*ddZ+Gdddej,Z-e-ej.ffgZ/ddZ0dS)N)urlparse)ConnectionError)HTTPConnection) PoolManager)dmi performancesources url_helperutil) EventScope EventType)NoDHCPLeaseError)EphemeralDHCPv4EphemeralIPv6Network)DataSourceHostname)ProcessExecutionErrorzhttp://169.254.42.42zhttp://[fd00:42::42] cs*eZdZdZfddZdddZZS)SourceAddressAdapterzF Adapter for requests to choose the local address to bind to. c s||_tt|jf|dSN)source_addresssuperr__init__)selfrkwargs __class__F/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceScaleway.pyr+szSourceAddressAdapter.__init__FcCs0tjtjtjdfg}t||||j|d|_dS)N)Z num_poolsmaxsizeblockrsocket_options)rZdefault_socket_optionssocketZ SOL_SOCKETZ SO_REUSEPORTrrZ poolmanager)rZ connectionsr!r"r#rrrinit_poolmanager/s z%SourceAddressAdapter.init_poolmanager)F)__name__ __module__ __qualname____doc__rr% __classcell__rrrrr&s rc Cshz(tj|d|d|ddd}t|jWStjk rb}z|jdkrPWY dSW5d}~XYnXdS)aQ Retrieve user data or vendor data. Scaleway user/vendor data API returns HTTP/404 if user/vendor data is not set. This function calls `url_helper.readurl` but instead of considering HTTP/404 as an error that requires a retry, it considers it as empty user/vendor data. Also, be aware the user data/vendor API requires the source port to be below 1024 to ensure the client is root (since non-root users can't bind ports below 1024). If requests raises ConnectionError (EADDRINUSE), the caller should retry to call this function on an other port. NrcSs|jdkot|jtjj S)N)code isinstancecauserequests exceptionsr)excrrrWs z%query_data_api_once..)datatimeoutretriesZsessionZ exception_cbr+)r readurlr decode_binarycontentsUrlErrorr,) api_addressr4requests_sessionrespr1rrrquery_data_api_once<s  r=c Cs(tdt|dD] }ztd||t}d}zRt|j}|}|ddkrZ|dd}tj |dtj d dd} | tj krd }Wnt k rYnX| d t||fd t|||d } td|| WStjk r} z(td|| td| } WYqW5d} ~ XYqXq| dS)a/Get user or vendor data. Handle the retrying logic in case the source port is used. Scaleway metadata service requires the source port of the client to be a privileged port (<1024). This is done to ensure that only a privileged user on the system can access the metadata service. r rz*Trying to get %s data (bind on port %d)...z0.0.0.0r[N)protoz0::zhttp://)r)r4r;z%s-data downloadedz%Error while trying to get %s data: %s)rangemaxLOGdebugr/ZSessionrZnetlocr$Z getaddrinfoZ IPPROTO_TCPZAF_INET6 ValueErrorZmountrr=r r9warningtimesleep) Zapi_typer:r5r4Zportr;Z localhostZ url_addressaddressZ addr_protor3r1last_excrrrquery_data_apidsX         rLcseZdZdZejejejej hiZ fddZ e ddfdd Z dd Zd d Zed d ZddZeddZeddZddZddZdddZeddZeddZZS) DataSourceScalewayScalewaycstt||||tt|ddgig|_t|jdt |_ t|jdt |_ t|jdt |_tj|_t|_d|_d|_d|_d|_d|_d|jkr|j|jd7_dS)NZ datasourcerNr5r4max_waitT metadata_urls)rrMrr Z mergemanydictZget_cfg_by_pathZds_cfgintgetDEF_MD_RETRIESr5DEF_MD_TIMEOUTr4DEF_MD_MAX_WAITrOrUNSET_network_config DS_BASE_URLSrP metadata_url userdata_urlvendordata_urlephemeral_fixed_addresshas_ipv4keys)rZsys_cfgdistropathsrrrrs"zDataSourceScaleway.__init__N)ci_pkl_versionreturncsFt|ddttddd}|D]}t||s"t||||q"dS)NT)r\r]rOrPrZr[)r _unpicklerUrXhasattrsetattr)rraZ attr_defaultsattrrrrrcs  zDataSourceScaleway._unpicklecCs|t}tj||j|jdd\}}|rZtd||d|_|d|_ |d|_ dStd|t t|t dS) zO Define metadata_url based upon api-metadata URL availability. F)urlsrOr4Zconnect_synchronouslyz%s is reachablez/conf?format=jsonz/user_data/cloud-initz/vendor_data/cloud-initNz3Unable to reach api-metadata at %s after %s seconds) rH monotonicr Z wait_for_urlrOr4rDrErYrZr[rQr)rrgZ start_timeZ avail_url_rrr_set_metadata_urls&     z$DataSourceScaleway._set_metadata_urlcCsZtj|j|j|jd}tt|j |_ t d|j |j|j|_ t d|j|j|j|_dS)N)r4r5z user-dataz vendor-data)r r6rYr4r5jsonloadsr r7r8metadatarLrZZ userdata_rawr[Zvendordata_raw)rr<rrr_crawl_metadatas$z"DataSourceScaleway._crawl_metadatacCs>td}|dkrdStjdr&dSt}d|kr:dSdS)a  There are three ways to detect if you are on Scaleway: * check DMI data: not yet implemented by Scaleway, but the check is made to be future-proof. * the initrd created the file /var/run/scaleway. * "scaleway" is in the kernel cmdline. zsystem-manufacturerrNTz/var/run/scalewayZscalewayN)rZ read_dmi_dataospathexistsr Z get_cmdline)Z vendor_nameZcmdlinerrr ds_detects  zDataSourceScaleway.ds_detectc Cs|jrz^t|j|jjD}td||jW5QRX||d|_ d|j d<W5QRXWn>t t t fk r}zttt|d|_W5d}~XYnX|jszTt|j|jj:td||jW5QRX|d|j d<W5QRXWnt k rYdSXdS) Nz7Setting api-metadata URL depending on IPv4 availabilityz fixed-addressipv4Z net_in_useFz7Setting api-metadata URL depending on IPv6 availabilityipv6T)r]rr_fallback_interfacerZTimedrjrPrnr\rmr rrr ZlogexcrDstrr)rrserrr _get_datasH zDataSourceScaleway._get_datac Cs|jdkr tdtjtj|_|jtjkr2|jS|jddkrVi}i}|jdD]}|d|jkrd|d<ddd d }d |kr|d |g7<n |g|d <qTd |kr|d |dd |df7<n|dd |df|d <|ddkrT|ddd}d |kr0|d |g7<qT|g|d <qT|||jj <d|d|_ndd|jj d}ddig}|jdr|dd|jddd|jddddd|jdddgdg7}||d <d!|gd"|_t d#|j|jS)$z` Configure networking according to data received from the metadata API. Nz5Found None as cached _network_config. Resetting to %sZ private_ipZ public_ipsrJTZdhcp4z169.254.42.42/32z 62.210.0.1)zon-linktoviaroutesZ addresses/netmaskZfamilyZinet6gatewayz::/0)rzryr)versionZ ethernetsZphysicalz%s)typenamerrtZstaticz::0)Znetworkprefixr~)rrJr}r{subnetsr )rZconfigznetwork_config : %s) rWrDrGrrVrmr\r^r_rurE)rZnetcfgZip_cfgZipZrouterrrrnetwork_config4sp             z!DataSourceScaleway.network_configcCsdSrrrrrr launch_indexszDataSourceScaleway.launch_indexcCs |jdS)Nid)rmrrrrget_instance_idsz"DataSourceScaleway.get_instance_idcCs^dd|jdD}d}t|}|jdgD]*}||s>q.|||dddq.|S)NcSsg|] }|dqS)keyr).0rrrr sz:DataSourceScaleway.get_public_ssh_keys..Zssh_public_keyszAUTHORIZED_KEY=Ztagsri )rmlenrR startswithappendreplace)rZssh_keysZakeypreplentagrrrget_public_ssh_keyss z&DataSourceScaleway.get_public_ssh_keysFcCst|jddS)NZhostnameF)rrm)rZfqdnZ resolve_ipZ metadata_onlyrrr get_hostnameszDataSourceScaleway.get_hostnamecCsdSrrrrrravailability_zonesz$DataSourceScaleway.availability_zonecCsdSrrrrrrregionszDataSourceScaleway.region)FFF)r&r'r(Zdsnamer ZNETWORKr ZBOOT_NEW_INSTANCEZBOOTZ BOOT_LEGACYZdefault_update_eventsrrQrcrjrn staticmethodrrrxpropertyrrrrrrrr*rrrrrMs2   2 O   rMcCs t|tSr)rZlist_from_depends datasources)Zdependsrrrget_datasource_listsr)1rkZloggingror$rHZ urllib.parserr/Zrequests.exceptionsrZurllib3.connectionrZurllib3.poolmanagerrZ cloudinitrrrr r Zcloudinit.eventr r Zcloudinit.net.dhcpr Zcloudinit.net.ephemeralrrZcloudinit.sourcesrZcloudinit.subprZ getLoggerr&rDrXrSrUrTZadaptersZ HTTPAdapterrr=rLZ DataSourcerMZDEP_FILESYSTEMrrrrrrs:        (4