Dh<dZddlZddlZddlZddlmZddlmZmZddl m Z ddl m Z m Z ddlmZddlmZmZe rdd lmZndZej,eZGd d ZGd d eZGddeZGddeZGddeZGddeZGddZGddeZ dZ! d&dZ"dZ#dZ$dZ% d&dZ&d Z'd!Z(d"Z)eeed#Z*e re*jWeed$e,e*j[Z.gd%Z/y)'aC The interfaces in this module are not intended for public use. This module defines interfaces for applying checksums to HTTP requests within the context of botocore. This involves both resolving the checksum to be used based on client configuration and environment, as well as application of the checksum to the request. N)crc32)sha1sha256)HAS_CRT)AwsChunkedWrapperErrorFlexibleChecksumError) StreamingBody)conditionally_calculate_md5determine_content_length) checksumsc.eZdZdZdZdZdZdZdZy) BaseChecksumcyNselfchunks w/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/botocore/httpchecksum.pyupdatezBaseChecksum.update. cyrrrs rdigestzBaseChecksum.digest1rrcj|j}tj|jdS)Nascii)rbase64 b64encodedecode)rbss r b64digestzBaseChecksum.b64digest4s) [[]#**733rcj}tfddD]}j|j|y)Nc:jjSr)read _CHUNK_SIZE)fileobjrsrz.BaseChecksum._handle_fileobj..:s',,t/?/?"@rr)telliterrseek)rr(start_positionrs`` r_handle_fileobjzBaseChecksum._handle_fileobj8s= @#F E KK   ^$rct|ttfr!|j||j S|j ||j Sr) isinstancebytes bytearrayrr.r#)rbodys rhandlezBaseChecksum.handle>sI dUI. / KK ~~   &~~rN) __name__ __module__ __qualname__r'rrr#r.r4rrrrr+s K  4%  rrceZdZdZdZdZy) Crc32Checksumcd|_yNr _int_crc32rs r__init__zCrc32Checksum.__init__G rc@t||jdz|_yNl)rr=rs rrzCrc32Checksum.updateJst7*Drc<|jjddSNbig) byteorderr=to_bytesrs rrzCrc32Checksum.digestM''U';;rNr5r6r7r>rrrrrr9r9FsEzCrtCrc32Checksum.__init__Sr?rcXtj||j}|dz|_yrA) crt_checksumsrr=rr new_checksums rrzCrtCrc32Checksum.updateVs$$**5$//B &3rc<|jjddSrCrGrs rrzCrtCrc32Checksum.digestZrIrNrJrrrrLrLQs4zCrtCrc32cChecksum.__init__`s rcXtj||j}|dz|_yrA)rOcrc32crVrPs rrzCrtCrc32cChecksum.updatecs'$++E43C3CD '*4rc<|jjddSrC)rVrHrs rrzCrtCrc32cChecksum.digestgs((e(<zSha1Checksum.__init__ls rc:|jj|yrr]rrs rrzSha1Checksum.updateo e$rc6|jjSrr]rrs rrzSha1Checksum.digestr~~$$&&rNrJrrrr[r[ks %'rr[ceZdZdZdZdZy)Sha256Checksumc"t|_yr)rr]rs rr>zSha256Checksum.__init__ws rc:|jj|yrr_rs rrzSha256Checksum.updatezr`rc6|jjSrrbrs rrzSha256Checksum.digest}rcrNrJrrrrerevs"%'rrec@eZdZdZ d dZdZd dZd dZdZdZ y) AwsChunkedWrapperrNcx||_||_||_|j| |j}||_yr)_raw_checksum_name _checksum_cls_reset_DEFAULT_CHUNK_SIZE _chunk_size)rraw checksum_cls checksum_name chunk_sizes rr>zAwsChunkedWrapper.__init__s= +)  11J%rcrd|_d|_d|_|jr|j|_yy)NrF) _remaining _completer]rnrs rrozAwsChunkedWrapper._resets5   !//1DN rc|dk7s|dk7r td|j|jjdy)Nrz Can only seek to start of stream error_msg)rrorlr,)roffsetwhences rr,zAwsChunkedWrapper.seeks: Q;&A+(<   qrc||dkrd}|jr |jsy|duxs|t|jkD}|jsR|rP|xj|jz c_|duxs|t|jkD}|js|rP|t|j}|jd|}|j|d|_|S)Nrr)rxrwlen _make_chunk)rsizewant_more_bytes to_returns rr&zAwsChunkedWrapper.reads   D >>$//$,E$T__1E*E.._ OOt//1 1O"dlIdS5I.IO.._ <t'DOOET* //$%0rc|jj|j}tt |ddj d}| |_|jr|jj||jrW|j rK|jj d}|jjj d}d||fzSd||fzS)Nrs 0 %s:%s s%s %s ) rlr&rqhexrencoderxr]rrmr#)r raw_chunkhex_lennamechecksums rrzAwsChunkedWrapper._make_chunksIINN4#3#34 c)n%ab)009& >> NN ! !) , >>dnn&&--g6D~~//188AH(D(+;; ;'9!555rc#dK|js |j|jsyywr)rxrrs r__iter__zAwsChunkedWrapper.__iter__s%..""$ $..s+00)Nzx-amz-checksumN)rr) r5r6r7rpr>ror,r&rrrrrrjrjs1% & & 226$%rrjc0eZdZfdZdfd ZdZxZS)StreamingChecksumBodycBt|||||_||_yr)superr>r] _expected)r raw_streamcontent_lengthrexpected __class__s rr>zStreamingChecksumBody.__init__s  ^4!!rct||}|jj|||s|dkDr|j |S)N)amtr)rr&r]r_validate_checksum)rrrrs rr&zStreamingChecksumBody.readsC  % e$ ;uq  # # % rc|jjtj|jk7r6d|jd|jj }t |y)NExpected checksum $ did not match calculated checksum: rz)r]rr b64decoderr#r)rr{s rrz(StreamingChecksumBody._validate_checksumsg >> "f&6&6t~~&F F$T^^$45!^^5578: ()< < Grr)r5r6r7r>r&r __classcell__)rs@rrrs" =rrc8t|||t|||yr)"resolve_request_checksum_algorithm$resolve_response_checksum_algorithms)requestoperation_modelparamss rresolve_checksum_contextrs&wH(/6Jrc|j}|jd}|r||vr|t}||j}||vrt d|zd}|j r|dj drd}||d|zd }|d |d vry|d jd i} || d<| |d d <y|js|jdr#|d jd i} d| d<| |d d <yy)NrequestAlgorithmMemberz"Unsupported checksum algorithm: %srzheaderurlzhttps:trailerx-amz-checksum-%s) algorithminrrheaderscontextrrequest_algorithmrequestChecksumRequiredconditional-md5) http_checksumget_SUPPORTED_CHECKSUM_ALGORITHMSlowerrhas_streaming_input startswithhttp_checksum_required) rrrsupported_algorithmsralgorithm_memberalgorithm_name location_typerchecksum_contexts rrrsI $11M$(()AB,6 '#A  01779 !5 5'>O !  . .u~((2!* ('.8 V  2 2 "9-11*bA09,-)9 :&  / /=3D3D!4#9-11*bA0A,-)9 :& 4rc|jdijdi}|jd}|sy|dk(r t|y|ddk(r t|y|ddk(r t|yt d|dz ) NrrrrrrrzUnknown checksum variant: %srz)rr _apply_request_header_checksum_apply_request_trailer_checksumr)rrrs rapply_request_checksumr s{{9b155j"E $$%89I %%#G, 4H $&w/ 4I %'0#4yF  rc|jdijdi}|jd}|d}||dvrytj|d}|j|d}||d|<y)Nrrrrrrr3)r _CHECKSUM_CLSr4)rrr location_namersrs rrr4s{{9b155j"E $$%89If%M ** $$Y{%;rs-  #M+  1M   8 $  6