U
` @ sF d dl Z d dlZd dlZd dlmZ d dlmZ dZG dd dZdS ) N)ProxySchemeUnsupported)sixi @ c @ s e Zd ZdZedd Zd:ddZdd Zd
d Zd d
Z d;ddZ
d<ddZ d=ddZ d>ddZ
d?ddZd@dd Zd d Zd d ZdAd"d#Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ Zd0d1 Zd2d3 Zd4d5 ZdBd6d7Z d8d9 Z dS )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 C s& t | ds"tjrtdntddS )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_biozKTLS in TLS requires SSLContext.wrap_bio() which isn't supported on Python 2zXTLS in TLS requires SSLContext.wrap_bio() which isn't available on non-native SSLContextN)hasattrr ZPY2r ) ssl_context r J/opt/alt/python38/lib/python3.8/site-packages/urllib3/util/ssltransport.py$_validate_ssl_context_for_tls_in_tls s
z1SSLTransport._validate_ssl_context_for_tls_in_tlsNTc C sH t | _t | _|| _|| _|j| j| j|d| _| | jj dS )zV
Create an SSLTransport around socket using the provided ssl_context.
)server_hostnameN)
sslZ MemoryBIOincomingoutgoingsuppress_ragged_eofssocketr sslobj _ssl_io_loopZ do_handshake)selfr r r r r r r __init__, s
zSSLTransport.__init__c C s | S Nr r r r r __enter__? s zSSLTransport.__enter__c G s | d S r )close)r _r r r __exit__B s zSSLTransport.__exit__c C s
| j S r )r filenor r r r r E s zSSLTransport.fileno c C s | ||S r )_wrap_ssl_read)r lenbufferr r r readH s zSSLTransport.readr c C s |dkrt d| |S )Nr z+non-zero flags not allowed in calls to recv)
ValueErrorr )r r flagsr r r recvK s zSSLTransport.recvc C s> |dkrt d|r&|d kr&t|}n |d kr2d}| ||S )Nr z0non-zero flags not allowed in calls to recv_intor )r! r r )r r nbytesr" r r r recv_intoP s
zSSLTransport.recv_intoc
C sn |dkrt dd}t|H}|d2}t|}||k rV| ||d }||7 }q2W 5 Q R X W 5 Q R X d S )Nr z.non-zero flags not allowed in calls to sendallB)r!
memoryviewcastr send)r datar" countZviewZ byte_viewZamountvr r r sendallY s zSSLTransport.sendallc C s$ |dkrt d| | jj|}|S )Nr z+non-zero flags not allowed in calls to send)r! r r write)r r* r" Zresponser r r r) c s zSSLTransport.sendrc
C s t |dddhks td|f d|k}d|kp4| }|sB|sBtd|k}d} |rZ| d7 } |rf| d7 } t| | }
| j jd7 _|dkrd}|d k rtj}|d kr|std
|
S |r|rt|
|
|} n&|rt |
|} n|stt
|
|} |r| S t | |||} || _ | 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.
r/ wbz&invalid mode %r (only r, w, b allowed) Nr z!unbuffered streams must be binary)
setr! AssertionErrorr ZSocketIOZ_io_refsioDEFAULT_BUFFER_SIZEBufferedRWPairBufferedReaderBufferedWriter
TextIOWrappermode)
r r= bufferingencodingerrorsnewlineZwritingZreadingZbinaryZrawmoderawr textr r r makefilei s@
zSSLTransport.makefilec C s | | jj d S r )r r unwrapr r r r rE s zSSLTransport.unwrapc C s | j d S r )r r r r r r r s zSSLTransport.closeFc C s | j |S r )r getpeercert)r Z binary_formr r r rF s zSSLTransport.getpeercertc C s
| j S r )r versionr r r r rG s zSSLTransport.versionc C s
| j S r )r cipherr r r r rH s zSSLTransport.cipherc C s
| j S r )r selected_alpn_protocolr r r r rI s z#SSLTransport.selected_alpn_protocolc C s
| j S r )r selected_npn_protocolr r r r rJ s z"SSLTransport.selected_npn_protocolc C s
| j S r )r shared_ciphersr r r r rK s zSSLTransport.shared_ciphersc C s
| j S r )r compressionr r r r rL s zSSLTransport.compressionc C s | j | d S r )r
settimeout)r valuer r r rM s zSSLTransport.settimeoutc C s
| j S r )r
gettimeoutr r r r rO s zSSLTransport.gettimeoutc C s | j d S r )r _decref_socketiosr r r r rP s z SSLTransport._decref_socketiosc
C s\ z| | jj||W S tjk
rV } z"|jtjkrD| jrDW Y
dS W 5 d }~X Y nX d S )Nr )r r r r SSLErrorerrnoZ
SSL_ERROR_EOFr )r r r er r r r s
zSSLTransport._wrap_ssl_readc
G s d}d}|rd}z || }W n@ t jk
r\ } z |jt jt jfkrF||j}W 5 d}~X Y nX | j }| j| |dkrd}q|t jkr| j t
}|r| j | q| j
q|S )z>Performs an I/O loop between incoming/outgoing and the socket.TNF)r rQ rR ZSSL_ERROR_WANT_READZSSL_ERROR_WANT_WRITEr r r r- r#
SSL_BLOCKSIZEr
r. Z write_eof)r funcargsZ should_loopZretrR rS Zbufr r r r s(
zSSLTransport._ssl_io_loop)NT)r N)r r )Nr )r )r )r/ NNNN)F)N) __name__
__module__ __qualname____doc__ staticmethodr
r r r r r r# r% r- r) rD rE r rF rG rH rI rJ rK rL rM rO rP r r r r r r r sD
-
r ) r7 r r Zurllib3.exceptionsr Zurllib3.packagesr rT r r r r r <module> s