U
    [e
                     @   s   d dl mZ d dlZd dlZd dlmZmZmZmZm	Z	m
Z
 d dlmZmZmZ e dd Ze dd Ze d	d
 ZdS )    )TemporaryFileN)DBusAddressHeaderFieldsmessage_busMessageType	new_errornew_method_return)open_dbus_connection
DBusRouterProxyc               
   #   s   d} t | dd}tddd` t }tt|| \}W 5 Q R X |dksPt fdd	}tj|dd
}|	  |V  W 5 Q R X |
  d S )Nz1io.gitlab.takluyver.jeepney.tests.respond_with_fd/Zbus_nameZobject_pathSESSIONTbusZ
enable_fds   c               	      s      } | jjtjkr | jjtj dkrttd<}|	d |
d t| d|f} | W 5 Q R  d S Q R X q  t| d q d S )NZGetFDzw+Zreadmer   hNoMethod)receiveheadermessage_typer   method_callfieldsr   memberr   writeseekr   sendr   )msgtfrepconn [/var/www/html/services/stratfitenv/lib/python3.8/site-packages/jeepney/io/tests/conftest.py_reply_once   s    



z$respond_with_fd.<locals>._reply_oncetargetdaemonr   r	   r
   r   r   ZRequestNameAssertionError	threadingThreadstartjoinnameaddrZrouterstatusr$   Zreply_threadr"   r    r#   respond_with_fd   s    
r2   c               
   #   s   d} t | dd}tddd` t }tt|| \}W 5 Q R X |dksPt fdd	}tj|dd
}|	  |V  W 5 Q R X |
  d S )Nz.io.gitlab.takluyver.jeepney.tests.read_from_fdr   r   r   Tr   r   c               	      s      } | jjtjkr | jjtj dkrn| jd 	d}|
d | }W 5 Q R X  t| d|f d S  t| d q d S )NZReadFDr   rbZayr   )r   r   r   r   r   r   r   r   bodyZto_filer   readr   r   r   )r   fbr    r"   r#   r$   5   s    
z!read_from_fd.<locals>._reply_oncer%   r(   r.   r"   r    r#   read_from_fd+   s    
r8   c               	   c   sB   d} t d,}||  |  |d || fV  W 5 Q R X d S )Ns   abc123zw+br   )r   r   flushr   )datar   r"   r"   r#   temp_file_and_contentsI   s    


r;   )tempfiler   r*   ZpytestZjeepneyr   r   r   r   r   r   Zjeepney.io.threadingr	   r
   r   Zfixturer2   r8   r;   r"   r"   r"   r#   <module>   s    

