
    gh                        S SK r S SKJr  S SKJr  S SKJr  S SKJrJ	r	  S SK
Jr  S SKJr  \(       a  S SKJrJr  S S	KJrJr   S SKrS S
KJrJr  S SKJrJr   " S S\R4                  R6                  5      rg! \ a	    \" S5      ef = f)    N)OP)DidNotEnable)SPAN_ORIGIN)TransactionTransactionSource)event_from_exception)TYPE_CHECKING)	AwaitableCallable)AnyOptional)HandlerCallDetailsRpcMethodHandler)
AbortErrorServicerContextzgrpcio is not installedc                   8   ^  \ rS rSrSU 4S jjrS rS rSrU =r$ )ServerInterceptor   c                 V   > U=(       d    U R                   U l        [        TU ]  5         g N)
_find_name_find_method_namesuper__init__)self	find_name	__class__s     j/home/kali/devsecops-assessor/venv/lib/python3.13/site-packages/sentry_sdk/integrations/grpc/aio/server.pyr   ServerInterceptor.__init__   s    !*!=doo    c                 J  ^ ^#    UT l         U" U5      I S h  vN mTc  g TR                  (       d)  TR                  (       d  [        R                  nUU 4S jnOTR                  (       d(  TR                  (       a  [        R
                  nU4S jnOqTR                  (       a(  TR                  (       d  [        R                  nU4S jnO8TR                  (       a'  TR                  (       a  [        R                  nU4S jnW" WTR                  TR                  S9$  GN	7f)Nc                   >#    TR                  U5      nU(       d  T" X5      I S h  vN $ [        R                  " [        UR	                  5       5      [
        R                  U[        R                  [        S9n[        R                  " US9    TR                  X5      I S h  vN sS S S 5        $  N N! [         a    e [         a)  n[        USSS.S9u  pV[        R                   " XVS9  e S nAff = f! , (       d  f       g = f7f)N)opnamesourceorigin)transactiongrpcF)typehandled)	mechanism)hint)r   r   continue_from_headersdictinvocation_metadatar   GRPC_SERVERr   CUSTOMr   
sentry_sdkstart_transactionunary_unaryr   	Exceptionr   capture_event)	requestcontextr$   r'   exceventr,   handlerr   s	          r   wrapped4ServerInterceptor.intercept_service.<locals>.wrapped(   s     --g6!(!::: *??4467~~,33&  11kJ
%,%8%8%JJ KJ ;  K% $ &:/5%&H' #00B KJsX   $DB3A'DC7B7%B5&B7)D5B77C4$C//C44C77
DDc                V   >#    TR                  X5        S h  vN nU7v   M   N
 g 7fr   )unary_streamr7   r8   rr;   s      r   r<   r=   G   s(     &33GE !GE   )'%')')c                 F   >#    TR                  X5      nUI S h  vN $  N7fr   )stream_unary)r7   r8   responser;   s      r   r<   r=   O   s      "//A%~%~s   !!c                V   >#    TR                  X5        S h  vN nU7v   M   N
 g 7fr   )stream_streamr@   s      r   r<   r=   W   s(     &44WF !GFrB   )request_deserializerresponse_serializer)
_handler_call_detailsrequest_streamingresponse_streamingr(   unary_unary_rpc_method_handlerunary_stream_rpc_method_handlerstream_unary_rpc_method_handler stream_stream_rpc_method_handlerrH   rI   )r   continuationhandler_call_detailshandler_factoryr<   r;   s   `    @r   intercept_service#ServerInterceptor.intercept_service   s     %9"$%9::?((1K1K"AAO8 **w/I/I"BBO
 &&w/I/I"BBO&
 &&7+E+E"CCO
 !(!=!= ' ; ;
 	
w ;s   D#D D	D#c                 .    U R                   R                  $ r   )rJ   method)r   r8   s     r   r   ServerInterceptor._find_nameb   s    ))000r    )r   rJ   r   )	__name__
__module____qualname____firstlineno__r   rT   r   __static_attributes____classcell__)r   s   @r   r   r      s    B
H1 1r    r   )r2   sentry_sdk.constsr   sentry_sdk.integrationsr   #sentry_sdk.integrations.grpc.constsr   sentry_sdk.tracingr   r   sentry_sdk.utilsr   typingr	   collections.abcr
   r   r   r   r(   r   r   grpc.aior   r   ImportErroraior    r    r   <module>rj      sf       0 ; = 1  3$294
M122 M1	  2
0
112s   A7 7B