ó
EV¥cc@sqdd
lZdd
l
Z
ddlmZ
ddlmZ
ddlmZ
ddlm	Z	
dd
l
Z
dd
lZddlm
Z
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
ejeƒ
Zd
dfZddddgZddgZdZdZdZdZ dZ!d„Z"d„Z#dej$f
d„ƒYZ$de%f
d„ƒYZ&d e&f
d!„ƒYZ'd"e&f
d#„ƒYZ(d$„Z)d%e%f
d&„ƒYZ*d'„Z+d(e%f
d)„ƒYZ,d*ej-f
d+„ƒYZ.d,„Z/d-„Z0d.„Z1d/e2f
d0„ƒYZ3e
j4e3ƒ
d1e%f
d2„ƒYƒ
Z5d3ej6j7f
d4„ƒYZ8d
S(5iÿÿÿÿN(
tlog(
t	jsonutils(
tencodeutils(
tstrutils(
tapi_version_request(
tversioned_method(
t	exception(
ti18n(
t
_(
tutils(
twsgisapplication/jsons&application/vnd.openstack.compute+jsontcreatetdeletetshowtupdatetPOSTtPUTs2.1tversioned_methodssOpenStack-API-VersionsX-OpenStack-Dmapi-API-Versionsopenstack.legacy_v2c
CstS(
N(
t_SUPPORTED_CONTENT_TYPES(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_supported_content_types=s
cCs(t|d
ƒr||
St
||
ƒSdS(Nt__getitem__(thasattrtgetattr(titemtitem_key((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytitem_getEs

tRequestcBs³eZ
dZd
„Zdd„
Zd„Zd„Zd„Zd„Zd„Z	d	„Z
d
„Zd„Zd„Z
d
„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(s@Add some OpenStack API-specific logic to the base webob.Request.c
OsNtt
|ƒj|
|Ž
i
id
6|_t|dƒsJtjƒ|_ndS(Ntdb_itemsR(tsuperRt__init__t_extension_dataRtapi_versiontAPIVersionRequestR(tselftargstkwargs((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyROs



tidcCsA|jd
j
|
iƒ}x!|D]}||t||ƒ<q WdS(s
Allow API methods to store objects from a DB query to be
        used by API extensions within the same API request.

        An instance of this class only lives for the lifetime of a
        single API request, so there's no need to implement full
        cache management.
        RN(Rt
setdefaultR(R!tkeytitemsRRR((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytcache_db_itemsUs


cCs|jd
|
S(s Allow an API extension to get previously stored objects within
        the same API request.

        Note that the object data will be slightly stale.
        R(
R(R!R&((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_db_itemsascCs|j|
ƒ
j
|ƒ
S(
s¡Allow an API extension to get a previously stored object
        within the same API request.

        Note that the object data will be slightly stale.
        (R)tget(R!R&R((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_db_itemiscCs|jd
|
dƒ
dS(Nt	instancestuuid(
R((R!R,((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytcache_db_instancesqs
cCs|jd
|
g
dƒ
dS(NR,R-(
R((R!tinstance((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytcache_db_instancets
c

Cs
|jd
ƒ
S(NR,(
R)(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_db_instancesws
cCs|jd
|
ƒS(NR,(
R+(R!t
instance_uuid((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_db_instancezs
cCs|jd
|
dƒ
dS(Ntflavorstflavorid(
R((R!R4((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytcache_db_flavors}s
cCs|jd
|
g
dƒ
dS(NR4R5(
R((R!tflavor((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytcache_db_flavor€s
c

Cs
|jd
ƒ
S(NR4(
R)(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_db_flavorsƒs
cCs|jd
|
ƒS(NR4(
R+(R!R5((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt
get_db_flavor†s
c
Cs¤d
|jkr™d}
|jjddƒ}t|ƒ
dkred|d}|tƒkre|}
qen|
sƒ|jjtƒƒ
}
n|
pŒd|jd
<n|jd
S(s.Determine the requested response content-type.sdmapi.best_content_typet
.i
sapplication/sapplication/jsonN(tenvirontNonetpathtrsplittlenRtacceptt
best_match(R!tcontent_typetpartst
possible_type((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytbest_match_content_type‰s




	

c
Cs[d
|jkrdS|j}
|
s/|
dkr3dS|
tƒkrWtjd|
ƒ
‚
n|
S(suDetermine content type of the request body.

        Does not do any body introspection, only checks header

        sContent-Types
text/plainRCN(theadersR=RCRRtInvalidContentType(R!RC((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_content_typeŸs
	

c

Cs#|js
d
S|jjtjƒƒ
S(sÆDetermine the best available language for the request.

        :returns: the best language match or None if the 'Accept-Language'
                  header was not available in the request.
        N(taccept_languageR=RBRtget_available_languages(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytbest_match_languageµs	

	
c
CsÜtj
|jd
ddtg
ƒ
}
|
dkrEtjtjƒ
|_n“|
dkrctj	ƒ|_nutj|
ƒ
|_|jj
tjƒtj	ƒƒsØtj
d|jjƒdtjƒjƒdtj	ƒjƒƒ‚
ndS(	s@Set API version request based on the request header information.tservice_typetcomputetlegacy_headerstlatesttreq_vertmin_vertmax_verN(tmicroversion_parsetget_versionRGt!LEGACY_API_VERSION_REQUEST_HEADERR=RR tDEFAULT_API_VERSIONRtmax_api_versiontmatchestmin_api_versionRtInvalidGlobalAPIVersiont
get_string(R!t
hdr_string((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytset_api_version_requestÀs"





	
	

	


c

Cst|j
t<dS(
N(tTrueR<t
ENV_LEGACY_V2(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt
set_legacy_v2Ûs
c

Cs|jj
ttƒS(
N(R<R*R`tFalse(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytis_legacy_v2Þs
(t__name__t
__module__t__doc__RR(R)R+R.R0R1R3R6R8R9R:RFRIRLR^RaRc(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRLs&
																tActionDispatcherc
Bs eZ
dZd
„Zd„ZRS(s6Maps method name to local methods through action name.c
Os:|jd
dƒ}t
|t|ƒ
|jƒ}||
|ŽS(sFind and call local method.tactiontdefault(tpopRtstrRi(R!R"R#Rht
action_method((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytdispatchås

c
Cs
tƒ‚
dS(
N(
tNotImplementedError(R!tdata((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRiës
(RdReRfRmRi(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRgâs
	tJSONDeserializercBs&eZ
d„Zd
d„
Zd„ZRS(cCsGytj
|
ƒ
SWn/tk
rB


td
ƒ
}tjd|ƒ
‚
n
XdS(Nscannot understand JSONtreason(R
tloadst
ValueErrorRRtMalformedRequestBody(R!t
datastringtmsg((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt
_from_jsonñs






RicCs|j|
d
|ƒ

S(NRh(
Rm(R!RuRh((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytdeserializeøs
cCsi
|j|
ƒ
d
6S(Ntbody(
Rw(R!Ru((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRiûs
(RdReRwRxRi(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRpïs	tJSONDictSerializercBs#eZ
dZd
d„
Zd„ZRS(s(Default JSON request body serialization.RicCs|j|
d
|ƒ

S(NRh(
Rm(R!RoRh((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt	serialize
s
cCstj
tj|
ƒ
ƒ
S(
N(tsixt	text_typeR
tdumps(R!Ro((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRi
s
(RdReRfR{Ri(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRzÿs
c
s‡f
d
†}
|
S(sÆAttaches response code to a method.

    This decorator associates a response code with a method.  Note
    that the function attributes are directly manipulated; the method
    is not wrapped.
    c

s
ˆ|_|S(
N(
t	wsgi_code(
tfunc(
tcode(s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt	decorator
s
	
((RR‚((
Rs</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytresponse	
stResponseObjectcBs_eZ
dZddd
„Zd„Zd„Zd„Zd„Ze	d„ƒ
Z
e	d„ƒ
ZRS(	sìBundles a response object

    Object that app methods may return in order to allow its response
    to be modified by extensions in the code. Its use is optional (and
    should only be used if you really know what you are doing).
    cCs:|
|_d
|_
||_|p$i|_tƒ|_dS(sBuilds a response object.iÈN(tobjt
_default_codet_codet_headersRzt
serializer(R!R…RRG((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
s
	
	
	

cCs|j|
j
ƒS(
s'Retrieves a header with the given name.(Rˆtlower(R!R&((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR(
scCs||j|
j
ƒ<d
S(s5Sets a header with the given name to the given value.N(RˆRŠ(R!R&tvalue((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt__setitem__-
scCs|j|
j
ƒ=d
S(s'Deletes the header with the given name.N(RˆRŠ(R!R&((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt__delitem__2
scCsÙ|j}d}|jdk	r3|j|jƒ
}ntjd
|ƒ
}|jjdƒ
rwtj	|jdƒ
|jd<n|j
|_x9t|j
jƒƒ
D]"\}}tj	|ƒ
|j|<q™Wtj	|ƒ
|jd<|S(sSerializes the wrapped object.

        Utility method for serializing the wrapped object.  Returns a
        webob.Response object.
        RysContent-LengthsContent-TypeN(R‰R=R…R{twebobtResponseRGR*R	tutf8Rt
status_inttlistRˆR'(R!trequestRCR‰RyRƒthdrR‹((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR{7
s	






"


c


Cs|jp|j
S(
sRetrieve the response status.(R‡R†(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRP
sc


Cs
|jj
ƒS(
sRetrieve the headers.(Rˆtcopy(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRGV
sN(RdReRfR=RRRŒRR{tpropertyRRG(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR„
s					c
CsŒytj
|ƒ
}
Wn/tk
rD


td
ƒ
}tjd|ƒ
‚
n
Xt|
ƒ
dkrxtdƒ
}tjd|ƒ
‚
nt|
jƒƒ
dS(sqDetermine action to invoke.

    This looks inside the json body and fetches out the action method
    name.
    scannot understand JSONRqi
stoo many body keysi(	R
RrRsRRRtR@R’tkeys(RytdecodedRv((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytaction_peek]
s






tResourceExceptionHandlerc
Bs eZ
dZd
„Zd„ZRS(sìContext manager to handle Resource exceptions.

    Used when processing exceptions generated by API implementation
    methods (or their extensions).  Converts most exceptions to Fault
    exceptions, with the appropriate logging.
    c


CsdS(
N(
R=(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt	__enter__{
s
cCs@
|s
tSt
|tjƒr@ttjjd
|jƒƒ
ƒ
‚
nüt
|tj	ƒrX‚nät
|tj
ƒr”ttjd|jd
|jƒƒƒ
‚
n¨t
|t
ƒrà|
||f}tjd|d|ƒ

ttjjƒƒ
‚
n\t
|tƒr
tjd|ƒ
|‚
n4t
|tjjƒr<
tjd|ƒ
t|ƒ
‚
ntS(NtexplanationRsException handling resource: %stexc_infosFault thrown: %ssHTTP exception thrown: %s(R_t
isinstanceRt	ForbiddentFaultRŽtexct
HTTPForbiddentformat_messagetVersionNotFoundForAPIMethodtInvalidtConvertedExceptionRt	TypeErrortLOGterrortHTTPBadRequesttinfot
HTTPExceptionRb(R!tex_typetex_valuetex_tracebackR((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt__exit__~
s.








	








	


(RdReRfR›R°(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRšs
s	tResourcecBs§eZ
dZeZd
„Zd„Zd„Zd„Zd„Z	d„Z
d„Zd„Ze
jjd	eƒ
d
„ƒ
Zd„Zd„Zd
„Zd„Zd„ZRS(s·WSGI app that handles (de)serialization and controller dispatch.

    WSGI app that reads routing information supplied by RoutesMiddleware
    and calls the requested action method upon its controller.  All
    controller action methods must accept a 'req' argument, which is the
    incoming wsgi.Request. If the operation is a PUT or POST, the controller
    method must also accept a 'body' argument (the deserialized request body).
    They may raise a webob.exc exception or return a dict, which will be
    serialized by requested content type.

    Exceptions derived from webob.exc.HTTPException will be automatically
    wrapped in Fault() to provide API friendly error responses.

    cCsP|
|_t
d
tƒ
|_i|_|
r:|j|
ƒ

ni|_i|_dS(sm:param controller: object that implement methods created by routes
                              lib
        tjsonN(t
controllertdictRztdefault_serializerstwsgi_actionstregister_actionstwsgi_extensionstwsgi_action_extensions(R!R³((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR¬
s		

	
cCsOt|
d
iƒ}x6t
|jƒƒ
D]"\}}t|
|ƒ|j|<q%WdS(s0Registers controller actions with this resource.R¶N(RR’R'R¶(R!R³tactionsR&tmethod_name((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR·¾
s

cCs«t|
d
gƒ}x’|D]Š\}}t|
|ƒ}|rp||j
krYg|j
|<n|j
|j|ƒ

q||jkrg|j|<n|j|j|ƒ

qWdS(s3Registers controller extensions with this resource.R¸N(RR¹tappendR¸(R!R³t
extensionsR»taction_namet	extension((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytregister_extensionsÅ
s




cCsšt|j
d
ƒr"|j
j|
ƒ
Sy|
ddjƒ}Wntttfk
rW


iSXy|d=Wntk
rv


n
Xy|d=Wntk
r•


n
X|S(s+Parse dictionary created by routes library.tget_action_argsswsgiorg.routing_argsi
R³tformat(RR³RÁR•tKeyErrort
IndexErrortAttributeError(R!trequest_environmentR"((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRÁØ
s











cCs|
jƒ}||
j
fS(
N(RIRy(R!R“RC((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytget_bodyñ
s
cCstƒj
|
ƒ
S(
N(RpRx(R!Ry((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRxö
s
cCsƒx||
D]t}d}y,t
ƒ
|d
|d||}WdQXWn/tjk
rX


qntk
rp
}
|}n
X|r|SqWdS(Ntreqtresp_obj(R=RšRR¤R (R!R½RÉR“taction_argstextRƒtex((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytprocess_extensionsù
s










cCs
|
jt
kS(
N(tmethodt_METHODS_WITH_BODY(R!R“((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt_should_have_bodys
tRequestClassc	Cs
|jr€y|
j
ƒ
Wq€tjk
rK
}
ttjjd
|jƒƒ
ƒ
Stj	k
r|
}
ttjj
d
|jƒƒ
ƒ
SXn|j|
jƒ
}|j
ddƒ}y%|j|
ƒ
\}}|
jƒ}Wn6tjk
r




tdƒ
}ttjjd
|ƒ
ƒ
SX|j|
|||||ƒS(s@WSGI method that controls (de)serialization and method dispatch.RœRhsUnsupported Content-TypeN(tsupport_api_request_versionR^RtInvalidAPIVersionStringR RŽR¡RªR£R[tHTTPNotAcceptableRÁR<RjR=RÇRFRHRtHTTPUnsupportedMediaTypet_process_stack(	R!R“t
eRÊRhRCRyRARv((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt__call__s&	













cCsóy"|j|
|||ƒ\}}Wn›t
tfk
rK


ttjjƒƒ
Stk
rŠ
}	
td
ƒ
|	j	d}
ttjj
d|
ƒ
ƒ
Stjk
r¿


tdƒ
}
ttjj
d|
ƒ
ƒ
SX|r
tdƒ
i|d6t
j|dƒd6t|ƒ
d	6}
tjtj|
ƒ
ƒ

ntjd
i
t|ƒ
d	6ƒ
y|j||
ƒ}Wn6tjk
r



tdƒ
}
ttjj
d|
ƒ
ƒ
SX|j|ƒ

|jddƒ}|
jjdƒ
}
|
r|r||
jkrtd
ƒ
i|d6|
jd6}
ttjj
d|
ƒ
ƒ
Sd}y)tƒ
|j||
|ƒ}WdQXWntk
rR
}	
|	}n
X|sd}t|ƒ
tks}|dkrŒt|ƒ
}nt |tƒr¤|}n|}|rét!|dƒrÎ|j"|_#n|j$|||
|ƒ}n|r|r|j%|
|ƒ}qnt!|dƒrïxdt&|j'j(ƒƒ
D]M\}}t
j)rat*j+|ƒ
|j'|<q3t,j-t*j+|ƒ
ƒ
|j'|<q3W|
j.j/ƒsïd|
j.j0ƒ|j't1<|
j.j0ƒ|j't2<|j'j3dt1ƒ
|j'j3dt2ƒ
qïn|S(sImplement the processing stack.sThere is no such action: %siRœsMalformed request bodys>Action: '%(action)s', calling method: %(meth)s, body: %(body)sRhsutf-8RytmethsCalling method '%(meth)s't
project_ids
dmapi.contextstMalformed request URL: URL's project_id '%(project_id)s' doesn't match Context's project_id '%(context_project_id)s'tcontext_project_idNRRGscompute tVary(4t
get_methodRÅR§R RŽR¡tHTTPNotFoundRÃRR"RªRRtR|R}RkR¨tdebugRt
mask_passwordt_get_request_contentRRjR=R<R*RÚRšRmttypeR´R„RžRRR†RÍR{R’RGR'tPY2R	RRtsafe_decodeRtis_nullR\tAPI_VERSION_REQUEST_HEADERRVtadd(R!R“RhRÊRCRyRARÙR½RÌRvtcontentsRÚtcontextRƒt
action_resultRÉR”tval((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRÖ9s€










	




	








	













	




"
	


cCsYi}|j|ƒ
rU|j
d
ks3|j
dkrCi
dd6}qU|j|
ƒ
}n|S(NiRy(RÐtcontent_lengthR=Rx(R!RyR“Rè((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRášs



cCs(|j|
|||ƒ\}}||fS(
N(
t_get_method(R!R“RhRCRyRÙR½((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRݤs

	



cCsÂy1|jst
||ƒ}nt
|j|ƒ}Wn4tk
rg


|js^|td
g
kr‚qnX||jj|gƒfS|d
krœt|ƒ
}n|}|j||jj|gƒfS(s6Look up the action-specific method and its extensions.Rh(	R³RRÅR¶t_ROUTES_METHODSR¸R*R™R¹(R!R“RhRCRyRÙR¾((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRí«s
	









cCs?y|
d
||
SWn$tj
k
r:


ttjjƒƒ
SXdS(s.Dispatch a call to the action-specific method.RÈN(RR¤R RŽR¡RÞ(R!RÎR“RÊ((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRmÄs

(RdReRfR_RÒRR·RÀRÁRÇRxRÍRÐRŽtdectwsgifyRRØRÖRáRÝRíRm(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR±›
s 
								%	a	
		c
s‡f
d
†}
|
S(sÞMark a function as an action.

    The given name will be taken as the action key in the body.

    This is also overloaded to allow extensions to provide
    non-extending definitions of create and delete operations.
    c

s
ˆ|_|S(
N(
twsgi_action(
R€(
tname(s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR‚Ùs
	
((RòR‚((
Ròs</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRhÐs	cs#‡f
d
†}|r||ŒS|S(sèIndicate a function extends an operation.

    Can be used as either::

        @extends
        def index(...):
            pass

    or as::

        @extends(action='resize')
        def _action_resize(...):
            pass
    c

s|jˆj
d
ƒ
f|_|S(NRh(RdR*twsgi_extends(
R€(
R#(s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR‚ïs
((R"R#R‚((
R#s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytextendsßs

c
s‡f
d
†}
|
S(s
Decorator for v2.1 API methods which specifies expected exceptions.

    Specify which exceptions may occur when an API method is called. If an
    unexpected exception occurs then return a 500 instead and ask the user
    of the API to file a bug report.
    c
s%tj
ˆƒ
‡
‡fd
†ƒ
}
|
S(Ncsùyˆ
||
ŽSWnátk
rô
}
t
|tjjƒrqt
ˆtƒrSˆf
}nˆ}|j|kr¹‚q¹nHt
|tjƒr‰‚n0t
|tj	ƒr¡‚nt
|tj
ƒr¹‚ntjd
ƒ

tdƒ
t
|ƒ
}tjjd|ƒ
‚
n
XdS(Ns"Unexpected exception in API methodsrUnexpected API Error. Please report this at http://support.trilio.io/ and attach the Dmapi API log if possible.
%sRœ(t	ExceptionRžRŽR¡tWSGIHTTPExceptiontintRRRŸtValidationErrortUnauthorizedR¨RRâtHTTPInternalServerError(R"R#R¡tt_errorsRv(terrorst
f(s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytwrappeds&






	




	

(t	functoolstwraps(RýRþ(
Rü(
Rýs</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR‚s
!%((RüR‚((
Rüs</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytexpected_errorsüs(tControllerMetaclassc
BseZ
dZd
„ZRS(s…Controller metaclass.

    This metaclass automates the task of assembling a dictionary
    mapping action keys to method names.
    c
Cs>
i}g}d}xg|D]_}|j
t|d
iƒƒ

|jdkrt|jkrxt|tƒ}t|tƒ
qxqqWxyt|jƒƒ
D]e\}}	t	|	ƒ
s­qnt|	ddƒrÏ|||	j
<qt|	ddƒr|j|	jƒ

qqW||d
<||d<|r
||t<nt
t|ƒj||
||ƒS(s.Adds the wsgi_actions dictionary to the class.R¶t
ControllerRñRóR¸N(R=RRRdtVER_METHOD_ATTRt__dict__tdelattrR’R'tcallableRñR¼RóRR
t__new__(
tmcsRòtbasestcls_dictRºR½RtbaseR&R‹((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
4s,


















(RdReRfR
(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
-sR
cBsYeZ
dZdZdd
„
Zd„Zedd„
ƒ
Ze	d„ƒ
Z
e	d„ƒ
ZRS(sDefault controller.cCs:|
r|
|_n$|j
r-|j
ƒ|_n	d
|_d
S(s3Initialize controller with a view builder instance.N(t
_view_buildert_view_builder_classR=(R!tview_builder((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRbs


	
cs~‡‡
‡fd
†‰ytj
ˆ
tƒ}Wntk
rK


tj
ˆ
ˆƒSX|rnˆtj
ˆ
tƒkrnˆStj
ˆ
ˆƒS(Ncs¡t|ƒ
d
kr"|
dj
}n
|d
j
}ˆ
jˆ}xL|D]D}|j|j|jƒrCtjˆ|jƒ
|jˆ
||
Ž
SqCWt	j
d|ƒ
‚
dS(sS
Look for the method which matches the name supplied and version
            constraints and calls it with the supplied arguments.

            @return: Returns the result of the method called
            @raises: VersionNotFoundForAPIMethod if there is no method which
                 matches the name and version constraints
            iRÈtversionN(R@RRRYt
start_versiontend_versionRÿtupdate_wrapperR€RR¤(R"R#tvert	func_listR€(R&R!tversion_select(s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
ms






(tobjectt__getattribute__R
RÅ(R!R&tversion_meth_dict((R&R!R
s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
ks




cs‡‡
‡fd
†}|S(sM
Decorator for versioning api methods.

        Add the decorator to any method which takes a request object
        as the first parameter and belongs to a class which inherits from
        wsgi.Controller.

        @min_ver: string representing minimum version
        @max_ver: optional string representing maximum version
        c
s

tj
ˆƒ
}
ˆ
r'tj
ˆ
ƒ
}ntj
ƒ}|j}tj||
||ƒ}tˆtiƒ}|stˆt|ƒ
n|j|gƒ}|s¤|||<n|j	|ƒ

t
j|ƒ
}|rðtj
d
|jd|jd|jƒ‚
n|jdd„dtƒ
|S(NRòRRRSR&c


Ss|jS(
N(
R
(
Rý((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt<lambda>Æstreverse(RR RdRtVersionedMethodRR
tsetattrR*R¼R
tcheck_for_versions_intersectionRtApiVersionsIntersectRòR
R
tsortR_(Rýtobj_min_vertobj_max_vert	func_nametnew_funct	func_dictR
tis_intersect(tclsRSRR(s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR‚¤s.


	









	
	
	
	
((R'
RRRSR‚((R'
RSRRs</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR˜s&cCs-|o|
|kstSd
„}|||
ƒ
S(Nc

Ss.y|jdƒ

tSWntk
r)


tSXdS(
N(R*R=R_RÅRb(
t
d((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytis_dictÑs







(
Rb(Rytentity_nameR)
((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt
is_valid_bodyÌs
	c
Cs›g}
d
}x@|D]8}|
j|j
d|fƒ

|
j|jd|fƒ

qWd„}|
jd|ƒ

x,|
D]$}||d7}|dkrotSqoWtS(s
Determines whether function list contains version intervals
        intersections or not. General algorithm:

        https://en.wikipedia.org/wiki/Intersection_algorithm

        :param func_list: list of VersionedMethod objects
        :return: boolean
        ii
iÿÿÿÿc

Ss|d
S(Ni((
t
x((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pytcompareës
R&(R¼R
R
R 
R_Rb(R
tpairstcounterRýR-
t
p((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
Ús




	


N(RdReRfR=R
RR
tclassmethodRtstaticmethodR+
R
(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR
\s		-
3R cBs‘eZ
dZid
d6dd6dd6dd6d	d
6dd6d
d6dd6d
d6dd6dd6Zd„Zejjdeƒ
d„ƒ
Z	d„Z
RS(s>Wrap webob.exc.HTTPException to provide API friendly response.t
badRequesti
tunauthorizedi‘
t	forbiddeni“
titemNotFoundi”
t	badMethodi•
tconflictingRequesti™
t	overLimiti
tbadMediaTypeiŸ
i­
tnotImplementediõ
tserviceUnavailablei÷
cCsX|
|_x<t
|jjjƒƒ
D]"\}}t|ƒ
|jj|<q"W|
j|_d
S(s1Create a Fault for the given webob.exc.exception.N(twrapped_excR’RGR'RkR‘(R!RR&R‹((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR	s	
%

RÑcCsy
|
jƒ}|j
j}|jj|d
ƒ}|j
j}tjdi|d6|d6ƒ
tj	||ƒ}i
i|d6|d6|6}|dksœ|dkrÎ|j
j
jddƒ}|rÎ|||d	<qÎn|
jj
ƒsB
d
|
jjƒ|j
j
t<|
jjƒ|j
j
t<|j
j
jdtƒ
|j
j
jdtƒ
nd|j
_d
|j
_tƒj|ƒ
|j
_|j
S(s?Generate a WSGI response based on the exception passed to ctor.tcomputeFaults+Returning %(code)s to user: %(explanation)sRRœtmessagei
i­
sRetry-Aftert
retryAfterscompute RÜsapplication/jsonsUTF-8N(RLR=
R‘t_fault_namesR*RœR¨RßRt	translateRGR=RRåR\RæRVRçRCtcharsetRzR{ttext(R!RÈtuser_localeRt
fault_nameRœt
fault_datatretry((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRØs2


	














c


Cs
|jj
ƒS(
N(R=
t__str__(
R!((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyRI
5s
(RdReRfRA
RRŽRïRðRRØRI
(((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyR ùs 












	%(9RÿRTtoslo_logRtloggingtoslo_serializationR
t
oslo_utilsRRR|RŽtdmapi.api.openstackRRRtdmapiRRt
dmapi.i18nRR	R
t	getLoggerRdR¨RRîRÏRWR
RæRVR`RRRR
RgRpRzRƒR„R™RštApplicationR±RhRôR

RâR
t
add_metaclassR
R¡R¬R (((s</usr/lib/python2.7/dist-packages/dmapi/api/openstack/wsgi.pyt<module>s^












	


	
	
		–

	F	(ÿ6			1/
œ