HEX

File: //opt/alt/python37/lib/python3.7/site-packages/urllib3/util/__pycache__/ssltransport.cpython-37.pyc
B

��`��@sFddlZddlZddlZddlmZddlmZdZGdd�d�ZdS)�N)�ProxySchemeUnsupported)�sixi@c@s�eZdZdZedd��Zd:dd�Zdd	�Zd
d�Zdd
�Z	d;dd�Z
d<dd�Zd=dd�Zd>dd�Z
d?dd�Zd@dd�Zdd�Zdd �ZdAd"d#�Zd$d%�Zd&d'�Zd(d)�Zd*d+�Zd,d-�Zd.d/�Zd0d1�Zd2d3�Zd4d5�ZdBd6d7�Zd8d9�ZdS)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.
    cCs&t|d�s"tjrtd��ntd��dS)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)�hasattrrZPY2r)�ssl_context�r�J/opt/alt/python37/lib/python3.7/site-packages/urllib3/util/ssltransport.py�$_validate_ssl_context_for_tls_in_tlss

z1SSLTransport._validate_ssl_context_for_tls_in_tlsNTcCsHt��|_t��|_||_||_|j|j|j|d�|_|�|jj	�dS)zV
        Create an SSLTransport around socket using the provided ssl_context.
        )�server_hostnameN)
�sslZ	MemoryBIO�incoming�outgoing�suppress_ragged_eofs�socketr�sslobj�_ssl_io_loopZdo_handshake)�selfrrrrrrr	�__init__,s

zSSLTransport.__init__cCs|S)Nr)rrrr	�	__enter__?szSSLTransport.__enter__cGs|��dS)N)�close)r�_rrr	�__exit__BszSSLTransport.__exit__cCs
|j��S)N)r�fileno)rrrr	rEszSSLTransport.fileno�cCs|�||�S)N)�_wrap_ssl_read)r�len�bufferrrr	�readHszSSLTransport.readrcCs|dkrtd��|�|�S)Nrz+non-zero flags not allowed in calls to recv)�
ValueErrorr)rr�flagsrrr	�recvKszSSLTransport.recvcCs>|dkrtd��|r&|dkr&t|�}n|dkr2d}|�||�S)Nrz0non-zero flags not allowed in calls to recv_intoi)rrr)rr�nbytesr rrr	�	recv_intoPs
zSSLTransport.recv_intoc
Csr|dkrtd��d}t|��L}|�d��6}t|�}x&||krX|�||d��}||7}q4WWdQRXWdQRXdS)Nrz.non-zero flags not allowed in calls to sendall�B)r�
memoryview�castr�send)r�datar �countZviewZ	byte_viewZamount�vrrr	�sendallYs
zSSLTransport.sendallcCs$|dkrtd��|�|jj|�}|S)Nrz+non-zero flags not allowed in calls to send)rrr�write)rr(r Zresponserrr	r'cszSSLTransport.send�rc
Cst|�dddhks td|f��d|k}d|kp4|}|sB|sBt�d|k}d}	|rZ|	d7}	|rf|	d7}	t�||	�}
|jjd7_|dkr�d}|d	kr�tj}|d	kr�|s�td
��|
S|r�|r�t�|
|
|�}n&|r�t�	|
|�}n|s�t�t�
|
|�}|r�|St�||||�}||_|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-�w�bz&invalid mode %r (only r, w, b allowed)��N���rz!unbuffered streams must be binary)
�setr�AssertionErrorrZSocketIOZ_io_refs�io�DEFAULT_BUFFER_SIZE�BufferedRWPair�BufferedReader�BufferedWriter�
TextIOWrapper�mode)
rr;�	buffering�encoding�errors�newlineZwritingZreadingZbinaryZrawmode�rawr�textrrr	�makefileis@
zSSLTransport.makefilecCs|�|jj�dS)N)rr�unwrap)rrrr	rC�szSSLTransport.unwrapcCs|j��dS)N)rr)rrrr	r�szSSLTransport.closeFcCs|j�|�S)N)r�getpeercert)rZbinary_formrrr	rD�szSSLTransport.getpeercertcCs
|j��S)N)r�version)rrrr	rE�szSSLTransport.versioncCs
|j��S)N)r�cipher)rrrr	rF�szSSLTransport.ciphercCs
|j��S)N)r�selected_alpn_protocol)rrrr	rG�sz#SSLTransport.selected_alpn_protocolcCs
|j��S)N)r�selected_npn_protocol)rrrr	rH�sz"SSLTransport.selected_npn_protocolcCs
|j��S)N)r�shared_ciphers)rrrr	rI�szSSLTransport.shared_cipherscCs
|j��S)N)r�compression)rrrr	rJ�szSSLTransport.compressioncCs|j�|�dS)N)r�
settimeout)r�valuerrr	rK�szSSLTransport.settimeoutcCs
|j��S)N)r�
gettimeout)rrrr	rM�szSSLTransport.gettimeoutcCs|j��dS)N)r�_decref_socketios)rrrr	rN�szSSLTransport._decref_socketiosc
CsTy|�|jj||�Stjk
rN}z|jtjkr<|jr<dS�Wdd}~XYnXdS)Nr)rrrr�SSLError�errnoZ
SSL_ERROR_EOFr)rrr�errr	r�szSSLTransport._wrap_ssl_readc
Gs�d}d}x�|r�d}y||�}Wn@tjk
r^}z |jtjtjfkrH|�|j}Wdd}~XYnX|j��}|j�|�|dkr�d}q
|tjkr
|j�	t
�}|r�|j�|�q
|j�
�q
W|S)z>Performs an I/O loop between incoming/outgoing and the socket.TNF)rrOrPZSSL_ERROR_WANT_READZSSL_ERROR_WANT_WRITErrrr+r!�
SSL_BLOCKSIZEr
r,Z	write_eof)r�func�argsZshould_loopZretrPrQZbufrrr	r�s(

zSSLTransport._ssl_io_loop)NT)rN)rr)Nr)r)r)r-NNNN)F)N)�__name__�
__module__�__qualname__�__doc__�staticmethodr
rrrrrr!r#r+r'rBrCrrDrErFrGrHrIrJrKrMrNrrrrrr	rs4	



	



,

	r)	r5rrZurllib3.exceptionsrZurllib3.packagesrrRrrrrr	�<module>s