GRAYBYTE WORDPRESS FILE MANAGER8887

a

�DOgCk�@s�dd
lZdd
l
Z
zdd
lZWney2


d
ZYn0ddlmZ
ddlmZ
ddlmZ
ddlm	Z	
dd�Z
d	Zd
ZdZ
dZGd
d�de�ZGdd�dejej�ZGdd�dej�Zd
S)�N�
)
�	constants)
�	protocols)
�
transports)
�loggercCs"|rtd
�
�
t
��}|
sd|_|S)Nz(Server side SSL needs a valid SSLContextF)�
ValueError�sslZcreate_default_contextZcheck_hostname)�server_side�server_hostname�
sslcontext�r�(/usr/lib64/python3.9/asyncio/sslproto.py�_create_transport_contexts




rZ	UNWRAPPEDZDO_HANDSHAKEZWRAPPEDZSHUTDOWNc@szeZ
dZd
Zddd�
Zedd��
Zedd��
Zed	d
��
Zedd��
Z	dd
d�
Z
ddd�
Zdd�Zddd�
Z
ddd�
ZdS)�_SSLPipeiNcCsH|
|_||_
||_t|_t��|_t��|_d|_	d
|_
d|_d|_dS�NF)
�_context�_server_side�_server_hostname�
_UNWRAPPED�_staterZ	MemoryBIO�	_incoming�	_outgoing�_sslobj�
_need_ssldata�
_handshake_cb�_shutdown_cb)�self�contextr	r
rrr
�__init__7s










z_SSLPipe.__init__c


Cs|jS�
N)
r�
rrrr
rMsz_SSLPipe.contextc


Cs|jSr)
rr rrr
�
ssl_objectRsz_SSLPipe.ssl_objectc


Cs|jSr)
rr rrr
�need_ssldataZsz_SSLPipe.need_ssldatac

Cs
|jt
kSr)r�_WRAPPEDr rrr
�wrapped`sz_SSLPipe.wrappedcCsR|jt
krtd
�
�
|jj|j|j|j|jd�|_	t
|_|
|_|jddd�\}}|S)Nz"handshake in progress or completed)r	r
�T)
�only_handshake)
rr�RuntimeErrorrZwrap_biorrrrr�
_DO_HANDSHAKEr�feed_ssldata�r�callback�ssldata�appdatarrr
�do_handshakeis	





�

z_SSLPipe.do_handshakecCsB|jt
krtd
�
�
|jtkr$td�
�
t|_|
|_|�d�
\}}|S)Nzno security layer presentzshutdown in progressr%)rrr'�	_SHUTDOWNrr)r*rrr
�shutdown~s	






z_SSLPipe.shutdownc
Cs|j�
�
|�d
�
\}
}dS)Nr%)rZ	write_eofr))rr,r-rrr
�feed_eof�s


z_SSLPipe.feed_eofFc
Cs�
|jt
kr"|
r|
g
}ng}g|fSd
|_|
r8|j�|
�

g}g}z�|jtkrz|j��
t|_|j	rl|�	d�

|rz||fWS|jtkr�|j�
|j�
}|�|�

|s�q�q�nJ|jt
kr�|j��
d|_t
|_|jr�|��
n|jt
kr�|�|j�
��

Wn|tjtjf�
yn
}
zZt|dd�}|tjtjtjfv
�
rN|jtk�
rL|j	�
rL|�	|�

�|tjk|_WYd}~n
d}~00|jj�
r�|�|j�
��

||fS)NF�errno)rrrr�writer(rr.r#r�read�max_size�appendr/�unwraprr�SSLError�CertificateError�getattr�SSL_ERROR_WANT_READ�SSL_ERROR_WANT_WRITE�SSL_ERROR_SYSCALLr�pending)r�datar&r-r,�chunk�exc�	exc_errnorrr
r)�sX


































�



"


z_SSLPipe.feed_ssldatar
c
Cs
|jt
kr6|t|
�
kr&|
|d�g
}ng}|t|
�
fSg}t|
�
}d
|_z(|t|�
krn||j�||d��
7}Wnjtjy�
}
zPt	|dd�}|j
dkr�tj}|_|tjtj
tjfv
r��|tjk|_WYd}~n
d}~00|jjr�|�|j���

|t|�
k�
s|jrB�
qqB||fS)NFr2ZPROTOCOL_IS_SHUTDOWN)rr�len�
memoryviewrrr3rr8r:�reasonr;r2r<r=rr>r6r4)rr?�offsetr,�viewrArBrrr
�feed_appdata�s4













�
"



z_SSLPipe.feed_appdata)
N)
N)
N)
F)
r
)�__name__�
__module__�__qualname__r5r�propertyrr!r"r$r.r0r1r)rHrrrr
r#s












Krc@s�eZ
dZejjZd
d�Zd$dd�
Zdd�Z	dd	�Z
d
d�Zdd
�Ze
jf
dd�
Zdd�Zdd�Zdd�Zd%dd�
Zdd�Zdd�Zedd��
Zdd�Zd d!�Zd"d#�ZdS)&�_SSLProtocolTransportcCs|
|_||_
d
|_dSr)�_loop�
_ssl_protocol�_closed)r�loopZssl_protocolrrr
r 
s

z_SSLProtocolTransport.__init__NcCs|j�
|
|�Sr)rO�_get_extra_info�r�name�defaultrrr
�get_extra_info&
sz$_SSLProtocolTransport.get_extra_infocCs|j�
|
�

dSr)rO�_set_app_protocol)r�protocolrrr
�set_protocol*
s
z"_SSLProtocolTransport.set_protocolc


Cs|jj
Sr)rO�
_app_protocolr rrr
�get_protocol-
s
z"_SSLProtocolTransport.get_protocolc


Cs|jSr)
rPr rrr
�
is_closing0
s
z _SSLProtocolTransport.is_closingc

Csd
|_|j
��
dS�NT)rPrO�_start_shutdownr rrr
�close3
s
z_SSLProtocolTransport.closecCs&|js"|
d
|��t
|d�
|��
dS)Nzunclosed transport )
�source)rP�ResourceWarningr_)r�_warnrrr
�__del__>
s


z_SSLProtocolTransport.__del__c
Cs |jj
}
|
durtd
�
�
|
��S)Nz*SSL transport has not been initialized yet)rO�
_transportr'�
is_reading)r�trrrr
reC
s



z _SSLProtocolTransport.is_readingc

Cs|jj
��
dSr)rOrd�
pause_readingr rrr
rgI
sz#_SSLProtocolTransport.pause_readingc

Cs|jj
��
dSr)rOrd�resume_readingr rrr
rhQ
sz$_SSLProtocolTransport.resume_readingcCs|jj
�|
|�
dSr)rOrd�set_write_buffer_limits)r�high�lowrrr
riY
sz-_SSLProtocolTransport.set_write_buffer_limitsc

Cs|jj
��Sr)rOrd�get_write_buffer_sizer rrr
rln
sz+_SSLProtocolTransport.get_write_buffer_sizec

Cs|jj
��Sr)rOrd�get_write_buffer_limitsr rrr
rmr
sz-_SSLProtocolTransport.get_write_buffer_limitsc


Cs
|jj
jSr)rOrd�_protocol_pausedr rrr
rnx
sz&_SSLProtocolTransport._protocol_pausedcCs<t|
t
ttf�s$td
t|
�
j���
�
|
s,dS|j�|
�

dS)Nz+data: expecting a bytes-like instance, got )	�
isinstance�bytes�	bytearrayrD�	TypeError�typerIrO�_write_appdata�rr?rrr
r3}
s

�

z_SSLProtocolTransport.writec


Csd
Srrr rrr
�
can_write_eof�
sz#_SSLProtocolTransport.can_write_eofc

Cs|j�
�
d
|_dSr])rO�_abortrPr rrr
�abort�
s

z_SSLProtocolTransport.abort)
N)NN)rIrJrKrZ
_SendfileModeZFALLBACKZ_sendfile_compatiblerrVrYr[r\r_�warnings�warnrcrergrhrirlrmrLrnr3rvrxrrrr
rM
s&




rMc@s�eZ
dZd+dd�
Zdd�Zd,dd	�
Zd
d�Zdd
�Zdd�Zdd�Z	dd�Z
dd�Zd-dd�
Zdd�Z
dd�Zdd�Zdd�Zd d!�Zd"d#�Zd.d%d&�
Zd'd(�Zd)d*�ZdS)/�SSLProtocolFNTc		Cs�tdurt
d
�
�
|dur tj}n|dk
r6td|���
�
|sDt||�}||_|rZ|sZ||_nd|_||_t	|d�
|_
t��|_
d|_||_|
|_|�|�

t|j|�|_d|_d|_d|_d|_d|_||_||_dS)Nzstdlib ssl module not availabler
z7ssl_handshake_timeout should be a positive number, got )
rF)rr'rZSSL_HANDSHAKE_TIMEOUTrrrr�_sslcontext�dict�_extra�collections�deque�_write_backlog�_write_buffer_size�_waiterrNrWrM�_app_transport�_sslpipe�_session_established�
_in_handshake�_in_shutdownrd�_call_connection_made�_ssl_handshake_timeout)	rrQ�app_protocolr�waiterr	r
Zcall_connection_madeZssl_handshake_timeoutrrr
r�
sB





��

�













zSSLProtocol.__init__cCs|
|_t
|
tj�|_dSr)rZrorZBufferedProtocol�_app_protocol_is_buffer)rr�rrr
rW�
s

�zSSLProtocol._set_app_protocolcCsD|jdurdS|j�
�s:|
du
r.|j�|
�

n|j�d�

d|_dSr)r��	cancelled�
set_exception�
set_result�rrArrr
�_wakeup_waiter�
s







zSSLProtocol._wakeup_waitercCs&|
|_t
|j|j|j�|_|��
dSr)rdrr|rrr��_start_handshake)r�	transportrrr
�connection_made�
s


�zSSLProtocol.connection_madecCsn|jr d
|_|j
�|jj|
�
n|jdu
r2d|j_d|_d|_t|dd�rT|j	�
�
|�|
�

d|_d|_dS)NFT�_handshake_timeout_handle)
r�rN�	call_soonrZ�connection_lostr�rPrdr:r��cancelr�r�r�rrr
r��
s












zSSLProtocol.connection_lostc

Cs|j�
�
dSr)rZ�
pause_writingr rrr
r�szSSLProtocol.pause_writingc

Cs|j�
�
dSr)rZ�resume_writingr rrr
r�szSSLProtocol.resume_writingcCs
|jdurdSz|j�
|
�
\}}WnHttfy:


�Yn2tyj
}
z|�|d
�
WYd}~dSd}~00|D]}|j�|�

qp|D]�}|�
rz&|jr�t	�
|j|�
n|j�|�

WnLttfy�


�Yn6t�
y
}
z|�|d�
WYd}~
dSd}~00q�|�
�

�
qq�dS)NzSSL error in data receivedz/application protocol failed to receive SSL data)r�r)�
SystemExit�KeyboardInterrupt�
BaseException�_fatal_errorrdr3r�rZ_feed_data_to_buffered_protorZ�
data_receivedr^)rr?r,r-�
er@�exrrr
r�s8












�




�
zSSLProtocol.data_receivedc
Cs^zL|j�
�rt�d
|�
|�t�

|js@|j��}
|
r@t�	d�

W|j
��
n|j
��
0dS)Nz%r received EOFz?returning true from eof_received() has no effect when using ssl)rN�	get_debugr�debugr��ConnectionResetErrorr�rZ�eof_received�warningrdr_)rZ	keep_openrrr
r�2s







zSSLProtocol.eof_receivedcCs4|
|jvr|j|
S|j
du
r,|j
�|
|�S|SdSr)r~rdrVrSrrr
rRHs







zSSLProtocol._get_extra_infoc

Cs.|jr
dS|j
r|��
nd
|_|�d�

dS)NTr%)r�r�rwrtr rrr
r^Ps





zSSLProtocol._start_shutdowncCs.|j�
|
d
f�

|jt|
�
7_|��
dS)Nr
)r�r6r�rC�_process_write_backlogrurrr
rtYs


zSSLProtocol._write_appdatac

Cs\|j�
�r$t�d
|�
|j��|_nd|_d|_|j�d�

|j�	|j
|j�|_|�
�
dS)Nz%r starts SSL handshakeT)r%r)rNr�rr��time�_handshake_start_timer�r�r6Z
call_laterr��_check_handshake_timeoutr�r�r rrr
r�^s






��zSSLProtocol._start_handshakec
Cs*|jd
ur&d|j
�d�}
|�t|
�
�

dS)NTz$SSL handshake is taking longer than z! seconds: aborting the connection)r�r�r��ConnectionAbortedError)r�msgrrr
r�ms


��z$SSLProtocol._check_handshake_timeoutc
Cs
d
|_|j
��
|jj}z|
du
r&|
�
|��}Wn^ttfyH


�YnHty�
}
z0t	|t
j�rhd}nd}|�||�
WYd}~dSd}~00|j
��r�|j
��|j}t�d||d�
|jj||��|��|d�
|jr�|j�|j�

|��
d|_|j
�|j�

dS)NFz1SSL handshake failed on verifying the certificatezSSL handshake failedz%r: SSL handshake took %.1f msg@�@)�peercert�cipher�compressionr!T)r�r�r�r�r!Zgetpeercertr�r�r�rorr9r�rNr�r�r�rr�r~�updater�r�r�rZr�r�r�r�r�r�)rZ
handshake_excZsslobjr�rAr�Zdtrrr
�_on_handshake_completevs8


















�


z"SSLProtocol._on_handshake_completec

CsB
|jdus|j
durdSz�tt|j�
�
D]�}
|jd
\}}|rR|j
�||�\}}n*|rj|j
�|j�
}d}n|j
�|j	�
}d}|D]}|j�
|�

q�|t|�
kr�||f|jd
<|jjr�|j��

q�|jd
=|j
t|�
8_
q(Wn\ttfy�


�YnFt�
y<
}
z,|j�
r|�|�

n|�|d�
WYd}~n
d}~00dS)Nr
rzFatal error on SSL transport)rdr��rangerCr�rHr.r�r0�	_finalizer3Z_pausedrhr�r�r�r�r�r�)r�
ir?rFr,r@rArrr
r��s:







�










z"SSLProtocol._process_write_backlog�Fatal error on transportcCsVt|
t
�r(|j��r@tjd
||dd�
n|j�||
|j|d��

|jrR|j�|
�

dS)Nz%r: %sT)
�exc_info)�message�	exceptionr�rX)	ro�OSErrorrNr�rr�Zcall_exception_handlerrdZ_force_close)rrAr�rrr
r��s








�
zSSLProtocol._fatal_errorc

Csd|_|j
du
r|j
��
dSr)r�rdr_r rrr
r��s


zSSLProtocol._finalizec

Cs0z |jdu
r|j�
�
W|��
n
|��
0dSr)rdrxr�r rrr
rw�s



zSSLProtocol._abort)FNTN)
N)
N)
r�)rIrJrKrrWr�r�r�r�r�r�r�rRr^rtr�r�r�r�r�r�rwrrrr
r{�
s,

�
.

&
		)+
r{)rryr�ImportError�rrr�logrrrr(r#r/�objectrZ_FlowControlMixinZ	TransportrM�Protocolr{rrrr
�<module>
s(











y
�~