]h9xBddlZddlZddlZddlZddlZddlZddlmZmZddl m Z ddl m Z m Z m Z mZddlmZmZmZmZddlmZddlmZmZmZddlmZmZmZmZmZm Z d d l!m"Z"m#Z#d d l$m%Z%d d l&m'Z'erdd l(m)Z)ddl*m+Z+m,Z,ejZe.Z/dZ0dZ1dZ2dZ3dZ4dZ5Gdde Z6GddeZ7Gdde Z8GddeZ9Gdde Z:Gdd eZ;Gd!d"e Z<Gd#d$eZ=Gd%d&e=Z>Gd'd(e=Z?Gd)d*eZ@y)+N)SEEK_SETUnsupportedOperation)time)AnyDictOptional TYPE_CHECKING) parse_qsl urlencodeurlparse urlunparse)format_date_time) AzureErrorServiceRequestErrorServiceResponseError)BearerTokenCredentialPolicy HeadersPolicy HTTPPolicyNetworkTraceLoggingPolicyRequestHistorySansIOHTTPPolicy)AzureSigningErrorStorageHttpChallenge)DEFAULT_OAUTH_SCOPE) LocationMode)TokenCredential)PipelineRequestPipelineResponsect|tr|jd}tj|}|j dS)Nzutf-8) isinstancestrencodebase64 b64encodedecode)dataencodeds i/var/www/core.comfia.cic-ware.com/crm/lib/python3.12/site-packages/azure/storage/blob/_shared/policies.py encode_base64r*1s9${{7#t$G >>' ""cr|d|d|d|df}ttd|}|syt|dkS)NtotalconnectreadstatusFr)listfiltermin)settings retry_countss r) is_exhaustedr69sLW%x ':HV|dr|dd|ddz |dd|yy)Nhookcountrmode) retry_count location_moder=)r4kwargss r) retry_hookr?As9eXg%6%:(SYJZe^der+c|jj}d|cxkrdkr#nn |dk(r|tjk(ry|dk(ryy|dk\r|dvryyy)Ni,iiTiF)ii) http_response status_coder SECONDARY)responser:r0s r)is_retryrEKs`  # # / /F fs S=T\%;%;; S= } Z  r+c||jjddr|jjjdr{|jjjddxs6t t j|jj}|jjd|k7ryy)Nvalidate_contentF content-md5T) contextgetrAheaders http_requestr*StorageContentValidationget_content_md5body)rD computed_md5s r)is_checksum_retryrQ`s.68;Q;Q;Y;Y;];]^k;l,,4488Ms)*B*R*RS[SiSiSnSnSp*qr   ! ! ) )- 8L H r+c|t|}|j|jdz|z}|jS)N/)path)r _replacerTgeturl)base_urlstub_urlparseds r)urljoinrZjs6 h F __&++"3h">_ ?F ==?r+ceZdZdZy)QueueMessagePolicyc|jjjdd}|r0t|jj ||j_yy)Nqueue_message_id)rIoptionspoprZrLurl)selfrequest message_ids r) on_requestzQueueMessagePolicy.on_requestrsL__,,001CTJ '.$$(((G $ r+N)__name__ __module__ __qualname__rer=r+r)r\r\psr+r\c$eZdZdZdfd ZxZS)StorageHeadersPolicyx-ms-client-request-idc@tt| |tt }||j j d<|jjjdd}|xsttj|j j d<y)Nz x-ms-dateclient_request_idrk) superrjrerrrLrKrIr_r`r"uuiduuid1)rbrc current_time custom_id __class__s r)rezStorageHeadersPolicy.on_request}s} "D4W='/ 4@$$[1OO++//0CTJ AJA_cRVR\R\R^N_$$%=>r+rcrreturnN)rfrgrhrequest_id_header_namere __classcell__rss@r)rjrjzs5``r+rjc(eZdZdfd ZddZxZS) StorageHostsc 8||_tt|yN)hostsrnrz__init__)rbr}r>rss r)r~zStorageHosts.__init__s  lD*,r+c|j|jjd<t|jj }t j}|jjD]\}}|j|k(s|}|jjjdd}|rzd|jjd<||jvrtd|||k7r@|j|j|}|j|j_|}||jjd<y)Nr} use_locationFretry_to_secondaryz*Attempting to use undefined host location netlocr<)r}rIr_r rLrarPRIMARYitemsrr` ValueErrorrUrV)rbrc parsed_urlr<keyvaluerupdateds r)rezStorageHosts.on_requests+/::(g22667 %,, ****, $JC  E) #  $ ..22>4H >+;$$( , 3@0r+r|rtrfrgrhr~rerwrxs@r)rzrzs-Ar+rzc>eZdZdZddeddffd Zd dZd dZxZS) StorageLoggingPolicyzA policy that logs HTTP request and response to the DEBUG logger. This accepts both global configuration, and per-request level with "enable_http_logger" logging_enableruNc ^|jdd|_tt|dd|i|y)N logging_bodyFrr=)r`rrnrr~)rbrr>rss r)r~zStorageLoggingPolicy.__init__s/"JJ~u= "D2[.[TZ[r+c |j}|jj}|jxs|j dd|_|j d|j rd|jd<t jtjsy |j}|j}d|vr|j|dd}t jd|t jd|jt jd |jj!D]\}}|j#d k(rd }n\|j#d k(rId|vrEt%|\}} } } } } t't)| }d |d<t+|| | | t-|| f}t jd ||t jd|jr)t jt/|j0yt jdyy#t2$r }t jd|Yd}~yd}~wwxYw)NrFrTsigz sig=*****zRequest URL: %rzRequest method: %rzRequest headers: authorizationz*****zx-ms-copy-source %r: %rz Request body:z1Hidden body, please use logging_body to show bodyzFailed to log request: %r)rLrIr_rr`enable_http_logger_LOGGER isEnabledForloggingDEBUGraqueryreplacedebugmethodrKrlowerr dictr r r r"rO Exception)rbrcrLr_log_url query_paramsheaderrschemerrTparamsrfragment parsed_qserrs r)rezStorageLoggingPolicy.on_requests++ //)) --S^U1S ;;')@)@ A04GOO, -'' 6 @&**+11 L(%ool5.A;OG /9 2L4G4GH 01%1%9%9%?%?%A ?MFE||~8 '+==%5.HPQVEfeX$(5)9$: +2 %(!+FFD&)T]J^`h+i jMM,> ? o.$$MM#l&7&7"89MM"UVA BB @ 93?? @sE0H! H!! I *II c~|jjd|jr=tj t j sy tjd|jjtjd|jjjD]\}}tjd||tjdtjdtj}|jjjd}|jjjdd }|r<|j!|r+|j#d d }tjd |nM|j%d rtjdn&|j'drtjd|j(r?|j'dr.tj|jj+y|j(r/ tj|jj-yyy#t.$rtjdYywxYw#t0$r)} tjdt3| Yd} ~ yd} ~ wwxYw)NrzResponse status: %rzResponse headers:rzResponse content:zattachment; ?filename=["\w.]+zcontent-dispositionz content-type=zFile attachments: %sz octet-streamzBody contains binary data.imagezBody contains image data.textzBody is streamablezFailed to log response: %s)rIr`rrrrrrrArBrKrrecompile IGNORECASErJmatch partitionendswith startswithrrrOrrrepr) rbrcrD res_headerrpatternrresp_content_typefilenamers r) on_responsez StorageLoggingPolicy.on_responses      0$2I2I J'' 6 G 3X5K5K5W5WX 12)1)?)?)G)G)M)M)OC%JMM, EBC 12**%Er}}U!//77;;?&11':MM"=>$$):)E)Ef)MMM("8"8"="="?@&&< h&<&<&A&A&CD'5 K:&< &:;< G :DIFF Gs= GJ ) J 6-I&&JJ JJ J<J77J<)FrtrcrrDrruN) rfrgrh__doc__boolr~rerrwrxs@r)rrs+ \t\$\&@P"Gr+rc&eZdZfdZddZxZS)StorageRequestHookc V|jd|_tt|yNraw_request_hook)rJ_request_callbackrnrr~rbr>rss r)r~zStorageRequestHook.__init__s#!',>!?  $02r+cz|jjjd|j}|r ||yyr)rIr_r`r)rbrcrequest_callbacks r)rezStorageRequestHook.on_requests6"??22667I4KaKab  W % r+rtrrxs@r)rr s 3&r+rc&eZdZfdZddZxZS)StorageResponseHookc V|jd|_tt|y)Nraw_response_hook)rJ_response_callbackrnrr~rs r)r~zStorageResponseHook.__init__s#"(**-@"A !413r+cl|jjd}|&|jjjdd}|jjd}|&|jjjdd}|jjd}|&|jjjdd}|jjdxs0|jjjd|j}|j j |}t||jjjdxs t|}|jjdk(}|xs| } | r||t|jjjdd z }||jjjd } | r2t| jd d d jd d d }n9|}n6| r4|2|t|jjjdd z }||fD]<} t| ds|| jd<|| jd<|| jd<>|r||||jd<|S)Ndata_stream_totaldownload_stream_currentupload_stream_currentresponse_callbackrr:izContent-Lengthrz Content-Range rrSrI)rIrJr_r`rnextsendrErQrArBintrKsplitrLhasattr) rbrcrrrrrD will_retry is_auth_errorshould_update_counts content_range pipeline_objs r)rzStorageResponseHook.sends#OO//0CD  $ ' 7 7 ; ;>'*h(?(?(C(CF(KLkPabjPk  ..::cA $.$?-@ $;$G #s8+A+A+I+I+M+MN^`a+b'c c # ( ( 6 6 > > B B? S  (+M,?,?Q,G,J,P,PQTVW,XYZ,[(\%(?% !&;&G !S)>)>)F)F)J)JK[]^)_%` ` !$h/ VL|Y/?@U $$%<=  V  h '3DGOO/ 0r+)rcrrur)rfrgrhr~rrwrxs@r)rrs 4(r+rcPeZdZdZdZdeddffd ZedZd dZ d d Z xZ S) rMzA simple policy that sends the given headers with the request. This will overwrite any headers already defined in the request. z Content-MD5r>ruNc *tt| yr|)rnrMr~rs r)r~z!StorageContentValidation.__init__Qs &68r+cxsdtj}ttr!|j |jSt dr_d} j }tfddD]}|j | j|t|jStd#Y[xYw#ttf$r}td|d}~wwxYw)Nr+r/rc&jdS)Ni)r/)r'sr)z:StorageContentValidation.get_content_md5..bsdiior+z4Data should be bytes or a seekable file-like object.)hashlibmd5r!bytesupdatertelliterseekrAttributeErrorIOErrorrdigest)r'rposchunkexcs` r)rNz(StorageContentValidation.get_content_md5Ts{skkm dE " JJt  zz|T6 "C iik5s; " 5! " b #x( zz|ST T  #G, b !WX^aa bs$CC C C* C%%C*cl|jjjdd}|r}|jjdk7rdt t j|jj}||jj|j<||jd<||jd<y)NrGFGETvalidate_content_md5) rIr_r`rLrr*rMrNr'rK header_name)rbrcrGrPs r)rez#StorageContentValidation.on_requestms"??22667I5Q  4 4 ; ;u D()A)Q)QRYRfRfRkRk)lmL=IG ( ()9)9 :6BGOO2 3.>*+r+c|jjddr|jjjdr|jjdxs6t t j |jj}|jjd|k7r5td|jjdd|d|jyyy) NrGFrHrz!MD5 mismatch. Expected value is 'z', computed value is 'z'.)rD) rIrJrArKr*rMrNrOr)rbrcrDrPs r)rz$StorageContentValidation.on_responseus      2E :x?U?U?]?]?a?abo?p"??../EFg6FFxG]G]GbGbGdef %%--m< L 78N8N8V8VWd8e7fg**6r;%33M@q :r+rtr) rfrgrhrrrr~ staticmethodrNrerrwrxs@r)rMrMIs@  K9990? r+rMc eZdZUdZeed< eed< eed< eed< eed< dedd ffd Zd e e efd d dd fdZ d d de e effdZ d e e efde fdZdZ dd e e efd d deddeedef dZdZxZS)StorageRetryPolicyzS The base class for Exponential and Linear retries containing shared code. total_retriesconnect_retries retry_read retry_statusrr>ruNc |jdd|_|jdd|_|jdd|_|jdd|_|jdd|_t t|#y) N retry_total retry_connectrrrF) r`rr read_retriesstatus_retriesrrnrr~rs r)r~zStorageRetryPolicy.__init__sq#ZZ r:%zz/1="JJ|Q7$jj;"(**-A5"I  $02r+r4rcrcf|drt|djrt|j}|dtj k(rtj |d<ntj |d<|j|dj|d}|j|_yyy)a A function which sets the next host location on the request, if applicable. :param Dict[str, Any]] settings: The configurable values pertaining to the next host location. :param PipelineRequest request: A pipeline request object. r}r:rN) allvaluesr rarrrCrUrJrV)rbr4rcrars r)_set_next_host_locationz*StorageRetryPolicy._set_next_host_locations G Xg%6%=%=%?!@7;;'C<#7#77#/#9#9 #/#7#7 ll(7*;*?*?@P*QlRG!..*GK"A r+c d}t|jjdr% |jjj}|j j}|jd|j|jd|j|jd|j|jd|j|jd|j|jdtj|jdd|jd d|d gd S#tt f$rYwxYw) Nr/rrrrrr<r}r?r) r-r.r/r0retry_secondaryr:r}r8 body_positionr9history)rrLrOrrrrIr_r`rrrrrrr)rbrcrr_s r)configure_retriesz$StorageRetryPolicy.configure_retriess 7'',,f 5  ' 4 4 9 9 > > @ //))[[0B0BC{{?D4H4HIKK d.?.?@kk.$2E2EF&{{+?AXAXYKK1E1EF[[$/KK d3*  #$89  s$D,,D>=D>cy)z Formula for computing the current backoff. Should be calculated by child class. :param Dict[str, Any] settings: The configurable values pertaining to the backoff time. :returns: The backoff time. :rtype: float rr=)rbr4s r)get_backoff_timez#StorageRetryPolicy.get_backoff_timesr+cX|j|}|r|dkry|j|y)Nr)r sleep)rbr4 transportbackoffs r)rzStorageRetryPolicy.sleeps*''1'A+  r+rDrerrorc|dxxdzcc<|r=t|tr-|dxxdzcc<|djt||nm|r=t|tr-|dxxdzcc<|djt||n.|r,|dxxdzcc<|djt||t |s|j d vr|d r|j|||jr@t|jdr*|d y |jj|d t|d xxdz cc<yy #ttf$rYy wxYw)aIncrement the retry counters. :param Dict[str, Any] settings: The configurable values pertaining to the increment operation. :param PipelineRequest request: A pipeline request object. :param Optional[PipelineResponse] response: A pipeline response object. :param Optional[AzureError] error: An error encountered during the request, or None if the response was received successfully. :returns: Whether the retry attempts are exhausted. :rtype: bool r-rr.r )rr/r0)rA)PUTrrFr9T)r!rappendrrr6rrrOrrrrr)rbr4rcrDrs r) incrementzStorageRetryPolicy.incrementsU Q Z':; Y 1 $  Y  & &~gU'K L z%)=> V  !  Y  & &~gU'K L "a'"#**>'QY+Z[H%~~W,:K1L,,Xw?|| f =O,4 !LL%%h&?J W  "  -j9! !s#EEEcd}d}|j|}|r |jj|}t||ds t |rt|j ||j |j}|rJt||j |jd|j||jj |dr|d|jd<|d|j_|S#t$r}}t|tr|j ||j |}|rEt||j d||j||jjYd}~Y|d}~wwxYw)NTr:)rcrD)rcrDr)rcrr )r rrrErQrrLrAr?rrIrrr!rr<)rbrcretries_remainingrDretry_settingsrs r)rzStorageRetryPolicy.send su //8 99>>'2HnV&<=ARS[A\(,& ' 4 4!)!7!7)7)9%)"*$+$8$8%-%;%;"& (  >7??3L3LM  ) $*8*CH  Y '/=f/E,# c#45$(NN"G,@,@%3%M!$& ' 4 4!%! # JJ~w/H/HI  sB(C00 E69A0E1/E11E6)NN)rfrgrhrr__annotations__rrr~rr"rr floatr rrrrrrwrxs@r)rrs$,O)+;333+S#X+IZ+_c+" ): tCH~ .c3hE!26&* 6S#X6"6-.6 # 6  6p&r+rceZdZUdZeed< eed< eed< d dededededededd ffd Zd e e efde fd Z xZ S)ExponentialRetryzExponential retry.initial_backoffincrement_baserandom_jitter_rangerrr>ruNc \||_||_||_tt|d||d|y)a Constructs an Exponential retry object. The initial_backoff is used for the first retry. Subsequent retries are retried after initial_backoff + increment_power^retry_count seconds. :param int initial_backoff: The initial backoff interval, in seconds, for the first retry. :param int increment_base: The base, in seconds, to increment the initial_backoff by after the first retry. :param int retry_total: The maximum number of retry attempts. :param bool retry_to_secondary: Whether the request should be retried to secondary, if able. This should only be enabled of RA-GRS accounts are used and potentially stale data can be handled. :param int random_jitter_range: A number in seconds which indicates a range to jitter/randomize for the back-off interval. For example, a random_jitter_range of 3 results in the back-off interval x to vary between x+3 and x-3. rrNr=)rrrrnrr~)rbrrrrrr>rss r)r~zExponentialRetry.__init__=sC8 /,#6  . V#8J VNT Vr+r4c tj}|j|ddk(rdnt|j|dz}||j kDr||j z nd}||j z}|j ||S)aT Calculates how long to sleep before retrying. :param Dict[str, Any]] settings: The configurable values pertaining to get backoff time. :returns: A float indicating how long to wait before retrying the request, or None to indicate no retry should be performed. :rtype: float r9r)randomRandomrpowrruniform)rbr4random_generatorrrandom_range_startrandom_range_ends r)r z!ExponentialRetry.get_backoff_time_s"==?&&x/@A/E!3tObObdlmtduKvwCJTMeMeCeWt'?'??kl"T%=%==''(:ruNc N||_||_tt|d||d|y)a Constructs a Linear retry object. :param int backoff: The backoff interval, in seconds, between retries. :param int retry_total: The maximum number of retry attempts. :param bool retry_to_secondary: Whether the request should be retried to secondary, if able. This should only be enabled of RA-GRS accounts are used and potentially stale data can be handled. :param int random_jitter_range: A number in seconds which indicates a range to jitter/randomize for the back-off interval. For example, a random_jitter_range of 3 results in the back-off interval x to vary between x+3 and x-3. r!Nr=)rrrnr-r~)rbrrrrr>rss r)r~zLinearRetry.__init__xs9, #6  k4) V#8J VNT Vr+r4ctj}|j|jkDr|j|jz nd}|j|jz}|j ||S)aT Calculates how long to sleep before retrying. :param Dict[str, Any]] settings: The configurable values pertaining to the backoff time. :returns: A float indicating how long to wait before retrying the request, or None to indicate no retry should be performed. :rtype: float r)r#r$rrr&)rbr4r'r(r)s r)r zLinearRetry.get_backoff_timesj"==?||d666"\\D,D,DD<= <<$*B*BB''(:ruNc 0tt| ||fi|yr|)rnr1r~)rbr2r3r>rss r)r~z+StorageBearerTokenCredentialPolicy.__init__s 0$@X`Y_`r+rcrrDrc |jjjd}t|}|j t z}|j|||jy#t$rYywxYw)NzWWW-AuthenticateF) tenant_idT) rArKrJrr resource_idrauthorize_requestr6)rbrcrD auth_header challengescopes r) on_challengez/StorageBearerTokenCredentialPolicy.on_challengess "0088<<=OPK,[9I%%(;; w9L9LM   s0A$$ A0/A0) rfrgrhrr"rr~rr<rwrxs@r)r1r1sKYa#4aasaW[a $5 AS X\ r+r1)Ar$rrr#rroiorrrtypingrrrr urllib.parser r r r wsgiref.handlersrazure.core.exceptionsrrrazure.core.pipeline.policiesrrrrrrauthenticationrr constantsrmodelsrazure.core.credentialsrazure.core.pipeline.transportrr getLoggerrfrr*r6r?rErQrZr\rjrzrrrrMrrr-r1r=r+r)rIs/ -55 .WWD* 6 '  H %#!f* ) `= `6A#A@TG4TGn &) &.*.b5/5pnnb;N);N|3N$3Nl)Dr+