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 AwaitableCallableDictOptional)MsgzNats-Service-ErrorzNats-Service-Error-Codec e Zd ZU ded< ddZedd Zedd
Zedd ZdddZ dddZ
dS ) Requestr
_msgmsgreturnNonec " || _ 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
subjectr 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 )zSend a response to the request.
:param data: The response data.
:param headers: Additional response headers.
zno reply subject setr N)r
reply
ValueError_clientpublish)r r! r s r respondzRequest.respond0 sz y 5 344 4i '' IO (
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)copyupdate ERROR_HEADERERROR_CODE_HEADERr( )r r) r* r! r s r
respond_errorzRequest.respond_error? sy llnnGGG k!4
ll4l11111111111r )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
III ! ! ! X! ! ! ! X! X
& ,0 2 2 2 2 2 2 2r r Nc L e Zd ZU ded< ded< d dZd dZed
d Zd
S ) ServiceErrorr r) r* r c $ | j d| j S )N:r) r* r s r __repr__zServiceError.__repr__e s )00d .000r Dict[str, Any]c | j | j dS )Nr< r< r s r to_dictzServiceError.to_dicth s $2BCCCr r! c l | | dd | dd S )Nr) r* r< )get)clsr! s r from_dictzServiceError.from_dictk s4 s,,$((=RT:U:UVVVVr Nr1 )r r> )r! r> r r9 )r2 r3 r4 r5 r= r@ classmethodrE r7 r r r9 r9 ` s}
III1 1 1 1D 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 rM s # " " " " " ! ! ! ! ! ! ; ; ; ; ; ; ; ; ; ; ; ; ; ; # - ?2 ?2 ?2 ?2 ?2 ?2 ?2 ?2D G9io-
. = W W W W W9 W W W W Wr