!dZddlmZddlmZddlmZddlZddlZddlmZddlm Z ddlm Z dd l m Z dd l mZdd lmZd Zd ZdZdZdZdZdZdZdZdZdZddZ ddZy)a4Generalized Apigee Management API request handler. The Apigee Management APIs were designed before One Platform, and include some design decisions incompatible with apitools (see b/151099218). So the gcloud apigee surface must make its own HTTPS requests instead of relying on an apitools-generated client. )absolute_import)division)unicode_literalsN)defaults)errors) resource_args) properties)requests)urllibzapigee.googleapis.comz%s-apigee.googleapis.comerrormessagectj}|D]T}tj|}|jdz}||vs||t j |j||||<V|S)aLReturns an OrderedDict uniquely identifying the resource to be accessed. Args: identifiers: a collection that maps entity type names to identifiers. entity_path: a list of entity type names from least to most specific. Raises: MissingIdentifierError: an entry in entity_path is missing from `identifiers`. Id) collections OrderedDictrENTITIESpluralrMissingIdentifierErrorsingular) identifiers entity_pathresource_identifier entity_nameentityid_keys 0lib/googlecloudsdk/command_lib/apigee/request.py_ResourceIdentifierr,sz$//1 k  # #K 0F ]]T !F [ K$7$?  ) )&// ::"-f"5 ! ctjj||||d}|j}|j}|j }|||fS)zHReturns HTTP status, reason, and response body for a given HTTP request.T)dataheadersstream)r GetSessionrequest status_codereasoncontent)urlmethodbodyr!responsestatusr&r s r _Communicater-BsW  " * * cgd+<(   & ??&   $  rc^t|tst|dr|j}|S)zReturns decoded string. Args: response: the raw string or bytes of JSON data Raises: ValueError: failure to load/decode JSON data decode) isinstancestrhasattrr/)r+s r_DecodeResponser3Ls( Hc "wx'B H /rc|xs|dS)z)Gets resource type from the inputed data.)entity_collectionrs r_GetResourceTyper8\s  -k"o-rctj|jDcgc]\}}|j|fc}}Scc}}w)z*Builds error identifier from inputed data.)rritemsr)rkeyvalues r_BuildErrorIdentifierr=asH  .A.G.G.I".I Us||U.I" "sA ctj|}t|vr6t|ttrt |tvr|tt Sy)zHExtracts error message from response, returns None if message not found.N)jsonloads ERROR_FIELDr0dict MESSAGE_FIELD)r+ json_responses r_ExtractErrorMessagerEhsJ**X&-M!jK  ' {!;;  %m 44 rcBtj|}t|S)z2Returns the Apigee host based on the organization.)rGetOrganizationLocation_GetApigeeHostByLocation) organizationlocations r_GetApigeeHostByOrganizationrKrs  - -l ;( !( ++rc2||dk(s|stSt|zS)z.Returns the Apigee host based on the location.global)APIGEE_GLOBAL_HOSTAPIGEE_LEP_HOST)rJs rrHrHxs" X-X  8 ##rc i} |r|| d<|r|| d<t||} dg} | jD]3\} }| | jtjj |gz } 5|rKt j|j}| jtjj ||rtjj|nd}tjjjj}| rd}t| }nY|r8tjj!|}|j"}|j$}nd}|j'dd}t)|}dj+| }|r|d d k(r ||z }d }|r|}tjj-|||d|df}t/|||| \}}}|d k\rut1||}|d k(rt2j4}n%|dvrt2j6}nt2j8}t;| } t=t?|}||||||||# t?|}tCjD|}|S|S#t@$rd}YBwxYw#t@$r4}t1||}t;| }t3jF||||d}~wwxYw)aMakes a request to the Apigee API and returns the response. Args: identifiers: a collection that maps entity type names to identifiers. entity_path: a list of entity type names from least to most specific. entity_collection: if provided, the final entity type; the request will not be specific as to which entity of that type is being referenced. method: an HTTP method string specifying what to do with the accessed entity. If the method begins with a colon, it will be interpreted as a Cloud custom method (https://cloud.google.com/apis/design/custom_methods) and appended to the request URL with the POST HTTP method. query_params: any extra query parameters to be sent in the request. accept_mimetype: the mimetype to expect in the response body. If not provided, the response will be parsed as JSON. body: data to send in the request body. body_mimetype: the mimetype of the body data, if not JSON. method_override: the HTTP method to use for the request, when method starts with a colon. location: the location of the apigee organization. Returns: an object containing the API's response. If accept_mimetype was set, this will be raw bytes. Otherwise, it will be a parsed JSON object. Raises: MissingIdentifierError: an entry in entity_path is missing from `identifiers`. RequestError: if the request itself fails. z Content-TypeAcceptv1httpsorganizationsIdN/r:POSTii)ii) user_help)$rr:rr parsequoterrappend urlencoder VALUESapi_endpoint_overridesapigeeGetrHurlparseschemenetlocgetrKjoin urlunparser-r8rEntityNotFoundErrorUnauthorizedRequestError RequestErrorr=rEr3 ValueErrorr?r@ResponseNotJSONError) rrr7r) query_paramsaccept_mimetyper* body_mimetypemethod_overriderJr!rurl_path_elementsr;r<collection_name query_stringendpoint_overriderchostendpointrIurl_pathr(r,r&r+ resource_typeexception_classerror_identifierrYr s rResponseToApiRequestr{sN ' +GN'GH+KEf'--/jc5#**fll&8&8&?@@0#,,->?FFOV\\//@A9E'' 52, ''>>EEIIK F #H -D||$$%67H __F ??D F??#4d;L ' 5D XX' (( q S  H Ff x\2 NO#)#vtWE&&( s]$%6 DM }22o : 77o++o,-@A&x'@Ai -)96 (i AA2 *hH%h //! i 2&'8+Fm./BC  ' '}>N(0 222s*&I/ J/ I=<I= J= /J88J=)N)NGETNNNzapplication/jsonNN)__doc__ __future__rrrrr?!googlecloudsdk.command_lib.apigeerrrgooglecloudsdk.corer googlecloudsdk.core.credentialsr six.movesr rNrOrArCrr-r3r8r=rErKrHr{r6rrrs'' 64;*4-,  ,  . , $,0 %&*)-"'9)-"&lr