§
    ÈtºfÄ  ã                   ó´   — d dl mZ d dlmZmZmZ d dlmZmZ d dl	m
Z
  G d„ dej        ¦  «        Z G d„ dej        ¦  «        Z G d	„ d
e
j        ¦  «        ZdS )é    )ÚBytesIO)ÚabstractÚdeferÚprotocol)ÚbasicÚloopback)Úunittestc                   ó"   — e Zd ZdZdeddfd„ZdS )ÚBufferingServeró    ÚdataÚreturnNc                 ó&   — | xj         |z  c_         d S ©N)Úbuffer)Úselfr   s     úW/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/test/test_tpfile.pyÚdataReceivedzBufferingServer.dataReceived   s   € ØˆŒ�tÑˆŒˆˆr   )Ú__name__Ú
__module__Ú__qualname__r   Úbytesr   © r   r   r   r      s;   € € € € € Ø€Fð ð ¨4ð ð ð ð ð ð r   r   c                   ó&   — e Zd Zdeddfd„Zdd„ZdS )ÚFileSendingClientÚfr   Nc                 ó   — || _         d S r   )r   )r   r   s     r   Ú__init__zFileSendingClient.__init__   s   € ØˆŒˆˆr   c                 ó´   ‡ — ‰ j         €J ‚t          j        ¦   «         }|                     ‰ j        ‰ j         d„ ¦  «        }|                     ˆ fd„¦  «         d S )Nc                 ó   — | S r   r   ©Úxs    r   ú<lambda>z2FileSendingClient.connectionMade.<locals>.<lambda>   s   € À!€ r   c                 ó6   •— ‰j                              ¦   «         S r   )Ú	transportÚloseConnection)Úrr   s    €r   r#   z2FileSendingClient.connectionMade.<locals>.<lambda>   s   ø€  ¤× =Ò =Ñ ?Ô ?€ r   )r%   r   Ú
FileSenderÚbeginFileTransferr   ÚaddCallback)r   ÚsÚds   `  r   ÚconnectionMadez FileSendingClient.connectionMade   s^   ø€ ØŒ~Ð)Ð)Ð)ÝÔÑÔˆØ×Ò ¤¨¬¸¸ÑDÔDˆØ	�ŠÐ?Ð?Ð?Ð?Ñ@Ô@Ð@Ð@Ð@r   ©r   N)r   r   r   r   r   r-   r   r   r   r   r      sP   € € € € € ð˜'ð  dð ð ð ð ðAð Að Að Að Að Ar   r   c                   ó8   — e Zd Zdej        d         fd„Zdd„ZdS )ÚFileSenderTestsr   Nc                 óÖ   ‡ ‡‡— dŠt          ¦   «         Št          t          ‰¦  «        ¦  «        }t          j        ‰|¦  «        }dt
          dd fˆˆ ˆfd„}|                     |¦  «        S )Ns„  xyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabc123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123r"   r   c                 ó>   •— ‰                      ‰j        ‰¦  «         d S r   )ÚassertEqualr   )r"   r+   r   ÚtestStrs    €€€r   Úcallbackz1FileSenderTests.testSendingFile.<locals>.callback&   s!   ø€ Ø×Ò˜QœX wÑ/Ô/Ð/Ð/Ð/r   )r   r   r   r   ÚloopbackTCPÚobjectr*   )r   Úcr,   r5   r+   r4   s   `   @@r   ÚtestSendingFilezFileSenderTests.testSendingFile   s†   øøø€ Ø<ˆÝÑÔˆÝ�g gÑ.Ô.Ñ/Ô/ˆå"*Ô"6°q¸!Ñ"<Ô"<ˆð	0�ð 	0 4ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð 	0ð �}Š}˜XÑ&Ô&Ð&r   c                 ó  — t          j        ¦   «         }t          j        ¦   «         }d|_        t          d¦  «        }|                     ||d„ ¦  «        }|                      |j        ¦  «         |  	                    |j
        d¦  «         d S )Né   r   c                 ó   — | S r   r   r!   s    r   r#   z6FileSenderTests.testSendingEmptyFile.<locals>.<lambda>1   s   € È€ r   z0producer unregistered with deferred being called)r   r(   r   ÚFileDescriptorÚ	connectedr   r)   ÚassertIsNoneÚproducerÚ
assertTrueÚcalled)r   Ú
fileSenderÚconsumerÚ	emptyFiler,   s        r   ÚtestSendingEmptyFilez$FileSenderTests.testSendingEmptyFile+   s‚   € ÝÔ%Ñ'Ô'ˆ
ÝÔ*Ñ,Ô,ˆØˆÔÝ˜C‘L”Lˆ	à×(Ò(¨°H¸k¸kÑJÔJˆð 	×Ò˜(Ô+Ñ,Ô,Ð,ð 	�Š˜œÐ"TÑUÔUÐUÐUÐUr   r.   )r   r   r   r   ÚDeferredr9   rF   r   r   r   r0   r0      sP   € € € € € ð
' ¤°Ô!5ð 
'ð 
'ð 
'ð 
'ðVð Vð Vð Vð Vð Vr   r0   N)Úior   Útwisted.internetr   r   r   Útwisted.protocolsr   r   Útwisted.trialr	   ÚProtocolr   r   ÚTestCaser0   r   r   r   ú<module>rN      s  ðð
 Ð Ð Ð Ð Ð à 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ð 6Ø -Ð -Ð -Ð -Ð -Ð -Ð -Ð -Ø "Ð "Ð "Ð "Ð "Ð "ðð ð ð ð �hÔ'ñ ô ð ðAð Að Að Að A˜Ô)ñ Aô Að AðVð Vð Vð Vð V�hÔ'ñ Vô Vð Vð Vð Vr   