U ]~ @sddlZddlZddlZddlmZddlZddlmZddlm Z ddl m Z m Z m Z mZmZmZmZmZddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZdd l m!Z!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mm?Z?m@Z@mAZAGdddZBGdddeBZCGdddeBZDejEe6eejEeeejEeee eFejGeHefd ddZIdS)N) TracebackType)AsyncioBackend)ConcurrencyBackend)DEFAULT_MAX_REDIRECTSDEFAULT_POOL_LIMITSDEFAULT_TIMEOUT_CONFIG CertTypesHTTPVersionTypes PoolLimits TimeoutTypes VerifyTypes) ASGIDispatch)AsyncDispatcher Dispatcher)ConnectionPool) HTTPProxy)ThreadedDispatcher) WSGIDispatch) HTTPError InvalidURL)BaseMiddleware)BasicAuthMiddleware)CustomAuthMiddleware)RedirectMiddleware)URL AsyncRequestAsyncRequestData AsyncResponseAsyncResponseContent AuthTypesCookies CookieTypesHeaders HeaderTypes ProxiesTypes QueryParamsQueryParamTypes RequestData RequestFilesResponseResponseContentURLTypes) ElapsedTimerget_environment_proxiesget_netrc_loginc@seZdZddddddddeeeddddddeeee e e e e eeeeejeefejeedddZeedddZejedd d dZeedd d Zeje dd dd Zee dddZ!e!jeddddZ!eddddZ"ee#dddZ$d.e ej%e d ddZ&d/eej%ed ddZ'd0eej%edddZ(dddddddd e)eeee e eee*d! d"d#Z+d1e)eeej%e,d$d%d&Z-e)ej.e/efed'd(d)Z0ddddddd*e/ee1e2ej3eee e)d+ d,d-Z4dS)2 BaseClientNT)authparamsheaderscookiesverifycert http_versionsproxiestimeout pool_limits max_redirectsbase_urldispatchappbackend trust_envc CsJ|dkrt}|||dk r\tt|j}|dks)r>r?T)r5r6r9r7r:r?r@)Zallow_relative) rcheck_concurrency_backendleninspect signature parametersAssertionErrorrrr@r isinstancerrrr<r1r&_paramsr#_headersr!_cookiesr;r=concurrency_backendtypingcastr%r._proxies_to_dispatchersr8)selfr1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@Z param_countZasync_dispatchrSl/var/www/html/staging.mfahmagazine.net/magazine_api/magazine_env/lib/python3.8/site-packages/httpx/client.py__init__7s^          zBaseClient.__init__returncCs|jSN)rLrRrSrSrTr3szBaseClient.headers)r3rWcCst||_dSrX)r#rL)rRr3rSrSrTr3scCs|jSrX)rMrYrSrSrTr4szBaseClient.cookies)r4rWcCst||_dSrX)r!rM)rRr4rSrSrTr4scCs|jSrX)rKrYrSrSrTr2szBaseClient.params)r2rWcCst||_dSrX)r&rK)rRr2rSrSrTr2sr?rWcCsdSrXrSrRr?rSrSrTrDsz$BaseClient.check_concurrency_backendurlrWcCs4|jj|d}|jdkr0t|jr0|jdd}|S)N)Z relative_urlhttphttps)scheme)r<joinr` hstspreloadZin_hsts_preloadhostZ copy_with)rRr]rSrSrT merge_urls zBaseClient.merge_urlcCs&|s |jr"t|j}|||S|SrX)r4r!update)rRr4Zmerged_cookiesrSrSrT merge_cookiess    zBaseClient.merge_cookiescCs&|s |jr"t|j}|||S|SrX)r3r#re)rRr3Zmerged_headersrSrSrT merge_headerss    zBaseClient.merge_headerscCs&|s |jr"t|j}|||S|SrX)r2r&re)rRr2Zmerged_queryparamsrSrSrTmerge_queryparamss    zBaseClient.merge_queryparamsFstreamr1allow_redirectsr5r6r9r@ requestrjr1rkr5r6r9r@rWc s|jjdkrtd|jttdfdd } tjt tjddd} | | t |j d } j ||dkr~j n||dkrjn|d } | dk r| | | } | |IdHS) Nr^r_z%URL scheme must be "http" or "https".)rmrWc sz6t}j|dIdH}W5QRX|j|_Wn4tk rj}z|jdkrX||_W5d}~XYnXj|sz|IdHW5|IdHX|S)N)r5r6r9) r-sendelapsedrrmr4Zextract_cookiescloseread)rmZtimerresponseexcr6r=rRrjr9r5rSrT get_responses&   z.BaseClient._get_response..get_response)rv middlewarerWcSstj||dS)N)rv) functoolspartial)rvrwrSrSrTwrapsz&BaseClient._get_response..wrap)rkr4)rmr@r1)r]r`r_dispatcher_for_requestr8rrrOCallablerrr4_get_auth_middlewarer@r1) rRrmrjr1rkr5r6r9r@rvrzZauth_middlewarerSrurT _get_responses(    zBaseClient._get_response)rmr@r1rWcCst|trt|d|ddSt|tr,|St|r>t|dS|dk rVtd|d|jjsf|jj rzt|jj|jj dS|rt |jj }|r|\}}}t||dSdS)Nrr)usernamepassword)r1z}When specified, "auth" must be a (username, password) tuple or a callable with signature (AsyncRequest) -> AsyncRequest (got )) rJtuplerrcallabler TypeErrorr]rrr/Z authority)rRrmr@r1Z netrc_loginr_rrSrSrTr}s*       zBaseClient._get_auth_middleware)rmr8rWc Cs|r|j}|jdkr|jdkp0|jdko0|jdk}|jd|j}|jd||rh|jd|jndd||rd|jnd|jd f}|D] }|r||kr||}|Sq|jS) zIGets the AsyncDispatcher instance that should be used for a given Requestr^Pr_i:z://Nzall://all)r]r`portrcr=) rRrmr8r]Zis_default_porthostnameZ proxy_keysZ proxy_key dispatcherrSrSrTr{s$  z"BaseClient._dispatcher_for_requestdatafilesjsonr2r3r4) methodr]rrrr2r3r4rWc CsD||}||}||}||}t||||||||d} | S)Nr)rdrgrfrhr) rRrr]rrrr2r3r4rmrSrSrT build_request8s     zBaseClient.build_request)N)N)N)N)5__name__ __module__ __qualname__rrrr r'r$r"r r r r%r r intr,rOUnionrrr|rboolrUpropertyr#r3setterr!r4r&r2rDrrdOptionalrfrgrhrrr~rr}Dictstrr{rr)AnyrrSrSrSrTr06s  P    ?   r0c@seZdZddddddddddd eeeeeeee e e ee d ddZ ddddddddddd eeeeeeee e e ee d dd Zddddddddddd eeeeeeee e e ee d d d Zdddddddddddddd eeeejeeeeeee e e ee d ddZdddddddddddddd eeeejeeeeeee e e ee d ddZdddddddddddddd eeeejeeeeeee e e ee d ddZdddddddddddddd eeeejeeeeeee e e ee d ddZdddddddddddddd eeeeejeeeeeee e e ee dddZddddddddeeeee e e ee d ddZddddZddd d!Zd%ejeee dd"d#d$Z!dS)& AsyncClientNFT r2r3r4rjr1rkr6r5r9r@ r]r2r3r4rjr1rkr6r5r9r@rWc s(|jd|||||||| || | d IdHSNGET r2r3r4rjr1rkr5r6r9r@rm rRr]r2r3r4rjr1rkr6r5r9r@rSrSrTgetVszAsyncClient.getc s(|jd|||||||| || | d IdHSNZOPTIONSrrrrSrSrToptionstszAsyncClient.optionsc s(|jd|||||||| || | d IdHSNZHEADrrrrSrSrTheadszAsyncClient.head rrrr2r3r4rjr1rkr6r5r9r@r]rrrr2r3r4rjr1rkr6r5r9r@rWc s.|jd||||||||| | | | | |dIdHSNZPOST rrrr2r3r4rjr1rkr5r6r9r@rrRr]rrrr2r3r4rjr1rkr6r5r9r@rSrSrTposts"zAsyncClient.postc s.|jd||||||||| | | | | |dIdHSNPUTrrrrSrSrTputs"zAsyncClient.putc s.|jd||||||||| | | | | |dIdHSNZPATCHrrrrSrSrTpatchs"zAsyncClient.patchc s.|jd||||||||| | | | | |dIdHSNZDELETErrrrSrSrTdeletes"zAsyncClient.deleterr]rrrr2r3r4rjr1rkr6r5r9r@rWc  s>|j||||||||d}|j|| | | | | ||dIdH}|SN)rr]rrrr2r3r4ri)rrorRrr]rrrr2r3r4rjr1rkr6r5r9r@rmrsrSrSrTrm@s*  zAsyncClient.requestrirlc s |j||||||||dIdHS)N)rmrjr1rkr5r6r9r@)r~) rRrmrjr1rkr5r6r9r@rSrSrTrois zAsyncClient.sendrVcs|jIdHdSrX)r=rqrYrSrSrTrqszAsyncClient.closecs|SrXrSrYrSrSrT __aenter__szAsyncClient.__aenter__exc_type exc_value tracebackrWcs|IdHdSrXrqrRrrrrSrSrT __aexit__szAsyncClient.__aexit__)NNN)"rrrr,r'r$r"rr r r r rrrrrr)rOrrrrrrrmrrorqrType BaseExceptionrrrSrSrSrTrUs " " " ( ( ( ) - rc@seZdZeddddZd-eejedddZ e e ddd Z ddddddd dd ddddd e eeeejeeeeeeeeeeed ddZd dd dddddeeeeeeeeed ddZdddd dd ddddd eeeeeeeeeeeed ddZdddd dd ddddd eeeeeeeeeeeed ddZdddd dd ddddd eeeeeeeeeeeed ddZddddddd dd ddddd eeeejeeeeeeeeeeedddZ ddddddd dd ddddd eeeejeeeeeeeeeeeddd Z!ddddddd dd ddddd eeeejeeeeeeeeeeedd!d"Z"ddddddd dd ddddd eeeejeeeeeeeeeeedd#d$Z#dd%d&d'Z$dd%d(d)Z%d.ej&e'e'e(dd*d+d,Z)dS)/ClientNrZcCs(t|trdSt|drdStddS)NZloopz9'Client' only supports asyncio-based concurrency backends)rJrhasattr ValueErrorr[rSrSrTrDs  z Client.check_concurrency_backend)rrWcCs6|dkst|tttfr|St|ds*t|j|S)z} If the request data is an bytes iterator then return an async bytes iterator onto the request data. N__iter__)rJrbytesdictrrIrNZiterate_in_threadpoolrRrrSrSrT_async_request_dataszClient._async_request_datacCs(t|tr|St|dst|j|S)N __aiter__)rJrrrIrNZiteraterrSrSrT _sync_datas zClient._sync_dataFTrrc  Cs>|j|||||||||d}|j|| | | | | ||d}|Sr)rrrorrSrSrTrms*  zClient.requestrirlc s|j|j} |g} d||||||d} j| f| | tdtdd} || } ddfdd }tjjj| |j j j d}|sz | W5| X|S) NTriZ _raw_contentZ _raw_streamrVcsjdSrX)runon_closerSZasync_responserNrSrT sync_on_closesz"Client.send..sync_on_close) status_code http_versionr3contentrrmhistoryrp)rNr~rgetattrrr*rrr3rmrrprqrr)rRrmrjr1rkr5r6r9r@ coroutineargskwargsrZ sync_contentrrsrSrrTrosD       z Client.sendrrc Cs"|jd|||||||| || | d SrrrrSrSrTrsz Client.getc Cs"|jd|||||||| || | d SrrrrSrSrTr7szClient.optionsc Cs"|jd|||||||| || | d SrrrrSrSrTrUsz Client.headrc Cs(|jd||||||||| | | | | |dSrrrrSrSrTrss"z Client.postc Cs(|jd||||||||| | | | | |dSrrrrSrSrTrs"z Client.putc Cs(|jd||||||||| | | | | |dSrrrrSrSrTrs"z Client.patchc Cs(|jd||||||||| | | | | |dSrrrrSrSrTrs"z Client.deleterVcCs|jj}|j|dSrX)r=rqrNr)rRrrSrSrTrqsz Client.closecCs|SrXrSrYrSrSrT __enter__szClient.__enter__rcCs |dSrXrrrSrSrT__exit__ szClient.__exit__)N)NNN)*rrrrrDr(rOrrrrr+rrr,r)rr'r$r"rr r r r r*rmrrorrrrrrrrqrrrrrrSrSrSrTrs  - : " " " ( ( ( $r) r8r5r6r9r7r:r?r@rWc sttdfdd }|dkr,iSt|ttfrFd||iSt|trXd|iSi} |D]4\} } t| ttfr|| | t| <qd| | t| <qd| SdS)Nr\c s<t|}|jdkr*t|dStd|dS)Nrn)r5r6r9r:r?r@r7zUnknown proxy for )rr`rr)r]r?r6r7r:r9r@r5rSrT_proxy_from_urls  z0_proxies_to_dispatchers.._proxy_from_urlr)r,rrJrritems) r8r5r6r9r7r:r?r@rZ new_proxieskeyZdispatcher_or_urlrSrrTrQs   rQ)JrxrFrOtypesrrbZconcurrency.asynciorZconcurrency.baserconfigrrrr r r r r Z dispatch.asgirZ dispatch.baserrZdispatch.connection_poolrZdispatch.proxy_httprZdispatch.threadedrZ dispatch.wsgir exceptionsrrZmiddleware.baserZmiddleware.basic_authrZmiddleware.custom_authrZmiddleware.redirectrZmodelsrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,utilsr-r.r/r0rrrrrrrQrSrSrSrTsP   (         P!<