o h~@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@mAZAGdddZBGdddeBZCGdddeBZDdejEe6dedejEededejEeded e d!eFd"ejGeHeffd#d$ZIdS)%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!@s@eZdZddddddddeeedddddddededede de d e d e d e d ed edededejeefdejdedef ddZedefddZejdeddfddZedefddZejde ddfddZede fddZ!e!jdeddfddZ!deddfd d!Z"d"ede#fd#d$Z$ d=de dej%e fd%d&Z& d=dedej%efd'd(Z' d=dedej%efd)d*Z(d+ddddddd,d-e)d.eded/ede d e d edede*fd0d1Z+ d=d-e)dededej%e,fd2d3Z-d-e)d ej.e/efdefd4d5Z0ddddddd6d7e/d"ed8e1d9e2d:ej3dedede de)fd;d<Z4dS)> BaseClientNT)authparamsheaderscookiesverifycert http_versionsproxiestimeout pool_limits max_redirectsbase_urldispatchappbackend trust_envr1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@c CsF|durt}|||dur.tt|j}|dvsJ|dkr(t|d} nt||d} |dur4dn||_| durHt ||| || ||jd}n t | t rSt | |}n| }| durat ddd|_nt | |_|durli}||_t||_t||_t||_| |_||_||_|dur|rttt}t|||| || ||d|_dS) N)rA)r>)r>r?T)r5r6r9r7r:r?r@)Zallow_relative)rcheck_concurrency_backendleninspect signature parametersrrr@r isinstancerrrr<r1r&_paramsr#_headersr!_cookiesr;r=concurrency_backendtypingcastr%r._proxies_to_dispatchersr8)selfr1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@Z param_countZasync_dispatchrRT/var/www/html/magazine_api/magazine_env/lib/python3.10/site-packages/httpx/client.py__init__7s^           zBaseClient.__init__returncC|jSN)rKrQrRrRrSr3zBaseClient.headerscCt||_dSrW)r#rK)rQr3rRrRrSr3cCrVrW)rLrXrRrRrSr4rYzBaseClient.cookiescCrZrW)r!rL)rQr4rRrRrSr4r[cCrVrW)rJrXrRrRrSr2rYzBaseClient.paramscCrZrW)r&rJ)rQr2rRrRrSr2r[cCsdSrWrRrQr?rRrRrSrDz$BaseClient.check_concurrency_backendurlcCs4|jj|d}|jdkrt|jr|jdd}|S)N)Z relative_urlhttphttps)scheme)r<joinra hstspreloadZin_hsts_preloadhost copy_with)rQr^rRrRrS merge_urls zBaseClient.merge_urlcC&|s|jrt|j}|||S|SrW)r4r!update)rQr4merged_cookiesrRrRrS merge_cookies   zBaseClient.merge_cookiescCrgrW)r3r#rh)rQr3Zmerged_headersrRrRrS merge_headersrkzBaseClient.merge_headerscCrgrW)r2r&rh)rQr2Zmerged_queryparamsrRrRrSmerge_queryparamsrkzBaseClient.merge_queryparamsFstreamr1allow_redirectsr5r6r9r@requestrorpc s|jjdvr td|jdtdtffdd } dtjdt dtjfd d } | | t |j d } j ||durCj n||durKjn|d } | durX| | | } | |IdHS) Nr_r`z%URL scheme must be "http" or "https".rqrUc sz%t}j|dIdH}Wdn1swY|j|_Wnty;}z |jdur6||_d}~wwj|s^z|IdHW|IdH|S|IdHw|S)N)r5r6r9) r-sendelapsedrrqr4extract_cookiesreadclose)rqZtimerresponseexcr6r=rQror9r5rRrS get_responses,   z.BaseClient._get_response..get_responser{ middlewarecSstj||dS)N)r{) functoolspartial)r{r|rRrRrSwrapsz&BaseClient._get_response..wrap)rpr4)rqr@r1)r^rar_dispatcher_for_requestr8rrrNCallablerrr4_get_auth_middlewarer@r1) rQrqror1rpr5r6r9r@r{rZauth_middlewarerRrzrS _get_responses0     zBaseClient._get_responsecCst|trt|d|ddSt|tr|St|rt|dS|dur+td|d|jjs3|jj r=t|jj|jj dS|rRt |jj }|rR|\}}}t||dSdS)Nrr)usernamepassword)r1z}When specified, "auth" must be a (username, password) tuple or a callable with signature (AsyncRequest) -> AsyncRequest (got )) rItuplerrcallabler TypeErrorr^rrr/ authority)rQrqr@r1Z netrc_loginr_rrRrRrSrs,       zBaseClient._get_auth_middlewarec Cs|rZ|j}|jdkr|jdkp|jdko|jdk}|jd|j}|jd||r4|jd|jndd||rAd|jnd|jd f}|D]}|rY||vrY||}|SqI|jS) zIGets the AsyncDispatcher instance that should be used for a given Requestr_Pr`i:z://Nzall://all)r^raportrdr=) rQrqr8r^Zis_default_porthostname proxy_keys proxy_key dispatcherrRrRrSrs& z"BaseClient._dispatcher_for_requestdatafilesjsonr2r3r4methodrrrc CsD||}||}||}||}t||||||||d} | S)Nr)rfrlrjrmr) rQrr^rrrr2r3r4rqrRrRrS build_request8s    zBaseClient.build_requestrW)5__name__ __module__ __qualname__rrrr r'r$r"r r r r%r r intr,rNUnionrrrrboolrTpropertyr#r3setterr!r4r&r2rDrrfOptionalrjrlrmrrrrrDictstrrrr)AnyrrRrRrRrSr06s,       P         ?      r0c!@seZdZddddddddddd dedededed ed ed ed e d e de dede fddZ ddddddddddd dedededed ed ed ed e d e de dede fddZddddddddddd dedededed ed ed ed e d e de dede fddZdddddddddddddd dedededejdededed ed ed ed e d e de dede fddZdddddddddddddd dedededejdededed ed ed ed e d e de dede fddZdddddddddddddd dedededejdededed ed ed ed e d e de dede fdd Zdddddddddddddd dedededejdededed ed ed ed e d e de dede fd!d"Zdddddddddddddd d#ededededejdededed ed ed ed e d e de dede f d$d%Zdddddddd&d'ed ed ed ed e d e de dede fd(d)Zd3d*d+Zd4d,d-Z   d5d.ejed/ed0e ddfd1d2Z!dS)6 AsyncClientNFT r2r3r4ror1rpr6r5r9r@r^r2r3r4ror1rpr6r5r9r@rUc *|jd|||||||| || | d IdHSNGET r2r3r4ror1rpr5r6r9r@rq rQr^r2r3r4ror1rpr6r5r9r@rRrRrSgetV zAsyncClient.getc rNOPTIONSrrrrRrRrSoptionstrzAsyncClient.optionsc rNHEADrrrrRrRrSheadrzAsyncClient.head rrrr2r3r4ror1rpr6r5r9r@rrrc 0|jd||||||||| | | | | |dIdHSNPOST rrrr2r3r4ror1rpr5r6r9r@rrQr^rrrr2r3r4ror1rpr6r5r9r@rRrRrSpost$ zAsyncClient.postc rNPUTrrrrRrRrSputrzAsyncClient.putc rNPATCHrrrrRrRrSpatchrzAsyncClient.patchc rNDELETErrrrRrRrSdeleterzAsyncClient.deleterc  s@|j||||||||d}|j|| | | | | ||dIdH}|SN)rr^rrrr2r3r4rn)rrsrQrr^rrrr2r3r4ror1rpr6r5r9r@rqrxrRrRrSrq@s,   zAsyncClient.requestrnrqc s"|j||||||||dIdHS)N)rqror1rpr5r6r9r@)r) rQrqror1rpr5r6r9r@rRrRrSrsis  zAsyncClient.sendcs|jIdHdSrW)r=rwrXrRrRrSrwszAsyncClient.closecs|SrWrRrXrRrRrS __aenter__szAsyncClient.__aenter__exc_type exc_value tracebackcs|IdHdSrWrwrQrrrrRrRrS __aexit__szAsyncClient.__aexit__rUN)rUrNNN)"rrrr,r'r$r"rr r r r rrrrrr)rNrrrrrrrqrrsrwrType BaseExceptionrrrRrRrRrSrUs      "      "      "      (      (      (      )      -    rc!@seZdZdeddfddZ d:dedejefddZ de de fd d Z ddddddd dd ddddd de dedededejdededededededededededef ddZd dd ddddddededededededededefd d!Zdddd dd ddddd" dedededededededededededefd#d$Zdddd dd ddddd" dedededededededededededefd%d&Zdddd dd ddddd" dedededededededededededefd'd(Zddddddd dd ddddd dedededejdededededededededededefd)d*Z ddddddd dd ddddd dedededejdededededededededededefd+d,Z!ddddddd dd ddddd dedededejdededededededededededefd-d.Z"ddddddd dd ddddd dedededejdededededededededededefd/d0Z#d;d1d2Z$dClientr?rUNcCs$t|trdSt|drdStd)Nloopz9'Client' only supports asyncio-based concurrency backends)rIrhasattr ValueErrorr\rRrRrSrDs  z Client.check_concurrency_backendrcCs6|dus t|tttfr|St|dsJ|j|S)z} If the request data is an bytes iterator then return an async bytes iterator onto the request data. N__iter__)rIrbytesdictrrMZiterate_in_threadpoolrQrrRrRrS_async_request_datas zClient._async_request_datacCs(t|tr|St|dsJ|j|S)N __aiter__)rIrrrMZiteraterrRrRrS _sync_datas  zClient._sync_dataFTrrr^rrr2r3r4ror1rpr6r5r9r@c  Cs>|j|||||||||d}|j|| | | | | ||d}|Sr)rrrsrrRrRrSrqs*  zClient.requestrnrqc s|j|j} |g} d||||||d} j| g| Ri| tdtdd} || } d fdd }tjjj| |j j j d}|s[z | W| |S| w|S) NTrnZ _raw_contentZ _raw_streamrUcsjdSrW)runon_closerRZasync_responserMrRrS sync_on_closesz"Client.send..sync_on_close) status_code http_versionr3contentrrqhistoryrtr)rMrrgetattrrr*rrr3rqrrtrvrw)rQrqror1rpr5r6r9r@ coroutineargskwargsrZ sync_contentrrxrRrrSrssD      z Client.sendrc C"|jd|||||||| || | d SrrrrRrRrSrz Client.getc CrrrrrRrRrSr7rzClient.optionsc CrrrrrRrRrSrUrz Client.headc C(|jd||||||||| | | | | |dSrrrrRrRrSrs"z Client.postc CrrrrrRrRrSrrz Client.putc CrrrrrRrRrSrrz Client.patchc CrrrrrRrRrSrrz Client.deletecCs|jj}|j|dSrW)r=rwrMr)rQrrRrRrSrwsz Client.closecCs|SrWrRrXrRrRrS __enter__r]zClient.__enter__rrrcCs |dSrWrrrRrRrS__exit__ s zClient.__exit__rWr)rUrr)*rrrrrDr(rNrrrrr+rrr,r)rr'r$r"rr r r r r*rqrrsrrrrrrrrwrrrrrrRrRrRrSrs       -   :      "      "      "      (      (      (      $ rr8r5r6r9r7r:r?r@rUc sdtdtffdd }|duriSt|ttfr$d||iSt|tr-d|iSi} |D]\} } t| ttfrG|| | t| <q3| | t| <q3| S)Nr^rUc s8t|}|jdvrt|dStd|)Nrr)r5r6r9r:r?r@r7zUnknown proxy for )rrarr)r^r?r6r7r:r9r@r5rRrS_proxy_from_urls  z0_proxies_to_dispatchers.._proxy_from_urlr)r,rrIrritems) r8r5r6r9r7r:r?r@r new_proxieskeyZdispatcher_or_urlrRrrSrPs"   rP)Jr}rFrNtypesrrcZconcurrency.asynciorZconcurrency.baserconfigrrrr r r r r Z dispatch.asgirZ dispatch.baserrZdispatch.connection_poolrZdispatch.proxy_httprZdispatch.threadedrZ dispatch.wsgir exceptionsrrZmiddleware.baserZmiddleware.basic_authrZmiddleware.custom_authrZmiddleware.redirectrmodelsrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,utilsr-r.r/r0rrrrrrrPrRrRrRrSsd   (         P!<