U
|
Z ±dþ¾ ã @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
|
m Z d dl m Z d dlZd dlmZ d dlZddlmZ ddlmZmZ dd lmZ dd
|
lmZmZ dd lm Z dd lmZ dd l m Z m Z m!Z!m"Z" ddl#m$Z$ ddl%m&Z& ddl'm(Z(m)Z)m*Z*m+Z+m,Z, e -¡ Z.e. /d¡Z0e 1ej2j3¡Z4e5edrRe4 j6ej7 M _6e0 8e4¡ ej9dddgddd Z:dddd Z;ed d Z<ed d Z=G d!d" d"Z>d#d$ Z?e d%d& Z@i i d'd(d)ZAd*d+ ZBd,d- ZCd.d/ ZDd0d1 ZEd2d3 ZFd4d5 ZGd6d7 ZHe&d8d9 ZId:d; ZJd<d= ZKejLjMe jNd>ko<ejOd?kd@dAdBdC ZPdDdE ZQejL RdFddGg¡dHdI ZSdJdK ZTdLdM ZUdNdO ZVdPdQ ZWdRdS ZXdTdU ZYdVdW ZZdXdY Z[dZd[ Z\d\d] Z]d^d_ Z^d`da Z_dbdc Z`ddde Zadfdg ZbejL cdhdi¡djdk Zddldm Zedndo Zfdpdq Zgdrds ZhdS )té N)Úcontextmanager)Úpartial)ÚSSL)Úasynccontextmanageré )Ú_core)Ú SocketStreamÚSocketListener)Úaclose_forcefully)ÚClosedResourceErrorÚBrokenResourceError)Úopen_tcp_stream)Úsocket)Ú SSLStreamÚ SSLListenerÚNeedHandshakeErrorÚ_is_eof)ÚConflictDetector)Úslow)Úassert_checkpointsÚ SequencerÚmemory_stream_pairÚlockstep_stream_pairÚcheck_two_way_streamútrio-test-1.example.orgÚOP_IGNORE_UNEXPECTED_EOFÚmoduleÚtls13Útls12)ZscopeÚparamsc C s` t ¡ }tt dr$| jt j M _t |¡ | jdkr<|S | jdkrTt jj |_
|
|S ds\t d S )Nr )Údefaultr r F) ÚsslÚcreate_default_contextÚhasattrÚoptionsr Ú TRIO_TEST_CAZconfigure_trustÚparamÚ
|
TLSVersionÚTLSv1_2Úmaximum_versionÚAssertionError)ÚrequestÚctx© r- úJd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/tests/test_ssl.pyÚ
|
client_ctxG s
|
|
|
|
|
r/ F©Ú expect_failc
|
C s> z,zºtj| ddd}| | ¡ | d¡}|s¦ttjf}z | ¡ W nH |k
|
r\ Y n6 tj k
|
r t
|
j j dkst
|
j dkrt d¡ Y nX W 5 Q R £ W W ¢d S | |¡ q$W 5 Q R X W n^ ttfk
|
rÜ Y W ¢Xd S tk
|
r } z"|r td| n td | W 5 d }~X Y nX |r,td
|
W 5 | ¡ X d S ) NTF)Ú server_sideÚsuppress_ragged_eofsi Úcpython)é é z\still an issue on recent python versions add a comment to https://bugs.python.org/issue32219z*ssl_echo_serve_sync got error as expected:z)ssl_echo_serve_sync got unexpected error:zfailed to fail?)ÚcloseÚ
|
SERVER_CTXÚ wrap_socketÚ do_handshakeÚrecvÚBrokenPipeErrorr! ÚSSLZeroReturnErrorÚunwrapÚSSLWantWriteErrorÚsysÚimplementationÚnameÚ version_infoÚpytestZfailÚsendallÚConnectionResetErrorÚConnectionAbortedErrorÚ ExceptionÚprintÚ RuntimeError)Úsockr1 ÚwrappedÚdataÚ
|
exceptionsÚexcr- r- r. Ússl_echo_serve_syncY sF ÿ
|
|
|
ÿþÿ
|
|
|
rP c K s| t ¡ \}}t ¡ 4 I d H P}|@ |0 | tjjtt|f| ¡ t t
|
|¡V W 5 Q R X W 5 Q R X W 5 Q I d H R X d S ©N) Ú stdlib_socketÚ
|
socketpairÚtrioÚ open_nurseryÚ
|
start_soonZ to_threadZrun_syncr rP r ÚtsocketÚfrom_stdlib_socket)ÚkwargsÚaÚbÚnurseryr- r- r. Ússl_echo_server_raw s ÿr] c
|
K s8 t f |4 I d H }t|| ddV W 5 Q I d H R X d S ©Nr ©Úserver_hostname)r] r )r/ rY rK r- r- r. Ússl_echo_server® s ra c @ sH e Zd ZdddZdd Zdd Zdd Zd
|
d Zd d ZdddZ dS )ÚPyOpenSSLEchoStreamNc C s° t t j¡}ddlm} | }t|jdr8| |jj¡ tt drFt t
|
|¡ t |d ¡| _ | j ¡ t ¡ | _t | _td| _td| _|d kr¦dd }|| _n|| _d S ) Nr )ÚBindingÚSSL_OP_NO_TLSv1_3Z OP_NO_TLSv1_4z2simultaneous calls to PyOpenSSLEchoStream.send_allz6simultaneous calls to PyOpenSSLEchoStream.receive_somec Ó s d S rQ r- ©Ú_r- r- r. Ú no_op_sleeperê s z3PyOpenSSLEchoStream.__init__.<locals>.no_op_sleeper)r ÚContextZ SSLv23_METHODZ,cryptography.hazmat.bindings.openssl.bindingrc r# ÚlibZ set_optionsrd r* ÚTRIO_TEST_1_CERTÚconfigure_certÚ
|
ConnectionÚ_connZset_accept_stater Z
|
ParkingLotÚ_lotÚ bytearrayÚ_pending_cleartextr Ú_send_all_conflict_detectorÚ _receive_some_conflict_detectorÚsleeper)Úselfrs r, rc r[ rg r- r- r. Ú__init__¸ s*
|
|
|
ÿÿz PyOpenSSLEchoStream.__init__c à s | j ¡ d S rQ )rm Z bio_shutdown©rt r- r- r. Úacloseñ s zPyOpenSSLEchoStream.aclosec C s
|
| j ¡ S rQ )rm Úrenegotiate_pendingrv r- r- r. rx ô s z'PyOpenSSLEchoStream.renegotiate_pendingc C s | j ¡ std S rQ )rm Ú renegotiater* rv r- r- r. ry ÷ s z PyOpenSSLEchoStream.renegotiatec à sB | j 2 t ¡ I d H t ¡ I d H | d¡I d H W 5 Q R X d S )NÚ wait_send_all_might_not_block)rq r Ú
|
checkpointrs rv r- r- r. rz ü s z1PyOpenSSLEchoStream.wait_send_all_might_not_blockc à sö t d | jÞ t ¡ I d H t ¡ I d H | d¡I d H | j |¡ | d¡I d H z| j d¡}W nL tj k
|
r | j
|
¡ t d| j ¡ Y qÆY qH tj k
|
r´ Y qÆY qHX | j |7 _ qH| j ¡ | d¡I d H t d W 5 Q R X d S )Nz --> transport_stream.send_allÚsend_allé zrenegotiations:z( <-- transport_stream.send_all finished)rI rq r r{ rs rm Z bio_writer; r ZZeroReturnErrorÚshutdownZtotal_renegotiationsÚ WantReadErrorrp rn Z
|
unpark_all)rt rM r- r- r. r| s&
|
|
|
z PyOpenSSLEchoStream.send_allc à s t d |d krd}| j^ z:t ¡ I d H t ¡ I d H | d¡I d H z | j |¡W W ¢úW 5 Q R £ S tjk
|
rT | j r8t d| j z"| j dd
}| j
|
t |¡ W np tjk
|
r( z&| j |¡W Y Y W ¢vW 5 Q R £ S tjk
|
r" t d | j ¡ I d H Y nX Y nX | j dd
= nt d | j ¡ I d H Y q>X q>W 5 | d¡I d H t d X W 5 Q R X d S )
|
Nz# --> transport_stream.receive_somei Ú receive_somez, <-- transport_stream.receive_some finishedz
|
tryingr r} z parking (a)z parking (b))rI rr rs r r{ rm Zbio_readr r rp ÚsendÚbytesrn Zpark)rt ÚnbytesZ next_byter- r- r. r s6
|
& z PyOpenSSLEchoStream.receive_some)N)N)
|
Ú__name__Ú
|
__module__Ú __qualname__ru rw rx ry rz r| r r- r- r- r. rb · s
|
9rb c à sº t } t tj¡D}t ¡ 4 I d H "}| | jd¡ | | jd¡ W 5 Q I d H R X W 5 Q R X dt|j ksnt
|
t } t tj¡B}t ¡ 4 I d H }| | jd¡ | | j ¡ W 5 Q I d H R X W 5 Q R X dt|j ksÚt
|
t } t tj¡@}t ¡ 4 I d H }| | j ¡ | | j ¡ W 5 Q I d H R X W 5 Q R X dt|j ksFt
|
t } t tj¡D}t ¡ 4 I d H "}| | j d¡ | | j d¡ W 5 Q I d H R X W 5 Q R X dt|j ks¶t
|
d S )Nó xZ simultaneousr} ) rb rD Úraisesr ÚBusyResourceErrorrU rV r| ÚstrÚvaluer* rz r )ÚsÚexcinfor\ r- r- r. Ú3test_PyOpenSSLEchoStream_gives_resource_busy_errorsQ s0 (& &(r c k s t f |}t|| ddV d S r^ )rb r )r/ rY Zfakesockr- r- r. Úvirtual_ssl_echo_serveru s
|
r ©Ú client_kwargsÚ server_kwargsc C s4 t || fddi|}t |tfddi|}||fS )Nr` r r2 T)r r8 )r/ Úclient_transportÚserver_transportr r Ú
|
client_sslÚ
|
server_sslr- r- r. Ú ssl_wrap_pair{ s" þýü ÿÿÿr c K s t \}}t| ||f|S rQ )r r ©r/ rY r r r- r- r. Ússl_memory_stream_pair s
|
r c K s t \}}t| ||f|S rQ )r r r r- r- r. Ússl_lockstep_stream_pair s
|
r c
|
à s^ t | 4 I d H F}|jr t| d¡I d H | d¡I d H dksDt| ¡ I d H W 5 Q I d H R X tdd4 I d H `}t ¡ }t ||dd}|jrtt
|
t ¡}| d¡I d H W 5 Q R X t |jjtjsÐtW 5 Q I d H R X tdd4 I d H \}t || dd}|jrtt
|
t ¡}| d¡I d H W 5 Q R X t |jjtjsJtW 5 Q I d H R X d S )Nr r} Tr0 r r_ ztrio-test-2.example.org)ra r2 r* r| r rw r] r! r" r rD r r Ú
|
isinstancer Ú __cause__ÚSSLErrorÚCertificateError)r/ r rK Zbad_client_ctxr r- r- r. Útest_ssl_client_basics s$
|
|
$ r c
|
sæ t ¡ \ } Ì |¼ t |¡}tt|tdd}|js>t fdd}t j
|
|d}| ¡ | d¡I d H dksxt| d¡I d H | d¡I d H d ks t| d¡I d H d
|
ks¸t| ¡ I d H | ¡ W 5 Q R X W 5 Q R X d S ) NT©r2 c sL j dd4} | d¡ | d¡dks,t| d¡ | ¡ W 5 Q R X d S )Nr r_ r r} ó yó z)r9 rE r; r* r> )Z client_sock©rZ r/ r- r. Úclient¿ s ÿ
|
|
z&test_ssl_server_basics.<locals>.client)Útargetr} r r¡ r¢ ó )rR rS rW rX r r r8 r2 r* Ú threadingÚThreadÚstartr r| rw Újoin)r/ r[ Z server_sockr r¤ Útr- r£ r. Útest_ssl_server_basics¶ s$
|
ÿ
|
r¬ c
|
à s> t dd4 I d H }| }t ¡ }t||dd}|j|ks>t|j|ksLt|jdksZt|jdkshtt
|
t ¡ |j W 5 Q R X dt |kstdt |ks¤tt
|
t ¡ d|_W 5 Q R X t
|
t ¡ d|_W 5 Q R X ||_|j|ksðtt
|
t¡}| ¡ I d H W 5 Q R X t|jjtjs*tW 5 Q I d H R X d S ) NTr0 r r_ FÚtransport_streamÚcontextZasdf)r] r! r" r r r* r® r2 r` rD r ÚAttributeErrorZ
|
asfdasdfsaÚdirr r: r r r r )r/ rK Zgood_ctxZbad_ctxr r r- r- r. Útest_attributesÔ s* r± c sð d d t t fdd}fdd}t| 4 I d H f}t ¡ 4 I d H 6}| ||¡ | ||¡ | |j¡ | |j¡ W 5 Q I d H R X | ¡ I d H W 5 Q I d H R X tt krÚksàn tksìtd S )Né i c s@ t D ]2}t| t|g }|7 | |¡I d H qd S rQ )ÚrangerI r r| )r ÚiÚchunk)ÚCHUNKSÚ
|
CHUNK_SIZEÚsentr- r. Úsender! s
|
z'test_full_duplex_basics.<locals>.senderc s. t k r*| d ¡I d H }|7 q d S )Nr )Úlenr )r rµ )r· ÚEXPECTEDÚreceivedr- r. Úreceiver) s z)test_full_duplex_basics.<locals>.receiver) ro ra r rU rV r: rw rº r* )r/ r¹ r½ r r\ r- )r¶ r· r» r¼ r¸ r. Útest_full_duplex_basics s "r¾ c à s t | |}| ¡ I d H |j ¡ | d¡I d H | d¡I d H dksJt| d¡I d H | d¡I d H dksrt| ¡ I d H W 5 Q R X d S )Nó ar} ó b)r r: r ry r| r r* rw ©r/ r r- r- r. Útest_renegotiation_simple> s
|
|
r c s d| _ dd l}| d¡fdd} fdd}fddfdd t||d
|
¡ I d H d I d H j ¡ d I d H | I d H td D ]®}t|d g}td| d g}j ¡ t
|
¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X t
|
¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X | I d H q¤td D ]}t|d g}td| d g}|I d H j ¡ |I d H t
|
¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X | I d H q\W 5 Q R X dd } fdd}
|
t|| d
|
pdI d H j ¡ t
|
¡ 4 I d H }| d¡ | |
|
¡ W 5 Q I d H R X | I d H ¡ I d H W 5 Q R X dd } t|| d
|
rdI d H j ¡ t
|
¡ 4 I d H }| d¡ | j ¡ W 5 Q I d H R X | I d H ¡ I d H W 5 Q R X d S )Nr c s t dd¡¡I d H d S )Nr é
|
)rT ÚsleepÚuniformre )Úrr- r. rs Z s z.test_renegotiation_randomized.<locals>.sleeperc sX j ¡ rLt dI d H W 5 Q R X t dI d H W 5 Q R X q td d S )Nó -z -- clear --)r rx r rI r- )Úexpectr r r- r. Úclear] s
|
z,test_renegotiation_randomized.<locals>.clearc sB j d¡I d H td| t | ¡I d H W 5 Q R X d S )Nz
|
outer sendzcalling SSLStream.send_all)r rs rI r r| )Úbyte©r r- r. r e s
|
z+test_renegotiation_randomized.<locals>.sendc sZ j d¡I d H td| t| dks,tt d¡I d H | ksLtW 5 Q R X d S )NrÈ z)calling SSLStream.receive_some, expectingr} )r rs rI rº r* r r )ÚexpectedrË r- r. rÈ k s
|
|
z-test_renegotiation_randomized.<locals>.expect)rs r¿ éd éÿ r c Ó s | dkrt d¡I d H d S )Nr| é ©rT rÄ ©Úmethodr- r- r. Úsleeper_with_slow_send_all s zAtest_renegotiation_randomized.<locals>.sleeper_with_slow_send_allc s" t d¡I d H ¡ I d H d S )Néè )rT rÄ rz r- rË r- r. Úsleep_then_wait_writable s z?test_renegotiation_randomized.<locals>.sleep_then_wait_writabler c Ó s6 | dkrt d¡I d H n| dkr2t d¡I d H d S )Nrz rÏ rÈ rÔ rÐ rÑ r- r- r. Ú*sleeper_with_slow_wait_writable_and_expect± s zQtest_renegotiation_randomized.<locals>.sleeper_with_slow_wait_writable_and_expect)Zautojump_thresholdÚrandomÚRandomr r: r ry r³ r r rU rV rw rz ) Z
|
mock_clockr/ r× rs rÉ r´ Zb1Zb2r\ rÓ rÕ rÖ r- )rÈ rÆ r r r. Ú test_renegotiation_randomizedP sr
|
|
|
|
|
ÿ
|
rÙ c sÜ fdd} fdd} fdd}t | \ }t tj¡<}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X W 5 Q R X dt|jkst t | \ }t tj¡<}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X W 5 Q R X dt|jksüt t | \ }t tj¡<}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X W 5 Q R X dt|jksjt t | \ }t tj¡<}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X W 5 Q R X dt|jksØt d S )Nc s& t d¡I d H W 5 Q R X d S )Nr )r r| r- rË r- r. Ú do_send_allÆ s z.test_resource_busy_errors.<locals>.do_send_allc s& t d¡I d H W 5 Q R X d S ©Nr} )r r r- rË r- r. Údo_receive_someÊ s z2test_resource_busy_errors.<locals>.do_receive_somec s$ t ¡ I d H W 5 Q R X d S rQ )r rz r- rË r- r. Ú do_wait_send_all_might_not_blockÎ s zCtest_resource_busy_errors.<locals>.do_wait_send_all_might_not_blockz another task)
|
r rD r r r rU rV r r r* )r/ rÚ rÜ rÝ rf r r\ r- rË r. Útest_resource_busy_errorsÅ s6
|
$
|
$
|
$
|
$rÞ c sN g G fddd} t ¡ }t| |dd}| ¡ I d H dgksJtd S )Nc s e Zd Z fddZdS )zEtest_wait_writable_calls_underlying_wait_writable.<locals>.NotAStreamc s d¡ d S )NÚok)Úappendrv ©Úrecordr- r. rz ó s zctest_wait_writable_calls_underlying_wait_writable.<locals>.NotAStream.wait_send_all_might_not_blockN)r r
r rz r- rá r- r. Ú
|
NotAStreamò s rã Úxr_ rß )r! r" r rz r* )rã r, r r- rá r. Ú1test_wait_writable_calls_underlying_wait_writableï s rå Únt)r5 rà z)frequently fails on Windows + Python 3.10)Úreasonc
|
à s t | 4 I d H }t | ¡ I d H W 5 Q R X t | ¡ I d H W 5 Q R X t | ¡ I d H W 5 Q R X t | d¡I d H W 5 Q R X t | d¡I d H W 5 Q R X t | d¡I d H W 5 Q R X t | d¡I d H W 5 Q R X t | ¡ I d H W 5 Q R X W 5 Q I d H R X t | 4 I d H 4}| ¡ I d H t | ¡ I d H W 5 Q R X W 5 Q I d H R X d S )Ns xxxr} )ra r r: rz r| r r> rw rÁ r- r- r. Útest_checkpointsü s* (rè c
|
à s® t | 4 I d H }| ¡ I d H t | d¡I d H W 5 Q R X t | d¡I d H W 5 Q R X | d¡I d H | d¡I d H dkst| ¡ I d H W 5 Q I d H R X d S )Nr¦ r r} )ra r: r r| r r* rw rÁ r- r- r. Útest_send_all_empty_string s ré Úhttps_compatibleTc s. fdd} fdd}t ||I d H d S )Nc s t dididS )Nrê r )r r- ©r/ rê r- r. Ú stream_maker/ s
|
ýz,test_SSLStream_generic.<locals>.stream_makerc
|
sN t \} }t ¡ 4 I d H }| | j¡ | |j¡ W 5 Q I d H R X | |fS rQ )r r rU rV r: )r¤ Úserverr\ ©r/ r- r. Úclogged_stream_maker6 s
|
z4test_SSLStream_generic.<locals>.clogged_stream_maker)r )r/ rê rì rï r- rë r. Útest_SSLStream_generic- s rð c
|
sx t | \ jjt fdd}fdd}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X d S )Nc
|
s ¡ I d H d¡I d H d¡I d H dks6t d¡I d H d4 I d H jj} d j_W 5 Q I d H R X d¡I d H dkst jkst ¡ I d H \}}|ks¼t|dksÈt jd ksÖt| d¡I d H | j_j ¡ I d H d S )Nr r} r¡ r¢ r r¦ ó trailing)r: r| r r* Ú send_streamÚ send_all_hookr r> )ró ÚrawÚtrailing)r r Úseqr- r. r¤ M s ztest_unwrap.<locals>.clientc
|
s¬ ¡ I d H d¡I d H dks&t d¡I d H d¡I d H dksNt d4 I d H ¡ I d H \} }W 5 Q I d H R X | kst|dkstjd ks¨td S )Nr} r r¡ r¢ rñ )r: r r* r| r> r )rô rõ )rö r r r- r. rí h s " ztest_unwrap.<locals>.server)r r r r rU rV ©r/ r¤ rí r\ r- )r r rö r r r. Ú test_unwrapF s
|
rø c
|
s² t | \ j} fdd}fdd}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X t t¡ | d¡I d H W 5 Q R X t
|
¡ I d H W 5 Q R X t
|
¡ I d H W 5 Q R X t t¡ d¡I d H W 5 Q R X t t¡ d¡I d H dk W 5 Q R X t t¡ ¡ I d H W 5 Q R X t t¡ ¡ I d H W 5 Q R X t | \ fdd }t ¡ 4 I d H }| j
|
¡ | |¡ W 5 Q I d H R X d S )
|
Nc s$ t ¡ I d H W 5 Q R X d S rQ )r rw r- )r r- r. Ú client_closer s z-test_closing_nice_case.<locals>.client_closerc sT d¡I d H dkst d¡I d H dks0tt ¡ I d H W 5 Q R X d S ©Nrà r¦ )r r* r rw r- ©r r- r. Ú server_closer s z-test_closing_nice_case.<locals>.server_closers 123rà r¦ c sN t d¡I d H dks tW 5 Q R X t ¡ I d H W 5 Q R X d S rú )r r r* rw r- rû r- r. Úexpect_eof_server¯ s "z1test_closing_nice_case.<locals>.expect_eof_server)r r r rU rV rD r r r| r rw r r> r: )r/ r rù rü r\ rý r- )r r r. Útest_closing_nice_case| s4
|
rþ c
|
sä t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X dd }||jj_t t
|
¡ | d¡I d H W 5 Q R X t t ¡ | ¡ I d H W 5 Q R X d fdd}||jj_||jj_| ¡ I d H dksàtd S )Nc Ó s t d S rQ ©ÚKeyErrorr- r- r- r. Úbad_hookÁ s z3test_send_all_fails_in_the_middle.<locals>.bad_hookr r c s d7 d S rÛ r- r- ©Úclosedr- r. Ú
|
close_hookÎ s z5test_send_all_fails_in_the_middle.<locals>.close_hookr )r r rU rV r: r rò ró rD r r r| r rz r Úreceive_streamrw r* )r/ r¤ rí r\ r r r- r r. Ú!test_send_all_fails_in_the_middleº s
|
|
|
r c
|
s t \}}t|| dd}t|tdd}t|| dd t|tdd fdd}fdd}t ¡ 4 I d H }| |¡ | |¡ W 5 Q I d H R X d S ) Nr r_ Tr c s, d¡I d H d¡I d H dks(td S )Nó hirà ó bye)r| r r* r- )Úclient_2r- r. r¤ æ s z!test_ssl_over_ssl.<locals>.clientc s, d¡I d H dkst d¡I d H d S )Nrà r r )r r* r| r- )Úserver_2r- r. rí ê s z!test_ssl_over_ssl.<locals>.server)r r r8 r rU rV )r/ Zclient_0Zserver_0Zclient_1Zserver_1r¤ rí r\ r- )r r
|
r. Útest_ssl_over_sslÙ s$
|
ÿ ÿ
|
r c
|
à s´ t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X t |¡I d H t t ¡ |
|
d¡I d H W 5 Q R X t t ¡ | d¡I d H W 5 Q R X | ¡ I d H d S )Nrà ó
|
xxxxxxxxxx) r r rU rV r: rT r
|
rD r r r r| rw r÷ r- r- r. Útest_ssl_bad_shutdownó s r c
|
à s´ t | ddiddid\}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X t |¡I d H | d¡I d H dks|tt
|
t ¡ | d¡I d H W 5 Q R X | ¡ I d H d S )Nrê T©r r rà r¦ r )r r rU rV r: rT r
|
r r* rD r r r| rw r÷ r- r- r. Ú test_ssl_bad_shutdown_but_its_ok s ý
|
r c
|
à sb t dd4 I d H @} t ¡ }t| |dd}t t¡ | ¡ I d H W 5 Q R X W 5 Q I d H R X d S )NTr0 r r_ )r] r! r" r rD r r rw )rK r/ r r- r- r. Ú(test_ssl_handshake_failure_during_aclose s
|
r c
|
s t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X |jjj d fdd}||jj_t t
|
¡ | ¡ I d H W 5 Q R X dkst d S )Nr c s d7 t d S rÛ rÿ r- ©Zclient_orig_close_hookZtransport_close_countr- r. r 7 s z4test_ssl_only_closes_stream_once.<locals>.close_hookr} ) r r rU rV r: r rò r rD r r rw r* )r/ r¤ rí r\ r r- r r. Ú test_ssl_only_closes_stream_once+ s
|
|
r c
|
s t | ddiddid\} t ¡ 4 I d H }| |j¡ | j¡ W 5 Q I d H R X fdd}t ¡ 4 I d H }| |j¡ | |¡ W 5 Q I d H R X d S )Nrê FTr c s: t t¡} d¡I d H W 5 Q R X t| jjs6td S )Nrà )rD r r r r r r r* )r ©rí r- r. Úreceive_and_expect_errorQ s zKtest_ssl_https_compatibility_disagreement.<locals>.receive_and_expect_error)r r rU rV r: rw )r/ r¤ r\ r r- r r. Ú)test_ssl_https_compatibility_disagreementD s ý
|
r c
|
sb t | ddiddid\} fdd}t ¡ 4 I d H }| |j¡ | |¡ W 5 Q I d H R X d S )Nrê Tr c s d¡I d H dkstd S rú )r r* r- r r- r. Úserver_expect_clean_eofc s zEtest_https_mode_eof_before_handshake.<locals>.server_expect_clean_eof)r r rU rV rw )r/ r¤ r r\ r- r r. Ú$test_https_mode_eof_before_handshake\ s ý
|
r c
|
à s t | \}}dd }||jj_t t¡& t | ¡ I d H W 5 Q R X W 5 Q R X t t ¡& t | ¡ I d H W 5 Q R X W 5 Q R X d S )Nc Ó s t d S rQ rÿ r- r- r- r. r n s z2test_send_error_during_handshake.<locals>.bad_hook)
|
r r rò ró rD r r r r: r )r/ r¤ rí r r- r- r. Ú test_send_error_during_handshakek s
|
" r c
|
s t | \ }dd }| jj_ fdd}t ¡ 4 I d H }| ||j¡ | |j¡ W 5 Q I d H R X t
|
t ¡& t ¡ I d H W 5 Q R X W 5 Q R X d S )Nc Ó s t d S rQ rÿ r- r- r- r. r s z5test_receive_error_during_handshake.<locals>.bad_hookc
|
sB t t¡& t ¡ I d H W 5 Q R X W 5 Q R X | ¡ d S rQ )rD r r r r: Úcancel)Ú cancel_scope©r¤ r- r. Ú client_side s "z8test_receive_error_during_handshake.<locals>.client_side) r r r Zreceive_some_hookr rU rV r r: rD r r r )r/ rí r r r\ r- r r. Ú#test_receive_error_during_handshake| s
|
r c à sL t | \}}t t¡ | ¡ W 5 Q R X t t¡ | ¡ W 5 Q R X d S rQ )r rD r r Úselected_alpn_protocol©r/ r¤ rí r- r- r. Ú,test_selected_alpn_protocol_before_handshake s
|
r c
|
à s~ t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X | ¡ d ksVt| ¡ d ksft| ¡ | ¡ ksztd S rQ )r r rU rV r: r r* r÷ r- r- r. Ú(test_selected_alpn_protocol_when_not_set s r! c à sL t | \}}t t¡ | ¡ W 5 Q R X t t¡ | ¡ W 5 Q R X d S rQ )r rD r r Úselected_npn_protocolr r- r- r. Ú+test_selected_npn_protocol_before_handshake¬ s
|
r# zCignore: ssl module. NPN is deprecated, use ALPN instead:UserWarningzAignore:ssl NPN is deprecated, use ALPN instead:DeprecationWarningc
|
à s~ t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X | ¡ d ksVt| ¡ d ksft| ¡ | ¡ ksztd S rQ )r r rU rV r: r" r* r÷ r- r- r. Ú'test_selected_npn_protocol_when_not_set¶ s r$ c à sL t | \}}t t¡ | ¡ W 5 Q R X t t¡ | ¡ W 5 Q R X d S rQ )r rD r r Úget_channel_bindingr r- r- r. Ú)test_get_channel_binding_before_handshakeÉ s
|
r& c
|
à s~ t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X | ¡ d k sVt| ¡ d k sft| ¡ | ¡ ksztd S rQ )r r rU rV r: r% r* r÷ r- r- r. Ú(test_get_channel_binding_after_handshakeÓ s r' c
|
à sz t | \}}t ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X | ¡ d ksVtt| ¡ d| ¡ d ksvtd S )N)ÚDNSr ÚsubjectAltName)r r rU rV r: Ú getpeercertr* rI r÷ r- r- r. Útest_getpeercertà s r+ c s& fdd}| I d H \}}}|4 I d H | ¡ I d H }|4 I d H J |jrRtt ¡ 4 I d H }| |j¡ | |j¡ W 5 Q I d H R X W 5 Q I d H R X | ¡ I d H | ¡ dksºtW 5 Q I d H R X |ddI d H \}}}| ¡ I d H }|jsøtt |I d H t |I d H t |I d H d S )Nc sb t ¡ }| d¡I d H | d¡ t|}t|tf| }t| ¡ I d H }t | dd}|||fS )N)z 127.0.0.1r r} r r_ )
|
rW r ÚbindÚlistenr r r8 r Ú getsocknamer )rY Ú listen_sockZsocket_listenerÚ ssl_listenerZtransport_clientÚ
|
ssl_clientrî r- r. Úsetupî s
|
ÿz test_SSLListener.<locals>.setupéÿÿÿÿT)rê )
|
ÚacceptZ_https_compatibler* r rU rV r: rw Úfilenor
|
)r/ r2 r/ r0 r1 Z
|
ssl_serverr\ rf r- rî r. Útest_SSLListenerí s"
|
,
|
r6 )iÚosÚrer@ rD r§ r rR r! Ú
|
contextlibr Ú functoolsr ZOpenSSLr ZtrustmeÚasync_generatorr rT Ú r Z_highlevel_socketr r Z_highlevel_genericr
|
r r Z_highlevel_open_tcp_streamr rW Ú_sslr r r r Z_utilr Z_core.tests.tutilr Ztestingr r r r r ÚCAr% Zissue_server_certrj r" ÚPurposeÚ CLIENT_AUTHr8 r# r$ r rk Zfixturer/ rP r] ra rb r r r r r r r¬ r± r¾ r rÙ rÞ rå ÚmarkZskipifrB rC rè ré Z parametrizerð rø rþ r r r r r r r r r r r r! r# Úfilterwarningsr$ r& r' r+ r6 r- r- r- r. Ú<module> s¬
|
|
|
D
|
|
$
|
|
ú E%
|
t* þ
|
|
6>
|
|
þ
|
|
|
