agent-first-http 0.4.3

+
�Yjv
��
�Rt^R
I
t
^R
It^R
It^R
It^R
It]!]PPRR44
t	R]	2t
Rt]	3
RRll
t]
R8Xdn^R
It^R
It]!]P"4
^
8�d]!]P"^
,4
M
]	t]!R	]2]P(R
7Rt]
P,!]!44
R
#R
#)z\
WebSocket test server for afhttp WebSocket tests.
Requires: pip install websockets  (>=10)
N�AFH_TEST_WS_PORT�18081zws://127.0.0.1:c
���"�VPPp
\P!RV
4pV'd^\	VP^
4
4
p\
V4
F2pVP\P!R
V/
4
4
GRjx
�L
K4	R#\P!RV
4pV'd�\	VP^
4
4
\	VP^4
4
rS\
V4
FfpVP\P!R
V/
4
4
GRjx
�L
WC^
,
8gKA\P!VR,4
GRjx
�L
Kh	R#V
R8Xd(VRjx
�L
pVPV4
GRjx
�L
K%V
R8Xd.VP\\
^4
4
4
GRjx
�L
R#V
R8XdgVPPP4UUu/uFwrxWxbK		p	ppVP\P!V	4
4
GRjx
�L
R#VPRR	4GRjx
�L
R#E
L�E
L-L�L�L�D�R#L�uuppiL9L5i
)
z^/ws/push/(\d+)$�seqNz^/ws/push/(\d+)/(\d+)$g@�@z/ws/echoz
/ws/binaryz/ws/headersi�zunknown path)�request�path�re�match�int�group�range�send�json�dumps�asyncio�sleep�bytes�headers�items�close)
�	websocketr�
m�
n�
i�delay_ms�message�
k�
vrs
&         �H/Users/roger/me/agentfirstkit/spores/agent-first-http/tests/ws_server.py�handlerrs�
������!�!�D�	���$�d�+�A���
���
�
�O�
��q��A��.�.����U�A�J�!7�8�8�8���	���*�D�1�A���!�'�'�!�*�o�s�1�7�7�1�:��8��q��A��.�.����U�A�J�!7�8�8�8��q�5�y��m�m�H�v�$5�6�6�6��	��z��&�
	*�
	*�'��.�.��)�)�)��|���n�n�U�5��9�-�.�.�.���}��$-�$5�$5�$=�$=�$C�$C�$E�F�$E�D�A�1�4�$E��F��n�n�T�Z�Z��0�1�1�1���/�/�$��
/�/�/�?
9�
9�6�

	*�)�'��	/��
G
�1�0�s��BI$
�

I	�(I$
�4A+I$
�
I� I$
�3 I$
�
I�I$
�'I�+
I�,I�/I$
�
I�3I$
�9
I�:4I$
�.
I�;+I$
�&
I �'I$
�
I"�I$
�
I$
�
I$
�
I�
I$
�I$
�I$
�"
I$
c

�D�V^8�dQ
h
R
\R\P/#)��port�return)r
�	threading�Thread)
�formats
"r�__annotate__r':s ��
�
�#�
�I�,<�,<�
�c
��aaaa�^R
Io\P!4oVVV3RloV3
Rlp
\P!V
RR7pVP	4SP^R7
'g\
R4
h
V#)zFStart WS test server in a daemon thread. Blocks until server is ready.Nc��&
<"�SP!\RSR
R7;
_uu_4G
R
jx
�L
S
P4\P!4GR
jx
�L
R
R
R
4GR
jx
�L
R
#LCLL
 +GR
jx
�L
'giR
#;i
5i
�z	127.0.0.1N)
�
ping_interval)�server�setr�Future)r"�ready�
websocketss���r�_main�start_ws_server.<locals>._main@sW�����#�#�G�[�$�d�S�S�S��I�I�K��.�.�"�"�"�T
�S�S�"�T
�S�S�S�s\�'B
�
A.�B
�)A4�
A0�A4�B
�'
A2�(B
�0
A4�2
B
�4B	�:
A=�;
B	�B	�	B
c�><
�\P!S!44
R#)
N)r�run)
r2s
�r�_run�start_ws_server.<locals>._runEs������E�G�r(T)�target�daemon)
�timeoutz%WebSocket test server failed to start)r1r$�Eventr%�start�wait�RuntimeError)r"r6�threadr2r0r1sf  @@@r�start_ws_serverr@:s[�����O�O��E�#�

��
�
�T�$�
7�F�
�L�L�N��:�:�a�:� � ��B�C�C��Mr(�__main__z(WebSocket test server on ws://127.0.0.1:)
�filec��
"�\P!\R\R
R7;
_uu_4G
R
jx
�L
\P
!4GR
jx
�L
R
R
R
4GR
jx
�L
R
#L3LL
 +GR
jx
�L
'giR
#;i
5i
r+)r1r-rr"rr/�r(r�_serverEVsM����#�#�G�[�$�d�S�S�S��.�.�"�"�"�T
�S�S�"�T
�S�S�S�s\�/B
�
A%�B
�A+�
A'�A+�B
�
A)�B
�'
A+�)
B
�+B	�1
A4�2
B	�=B	�?	B
)�__doc__rr�osrr$r
�environ�get�WS_PORT�WS_BASErr@�__name__�sysr1�len�argvr"�print�stderrrEr5rDr(r�<module>rR
s��


�
�

��	�	��

�b�j�j�n�n�/��9�
:���G�9�
%��'
0�T
!(�
�*�z����"�3�8�8�}�q�0�3�s�x�x�
�{��g�D�	�4�T�F�
;�#�*�*�M�#��K�K����r(