dbfdg 3 °Îwhã@sÂddlZddlZddlZddlmZddlZddlmZmZddlmZddlm Z ddlm Z ddlmZm Z mZmZmZd d „Zddd „Zdd„Zdd„Zddd„Zdd„Zdd„ZeƒZdS)éN)ÚSSLErroré)ÚconfigÚ constants)Ú log_utils)Úutils)Úerrors)ÚRequestÚstd_urlopenÚ HTTPErrorÚURLErrorÚhttplibc Os°t|dƒr|jƒ}n|}t|ƒ}|jdiƒ}|jtjtjdœƒx |jƒD]\}}|j ||ƒqJWt jdj||ƒƒyltj rd|krtj|d<tjrÒttddƒrÒtjƒ}d|_tj|_||d<t|f|ž|ŽSt|f|ž|ŽStk r.}z0|jd krtj|j|j|j|j|jƒ‚‚WYdd}~Xn~t k rª}z`|j!r„t|j!d dƒr„|j!d j"t"j#kr„tj|d t$|ƒddƒ‚dj||ƒ|_%||_‚WYdd}~XnXdS) NÚget_full_urlÚheaders)z KC-VersionzKC-Patch-Versionz#Requesting url: `{0}`. Headers: {1}ÚtimeoutÚHAS_SNIFÚcontexti”rÚerrnozRequest for `{0}` failed: {1})&Úhasattrrr ÚpopÚupdaterÚVERSIONÚKC_PATCH_VERSIONÚitemsÚ add_headerrÚlogdebugÚformatÚPY2_6rÚHTTP_TIMEOUTÚCHECK_SSL_CERTSÚgetattrÚsslÚcreate_default_contextÚcheck_hostnameÚ CERT_NONEÚverify_moder rÚcoderÚNotFoundÚurlÚmsgÚhdrsÚfprÚargsrÚENOENTÚstrÚreason) r(r,ÚkwargsZrequest_urlrÚheaderÚvalueÚctxÚex©r5ú0/usr/libexec/kcare/python/kcarectl/http_utils.pyÚurlopen_bases> .r7Tcs‡fdd„}|S)Ncsbt|tƒrˆo|jdkSt|ttjttjfƒr2dSt |dƒr^t |jƒdkr^|jdtj kr^dSdS)NiôTr,ér)Ú isinstancerr&rr Ú HTTPExceptionrÚsocketrrÚlenr,rZ ECONNRESET)ÚeÚstate)Úretry_on_500r5r6Úcheck_functionDs (z3check_urlopen_retry_factory..check_functionr5)r?r@r5)r?r6Úcheck_urlopen_retry_factoryCs rAcCst|dƒr|jƒ}|jdƒS)Nrzfile:)rrÚ startswith)r(r5r5r6Úis_local_urlPs rCcOsV|jddƒ}|jdtjƒ}t|ƒr2t|f|ž|ŽStjt|d|dtƒ|f|ž|ŽS)Nr?TÚretry_count)r?)Úcount)rrÚRETRY_COUNTrCr7rÚretryrA)r(r,r0r?rDr5r5r6ÚurlopenVs rHcCsHt||d}tjr*|r*|jddj|ƒƒtjrD|rD|jtj|ƒ|S)N)ÚmethodÚ Authorizationz Basic {0})r rÚUPDATE_FROM_LOCALrrrÚAUTH_TOKEN_HEADER)r(Zauth_stringZ auth_tokenrIÚrequestr5r5r6Úhttp_request^srNcCs<|dkrtjdƒptjdƒS|dkr8tjdƒp6tjdƒSdS)NÚhttpZ http_proxyZ HTTP_PROXYÚhttpsZhttps_proxyZHTTPS_PROXY)ÚosÚgetenv)Úschemer5r5r6Úget_proxy_from_envisrTcCsttdƒƒpttdƒƒS)NrOrP)ÚboolrTr5r5r5r6Ú proxy_is_usedpsrV)T)NN)rrQr!rr;ÚrrrrrÚpy23r r rrr r7rArCrHrNrTrVZcheck_urlopen_retryr5r5r5r6Ús"1