o
    `M                     @   s   d dl Z d dlZd dlmZmZ d dlmZ d dlmZm	Z	 d dl
mZ ejj ejje ddgZe dd	 Zd
d ZeddddZdd Zdd ZdS )    N)DBusAddressnew_method_call)message_bus)connect_and_authenticateProxy)have_session_buszTests require DBus session bus)reasonc                  C  s(   t ddI d H \} }|V  |   d S )NSESSION)bus)r   close)	transportproto r   F/usr/lib/python3/dist-packages/jeepney/integrate/tests/test_asyncio.pysession_proto   s   r   c                    s   | j ds	J d S )N:)unique_name
startswith)r   r   r   r   test_connect_old   s   r   zorg.freedesktop.DBusz/org/freedesktop/DBuszorg.freedesktop.DBus.Peer)bus_nameobject_path	interfacec                    s6   t td}tj| |ddI d H }|dksJ d S )NPing   )timeoutr   )r   bus_peerasynciowait_forsend_message)r   	ping_call
reply_bodyr   r   r   test_send_and_get_reply_old"   s   

r!   c                    sN   t t| }d}||I d H }|dv sJ ||I d H \}|du s%J d S )Nz+io.gitlab.takluyver.jeepney.examples.Server>         T)r   r   RequestNameNameHasOwner)r   proxynameres	has_ownerr   r   r   test_proxy_old)   s   
r,   )r   pytestjeepneyr   r   jeepney.bus_messagesr   jeepney.integrate.asyncior   r   jeepney.io.tests.utilsr   markskipif
pytestmarkfixturer   r   r   r!   r,   r   r   r   r   <module>   s*    
