
    gh;                     >   S SK Jr  S SKrS SKJrJr  S SKJrJrJ	r	  S SK
Jr  S SKJrJrJrJr  S SKJr  \(       a  S SKJr  S S	KJr  S S
KJr  S SKJr   S SKJr  S SKJr  S SKJr  S SKJr   " S S\5      r!\" \!5      S 5       r"S r#S r$g! \  a	    \	" S5      ef = f)    )partialN)OPSPANDATA)_check_minimum_versionIntegrationDidNotEnable)Span)capture_internal_exceptionsensure_integration_enabled	parse_urlparse_version)TYPE_CHECKING)Any)Dict)Optional)Type)__version__)
BaseClient)StreamingBody)
AWSRequestzbotocore is not installedc                   2    \ rS rSrSrS\ 3r\S 5       rSrg)Boto3Integration   boto3z
auto.http.c                     ^ [        [        5      n [        [        U S5        [        R
                  mU4S jnU[        l        g )Nbotocorec                 N  > T" U /UQ70 UD6  U R                   nUR                  R                  R                  5       nUR                  R                  S[        [        US95        UR                  R                  S[        5        UR                  R                  S[        5        g )Nzrequest-created)
service_idz
after-callzafter-call-error)
metaservice_modelr   	hyphenizeeventsregisterr   _sentry_request_created_sentry_after_call_sentry_after_call_error)selfargskwargsr   r   	orig_inits        `/home/kali/devsecops-assessor/venv/lib/python3.13/site-packages/sentry_sdk/integrations/boto3.pysentry_patched_init8Boto3Integration.setup_once.<locals>.sentry_patched_init+   s    d,T,V,99D++66@@BJKK  !/JG KK  /ABKK  !35MN    )r   BOTOCORE_VERSIONr   r   r   __init__)versionr,   r*   s     @r+   
setup_onceBoto3Integration.setup_once#   s8       01/*E''	
	O 2
r.    N)	__name__
__module____qualname____firstlineno__
identifieroriginstaticmethodr2   __static_attributes__r4   r.   r+   r   r      s%    J*&F2 2r.   r   c                    SU < SU< 3n[         R                  " [        R                  U[        R
                  S9n[        5          [        UR                  SS9nUR                  SUR                  5        UR                  [        R                  UR                  5        UR                  [        R                  UR                  5        S S S 5        UR                  SU 5        UR                  SU5        UR                  [        R                   UR"                  5        UR%                  5         XQR&                  S	'   g ! , (       d  f       N{= f)
Nzaws..opnamer:   F)sanitizezaws.request.urlzaws.service_idzaws.operation_name_sentrysdk_span)
sentry_sdk
start_spanr   HTTP_CLIENTr   r:   r
   r   urlset_datar   
HTTP_QUERYqueryHTTP_FRAGMENTfragmentset_tagHTTP_METHODmethod	__enter__context)r   requestoperation_namer)   descriptionspan
parsed_urls          r+   r$   r$   :   s     ",^<K  >>&&D 
%	&w{{U;
'8h)):+;+;<h,,j.A.AB	 
' 	LL!:.LL%~6MM(&&7 	NN *.OO%&! 
'	&s   BE
Ec                 |  ^^^	 U R                  SS 5      nUc  g UR                  S S S 5        UR                  S5      n[        U[        5      (       d  g UR                  [        R                  UR                  [        R                  S9m	UR                  mUR                  mUU	4S jnXTl        UU	4S jnXdl        g )NrC   Bodyr?   c                     >  T" U 0 UD6nU(       d  TR                  5         U$ ! [         a    TR                  5         e f = fN)finish	Exception)r(   r)   ret	orig_readstreaming_spans      r+   sentry_streaming_body_read6_sentry_after_call.<locals>.sentry_streaming_body_readm   sI    	T,V,C%%'J 	!!#	s	    $ A c                  6   > TR                  5         T" U 0 UD6  g rZ   )r[   )r(   r)   
orig_closer_   s     r+   sentry_streaming_body_close7_sentry_after_call.<locals>.sentry_streaming_body_closez   s    D#F#r.   )pop__exit__get
isinstancer   start_childr   HTTP_CLIENT_STREAMrT   r   r:   readclose)
rQ   parsedr)   rU   bodyr`   rd   rc   r^   r_   s
          @@@r+   r%   r%   W   s    ;;($/D |MM$d#::fDdM**%%  && & N 		IJ	 +I$
 -Jr.   c                 h    U R                  SS 5      nUc  g UR                  [        U5      US 5        g )NrC   )rf   rg   type)rQ   	exceptionr)   rU   s       r+   r&   r&      s1    ;;($/D |MM$y/9d3r.   )%	functoolsr   rD   sentry_sdk.constsr   r   sentry_sdk.integrationsr   r   r   sentry_sdk.tracingr	   sentry_sdk.utilsr
   r   r   r   typingr   r   r   r   r   r   r   r/   botocore.clientr   botocore.responser   botocore.awsrequestr   ImportErrorr   r$   r%   r&   r4   r.   r+   <module>r}      s      * U U #  !48*/.
2{ 26 ,-. ..8(-V4O  4
2
334s   B B