Ë
|
ê^i" ã óÎ d dl mZ d dlZd dlZd dlZd dlZddlmZ ej rd dl m
|
Z
|
ddl m Z m Z ej eef Z ej$ d« Zd Z G d
|
d « Zy) é )Ú annotationsNé )ÚProxySchemeUnsupported)ÚSelfé )Ú_TYPE_PEER_CERT_RETÚ_TYPE_PEER_CERT_RET_DICTÚ _ReturnValuei @ c ó" e Zd ZdZed!d« Z d" d#dZd$dZd%dZd&dZ d'd(dZ
|
d)d*d Z d+ d,d
|
Z d-d.d Z d-d/d Z d0dddd d1dZd2dZd2dZej& d3 d4d« Zej& d5d« Zd6d7dZd8dZd9dZd8dZd:dZd8dZd;dZd<dZd2dZ d0d=d Z ej& d>d « Z ej& d?d « Z ej& d@d « Z dA dBd Z y)CÚ SSLTransportaL
|
The SSLTransport wraps an existing socket and establishes an SSL connection.
|
|
Contrary to Python's implementation of SSLSocket, it allows you to chain
|
multiple TLS connections together. It's particularly useful if you need to
|
implement TLS within TLS.
|
|
The class supports most of the socket API operations.
|
c ó2 t | d« s t d« y)zÒ
|
Raises a ProxySchemeUnsupported if the provided ssl_context can't be used
|
for TLS in TLS.
|
|
The only requirement is that the ssl_context provides the 'wrap_bio'
|
methods.
|
Úwrap_biozXTLS in TLS requires SSLContext.wrap_bio() which isn't available on non-native SSLContextN)Úhasattrr )Ú ssl_contexts õl H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\urllib3/util/ssltransport.pyÚ$_validate_ssl_context_for_tls_in_tlsz1SSLTransport._validate_ssl_context_for_tls_in_tls! s% ô { JÔ/Ü(ð5óð ð 0ó Nc ó( t j « | _ t j « | _ || _ || _ |j | j | j |¬« | _ | j | j j « y)zV
|
Create an SSLTransport around socket using the provided ssl_context.
|
)Úserver_hostnameN)
|
ÚsslÚ MemoryBIOÚincomingÚoutgoingÚsuppress_ragged_eofsÚsocketr ÚsslobjÚ _ssl_io_loopÚ do_handshake)Úselfr r r r s r Ú__init__zSSLTransport.__init__1 sm ô Ü à$8Ô!Ø à!×*Ñ*Ø MM4==¸/ð +ó
|
ð
|
×Ñ$++×2Ñ2Õ3r c ó | S ©N© ©r s r Ú __enter__zSSLTransport.__enter__H s Ø r c ó$ | j « y r" )Úclose)r Ú_s r Ú__exit__zSSLTransport.__exit__K s Ø
|
|
r c ó6 | j j « S r" )r Úfilenor$ s r r+ zSSLTransport.filenoN ó Ø{{×!Ñ!Ó#Ð#r c ó& | j ||« S r" )Ú_wrap_ssl_read)r ÚlenÚbuffers r ÚreadzSSLTransport.readQ s Ø×"Ñ" 3¨Ó/Ð/r c óD |dk7 r t d« | j |« S )Nr z+non-zero flags not allowed in calls to recv)Ú
|
ValueErrorr. )r ÚbuflenÚflagss r ÚrecvzSSLTransport.recvT s& Ø A:Ü Ð JÓKÐ KØ×"Ñ" 6Ó*Ð*r c ó` |dk7 r t d« | t |« }| j ||« S )Nr z0non-zero flags not allowed in calls to recv_into)r3 r/ r1 )r r0 Únbytesr5 s r Ú recv_intozSSLTransport.recv_intoY s6 ð A:Ü Ð OÓPÐ PØ >Ü[FØyy Ó(Ð(r c ó |dk7 r t d« d}t |« 5 }|j d« 5 }t |« }||k r | j ||d « }||z }||k r d d d « d d d « y # 1 sw Y xY w# 1 sw Y y xY w)Nr z.non-zero flags not allowed in calls to sendallÚB)r3 Ú
|
memoryviewÚcastr/ Úsend)r Údatar5 ÚcountÚviewÚ byte_viewÚamountÚvs r ÚsendallzSSLTransport.sendalle s Ø A:Ü Ð MÓNÐ NØÜ Ó ð t§y¡y°£~ð ¸Ü^FØ&.ØIIi¨¨Ð /Ó0Ø
|
ð &.÷ ÷ ÷ ñ ú÷ ð ús" A=°/A1Á A=Á1A: Á6A=Á=Bc ón |dk7 r t d« | j | j j |« S )Nr z+non-zero flags not allowed in calls to send)r3 r r Úwrite)r r? r5 s r r> zSSLTransport.sendo s2 Ø A:Ü Ð JÓKÐ KØ× Ñ §¡×!2Ñ!2°DÓ9Ð9r )ÚencodingÚerrorsÚnewlinec ó: t |« h d£k st d|d« d|v }d|v xs | }|s|sJ d|v }d} |r| dz } |r| dz } t j | | « }
|
| j xj dz c_ |d }|d
|
k rt
|
j }|d
|
k( r|s t d « |
|
S |r|rt j |
|
|
|
|« } n3|rt j |
|
|« } n|sJ t j |
|
|« } |r| S t j | |||« } || _ | S ) a
|
Python's httpclient uses makefile and buffered io when reading HTTP
|
messages and we need to support it.
|
|
This is unfortunately a copy and paste of socket.py makefile with small
|
changes to point to the socket directly.
|
> ÚbÚrÚwz invalid mode z (only r, w, b allowed)rN rM rL Ú r éÿÿÿÿr z!unbuffered streams must be binary) Úsetr3 r ÚSocketIOÚ_io_refsÚioÚDEFAULT_BUFFER_SIZEÚBufferedRWPairÚBufferedReaderÚBufferedWriterÚ TextIOWrapperÚmode) r rZ Ú bufferingrH rI rJ ÚwritingÚreadingÚbinaryÚrawmodeÚrawr0 Útexts r ÚmakefilezSSLTransport.makefilet s= ô 4yOÒ+Ü }¨T¨HÐ4KÐ LÓMÐ Mà+Ø+Ò, W Ù'Ð!Ð!ØØÙ Ø sNGÙ Ø sNGÜood GÓ,Ø × Ò Ñ!Õ Ø Ð ØIØ q=Ü×.Ñ.IØ >ÙÜ Ð!DÓEÐEØJá wÜ×&Ñ& s¨C°Ó;FÙ Ü×&Ñ& s¨IÓ6FáN7Ü×&Ñ& s¨IÓ6FÙ ØMÜ× Ñ ¨°&¸'ÓBØ Ø r c óN | j | j j « y r" )r r Úunwrapr$ s r rd zSSLTransport.unwrap¨ s Ø ×Ñ$++×,Ñ,Õ-r c ó8 | j j « y r" )r r' r$ s r r' zSSLTransport.close« s Ø ×ÑÕr c ó y r" r# ©r Ú binary_forms r Ú getpeercertzSSLTransport.getpeercert® s ð +.r c ó y r" r# rg s r ri zSSLTransport.getpeercert³ s ØNQr c ó8 | j j |« S r" )r ri rg s r ri zSSLTransport.getpeercert¶ s Ø{{×&Ñ& {Ó3Ð3r c ó6 | j j « S r" )r Úversionr$ s r rm zSSLTransport.version¹ s Ø{{×"Ñ"Ó$Ð$r c ó6 | j j « S r" )r Úcipherr$ s r ro zSSLTransport.cipher¼ r, r c ó6 | j j « S r" )r Úselected_alpn_protocolr$ s r rq z#SSLTransport.selected_alpn_protocol¿ s Ø{{×1Ñ1Ó3Ð3r c ó6 | j j « S r" )r Úshared_ciphersr$ s r rs zSSLTransport.shared_ciphers s Ø{{×)Ñ)Ó+Ð+r c ó6 | j j « S r" )r Ú compressionr$ s r ru zSSLTransport.compressionÅ s Ø{{×&Ñ&Ó(Ð(r c ó: | j j |« y r" )r Ú
|
settimeout)r Úvalues r rw zSSLTransport.settimeoutÈ s Ø × Ñ uÕ%r c ó6 | j j « S r" )r Ú
|
gettimeoutr$ s r rz zSSLTransport.gettimeoutË s Ø{{×%Ñ%Ó'Ð'r c ó8 | j j « y r" )r Ú_decref_socketiosr$ s r r| z SSLTransport._decref_socketiosÎ s Ø ×%Ñ%Õ'r c óæ | j | j j ||« S # t j $ r4}|j
|
t j k( r| j rY d }~y d }~ww xY w©Nr )r r r1 r ÚSSLErrorÚerrnoÚ SSL_ERROR_EOFr )r r/ r0 Úes r r. zSSLTransport._wrap_ssl_readÑ sZ ð Ø×$Ñ$ T§[¡[×%5Ñ%5°s¸FÓCÐ CøÜ||ò Øww#×+Ñ+Ò+°×0IÒ0IÜàûð ús &) ©A0¼)A+Á*A+Á+A0c ó y r" r# )r Úfuncs r r zSSLTransport._ssl_io_loopÛ s ØEHr c ó y r" r# )r r Úarg1s r r zSSLTransport._ssl_io_loopß s ØUXr c ó y r" r# )r r r Úarg2s r r zSSLTransport._ssl_io_loopã s ð r c ó d}d}|rÊd} |
|
| |« }n| ||« }n |||« }| j
|
j « }| j j |« |d}nj|t j k( rW| j j t « }|r | j j |« n| j j « |rÊt j t |« S # t j $ rE}|j t j t j fvr||j }Y d}~d}~ww xY w)z>Performs an I/O loop between incoming/outgoing and the socket.TNF)r r r ÚSSL_ERROR_WANT_READÚSSL_ERROR_WANT_WRITEr r1 r rE r6 Ú SSL_BLOCKSIZEr rG Ú write_eofÚtypingr= r
|
) r r r r Ú should_loopÚretr r Úbufs r r zSSLTransport._ssl_io_loopë s ð ØáØEð Ø< D LÙ &CØ\Ù t*Cá t TÓ*Cð --×$Ñ$Ó&CØ KK× Ñ Ô $à}Ø # Ø#×1Ñ1Ò1Økk×&Ñ&¤}Ó5ÙØMM×'Ñ'¨Õ,àMM×+Ñ+Ô-ò3 ô4 {{<¨Ó-Ð-øô# <<ò Ø77¤3×#:Ñ#:¼C×<TÑ<TÐ"UÑUàGØûð ús C+ Ã+EÃ>:D>Ä>E)r ússl.SSLContextÚreturnÚNone)NT)
|
r z socket.socketr r r ú
|
str | Noner Úboolr r )r r )r( z
|
typing.Anyr r )r Úint)é N)r/ r r0 ztyping.Any | Noner ú int | bytes)r r )r4 r r5 r r r r~ )r0 Ú _WriteBufferr8 ú
|
int | Noner5 r r zNone | int | bytes)r )r? Úbytesr5 r r r )r? r r5 r r r r" ) rZ Ústrr[ r rH r rI r rJ r r z1typing.BinaryIO | typing.TextIO | socket.SocketIO)r r ).)rh ztyping.Literal[False]r z _TYPE_PEER_CERT_RET_DICT | None)rh ztyping.Literal[True]r z bytes | None)F)rh r r r )r r )r ztuple[str, str, int] | None)r z!list[tuple[str, str, int]] | None)rx ú float | Noner r )r r )r/ r r0 úbytearray | Noner r )r ztyping.Callable[[], None]r r )r z typing.Callable[[bytes], int]r r r r )r z/typing.Callable[[int, bytearray | None], bytes]r r r r r r )NN)r z"typing.Callable[..., _ReturnValue]r zNone | bytes | intr r r r
|
) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú staticmethodr r r% r) r+ r1 r6 r9 rE r> rb rd r' r Úoverloadri rm ro rq rs ru rw rz r| r. r r# r r r r s ñð ò ó ð ð& '+Ø%)ð 4à ð4ð $ð4ð $ð 4ð
|
#ð 4ð
|
ó 4ó.óó$ô0ô+ð "Øð
|
)à ð
|
)ð ð
|
)ð ð
|
)ð
|
|
ó
|
)ôô:ð !%ð2ð
|
$Ø !Ø "ñ2àð2ð ð2ð
|
ð 2ð ð 2ð ð2ð
|
;ó2óh.ó ð __à36ð.Ø0ð.à (ò.ó ð.ð __ÚQó ØQô4ó%ó$ó4ó,ó)ó&ó(ó(ôð __ÚHó ØHð __ÚXó ØXð __ðà=ðð ðð ð ð
|
|
ò ó ðð $(Ø!%ð $.à0ð$.ð !ð$.ð ð $.ð
|
|
ô $.r r )Ú
|
__future__r rT r r r Ú
|
exceptionsr Ú TYPE_CHECKINGÚtyping_extensionsr Ússl_r r ÚUnionÚ bytearrayr< r ÚTypeVarr
|
r r r# r r ú<module>r® s\ ðÝ "ã Û Û
|
Û å /à ×ÒÝ&çCð ||I zÐ 1Ñ2 Ø v~~nÓ- à ÷y.ò y.r
|
