'wf:ddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z m Z ddl mZGddeZdZ ddZGd d eZd Z dd Zd Z ddZy)N)UnknownClientMethodError) RequestSignerS3PostPresignerUnknownSignatureVersionError UnsupportedSignatureVersionError_should_use_global_endpointcreate_request_objectprepare_request_dict) ArnParsercHeZdZddZ ddZdZ ddZeZ d dZy) AioRequestSignerNcBK|j||d{S7wN)sign)selfoperation_namerequestkwargss g/home/panchajanya/Development/work/volatility3/venv/lib/python3.12/site-packages/aiobotocore/signers.pyhandlerzAioRequestSigner.handlers YY~w7777s c `K|}| |j}| |j}|j|||jd{}|jj dj |jj||||j|||d{|tjk7r|||d} ||| d<|jjdi} |s| jdr| d| d<| jdr| d| d<| jd r| d | d <| jd |j| | d | d  |jdi| d{} | j!|yy7B77#t$r} |d k7r t| | d} ~ wwxYww)Nzbefore-sign.{}.{})r signing_name region_namesignature_versionrequest_signerr)rrrexpiressigningregionrrrequest_credentialsidentity_cache cache_keystandardr) _region_name _signing_name_choose_signercontext_event_emitteremitformat _service_id hyphenizebotocoreUNSIGNEDget_resolve_identity_cacheget_auth_instancerradd_auth) rrrr signing_type expires_inrexplicit_region_namerrsigning_contextauthes rrzAioRequestSigner.signs +  ++K  --L"&"5"5 L'//#   !!&&  & &  **,n %))/)'    1 1 1 ,*%6F %$.y!%oo11)R@O'O,?,?,I(7(A}%"">2)8)H~&""#890?)1,-""#34@,,#$45#K0  3T33=f== MM' "C 2# H>/ :-:*;G  s[?F.FAF.FB7F.F +F,F 0F.F.F F+F&&F++F.c`Kddd}|j|d}|jdxs |j}|jdi}|jd|j}|jd|j} |tj ur|j |s||z }|jjd j|jj||| || d{\} } | *| }|tj ur|j |s||z }|S75w) Nz -presign-postz-query) presign-post presign-url auth_typerrrzchoose-signer.{}.{})rrrr() r0_signature_versionr&r%r.r/endswithr)emit_until_responser+r,r-) rrr4r(signing_type_suffix_mapsuffixrrrrrresponses rr'zAioRequestSigner._choose_signer^s?+## ),,\2>$KK 4O8O8O++i,{{>43E3EF kk(D,=,=> X%6%6 6%..v6  ' "&"5"5"I"I ! ( (  **,n &#/#J#     ( "):)::)226:!V+!  ) sC4D.6D,76D.cK| |j}tjjj |}| t ||j dur:d}|j"|jjd{}||}|S|xs |j} t|dddur&|d} |d} | j| d{} |d=d} | | jd{} | |d<|jr4|jtjj!||d<||d<|d i|}|S77t7Ww) Nr#TREQUIRES_IDENTITY_CACHEr r! credentialsr service_namer$)r?r.r8AUTH_TYPE_MAPSr0rREQUIRES_TOKEN _auth_tokenget_frozen_token _credentialsgetattrget_credentialsget_frozen_credentialsREQUIRES_REGIONr% exceptions NoRegionError) rrrrrrcls frozen_tokenr8rGcachekeyfrozen_credentialss rr2z"AioRequestSigner.get_auth_instancesl  $ $ 7 7 mm**../@A ;."3     %L+%)%5%5%F%F%HH |$DK)>T->-> 314 8D @+,E%C % 5 5c ::K{#!  "'2'I'I'K!K  2}     ())7799$/F= !%1F> "}V} + I; "Ls8A?EEA E EE,E-AEEEcKt|}|j|||d||d{|j|jS7 w)Nr<)r rprepareurl)r request_dictrr5rrrs rgenerate_presigned_urlz'AioRequestSigner.generate_presigned_urlsU( 5ii           {{ s%A A!A )NN)Nr"NN)NN) __name__ __module__ __qualname__rrr'r2get_authr]r$rr r sG8B#H'!Z )X!H  rcr c t|d<y)Ngenerate_db_auth_token)reclass_attributesrs radd_generate_db_auth_tokenrh1G-.rccK|}||jj}d|d}ddi|dd}d}||d |} t|| |jj d||d d d{} | t |dS7w) 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)rr\rr5r)metarr _request_signerr]len) r DBHostnamePort DBUsernameRegionrparamsr\scheme endpoint_url presigned_urls rreres(F ~&&F  LFXj\4&1L|4..EE ! FM V ''sA"A9$A7%A9ceZdZ ddZy)AioS3PostPresignerNcK|i}|g}i}tjj}|tj|z}|jtj j |d<g|d<|D]} |dj| t|} || jd<|| jd<|jjd| |dd{| j|dS7w) N)seconds expiration conditionszs3-presign-post-fieldszs3-presign-post-policy PutObjectr;)r[fields) datetimeutcnow timedeltastrftimer.r8ISO8601appendr r(rwrr[) rr\rrr5rpolicy datetime_now expire_date conditionrs rgenerate_presigned_postz*AioS3PostPresigner.generate_presigned_posts >F  J ((//1 "X%7%7 %KK *33HMM4I4IJ| "|# 3I < ' ' 2 3( 54:014:01""'' +~   {{f55  sCC0C.C0)NNr^N)r_r`rarr$rcrrrs $6rcrc t|d<y)Nr])r]rfs radd_generate_presigned_urlr/rirccLK|}|}|i}|}|}dt|d} |j} |j|} |j j j| } |j|| | d{}tj|jdd} |j| || | d{\}}}|j|| || |d d{}|||d <| j||| d{S#t$r t |wxYw77e7D7#w) 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_regionFrrrr(rrset_user_agent_headerrt)r\r5r)rrw_PY_TO_OP_NAMEKeyErrorrrv service_modelr_emit_api_paramsr is_arnr0_resolve_endpoint_ruleset_convert_to_request_dictr])r ClientMethodParams ExpiresIn HttpMethod client_methodr}r5 http_methodr(rrr bucket_is_arnradditional_headers propertiesr\s rr]r]3s,!M F ~JK":4@G ))NB,,];ii--==nMO((')F $$VZZ"%=>M ,,#00 -  66'!"# 7L!, X 66!%7 G B&=AAB  s^'D$DD"?D$DD$D$ D$"D$c t|d<y)Nr)rrfs radd_generate_presigned_postrs2I./rcc K|}|}|}|} |} |i}n|j}| g} dt|d} t|j} |jj j d} |jd|i| | d{}tj|jdd}|j| || | d{\}}}|j|| || |d d{}| jd |i|jd r"| jd d |dtd  gn| jd|i||d<| j!||| | d{S7777 w)NTr CreateBucketrrr=rFrbucketz ${filename}z starts-withz$keyrW)r\rrr5)copyrrrwrvrrrr rr0rrrr@rxr)rrKeyFields ConditionsrrrWrrr5r(post_presignerrr}rrrrr\s rrrsF C FJJ ~ #:4@G ((<(<=Nii--==nMO((f%')F $$VZZ"%=>M ,,#00 -  66'!"# 7Lx() ||M"=K]9K8K2LMN5#,'F5M77! 8 O , sJBE5E-AE5 E/ "E5-E1.A:E5(E3)E5/E51E53E5r)Nr^N)NNr^)rr. botocore.authbotocore.exceptionsrbotocore.signersrrrrrr r botocore.utilsr r rhrerrr]rrr$rcrrsy8%v}vrH 045(p%6%6PH AEL^J @DGrc