__ __ __ __ _____ _ _ _____ _ _ _
| \/ | \ \ / / | __ \ (_) | | / ____| | | | |
| \ / |_ __\ V / | |__) | __ ___ ____ _| |_ ___ | (___ | |__ ___| | |
| |\/| | '__|> < | ___/ '__| \ \ / / _` | __/ _ \ \___ \| '_ \ / _ \ | |
| | | | |_ / . \ | | | | | |\ V / (_| | || __/ ____) | | | | __/ | |
|_| |_|_(_)_/ \_\ |_| |_| |_| \_/ \__,_|\__\___| |_____/|_| |_|\___V 2.1
if you need WebShell for Seo everyday contact me on Telegram
Telegram Address : @jackleet
For_More_Tools:
�
1̟��� � � d dl mZ d dlmZ d dlmZmZmZmZm Z d dl
m Z dZ dZ
G d� d� � Zeeged f Z e G d
� d e� � � � Zd S ) � )� annotations)� dataclass)�Any� Awaitable�Callable�Dict�Optional)�MsgzNats-Service-ErrorzNats-Service-Error-Codec � � e Zd ZU ded< dd�Zedd�� � Zedd
�� � Zedd �� � Zddd�Z ddd�Z
dS ) �Requestr
�_msg�msg�return�Nonec �" � || _ d | _ d S )N)r
�_error)�selfr s �r/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/micro/request.py�__init__zRequest.__init__ s � ��� ��� � � � �strc � � | j j S )z*The subject on which request was received.)r
�subject�r s r r zRequest.subject! � � � �y� � r �Optional[Dict[str, str]]c � � | j j S )zThe headers of the request.)r
�headersr s r r zRequest.headers& r r �bytesc � � | j j S )zThe data of the request.)r
�datar s r r! z Request.data+ s � � �y�~� r r Nr! r c � � K � | j j st d� � �| j j � | j j ||�� � � d{V �� dS )z�Send a response to the request.
:param data: The response data.
:param headers: Additional response headers.
zno reply subject set�r N)r
�reply�
ValueError�_client�publish)r r! r s r �respondzRequest.respond0 sz � � � � �y�� 5� � 3�4�4� 4��i� �'�'� �I�O� �� (�
�
�
�
�
�
�
�
�
�
�
r �code� descriptionc � � K � |r|� � � }ni }|� t |t |i� � | � ||�� � � d{V �� dS )a$ Send an error response to the request.
:param code: The error code describing the error.
:param description: A string describing the error which can be displayed to the client.
:param data: The error data.
:param headers: Additional response headers.
r# N)�copy�update� ERROR_HEADER�ERROR_CODE_HEADERr( )r r) r* r! r s r �
respond_errorzRequest.respond_error? sy � � � � � � �l�l�n�n�G�G��G���� �k�!�4�
�
�
�
� �l�l�4��l�1�1�1�1�1�1�1�1�1�1�1r )r r
r r �r r )r r )r r )r N)r! r r r r r )
r) r r* r r! r r r r r ) �__name__�
__module__� __qualname__�__annotations__r �propertyr r r! r( r0 � r r r r s� � � � � � � �
�I�I�I�� � � � �!� !� !� �X�!� �!� !� !� �X�!� � � � � �X� �
�
�
�
�
�& �,0� 2� 2� 2� 2� 2� 2� 2r r Nc �L � e Zd ZU ded< ded< d d�Zd d�Zed
d �� � Zd
S )� ServiceErrorr r) r* r c �$ � | j � d| j � �S )N�:�r) r* r s r �__repr__zServiceError.__repr__e s � ��)�0�0�d� .�0�0�0r �Dict[str, Any]c � � | j | j d�S )Nr< r< r s r �to_dictzServiceError.to_dicth s � � � �$�2B�C�C�Cr r! c �l � | |� dd� � |� dd� � �� � S )Nr) � r* r< )�get)�clsr! s r � from_dictzServiceError.from_dictk s4 � ��s������,�,�$�(�(�=�RT�:U�:U�V�V�V�Vr Nr1 )r r> )r! r> r r9 )r2 r3 r4 r5 r= r@ � classmethodrE r7 r r r9 r9 ` s} � � � � � � �
�I�I�I�����1� 1� 1� 1�D� D� D� D� �W� W� W� �[�W� W� Wr r9 )�
__future__r � dataclassesr �typingr r r r r � nats.aio.msgr
r. r/ r �Handler� Exceptionr9 r7 r r �<module>rM s� �� #� "� "� "� "� "� !� !� !� !� !� !� ;� ;� ;� ;� ;� ;� ;� ;� ;� ;� ;� ;� ;� ;� � � � � � �#� �-� �?2� ?2� ?2� ?2� ?2� ?2� ?2� ?2�D �G�9�i��o�-�
.�� =� � W� W� W� W� W�9� W� W� �� W� W� Wr