�
�GXc@@
s]
dd
lm
Z
mZ
ddlZddlZddlmZ
ddlZddlZ	ddl
Z
ddlZddlZddl
Z
ddlmZmZ
ddlmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
d
ef
d��YZdef
d
��YZdd�
Zd�Zde f
d��YZ!de f
d��YZ"dS(i(tabsolute_importtprint_functionN(
tpartial(tEMPTYtPARAMS(
tBaseCommand(
tServerError(
tBaseService(
taggregate_subclass_fields(
tparse_listdelimited_aws_xmltBaseRequestcB@
s�eZ
dZeZdZdZd
Ze	f
Z
ddd�Zed��
Z
e
jd��
Z
ed��
Zed��
Zd�Zd�Zd	�Zed
��
Zd�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(s
    The basis for a command line tool that represents a request.  The data for
    this request are stored in a few instance members:
     - method:   the HTTP method to use (e.g. 'GET').  Defaults to self.METHOD.
     - path:     the path to append to the service's path (e.g. 'sub/dir')
     - headers:  a dict of HTTP headers
     - params:   a dict of query parameters
     - body:     a string or file object containing a request body, or a dict
                 to pass to the server as form data

    This specialization of BaseCommand that implements main() as a three-step
    process:
     - preprocess():   do any processing needed before sending the request,
                       such as parsing complex command line arguments and
                       storing them in self.params, self.headers, and so forth.
     - send():         send this request to the server using the data stored
                       in its attributes, parse it using self.parse_result(),
                       and return it
     - postprocess():  given a parsed response, do any processing needed before
                       main() returns the response.

    Most requests need only implement preprocess().  Requests whose workflows
    involve sending other requests often do so in postprocess(), where the
    result of the request is known.

    Important members of this class, in addition to those inherited from
    BaseCommand, include:
     - SERVICE_CLASS:  a class corresponding to the web service in use
     - AUTH_CLASS:     a class corresponding to the authentication method
                       to use, if any
     - NAME:           a string representing the name of this request.
                       This defaults to the class's name.
     - METHOD:         the HTTP method to use by default
    tGETcK@
sq|j|_
d|_i|_i|_d
|_i|_d|_t	|_
||_|
|_t
j||�

dS(Nt(tMETHODtmethodtNonetpaththeaderstparamstbodytfilestresponsetFalset_BaseRequest__configuredt_BaseRequest__autht_BaseRequest__serviceRt__init__(tselftservicetauthtkwargs((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyROs
	
	
	
	
			
	
	c

C@
sD|jr=|j
dk	r=|j
|jd
|jj�

|_n|jS(Ntloglevel(Rt
AUTH_CLASSRtconfigtlogtlevel(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRas$cC@
s
|
|_dS(
N(
R(Rtnewval((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRisc

C@
sD|jr=|j
dk	r=|j
|jd
|jj�

|_n|jS(NR(Rt
SERVICE_CLASSRR!R"R#(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRms


cK@
sU|jd
|
j
�
|jd|
j�
|jd|
jj�
|d|
j|�
}|S(NRRRR!(t
setdefaultRRR"R#R!(tclstotherRtnew((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyt
from_otherts



c
C@
sotj
|�
}
|jdk	r=|
jt|jjd
��

n|jdk	rk|
jt|jjd
��

n|
S(NtARGS(Rtcollect_arg_objsRRtextendRt	__class__R(Rtarg_objs((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR,}s







c

C@
satj
|�

|jdk	r5|jjj|j�

n|jdk	r]|jjj|j�

ndS(
N(Rtdistribute_argsRRtargstupdateR(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR0�s






c

C@
sXtj
|�

|jdk	r,|jj
�
n|jdk	rK|jj
�
nt|_dS(
N(Rt	configureRRRtTrueR(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR3�s





c

C@
s|jp|j
jS(
N(tNAMER.t__name__(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pytname�sc
C@
s
|js|j
jd
�

nt|jp+i�
}
|
jd|jj��
yb|jj	d|j
d|jd|
d|jd|j
d|jd	|j�|_|j|j�
SWn]tk
r

}
|j|_y |jdk	r�|jj
nWntk
r�


n
X|j|�
SXdS(
Ns1send() called before configure(); bugs may results
User-AgentRRRRtdataRR(RR"twarntdictRR&tsuitetget_user_agentRtsend_requestRRRRRRRtparse_responseRRtcontenttRuntimeErrorthandle_server_error(RRterr((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pytsend�s$
	















cC@
sg|jj
d
di
td6�


|jj
|jjdi
td6�


|jj
d�

|jjd�

�dS(Ns-- response content --
textratappends-- end of response content --sresult: failure(R"tdebugR4Rttexttinfo(RRB((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRA�s


#


c
C@
s|
S(
N((RR((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR>�s
cK@
sy|jj
d
di
td6�


t|jjd�
�
�.}t||jtj�}|||�
}WdQX|jj
d�

|S(Ns-- response content --
RDREi@s-- end of response content --(	R"RFR4t_IteratorFileObjAdapterRtiter_contentt_ReadLoggingFileWrappertloggingtDEBUG(RRt
parse_funcRtcontent_fileobjtlogged_fileobjtparsed_response((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pytlog_and_parse_response�s





c
C@
s'|j�
|j
�}
|j|
�

|
S(
s

        The main processing method for this type of request.  In this method,
        inheriting classes generally populate self.headers, self.params, and
        self.body with information gathered from self.args or elsewhere,
        call self.send, and return the response.
        (t
preprocessRCtpostprocess(RR((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pytmain�s




c


C@
sdS(
N((
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRS�s
c
C@
sdS(
N((RR((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRT�s
cC@
s�t|
t
�rld
jtjjtjd�
|
j��}t	|dtj
�


|jr\�ntjd�

nt
j||
�
dS(Ns{0}: {1}itfilei
(t
isinstanceRtformattosRtbasenametsystargvtformat_for_clitprinttstderrRFtexitRthandle_cli_exception(RRBtmsg((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRa�s




	

N(R6t
__module__t__doc__RR%RR R5R
RtDEFAULT_ROUTESRtpropertyRtsetterRtclassmethodR*R,R0R3R7RCRAR>RRRURSRTRa(((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR
$s."


			
										tAWSQueryRequestcB@
seeZ
dZgZgZd�Zd
�Zed��
Z	d�Z
d�Zdd�
Ze
d�
ZRS(cC@
sytj
||
|�
|jru|
jd
dddddddd	d
ttd|j�

�

|j�|
_d|j	d<ndS(
Ns--filtertmetavars
NAME=VALUEtactionREtdesttfiltersthelps,restrict results to those that meet criteriattypetfilter_objs(
N(
R
t_populate_parsertFILTERStadd_argumentRt
_parse_filtert#_AWSQueryRequest__build_filter_helptepilogRt_arg_routes(RtparserR/((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRq�s

	






c

C@
sUtj
|�

d
|jkrQt|jjd
�
�
|jd<|jf
|jd<ndS(NRmtFilter(R
tprocess_cli_argsR1t_process_filterstpopRRw(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRz�s




c


C@
s|jS(
N(
R7(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRk�sc
C@
s3
|j}
t
j|j�
}|j|j�
}|j|d
<|jpL|jj|d<t|�
}xI|D]A}|j�j	d�
rft
ddi
d�d6��||<qfqfW|jjd|�
|j
j�dkr�|jjd	�

||_i|_n|jjd
�

||_ztj|�
SWd|
|_XdS(NtActiontVersiontpasswordtREDACTEDc


S@
sd
S(Ns
<redacted>((
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyt<lambda>
st__repr__sparameters: %stPOSTs)sending flattened parameters as form datas,sending flattened parameters as query string((Rtcopytdeepcopytflatten_paramsRktAPI_VERSIONRR:tlowertendswithRoR"RHRtupperRFRR
RC(Rtorig_paramsRtredacted_paramstkey((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRC
s(
	









'


	

	

cC@
s3|j|
t
d
|j�
}|t|j��
dS(Nt	list_tagsi(RRR	t	LIST_TAGStlisttkeys(RRt
response_dict((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR>
s
c	C@
s�i}|
dkrnnt
|
t�rR
x\tj|
�
D]
\}}|r[d
j||�}nt|�
}t
|t�s�t
|t�r�|j|j	||��

q4t
|t
�r�t|�
j�||<q4t
|t�r�|j
�||<q4t
|t�r

t|�
||<q4|s
|dkr2
t|�
||<q4|tkr4d||<q4q4Wn1
t
|
t�rmx
t|
d�D]�\}}|r�
d
j||�}nt|�
}t
|t�s�
t
|t�r�
|j|j	||��

qq
t
|t
�rt|�
j�||<qq
t
|t�r(|j
�||<qq
|s:|dkrMt|�
||<qq
|tkrq
d||<qq
qq
Wntd|
jj�
�
|S(s
        Given a possibly-nested dict of args and an arg routing
        destination, transform each element in the dict that matches the
        corresponding arg routing table into a simple dict containing
        key-value pairs suitable for use as query parameters.  This
        implementation flattens dicts and lists into the format given
        by AWS query APIs, which use dotted lists of dict keys and list
        indices to indicate nested structures.

        Keys with non-boolean, non-zero values that evaluate as false
        are ignored.  To include an empty string as a parameter, pass
        EMPTY (the object, not the string) as its value.

        Examples:
          in:  {'InstanceId': 'i-12345678', 'PublicIp': '1.2.3.4'}
          out: {'InstanceId': 'i-12345678', 'PublicIp': '1.2.3.4'}

          in:  {'RegionName': ['us-east-1', 'us-west-1']}
          out: {'RegionName.1': 'us-east-1',
                'RegionName.2': 'us-west-1'}

          in:  {'Filter': [{'Name':  'image-id',
                            'Value': ['ami-12345678']},
                           {'Name':  'instance-type',
                            'Value': ['m1.small', 't1.micro']}],
                'InstanceId': ['i-24680135']}
          out: {'Filter.1.Name':    'image-id',
                'Filter.1.Value.1': 'ami-12345678',
                'Filter.2.Name':    'instance-type',
                'Filter.2.Value.1': 'm1.small',
                'Filter.2.Value.2': 't1.micro',
                'InstanceId.1':     'i-24680135'}
        s{0}.{1}iRi
snon-flattenable type: N(RRWR:tsixt	iteritemsRXtstrR�R2R�tboolR�RVtreadtfloatRt	enumeratet	TypeErrorR.R6(	RR1tprefixt	flattenedR�tvaltprefixed_keyti_itemtitem((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR�&
sJ"




























c
C@
s�
d
tj
kr)dtj
kr)|
r)dSdg
}xB
|jD]7
}|jtjkrZq<q<|jr_
|jjd�
\}}}|jd�
r�|jd�
r�|dtj	|�
}n	|j}t
|j�
dk
r
dj|j�
}tj
d	td
|ddd�}	n:|jd
|j�

tj
d	td
ddddd�}	|j|	j|�
�

q<|jd
|j�

q<Wdj|�
S(s�
        Return a pre-formatted help string for all of the filters defined in
        self.FILTERS.  The result is meant to be used as command line help
        output.
        s-hs--helpRsallowed filter names:s

t
 is  {0:<20}  tfix_sentence_endingstinitial_indenttsubsequent_indentis  (R[R\RrRntargparsetSUPPRESSt	partitiont
startswithttextwraptdedenttlenR7RXtTextWrapperR4RER-twraptjoin(
Rtforcet	helplinest
filter_objtfirstt
_trestR?t	firstlinetwrapper((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyt__build_filter_helpu
s.%	



	

	

	


	




N(R6RcRR�RrR�RqRzRfRkRCR>R�RRu(((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRi�s


				OcC@
sfg|
pgD]}|j|�
r
|^q
}
|
sUd
j
|�
}tj|�
�
n|
dj|�
S(s

    Given a "key=value" string given as a command line parameter, return a pair
    with the matching filter's dest member and the given value after converting
    it to the type expected by the filter.  If this is impossible, an
    ArgumentTypeError will result instead.
    s""{0}" matches no available filtersi(tmatches_argvalRXR�tArgumentTypeErrortconvert(t
filter_strRptobjRb((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRt�
s




c
C@
s~i}
x;|piD]-\}}|
j|g�
|
|j
|�

qWgtj|
�
D] \}}i|d
6|d6^qT}|S(s�
    Change filters from the [(key, value), ...] format given at the command
    line to [{'Name': key, 'Value': [value, ...]}, ...] format, which
    flattens to the form the server expects.
    tNametValue(R&RER�R�(tcli_filterstfilter_argsR�R�R7tvaluesRm((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR{�
s


3
RIcB@
sGeZ
d�Zd
�Zd�Zed��
Zd�Zdd�
ZRS(cC@
s(|
|_g|_
t|_d
|_dS(Ni(t_sourcet_buflistRt_closedt_len(Rtsource((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR�
s
	
	
	
c


C@
s|S(
N((
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyt	__enter__�
s
c

G@
s|j�
dS(
N(
tclose(RR1((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyt__exit__�
s
c


C@
s|jS(
N(
R�(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pytclosed�
sc

C@
s"|jsd|_t|_ndS(
N(R�RR�R4(
R((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR��
s
	
	
i����cC@
s2
|
dks|
d
krcx!|j
D]}|jj|�

q"Wdj|j�
}g|_d
|_n�x`|j|
kr�y8t|j
�
}|jj|�

|jt|�
7_Wqftk
r�


PqfXqfWdj|j�
}t|�
|
}g|_d
|_|d
kr.
||g
|_||_|| }n|S(NiR(	RR�R�RER�R�tnextR�t
StopIteration(Rtsizetchunktresultt	extra_len((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR��
s,




	







	


	
	


	

(	R6RcRR�R�RfR�R�R�(((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRI�
s
				RKcB@
seZ
d�Zd
d�
ZRS(cC@
s|
|_||_
||_dS(
N(tfileobjtloggerR#(RR�R�R#((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR�
s
	
	
i����cC@
s9|jj
|
�
}|jj|j|d
i
td6�

|S(NRDRE(R�R�R�R"R#R4(RR�R�((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyR��
s

#
(R6RcRR�(((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyRK�
s
	(#t
__future__RR
R�R�t	functoolsRRLtos.pathRYR[R�twarningsR�trequestbuilderRRtrequestbuilder.commandRtrequestbuilder.exceptionsRtrequestbuilder.serviceRtrequestbuilder.utilRtrequestbuilder.xmlparseR	R
RiRRtR{tobjectRIRK(((s:/usr/lib/python2.7/site-packages/requestbuilder/request.pyt<module>s*











��	0