iddlmZddlZddlmZddlmZddlmZ ej rddl m Z ddl mZdd lmZdd lmZdd lmZmZmZmZmZGd d eZdS)) annotationsN)ABCMeta)contextmanager)timeout) HttpVersion)DirectStreamAccess) HTTPResponse) TrafficPolice) BaseSSLError ProtocolErrorReadTimeoutErrorSSLErrorMustRedialErrorc eZdZdZd%dZed&dZed&dZed'd Z d(d Z ed)dZ e d*dZ e d+dZe d,dZe d-dZd.dZd%dZd/dZd0d Zd1d#Zd$S)2ExtensionFromHTTPzRepresent an extension that can be negotiated just after a "101 Switching Protocol" HTTP response. This will considerably ease downstream integration.returnNonec0d|_d|_d|_dSN)_dsa _response_police_officerselfs h/root/projects/butler/venv/lib/python3.11/site-packages/urllib3_future/contrib/webextensions/protocol.py__init__zExtensionFromHTTP.__init__s/3 .259"typing.Generator[None, None, None]c#rKd} dVn#t$rC}d}|jr!t|jdr |jjnd}t |dd|d}~wt $rd}dt |vrt||d}|jr!t|jdr |jjnd}t |dd|d}~wttf$r}td|||d}~wwxYwd}|s|jr| dSdSdS#|s|jr| wwwxYw) 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: ) SocketTimeoutrhasattrr"rr strrOSErrorrr closer clean_exitepools r_read_error_catcherz%ExtensionFromHTTP._read_error_catcher s ) ! K  M M M! ~*1$.'*J*JDN(( 'tT3DEE1L M M M-SVV;;"1++1,! ~*1$.'*J*JDN(( 'tT3DEE1L_- K K K#$?!$?$?CCJ K J !>!JJLLLLL  ! !!!  !>!JJLLLL  !!s> D C->A C-!ACC-C((C--D!D6c#Kd} dVn#t$rA}|jr!t|jdr |jjnd}t |dd|d}~wt $r}t ||d}~wt$r}td|||d}~wwxYwd}|s|jr| dSdSdS#|s|jr| wwwxYw)r!FNr"r#r$T) r%rr&r"rr rr(r r)r*s r_write_error_catcherz&ExtensionFromHTTP._write_error_catcherVs\  ! K  M M M~*1$.'*J*JDN(( 'tT3DEE1L ) ) )qkkq( K K K#$?!$?$?CCJ K J !>!JJLLLLL  ! !!!  !>!JJLLLL  !!s= B= Brms3"""""" %%%%%%++++++ 5&&&&&&333333((((((444444f"f"f"f"f"'f"f"f"f"f"f"r