
    .Ph4                         d dl Z d dlZd dlmZmZmZmZ d dlmZm	Z	 d dl
mZmZmZ ddlmZ ej        j         ej                            e d          gZd	 Z ed
dd          Zd Zd Zd Zd Zd Zd Zd ZdS )    N)DBusAddressDBusErrorResponseMessageTypenew_method_call)message_bus	MatchRule)open_dbus_connectionopen_dbus_routerProxy   )have_session_buszTests require DBus session bus)reasonc                     K   t          d           d {V } | 4 d {V  | j                            d          sJ 	 d d d           d {V  d S # 1 d {V swxY w Y   d S )NSESSIONbus:)r	   unique_name
startswith)conns    Z/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/jeepney/io/tests/test_trio.pytest_connectr      s     %)444444444D 0 0 0 0 0 0 0 0**3//////0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s   A
AAzorg.freedesktop.DBusz/org/freedesktop/DBuszorg.freedesktop.DBus.Peer)bus_nameobject_path	interfacec                    K   t          t          d          } t          d          4 d {V }t          j        d          5  |                    |            d {V }d d d            n# 1 swxY w Y   d d d           d {V  n# 1 d {V swxY w Y   |j        j        t          j	        k    sJ |j
        dk    sJ d S )NPingr   r       )r   bus_peerr
   trio
fail_aftersend_and_get_replyheadermessage_typer   method_returnbody	ping_callreqreplys      r   test_send_and_get_replyr,       s     &11II... < < < < < < <#_Q 	< 	<00;;;;;;;;E	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	<< < < < < < < < < < < < < < < < < < < < < < < < < < < <$(AAAAA:5   BA+B+A/	/B2A/	3B
BBc                  n  K   t          t          d          } t          d          4 d {V }t          j        d          5  |                    |            d {V }d d d            n# 1 swxY w Y   d d d           d {V  n# 1 d {V swxY w Y   |j        j        t          j	        k    sJ d S )NSnartr   r   r   )
r   r    r
   r!   r"   r#   r$   r%   r   errorr(   s      r   test_send_and_get_reply_errorr1   *   s}     '22II... < < < < < < <#_Q 	< 	<00;;;;;;;;E	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	< 	<< < < < < < < < < < < < < < < < < < < < < < < < < < < <$(9999999r-   c                  8  K   t          d          4 d {V } t          t          |           }d}|                    |           d {V }|dv sJ |                    |           d {V \  }|du sJ 	 d d d           d {V  d S # 1 d {V swxY w Y   d S )Nr   r   z+io.gitlab.takluyver.jeepney.examples.Server>   r      T)r
   r   r   RequestNameNameHasOwner)r*   proxynameres	has_owners        r   
test_proxyr<   3   sW     I... ! ! ! ! ! ! !#k3''<%%d++++++++l"""" --d33333333
	D     ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s   AB		
BBc                  B  K   t          d          4 d {V } t          t          |           }t          j        t
                    5  |                    d           d {V  d d d            n# 1 swxY w Y   d d d           d {V  d S # 1 d {V swxY w Y   d S )Nr   r   z:123)r
   r   r   pytestraisesr   r6   )r*   r8   s     r   test_proxy_errorr@   >   sm     I... , , , , , , ,#k3''],-- 	, 	,##F+++++++++	, 	, 	, 	, 	, 	, 	, 	, 	, 	, 	, 	, 	, 	, 	,, , , , , , , , , , , , , , , , , , , , , , , , , , , , , ,s5   /BA0$B0A4	4B7A4	8B
BBc                    K   d} t          d          4 d {V }t          t          |          }t          dt          j        t          j        dt          j                  }|                    d|            |                    |           d {V  |	                    |          4 d {V }|
                    |            d {V \  }|dk    sJ t          j        d	          5  |                                 d {V }d d d            n# 1 swxY w Y   |j        | d
|j        fk    sJ 	 d d d           d {V  n# 1 d {V swxY w Y   d d d           d {V  d S # 1 d {V swxY w Y   d S )Nz2io.gitlab.takluyver.jeepney.tests.trio_test_filterr   r   signalNameOwnerChanged)typesenderr   memberpathr   r   g       @ )r
   r   r   r   r   r   r   add_arg_conditionAddMatchfilterr6   r!   r"   receiver'   r   )r9   routerr   
match_rulechanr:   
signal_msgs          r   test_filterrQ   E   s+     ?DI... E E E E E E E&K(('!+%(
 
 

 	$$Q--- ll:&&&&&&&&&==,, 	E 	E 	E 	E 	E 	E 	E........DC!8888%% 2 2#'<<>>111111
2 2 2 2 2 2 2 2 2 2 2 2 2 2 2?tR1C&DDDDDD	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	E 	EE E E E E E E E E E E E E E E E E E E E E E E E E E E E E EsZ   BE'/:E)DEDEDE1E'
E	E'E	E''
E14E1c                 
  K   t          | d          }t          j        d          5  t          dd          4 d {V }|                    |           d {V }d d d           d {V  n# 1 d {V swxY w Y   d d d            n# 1 swxY w Y   |j        j        t          j        u sJ |j	        d         
                    d          5 }|                                dk    sJ 	 d d d            d S # 1 swxY w Y   d S )	NGetFDr   r   Tr   
enable_fdsr   zw+readme)r   r!   r"   r
   r#   r$   r%   r   r&   r'   to_fileread)respond_with_fd
getfd_callrM   r+   fs        r   test_recv_fdr\   _   sC      '::J			 @ @#	dCCC 	@ 	@ 	@ 	@ 	@ 	@ 	@v 33J????????E	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@@ @ @ @ @ @ @ @ @ @ @ @ @ @ @ <$(AAAAA	A		t	$	$ $vvxx8#####$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $sF   B
A-B
-
A7	7B
:A7	;B

BBC88C<?C<c                   K   | \  }}t          |dd|f          }t          j        d          5  t          dd          4 d {V }|                    |           d {V }d d d           d {V  n# 1 d {V swxY w Y   d d d            n# 1 swxY w Y   |j        j        t          j        u sJ |j	        d         |k    sJ d S )NReadFDhr   r   TrT   r   )
r   r!   r"   r
   r#   r$   r%   r   r&   r'   )temp_file_and_contentsread_from_fd	temp_filedatareadfd_callrM   r+   s          r   test_send_fdre   j   s     ,OIt!,#	|LLK			 A A#	dCCC 	A 	A 	A 	A 	A 	A 	Av 33K@@@@@@@@E	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	A 	AA A A A A A A A A A A A A A A <$(AAAAA:a=D      s5   BA5#B5
A?	?BA?	BBB)r!   r>   jeepneyr   r   r   r   jeepney.bus_messagesr   r   jeepney.io.trior	   r
   r   utilsr   markskipif
pytestmarkr   r    r,   r1   r<   r@   rQ   r\   re   r       r   <module>rn      ss     P P P P P P P P P P P P 7 7 7 7 7 7 7 7          $ # # # # # K
K%E   
0 0 0
 ;#')    : : :! ! !, , ,E E E4$ $ $! ! ! ! !rm   