E0j;ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZmZddlmZmZdd lmZdd lmZdd lmZd Zd ZdZdZdZGdde ZdS)N)default_backend)hashes)padding)load_pem_private_key) quote_plusquote)hash_sm3Sm3)Client) STREAM_CLASS)TeaModelct||St|trt|dSt|S)Nutf-8encoding) isinstancebytesstr)vals h/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/alibabacloud_openapi_util/client.pyto_strrs< { #u3))))3xxc|dsd|z}|dsd|z}t|dt}||t jtjS)Ns-----BEGIN RSA PRIVATE KEY-----s"-----BEGIN RSA PRIVATE KEY----- %ss-----END RSA PRIVATE KEY-----s %s -----END RSA PRIVATE KEY-----)passwordbackend) startswithendswithrrsignrPKCS1v15rSHA256) plaintextsecretkeys rrsa_signr%s   ? @ @A7&@ ??; < <?5> vo>O>O P P PC 88Iw/116=?? C CCrc\|d}|d}|dkr2tj||tjS|dkr-tj||t S|dkrt||SdS)NrACS3-HMAC-SHA256 ACS3-HMAC-SM3ACS3-RSA-SHA256)encodehmacnewhashlibsha256digestr r%)r#source sign_types rsignature_methodr2)s ]]7 # #F ]]7 # #F&&&x77>>@@@ o % %x,,33555 ' ' '''' ( 'rc:|t|dkrdSg}|D]\}}||||d}|D]/}t ||dd}||d}n|d|d}||z }0|ddS) Nr~rsafer&=)lenitemsappendsortr)query canon_keyskv query_stringr$valuess rget_canonical_query_stringrF4s }E arJ !!1 =   a OOLeCjsW=== = AA!!!!!A  rcg}i}|D]\}}|||vr_||t|g||<|||t||d}|D]7}dt||}|d|d}||z }8|d|fS)Nr4,: ;)r<lowerr=rstripr>joinsorted) headersr@ tmp_headersrArBcanonical_headersr$ header_entryrEs rget_canonicalized_headersrTHs5JK AA1 =wwyy **!!!'')),,,*0))//*;*;)< AGGII&&AGGII&--fQiioo.?.?@@@OOxx{3'7 8 899  % %\ % % %Q chhz22 22rceZdZdZedZedZedZedZedZ edZ edZ ed Z ed Z ed Zed Zed ZedZedZedZedZedZedZedZedZedZedZdS)r z" This is for OpenApi Util ct|}||dS)z Convert all params of body other than type of readable into content @param body: source Model @param content: target Model @return: void N)r _except_streamto_mapfrom_map)bodycontentbody_maps rconvertzClient.convertas9((77"""""rct|tr;i}|D]"\}}t|||<#|St|t rjg}|D]c}|2t|}|||6|t|d|St|trdS|SN)rdictr<r rWlistr=r )rresultrArBiitems rrWzClient._except_streamos c4  F  5 51"11!44q M T " " F < <=!0033D' d+++MM&"7"7":":;;;;M \ * * 4 rcg}|D],}|dr||-t|}d}|D]}||d||dz }|S)Nzx-acs-r4rIrJ)rr=rO)rPr@rA canon_headers r_get_canonicalized_headersz!Client._get_canonicalized_headerss  % %A||H%% %!!!$$$J''   8 8A GAJJJ7 7LLrct|dkr|Sd|z}tt|}|D]/}||%||dkrd|z}n|d||d}||z }0|ddS)Nrz%s?r4z%s&r9r8r:)r;rOra)pathnamer?resource query_listr$rEs r_get_canonicalized_resourcez"Client._get_canonicalized_resources u::??O8#DKK((   CSz%:## AA$'CCs4AA }rc @|j|j|j|jf\}}}}|ddn|d}|ddn|d}|ddn|d}|ddn|d}|d|d|d|d|d } t |} t ||} | | z| z} | S)z Get the string to be signed according to request @param request: which contains signed messages @return: the signed string acceptNr4z content-md5z content-typedaterJ)methodrirPr?getr rgrl) requestrprirPr?rn content_md5 content_typeroheader canon_headerscanon_resourcesign_strs rget_string_to_signzClient.get_string_to_signs#,3>7;KW_^e^k+k('5{{8,,4'++h:O:O#KK 66>bbGKKP]D^D^ $[[88@rrgkkR`FaFa [[((0rrgkk&6I6I+166666;;; VZVZVZ[99'BB ;;HeLLM)N:rctj|d|dtj}t j|d}|S)z Get signature according to stringToSign, secret @type string_to_sign: str @param string_to_sign: the signed string @type secret: str @param secret: accesskey secret @return: the signature r) r+r,r*r-sha1r/base64 b64encodedecode)string_to_signr#hash_val signatures rget_roasignaturezClient.get_roasignaturese8FMM'22N4I4I'4R4RT[T`aahhjj$X..55g>> rc|dSt|tr=|D]&\}}t|d|||'dSt|t rO|D]&\}}t|d|||'dSt|ttfr;t|D])\}}t|d|dz||*dS| dr |dd}t|trt|d||<dSt|tst|||<dSdS)N.r rr)rr`r<r _object_handlerrrXratuple enumeraterrrr )r$rDoutrArBindexrs rrzClient._object_handlers = F eT " " &  C C1&&###qq'91cBBBB C C x ( ( & ,,.. C C1&&###qq'91cBBBB C C e} - - &'.. M M s&&###uqyy'A3LLLL M M~~c"" !""g%'' &uw777C|44 &u::C & &rci}|rtd||tjtj|S)z Parse filter into a form string @type filter: dict @param filter: object @return: the string r4)r rUtilto_form_stringanyify_map_value)filterrbs rto_formzClient.to_formsL  7  " "2vv 6 6 6"  !& ) )   rcdtjdS)zF Get timestamp @return: the timestamp string z%Y-%m-%dT%H:%M:%SZ)datetimeutcnowstrftimerr get_timestampzClient.get_timestamps( ''))223GHHHrcFi}|rtd|||S)z Parse filter into a object which's type is map[string]string @type filter: dict @param filter: query param @return: the object r4)r r)rout_dicts rr?z Client.querys.  9  " "2vx 8 8 8rc H|}t|}|d}|D];}||1|dt |dddt ||ddz }<|dt |d ddd}t jt|dzd t|d tj }| } ttj| d } | S) aU Get signature according to signedParams, method and secret @type signed_params: dict @param signed_params: params which need to be signed @type method: str @param method: http method e.g. GET @type secret: str @param secret: AccessKeySecret @return: the signature r4Nr8r5rr6r9z&%2F&r r) digestmod)copyrakeysr>rrr+r,rr-r{r/rr|r}) signed_paramsrpr#queriesrcanonicalized_query_stringrAr digest_maker hash_bytes signed_strs rget_rpcsignaturezClient.get_rpcsignaturesO  $$&&GLLNN## %'" a aAqz%*/a%g2V2V2V/a/a16wqzV]1^1^1^/a/aa*#qq4Nqrr4RY\gn)o)o)oqqxfslW E E E %nw G G G*1,888 "((** )*55HHH rc|dS|dkrt||iS|dkr(dtt|S|dkr(dtt|S|dkr(d tt|S|d kr,t jt|SdS) a Parse array into a string with specified style @type array: any @param array: the array @type prefix: str @param prefix: the prefix string @param style: specified style e.g. repeatList @return: the string Nr4 repeatListsimplerHspaceDelimited pipeDelimited|json)r _flat_repeat_listrNmaprr to_jsonstring_parse_to_dict)arrayprefixstyles r$array_to_string_with_specified_stylez+Client.array_to_string_with_specified_style*s =2 L ++VUO<< < h  88CUOO,, , & & &88CUOO,, , o % %88CUOO,, , f__%f&;&;E&B&BCC C2rci}|rtd||g}t|}|D]E}t|d}t||d}||dz|zFd|S)Nr4rrr9z&&)r rrOrr=rN)dicr?lqrcrArBs rrzClient._flat_repeat_listIs  3  " "2sE 2 2 2  5MM " "A1w///A58g666A HHQWq[ ! ! ! !yy||rc t|}tj|S#t$rYdSwxYw)z) Transform input as map. N)r rrdeepcopy TypeError)inprbs r parse_to_mapzClient.parse_to_mapWsL  **3//F=(( (    FF s -0 >>cNt|trci}|D]J\}}t|tttfrt |||<E|||<K|St|trng}|D]g}t|tttfr.|t |R||h|St|tr|SdSr_) rr`r<rarr rr=rX)rrbrArBrcs rrzClient._parse_to_dictbs c4  F  " "1a$h!788" & 5 5a 8 8F1II !F1IIM T " " F % %a$h!788%MM&"7"7":":;;;;MM!$$$$M X & & ::<<   rc|dkr:|d}|dxxdz cc<d|}|r|dkrdS|S)aX If endpointType is internal, use internal endpoint If serverUse is true and endpointType is accelerate, use accelerate endpoint Default return endpoint @param server_use whether use accelerate endpoint @param endpoint_type value must be internal or accelerate @return the final endpoint internalrrz -internal acceleratezoss-accelerate.aliyuncs.com)splitrN)endpoint server_use endpoint_type str_splits r get_endpointzClient.get_endpointwsd J & & s++I aLLLK 'LLLxx **H  1-<7700rc|dks|dkr&tj|S|dkrt|SdS)Nr'r)r()r-r.r/r )rawr1s rhashz Client.hashsT * * *i;L.L.L>#&&--// / / ) )C== * )rcX|r'tj|dSdS)Nr)binasciib2a_hexr~)rs r hex_encodezClient.hex_encodes3  9#C((//88 8 9 9rc |jr|jnd}t|j}t|j\}}|jd|d|d|d|d| } |dt t | d|} t t|| |} |d|d|d| } | S)N/rJrz Credential=z,SignedHeaders=z ,Signature=) rirFr?rTrPrpr rrr*r2) rrr1payloadakr# canonical_uricanonicalized_querycanonicalized_headerssigned_headerscanonical_request str_to_signrauths rget_authorizationzClient.get_authorizations ,3,<E((# 8GG0I'/0Z0Z-~&~)),))2)) 5)) . )) ' ))#ttf&7&7 DUD\D\]dDeDegp8q8q&r&rtt %%&6v{I&V&VWW bbbbNbbW`bb rc&t|ddS)Nz/~rr6r)paths rget_encode_pathzClient.get_encode_pathsTw7777rc&t|ddS)Nr5rr6r)params rget_encode_paramzClient.get_encode_paramsUw7777rc*||St|tr6g}|D]/}|t|0|St|t r|}i}|D]\}}t|trgt|t sRi}|D]5\}}t||dt|d|<6|||<t|||<|St|trNi}|D]5\}}t||dt|d|<6|S|S)a# Transform a map to a flat style map where keys are prefixed with length info. Map keys are transformed from "key" to "#length#key" format. @param obj: the input object (can be a TeaModel, list, dict, or other types) @return: the transformed object. N#) rrar=r map_to_flat_stylerrXr<r`r;) objrbrdobj_mapr$rDflat_map entry_key entry_values rrzClient.map_to_flat_styles ;J c4  F > > f66t<<====M X & & jjllGF%mmoo B B UeT**B:eX3N3NB!H27++--kk. ;EKE]E]^iEjEj!AS^^!A!Ai!A!ABB"*F3KK"(":":5"A"AF3KKM T " " H!iikk Q Q U171I1I%1P1P-SXX----..O rN)__name__ __module__ __qualname____doc__ staticmethodr]rWrgrlryrrrrr?rrrrrrrrrrrrrrrr r \st # #\ #\(  \   \ \*\ &&\&*  \ II\I  \ ""\"H\<  \ \  \ (\&!!\! 99\9\"88\888\8""\"""rr )!rrr-r+r|rcryptography.hazmat.backendsrcryptography.hazmat.primitivesr)cryptography.hazmat.primitives.asymmetricr,cryptography.hazmat.primitives.serializationr urllib.parserrsm3r r alibabacloud_tea_util.clientr r Tea.streamr Tea.modelrrr%r2rFrTobjectrrrrsu 888888111111======MMMMMM********777777######DDD((((333(xxxxxVxxxxxr