iVdZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z ddl mZddlmZddlmZej&eZdadaej0ZdZhd Zd Zd Zd Zd ZdZ GddZ!dZ"dZ#dZ$dZ%y)a6 This file contains private functionality for interacting with the AWS Common Runtime library (awscrt) in boto3. All code contained within this file is for internal usage within this project and is not intended for external consumption. All interfaces contained within are subject to abrupt breaking changes. N)Session)BotocoreCRTCredentialsWrapperBotocoreCRTRequestSerializerCRTTransferManageracquire_crt_s3_process_lockcreate_s3_crt_client)TRANSFER_CONFIG_SUPPORTS_CRT)InvalidCrtTransferConfigError)CRT_TRANSFER_CLIENTboto3>max_concurrencymultipart_chunksizemultipart_thresholdmax_request_concurrencypreferred_transfer_clientc$|d|d}tdi|S)zCreate a CRT S3 Client for file transfer. Instantiating many of these may lead to degraded performance or system resource exhaustion. T)regionuse_sslcrt_credentials_provider)r)sessionconfig region_name cred_providercreate_crt_client_kwargss `/var/www/acinvestment.org/public_html/aci/backend/venv/lib/python3.12/site-packages/boto3/crt.py_create_crt_clientr:s&$1  ;": ;;c t||ddS)N)r endpoint_url)r)rrs r_create_crt_request_serializerr!Hs 'dC rc lt|}|j}tt|||||||S)zFCreate boto3 wrapper class to manage crt lock reference and S3 client.)rto_crt_credentials_provider CRTS3Clientr)rrr credentialslockkwargs cred_wrapperrs r_create_crt_s3_clientr)Ns@1=L <<>M 7FKG   rctt}|yt}|jj}|j }t ||}t|||||}||fS)N)NN)rPROCESS_LOCK_NAMErmetar_get_credentialsr!r))clientrr&rrr% serializer s3_clients r#_initialize_crt_transfer_primativesr1\si &'8 9D |iG++))K))+K/EJ%k4I y  rct5tt||\}}|a|adddtS#1swYtSxYwN)CLIENT_CREATION_LOCK CRT_S3_CLIENTr1BOTOCORE_CRT_SERIALIZER)r.rr/r0s rget_crt_s3_clientr7osN &  $G% !J '1 #%M & & s/=ceZdZdZdZy)r$a This wrapper keeps track of our underlying CRT client, the lock used to acquire it and the region we've used to instantiate the client. Due to limitations in the existing CRT interfaces, we can only make calls in a single region and does not support redirects. We track the region to ensure we don't use the CRT client when a successful request cannot be made. c<||_||_||_||_yr3) crt_client process_lockrr)selfr:r;rrs r__init__zCRTS3Client.__init__s $( *rN)__name__ __module__ __qualname____doc__r=rrrr$r$~s +rr$c|y|j}|yt|j|j}|jj |j k(}|xr|S)z Boto3 client must use same signing region and credentials as the CRT_S3_CLIENT singleton. Otherwise fallback to classic. F)r-compare_identityget_frozen_credentialsrr,rr)r. crt_s3_client boto3_credsis_same_identityis_same_regions ris_crt_compatible_requestrIsk ))+K'**,m.I.I[[,, 0D0DDN  ...rc |}|j|jk(xr4|j |j k(xr|j|jk(}|S#tjj$rYywxYw)NF) botocore exceptionsNoCredentialsError access_key access_key_id secret_keysecret_access_keytoken session_token)rF crt_s3_creds crt_credsis_matching_identitys rrCrCs N )"9"99 9  " "i&A&A A 9   !8!8 8     1 1sAA:9A:c@|y|jtk7ryg}|jjD]<}|j |}|t vs||j us,|j|>t|dkDrtddj|dy)Nrz`The following transfer config options are invalid when preferred_transfer_client is set to crt: z, `) rr DEFAULTSkeys get_deep_attr$_ALLOWED_CRT_TRANSFER_CONFIG_OPTIONS UNSET_DEFAULTappendlenr join)rinvalid_crt_argsparamvals r_validate_crt_transfer_configrds ~''+>>%%'+""5) = =6///  # #E * + q + =yy)*+1 .  !rct||}t||rQ|jtd}trt |||d<ts|rt jdtdi|Sy)z8Create a CRTTransferManager for optimized data transfer.)rEcrt_request_serializerrzfUsing TransferConfig with CRT client requires s3transfer >= 0.16.0, configured values will be ignored.Nr) r7rIr:r6r rdloggerwarningr)r.rrEcrt_transfer_manager_kwargss rcreate_crt_transfer_managerrjso%ff5M 7*55&=' # ( )& 14: ' 1+ NNK "@$?@@ r)&rAlogging threadingbotocore.exceptionsrKbotocore.sessionrs3transfer.crtrrrrr boto3.compatr boto3.exceptionsr boto3.s3.constantsr getLoggerr>rgr5r6Lockr4r+r\rr!r)r1r7r$rIrCrdrjrrrrus$6:2   8 $ %y~~'($ < !& ++"/&   0r