x[hSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r J r SSK J r SSKJr SSKJr SSKJr SSKJr SSKJrJrJrJrJrJrJrJrJr SS K J!r!J"r"J#r#J$r$ SSK%r%SS K%J&r& SS K'J(r(J)r)J*r* \RV"\,5r-S r.\\S /\/4r0Sr1Sr2S\34Sjr4SKS\5S\6S\7SS4Sjjr8S\5SS4Sjr9S\S4Sjr:"SS5r;"SS\;5r<"SS\;5r="S S!5r>"S"S \?5r@S#rAS$\5S\64S%jrBSS&.S'\@S(\0S\\64S)jjrCSSSS*SSSSS+S+SSS,S+S-S,S..S(\0S/\/S\>4S0jjrDSLS1\S2\4S3\5S\3S4\RS5\\6S\4 S6jjrFSMS1\S2\4S8\\5S9\6S\3S\\\5\\>44 S:jjrG"S;S<\5rH\6"S=5S\-RSSSSSS-S+S7S>. S?\6S\\6S@\SA\\SB\\6S(\0SC\\\\6/\64SD\5SE\/SF\64SGjjrJ"SHSI5rKSLSJjrLg)NN)ThreadPoolExecutor TimeoutError as_completed) parsedate)partial) NOT_FOUND)count)create_default_context) AnyCallableIteratorListMapping NamedTupleOptionalTupleUnion)quoteurlparseurlsplit urlunparse) exceptions) performanceutilversionREDACTEDUrlErrorc[[USS95nUS(dUS(a USUS'SUS'[U5$)Nhttp)scheme)listrr)url parsed_urls 6/usr/lib/python3/dist-packages/cloudinit/url_helper.py _cleanurlr(1sChs623J a=Z]#1 1  1 j !!c2SnUnUH nU"X45nM U$)Nc[[U55nUSnU(aURS5(dUS- nU[[ U5SS9- nX2S'[ U5$)Nr"/z/:)safe)r$rendswithrstrr)r%add_on url_parsedpaths r'combine_single#combine_url..combine_single<sZ(3-( !}  c** CKD c&k--1 *%%r))baseadd_onsr3r%r0s r' combine_urlr8;s'& CS) Jr)returnc L[RS[RS[RS[RS[ S0nUR [U55nU(d:[U[5(aURnU$[RS5 SnU$)z4helper for read_ftps to map return codes to a number,iXiz9Unexpected exception type while connecting to ftp server.i) ftplib error_reply error_temp error_perm error_protoEOFErrorgettype isinstanceOSErrorerrnoLOGwarning)excftp_error_codescodes r'"ftp_get_return_code_from_exceptionrNKs C33C# O   tCy )D  c7 # #99D K KKK D Kr)r%timeoutkwargs FtpResponsec b[U5nUR(d[S[SUS9e[R "5nUR =(d SnUR=(d SnSUR:XGaG[R"[5S9n[RSUU5 URURUU=(d S S 9 [RSU5 UR#UUR$=(d SS9 [RS5 UR'5 [RSUR,5 UR/SUR,3UR0S9 [3UR55U5[RS5 UR75 sSSS5 $[R8"5n [RSX5 U RURUU=(d S S 9 [RSU5 U R#UUR$=(d SS9 [RSUR,5 U R/SUR,3UR0S9 [3UR55U5[RS5 U R75 sSSS5 $![Ra$n[!U5n [S US U S 3U SUS9UeSnAff=f![R(a'n[R+S5 [SSSUS9UeSnAff=f![Ra$n[!U5n [SUS U S 3U SUS9UeSnAff=f![RS5 UR75 f=f![Ra$n[!U5n [SUS U S 3U SUS9UeSnAff=f![RS5 W R75 f=f!,(df  g=f)aNconnect to URL using ftp over TLS and read a file when using strict mode (ftps://), raise exception in event of failure when not using strict mode (ftp://), fall back to using unencrypted ftp url: string containing the desination to read a file from. The url is parsed with urllib.urlsplit to identify username, password, host, path, and port in the following format: ftps://[username:password@]host[:port]/[path] host is the only required component timeout: maximum time for the connection to take kwargs: unused, for compatibility with read_url returns: UrlResponse zInvalid url providedNcauserMheadersr% anonymousftps)contextz3Attempting to connect to %s via port [%s] over tls.@)hostportrOz1Reading file from server over tls failed for url z []z"Attempting to login with user [%s]r#)userpasswdzCreating a secure connectionzAttempted to connect to an insecure ftp server but used a scheme of ftps://, which is not allowed. Use ftp:// to allow connecting to insecure ftp servers.r=zReading file: %szRETR )callbackzClosing connectionz,Reading file from ftp server failed for url z(Attempting to connect to %s via port %s.)rhostnamerrioBytesIOr\usernamer r>FTP_TLSr rIdebugconnect all_errorsrNloginpasswordprot_prArJr2 retrbinarywriterQgetvaluecloseFTP) r%rOrP url_partsbufferr\r^ftp_tlserMftps r' read_ftpsrvbs  I   (y$C   ~~#!!0[ Y%% %  ..24 I "++#Ns  II:D A  $--3 89 "  ,inn=""INN+,v||##6??#4c: ./ S V jjl > "++#Ns  >E $--3 ,inn=y~~&67&,,O"6??#4c: ./ U $$$ 9!<**-ba9  &$$  C N     .$$ 9!<++.%r$q:   ./ ($$ 9!<++.%r$q:   ./ U s

[TU]XUS9 g)Nrsuperr)rr}r%rM __class__s r'rFileResponse.__init__!s T2r)r5r rrrrbytesr/rr __classcell__rs@r'rwrw s33S33r)c4^\rSrSrS\S\4U4SjjrSrU=r$)rQi%r}r%c$>[TU]X5 grr)rr}r%rs r'rFtpResponse.__init__&s 'r)r5rrs@r'rQrQ%s((S((r)c\rSrSrS\R 4Sjr\S\4Sj5r \S\ 4Sj5r SS\ 4Sjjr \S5r\S\4S j5rS rSS \\S \ S\\4S jjrSrg)ri*responsecXlgr _response)rrs r'rUrlResponse.__init__+s!r)r9c^URRcgURR$)Nr))rcontentrs r'r}UrlResponse.contents.s% >> ! ! )~~%%%r)c.URR$r)rr%rs r'r%UrlResponse.url4s~~!!!r)cPSnU(aSnSURs=::aU:ag gg)Nr;r<rTFr)r redirects_okuppers r'rUrlResponse.ok8s- E $)) #e # $r)c.URR$r)rrUrs r'rUUrlResponse.headersAs~~%%%r)c.URR$r)r status_coders r'rMUrlResponse.codeEs~~)))r)c.URR$r)rtextrs r'rUrlResponse.__str__Is~~"""r) chunk_sizedecode_unicodec#V# URRX5ShvN gN7f)aDIterates over the response data. When stream=True is set on the request, this avoids reading the content at once into memory for large responses. :param chunk_size: Number of bytes it should read into memory. :param decode_unicode: If True, content will be decoded using the best available encoding based on the response. N)r iter_content)rrrs r'rUrlResponse.iter_contentLs>>..zJJJs )')rN)F)r!F)rrrrrequestsResponserpropertyrr}r/r%boolrrUintrMrrr rrr5r)r'rr*s"!2!2"&%&& "S""&&*c**#EJ K"3- K=A K % K Kr)rc J\rSrSrS S\S\\S\\S\\4Sjjr Sr g) ri[NrTrMrUr%c~[RU[U55 XlX lUc0OUUlX@lgr)r|rr/rTrMrUr%)rrTrMrUr%s r'rUrlError.__init__\s4 s5z*  &-o7 r)rS)NNN) rrrrr rrrr/rrr5r)r'rr[sJ#%)!  sm '"  c]  r)c0n[U5RnUS:XaWU(aPSU;aUS(a USUS'OSUS'SU;aSU;aUSUS/US'U$SU;a[US5US'U$)Nrca_certsverifyT cert_filekey_filecert)rr r/)r% ssl_detailsssl_argsr s r' _get_ssl_argsrjsH c] ! !F [  $Z)@!,Z!8HX !%HX  + %* *CK(J' HV  OK '";{#;US9nUnSnAO2SnAf[4R@anUS9nUnSnSnAOSnAff=f[CUU S9nU(dU =(d US -U:nU(dUUeU=(d Un US:dGMJU(a[$R'SU5 [DRF"U 5 GM)aWrapper around requests.Session to read the url and retry if necessary :param url: Mandatory url to request. :param data: Optional form data to post the URL. Will set request_method to 'POST' if present. :param timeout: Timeout in seconds to wait for a response. May be a tuple if specifying (connection timeout, read timeout). :param retries: Number of times to retry on exception if exception_cb is None or exception_cb returns True for the exception caught. Default is to fail with 0 retries on exception. :param sec_between: Default 1: amount of seconds passed to time.sleep between retries. None or -1 means don't sleep. :param headers: Optional dict of headers to send during request :param headers_cb: Optional callable returning a dict of values to send as headers during request :param headers_redact: Optional list of header names to redact from the log :param ssl_details: Optional dict providing key_file, ca_certs, and cert_file keys for use on in ssl connections. :param check_status: Optional boolean set True to raise when HTTPError occurs. Default: True. :param allow_redirects: Optional boolean passed straight to Session.request as 'allow_redirects'. Default: True. :param exception_cb: Optional callable to handle exception and returns True if retries are permitted. :param session: Optional exiting requests.Session instance to reuse. :param infinite: Bool, set True to retry indefinitely. Default: False. :param log_req_resp: Set False to turn off verbose debug messages. :param request_method: String passed as 'method' to Session.request. Typically GET, or POST. Default: POST if data is provided, GET otherwise. :param stream: if False, the response content will be immediately downloaded. )r%rrPOSTGETmethodNrOrr!z Cloud-Init/%sryz User-AgentrUz'[%s/%s] open '%s' with %s configurationrz(Read from %s (%s, %sb) after %s attempts)r%rMrUr%r1Please wait %s seconds while we wait to try againz"This path should be unreachable...r5)%r(updaterrFtuplemaxrrrversion_stringcopyrSessionr itemsrDdeepcopyrrIrfrequestraise_for_statusrlenrrrSSLErrorr HTTPErrorrrURequestExceptionrrsleep RuntimeError)!r%ryrOrrrUrrrrrrrrrrrreq_args manual_tries user_agentifiltered_req_argskvmatched_headerskeyrrt url_errorraised_exceptionresponse_sleep_time will_retry sleep_times! r'rrs[j C.CH OOM#34"1H  #'U'HX gu % %")HY "%eGna"8HY L3wTbT$US-S-$)Nr!r5)_rIrs r'default_sleep_time(wait_for_url..default_sleep_time s'3zM9IA9MMr)rrC start_timerczU[S5S4;agUS:*=(d [R"5U- U-U:$)z4Check if time is up based on start time and max waitrBNFr)rr monotonic)rCrOrs r'timeupwait_for_url..timeups@ e d+ +A  NN z )J 6 A r)rr%cSnSnU(aU(dSn[[U55nX24$URR5 UR(d;SUR-n[[U5URURUS9nX24$UR5(d8SUR-n[[U5URURUS9nX24$![R R aKn[UURRURRUS9nU[U54sSnA$SnAff=f)z?Map requests response code/contents to internal "UrlError" typer#NzRequest timed outrzempty response [%s]zbad status code [%s])rrrrrrrrrrUr/r}rMr)rr%reasonurl_excrts r'handle_url_response)wait_for_url..handle_url_responses4S(Fz&12G? " #    / / 1  *hmmSnSnU"U5upgT "Xv5upU(d [XgSS9$[[R "5U- 5n T(aST-OSn SU=(d [ US S 5<S U <S U <S U<3n U"U 5 [SS[U[5(a [XS 9S9$SS9$![an SU -nU nSn A NSn A f[an SU -nU nSn A NSn A ff=f)z:Execute request, handle response, optionally log exceptionr#N)r@zrequest error [%s]zunexpected error [%s]z%ss unlimitedz Calling 'r%z ' failed [r,z]: rr%rr@) r?r ExceptionrrrQgetattrrFr)rYrZrOr[r\rUr%rrVrt time_taken max_wait_str status_msgrWrCs r'read_url_handle_exceptions0wait_for_url..read_url_handle_exceptionsAs  )$/MC1(@OG&sEE)J67 +3ux'  177E51 1     zgx00g;      ! )A-FG ,q0FG s#$B55 C)?C  C)C$$C)rOc 6>[UTc0OT"U5TUSTS9$)NF)rUrrOrr)r)r%rOrrrs r' read_url_cb!wait_for_url..read_url_cbms- $,B*S/))   r)c>^S[4U U4Sjjn/nTHn[R"5nT S:waIT (dBT"T U5(a [SSSS9s $T b$T(aUT-UT -:a[ UT -U- 5mT"XFXU5nUR (aUs $UR (dMURUR 5 M U(a [U5OSn [SSU S9$)zliterate over list of urls, request each one and handle responses and thrown exceptions individually per url r%c>UT"UT54$rr5)r%rhrOs r'url_reader_serial@wait_for_url..read_url_serial..url_reader_serial~sS'23 3r)rNr_) r/rrQr?rrr@r/r)rOrOr[r\rl wait_timesr%nowoutr@loop_nrCmust_try_againrhrerRrZs ` r'read_url_serial%wait_for_url..read_url_serialws 43 4 4 C.."C{>(J//* 44(w*x*?@":#8C"?@G,! FC|| !!#--0+,(2C Ot 4$)LLr)c:>[[TTUS9nT"UTXU5$)zpass list of urls to dual_stack which sends requests in parallel handle response and exceptions of the first endpoint to respond )r&rO)rr=) rOrOr[r\url_reader_parallelrGrhrerZs r'read_url_parallel'wait_for_url..read_url_parallels4 &  %   * z6  r)z3sleep_time and sleep_time_cb are mutually exclusiveNTFr!r)FN)r)rrrrr/rrr r rrExceptionCallbackr?rrQrrr%r}r@r rIrf)rZrCrOrDrrrrrErrFrGrMrsrwrO do_read_urlcalculate_sleep_timerrespcurrent_sleep_time current_timerWrqrrrhrerRs`` ``` ` ` @@@@@@r' wait_for_urlrs\^N3N5N  E u '!;''!.6sm'! x!3& ''!R*  E5#(==> > * CcN# *  * " * *  * * X  s {  "M "M"MH   !JmNOO16G)>,>FH : H ==88T]]333 3 ^^ JJt~~ &aZF!N 1(FC (J(: ; ; " ! ?   %&~~' |g- X0EE,";>$2E2E#F#F""Xd.A.A-B#CDd###Gyy}GGDD GGD EDs$#B<8B" B<" B0 ,B<< C czUR(dgUR5nUc0nX#U'[R"SUR35 [ URSS9nUR [ R"U55 SSS5 SSS5 g!,(df  N=f!,(df  g=f)NzWriting wr)rrrrrrmrdumps)rr[valuecurrs r'update_skew_fileOauthUrlHelper.update_skew_files"" !!# ;CD   $*=*=)>? @$   cC  HHTZZ_ %C @ @C C @ @s$B,$&B B, B) %B,, B:c[U[5(a URS:XdURS:XdgSUR;a![R SUR5 gURSn[ R"[U55n[U[ R "5- 5n[UR5RnURRUS5n[!Xu- 5UR":a'UR%Xe5 [R SXe5 XPRU'g![a n[R SX$5 SnAgSnAff=f)Niidatez$Missing header 'date' in %s responsez#Failed to convert datetime '%s': %srz$Setting oauth clockskew for %s to %d)rFrrMrUrIrJrrrr`rrr%netlocrrDabsrr)rr.r remote_timertskewr[old_skews r'rOauthUrlHelper.exception_cbs y( + +3&)..C*?  ** * KK>  O   ( ++io6K ;,- &-->>%%dA. x $"8"8 8  ! !$ - KK> K#t  KK=t G  s8E E.E))E.c ^UR(d0$Sn[U5RnUR(a=X0R;a.[ [ R "55URU-n[ UURURURURUS9$)N)r%rrrr timestamp) rrrrrr oauth_headersrrrr)rr%rr[s r'rOauthUrlHelper.headers_cb*s~~I }## >>dnn4DIIK(4>>$+??I**nn** 00   r)c[URURS55US'[URURS55US'U"U0UD6$)Nrr)r _headers_cbrD _exception_cb)r wrapped_funcrrPs r'_wrappedOauthUrlHelper._wrapped<s\&   fjj6 |")    > :" ~T,V,,r)c.UR[X5$r)rrrs r'rOauthUrlHelper.wait_for_urlEs}}\488r)c.UR[X5$r)rrrs r'rOauthUrlHelper.readurlHs}}Wd33r)cxSnU(aU"U5nURU5 U$!URU5 f=f)NTr)rextra_exception_cbr.rets r'rOauthUrlHelper._exception_cbKs> )!(3   i (    i (s&9ch0nU(aU"U5nURURU55 U$r)rr)rextra_headers_cbr%rUs r'rOauthUrlHelper._headers_cbTs. &s+Gts+,r))rrrrrrrr)NNNNz/run/oauth_skew.json)rrrrrrrrrrrrrrrr5r)r'rrsE- #6 &8 $-94r)rc SSKJn U(a [ U5nOSnUR UUUUUR US9nURU5upn U $![an[S5UeSnAff=f)Nrzoauth support is not available) client_secretresource_owner_keyresource_owner_secretsignature_methodr)oauthlib.oauth1oauth1 ImportErrorNotImplementedErrorr/ClientSIGNATURE_PLAINTEXTsign) r%rrrrrrrtclient_urisigned_headers_bodys r'rr\sK( N  ]]%$*33 F#)++c"2D% # K!"BCJKsA A, A''A,)rZr)r$ )Mrr>rbrloggingrr*rconcurrent.futuresrrr email.utilsr functoolsr http.clientr itertoolsr sslr typingr r r rrrrrr urllib.parserrrrrr cloudinitrrr getLoggerrrIrrryr(r8rrNr/rdictrvr~rrrwrQrr|rrrrrr+r#r=r?rfrrrr5r)r'rs\   MM!!&   ?>00 ! XzlD&89:"  s.3D MS M~ M & 78&< - -3>3 (.( .K.Kb w $#%J'+ $e_ J    &*  %m=$m=$ %m=&'m=j"  38   ??  E?   *! P- 38 P-CyP-P- P-  8C=(;/ /0 P-fjEl#))%)"&&*=A"&||e_ |  | " ||$|Hc5\5%89:|| ||~||@LPr)