o .jy@sddlmZddlZddlmZddlmZddlmZ ej r7ddl m Z ddl mZdd lmZdd lmZdd lmZmZmZmZmZGd d d edZdS)) annotationsN)ABCMeta)contextmanager)timeout) HttpVersion)DirectStreamAccess) HTTPResponse) TrafficPolice) BaseSSLError ProtocolErrorReadTimeoutErrorSSLErrorMustRedialErrorc@seZdZdZd4ddZed5ddZed5d d Zed6d d Z d7ddZ ed8ddZ e d9ddZ e d:ddZe d;ddZe dd)d*Zd?d-d.Zd@d1d2Zd3S)AExtensionFromHTTPzRepresent an extension that can be negotiated just after a "101 Switching Protocol" HTTP response. This will considerably ease downstream integration.returnNonecCsd|_d|_d|_dSN)_dsa _response_police_officerselfr[/home/thesage/.local/lib/python3.10/site-packages/urllib3/contrib/webextensions/protocol.py__init__s zExtensionFromHTTP.__init__"typing.Generator[None, None, None]c cs d}zzdVWnhty-}zd}|jr t|jdr |jjnd}t|dd|d}~wty[}z#dt|vr?t||d}|jrNt|jdrN|jjnd}t|dd|d}~wtt fyq}z t d|||d}~wwd}W|s|jr| dSdSdS|s|jr| www) Catch low-level python exceptions, instead re-raising urllib3 variants, so that low-level exceptions are not leaked in the high-level api. On unrecoverable issues, release the connection back to the pool. FNT_poolRead timed out.zread operation timed outConnection broken: ) SocketTimeoutrhasattrrr r strrOSErrorrr closer clean_exitepoolrrr_read_error_catcher sT          z%ExtensionFromHTTP._read_error_catcherc csd}z^zdVWnFty+}z|jrt|jdr|jjnd}t|dd|d}~wty;}zt||d}~wtyO}z td|||d}~wwd}W|s^|jr`| dSdSdS|sl|jrm| www)rFNrrr T) r!rr"rr r rr$r r%r&rrr_write_error_catcherVs@       z&ExtensionFromHTTP._write_error_catcherdict[str, typing.Any]cCsiS)zIReturn prerequisites. Must be passed as additional parameters to urlopen.rrrrrurlopen_kwargsz ExtensionFromHTTP.urlopen_kwargsresponser cCs:|jdus t|jdstd|jj|_|j|_||_dS)zEThe HTTP server gave us the go-to start negotiating another protocol.NrzJAttempt to start an HTTP extension without direct I/O access to the stream)_fpr" RuntimeErrorrrr)rr/rrrstarts  zExtensionFromHTTP.startboolcCs |jduSr)rrrrrcloseds zExtensionFromHTTP.closedset[HttpVersion]cCt)z3Hint about supported parent SVN for this extension.NotImplementedErrorrrrr supported_svnr.zExtensionFromHTTP.supported_svnr#cCr6rr7rrrrimplementationz ExtensionFromHTTP.implementationset[str]cCr6)z%Recognized schemes for the extension.r7rrrrsupported_schemesr.z#ExtensionFromHTTP.supported_schemesschemecCr6)zJConvert the extension scheme to a known http scheme (either http or https)r7)r>rrrscheme_to_http_schemer.z'ExtensionFromHTTP.scheme_to_http_scheme http_versionrdict[str, str]cCr6)zHSpecific HTTP headers required (request) before the 101 status response.r7)rr@rrrheadersr;zExtensionFromHTTP.headerscCr6)z"End/Notify close for sub protocol.r7rrrrr%r;zExtensionFromHTTP.closestr | bytes | NonecCr6)zUnpack the next received message/payload from remote. This call does read from the socket. If the method return None, it means that the remote closed the (extension) pipeline. r7rrrr next_payloadszExtensionFromHTTP.next_payloadbuf str | bytescCr6)zDispatch a buffer to remote.r7)rrErrr send_payloadr;zExtensionFromHTTP.send_payloadcallback+typing.Callable[[str | bytes | None], None]cCr6)zSet up a callback that will be invoked automatically once a payload is received. Meaning that you stop calling manually next_payload().r7)rrHrrr on_payloadr.zExtensionFromHTTP.on_payloadN)rr)rr)rr,)r/r rr)rr3)rr5)rr#)rr<)r>r#rr#)r@rrrA)rrC)rErFrr)rHrIrr)__name__ __module__ __qualname____doc__rrr*r+propertyr-r2r4 staticmethodr9r:r=r?rBr%rDrGrJrrrrrs2  5 *           r) metaclass) __future__rtypingabcr contextlibrsocketrr! TYPE_CHECKINGbackendr backend._baserr/r util.traffic_policer exceptionsr r r rrrrrrrs