§
    Ìtºfy  ã                   óÔ  — d dl Z d dlZd dlmZmZ d dlmZmZmZm	Z	m
Z
 d dlmZ d dlmZ d dlmZ e j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         Ze j                             ej                             dd¦  «         d	¬
¦  «        d„ ¦   «         ZdS )é    N)ÚMockÚcall)ÚPrefixProtocolÚRawSocketClientProtocolÚRawSocketServerProtocolÚWampRawSocketClientFactoryÚWampRawSocketServerFactory)Úget_serializers)Úmessage)ÚTransportDetailsÚUSE_ASYNCIOFztest runs on asyncio only)Úreasonc                 ó¾   — t          ¦   «         }t          |¦  «        dk    sJ ‚ |d         ¦   «                              t          j        d¦  «        ¦  «        }|sJ ‚d S )Nr   Úclose)r
   ÚlenÚ	serializer   ÚAbort)Ú
event_loopÚserializersÚms      úg/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/asyncio/test/test_aio_rawsocket.pyÚ	test_sersr      s\   € å!Ñ#Ô#€KÝˆ{ÑÔ˜aÒÐÐÐØˆ�AŒÑÔ×"Ò"¥7¤=°Ñ#9Ô#9Ñ:Ô:€AØ€H€H€H€H€Hó    c                 óJ  — t          ¦   «         }t          ¦   «         }t          ¦   «         }||_        |                     |¦  «         d}|                     |¦  «         |                     d¦  «         t          |j        ¦  «        dk    sJ ‚|                     d¦  «         |j	         
                    t          d¦  «        t          d¦  «        g¦  «         |                     ¦   «          |                     ¦   «          d}|                     |dd…         ¦  «         |j        rJ ‚|                     |dd…         ¦  «         |j        rJ ‚|                     |dd…         ¦  «         |j        rJ ‚|                     |dd	…         ¦  «         |                     d
¦  «         |                     ¦   «          |                     ¦   «          d}|                     |¦  «         | 
                    t          d¦  «        t          d¦  «        g¦  «         |j        dk    sJ ‚d S )Ns      abcdó   abcdr   s      s      0123456789ABé   é   é   é   s   0123456789ABs      abcd   12345 s   12345ó    )r   r   ÚstringReceivedÚconnection_madeÚdata_receivedÚassert_called_once_withr   Ú_bufferÚ
sendStringÚwriteÚassert_has_callsr   Ú
reset_mockÚcalled)r   ÚpÚ	transportÚreceiverÚ	small_msgÚbig_msgÚtwo_messagess          r   Útest_prefixr1      s  € åÑÔ€AÝ‘”€IÝ‰vŒv€HØ€AÔØ×Ò�iÑ Ô Ð Ø'€IØ‡O‚O�IÑÔÐØ×$Ò$ WÑ-Ô-Ð-ÝˆqŒy‰>Œ>˜QÒÐÐÐà‡L‚L�ÑÔÐð „O×$Ò$¥dÐ+>Ñ&?Ô&?ÅÀgÁÄÐ%OÑPÔPÐPà×ÒÑÔÐØ×ÒÑÔÐà3€Gà‡O‚O�G˜A˜a˜C”LÑ!Ô!Ð!ØŒÐÐÐà‡O‚O�G˜A˜a˜C”LÑ!Ô!Ð!ØŒÐÐÐà‡O‚O�G˜A˜b˜D”MÑ"Ô"Ð"ØŒÐÐÐà‡O‚O�G˜B˜r˜E”NÑ#Ô#Ð#Ø×$Ò$ _Ñ5Ô5Ð5à×ÒÑÔÐØ×ÒÑÔÐà[€LØ‡O‚O�LÑ!Ô!Ð!Ø×Ò�t G™}œ}­d°8©n¬nÐ=Ñ>Ô>Ð>ØŒ9˜ÒÐÐÐÐÐr   c                 ó¦  —  G d„ dt           ¦  «        } |¦   «         }t          ¦   «         }t          ¦   «         }t          ¦   «         }||_        ||_        |j                             ¦   «         sJ ‚|                     |¦  «         |j                             ¦   «         rJ ‚|                     d ¦  «         |j                             ¦   «         sJ ‚d S )Nc                   ó$   — e Zd Zed„ ¦   «         ZdS )útest_is_closed.<locals>.CPc                 ó   — dS ©Né   © ©Úselfs    r   Úserializer_idz(test_is_closed.<locals>.CP.serializer_idC   ó   € à�1r   N©Ú__name__Ú
__module__Ú__qualname__Úpropertyr;   r8   r   r   ÚCPr4   B   ó-   € € € € € Ø	ð	ð 	ñ 
Œð	ð 	ð 	r   rB   )r   r   r!   Ú_on_handshake_completeÚ	is_closedÚdoner"   Úconnection_lost©r   rB   ÚclientÚon_hsr,   r-   s         r   Útest_is_closedrK   @   sä   € ðð ð ð ð Õ$ñ ô ð ð ˆR‰TŒT€Få‰FŒF€EÝ‘”€IÝ‰vŒv€HØ$€FÔØ$)€FÔ!ØÔ× Ò Ñ"Ô"Ð"Ð"Ð"Ø
×Ò˜9Ñ%Ô%Ð%ØÔ×$Ò$Ñ&Ô&Ð&Ð&Ð&Ø
×Ò˜4Ñ Ô Ð àÔ× Ò Ñ"Ô"Ð"Ð"Ð"Ð"Ð"r   c                 ó  — t          ¦   «         }t          d¬¦  «        }t          ¦   «         }t          ¦   «         }t          ¦   «         }||_        ||_        ||_        ||_        |                     |¦  «         d}|                     |¦  «         |                     d¦  «         |                     ¦   «          |j        j	        sJ ‚|j                             d¦  «         |j
        j	        rJ ‚|                     d¦  «         d S )NT©Úreturn_valueó   ñ     abcdr7   ó   ñ  r   )r   r   Úsupports_serializerr!   rD   r"   r#   r$   r'   r*   r   )r   ÚserverÚserrJ   r,   r-   Úhss          r   Útest_raw_socket_server1rU   U   s   € õ %Ñ&Ô&€FÝ
˜DÐ
!Ñ
!Ô
!€CÝ‰FŒF€EÝ‘”€IÝ‰vŒv€HØ!$€FÔØ$€FÔØ$)€FÔ!Ø$€FÔà
×Ò˜9Ñ%Ô%Ð%Ø	6€BØ
×Ò˜ÑÔÐà×Ò Ñ"Ô"Ð"Ø	×!Ò!Ñ#Ô#Ð#ØŒ?Ô!Ð!Ð!Ð!Ø„O×+Ò+Ð,?Ñ@Ô@Ð@ØŒÔ%Ð%Ð%Ð%Ø×$Ò$ WÑ-Ô-Ð-Ð-Ð-r   c                 óÚ  — t          ¦   «         }t          d¬¦  «        }t          ¦   «         }t          ¦   «         }t          ¦   «         }||_        ||_        ||_        ||_        |                     |¦  «         |                     d¦  «         |j                             ¦   «          t          ¦   «         }t          d¬¦  «        }t          ¦   «         }t          d¬¦  «        }t          ¦   «         }||_        ||_        ||_        ||_        |                     |¦  «         |                     d¦  «         |j                             ¦   «          |j	                             d¦  «         d S )	NTrM   s   abcdefF©r   r'   Úget_extra_info©Úspec_setrP   s     )
r   r   rQ   r!   rD   r"   r#   r   r$   r'   )r   rR   rS   rJ   r,   r-   s         r   Útest_raw_socket_server_errorsr[   n   sN  € õ %Ñ&Ô&€FÝ
˜DÐ
!Ñ
!Ô
!€CÝ‰FŒF€EÝ‘”€IÝ‰vŒv€HØ!$€FÔØ$€FÔØ$)€FÔ!Ø$€FÔØ
×Ò˜9Ñ%Ô%Ð%Ø
×Ò˜Ñ#Ô#Ð#Ø„O×+Ò+Ñ-Ô-Ð-å$Ñ&Ô&€FÝ
˜EÐ
"Ñ
"Ô
"€CÝ‰FŒF€EÝÐBÐCÑCÔC€IÝ‰vŒv€HØ!$€FÔØ$€FÔØ$)€FÔ!Ø$€FÔØ
×Ò˜9Ñ%Ô%Ð%Ø
×ÒÐ,Ñ-Ô-Ð-Ø„O×+Ò+Ñ-Ô-Ð-Ø„O×+Ò+Ð,?Ñ@Ô@Ð@Ð@Ð@r   c                 óÂ  —  G d„ dt           ¦  «        } |¦   «         }t          ¦   «         }t          ¦   «         }t          ¦   «         }||_        ||_        |                     |¦  «         |                     d¦  «         |                     ¦   «          |j        j        sJ ‚|j         	                    d¦  «         |j
        j        rJ ‚|                     d¦  «         d S )Nc                   ó$   — e Zd Zed„ ¦   «         ZdS )ú#test_raw_socket_client1.<locals>.CPc                 ó   — dS r6   r8   r9   s    r   r;   z1test_raw_socket_client1.<locals>.CP.serializer_id�   r<   r   Nr=   r8   r   r   rB   r^   �   rC   r   rB   rO   rP   r   )r   r   r!   rD   r"   r#   r$   r'   r*   Úcalled_one_withr   rH   s         r   Útest_raw_socket_client1ra   �   só   € ðð ð ð ð Õ$ñ ô ð ð ˆR‰TŒT€Få‰FŒF€EÝ‘”€IÝ‰vŒv€HØ$€FÔØ$)€FÔ!à
×Ò˜9Ñ%Ô%Ð%Ø
×ÒÐFÑGÔGÐGØ	×!Ò!Ñ#Ô#Ð#ØŒ?Ô!Ð!Ð!Ð!Ø„O×#Ò#Ð$7Ñ8Ô8Ð8ØŒÔ%Ð%Ð%Ð%Ø×$Ò$ WÑ-Ô-Ð-Ð-Ð-r   c                 ó:  —  G d„ dt           ¦  «        } |¦   «         }t          ¦   «         }t          d¬¦  «        }t          ¦   «         }||_        ||_        |                     |¦  «         |                     d¦  «         |j                             ¦   «          d S )Nc                   ó$   — e Zd Zed„ ¦   «         ZdS )ú(test_raw_socket_client_error.<locals>.CPc                 ó   — dS r6   r8   r9   s    r   r;   z6test_raw_socket_client_error.<locals>.CP.serializer_id§   r<   r   Nr=   r8   r   r   rB   rd   ¦   rC   r   rB   rW   rY   s   ñ )r   r   r!   rD   r"   r#   r   r$   rH   s         r   Útest_raw_socket_client_errorrf   ¤   s°   € ðð ð ð ð Õ$ñ ô ð ð ˆR‰TŒT€Få‰FŒF€EÝÐBÐCÑCÔC€IÝ‰vŒv€HØ$€FÔØ$)€FÔ!Ø
×Ò˜9Ñ%Ô%Ð%à
×ÒÐ,Ñ-Ô-Ð-Ø„O×+Ò+Ñ-Ô-Ð-Ð-Ð-r   c           
      óJ  ‡‡— t          d¬¦  «        }t          ˆfd„¬¦  «        |_        t          ddg¬¦  «        Šˆfd„}g Š t          |¦  «        ¦   «         }|                     |¦  «         |j        j        d	u sJ ‚|j        j        t          j        k    sJ ‚|j	        j
        sJ ‚|j	        j
        d
         j        }|                     t          t          dd|z  ddg¦  «        ¦  «        ¦  «         |j        sJ ‚‰j                             |¦  «         |                     t'          j        d¦  «        ¦  «         ‰d
d …         D ]}|                     |¦  «         Œ‰j        j        sJ ‚t/          ‰j        j        d         d         t&          j        ¦  «        sJ ‚d S )N©Úabortr   r'   rX   rY   c                 ó.   •— ‰                      | ¦  «        S ©N©Úappend©r   Úmessagess    €r   ú<lambda>z"test_wamp_server.<locals>.<lambda>º   ó   ø€ °·²ÀÑ1CÔ1C€ r   ©Úside_effectÚonOpenÚ	onMessage©Úspecc                  ó   •— ‰ S rk   r8   )rR   s   €r   Úfact_serverz%test_wamp_server.<locals>.fact_server½   ó   ø€ Øˆr   Tr7   é   éð   r   r   )r   r'   r	   r"   Útransport_detailsÚ	is_serverÚchannel_framingr   ÚCHANNEL_FRAMING_RAWSOCKETÚfactoryÚ_serializersÚRAWSOCKET_SERIALIZER_IDr#   ÚbytesÚ	bytearrayÚ_serializerrt   r$   Úsendr   r   ru   r*   Ú
isinstanceÚ	call_args)r   r,   ry   ÚprotoÚsÚdro   rR   s         @@r   Útest_wamp_serverr�   ·   sÅ  øø€ åÐKÐLÑLÔL€IÝÐ'CÐ'CÐ'CÐ'CÐDÑDÔD€I„OÝ˜ +Ð.Ð/Ñ/Ô/€Fðð ð ð ð ð €Hà3Õ& {Ñ3Ô3Ñ5Ô5€EØ	×Ò˜)Ñ$Ô$Ð$ØÔ"Ô,°Ð4Ð4Ð4Ð4ØÔ"Ô2Õ6FÔ6`Ò`Ð`Ð`Ð`ØŒ=Ô%Ð%Ð%Ð%ØŒÔ" 1Ô%Ô=€AØ	×Ò��i¨¨t°a©x¸¸AÐ(>Ñ?Ô?Ñ@Ô@ÑAÔAÐAØÔÐÐÐØ
„M×)Ò)¨%Ñ0Ô0Ð0à	‡J‚J�wŒ}˜WÑ%Ô%Ñ&Ô&Ð&Ø�a�b�bŒ\ð ð ˆØ×Ò˜AÑÔÐÐØÔÔ"Ð"Ð"Ð"Ý�fÔ&Ô0°Ô3°AÔ6½¼ÑFÔFÐFÐFÐFÐFÐFr   c           
      ó  ‡‡— t          d¬¦  «        }t          ˆfd„¬¦  «        |_        t          ddg¬¦  «        Šˆfd„}g Š t          |¦  «        ¦   «         }|                     |¦  «         |j        j        d	u sJ ‚|j        j        t          j        k    sJ ‚|j	        sJ ‚|j	        j
        }|                     t          t          d
d|z  ddg¦  «        ¦  «        ¦  «         ‰j                             |¦  «         |                     t#          j        d¦  «        ¦  «         ‰dd …         D ]}|                     |¦  «         Œ‰j        j        sJ ‚t+          ‰j        j        d         d         t"          j        ¦  «        sJ ‚d S )Nrh   rY   c                 ó.   •— ‰                      | ¦  «        S rk   rl   rn   s    €r   rp   z"test_wamp_client.<locals>.<lambda>Ö   rq   r   rr   rt   ru   rv   c                  ó   •— ‰ S rk   r8   )rI   s   €r   Úfact_clientz%test_wamp_client.<locals>.fact_clientÙ   rz   r   Fr{   r|   r   r   r7   )r   r'   r   r"   r}   r~   r   r   r€   r†   rƒ   r#   r„   r…   rt   r$   r‡   r   r   ru   r*   rˆ   r‰   )r   r,   r‘   rŠ   r‹   rŒ   rI   ro   s         @@r   Útest_wamp_clientr’   Ó   s­  øø€ åÐKÐLÑLÔL€IÝÐ'CÐ'CÐ'CÐ'CÐDÑDÔD€I„OÝ˜ +Ð.Ð/Ñ/Ô/€Fðð ð ð ð ð €Hà3Õ& {Ñ3Ô3Ñ5Ô5€EØ	×Ò˜)Ñ$Ô$Ð$ØÔ"Ô,°Ð5Ð5Ð5Ð5ØÔ"Ô2Õ6FÔ6`Ò`Ð`Ð`Ð`ØÔÐÐÐØÔÔ1€AØ	×Ò��i¨¨t°a©x¸¸AÐ(>Ñ?Ô?Ñ@Ô@ÑAÔAÐAØ
„M×)Ò)¨%Ñ0Ô0Ð0à	‡J‚J�wŒ}˜WÑ%Ô%Ñ&Ô&Ð&Ø�a�b�bŒ\ð ð ˆØ×Ò˜AÑÔÐÐØÔÔ"Ð"Ð"Ð"Ý�fÔ&Ô0°Ô3°AÔ6½¼ÑFÔFÐFÐFÐFÐFÐFr   )ÚpytestÚosÚunittest.mockr   r   Úautobahn.asyncio.rawsocketr   r   r   r   r	   Úautobahn.asyncio.utilr
   Úautobahn.wampr   Úautobahn.wamp.typesr   ÚmarkÚskipifÚenvironÚgetr   r1   rK   rU   r[   ra   rf   r�   r’   r8   r   r   ú<module>rž      s7  ðØ €€€Ø 	€	€	€	à $Ð $Ð $Ð $Ð $Ð $Ð $Ð $ð;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;ð ;à 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø !Ð !Ð !Ð !Ð !Ð !Ø 0Ð 0Ð 0Ð 0Ð 0Ð 0ð „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔaðð ñ bÔaðð „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔað' ð ' ñ bÔað' ðT „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔað#ð #ñ bÔað#ð( „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔað.ð .ñ bÔað.ð0 „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔaðAð Añ bÔaðAð< „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔað.ð .ñ bÔað.ð, „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔað.ð .ñ bÔað.ð$ „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔaðGð Gñ bÔaðGð6 „×Ò˜œ
Ÿš }°eÑ<Ô<Ð<ÐE`ÐÑaÔaðGð Gñ bÔaðGð Gð Gr   