U
    [eM                     @   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 )NZSESSION)bus)r   close)	transportproto r   f/var/www/html/services/stratfitenv/lib/python3.8/site-packages/jeepney/integrate/tests/test_asyncio.pysession_proto   s    r   c                    s   | j dstd S )N:)Zunique_name
startswithAssertionError)r   r   r   r   test_connect_old   s    r   zorg.freedesktop.DBusz/org/freedesktop/DBuszorg.freedesktop.DBus.Peer)Zbus_nameZobject_pathZ	interfacec                    s4   t td}tj| |ddI d H }|dks0td S )NZPing   )timeoutr   )r   bus_peerasynciowait_forsend_messager   )r   Z	ping_callZ
reply_bodyr   r   r   test_send_and_get_reply_old"   s    
 r   c                    sL   t t| }d}||I d H }|dks*t||I d H \}|dksHtd S )Nz+io.gitlab.takluyver.jeepney.examples.Server>         T)r   r   ZRequestNamer   ZNameHasOwner)r   proxynameresZ	has_ownerr   r   r   test_proxy_old)   s    
r"   )r   ZpytestZjeepneyr   r   Zjeepney.bus_messagesr   Zjeepney.integrate.asyncior   r   Zjeepney.io.tests.utilsr   markZskipifZ
pytestmarkZfixturer   r   r   r   r"   r   r   r   r   <module>   s*    
