
    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  \(       a  S SK
JrJr  S SKJr   S SKrS S	KJrJrJr   " S S\R*                  5      rg! \ a	    \" S
5      ef = f)    N)OP)DidNotEnable)SPAN_ORIGIN)TransactionTransactionSource)TYPE_CHECKING)CallableOptional)Message)ServicerContextHandlerCallDetailsRpcMethodHandlerzgrpcio is not installedc                   B   ^  \ rS rSrSU 4S jjrS r\S 5       rSrU =r	$ )ServerInterceptor   c                 ^   > U=(       d    [         R                  U l        [        TU ]  5         g N)r   
_find_name_find_method_namesuper__init__)self	find_name	__class__s     f/home/kali/devsecops-assessor/venv/lib/python3.13/site-packages/sentry_sdk/integrations/grpc/server.pyr   ServerInterceptor.__init__   s"    !*!J.?.J.J    c                    ^ ^ U" U5      mT(       a  TR                   (       d  T$ UU 4S jn[        R                  " UTR                  TR                  S9$ )Nc           	      (  > [         R                  " 5          TR                  U5      nU(       a  [        UR	                  5       5      n[
        R                  " U[        R                  U[        R                  [        S9n[         R                  " US9    TR                  X5      sS S S 5        sS S S 5        $ TR                  X5      sS S S 5        $ ! [         a  nUeS nAff = f! , (       d  f       O= f S S S 5        g ! , (       d  f       g = f)N)opnamesourceorigin)transaction)
sentry_sdkisolation_scoper   dictinvocation_metadatar   continue_from_headersr   GRPC_SERVERr   CUSTOMr   start_transactionunary_unaryBaseException)requestcontextr!   metadatar$   ehandlerr   s         r   behavior5ServerInterceptor.intercept_service.<locals>.behavior!   s    ++---g6#G$?$?$ABH"-"C"C >>!077*#K $55+N$#*#6#6w#H ON .-( #..w@) .-"  - $"#G$ ONN .--sH   A>DC(C'	D:D
C%C  C%%C((
C6	2D
D)request_deserializerresponse_serializer)r-   grpcunary_unary_rpc_method_handlerr6   r7   )r   continuationhandler_call_detailsr4   r3   s   `   @r   intercept_service#ServerInterceptor.intercept_service   sN    34g11N	A0 22!(!=!= ' ; ;
 	
r   c                 ^    U R                   R                  R                  R                  5       $ r   )
_rpc_eventcall_detailsmethoddecode)r0   s    r   r   ServerInterceptor._find_name?   s%     !!..55<<>>r   )r   r   )
__name__
__module____qualname____firstlineno__r   r<   staticmethodr   __static_attributes____classcell__)r   s   @r   r   r      s"    "
H ? ?r   r   )r%   sentry_sdk.constsr   sentry_sdk.integrationsr   #sentry_sdk.integrations.grpc.constsr   sentry_sdk.tracingr   r   typingr   r	   r
   google.protobuf.messager   r8   r   r   r   ImportErrorr    r   r   <module>rS      s]       0 ; =  )/2JJ
.?.. .?	  2
0
112s   A A.