File: //usr/lib/python3/dist-packages/boto/roboto/__pycache__/awsqueryrequest.cpython-310.pyc
o
ckF[�H � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZzd dl Z
W n
e y7 d dl Z
Y nw dd� Z
G dd� de�ZG dd� dejj�ZG dd � d ejj�ZG d
d � d ejj�ZG d d
� d
e�ZG dd� de�ZdS )� Nc s � �fdd�}|S )Nc s� | t ju r
t�d� tjt_�r/tj�� r/tj�� r/t j
dkr(t � || |� d S t � |� d S � r?t t
�|�� t�d� d S t |� t�d� d S )N� �epdb)�bdb�BdbQuit�sys�exit�__excepthook__�
excepthook�stdout�isatty�stdin�debugger�__name__� post_mortem�print� traceback�print_tb)�typ�value�tb��
debug_flag�
debugger_flag� �=/usr/lib/python3/dist-packages/boto/roboto/awsqueryrequest.pyr & s
z$boto_except_hook.<locals>.excepthookr )r r r r r r �boto_except_hook% s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�Linec C s& || _ || _|| _d| | _d| _d S )N�%s F)�fmt�data�label�line�printed)�selfr r r r r r �__init__; s
z
Line.__init__c C s | j d| 7 _ d S )Nr )r! )r# �datumr r r �appendB s z Line.appendc C s | j s
t| j� d| _ d S d S )NT)r" r r! �r# r r r �print_itE s
�z
Line.print_itN)r �
__module__� __qualname__r$ r& r( r r r r r 9 s r c � e Zd Z� fdd�Z� ZS )�RequiredParamErrorc �$ || _ d| j }tt| ��|� d S )Nz#Required parameters are missing: %s)�required�superr, r$ )r# r. �s�� __class__r r r$ L �
zRequiredParamError.__init__�r r) r* r$ �
__classcell__r r r1 r r, J � r, c r+ )� EncoderErrorc s d| }t t| ��|� d S )NzError encoding value (%s))r/ r7 r$ )r# � error_msgr0 r1 r r r$ S s zEncoderError.__init__r4 r r r1 r r7 Q r6 r7 c r+ )� FilterErrorc r- )N�Unknown filters: %s)�filtersr/ r9 r$ )r# r; r0 r1 r r r$ Y r3 zFilterError.__init__r4 r r r1 r r9 W r6 r9 c @ s^ e Zd Zeddd��Zedd� �ZeZeZedd� �Zedd � �Z ed
d � �Z
ed d
� �Z dS )�EncoderNc C sR |j �d�rd S zt| d|j �}|||||� W d S ty( td|j ��w )N�_�encode_zUnknown type: %s)�name�
startswith�getattr�ptype�AttributeErrorr7 )�cls�p�rp�vr �mthdr r r �encode` s �zEncoder.encodec C � |r|}n|j }|||< d S �N�r? �rD rE rF rG �lr r r r �
encode_stringj � zEncoder.encode_stringc C s |r|}n|j }d| ||< d S )Nz%drL rM r r r �encode_integeru s zEncoder.encode_integerc C s* |r|}n|j }|r
d}nd}|||< d S )N�true�falserL rM r r r �encode_boolean} s zEncoder.encode_booleanc C rJ rK rL rM r r r �encode_datetime� rP zEncoder.encode_datetimec C sJ t j�|�}|r |}n|j}|d }t|�D ] \}}||||d < qd S )Nz.%dr )�boto�utils�mklistr? � enumerate)rD rE rF rG rN r �ir r r r � encode_array� s �zEncoder.encode_arrayrK ) r r) r* � classmethodrI rO � encode_file� encode_enumrQ rT rU r[ r r r r r< ^ s
r< c @ s� e Zd ZdZdZg Zg Zg Zi Zddddddddd�Z e
dd� �Z d d
� Z d d � Z
d
d� Zedd� �Zedd� �Zedd� �Zdd� Zdd� Zd,dd�Zd-d d �Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd.d(d)�Z d*d+� Z dS )/�AWSQueryRequestN� �string�int�choice)ra �integerrb �enum�datetime�dateTime�file�booleanc C s | j S rK )r )rD r r r r? � s zAWSQueryRequest.namec K s@ || _ d | _d | _d | _d | _d | _g | _g | _i | _d | _ d S rK )
�args�parser� cli_options�cli_args�cli_output_format�
connection� list_markers� item_markers�request_params�connection_args�r# rj r r r r$ � s
zAWSQueryRequest.__init__c C s | � � S rK rL r' r r r �__repr__� s zAWSQueryRequest.__repr__c K s" | j d u r| jdi |��| _ | j S )Nr )ro � ServiceClassrt r r r �get_connection� s
z AWSQueryRequest.get_connectionc C � d }| j d ur | j j}|S rK )�
http_response�status�r# �retvalr r r rz � �
zAWSQueryRequest.statusc C rx rK )ry �reasonr{ r r r r~ � r} zAWSQueryRequest.reasonc C s d }| j d ur
t| j d�}|S )N� requestId)� aws_responserA r{ r r r �
request_id� s
zAWSQueryRequest.request_idc s� | j �dg �}dd� | jD �� � fdd�|D �}|r td| ��t| j�D ]5\}}|d }||v rZ|| jd|d < ttj�|| ��D ]\}}t �
|| j|d |d |d f � qDq%d S )
Nr; c S s g | ]}|d �qS rL r ��.0�fr r r �
<listcomp>� s z3AWSQueryRequest.process_filters.<locals>.<listcomp>c s g | ]}|� vr|�qS r r r� �� filter_namesr r r� � � r: r? zFilter.%d.Namer zFilter.%d.Value.%d) rj �get�Filtersr9 rY rr rV rW rX r< rI )r# r; �unknown_filtersrZ �filterr? �jr r r� r �process_filters� s ���z AWSQueryRequest.process_filtersc K s� | j �|� t�| j �| _d| j v r | j d dkr t�| �� � dd� | j| j D �}| j| j D ]W}|j r>|j �
dd�}ntj � |jd�}d}|| j v rR| j | }|du rY|j
}|dur|j|v rh|�|j� |jr|jrw|�|| j|� nt�|| j|� || j v r�| j|= q1|r�g }| j| j D ]-}|j|v r�|jr�|j r�|�d|j|jf � q�|jr�|�d |j � q�|�d |j � q�td
�|���tj�d | j � | � | j � dS ) a�
Responsible for walking through Params defined for the request and:
* Matching them with keyword parameters passed to the request
constructor or via the command line.
* Checking to see if all required parameters have been specified
and raising an exception, if not.
* Encoding each value into the set of request parameters that will
be sent in the request to the AWS service.
�debug� c S s g | ]}|j s|j�qS r )�optionalr? )r� rE r r r r� � r� z0AWSQueryRequest.process_args.<locals>.<listcomp>�-r= Nz(%s, %s)z(%s)�,zrequest_params: %s) rj �update�copyrs rV �set_stream_loggerr? �Params�Args� long_name�replacerW �pythonize_name�default�remove�
request_param�encoderrr r< rI �
short_namer& �optparse_short_name�optparse_long_namer, �join�logr� �process_markers�Response)r# rj r. �param� python_namer rN rE r r r � process_args� sN
�
��z AWSQueryRequest.process_argsc C sj |r|d dkr|d D ]
}| � ||d � q d S |r1|d dkr3| j�|� | j�|d � d S d S d S )N�type�object�
propertiesr? �array)r� rp r& rq )r# r � prev_name�propr r r r� s � �z AWSQueryRequest.process_markers�GETc K s� | j di |�� | �� | jdi | j��}|j| �� | j|d�| _| j�� | _ t
j � | j � | jj
dkrPt
jj| j| jd�| _t
j�| j| �}|�| j � | jS t
j �d| jj
| jjf � t
j �d| j � |�| jj
| jj| j ��)N)�verb�� )� list_marker� item_markerz%s %sz%sr )r� r� rw rs � make_requestr? rr ry �read�bodyrV r� r� rz � jsonresponse�Elementrp rq r� �
XmlHandler�parse�errorr~ �
ResponseError)r# r� rj �conn�hr r r �send% s0
�
� �
�zAWSQueryRequest.sendc C s� t �| jd�}|jddddd� |jdddd d
� |jd d d
dd� |jdd
dd� |jddd
dd� |jddd
dd� |jdddd� | jrZ| jjdddd� | jjdd d d d � | j�|� d S ) NzStandard Optionsz-Dz--debug�
store_truez Turn on all debugging output)�action�helpz
--debuggerFz$Enable interactive debugger on error)r� r� r� z-Uz--url�storez(Override service URL with value providedz--regionz Name of the region to connect toz-Iz--access-key-idzOverride access key valuez-Sz --secret-keyzOverride secret key valuez --versionzDisplay version stringz--help-filtersz!Display list of available filtersz--filterr& z name=valuez!A filter for limiting the results)r� �metavarr� )�optparse� OptionGrouprk �
add_optionr� �group�add_option_group)r# r� r r r �add_standard_options< s@
��
��
�
��
�
�z$AWSQueryRequest.add_standard_optionsc C s� t |d�r!|jr!td� | jD ] }td|j|jf � qt�d� |jr)d| j d< |j
r2|j
| j d< |j r;|j | j d< |j rD|j | j d < |j
rM|j
| j d
< |jrXtd � td� t|j|j�t_d S ) N� help_filterszAvailable filters:z%s %sr r� r� �url�region�aws_access_key_id�aws_secret_access_keyz version x.xx)�hasattrr� r r� r? �docr r r� rj r� r� �
access_key_id�
secret_key�versionr r
r )r# �optionsrj �dr� r r r �process_standard_optionsV s*
�z(AWSQueryRequest.process_standard_optionsc C sL d}dd� | j D �}|d�|�7 }| j D ]}|jr#|d|j|jf 7 }q|S )Nzusage: %prog [options] c S s g | ]}|j �qS r )r� )r� �ar r r r� o s z-AWSQueryRequest.get_usage.<locals>.<listcomp>� z
%s - %s)r� r� r� r� )r# r0 rN r� r r r � get_usagem s
�zAWSQueryRequest.get_usagec C s� t j| j| �� d�| _| �� | jD ]f}d } }}|j| jv r(| j|j }d}|jdkr0d}n |jdkrFt |j
�dkrE|j
d d }d }n|j dkrMd }|sS|dkrx|j rg| jj
|j|j|||j|jd
� q|jrx| jj
|j|||j|jd
� qd S ) N)� description�usager� ri r� r� r r r� r& )r� r� �choicesr� )r� � OptionParser� Descriptionr� rk r� r� rB �
CLITypeMap�len�items� cardinalityr� r� r� r� r� r� r� )r# r� rB r� r� r r r �build_cli_parserv sD �
�
�
���z AWSQueryRequest.build_cli_parserc
C s� | j s| �� | j �� \| _| _i }| �| j| j|� | jD ]V}|jr+|j�dd�}nt j
� |j �}t
| j|�}|jdkrp|rp|dkrItj�� }n'tj�|�}tj�|�}tj�|�rht|�}|�� }|�� n| j �d| � |||< q | jD ]/}|jr�|j�dd�}nt j
� |j �}d }|jdkr�t | j�dkr�| jd }n| j}|||< qx| j � |� t | jd�r�| jj r�i }| jj D ]
}|�!d�\} }||| < q�d | j v r�| j d � |� n|| j d < z | �"� }
| �#|
� W d S t$�y } zt%| � t�&d� W Y d } ~ d S d } ~ w | j'j(�y, } zt%d
| j)| j*f � t�&d� W Y d } ~ d S d } ~ w t j+j,j-�yK } zt%d � t�&d� W Y d } ~ d S d } ~ w t.�yg } zt%| � t�&d� W Y d } ~ d S d } ~ ww ) Nr� r= rh zUnable to read file: %sr r r� �=r; z
Error(%s): %szUnable to find credentials.)/rk r� �
parse_argsrl rm r� r� r� r� rV rW r� r? rA rB r r r� �os�path�
expanduser�
expandvars�isfile�open�closer� r� r� r� rj r� r� r� �split�main�
cli_formatterr, r r rv r� �
error_code�
error_message�roboto�awsqueryservice�NoCredentialsError� Exception)
r# r� r� �p_namer r� �fp�argr� r? �response�e�errr r r �do_cli� sz
�
�����zAWSQueryRequest.do_clic C s� |d dkrA|d D ]4}d|v r7|d |v r ||d }|d | j v r7|d }|d dkr3|dd� }|�� }| �|||� q
d S |d dkrr|D ]*}t|||�}t|t�rc|D ] }|�|| � qXn
t|t�rm|�|� |�� qId S d S ) Nr� r� r� r? ���r0 r r� ) rp �upper�_generic_cli_formatterr �
isinstance�dictr& �
basestringr( )r# r r r r� �itemr! �
field_namer r r r � s0 �
�
�z&AWSQueryRequest._generic_cli_formatterc C s |r | � | j|� dS dS )a�
This method is responsible for formatting the output for the
command line interface. The default behavior is to call the
generic CLI formatter which attempts to print something
reasonable. If you want specific formatting, you should
override this method and do your own thing.
:type data: dict
:param data: The data returned by AWS.
N)r r� )r# r r r r r� � s �z AWSQueryRequest.cli_formatterrK )r� )r` ) r r) r* rv r� r� r� r� r� r� r\ r? r$ ru rw �propertyrz r~ r� r� r� r� r� r� r� r� r� r� r r� r r r r r_ � sL �
3
? r_ )r r� rV r� r� �boto.exception�boto.roboto.awsqueryservicer r r r
� ImportError�pdbr r� r � exception�BotoClientErrorr, r7 r9 r< r_ r r r r �<module> s* �>