pge6ddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z m Z ddl mZGddeZdZ ddZGd d eZd Z dd ZdZ ddZdS)N)UnknownClientMethodError) RequestSignerS3PostPresignerUnknownSignatureVersionError UnsupportedSignatureVersionError_should_use_global_endpointcreate_request_objectprepare_request_dict) ArnParsercHeZdZd dZ d dZdZ d dZeZ d dZdS) AioRequestSignerNc>K|||d{VSN)sign)selfoperation_namerequestkwargss 3lib/python3.11/site-packages/aiobotocore/signers.pyhandlerzAioRequestSigner.handlers. YY~w777777777standardc K|}||j}||j}||||jd{V}|jd|j||||j|||d{V|tj kr|||d} ||| d<|j di} |s | dr | d| d<| dr | d| d< |j d i| d{V} n*#t$r} |d krt| | d} ~ wwxYw| |dSdS) Nzbefore-sign.{}.{})r signing_name region_namesignature_versionrequest_signerr)rrrexpiressigningregionrrrr) _region_name _signing_name_choose_signercontext_event_emitteremitformat _service_id hyphenizebotocoreUNSIGNEDgetget_auth_instancerradd_auth) rrrr signing_type expires_inrexplicit_region_namerrsigning_contextauthes rrzAioRequestSigner.signs% +  +K  -L"&"5"5 L'/# #        !&&  & & **,,n  %)/)'     1 1 1 ,*%6F %$.y!%o11)R@@O' BO,?,?,I,I B(7(A}%"">22 I)8)H~& 3T3==f========/   :--:*;G   MM' " " " " "/ 2 1s D E)EEc^Kddd}||d}|dp|j}|di}|d|j}|d|j} |tjur||s||z }|jd |j ||| || d{V\} } | *| }|tjur||s||z }|S) Nz -presign-postz-query) presign-post presign-url auth_typerrr zchoose-signer.{}.{})rrrr&) r._signature_versionr$r#r,r-endswithr'emit_until_responser)r*r+) rrr1r&signing_type_suffix_mapsuffixrrrrrresponses rr%zAioRequestSigner._choose_signerTsy+## # ),,\2>>$KK 44O8O++i,,{{>43EFF kk(D,=>> X%6 6 6%..v66 7  ' "&"5"I"I ! ( ( **,,n  &#/#J# #          ( "):::)226::;"V+!  rcK||j}tjj|}|t ||jdur5d}|j|jd{V}||}|Sd}|j |j d{V}||d<|j r/|j tj ||d<||d<|di|}|S)Nr!T credentialsr service_namer")r<r,r5AUTH_TYPE_MAPSr.rREQUIRES_TOKEN _auth_tokenget_frozen_token _credentialsget_frozen_credentialsREQUIRES_REGIONr# exceptions NoRegionError) rrrrrcls frozen_tokenr5frozen_credentialss rr/z"AioRequestSigner.get_auth_instance}s>  $ $ 7 m*../@AA ;."3    % %L+%)%5%F%F%H%HHHHHHH 3|$$DK!   ('>>@@@@@@@@ !3}   2 ()77999$/F= !%1F> "s}}V}} rcKt|}||||d||d{V||jS)Nr9)r rprepareurl)r request_dictrr2rrrs rgenerate_presigned_urlz'AioRequestSigner.generate_presigned_urlsu( 55ii                 {r)NN)NrNNr)rQNN) __name__ __module__ __qualname__rrr%r/get_authrVr"rrr r s88888#8#8#8#t'!'!'!T<@D!H  rr c t|d<dS)Ngenerate_db_auth_token)r\class_attributesrs radd_generate_db_auth_tokenr_1G-...rcK|}| |jj}d|d}ddi|dd}d}||d |} t|| |jd||d d d{V} | t |dS) aGenerates an auth token used to connect to a db with IAM credentials. :type DBHostname: str :param DBHostname: The hostname of the database to connect to. :type Port: int :param Port: The port number the database is listening on. :type DBUsername: str :param DBUsername: The username to log in as. :type Region: str :param Region: The region the database is in. If None, the client region will be used. :return: A presigned url which can be used as an auth token. Nconnect)ActionDBUser/r:GET)url_path query_stringheadersbodymethodzhttps://:izrds-db)rrUrr2r)metarr _request_signerrVlen) r DBHostnamePort DBUsernameRegionr paramsrUscheme endpoint_url presigned_urls rr\r\s(F ~&F  LF1j11411L|444.EE ! FM V ''rceZdZ ddZdS)AioS3PostPresignerNrQcK|i}|g}i}tj}|tj|z}|tjj|d<g|d<|D]} |d| t|} || j d<|| j d<|j d| |dd{V| j |dS) N)seconds expiration conditionszs3-presign-post-fieldszs3-presign-post-policy PutObjectr8)rTfields) datetimeutcnow timedeltastrftimer,r5ISO8601appendr r&rnrrT) rrUrr}r2rpolicy datetime_now expire_date conditionrs rgenerate_presigned_postz*AioS3PostPresigner.generate_presigned_posts# >F  J (//11 "X%7 %K%K%KK *33HM4IJJ| "|# 3 3I < ' ' 2 2 2 2( 554:014:01"'' +~         {f555r)NNrQN)rWrXrYrr"rrryrys6 $6$6$6$6$6$6rryc t|d<dS)NrV)rVr]s radd_generate_presigned_urlrr`rrQcFK|}|}|i}|}|}dt|d} |j} |j|} n#t$rt |wxYw|jj| } ||| | d{V}tj | dd} | | || | d{V\}}| || || |d d{V}|||d <| ||| d{VS) axGenerate a presigned url given a client, its method, and arguments :type ClientMethod: string :param ClientMethod: The client method to presign for :type Params: dict :param Params: The parameters normally passed to ``ClientMethod``. :type ExpiresIn: int :param ExpiresIn: The number of seconds the presigned url is valid for. By default it expires in an hour (3600 seconds) :type HttpMethod: string :param HttpMethod: The http method to use on the generated url. By default, the http method is whatever is used in the method's model. :returns: The presigned url NTis_presign_requestuse_global_endpoint) method_name api_paramsoperation_modelr&Bucketr:ignore_signing_regionFrrrvr&riset_user_agent_headerrk)rUr2r)rrn_PY_TO_OP_NAMEKeyErrorrrm service_modelr_emit_api_paramsr is_arnr._resolve_endpoint_ruleset_convert_to_request_dictrV)r ClientMethodParams ExpiresIn HttpMethod client_methodrtr2 http_methodr&rrr bucket_is_arnrvadditional_headersrUs rrVrVs,!M F ~JK":4@@G )NB,]; BBB&=AAAABi-==nMMO((')F $VZZ"%=%=>>M-1-K-K#00 .L..(((((($L$66'!"# 7L!, X 66!%7      s 7Ac t|d<dS)Nr)rr]s radd_generate_presigned_postrjs2I.///rc "K|}|}|}|} |} |i}n|}| g} dt|d} t|j} |jjd} |d|i| | d{V}tj | dd}| | || | d{V\}}| || || |d d{V}| d |i|d r/| d d |dtd  gn| d|i||d<| ||| | d{VS)NTr CreateBucketrrr:rFrbucketz ${filename}z starts-withz$keykey)rUrr}r2)copyrryrnrmrrrr rr.rrrr=ror)rrKeyFields Conditionsrrrrr}r2r&post_presignerrrtrrvrrUs rrrns\F C FJJ ~ #:4@@G ((<==Ni-==nMMO((f%')F $VZZ"%=%=>>M-1-K-K#00 .L..(((((($L$66'!"# 7Lx())) ||M""(=K]9K9K8K6K2LMNNNN5#,'''F5M77! 8      rr)NrQN)NNrQ)rr, botocore.authbotocore.exceptionsrbotocore.signersrrrrrr r botocore.utilsr r r_r\ryrrVrrr"rrrs888888%$$$$$bbbbb}bbbJHHH 045(5(5(5(p%6%6%6%6%6%6%6%6PHHH AEHHHHVJJJ @DCCCCCCr