⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
handlers.cpython-312.pyc
Pe d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl Z ddl Z ddl m Z ddl mZmZmZmZmZmZmZmZmZmZmZ ddlmZmZm Z ddl m Z ddl m Z m!Z!m"Z" dd l#m$Z$ dd l%m&Z&m'Z'm(Z( dd l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ dd l m0Z0 dd l m1Z1 ddl m2Z2 ddl m3Z3 ddl)m4Z4 ddl)m5Z5 ddl)m6Z6 ejn e8 Z9 e: Z; e: Z< ejz d Z>dZ?dZ@ ejz dj e?e@g ZBdZC ejz d ZDd ZEd ZFd ZGd ZHd ZId ZJd ZKd ZLd! ZMd" ZNd# ZOd$ ZPd% ZQdd&ZRd' ZSd( ZTd) ZU G d* d+ ZVd, ZWd- ZXd. ZYd/ ZZd0 Z[d1 Z\d2 Z]d3 Z^d4 Z_d5 Z`d6 Zad7 Zbd8 Zcd9 Zdd: Zed; Zfd< Zgd= Zhd> Zid? Zjd@ ZkdA ZldB ZmdC ZndD ZodE ZpdF ZqdG ZrdH ZsdI ZtdJ Zu G dK dL Zv G dM dN Zw G dO dP ZxdQ ZydR ZzdS Z{dT Z|dU Z}dV Z~dW ZdX Zg dYeEfdZ ewd[ fd\ete<fd]ete<fd^e(fd_e'fd`emfdaezfdbe_fdceKfddeNfdeeafdfeLfdgeOfdge|fdheofdieofdjeofdkeXfdleXfdkedfd]edfdmedfdne}fdoeWfdpeWfdqefdreFfdseUfdtegfduehfdve,fdwe-fdxeGfdxe,fdyeGfdzeifd{eifd|e]fd}e{fd~elfdeHe;fdeHe;fdeHe;fdeTfdeTfdeTfdeTfdeTfdeTfdeJfdePfdePfd]ePfdkePfdkeQfdmePfd\ePfdlePfdleQfdePfdePfdebfdebfdeefdeffde~fdefdepfdeqfderfdenfd edd j fd ed j fd ed j fd ej fdekfd ecd fd ecd fd ed j fd ed j fd ed j fd ed j fd ecd fd e ddg d j fde&fde^fde^fde^fde^fde^fd ed j fd ed j fd ed j fd ed j fd ed j fde^fde^fd ed j fd ed j fde^fde^fd ed j fd ed j fdreyfZ eue y)z_Builtin event handlers. This module contains builtin handlers for events emitted by botocore. N)BytesIO)utils) ETree OrderedDict XMLParseError ensure_bytesget_md5jsonquoteunquote unquote_strurlsplit urlunsplit)AppendParamDocumentationAutoPopulatedParamHideParamFromOperations)VALID_HOST_LABEL_RE)AliasConflictParameterErrorParamValidationError UnsupportedTLSVersionWarning)EndpointResolverBuiltins)add_generate_db_auth_tokenadd_generate_presigned_postadd_generate_presigned_url) SAFE_CHARS ArnParser conditionally_calculate_checksumconditionally_calculate_md5percent_encodeswitch_host_with_param) retryhandler) translate) MD5_AVAILABLE)MissingServiceIdError)hyphenize_service_id)is_global_accesspoint)SERVICE_NAME_ALIASESz^[a-zA-Z0-9.\-_]{1,255}$z]^arn:(aws).*:(s3|s3-object-lambda):[a-z\-0-9]*:[0-9]{12}:accesspoint[/:][a-zA-Z0-9\-.]{1,63}$zt^arn:(aws).*:s3-outposts:[a-z\-0-9]+:[0-9]{12}:outpost[/:][a-zA-Z0-9\-]{1,63}[/:]accesspoint[/:][a-zA-Z0-9\-]{1,63}$|)s3z s3-outpostszs3-object-lambda s3expressz\?versionId=[^\s]+$c . t j | | S N)r' get) service_namekwargss 3/usr/lib/python3/dist-packages/botocore/handlers.pyhandle_service_name_aliasr1 i s # #L, ?? c dt j v }t j j d }|r |r| d }d|vrt |d |d< y y y y )NAWS_LAMBDA_FUNCTION_NAME_X_AMZN_TRACE_IDheaderszX-Amzn-Trace-Idz -=;:+&[]{}"',safe)osenvironr- r )paramsr/ has_lambda_nametrace_idr6 s r0 add_recursion_detection_headerr> m sY 0BJJ>Ozz~~ 01H8# G +).x>N)OG% & , $r2 c p | d }d|v r|j dd }d|v r|j dd }|| d< y )Nbody s s )replace)r; r/ r@ s r0 escape_xml_payloadrD v sD &>D }||E8, }||E8,F6Nr2 c f | y | \ }}t | r t j d| d|_ y y )NzWError found for response with 200 status code, errors: %s, changing status code to 500.i ) _looks_like_special_case_errorloggerdebug status_code)responser/ http_responseparseds r0 check_for_200_errorrM sF $M6%m4 %( ! 5r2 c | j dk( re t j t j d }|j | j |j }|j dk( ryy# t $ r Y yw xY w)N utf-8targetencodingTErrorF) rI r XMLParser TreeBuilderfeedcontentcloser tag)rK parserroots r0 rF rF sz C' __ ((*WF KK -- .<<>D 88w s AA6 6 BBc | j d }|sy|dk( rt j S |dk( ry|j d rM|dk( r|S |dk( r&d|d }d | v r| d j | n|| d < d}nd}|d k( rd | d < |t v rd| }|S y)a' Choose the operation-specific signer. Individual operations may have a different auth type than the service as a whole. This will most often manifest as operations that should not be authenticated at all, but can include other auth modes such as sigv4 without body signing. auth_typeNnonebearerv4z v4-s3expressv4a*)region signing_namesigningzv4-unsigned-bodyFpayload_signing_enabledr) )r- botocoreUNSIGNED startswithupdateS3_SIGNING_NAMES)contextre r/ r^ rf signature_versions r0 set_operation_specific_signerro s K(I F H D! & "%lCGG# "))'2%, " % $ * *16G- . + +"$%6$7 8 5 "r2 c d| v r9 t j t | d d j dd }|| d< y y # t t t f$ r t j dd Y y w xY w)NOutputzlatin-1rP rC zError decoding base64Texc_info) base64 b64decodebytesdecode ValueError TypeErrorAttributeErrorrG rH rL r/ values r0 decode_console_outputr} s| 6 A $$fX& 2fWi( %F8 I~6 A LL04L @ As 7? +A-,A-c |j D ]F }|| vst t j | |< t j d| | d|d H y )Nz injecting idempotency token (z) into param 'z'.)idempotent_membersstruuiduuid4rG rH )r; modelr/ names r0 generate_idempotent_uuidr sH (( v tzz|,F4L LL$<' )r2 c t j t | } | S # t t f$ r t j dd Y | S w xY w)NzError loading quoted JSONTrr )r loadsr rx ry rG rH )r| s r0 decode_quoted_jsondocr sO A 75>* L " A 04 @ LAs " &A A c d| v r% t j | d t }|| d< y y # t t f$ r t j dd Y y w xY w)N TemplateBody)object_pairs_hookzerror loading JSONTrr )r r r rx ry rG rH r{ s r0 json_decode_template_bodyr s_ >JJ~&+E &+F> " I& > LL-L = >s #+ &AAc d| vry | d }t j | sJt j | s4d| dt j dt j d}t | y y )NBucketzInvalid bucket name "z%": Bucket name must match the regex "z#" or be an ARN matching the regex ""report) VALID_BUCKETsearch VALID_S3_ARNpatternr )r; r/ bucket error_msgs r0 validate_bucket_namer s} v H F v &|/B/B6/J#F8 ,&../ 0&../q 2 #)44 0K &r2 c t | d y)z S3 server-side encryption requires the encryption key to be sent to the server base64 encoded, as well as a base64-encoded MD5 hash of the encryption key. This handler does both if the MD5 has not been set by the caller. SSECustomerN_sse_md5r; r/ s r0 sse_md5r # s V]#r2 c t | d y)a1 S3 server-side encryption requires the encryption key to be sent to the server base64 encoded, as well as a base64-encoded MD5 hash of the encryption key. This handler does both if the MD5 has not been set by the caller specifically if the parameter is for the copy-source sse-c key. CopySourceSSECustomerNr r s r0 copy_source_sse_md5r - s V,-r2 c P t | | sy |dz }|dz }| | }t |t r|j d }t j t | j j d }t j | j d }|| |< || |< y )NKeyKeyMD5rP ) _needs_s3_sse_customization isinstancer encodert b64encoder digestrw )r; sse_member_prefixsse_key_membersse_md5_member key_as_bytes key_md5_strkey_b64_encodeds r0 r r 7 s &v/@ A&.N&1N.)L,$#**73 ""7<#8#?#?#ABIIK &&|4;;GDO ,F> (F>r2 c @ | j |dz d uxr |dz | vS )Nr r r- )r; r s r0 r r H s0 $u,-T9 7 ( 6r2 c " t j S )zk This handler disables request signing by setting the signer name to a special sentinel value. )rh ri )r/ s r0 disable_signingr O s r2 c | j j dd dvry d|v r0|d }t |d r t j d d|d d < y y y ) Nmethod )PUTPOSTr@ readz-Adding expect 100 continue header to request.z 100-continuer6 Expect)httpr- hasattrrG rH )r r; r/ r@ s r0 add_expect_headerr W s_ zz~~h#?: f~ 4 LLH I*8F9 h ' ! r2 c e Zd Zd Zd Zy)DeprecatedServiceDocumenterc || _ y r, )_replacement_service_name)selfreplacement_service_names r0 __init__z$DeprecatedServiceDocumenter.__init__d s )A&r2 c |j j |j d |j j | j | j |j d |j j y )Nz.This service client is deprecated. Please use z instead.)stylestart_importantwriterefr end_important)r section event_namer/ s r0 inject_deprecation_noticez5DeprecatedServiceDocumenter.inject_deprecation_noticeg sa %%' FG * * * * k" ##%r2 N)__name__ __module__ __qualname__r r r2 r0 r r c s B&r2 r c d|v rU| j d }|j d }|j d }|j |j d y d|v rv| j d }|j d }|j |j d |j d }|j |j d y y ) Nzrequest-examplestructure-value CopySource member-valuezH'string' or {'Bucket': 'string', 'Key': 'string', 'VersionId': 'string'}zrequest-params param-typez :type CopySource: str or dictzparam-documentationaq The name of the source bucket, key name of the source object, and optional version ID of the source object. You can either provide this value as a string or a dictionary. The string form is {bucket}/{key} or {bucket}/{key}?versionId={versionId} if you want to copy a specific version. You can also provide this value as a dictionary. The dictionary format is recommended over the string format because it is more explicit. The dictionary format is: {'Bucket': 'bucket', 'Key': 'key', 'VersionId': 'id'}. Note that the VersionId key is optional and may be omitted. To specify an S3 access point, provide the access point ARN for the ``Bucket`` key in the copy source dictionary. If you want to provide the copy source for an S3 access point as a string instead of a dictionary, the ARN provided must be the full S3 access point object ARN (i.e. {accesspoint_arn}/object/{key}) get_section clear_textr ) r r r/ parent param_line value_portion param_section type_section doc_sections r0 document_copy_source_formr r s J&$$%67'' 5 "..~> " 6 Z ' ++L9 $00 > !:;#//0EF 5 (r2 c | j d }|yt |t rt | | d< yt |t rt | | d< yy)aH Convert CopySource param for CopyObject/UploadPartCopy. This handler will deal with two cases: * CopySource provided as a string. We'll make a best effort to URL encode the key name as required. This will require parsing the bucket and version id from the CopySource value and only encoding the key. * CopySource provided as a dict. In this case we're explicitly given the Bucket, Key, and VersionId so we're able to encode the key and ensure this value is serialized and correctly sent to S3. r N)r- r r _quote_source_headerdict _quote_source_header_from_dict)r; r/ sources r0 handle_copy_source_paramr sS ZZ %F ~ &# 3F ;| FD ! =f E| "r2 c | d }| d }| j d }t j | r| d| }n| d| }t |t dz }||d |z z }|S # t $ r }t dt | d }~ww xY w) Nr r VersionIdz/object//z Missing required parameter: r r7 z ?versionId=%s)r- r r KeyErrorr r r r ) source_dictr key version_idfinales r0 r r s X&% __[1 v & hhse,E hau%E 5zC'7 8E :-- L "1#a&: s ?A! ! B*BBc t j | }|t | t dz S | d |j | |j d }}t |t dz |z S )Nr r7 )VERSION_ID_SUFFIXr r r start)r| resultfirstr s r0 r r se % %e ,F ~ e*s*:;; !"2FLLN 3U6<<>;K5Lz e*s*:;jHHr2 c t j | }||d d< |d j || |d< d|d< i |d< | j |||j S )Nr@ DestinationRegionurlGETr r6 ) region_nameoperation_name)copydeepcopyrC generate_presigned_urlr )request_signer request_dictr source_regiondestination_regionrequest_dict_copys r0 _get_cross_region_presigned_urlr s l35Gf 12 +E 2 : :M e #(h #%i 0 0}UZZ 1 r2 c D | j }|j d }||fS )N SourceRegion) _region_namer- )r r; r r s r0 1_get_presigned_url_source_and_destination_regionsr s( '44JJ~.M , ,,r2 c v d| d v ry t || d \ }}t || ||| }|| d d< || d d< y )N PresignedUrlr@ r r r r; r r r/ srcdestr s r0 inject_presigned_url_ec2r s` 'AvIC *sD C &)F6N>" +/F6N&'r2 c d| d vry t || d \ }}| d d= d| d v ry t || ||| }|| d d< y )Nr r@ PreSignedUrlr r s r0 inject_presigned_url_rdsr sl VF^+AvIC v~& ' )sD C &)F6N>"r2 c N |j }|t | |j y y r, ) output_shape_decode_policy_types)rL r r/ r s r0 json_decode_policiesr s* %%L VU%7%78 r2 c X d}|j dk( rj|j j D ]M \ }}|j dk( r%|j |k( r|| v rt | | | |< :|| v s?t | | | O |j dk( r |j }| D ] }t || y y )NpolicyDocumentType structurestringlist) type_namemembersitemsr r r member)rL shape shape_name member_name member_shape shape_memberitems r0 r r s &J +%). )<)<)> %K &&(2 %%3 6)&;;''{# &$VK%8,G *? & || D | 4 !r2 c |j y |j }t j t j d }|j | |j }|j }|| d< y )NrP rQ LocationConstraint)rawrX r rU rV rW rY text)rL rK r/ response_bodyr[ r\ rd s r0 parse_get_bucket_locationr* 6 sb !))M __E$5$5$7' JF KK <<>D YYF#)F r2 c d| v rUt | d t r| d j d | d< t j | d j d | d< y y )NUserDatarP )r r r rt r rw r s r0 base64_encode_user_datar- F s` V fZ(# .!' !3!:!:7!CF: # - -fZ.@ A H H z r2 c 6 d}t | | }|j S )Nzw**This value will be base64 encoded automatically. Do not base64 encode this value prior to performing the operation.**r append_documentation)param descriptionappends r0 document_base64_encodingr4 P s& &e[ 9F & &&r2 c | j d }|rt |t sy|j D ]( \ }} |j d |j d * y# t $ r d|d|d}t | w xY w)aE Verify S3 Metadata only contains ascii characters. From: http://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html "Amazon S3 stores user-defined metadata in lowercase. Each name, value pair must conform to US-ASCII when using REST and UTF-8 when using SOAP or browser-based uploads via POST." MetadataNasciiz3Non ascii characters found in S3 metadata for key "z ", value: "z4". S3 metadata can only contain ASCII characters. r )r- r r r r UnicodeEncodeErrorr )r; r/ metadatar r| r s r0 validate_ascii_metadatar: Z s zz*%H :h5 nn& U 9 JJw LL ! ' " 9 14U< 'i8 8 9s "A!! B c @ |j }|r t |d sy|j j D cg c] \ }}|j dv r| }}}|D ]> }|| v s| | }|j d d | |< t j d||| | @ yc c}}w )z Check for and split apart Route53 resource IDs, setting only the last piece. This allows the output of one operation (e.g. ``'foo/1234'``) to be used as input in another operation (e.g. it expects just ``'1234'``). r N) ResourceIdDelegationSetIdChangeIdr z %s %s -> %s) input_shaper r r r splitrG rH )r; r r/ r@ r r r orig_values r0 fix_route53_idsrC y s ##K gk9 = ) 0 0 6 6 8 8MT5 ::F F 8 6> J%++C04F4L LL j&, G s Bc 2 | j d d| d< y y )N accountId-r r s r0 inject_account_idrG s" zz+ & "{ 'r2 c 2 |}| j d |d d< y )N apiVersionr6 zx-amz-glacier-version)r9 r r; r/ r s r0 add_glacier_versionrK s# L7<~~8L 34r2 c D |d j dd |}d|d d< y y )Nr6 Acceptzapplication/jsonr rJ s r0 add_accept_headerrN s3 i Xt,4 ,> Y ) 5r2 c * | }|d }|d }t |t r t | }|j }d|vrt j |d |d< |j | d|vrt j | |d< |j | y)zAdd glacier checksums to the http request. This will add two headers to the http request: * x-amz-content-sha256 * x-amz-sha256-tree-hash These values will only be added if they are not present in the HTTP request. r6 r@ zx-amz-content-sha256T)as_hexzx-amz-sha256-tree-hashN)r rv r tellr calculate_sha256seekcalculate_tree_hash)r; r/ r r6 r@ starting_positions r0 add_glacier_checksumsrV s L9%G D$ t} W,*/*@*@ + &' II w.,1,E,Ed,K()II r2 c 2 d} t d| j S )Na This is a required field. Ideally you will want to compute this value with checksums from previous uploaded parts, using the algorithm described in `Glacier documentation <http://docs.aws.amazon.com/amazonglacier/latest/dev/checksum-calculations.html>`_. But if you prefer, you can also use botocore.utils.calculate_tree_hash() to compute it from raw file by:: checksum = calculate_tree_hash(open('your_file.txt', 'rb')) checksumr/ )docs r0 #document_glacier_tree_hash_checksumrZ s C $J 4 I IIr2 c F d|v rD| j d }|j d }|j |j d y d|v rU| j d }|j d }|j d }|j |j d y y ) Nzresponse-paramsr r z (*dict*) --zresponse-exampler r z{}r )r r r/ template_body_sectionr r r r s r0 0document_cloudformation_get_template_return_typer] s J& ' 3 3N C ,88 F !=) z )$$%67''7 "..~> "D! *r2 c t | d y )NPredictEndpoint)r requestr/ s r0 switch_host_machinelearningrb s 7$56r2 c dd l } |j }|dk r(t j d|j z t y y # t $ r Y y w xY w)Nr ) r rd zCurrently installed openssl version: %s does not support TLS 1.2, which is required for use of iot-data. Please use python installed with openssl version 1.0.1 or higher.)sslOPENSSL_VERSION_INFOwarningswarnOPENSSL_VERSIONr rz )r/ re openssl_version_tuples r0 &check_openssl_supports_tls_version_1_2rk s] # 8 8 9 , MM ! 0 02 - - s 8A A A c | j dk( rOd| j v r@d| j d< d| _ | j j dd \ | _ | _ y y y )Nr ?z!application/x-www-form-urlencoded Content-Typer rd )r r r6 rA datar` s r0 change_get_to_postrp sW ~~ 3'++#5*M' $+KK$5$5c1$=! W\ $6 r2 c " d| vr d|d< d| d< y y )N EncodingTypeTencoding_type_auto_setr r )r; rm r/ s r0 "set_list_objects_encoding_type_urlrt s& V# -1()!&~ $r2 c * t g dddg| | y )N) DelimiterMarker NextMarkerContentsr CommonPrefixesPrefixtop_level_keys nested_keysrL rm _decode_list_objectrL rm r/ s r0 decode_list_objectr s <(*FG r2 c * t g dddg| | y )N)rv r} StartAfterry r{ r~ r r s r0 decode_list_object_v2r " s <(*FG r2 c * t g dg d| | y )N) KeyMarker NextKeyMarkerr} rv ))Versionsr ) DeleteMarkersr r{ r~ r r s r0 decode_list_object_versionsr / s r2 c |j d dk( rZ|j d rH| D ] }||v st || ||< |D ]% \ }}||v s || D ] }t || ||< ' y y y )Nrr r rs )r- r )r r rL rm r top_key child_keyr s r0 r r E s zz.!U*w{{ 0 "Cf} )&+ 6s " #. GY& $WoF(3F94E(FF9% . #.0*r2 c d| v rTt | d t rt t | d | d< y t | d t rt | d | d< y y y )NBody)r r r r rv r s r0 convert_body_to_file_like_objectr T sY fVnc * $\&.%A BF6N v . $VF^ 4F6N / r2 c dddd}|j D ]r \ }}|j dd \ }}t || }d|z |j t f}d|z d z |j f}| j | | j | t y ) NFiltersfromTime returnFields)z ec2.*.Filterzlogs.CreateExportTask.fromz cloudsearchdomain.Search.return.rd zbefore-parameter-build.zdocs.*.z.complete-section)r rsplitParameterAliasalias_parameter_in_callREGISTER_FIRST alias_parameter_in_documentationr3 ) handler_listaliasesoriginalnew_name event_portion original_nameparameter_alias#parameter_build_event_handler_tupledocs_event_handler_tuples r0 _add_parameter_aliasesr \ s "&0+9G &mmo('/sA'>$ }( A & 5 3 3 / + %(; ; < <$ ?@ 45% .r2 c $ e Zd Zd Zd Zd Zd Zy)r c || _ || _ y r, )_original_name _alias_name)r r alias_names r0 r zParameterAlias.__init__~ s +%r2 c F |j r| j |j j v rr| j |v rc| j |v r,t | j | j |j |j | j || j < y y y y )N)r alias operation)r@ r r r r r pop)r r; r r/ s r0 r z&ParameterAlias.alias_parameter_in_call s ""e&7&7&?&??##v-**f4 9%)%8%8"&"2"2&+jj 39**T=M=M2NF4../ . @ r2 c |j d ry| j |j vry |j | j }|j d }| j | |j d }| j | y |j d rW|j d }| j |j vry |j | j }| j | y y )Nzdocs.request-paramsr z param-namezdocs.request-exampler )rj r available_sectionsr _replace_content)r r r r/ r param_type_sectionparam_name_sections r0 r z/ParameterAlias.alias_parameter_in_documentation s !6 7""'*D*DD # / /0C0C DM!.!:!:<!H ! !"4 5 "/!:!:<!H ! !"4 5 " "#9 : ))*;<G""'*D*DD # / /0C0C DM ! !- 0 ;r2 c |j j d }|j | j | j }|j |j | y )NrP )getvaluerw rC r r r r )r r rX updated_contents r0 r z ParameterAlias._replace_content sT ""$++G4!// !1!1 o&r2 N)r r r r r r r r r2 r0 r r } s &O 1('r2 r c e Zd Zd Zd Zy)ClientMethodAliasc || _ y)zAliases a non-extant method to an existing method. :param actual_name: The name of the method that actually exists on the client. N)_actual)r actual_names r0 r zClientMethodAlias.__init__ s # r2 c . t || j S r, )getattrr )r clientr/ s r0 __call__zClientMethodAlias.__call__ s vt||,,r2 N)r r r r r r r2 r0 r r s #-r2 r c b e Zd ZdZ ej dej Zd Zd Z d Z d Z y)HeaderToHostHoisterz;Takes a header and moves it to the front of the hoststring.z(?!-)[a-z\d-]{1,63}(?<!-)$c || _ y r, ) _header_name)r header_names r0 r z HeaderToHostHoister.__init__ s 'r2 c | j |d vry|d | j }| j | |d }| j || }||d< y)a Hoist a header to the hostname. Hoist a header to the beginning of the hostname with a suffix "." after it. The original header should be removed from the header map. This method is intended to be used as a target for the before-call event. r6 Nr )r _ensure_header_is_valid_host_prepend_to_host)r r; r/ header_value original_urlnew_urls r0 hoistzHeaderToHostHoister.hoist sa F9$5 5 i():):; )),7 e} '' lC u r2 c V | j j | }|s t d y )Nz`Hostnames must contain only - and alphanumeric characters, and between 1 and 63 characters long.r )_VALID_HOSTNAMEmatchr )r headerr s r0 r z0HeaderToHostHoister._ensure_header_is_valid_host s2 $$**62&< r2 c t | }|j j d }|g|z }dj | }|j ||j |j df}t | }|S )Nr r )r netlocrA joinschemepathqueryr )r r prefixurl_componentsparts new_netlocnew_componentsr s r0 r z$HeaderToHostHoister._prepend_to_host ss !# %%++C05 XXe_ ! ! ^,r2 N) r r r __doc__recompile IGNORECASEr r r r r r r2 r0 r r s0 E bjj!> NO( r2 r c V | j sy | j j |d d< y )Nr6 zx-amz-api-version) is_endpoint_discovery_operation service_model api_version)r r; r/ s r0 #inject_api_version_header_if_neededr s* 0 0-2-@-@-L-LF9)*r2 c d| v r| d= yy)z>Operation requires h2 which is currently unsupported in Pythonstart_conversationNr )class_attributesr/ s r0 remove_lex_v2_start_conversationr s // 1 2 0r2 c | j j d }|sy | j }|d |d< d}|D cg c] }||v r | d|| }}dj | |d< y c c}w )Nretriesz invocation-idzamz-sdk-invocation-id)ttlattemptmax=z; zamz-sdk-request)rm r- r6 r )ra r/ retries_contextr6 sdk_retry_keysr sdk_request_headerss r0 add_retry_headersr s oo)))4O ooG'6'GG #$.N "!C / ! %q %&'! "&+>!?G s A%c |j d }d}|j | rK|t | d |j d< |j d d }||k( }|r| dn||j d< yy)a Strips leading `{Bucket}/` from any operations that have it. The original value is retained in a separate "authPath" field. This is used in the HmacV1Auth signer. See HmacV1Auth.canonical_resource in botocore/auth.py for details. This change is applied to the operation model during the first time the operation is invoked and then stays in effect for the lifetime of the client object. When the ruleset based endpoint resolver is in effect, both the endpoint ruleset AND the service model place the bucket name in the final URL. The result is an invalid URL. This handler modifies the operation model to no longer place the bucket name. Previous versions of botocore fixed the URL after the fact when necessary. Since the introduction of ruleset based endpoint resolution, the problem exists in ALL URLs that contain a bucket name and can therefore be addressed before the URL gets assembled. requestUriz /{Bucket}Nrm r r authPath)r rj lenrA )r; r rm r/ req_uri bucket_path needs_slashs r0 'remove_bucket_from_url_paths_from_modelr s~ & jj &G K+&#*3{+;+=#> < --$Q' , 2=G9A 7 : 'r2 c t d |j D }|j 0|j j d dk( r|r|j d= yyyy)aP Removes the `{AccountId}.` prefix from the operation model. This change is applied to the operation model during the first time the operation is invoked and then stays in effect for the lifetime of the client object. When the ruleset based endpoint resolver is in effect, both the endpoint ruleset AND the service model place the {AccountId}. prefix in the URL. The result is an invalid endpoint. This handler modifies the operation model to remove the `endpoint.hostPrefix` field while leaving the `RequiresAccountId` static context parameter in place. c 3 Z K | ]# }|j d k( xr |j du % yw)RequiresAccountIdTN)r r| ).0 ctx_params r0 <genexpr>z6remove_accid_host_prefix_from_model.<locals>.<genexpr>8 s3 8I --I)//T2II8s )+N hostPrefixz {AccountId}.)anystatic_context_parametersendpointr- )r; r rm r/ has_ctx_params r0 #remove_accid_host_prefix_from_modelr + sb 88 M " NN | , > NN< ( ? #r2 c | j }t |t rq|j d r_|j d }t | dkD r?t j t |d r dj dg|dd | _ y y y y y )Nz/arn%3Ar rd r ) auth_pathr r rj rA r r is_arnr r )ra r/ r auth_path_partss r0 remove_arn_from_signing_pathr D s !!I)S!i&:&:9&E#//#. ! # (8(8 OA& ') !$")Cqr/B)C DG ) # 'F!r2 c |j d }|duxr t j | }|j dk( rd| t j < n|rd| t j < |duxr t j | }| t j }|j d rF|sC|s@|s=t j | s'd| t j < d| t j < yyyyyy)a Modify builtin parameter values for endpoint resolver Modifies the builtins dict in place. Changes are in effect for one call. The corresponding event is emitted only if at least one builtin parameter value is required for endpoint resolution for the operation. r NGetBucketLocationTFuse_global_endpointz aws-global) r- r r r r AWS_S3_FORCE_PATH_STYLEr r r is_s3express_bucket AWS_REGIONAWS_S3_USE_GLOBAL_ENDPOINT) builtinsr r; rm r/ bucket_name bucket_is_arnpath_style_requiredpath_style_requesteds r0 $customize_endpoint_resolver_builtinsr N s **X&K t+M 0@0@0MM zz((EI)AAB EJ)AAB 4 N(;(A(A+(N$N $ 88 )*#$ ))+68D)445HL)DDE 7 % $ +r2 c x | j j d du r d| j v r| j d= y y y )Nis_presign_requestTrn )rm r- r6 r` s r0 )remove_content_type_header_for_presigningr | s< 01T9 goo - OON + . :r2 zchoose-service-namez/getattr.mturk.list_hi_ts_for_qualification_type list_hits_for_qualification_typez$before-parameter-build.s3.UploadPartz#before-parameter-build.s3.PutObjectzcreating-client-classzcreating-client-class.s3z creating-client-class.iot-dataz$creating-client-class.lex-runtime-v2zafter-call.iamz after-call.ec2.GetConsoleOutputz%after-call.cloudformation.GetTemplatez after-call.s3.GetBucketLocationzbefore-parameter-buildzbefore-parameter-build.s3z%before-parameter-build.s3.ListObjectsz'before-parameter-build.s3.ListObjectsV2z,before-parameter-build.s3.ListObjectVersionsz$before-parameter-build.s3.CopyObjectz(before-parameter-build.s3.UploadPartCopyz/before-parameter-build.s3.CreateMultipartUploadz!before-parameter-build.s3-controlz%docs.*.s3.CopyObject.complete-sectionz)docs.*.s3.UploadPartCopy.complete-sectionz before-endpoint-resolution.s3z before-callzbefore-call.s3zbefore-call.glacierzbefore-call.apigatewayzbefore-call.s3.PutObjectzbefore-call.s3.UploadPartz before-call.s3.DeleteObjectsz.before-call.s3.PutBucketLifecycleConfigurationz!before-call.glacier.UploadArchivez'before-call.glacier.UploadMultipartPartz before-call.ec2.CopySnapshotzrequest-createdz'request-created.machinelearning.Predictz needs-retry.s3.UploadPartCopyzneeds-retry.s3.CopyObjectz&needs-retry.s3.CompleteMultipartUploadz$choose-signer.cognito-identity.GetIdz-choose-signer.cognito-identity.GetOpenIdTokenz-choose-signer.cognito-identity.UnlinkIdentityz8choose-signer.cognito-identity.GetCredentialsForIdentityz$choose-signer.sts.AssumeRoleWithSAMLz+choose-signer.sts.AssumeRoleWithWebIdentityz choose-signerz$before-parameter-build.s3.HeadObjectz#before-parameter-build.s3.GetObjectz1before-parameter-build.s3.CompleteMultipartUploadz-before-parameter-build.s3.SelectObjectContentz'before-parameter-build.ec2.RunInstancesz<before-parameter-build.autoscaling.CreateLaunchConfigurationz before-parameter-build.route53z before-parameter-build.glacierzbefore-sign.s3z"before-sign.polly.SynthesizeSpeechzafter-call.s3.ListObjectszafter-call.s3.ListObjectsV2z after-call.s3.ListObjectVersionsz(request-created.cloudsearchdomain.Searchz!docs.*.glacier.*.complete-sectionrE zJNote: this parameter is set to "-" bydefault if no value is not specified.z-docs.*.glacier.UploadArchive.complete-sectionrX z3docs.*.glacier.UploadMultipartPart.complete-sectionzDdocs.request-params.glacier.CompleteMultipartUpload.complete-sectionz2docs.*.cloudformation.GetTemplate.complete-sectionz(docs.*.ec2.RunInstances.complete-sectionr, z=docs.*.autoscaling.CreateLaunchConfiguration.complete-sectionz(docs.*.ec2.CopySnapshot.complete-sectionr r z docs.*.s3.*.complete-sectionSSECustomerKeyMD5CopySourceSSECustomerKeyMD5z1docs.*.lambda.UpdateFunctionCode.complete-sectionZipFiler) ContentMD5) DeleteObjects PutBucketAcl PutBucketCorsPutBucketLifecyclePutBucketLoggingPutBucketNotificationPutBucketPolicyPutBucketReplicationPutBucketRequestPaymentPutBucketTaggingPutBucketVersioningPutBucketWebsite PutObjectAclzcreating-client-class.rdsz%before-call.rds.CopyDBClusterSnapshotz before-call.rds.CreateDBClusterz before-call.rds.CopyDBSnapshotz+before-call.rds.CreateDBInstanceReadReplicaz:before-call.rds.StartDBInstanceAutomatedBackupsReplicationz1docs.*.rds.CopyDBClusterSnapshot.complete-sectionr z+docs.*.rds.CreateDBCluster.complete-sectionz*docs.*.rds.CopyDBSnapshot.complete-sectionz7docs.*.rds.CreateDBInstanceReadReplica.complete-sectionzFdocs.*.rds.StartDBInstanceAutomatedBackupsReplication.complete-sectionz)before-call.neptune.CopyDBClusterSnapshotz#before-call.neptune.CreateDBClusterz5docs.*.neptune.CopyDBClusterSnapshot.complete-sectionz/docs.*.neptune.CreateDBCluster.complete-sectionz'before-call.docdb.CopyDBClusterSnapshotz!before-call.docdb.CreateDBClusterz3docs.*.docdb.CopyDBClusterSnapshot.complete-sectionz-docs.*.docdb.CreateDBCluster.complete-section)r )r rt r loggingr9 r r rg ior rh botocore.authr botocore.compatr r r r r r r r r r r botocore.docs.utilsr r r botocore.endpoint_providerr botocore.exceptionsr r r botocore.regionsr botocore.signersr r r botocore.utilsr r r r r r r! r" r# r$ r% r& r' getLoggerr rG objectr REGISTER_LASTr r _ACCESSPOINT_ARN _OUTPOST_ARNr r rl r r1 r> rD rM rF ro r} r r r r r r r r r r r r r r r r r r r r r r* r- r4 r: rC rG rK rN rV rZ r] rb rk rp rt r r r r r r r r r r r r r r r r r document_auto_populated_param hide_paramBUILTIN_HANDLERSr r2 r0 <module>rB sZ ; 6 " ) 5 / 0 / 8 $ rzz56 B rzz#(($4l#CDE J BJJ 56 @P (>$1!h A > 5$.)" 9 & & " JF6&I.- / )0 95, * ' 9>H0"? !BJ" " 7 &>'" , G 5 6B/' /'d - - . .bM 3 @ KD)2E+M\,@ 56@ :<=@ /( @ .(@ 89!@" !<=#@$ &'MN%@& ,-MN'@( +,)@* '(=>+@, -.GH-@. '(AB/@0 781@2 !"673@4 !"IJ5@8 0*7@@ 2*?@H 7*G@N ,-EFO@P 01IJQ@R ,-DES@T +,CDU@X : W@^ )*MN_@` -.GHa@b 12KLc@d %&JKe@f 23g@h ()i@j /0k@l 01m@n !ABo@p !"=>q@r $%78s@t $%EFu@v 67IJw@x )*?@y@z /0EF{@| $%=>}@~ )*@@ /0KLA@B %&9>JC@D !"5~FE@H 1G@P ,_=Q@R 5oFS@T 5oFU@X CW@^ ,_=_@` 3ODa@b 34c@d ,W5e@f +G4g@h +G4i@j ,W5k@l ,-@Am@n 7@o@p ,W5q@r 09s@t 01DEu@v 9'Bw@x 5g>y@z /0GH{@~ G }@D &7E@F &'89G@H 34I@L -1K@R !"45S@T #$9:U@V ()DEW@Z 01CD[@` , 4 ( ' _@p 8:&DDo@x >:&DDw@@ O+-@J =8I@T 3 ,S@\ H ,[@f 3>*HHe@n 3./MMm@x './MMw@B ' ) ' ' A@P < +O@Z ' $ *)Y@J !"<=K@L -.FGM@N '(@AO@P &'?@Q@R 34LMS@V E U@` <>*HH_@h 6>*HHg@p 5>*HHo@x B>*HHw@@ Q>*HH@L 12JKM@N +,DEO@T @>*HHS@\ :>*HH[@h /0HIi@j )*BCk@p >>*HHo@x 8>*HHw@~ 78@ B ' (r2