📁 File Manager Pro
v10.0.2 | PHP: 8.1.34
Server: LiteSpeed
2026-06-27 19:38:34
📂
/
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
grpc
/
aio
/
__pycache__
✏️
Editing: server.cpython-312.pyc
� Yr*j. � � � d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl m Z d dl m Z d dl mZ erd d lmZmZ d d l mZmZ d dlZd d lmZmZ d d lmZmZ G d� dej6 j8 � Z y# e$ r ed � �w xY w)� )� TYPE_CHECKINGN)�OP)� DidNotEnable)� SPAN_ORIGIN)�TransactionSource)�has_span_streaming_enabled)�event_from_exception)� Awaitable�Callable)�Any�Optional)�HandlerCallDetails�RpcMethodHandler)� AbortError�ServicerContextzgrpcio is not installedc �F � � e Zd Z d d� fd� Z dd�Z� xZS )�ServerInterceptorc �0 �� || _ t �| � � y �N)�_custom_find_name�super�__init__)�self� find_name� __class__s ��V/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/grpc/aio/server.pyr zServerInterceptor.__init__ s �� � "+�� � ���� c � �" ���K � ||� � d { ��� ���y |j �| j ��j s%�j st j }d���fd� }n��j s#�j rt j }d�fd� }n]�j r#�j st j }d�fd� }n.�j r"�j rt j }d�fd� } �j �j �� S 7 ���w)Nc � �� �K � t j � 5 �r �|� n� }|s � | |� � d { ��� cd d d � S t t j � j � }|r�t j j t |j � � � t j j |t j t j j t d�d �� 5 � j! | |� � d { ��� cd d d � cd d d � S t j t |j � � t j |t j t �� }t j* |� � 5 � j! | |� � d { ��� cd d d � cd d d � S 7 ���7 ��# t" $ r � t$ $ r0}t' |ddd��� \ }}t j( ||�� � d }~ww xY w# 1 sw Y nVxY w7 �l# t" $ r � t$ $ r0}t' |ddd��� \ }}t j( ||�� � d }~ww xY w# 1 sw Y nxY wd d d � y # 1 sw Y y xY w�w) N)z sentry.opzsentry.span.sourcez sentry.origin)�name� attributes� parent_span�grpcF)�type�handled)� mechanism)�hint)�opr �source�origin)� transaction)� sentry_sdk�isolation_scoper � get_client�options�traces�continue_trace�dict�invocation_metadata� start_spanr � GRPC_SERVERr �CUSTOM�valuer � unary_unaryr � Exceptionr � capture_event�start_transaction) �request�contextr �span_streaming�exc�eventr' r+ �custom_find_name�handler� method_names ���r �wrappedz4ServerInterceptor.intercept_service.<locals>.wrapped0 s- �� �� � �/�/�1�5E�(��1�;� � �%,�W�g�%>� >� 2�1� &@�"�-�-�/�7�7�&�N� &�"�)�)�8�8� ��!<�!<�!>� ?�� (� .� .� 9� 9�!%�-/�^�^�6G�6N�6N�6T�6T�1<�( � )-� :� � &�-4�-@�-@��'�-R�'R� � �! 2�1�L '1�&?�&?� ��!<�!<�!>� ?� !�~�~�!%�#4�#;�#;�#.� '� � (� 9� 9�k� R� &�-4�-@�-@��'�-R�'R� S� R�] 2�1� ?��* (S��#-� &� %�#,� &�.B�$'�7=�%�.P�/"� ��t� !+� 8� 8��T� J� %�� &�� � ��@ (S��#-� &� %�#,� &�.B�$'�7=�%�.P�/"� ��t� !+� 8� 8��T� J� %�� &�� S� R��] 2�1�1�s� �I1�I%�F3�I%� I1�B/I%�0G=�2F8�F6�F8� I%� I1� A'I%�I�H � H � H � I%�) I1�3I%�6F8�8G:� +G5�5G:�:G=�=H �I%� H � I � +I�I � I�I �I%� I1�%I.�*I1c �V �K � �j | |� 2 3 d { ��� }|��� �7 � 6 y �wr )� unary_stream�r< r= �rrB s �r rD z4ServerInterceptor.intercept_service.<locals>.wrappedo s, �� �� � &� 3� 3�G�W� E� �!��G� �� E�� �)�'�%�'�)�'�)c � �H �K � �j | |� }|� d { ��� S 7 ��wr )� stream_unary)r< r= �responserB s �r rD z4ServerInterceptor.intercept_service.<locals>.wrappedv s# �� �� �"�/�/���A�� %�~�%�~�s �"� �"c �V �K � �j | |� 2 3 d { ��� }|��� �7 � 6 y �wr )� stream_streamrG s �r rD z4ServerInterceptor.intercept_service.<locals>.wrapped} s, �� �� � &� 4� 4�W�g� F� �!��G� �� F�rI )�request_deserializer�response_serializer)r< r r= r �returnr ) �methodr �request_streaming�response_streamingr# � unary_unary_rpc_method_handler� unary_stream_rpc_method_handler� stream_unary_rpc_method_handler� stream_stream_rpc_method_handlerrO rP )r � continuation�handler_call_details�handler_factoryrD rA rB rC s @@@r �intercept_servicez#ServerInterceptor.intercept_service! s� �� �� � %�%9�:�:�� �?��*�1�1� � �1�1���(�(��1K�1K� "� A� A�O�: &� : &�x �*�*�w�/I�/I� "� B� B�O� � � &� &�w�/I�/I� "� B� B�O� &� � &� &�7�+E�+E� "� C� C�O� � � �!(�!=�!=� '� ;� ;� � �w ;�s � D�D �C<Dr )r r r z'Callable[[ServicerContext], str] | NonerQ N)r r rY z;Callable[[HandlerCallDetails], Awaitable[RpcMethodHandler]]rZ r rQ z%Optional[Awaitable[RpcMethodHandler]])�__name__� __module__� __qualname__r r\ � __classcell__)r s @r r r sW �� � @D��!��<�� ��d �!�d �S�d � 3�d � 1� d r r ) �typingr r, �sentry_sdk.constsr �sentry_sdk.integrationsr �#sentry_sdk.integrations.grpc.constsr �sentry_sdk.tracingr �sentry_sdk.tracing_utilsr �sentry_sdk.utilsr �collections.abcr r r r r# r r �grpc.aior r � ImportError�aior � r r �<module>rm si �� � � � 0� ;� 0� ?� 1��3�$�2��9�4� m ����2�2� m �� � 2� �0� 1�1�2�s �A6 �6B
💾 Save Changes
❌ Cancel