File: //lib/python3.6/site-packages/awscli/__pycache__/utils.cpython-36.pyc
3
�T_� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dlm
Z
dd� Z dd� Z d d
d �Z
d d
� Zdd� Zdd� Zejdd� �Zdd� Zdd� ZG dd� de�Zdd� ZdS ) � N)�six)�get_binary_stdout)� get_popen_kwargs_for_pager_cmdc s^ t � fdd�d D ��s � jd�S t � fd d�d
D ��sRttjtj� �dd
��d S t� �S d S )Nc 3 s | ]}|� kV qd S )N� )�.0�char)�valuer �/usr/lib/python3.6/utils.py� <genexpr> s z"split_on_commas.<locals>.<genexpr>�"�\�'�]�[�,c 3 s | ]}|� kV qd S )Nr )r r )r r r r
s )�
escapecharr )r r r
r r )r r
r r )�any�split�list�csv�readerr �StringIO�_split_with_quotes)r r )r r �split_on_commas s
r c C sN y t tjtj| �dd��d }W n" tjk
rB td| ��Y nX t|�}g }x�|D ]�}t|�}|j d�}|dkr�| j d�d kr�|d ks�|j |�|kr�d|kr�|}nt
| ||d�}t ||d d � �}|d |d � d j |� }|j
|� qVn<|d k�r|j
|� qVn$|j|�dk�r,|j
|j|d
�� qVt
| ||||�}|j
|� qVW |S )
Nr )r r zBad csv value: %sz=[r � � r � ���r )r r r r r �Error�
ValueError�iter�_find_quote_char_in_part�find�
_eat_itemsr �join�append�count�replace) r �parts�
iter_partsZ new_parts�part�
quote_charZ
list_startZ new_chunkZ
list_itemsr r r r ' s6
r r c C sl |}|j |d�g}xNytj|�}W n tk
r> t| ��Y nX |j|j |d�� |j|�rP qW dj|�S )z�
Eat items from an iterator, optionally replacing characters with
a blank and stopping when the end_char has been reached.
r r )r' r Zadvance_iterator�
StopIterationr r% �endswithr$ )r r) r* Zend_charZ replace_charZcurrentZchunksr r r r# R s
r# c C sv d| krd| krd S d }| j d�}| j d�}|dkrB|dkrBd}n0|dkrX|dkrXd}n||k rfd}n ||k rrd}|S )Nr r
r r r r )r" )r* r+ Z double_quoteZ single_quoter r r r! d s
r! c C sJ | j d�dd� }d}t|�dkr*|d }d}t|�dkrB|d }||fS )z�
Grabs the service id and the operation name from an event name.
This is making the assumption that the event name is in the form
event.service.operation.
�.r Nr )r �len)Z
event_nameZ split_eventZ service_nameZoperation_namer r r �%find_service_and_method_in_event_nameu s r0 c C s t | tj�r| j� S | S dS )z6JSON encoder that formats datetimes as ISO8601 format.N)�
isinstance�datetimeZ isoformat)�objr r r � json_encoder� s r4 c c s0 t j t jt j�} z
d V W d t j t j| � X d S )N)�signal�SIGINT�SIG_IGN)�originalr r r �
ignore_ctrl_c� s
r9 c C s | j d|| d� d S )Nztop-level-args-parsed)Z parsed_args�session)�emit)r: �argsr r r � emit_top_level_args_parsed_event� s r= c C s6 yt jtjj� �S tk
r0 } zdS d } ~ X nX d S )NF)�os�isatty�sys�stdout�fileno� Exception)�er r r �is_a_tty� s rE c @ s< e Zd Zd
dd�Zejd dd��Zejdd� �Zdd � ZdS ) �OutputStreamFactoryNc C s || _ |d krtj| _ d S )N)�_popen�
subprocess�Popen)�self�popenr r r �__init__� s z OutputStreamFactory.__init__c c sL | j |�}z2y| jf |�}|jV W n tk
r8 Y nX W d |j� X d S )N)�_get_process_pager_kwargsrG �stdin�IOErrorZ communicate)rJ Zpreferred_pagerZ popen_kwargsZprocessr r r �get_pager_stream� s
z$OutputStreamFactory.get_pager_streamc c s t � V d S )N)r )rJ r r r �get_stdout_stream� s z%OutputStreamFactory.get_stdout_streamc C s t |�}tj|d< |S )NrN )r rH �PIPE)rJ Z pager_cmd�kwargsr r r rM � s
z-OutputStreamFactory._get_process_pager_kwargs)N)N) �__name__�
__module__� __qualname__rL �
contextlib�contextmanagerrP rQ rM r r r r rF � s
rF c C s( |j d� |j tj| �� |j d� d S )N�
)�writer Z text_type)ZexZoutfiler r r �write_exception� s
r[ )r )r r5 r2 rW r> r@ rH Z
awscli.compatr r r r r r# r! r0 r4 rX r9 r= rE �objectrF r[ r r r r �<module>
s(
+