PATH:
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
grpc
/
__pycache__
� o 0i� � � � d dl mZ d dlZd dlmZmZmZ d dlmZ d dlmZ d dl m Z d dl m Z dd l mZ dd lmZ dd lmZ dd lmZ dd lmZ d d lmZmZmZm Z er d dlm Z m Z n G d� d� Z G d� d� Z e � Z e d� Z e ejB � Z"de e ef de e ef fd�Z#de e ef de e ef fd�Z$de e ef de e ef fd�Z%de e ef de e ef fd�Z&de e ef de e ef fd�Z' G d� d e � Z(y) � )�wrapsN)�Channel�Server�intercept_channel)r )r )� Integration)� parse_version� )�ClientInterceptor)�ServerInterceptor)�!SentryUnaryUnaryClientInterceptor)�"SentryUnaryStreamClientInterceptor)� TYPE_CHECKING�Any�Optional�Sequence)� ParamSpec�Callablec � � e Zd Zd� Zy)r c � � d | _ d | _ y �N)�args�kwargs��self�_s �T/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/grpc/__init__.py�__init__zParamSpec.__init__ s � � �D�I� �D�K� N)�__name__� __module__� __qualname__r � r r r r s � � r r c � � e Zd Zd� Zy)� _Callablec � � y r r" r s r � __getitem__z_Callable.__getitem__% s � �r N)r r r! r& r" r r r$ r$ $ s � � r r$ �P�func�returnc �T � � t � � dt dt dt f� fd� � }|S )z4Wrapper for synchronous secure and insecure channel.r r r) c �v �� �| i |��}t j s dt _ t |t � � S |S )NT)r �_is_interceptedr )r r �channelr( s �r �patched_channelz+_wrap_channel_sync.<locals>.patched_channel3 s: �� ���'��'�� �0�0�04� � -�$�W�.?�.A�B� B��Nr )r r r �r( r. s ` r �_wrap_channel_syncr0 0 s8 �� � �4�[��s� �c� �g� � �� �r c �b � t | � dt dt j dt fd�� }|S )Nr- � interceptorsr) c � � t j r*t |D �cg c] }t |t � s|�� c}� }n|}t | g|��� S c c}w r )r r, �tuple� isinstancer )r- r2 � interceptors r �patched_intercept_channelz:_wrap_intercept_channel.<locals>.patched_intercept_channel@ s[ � � � ,� ,� � (4��'3� �%�k�3D�E� �'3�� �L� (�L� ��8�<�8�8��s �A )r r �grpcr )r( r7 s r �_wrap_intercept_channelr9 ? s> � � �4�[� 9�� 9�)-�)?�)?� 9� � 9� � 9� %�$r c �� � � t � � dd�dt j dt t t j j dt j dt f� fd�� }|S )z5Wrapper for asynchronous secure and insecure channel.N�r2 r r2 r r) c �T �� t � t � g}g |�| xs g �} �|d| i|��S �Nr2 )� AsyncUnaryUnaryClientInterceptor� AsyncUnaryStreamClientIntercetor)r2 r r �sentry_interceptorsr( s �r r. z,_wrap_channel_async.<locals>.patched_channelV sF �� � -� .� ,� .� �� E�,�D� �0B��D� ��T�?� �?��?�?r ) r r' r r r r8 �aior r r r/ s ` r �_wrap_channel_asyncrB S sp �� � �4�[� HL� @��v�v� @� �x����(B�(B� C�D� @� �(�(� @� � @� � @� �r c � � � t � � dd�dt j dt t t j dt j dt f� fd�� }|S )z Wrapper for synchronous server.Nr; r r2 r r) c � �� | xs g D �cg c] }t |t � s|�� } }t � }|g| xs g �} �|d| i|��S c c}w r= )r5 r )r2 r r r6 �server_interceptorr( s �r �patched_serverz)_wrap_sync_server.<locals>.patched_serveri so �� � ,� 1�r� 1� � 1� � �k�+<�=� � 1� � � /� 0��*�B�l�.@�b�B� ��T�?� �?��?�?�� s �A� r r' r r r r8 r r r )r( rF s ` r �_wrap_sync_serverrH f sl �� � �4�[� DH� @��v�v� @� �x��(>�(>� ?�@� @� �(�(� @� � @� � @� �r c � � � t � � dd�dt j dt t t j dt j dt f� fd�� }|S )z Wrapper for asynchronous server.Nr; r r2 r r) c � �� t � }|g| xs g �} t �t dk r t | � } �|d| i|��S # t $ r Y �w xY w)N)r �* r r2 )�AsyncServerInterceptor� GRPC_VERSIONr4 � Exception)r2 r r rE r( s �r �patched_aio_serverz._wrap_async_server.<locals>.patched_aio_server~ sn �� � 4� 5�� � �� �b� � � � �'�L�:�,E� $�\� 2� � �T�?� �?��?�?�� � � � �s �: � A�ArG )r( rO s ` r �_wrap_async_serverrP { sl �� � �4�[� DH�@��v�v�@� �x��(>�(>� ?�@�@� �(�(�@� � @� �@�. � r c �" � e Zd ZdZedd�� Zy)�GRPCIntegrationr8 Nc �� � dd l } t | j � | _ t | j � | _ t | j � | _ t | j j � | j _ t | j j � | j _ t | j � | _ t | j j � | j _ y )Nr ) r8 r0 �insecure_channel�secure_channelr9 r rB rA rH �serverrP )r8 s r � setup_oncezGRPCIntegration.setup_once� s� � �� 2�4�3H�3H� I�� � 0��1D�1D� E���!8��9O�9O�!P�� �$7����8Q�8Q�$R����!�"5�d�h�h�6M�6M�"N���� �'�� � �4�� �,�T�X�X�_�_�=����r )r) N)r r r! � identifier� staticmethodrW r" r r rR rR � s � ��J�� >� � >r rR ))� functoolsr r8 r r r �grpc.aio� AsyncChannel� AsyncServer�sentry_sdk.integrationsr �sentry_sdk.utilsr �clientr rV r � aio.serverrL � aio.clientr r> r r? �typingr r r r r r r$ r' � __version__rM r0 r9 rB rH rP rR r" r r �<module>re s> �� � � 3� 3� ,� *� /� *� %� %� C��� :� 9� �*�*� � � � � �{�H� �c�N�� �T� -� -�.� � �X�a��j� 1� �h�q�'�z�6J� � %�(�1�g�:�"6� %�8�A�w�J�;O� %�(�h�q�,�� 7� �H�Q� �_�<U� �&�H�Q��Y� /� �H�Q��Y�4G� �* �X�a��n� 5� �(�1�k�>�:R� �<>�k� >r
[-] server.cpython-312.pyc
[edit]
[+]
..
[-] consts.cpython-312.pyc
[edit]
[-] __init__.cpython-312.pyc
[edit]
[-] client.cpython-312.pyc
[edit]