4Yѓn J d Z ddlmZ ddlZddlZddlmZmZ ddlm Z ej
d Z ej
d Z ej
d Z
ej
d Z ej
d
Z ej
d Z ej
d Zd
ZdZdZdZdZdZdZdZdZdZdZ dZ dZ dZ ee z Z ee z Z!ee z Z" e#e Z$ e#e Z% e#e! Z& e#e" Z' e#e Z( e#e Z)dZ*d Z+d Z,d Z-d Z.d Z/ G d! d" Z0 G d# d$e Z1dS )%z
NATS network protocol parser.
) annotationsN)AnyDict)
ProtocolErrors8 \AMSG\s+([^\s]+)\s+([^\s]+)\s+(([^\s]+)[^\S
]+)?(\d+)
sC \AHMSG\s+([^\s]+)\s+([^\s]+)\s+(([^\s]+)[^\S
]+)?([\d]+)\s+(\d+)
s \A\+OK\s*
s \A-ERR\s+('.+')?
s \APING\s*
s \APONG\s*
s \AINFO\s+([^
]+)
s INFOs CONNECTs PUBs MSGs HMSGs SUBs UNSUBs PINGs PONGs +OKs -ERR
s
i zstale connectionzauthorization violationzpermissions violationc 2 e Zd Zd d
dZddZd
dZddd ZdS )ParserNreturnNonec < || _ | d S N)ncreset)selfr s t/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/nats/protocol/parser.py__init__zParser.__init__G s
strc d| j dS )Nz )stater s r __repr__zParser.__repr__K s ;dj;;;;r c n t | _ t | _ d| _ d| _ i | _ d S )Nr ) bytearraybufAWAITING_CONTROL_LINEr needed
header_neededmsg_argr s r r z Parser.resetN s. ;;*
') r r databytesc N K | j | | j r| j t k r't | j }|r | \ }}}}}|| j d< t | | j d< |r || j d< n
d| j d< t | | _ | j d|
= t | _ # t $ r t d w xY wt | j }|r | \ }}}}}}|| j d< t | | j d< |r || j d< n
d| j d< t | | _ t | | _ | j d|
= t | _ # t $ r t d w xY wt | j } | r | j d|
=
t" | j }
|
r~|
} | d } | j | d{V | j d|
= t, | j }
|
r=| j d|
= | j d{V t0 | j }|r=| j d|
= | j d{V et4 | j }|r~| d }t7 j | }| j | d{V | j d|
= t= | j t> k r t@ | j v rt d dS | j t k r-t= | j | j tB z k rd}| j d }| j d }| j d }| j dk rhtE | j d| j }tE | j | j | j }|}| j d| j tB z = d| _ n8tE | j d| j }| j d| j tB z = t | _ | j # ||||| d{V ndS | j ~dS dS ) zv
Parses the wire protocol from NATS for the client
and dispatches the subscription callbacks.
subjectsidreplyr Nznats: malformed MSGr znats: unknown protocol)$r extendr r MSG_REmatchgroupsr# intr! endAWAITING_MSG_PAYLOAD Exceptionr HMSG_REr" OK_REERR_REdecodelowerr _process_errPING_RE
_process_pingPONG_RE
_process_pongINFO_REjsonloads
_process_infolenMAX_CONTROL_LINE_SIZE_CRLF_ CRLF_SIZEr% _process_msg)r r$ msgr' r( _r) needed_bytes header_sizeokerrerr_msgemsgpingponginfo info_linesrv_infohdrhbufpayloads r parsez Parser.parseU s
h i z 222 ll48,, C
C?Bzz||<a 29 Y/.1#hh U+ 849DL 1 147DL 1&),&7&7 H[swwyy[ 1%9
$ C C C +,A B BBC mmDH-- CCLOJJLLIa \29 Y/.1#hh U+ 849DL 1 147DL 1&),&7&7 -0-=-=* H[swwyy[ 1%9
$ C C C +,A B BBC [[** 26688, ll48,, !jjllG"1:,,..4466D '..t444444444 37799- }}TX.. 488:: . '//111111111 }}TX.. 488:: . '//111111111 }}TX.. $
a 0I #z)*:*:*<*< = =H '//999999999 488:: . tx==#888Vtx=O=O ((@AAA E 333tx==DK)$;;; C "l9 5G ,u-C L 1E )A-- $TX.B0B.B%C D D"'1Cdk1Q(R"S"S " H%>t{Y'>%> ?-.**"' 4; (?"@"@ H%>t{Y'>%> ?!6DJ '..sGUGSQQQQQQQQQQ ES h i i i i i s BC' 'D&B#G G%r )r
r r
r )r )r$ r% )__name__
__module__ __qualname__r r r rU r r r r F su < < < <* * * *o o o o o o or r c e Zd ZdZddZdS ) ErrProtocolz
.. deprecated:: v2.0.0
r
r c dS )Nznats: Protocol ErrorrZ r s r __str__zErrProtocol.__str__ s %%r NrV )rW rX rY __doc__r^ rZ r r r\ r\ s2 & & & & & &r r\ )2r_
__future__r r= retypingr r nats.errorsr compiler+ r2 r3 r4 r8 r: r< INFO_OP
CONNECT_OPPUB_OPMSG_OPHMSG_OPSUB_OPUNSUB_OPPING_OPPONG_OPOK_OPERR_OPMSG_ENDrB _SPC_OKPINGPONGr@ rC OK_SIZE PING_SIZE PONG_SIZE MSG_OP_SIZE ERR_OP_SIZEr r0 rA STALE_CONNECTIONAUTHORIZATION_VIOLATIONPERMISSIONS_ERRr r\ rZ r r r} s # " " " " " % % % % % % \ ] ]
"*j
k
k
&'' - . .
"*'
(
(
"*'
(
(
"*1
2
2
V^ CKK
#b'' CII CII c&kk c&kk & 3 )~ ~ ~ ~ ~ ~ ~ ~B& & & & &- & & & & &r