h<dZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Zddl mZddlmZddlmZmZdd lmZmZmZej2eZd d gZgd Zd ZdZdZ dZ!GddZ"GddZ#Gdde$e#Z%y)zInternal module to help with normalizing botocore client args. This module (and all function/classes within this module) should be considered internal, and *not* a public API. N)Config)EndpointCreator)EndpointResolverBuiltins)EndpointRulesetResolver) RequestSigner)UserAgentStringregister_feature_id)$PRIORITY_ORDERED_SUPPORTED_PROTOCOLSensure_booleanis_s3_accelerate_urllegacyregional)zap-northeast-1z ap-south-1zap-southeast-1zap-southeast-2 aws-globalz ca-central-1z eu-central-1z eu-north-1z eu-west-1z eu-west-2z eu-west-3z sa-east-1 us-east-1z us-east-2z us-west-1z us-west-22)when_supported when_required) preferreddisabledrequiredceZdZ d&dZ d'dZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZd&dZdZdZdZdZdZdZdZdZdZdZdZ d Z!d!Z"d"Z#d#Z$d$Z%d%Z&y)(ClientArgsCreatorNc||_||_||_||_||_|t j |_y||_yN)_event_emitter_response_parser_factory_loader_exceptions_factory _config_storerfrom_environment_session_ua_creator)self event_emitter user_agentresponse_parser_factoryloaderexceptions_factory config_storeuser_agent_creators i/home/developers/rajanand/mypropertyqr-fmb-refixing-v2/venv/lib/python3.12/site-packages/botocore/args.py__init__zClientArgsCreator.__init__VsJ,(?% #5 )  %'6'G'G'ID $'9D $c |j||| ||||} | d}| d}| d}| d}| d}| d}|djdd}| d }| d }|d }|d }|d }tj|j}t |j ||d|d||| }||d<t di|}t|}|j|||d||j|j|j|j|jf||j|j }t j"j%||}t j&j)|} |j+| | |||||||| ||| }!|j,j/|}"|r |j0nd}#|#|_||| ||||j4|||j6|!|"d S)N service_nameparameter_validationendpoint_configprotocol config_kwargs s3_configmetadata partitionsocket_optionsconfigured_endpoint_urlsigning_region region_nameaccount_id_endpoint_mode signing_namesignature_versions3 endpoint_url) r9r>verifyr%max_pool_connectionsproxiestimeoutr6 client_certproxies_config) serializerendpointresponse_parserr#request_signer service_modelr& client_configr5r'endpoint_ruleset_resolverr))compute_client_argsgetcopyrr service_idrrcreate_endpointrr@rAconnect_timeout read_timeoutrCrDbotocore serializecreate_serializerparsers create_parser_build_endpoint_resolverr!with_client_configr$_supplied_user_agentrr)$r"rIr9 is_securer>r? credentials scoped_configrJendpoint_bridge auth_tokenendpoints_ruleset_datapartition_data final_argsr.r/r0r1r2r3r5r6r7r8endpoint_region_namer:r#signer new_configendpoint_creatorrFrErGruleset_resolverclient_ua_creator supplied_uas$ r*get_client_argsz!ClientArgsCreator.get_client_argsjsj--        ".1 )*@A$%67j)"?3 {+ #J/33KF #$45",-F"G()9:.}=#01K#L  $"5"56   $ $  N + / 0    ( d,m, *=9#33 ,(8$($A$A!+!@!@&&//1H1HI)"..%444  ''99 * #**88B88 "     #      $ "!44GG  3@m..T *5 '% .*$*ll'""&":":)9"3  r,c|j}|j} d} |r|jsd} n |r|jd} | t | } |j |} |j ||} | td|j||| ||| }|djdg}|jj|j}t|d |d | }d |vr|jd d|vr|jd||j|j|j|j |j"|j$|j&|j(|j*|j,|j.|j0|j2|j4|j6|j8|j:|j<|j>|j@|jC||jE||jG||jI||jK||jM||jO||jQ|||jS|||jU|||j |} |jW|}|r d |vr | i} d| d<|| | || || |jY||dS)NTFr/)rJr>ENDPOINT_OVERRIDE)r.r9r>r\r_r3r4tagsr9r<)r9r<r$ dualstack)use_dualstack_endpointfips)use_fips_endpoint)rRrSr@rArDretriesrCinject_host_prefix tcp_keepaliveuser_agent_extrauser_agent_appid"request_min_compression_size_bytesdisable_request_compressionclient_context_paramssigv4a_signing_region_setrequest_checksum_calculationresponse_checksum_validationr:auth_scheme_preferencerp)r.r/r7r0r1r2r3r6)-endpoint_prefixresolved_protocolr/rNr compute_s3_config _compute_configured_endpoint_urlr _compute_endpoint_configr!rZ to_stringdictupdaterRrSr@rArDrsrCrtrurvrwrxryrzr{r|r}r:r~_compute_retry_config_compute_connect_timeout _compute_user_agent_appid_config#_compute_request_compression_config)_compute_sigv4a_signing_region_set_config_compute_checksum_config(_compute_account_id_endpoint_mode_config_compute_inject_host_prefix&_compute_auth_scheme_preference_config!_compute_signature_version_config_is_s3_service_compute_socket_options)r"rIrJr_r9r>r\r^r.r1r/ raw_valuer3r7r0endpoint_variant_tagspreliminary_ua_stringr2 is_s3_services r*rMz%ClientArgsCreator.compute_client_argss(%44  22# !C!C#( %))*@AI$'5i'@$**=9 "&"G"G'%#H#  # .  3 477%#0+ 8 !0 ; ? ? K!% 8 8 K K ! )+  ' 6-.AB, / /   = * *  4 8  $  - = =*77%2%G%G%--,;;%--)55#0#C#C+99!.!?!?!.!?!?!DD"==&3&I&I!;;">>">>)6)O)O'4'K'K; ! > ""=1 %%m4 --m< 00? 66}E %%m4 55mD (( F 33 =  ..}mL**=9 ++L9 [,AA  26I. /)$8'>. *""::}  r,cz||jdk(r*|jjd}|| |d<yd|d<yy)NUNSETdisable_host_prefix_injectionrtT)_inject_host_prefixrget_config_variable)r"rJr2(configured_disable_host_prefix_injections r*rz-ClientArgsCreator._compute_inject_host_prefixVsf  !00G;""663 5 8CA@(7; 23) _ignore_configured_endpoint_urlsloggerdebugrr)r"rJr>s r*rz2ClientArgsCreator._compute_configured_endpoint_urlisF  #   0 0 ? LL= > !!55nEEr,cl|r|j |jS|jjdS)Nignore_configured_endpoint_urls)rrr)r"rJs r*rz2ClientArgsCreator._ignore_configured_endpoint_urlsss9 ==I @@ @!!55 -  r,c|jjd}|G|j;||j}|S|j}|j |j|S)Nr=)rrr=rOr)r"rJs3_configurations r*rz#ClientArgsCreator.compute_s3_config~sr--AA$G  $+#+'4'7'7$ (8'<'<'>$$++M,<,<=r,c |dvS)a,Whether the service is S3 or S3 Control. Note that throughout this class, service_name refers to the endpoint prefix, not the folder name of the service in botocore/data. For S3 Control, the folder name is 's3control' but the endpoint prefix is 's3-control'. )r=z s3-controlrL)r"r.s r*rz ClientArgsCreator._is_s3_services333r,c|||||d}|dk(r|jdd|i|S|dk(r|jdi|S|jdi|S)N)r.r9r>r\r_r=r3stsrL)_compute_s3_endpoint_config_compute_sts_endpoint_config_resolve_endpoint)r"r.r9r>r\r_r3resolve_endpoint_kwargss r*rz*ClientArgsCreator._compute_endpoint_configs)&(". #  4 3433#'>  5 4444O7NO O%t%%@(?@@r,c |j|d|}|rd|d<|jdi|}|j||d|r |ddk(rd|d<|S)Nr9r_rrrL)_should_force_s3_globalr!_set_region_if_custom_s3_endpoint)r"r3rforce_s3_globalr0s r*rz-ClientArgsCreator._compute_s3_endpoint_configs66 #M 2I  59 #M 20$00K3JK .. 45FG  }=M-8OM *r,cXd}|rd|vr|d}|j||dv}|dk(xr|S)Nr us_east_1_regional_endpoint)rN)_validate_s3_regional_config)r"r9r3s3_regional_configis_global_regions r*rz)ClientArgsCreator._should_force_s3_globalsK% 6)C!*+H!I   - -.@ A&*==!X-B2BBr,cT|tvr tjj|y)N)%s3_us_east_1_regional_endpoint_config)VALID_REGIONAL_ENDPOINTS_CONFIGrT exceptions+InvalidS3UsEast1RegionalEndpointConfigError)r" config_vals r*rz.ClientArgsCreator._validate_s3_regional_configs2 < <%%QQ6@R  =r,c^|d(|d"|jd}|d|d<|d|d<yyy)Nr8r9r=resolve)r"r0r_rFs r*rz3ClientArgsCreator._set_region_if_custom_s3_endpointsU , - 5 .6&..t4H089I0JO, --5m-DOM * 7 6r,c |jdi|}|j|d|d|r|j||d|S)Nr9r>r\rL)r_should_set_global_sts_endpoint_set_global_sts_endpoint)r"rr0s r*rz.ClientArgsCreator._compute_sts_endpoint_configs\0$00K3JK  / / #M 2 #N 3   ) )!8!E r,c|xr!|jdijd}|s|ry|jdk(xr|tvS)Nr4rnFr )rN"_get_sts_regional_endpoints_configLEGACY_GLOBAL_STS_REGIONS)r"r9r>r0has_variant_tagss r*rz1ClientArgsCreator._should_set_global_sts_endpoints[+/B/B 0 #f+  +  3 3 5 A 988 r,c|jjd}|sd}|tvr tjj ||S)Nsts_regional_endpointsr)sts_regional_endpoints_config)rrrrTr&InvalidSTSRegionalEndpointsConfigError)r"rs r*rz4ClientArgsCreator._get_sts_regional_endpoints_configs^(,(:(:(N(N $) %-,6 ) )2 3%%LL.KM -,r,c*|rdnd}|d|d<d|d<y)Nhttpshttpz://sts.amazonaws.comr>rr8rL)r"r0r\schemes r*rz*ClientArgsCreator._set_global_sts_endpoint s(%6-3H4H*I',7()r,c*|j||||Srr)r"r.r9r>r\r_s r*rz#ClientArgsCreator._resolve_endpoints && +|Y  r,ctjtjdfg}|xr |j}|xr!|j |j dd}|s|r0|j tjtjdf|S)NruF) socket IPPROTO_TCP TCP_NODELAYru_ensure_booleanrNappend SOL_SOCKET SO_KEEPALIVE)r"r^rJr6client_keepalivescoped_keepalives r*rz)ClientArgsCreator._compute_socket_optionss"--v/A/A1EF(H]-H-H( T-A-A   ou 5.  /  ! !6#4#4f6I6I1"M Nr,cH|j||j|yr)_compute_retry_max_attempts_compute_retry_moder"r2s r*rz'ClientArgsCreator._compute_retry_config+s ((7   /r,c|jd}|5d|vr|jddyd|vr|jd}|dz|d<y|jjd}||i}||d<||d<yy)Nrstotal_max_attempts max_attemptsr)rNpoprr)r"r2rsvaluers r*rz-ClientArgsCreator._compute_retry_max_attempts/s ##I.  #w. ND1( N316 ,-))==nM  #+2 i(,8G( ) $r,c|jd}|i}||d<nd|vry|jjd}|d}||d<y)Nrsmode retry_moder rNrr)r"r2rsrs r*rz%ClientArgsCreator._compute_retry_modeOs]##I. ?G'.M) $ w  '';;LI  !J$r,cr|jd}|y|jjd}|r||d<yy)NrRr)r"r2rRs r*rz*ClientArgsCreator._compute_connect_timeout]sL(++,=>  & ,,@@   />M+ , r,c |jd}|jd}||jjd}|j|}||d<||jjd}n t |}||d<y)Nrxry)rNrr_validate_min_compression_sizer )r"r2min_sizers r*rz5ClientArgsCreator._compute_request_compression_configjs $$%IJ $$%BC  ))==4H 66x@>F :;  ))==-H &h/H7? 34r,c*d}d}d|d} t|}||cxkr|ks-n|d|d |d }tj j ||S#ttf$r2|dt|d}tj j |wxYw) NrizInvalid value "z)" for request_min_compression_size_bytes.z$ Value must be an integer. Received z instead. error_msgz Value must be between z and .)int ValueError TypeErrortyperTrInvalidConfigError)r"rmin_allowed_min_sizemax_allowed_min_sizeerror_msg_basemsgs r*rz0ClientArgsCreator._validate_min_compression_sizes &hZ(2 2  H8}H$xG3GG!""9'(.B-C1F %%8838G GI& H!"# N+96 %%8838G G  Hs AABcLt|tr|S|jdk(S)Ntrue) isinstanceboollower)r"vals r*rz!ClientArgsCreator._ensure_booleans" c4 J99;&( (r,c Z|y|j|xsi}|j}|dvs||}n|}|j|||| ||j| | }||jxsi}ni}|j |r|j || |jnd}t|||||| | |S)N)r=r)r9r.r3r_client_endpoint_urllegacy_endpoint_urlr]r:)endpoint_ruleset_datarbrIbuiltinsclient_contextr#use_sslrequested_auth_scheme) rr*compute_endpoint_resolver_builtin_defaultshostrzrrr<r)r"rarbrJrIrdr9r>rFr\r_r#r]r: s3_config_rawservice_name_raweprv2_region_nameresolver_builtinsr sig_versions r*rYz*ClientArgsCreator._build_endpoint_resolvers " )..}=C (88 } , 0C 4  +  KK))#+ , ( #%=L    $*@@FBNN   / 0  ! !- 0(  + +  '"8)'&)'"-  r,c |r|} n|js|} nd} |jddrd} n6| t|s|jddk7} n|jddk(} tj|tj | duxr|j dxsdtj| duxr|j|xsdtj|j|ddtj|j||tj|jddtj| tj|jdd tj |jddtj"|jd dtj$| tj&|r|j)d ndtj*|i S) Nuse_accelerate_endpointFaddressing_stylevirtualpathrr)r9r>r0use_arn_regionT$s3_disable_multiregion_access_points account_id)resolver_uses_builtin_datarNr EPRBuiltins AWS_REGION AWS_USE_FIPS$_resolve_endpoint_variant_config_varAWS_USE_DUALSTACK_resolve_use_dualstack_endpointAWS_STS_USE_GLOBAL_ENDPOINTrAWS_S3_USE_GLOBAL_ENDPOINTrAWS_S3_ACCELERATEAWS_S3_FORCE_PATH_STYLEAWS_S3_USE_ARN_REGIONAWS_S3CONTROL_USE_ARN_REGIONAWS_S3_DISABLE_MRAP SDK_ENDPOINT ACCOUNT_IDget_deferred_propertyACCOUNT_ID_ENDPOINT_MODE) r"r9r.r3r_rrr]r:given_endpointforce_path_styles r*rzsl(,,-?@  ##11EE"    ($%(>> NN3&  -= ()r,cj|jd}||jjd}||d<y)Nr{r)r"r2r{s r*rz;ClientArgsCreator._compute_sigv4a_signing_region_set_configOsF$1$5$5 '% ! % ,(,(:(:(N(N+) %6O 12r,cd|j|dt|j|dty)Nr|) config_key valid_optionsr})_handle_checksum_config)VALID_REQUEST_CHECKSUM_CALCULATION_CONFIG)VALID_RESPONSE_CHECKSUM_VALIDATION_CONFIGrs r*rz*ClientArgsCreator._compute_checksum_configYs< $$ 5C % $$ 5C % r,c|j|}||jj|}t|tr|j }||vr"t jj||||j|||||<y)N)r. config_valuer/) rNrrrstrrrTrInvalidChecksumConfigError%_register_checksum_config_feature_ids)r"r2r.r/rs r*r0z)ClientArgsCreator._handle_checksum_configes !!*- =&&:::FE eS !KKME  %%%@@%"+A  225*E$) j!r,cd}|dk(rd|j}n|dk(rd|j}| t|yy)Nr|FLEXIBLE_CHECKSUMS_REQ_r}FLEXIBLE_CHECKSUMS_RES_)upperr )r"rr.checksum_config_feature_ids r*r7z7ClientArgsCreator._register_checksum_config_feature_ids{s\%)" 7 7)%++-9 '9 9)%++-9 ' & 1  : ; 2r,c ld}|jd}|tjurd||<y|j|}||jj |}t |t r|j}|tvr.tjjd|d|dtd|||<y) Nr:r<rzThe configured value 'z' for 'z ' is invalid. Valid values are: rr) rNrTUNSIGNEDrrrr5r%VALID_ACCOUNT_ID_ENDPOINT_MODE_CONFIGrr)r"r2r.r<r:s r*rz:ClientArgsCreator._compute_account_id_endpoint_mode_configs/ *--.AB  1 1 1(2M* % #0#4#4Z#@ # +'+'9'9'M'M( $ . 4'?'E'E'G $ %8 9%%8823K2LGT^S_`..S-TTUW9  %= j!r,cd}d}|r|jr|j}d}n|jj|}|d||<yt|ts2t j j|dt|d|ddjd |jdD}|r t|}|||<y) Nr~FTz, must be a comma-delimited string. Received z instead: rr,c3K|]6}|jr$|jddjdd8yw)  N)stripreplace).0items r* zKClientArgsCreator._compute_auth_scheme_preference_config..s9 zz| LLb ! ) )$ 3 s<>) r~rrrr5rTrrrjoinsplitClientConfigString)r"rJr2r.set_in_config_objectrs r*rz8ClientArgsCreator._compute_auth_scheme_preference_configs. $ ]AA!88E#' &&:::FE =(,M* % %%%%88!l# $U }JugQ@9   C(   &u-E$) j!r,cz|r9|jr,|j}t|trt||d<yyyy)Nr<)r<rr5rM)r"rJr2rs r*rz3ClientArgsCreator._compute_signature_version_configs> ]<<!33E%%5G5N 12&==r,r)NNN)'__name__ __module__ __qualname__r+rkrMrrrrrrrrrrrrrrrrrrrrrrrrYrrrrr0r7rrrrLr,r*rrUs :>#l \| |;&F   &4A0*C E    -8   09@ % ?@,0) B HZ x="O  *, <=rhs  "-D4*C   8 $ #(-)-) )%x Ox Ov  +1+r,