o i;@s ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddlmZmZddlmZddlmZmZmZddlmZddlmZmZmZmZmZzddlm Z Wn e!yydZ Ynwdd l"m#Z#ddl$Z$dd l%m&Z&dd l'm(Z(m)Z)m*Z*dd l+m,Z,m-Z-m.Z.m/Z/e#rdd l0m1Z1m2Z2ddl"m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCddlDmEZEddl'mFZFmGZGmHZHmIZImJZJmKZKmLZLeZgde^d d9fd?d@Zh dQ A BdRdCdDZiGdEdFdFejZkGdGdHdHZlGdIdJdJZmdSdMdNZndSdOdPZodQdRd epfdSdTZqdTdXdYZr   dUdZe^d[esd\d]d^d_d`d'd daf dbdcZt dQ R d ] e ] adVdfdgZuddd e^fdhdiZvddd e^fdjdkZw ` ' l ' 'dWdmdnZx  o o  dXdQdRddd]dpepdqepded]drdsd dtfdudvZy o o dYdpepdqepded]d dtfdwdxZzdye{d d_fdzd{Z|dyd|d e^fd}d~Z}      dZ L y | U V ] ] ' td[ddZ~eedZerXd\ddZnd\ddZ    d]ddLdyd|dUdVdddddesdesdd'ddd dfddZ   dU 6 d^ddZde^d e^fddZd_ddZd`ddZ   dU ' daddZ dQ  ' _dbddZdcddZ ddddZ  de dfddZdd'ddd epfddZdld'd epfddZdld'dd'd epfddZde^desd e^fddZde^d d]fddZ dQde^d\d]d dfddZde^d dfddńZd epfddDŽZded efddʄZdgdd̈́Ze\ZZdZdhdd҄ZdhddԄZedՃZGddׄdeZGddلde jZde^d d'fdd܄Zde^d d'fdd߄ZedgdZ o o dide^depdepdepd df ddZedgdZdjde^depd dfddZddde^d epfddZ  dkde^dddepd epfddZddde^d epfddZdlddZde^d e^fddZde^d e^fddZdmddZde^d dfddZ dQ   | U _  dnd d ZdoddZe#rUeC      dpddZeC    dqddZef     drddZe&rud esfddZn d esfddZd edfddZzdd lmZdd!lmZWne!ydsd#d$Zd%e^d epfd&d'ZYnwd epfd(d)Z dQ +  ,dtd-d.Zd/dddd epfd0d1Ze#re@d2Zdud6d7Zd$dd e^fd8d9Zd:d;d epfd<d=Z : ;  >dvd?d@Zd:d;d epfdAdBZ : ;  CdwdDdEZdxdHdIZÐdydKdLZdS(zN) namedtuple)datetimetimezone)Decimal)partial partialmethodwraps)Real)parse_qsunquote urlencodeurlsplit urlunsplit)BaseExceptionGroup) TYPE_CHECKING)PY37)SENSITIVE_DATA_SUBSTITUTE AnnotatedAnnotatedValue)DEFAULT_ADD_FULL_STACKDEFAULT_MAX_STACK_FRAMESDEFAULT_MAX_VALUE_LENGTH EndpointType) FrameType TracebackType)AnyCallableContextManagerDictIteratorListLiteralNoReturnOptional ParamSpecSetTupleTypeTypeVarUnioncastoverload)Hub)AttributeValueSerializedAttributeValueEventExcInfoHintLogMetricPRizsentry_sdk.errorsz^[a-zA-Z0-9/+=]*$)falsefnnooff0)truetyyeson1iF)strictvaluerrCOptional[bool]return bool | NonecCs@|dur t|nd}|tvrdS|tvrdS|rdSt|S)zCasts an ENV variable value to boolean using the constants defined above. In strict mode, it may return None if the value doesn't match any of the predefined values. NFT)strlowerFALSY_ENV_VALUESTRUTHY_ENV_VALUESbool)rDrC normalizedrNM/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/sentry_sdk/utils.py env_to_boolds rPdatacCstj|ddddS)zCSerialize data into a compact JSON representation encoded as UTF-8.F),:) allow_nan separatorsutf-8)jsondumpsencode)rQrNrNrO json_dumpsssrZ Optional[str]c CszJttjjd8}d}tjdkstjdkr!t}|jtj O_tj gd|tj ||d d d}WdW|S1sCwYW|StttfyWYdSw)Nzw+win32cygwin)gitz rev-parseHEAD) startupinfostdoutstderrstdinrrV)openospathdevnullsysplatform subprocess STARTUPINFOdwFlagsSTARTF_USESHOWWINDOWPopenPIPE communicatestripdecodeOSErrorIOErrorFileNotFoundError)nullr`revisionrNrNrOget_git_revisionxs2 rxcCsHtjd}|r |St}|r|SdD]}tj|}|r!|SqdS)zTry to guess a default release.SENTRY_RELEASE)HEROKU_SLUG_COMMITSOURCE_VERSION!CODEBUILD_RESOLVED_SOURCE_VERSION CIRCLE_SHA1GAE_DEPLOYMENT_ID K_REVISIONN)reenvirongetrx)releasevarrNrNrOget_default_releases  rinstalled_integrationsz List[str]cCs,gd}|D] }||vrd|SqdS)zAReturn the SDK name including the name of the used web framework.)djangoflaskfastapibottlefalconquartsanic starlettelitestarstarlitechalice serverlesspyramidtornadoaiohttp aws_lambdagcpbeamasgiwsgizsentry.python.{}z sentry.python)format)rframework_integrations integrationrNrNrO get_sdk_names rc@s4eZdZdZdddZdddd d d defd d ZdS)CaptureInternalExceptionrNrFContextManager[Any]cCs|SNrNselfrNrNrO __enter__z"CaptureInternalException.__enter__tyOptional[Type[BaseException]]rDOptional[BaseException]tbOptional[TracebackType]cCs"|dur|durt|||fdS)NT)capture_internal_exception)rrrDrrNrNrO__exit__sz!CaptureInternalException.__exit__NrFr)__name__ __module__ __qualname__ __slots__rrLrrNrNrNrOrs rrcCstSr)_CAPTURE_INTERNAL_EXCEPTIONrNrNrNrOcapture_internal_exceptionsrrexc_infor0cCs"trtjd|ddSdS)z Capture an exception that is likely caused by a bug in the SDK itself. These exceptions do not end up in Sentry and are just logged instead. zInternal error in sentry_sdkrN) sentry_sdk get_client is_activeloggererrorrrNrNrOrs rrcCs |tSr)epoch total_secondsrDrNrNrO to_timestamp rcCs|tj}|dS)zFormats a timestamp in RFC 3339 format. Any datetime objects with a non-UTC timezone are converted to UTC, so that all timestamps are formatted in UTC. z%Y-%m-%dT%H:%M:%S.%fZ) astimezonerutcstrftime)rDutctimerNrNrOformat_timestamps  r)+-c Cszt|}WnGttfyNd|vrdnd}|dr%|ddd}|dtvr<|d7}|dd |d d}n |d tvrF|d7}t||}Ynw|tj S) N.z%Y-%m-%dT%H:%M:%S.%fz%Y-%m-%dT%H:%M:%SZz+0000iz%z) r fromisoformatAttributeError ValueErrorendswithISO_TZ_SEPARATORSstrptimerrr)rDresulttimestamp_formatrNrNrOdatetime_from_isoformats    rOptional[ExcInfo]Dict[str, Optional[ExcInfo]]cCs2|dur t}nt|}|ddurd}d|iS)z+Creates a hint with the exc info filled in.Nrr)rhrexc_info_from_errorrrNrNrOevent_hint_with_exc_infos   rc@eZdZdZdS)BadDsnzRaised on invalid DSNs.Nrrr__doc__rNrNrNrOr'src@s^eZdZdZedZ d     dd d Zede fd d Z ddddZ de fddZ dS)DsnzRepresents a DSN.z ^o(\d+)\.NrDUnion[Dsn, str]org_idr[rFc Cs>t|tr t|j|_dStt|}|jdvrtd|j|j|_|jdur,td|j|_ |dur8||_ ntj |j }|rF| dnd|_ |jdurY|jdkrUdpVd|_n|j|_|jsdtd|j|_|j|_|jd d}z tt||_Wnttfytd |jpd ddwd |d |_dS) N)httphttpszUnsupported scheme %rzMissing hostnamer6rPzMissing public key/zInvalid project in DSN (%r)) isinstancerdict__dict__r rHschemerhostnamehostr ORG_ID_REGEXmatchgroupportusername public_keypassword secret_keyrfrsplitintpop project_idr TypeErrorjoin)rrDrparts org_id_matchrfrNrNrO__init__0s8      z Dsn.__init__cCs(|j}|j|jfdvrd||jf}|S)zThe netloc part of a DSN.))rr)rrz%s:%s)rrrrrvrNrNrOnetloc[sz Dsn.netlocclient Optional[Any]Authc Cs"t|j|j|j|j|j|j|dS)z*Returns the auth info object for this dsn.)rrrfrrrr)rrrrfrrr)rrrNrNrOto_authcsz Dsn.to_authcCs.d|j|j|jr d|jpd|j|j|jfS)Nz%s://%s%s@%s%s%s@r)rrrrrfrrrNrNrO__str__osz Dsn.__str__r)rDrrr[rFN)rrrFr) rrrrrecompilerrpropertyrHrrrrNrNrNrOr+s  +  rc@sneZdZdZ    ddedededed d d ed d deddfddZejfdddefddZ defddZ dS)rz,Helper object that represents the auth info.Nrrrrrrr[versionrrrfrFc Cs4||_||_||_||_||_||_||_||_dSr)rrrfrrrr r) rrrrrrr rrfrNrNrOr}s  z Auth.__init__typercCsd|j|j|j|j|jfS)z'Returns the API url for storing events.z%s://%s%sapi/%s/%s/)rrrfrrD)rr rNrNrO get_api_urlszAuth.get_api_urlcCs`d|jfd|jfg}|jdur|d|jf|jdur$|d|jfdddd |DS) z!Returns the auth header a string. sentry_keysentry_versionN sentry_client sentry_secretzSentry z, css |] \}}d||fVqdS)z%s=%sNrN).0keyrDrNrNrO sz!Auth.to_header..)rr rappendrrrrNrNrO to_headers   zAuth.to_header)Nr Nr) rrrrrHrrrENVELOPEr rrNrNrNrOrzs@    rclsOptional[type]cCst|ddp t|ddS)Nrrgetattr)rrNrNrO get_type_namesrcCst|dd}|dvr |SdS)Nr)Nbuiltins __builtins__r)rmodrNrNrOget_type_modules rframerc Cslz|jd}|drWdSWn ttfyYnwdD]}z |j|r)WdSWqty3YqwdS)Nrz sentry_sdk.T)__traceback_hide____tracebackhide__F) f_globals startswithrKeyErrorf_locals Exception)r r flag_namerNrNrOshould_hide_frames"    r)rrIterator[TracebackType]ccs4|}|durt|js|V|j}|dusdSdSr)r)tb_frametb_next)rtb_rNrNrO iter_stackss r.filenamelineno max_length Optional[int]loaderrmoduleKTuple[List[Annotated[str]], Optional[Annotated[str]], List[Annotated[str]]]c s6d}d}|dur*t|dr*z||}Wn ttfy!d}Ynw|dur*|}|durFzt|}WnttfyEgdgfYSw|sMgdgfStd||}t |d|t |} z-fdd|||D} t || dd} fd d||d| D} | | | fWSt ygdgfYSw) N get_sourcerr6cg|] }t|ddqS r1 strip_stringrqrliner;rNrO z'get_lines_from_file..r:r;cr8r9r<r>r;rNrOr@rA)hasattrr7 ImportErrorrt splitlines linecachegetlinesrsmaxminlenr=rq IndexError) r/r0r1r3r4 context_linessource source_str lower_bound upper_bound pre_context context_line post_contextrNr;rOget_lines_from_files@      rS tb_linenomax_value_lengthcCsz|jj}Wn tyd}Ynwz|jd}Wnty'gdgfYSwz|jd}Wn ty:d}Ynw|durN|rN|d}t|||||dSgdgfS)Nr __loader__r6)r3r4)f_code co_filenamer'r#rS)r rTrUabs_pathr4r3r0rNrNrOget_source_contexts*       rZcCs&zt|WStyt|YSwr)rHr' safe_reprrrNrNrOsafe_strs    r\cCs zt|WStyYdSw)Nz )reprr'rrNrNrOr[s   r[rYcCs|r|s|Sz=|dr|dd}|ddd}||kr%tj|WStj|j}|s0|WS||tj dddd tj WSt yN|YSw)Nz.pycrrr6r) rsplitrerfbasenamerhmodules__file__rseplstripr')r4rY base_modulebase_module_pathrNrNrOfilename_for_module#s"    rgTinclude_local_variablesinclude_source_context custom_reprz&Optional[Callable[..., Optional[str]]]Dict[str, Any]c Cst|dd}|s d}d}n|jj}|jj}z|jd} Wn ty'd} Ynw|dur/|j}z |r8tj |nd} Wn tyFd} Ynwt | |pMd| |pQd| |d} |rgt |||\| d<| d<| d<|r{dd l m } | t|jd |d | d <| S) NrWrz )r/rYfunctionr4r0rPrQrRr) serializeT)is_varsrjvars)rrWrXco_namer#r'f_linenorerfabspathrgrZsentry_sdk.serializerrmrr&) r rTrhrirUrjrWrYrlr4 os_abs_pathrrmrNrNrOserialize_frame<sD       rucCsTd}g}t}|dur"t|s|t||||d|j}|dus |d|iS)NT)rhrirUframes)rh _getframer)rruf_backreverse)rhrirUr"rvr8rNrNrOcurrent_stacktraceos" rz exc_valuecCs t|ddS)Nerrnor)r{rNrNrO get_errnorr}rcCsftt|ddpt|ddpt|}t|dd}t|tr1t|dkr1|dddd|D7}|S) Nmessagerdetail __notes__r css|] }t|tr|VqdSr)rrH)rnoterNrNrOrsz$get_error_message..)r\rrlistrIr)r{r~notesrNrNrOget_error_messages   rexc_typeclient_optionsOptional[Dict[str, Any]] mechanism exception_id parent_idrL full_stackOptional[list[dict[str, Any]]]c si} |r|nddd| d<|dur|| dd<|dur"t|} nd} | dur8| ddidid | |durB|| dd <|d k} | sX|durX|| dd <d | dd<| rfd| dvrfd| dd<tduont|t} | rwd| dd<t|| d<t|| d<t|| d<|durddtdn|d|d|d| dfddt t |t t dD} t| t krtjdd| d<| S| r|s| }nt| ||}d|i| d<| S)z Creates a dict that goes into the events `exception.values` list and is ingestible by Sentry. See the Exception Interface documentation for more details: https://develop.sentry.dev/sdk/event-payloads/exception/ genericTr handledrNrmetar|numberrLrrchainedr is_exception_groupr4rDrhrirUrjc s(g|]\}}t|j|jdqS))rTrhrirUrj)rur+rT)rr_rjrhrirUrNrOr@s z5single_exception_from_error_tuple..r6r stacktracerv)copyr} setdefaultrrrrrrrzipr.rangeMAX_STACK_FRAMESrIrremoved_because_over_size_limitmerge_stack_frames)rr{rrrrrrLrexception_valuer|is_root_exceptionrrv new_framesrNrrO!single_exception_from_error_tuplesh                    r__suppress_context__Iterator[ExcInfo]ccs|\}}}g}t}|durW|durYt||vr[|||fV|||t||jr2|j}n|j}|dur;dSt|}|}t|dd}|dur]|dur_t||vsdSdSdSdSdSdS)N __traceback__) setidraddr __cause__ __context__r r)rrr{rseen_exceptionsseen_exception_idscauserNrNrOwalk_exception_chain s4     rccs |VdSrrNrrNrNrOr(s z Tuple[int, List[Dict[str, Any]]]c  CsPt|||||||||d } | g} |}|d7}t|do|j} | rK|o+t|do+|jdu} | rJ|j} tt| | t| dd|||d|d\}}| |n*|oVt|doV|jdu}|ru|j}tt||t|dd|||d|d\}}| ||o{t|d }|rt |j D] \}}tt||t|dd||||d ||d \}}| |q|| fS) z Creates the list of exceptions. This can include chained exceptions and exceptions from an ExceptionGroup. See the Exception Interface documentation for more details: https://develop.sentry.dev/sdk/event-payloads/exception/ ) rr{rrrrrrLrr6rrNr)rr{rrrrrLrr exceptionszexceptions[%s]) rrBrrexceptions_from_errorr rextendr enumerater)rr{rrrrrrLrparentrshould_supress_contextexception_has_causerchild_exceptionsexception_has_contentcontextridxerNrNrOr,s       rList[Dict[str, Any]]c Cs||\}}}tduo t|t}|rt|||||dd|d\}} ng} t|D]\}}}| t||||||dq%| | S)Nr)rr{rrrrrr)rr{rrrr)rrrrrrry) rrrrrr{rrrrrNrNrOexceptions_from_error_tuples:     rcCs.zt|WStyt|ddYSw)Nr6r)rHUnicodeDecodeErrorr]rrNrNrO to_strings   reventr/#Iterator[Annotated[Dict[str, Any]]]ccsd|vr |dVd|vr#|ddpdD] }d|vr"|dVqd|vrA|ddp/dD]}t|tr@d|vr@|dVq0dSdS)NrthreadsvaluesrN exception)rrr)rthreadrrNrNrOiter_event_stacktracess   rIterator[Dict[str, Any]]ccsBt|D]}t|tr|jpi}|dpdD]}|VqqdS)NrvrN)rrrrDr)rrr rNrNrOiter_event_framess   rin_app_excludeOptional[List[str]]in_app_include project_rootcCs<t|D]}t|tr|jpi}t|d|||dq|S)Nrv)rrr)rrrrDset_in_app_in_framesr)rrrrrrNrNrO handle_in_apps   rrvcCs|sdS|D]B}|d}|durq|d}t||r!d|d<qt||r+d|d<q|d}|dur5qt|r>d|d<qt||rHd|d<qq|S)Nin_appr4TFrY)r_module_in_list_is_external_source_is_in_project_root)rvrrrr current_in_appr4rYrNrNrOrs0      rrUnion[BaseException, ExcInfo]cCst|trt|dkr|\}}}n2t|tr;t|dd}|dur't|}|}nt\}}}||ur:d}|}t|}ntdt||||f}t rOt t |}|S)Nrz,Expected Exception object to report, got %s!) rtuplerI BaseExceptionrr rhrrrr*r0)rrr{rrrNrNrOrs$     rcs^dd|Dfdd|D}|||r|dtnd}|dur-|t||d}|S)zV Add the missing frames from full_stack to frames and return the merged list. cSs(h|]}|d|d|d|dfqSrYrQr0rlrN)rr rNrNrO =sz%merge_stack_frames..cs0g|]}|d|d|d|dfvr|qSrrN)r stackframe frame_idsrNrOr@Gsz&merge_stack_frames..max_stack_framesN)rrrrI)rvrrrrrNrrOr5s  rTuple[Event, Dict[str, Any]]cCsZt|}t|}|r|dtrt|d|ddd}nd}ddt||||id|fS) Nadd_full_stackrhrU)rhrUrvrr)levelr)rrrrrzr)rrrhintrrNrNrOevent_from_exception`s$rnameitemscCs>|durdS|s dS|D]}||ks||drdSq dS)NFrTr$)rritemrNrNrOr}srcCs |durdStd|du}|S)NFz [\\/](?:dist|site)-packages[\\/]rsearch)rYexternal_sourcerNrNrOrs rcCs&|dus|dur dS||rdSdS)NFTr)rYrrNrNrOrs  rstring max_bytescCs(|dd|djddd}|dS)zd Truncate a UTF-8-encodable string to the last full codepoint so that it fits in max_bytes. rVNrignore)errors...)rYrr)rr truncatedrNrNrO_truncate_by_bytess rc Cs*zt|dWSttfyYdSw)NrV)rIrYUnicodeEncodeErrorrrrNrNrO_get_size_in_bytess rzUnion[AnnotatedValue, str]cCs|s|S|dur t}t|}t|}|dur ||kr t||}n|dur3||kr3|d|dd}n|St||p:|dd|d|ggddS)Nrrz!limitx)rIrem)rDmetadata)rrrIrr)rDr1 byte_size text_sizetruncated_valuerNrNrOr=s" r=r zOptional[Tuple[int, ...]]c Cspd}td|dtjtjB}z||d}ttt| ddd}W|St t t fy7YdSw)z Parses a version string into a tuple of integers. This uses the parsing loging from PEP 440: https://peps.python.org/pep-0440/#appendix-b-parsing-version-strings-with-regular-expressions a # noqa: N806 v? (?: (?:(?P[0-9]+)!)? # epoch (?P[0-9]+(?:\.[0-9]+)*) # release segment (?P
                                          # pre-release
                [-_\.]?
                (?P(a|b|c|rc|alpha|beta|pre|preview))
                [-_\.]?
                (?P[0-9]+)?
            )?
            (?P                                         # post release
                (?:-(?P[0-9]+))
                |
                (?:
                    [-_\.]?
                    (?Ppost|rev|r)
                    [-_\.]?
                    (?P[0-9]+)?
                )
            )?
            (?P                                          # dev release
                [-_\.]?
                (?Pdev)
                [-_\.]?
                (?P[0-9]+)?
            )?
        )
        (?:\+(?P[a-z0-9]+(?:[-_\.][a-z0-9]+)*))?       # local version
    z^\s*z\s*$rrNr)
rrVERBOSE
IGNORECASEr	groupdictrmaprr_rrr)r
VERSION_PATTERNpatternr
release_tuplerNrNrO
parse_versions

rcCsz7ddl}ddlm}tddtd|jddD}|dd	r6tjd
kr+|dks0|dd
r3WdSWdSWn	t	y@Ynwz,ddl
}ddlm}t
|j}|dur]tdWdS|drh|dkrkWdSWdSWdSt	ywYdSw)z
    Returns whether gevent/eventlet have patched the stdlib in a way where thread locals are now more "correct" than contextvars.
    rN)is_object_patchedcSsg|]}t|qSrN)r)rpartrNrNrOr@z*_is_contextvars_broken..z	a|b|rc|\.r^	threadinglocalrr	)	contextvars
ContextVarFT)is_monkey_patchedzYInternal error in Sentry SDK: Could not parse Greenlet version from greenlet.__version__.r)rr6)gevent
gevent.monkeyrrrr___version__rhversion_inforCgreenleteventlet.patcherr
rrr)rr
version_tuplerr
greenlet_versionrNrNrO_is_contextvars_brokensF
	
rrcsGfddd}|S)NcsHeZdZddeddddffdd
Zdddd	ZdddZdddZdS)z1_make_threadlocal_contextvars..ContextVarNrdefaultrrFcs ||_||_|_|_dSr)_name_default_local_original_local)rrrrrNrOr;sz:_make_threadlocal_contextvars..ContextVar.__init__cSst|jd|p|jS)NrD)rrr)rrrNrNrOrAsz5_make_threadlocal_contextvars..ContextVar.getrDcSs0ttd}|}t|j||||j_|S)N@)rHrandomgetrandbitsrsetattrrrrD)rrDtokenoriginal_valuerNrNrOrDs
z5_make_threadlocal_contextvars..ContextVar.setrcSst|j||j_|jj|=dSr)rrrrDr)rrrNrNrOresetKsz7_make_threadlocal_contextvars..ContextVar.resetr)rrrFr)rDrrFr)rrrFN)rrrrHrrrr rNrrNrOr	8s

r	rN)rr	rNrrO_make_threadlocal_contextvars7sr!Tuple[bool, type]cCs|ts2tjdkrzddlm}d|fWStyYnwzddlm}d|fWSty1Ynwddlm}dt	|fS)z
    Figure out the "right" contextvars installation to use. Returns a
    `contextvars.ContextVar`-like class with a limited API.

    See https://docs.sentry.io/platforms/python/contextvars/ for more information.
    rr)r	TrF)
rrhraiocontextvarsr	rCrrrr!)r	rrNrNrO_get_contextvarsSs 


r$z

With asyncio/ASGI applications, the Sentry SDK requires a functional
installation of `contextvars` to avoid leaking scope/context data across
requests.

Please refer to https://docs.sentry.io/platforms/python/contextvars/ for more information.
funcCallable[..., Any]cCsd}z
d|jj|jj|jfWStyYnwd\}}t|tr0t|jdr0d\}}|j}nt|ddp;t|dd}t|t	rHd\}}|j}t|d	rQ|j
}nt|drY|j}|durut|d
rot|jtro|jd|}|||}|S)zbReturn the qualified name of func. Works with regular function, lambda, partial and partialmethod.Nz%s.%s.%s)rrr)zpartial()_partialmethod__partialmethod__)zpartialmethod(Raised when a serverless method is about to reach its timeout.NrrNrNrNrOr3sr3c@sReZdZdZ		ddededdddddf
d	d
ZdddZdddZdddZ	dS)
TimeoutThreadzCreates a Thread which runs (sleeps) for a time duration equal to
    waiting_time and raises a custom ServerlessTimeout exception.
    Nwaiting_timeconfigured_timeoutisolation_scopezOptional[sentry_sdk.Scope]
current_scoperFcCs2tj|||_||_||_||_t|_dSr)	rThreadrr5r6r7r8r/_stop_event)rr5r6r7r8rNrNrOrszTimeoutThread.__init__cCs|jdSr)r:rrrNrNrOstopszTimeoutThread.stopr0cCs<t}t}t||jdddd\}}tj||d|S)NrFr)rr)r)rhrrrroptions
capture_event)rrrrrrNrNrO_capture_exceptions
z TimeoutThread._capture_exceptionc
Cs|j|j|jrdSt|j}||jkr|d}|jdurk|jdurktj	
|j6tj	|jztd
|tyLt|YnwWdn1sWwYWdn1sfwYtd
|)Nr6zZWARNING : Function is expected to get timed out. Configured timeout duration = {} seconds.)r:waitr5is_setrr6r7r8rscopeuse_isolation_scope	use_scoper3rr'reraiser>)rinteger_configured_timeoutrNrNrOruns6


zTimeoutThread.runNN)rFN)rFr0)
rrrrfloatrrr;r>rFrNrNrNrOr4s$



r4originalc
Csdd}z|d}t|}|d}W|Sty1}ztdj|d|WYd}~|Sd}~ww)zO
    Convert a string to base64, via UTF-8. Returns None on invalid input.
    NUTF-8z"Unable to encode {orig} to base64:)orig)rYbase64	b64encoderrr'rwarningr)rI
base64_string
utf8_bytesbase64_byteserrrNrNrO	to_base64s

rSrOc
Csvd}zt|}|sJ|d}t|}|d}W|Sty:}ztdj	|d|WYd}~|Sd}~ww)zQ
    Convert a string from base64, via UTF-8. Returns None on invalid input.
    NrJz#Unable to decode {b64} from base64:)b64)
BASE64_ALPHABETrrYrL	b64decoderrr'rrNr)rOutf8_stringonly_valid_charsrQrPrRrNrNrOfrom_base64s


rY
Components)rrrfqueryfragmenturlremove_authorityremove_query_valuesr_zUnion[str, Components]c
Cst|}t|jdd}|r'|jd}t|dkr#dtt|df}n|j}n|j}|r8ttdd|D}n|j}t	|j
|||j|jd	}	|rK|	St
|	S)
zL
    Removes the authority and query parameter values from a given URL.
    T)keep_blank_valuesrr6z%s:%s@%srcSsi|]}|tqSrN)r)rrrNrNrO
Fsz sanitize_url..rrr[rfr\)r
r
r[rr_rIrrrrZrrfr\r)
r]r^r_r_
parsed_urlquery_paramsnetloc_partsrquery_string
componentsrNrNrOsanitize_url)s6	rh	ParsedUrlr]r[r\sanitizecCs>t|d|dd}tt|j|jd|jdd}t||j|jdS)z
    Splits a URL into a url (including path), query and fragment. If sanitize is True, the query
    parameters will be sanitized to remove sensitive data. The autority (username and password)
    in the URL will always be removed.
    T)r^r_r_rrbrj)	rhrrZrrrfrir[r\)r]rkrcbase_urlrNrNrO	parse_url\s"
rmratecCsjt|ttfrt|rtdj||t|ddSt	|}|dks'|dkr3tdj||ddSdS)	z
    Checks the given sample rate to make sure it is valid type and value (a
    boolean or a number between 0 and 1, inclusive).
    z|{source} Given sample rate is invalid. Sample rate must be a boolean or a number between 0 and 1. Got {rate} of type {type}.)rLrnrFrr6zW{source} Given sample rate is invalid. Sample rate must be between 0 and 1. Got {rate}.)rLrnT)
rr	rmathisnanrrNrrrH)rnrLrNrNrOis_valid_sample_ratews 	
rqr
regex_listsubstring_matchingcCsH|durdS|D]}|s|ddkr|d7}t||}|r!dSqdS)NFr$Tr)rrrrsitem_matchermatchedrNrNrOmatch_regex_listsrwrzsentry_sdk.client.BaseClientcCs,|duo|jduo|jjduo|jjj|vS)zB
    Determines whether the given URL matches the Sentry DSN.
    N)	transport
parsed_dsnr)rr]rNrNrO
is_sentry_urls
rzIterator[Tuple[str, str]]ccsz6ddlm}t}|D]%}|jdd}|dur4t|}|jdur4||vr4||jfV||qWdStybzddl	}WntyOYYdSw|j
D]}t|j|jfVqSYdSw)Nr)rName)	importlibrr
distributionsr_normalize_module_namer
rrC
pkg_resourcesworking_setr)ryieldeddistrnormalized_namerinforNrNrO_generate_installed_moduless.

rcCs|Sr)rIrrNrNrOrr1rcCstdd|S)Nz[-_.]+r)rsubrrNrNrO1_replace_hyphens_dots_and_underscores_with_dashessrDict[str, str]cCstdur	ttatSr)_installed_modulesrrrNrNrNrO_get_installed_moduless
rpackagecCs>tt|}ddtD}||}|durdSt|S)NcSsi|]	\}}t||qSrN)r)rr4vrNrNrOrasz#package_version..)rrrrrr)rnormalized_packageinstalled_packagesr
rNrNrOpackage_versions
rtprr"cCs$|dusJ|j|ur|||r)rwith_traceback)rrDrrNrNrOrDs

rD_a_kcOdS)z.No-op function for ensure_integration_enabled.NrN)rrrNrNrO_no_oprr)type[sentry_sdk.integrations.Integration]original_functionCallable[P, R]*Callable[[Callable[P, R]], Callable[P, R]]cCdSrrNrrrNrNrOensure_integration_enabledsr0Callable[[Callable[P, None]], Callable[P, None]]cCrrrN)rrNrNrOrs(Union[Callable[P, R], Callable[P, None]]cs*trttttfdfdd}|S)a
    Ensures a given integration is enabled prior to calling a Sentry-patched function.

    The function takes as its parameters the integration that must be enabled and the original
    function that the SDK is patching. The function returns a function that takes the
    decorated (Sentry-patched) function as its parameter, and returns a function that, when
    called, checks whether the given integration is enabled. If the integration is enabled, the
    function calls the decorated, Sentry-patched function. If the integration is not enabled,
    the original function is called.

    The function also takes care of preserving the original function's signature and docstring.

    Example usage:

    ```python
    @ensure_integration_enabled(MyIntegration, my_function)
    def patch_my_function():
        with sentry_sdk.start_transaction(...):
            return my_function()
    ```
    sentry_patched_functionrrFcs2d	fdd}turt|St|S)
NargsP.argskwargsP.kwargsrFr5cs.tdur|i|S|i|Sr)rrget_integration)rr)rrrrNrOrunner-sz;ensure_integration_enabled..patcher..runner)rrrrrFr5)rr)rrr)rrOpatcher,sz+ensure_integration_enabled..patcherN)rrrFr)rr*rr4r5)rrrrNrrOrscCtSr)timeperf_counter_nsrNrNrNrOnanosecond_time=r1rcCsttdS)NgeA)rrperf_counterrNrNrNrOrBcCrr)rrrNrNrNrOnowFr1r)get_hubis_module_patched
Optional[Hub]cCrrrNrNrNrNrOget_gevent_hubPrrmod_namecCrNFrN)rrNrNrOrSrrcCstdptdS)Nr_threadrrNrNrNrO	is_geventXrrrOptional[threading.Thread]#Tuple[Optional[int], Optional[str]]cCs|durz|j}|j}|dur||fWSWn	tyYnwtr9t}|dur9z|jdfWSty8Ynwzt}|j}|j}|durM||fWSWn	tyWYnwzt}|j}|j}|durl||fWSWdStyxYdSw)zK
    Try to get the id of the current thread, with various fall backs.
    NrG)	identrrrrthread_identrcurrent_threadmain_thread)r	thread_idthread_name
gevent_hubrNrNrOget_current_thread_meta\sP


rrcCs$|tkrt|dr|jdvrdSdS)Ncode)rNFT)
SystemExitrBr)rrDrNrNrOshould_be_treated_as_errorsrTconvert_funcCallable[[Any], T]Optional[T]cCsHz
t||r	|WSWn	tyYnwz||WSty#YdSw)z
    Attempt to convert from an unknown type to a specific type, using the
    given function. Return None if the conversion fails, i.e. if the function
    raises an exception.
    N)rrr')rrDrNrNrOtry_converts

rcsJ				d	fddz|}tj|tdWSty$t|YSw)
z&Safely serialize to a readable string.rrrF6Union[str, dict[Any, Any], list[Any], tuple[Any, ...]]cs2t|rJz3t|dd}t|dd}t|dd}|r#|r#|d|}n|r/|r/|d|}n|}d|dWStyIdt|jdYSwt|trZfd	d
|DSt|tt	frjfdd|DSt
|d
rzfdd
t|D}dt|jd|dWStyt|YSw|S)Nrrr	anonymousrz
z
.serialize_item..csg|]}|qSrNrN)rrrrNrOr@rz:safe_serialize..serialize_item..rcs$i|]\}}|ds||qS)rrrrrNrOras< )
callablerr'rrrrrrrrBror])rr4qualnamer	full_pathattrsrrNrOrs8



z&safe_serialize..serialize_item)rN)rrrFr)rWrXrHr')rQ
serializedrNrrOsafe_serializes$rr<Optional[dict[str, Any]]cCs,|durdSt|ddp|dddS)NFenable_logs_experimentsrLrr<rNrNrOhas_logs_enabledsr.Optional[Callable[[Log, Hint], Optional[Log]]]cC$|durdS|dp|ddS)Nbefore_send_logrrrrNrNrOget_before_send_log
rcCs|durdSt|ddS)NFenable_metricsTrrrNrNrOhas_metrics_enabledsr4Optional[Callable[[Metric, Hint], Optional[Metric]]]cCr)Nbefore_send_metricrrrrNrNrOget_before_send_metricrrvalr-cst|ttttfr|Stdtdtdtdi}t|ttfr |s gSt|trCt|d|vr?tfdd|Dr?t	
|St|St|trat|d|vratfdd|Drat|St|S)	a
    Turn unsupported attribute value types into an AttributeValue.

    We do this as soon as a user-provided attribute is set, to prevent spans,
    logs, metrics and similar from having live references to various objects.

    Note: This is not the final attribute value format. Before they're sent,
    they're serialized further into the actual format the protocol expects:
    https://develop.sentry.dev/sdk/telemetry/attributes/
    zstring[]z	integer[]zdouble[]z	boolean[]rc3|]	}t|uVqdSrrrrrrNrOrz#format_attribute..c3rrrrrrNrOr!r)rrLrrHrHrrrallrdeepcopyr[)r
list_typesrNrrOformat_attributes&


rr.cst|tr
|ddSt|tr|ddSt|tr|ddSt|tr(|ddSt|trR|s4gddSt|dttttfvrRtfdd	|DrR|ddSt|ddS)
z2Serialize attribute value to the transport format.boolean)rDrintegerdoublerarrayrc3rrrrrrNrOr8rz&serialize_attribute..)	rrLrrHrHrrrr[)rrNrrOserialize_attribute's









&
r)rDrrCrErFrG)rFr[r)rr0rFNr)rrrFr)rrrFr[)rrrFr*)NNN)r rrTr2rUr2rFr5)r4r[rYr[rFr[)NTTNN)TTN)NNNNNN)rrr{rrrrrrrrr2rr2rLr[rrrFrk)rr0rFr)NNrrNN)
rr0rrrrrrrFr)rr/rFr)rr/rFr)
rr/rrrrrr[rFr/)
rvrrrrrrr[rFr)rrrFr0)rvrrrrrrFrrG)rrrrrrrFr)rFr")r%r&rFr[)TTF)Tr)rFr{)rFr)rrrDrrrrFr")rrrrrFN)rrrrrFr)rrrFr)rrrrrFr)rFr)rrrFr)rrrDrrFr)r<rrFr)r<rrFr)rrrFr-)rr-rFr.)rLrWrEloggingrorerrrrjrhrrcollectionsrrrdecimalr	functoolsrrrnumbersr	urllib.parser
rrr
rrrrCtypingrrsentry_sdk._compatrsentry_sdk._typesrrrsentry_sdk.constsrrrrtypesrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+
gevent.hubr,r-r.r/r0r1r2r3r4r5r	getLoggerrrrrU	frozensetrJrKrrPbytesrZrxrrHrrrrrrHrrrrrrrrrrrrLr)r.rrSrZr\r[rgrurzrr}rrrBr'HAS_CHAINED_EXCEPTIONSrrrrrrrrrrrrrrrrr=rrrr!r$HAS_REAL_CONTEXTVARSr	CONTEXTVARS_ERROR_MESSAGEr/r0r2r3r9r4rSrYrZrhrirmrqrwrzrrrrrrDrrrrrrrrrrrrrrrrrrrrrrNrNrNrOsL$


	#
O.
0
4
	

f	

h+
+-

	
33
%
+E
0 
-4
.
$